- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Wagner (0.27 sec)
-
internal/hash/reader.go
func (r *Reader) ActualSize() int64 { return r.actualSize } // ETag returns the ETag computed by an underlying etag.Tagger. // If the underlying io.Reader does not implement etag.Tagger // it returns nil. func (r *Reader) ETag() etag.ETag { if t, ok := r.src.(etag.Tagger); ok { return t.ETag() } return nil } // MD5Current returns the MD5 checksum of the content
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.8K bytes - Viewed (0) -
cmd/metacache-server-pool.go
// skip latest object from listing only for regular // listObjects calls, versioned based listing cannot // filter out between versions 'obj' cannot be truncated // in such a manner, so look for skipping an object only // for regular ListObjects() call only. if !o.Versioned && !o.V1 { fi, err := obj.fileInfo(o.Bucket) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
internal/jwt/parser.go
} if err = claims.UnmarshalJSON(buf[:n]); err != nil { return nil, &jwtgo.ValidationError{Inner: err, Errors: jwtgo.ValidationErrorMalformed} } for _, signer := range hmacSigners { if string(alg) == signer.Name { return signer, nil } } return nil, jwtgo.NewValidationError(fmt.Sprintf("signing method (%s) is unavailable.", string(alg)), jwtgo.ValidationErrorUnverifiable) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 09 07:53:08 GMT 2023 - 13.9K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
// the token is generated by kubectl under the workload group's namespace and service account // TODO: Make the following accurate when using the Kubernetes certificate signer func createCertsTokens(kubeClient kube.CLIClient, wg *clientv1alpha3.WorkloadGroup, dir string, out io.Writer) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
internal/etag/etag_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package etag import ( "context" "io" "net/http" "strings" "testing" ) var _ Tagger = Wrap(nil, nil).(Tagger) // runtime check that wrapReader implements Tagger var parseTests = []struct { String string ETag ETag ShouldFail bool }{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 12.6K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
{serverType: "ErasureSD", signer: signerV4}, // Init and run test on ErasureSD backend, with tls enabled. {serverType: "ErasureSD", signer: signerV4, secure: true}, // Init and run test on Erasure backend. {serverType: "Erasure", signer: signerV4}, // Init and run test on ErasureSet backend. {serverType: "ErasureSet", signer: signerV4}, } testCases := []*TestSuiteIAM{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 16:36:16 GMT 2024 - 45.7K bytes - Viewed (0) -
operator/cmd/mesh/install.go
// create normalized tags for multiple control plane revisions for _, icp := range *icps { if icp.Revision != revision { continue } tagVer, err := GetTagVersion(icp.Info.GitTag) if err != nil { return err } icpTags = append(icpTags, tagVer) } // sort different versions of control plane revisions sort.Strings(icpTags) // capture latest revision installed for comparison
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1) -
internal/etag/etag.go
// } // ETag = ETag.Format() func (e ETag) Format() ETag { if !e.IsEncrypted() { return e } return e[len(e)-16:] } var _ Tagger = ETag{} // compiler check // ETag returns the ETag itself. // // By providing this method ETag implements // the Tagger interface. func (e ETag) ETag() ETag { return e } // FromContentMD5 decodes and returns the Content-MD5
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 13.3K bytes - Viewed (0) -
cmd/server-main.go
} if !globalEndpoints.HTTPS() && globalIsTLS { logger.Fatal(config.ErrCertsAndHTTPEndpoints(nil), "Unable to start the server") } } // Check for updates in non-blocking manner. go func() { if !globalServerCtxt.Quiet && !globalInplaceUpdateDisabled { // Check for new updates from dl.min.io. bootstrapTrace("checkUpdate", func() { checkUpdate(getMinioMode()) }) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (2) -
cmd/notification.go
func (sys *NotificationSys) VerifyBinary(ctx context.Context, u *url.URL, sha256Sum []byte, releaseInfo string, bin []byte) []NotificationPeerErr { // FIXME: network calls made in this manner such as one goroutine per node, // can easily eat into the internode bandwidth. This function would be mostly // TX saturating, however there are situations where a RX might also saturate.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0)