- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 168 for interfaces (0.14 sec)
-
cmd/bucket-lifecycle-audit.go
lcEventSrc_s3CopyObject lcEventSrc_s3CompleteMultipartUpload ) //revive:enable:var-naming type lcAuditEvent struct { lifecycle.Event source lcEventSrc } func (lae lcAuditEvent) Tags() map[string]interface{} { event := lae.Event src := lae.source const ( ilmSrc = "ilm-src" ilmAction = "ilm-action" ilmDue = "ilm-due"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 01 15:56:24 GMT 2023 - 2.6K bytes - Viewed (0) -
docs/iam/access-manager-plugin.go
var out bytes.Buffer json.Indent(&out, body, "", " ") fmt.Printf("Received JSON payload:\n%s\n", out.String()) reqMap := make(map[string]interface{}) err = json.Unmarshal(body, &reqMap) if err != nil { writeErrorResponse(w, err) return } m := reqMap["input"].(map[string]interface{}) accountValue := m["account"].(string) actionValue := m["action"].(string) // Allow user `minio` to perform any action.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 08 17:15:20 GMT 2024 - 2.7K bytes - Viewed (0) -
internal/event/targetlist.go
maxConcurrentAsyncSend = 50000 ) // Target - event target interface type Target interface { ID() TargetID IsActive() (bool, error) Save(Event) error SendFromStore(store.Key) error Close() error Store() TargetStore } // TargetStore is a shallow version of a target.Store type TargetStore interface { Len() int } // Stats is a collection of stats for multiple targets.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
internal/kms/kms.go
package kms import ( "context" "encoding" "encoding/json" jsoniter "github.com/json-iterator/go" "github.com/minio/kms-go/kes" ) // KMS is the generic interface that abstracts over // different KMS implementations. type KMS interface { // Stat returns the current KMS status. Stat(cxt context.Context) (Status, error) // IsLocal returns true if the KMS is a local implementation IsLocal() bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/s3select/sql/value_test.go
if got := vAlt.CSVString(); got != tt.wantAlt { t.Errorf("CSVString() = %v, want %v", got, tt.wantAlt) } }) } } func TestValue_bytesToInt(t *testing.T) { type fields struct { value interface{} } tests := []struct { name string fields fields want int64 wantOK bool }{ { name: "zero", fields: fields{ value: []byte("0"), }, want: 0,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 12.5K bytes - Viewed (0) -
internal/grid/msg.go
func (m *message) setZeroPayloadFlag() { m.Flags &^= FlagPayloadIsZero if len(m.Payload) == 0 && m.Payload != nil { m.Flags |= FlagPayloadIsZero } } type receiver interface { msgp.Unmarshaler Op() Op } type sender interface { msgp.MarshalSizer Op() Op } type connectReq struct { ID [16]byte Host string } func (connectReq) Op() Op { return OpConnect }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0) -
internal/logger/message/audit/entry.go
DeploymentID: deploymentID, Time: time.Now().UTC(), } } // ToEntry - constructs an audit entry from a http request func ToEntry(w http.ResponseWriter, r *http.Request, reqClaims map[string]interface{}, deploymentID string) audit.Entry { entry := NewEntry(deploymentID) entry.RemoteHost = handlers.GetSourceIP(r) entry.UserAgent = r.UserAgent() entry.ReqClaims = reqClaims entry.ReqHost = r.Host
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.2K bytes - Viewed (0) -
cmd/os_unix.go
// By default at least 128 entries in single getdents call (1MiB buffer) var ( direntPool = sync.Pool{ New: func() interface{} { buf := make([]byte, blockSize*128) return &buf }, } direntNamePool = sync.Pool{ New: func() interface{} { buf := make([]byte, blockSize) return &buf }, } ) // unexpectedFileMode is a sentinel (and bogus) os.FileMode
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/store/batch.go
package store import ( "errors" "fmt" "sync" ) // ErrBatchFull indicates that the batch is full var ErrBatchFull = errors.New("batch is full") type key interface { string | int | int64 } // Batch represents an ordered batch type Batch[K key, T any] struct { keys []K items map[K]T limit uint32 sync.Mutex } // Add adds the item to the batch
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 2.5K bytes - Viewed (0) -
internal/logger/target/testlogger/testlogger.go
func (t *testLogger) IsOnline(ctx context.Context) bool { return t.current.Load() != nil } func (t *testLogger) Cancel() { t.current.Store(nil) } func (t *testLogger) Send(ctx context.Context, entry interface{}) error { tb := t.current.Load() var logf func(format string, args ...any) if tb != nil { tbb := *tb tbb.Helper() switch t.action.Load() { case errorMessage: logf = tbb.Errorf
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 4K bytes - Viewed (0)