- Sort Score
- Result 10 results
- Languages All
Results 511 - 520 of 1,950 for func (0.12 sec)
-
internal/bucket/versioning/versioning.go
default: return Errorf("unsupported Versioning status %s", v.Status) } return nil } // Enabled - returns true if versioning is enabled func (v Versioning) Enabled() bool { return v.Status == Enabled } // Versioned returns if 'prefix' has versioning enabled or suspended. func (v Versioning) Versioned(prefix string) bool { return v.PrefixEnabled(prefix) || v.PrefixSuspended(prefix) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
internal/jwt/parser_test.go
) var ( defaultKeyFunc = func(claim *MapClaims) ([]byte, error) { return []byte("HelloSecret"), nil } emptyKeyFunc = func(claim *MapClaims) ([]byte, error) { return nil, nil } errorKeyFunc = func(claim *MapClaims) ([]byte, error) { return nil, fmt.Errorf("error loading key") } ) var jwtTestData = []struct { name string tokenString string keyfunc func(*MapClaims) ([]byte, error) claims jwt.Claims
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Nov 05 19:20:08 UTC 2021 - 6K bytes - Viewed (0) -
cmd/streaming-v4-unsigned.go
reader *bufio.Reader trailers http.Header buffer []byte offset int err error debug bool } func (cr *s3UnsignedChunkedReader) Close() (err error) { return cr.err } // Read - implements `io.Reader`, which transparently decodes // the incoming AWS Signature V4 streaming signature. func (cr *s3UnsignedChunkedReader) Read(buf []byte) (n int, err error) { // First, if there is any unread data, copy it to the client
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat May 06 02:53:12 UTC 2023 - 6.1K bytes - Viewed (0) -
internal/bucket/versioning/versioning_test.go
t.Fatalf("XML shouldn't contain ExcludedPrefixes tag - %s", str) } } func TestVersioningZero(t *testing.T) { var v Versioning if v.Enabled() { t.Fatalf("Expected to be disabled but got enabled") } if v.Suspended() { t.Fatalf("Expected to be disabled but got suspended") } } func TestExcludeFolders(t *testing.T) { v := Versioning{ Status: Enabled,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun May 08 05:06:44 UTC 2022 - 8.8K bytes - Viewed (0) -
internal/http/request-recorder.go
buf bytes.Buffer // total bytes read including header size bytesRead int } // Close is a no operation closer func (r *RequestRecorder) Close() error { // no-op return nil } // Read reads from the internal reader and counts/save the body in the memory func (r *RequestRecorder) Read(p []byte) (n int, err error) { n, err = r.Reader.Read(p) r.bytesRead += n if r.LogBody { r.buf.Write(p[:n])
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Apr 12 21:37:19 UTC 2023 - 1.8K bytes - Viewed (0) -
internal/event/arn.go
type ARN struct { TargetID region string } // String - returns string representation. func (arn ARN) String() string { if arn.TargetID.ID == "" && arn.TargetID.Name == "" && arn.region == "" { return "" } return "arn:minio:sqs:" + arn.region + ":" + arn.TargetID.String() } // MarshalXML - encodes to XML data. func (arn ARN) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 2.1K bytes - Viewed (0) -
internal/bucket/replication/sourceselectioncriteria.go
} // IsValid - checks whether SourceSelectionCriteria is valid or not. func (s SourceSelectionCriteria) IsValid() bool { return s.ReplicaModifications.Status == Enabled || s.ReplicaModifications.Status == Disabled } // Validate source selection criteria func (s SourceSelectionCriteria) Validate() error { if (s == SourceSelectionCriteria{}) { return nil } if !s.IsValid() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 2.5K bytes - Viewed (0) -
tests/table_test.go
gorm.Model Name string } func (UserWithTableNamer) TableName(namer schema.Namer) string { return namer.TableName("user") } func TestTableWithNamer(t *testing.T) { db, _ := gorm.Open(tests.DummyDialector{}, &gorm.Config{ NamingStrategy: schema.NamingStrategy{ TablePrefix: "t_", }, }) sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Sat Mar 09 09:31:28 UTC 2024 - 10.6K bytes - Viewed (0) -
src/cmd/asm/internal/asm/operand_test.go
// // For unexpected panics, calls t.Fatal. func tryParse(t *testing.T, parse func()) (err error) { panicOnError = true defer func() { panicOnError = false e := recover() var ok bool if err, ok = e.(error); e != nil && !ok { t.Fatal(e) } }() parse() return nil } func testBadOperandParser(t *testing.T, parser *Parser, tests []badOperandTest) { for _, test := range tests {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Aug 29 18:31:05 UTC 2023 - 23.9K bytes - Viewed (0) -
cmd/admin-handlers-idp-config.go
// // POST <admin-prefix>/idp-cfg/openid/_ -> update (default) named config `_` func (a adminAPIHandlers) UpdateIdentityProviderCfg(w http.ResponseWriter, r *http.Request) { ctx := r.Context() addOrUpdateIDPHandler(ctx, w, r, true) } // ListIdentityProviderCfg: // // GET <admin-prefix>/idp-cfg/openid -> lists openid provider configs. func (a adminAPIHandlers) ListIdentityProviderCfg(w http.ResponseWriter, r *http.Request) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.7K bytes - Viewed (0)