- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 168 for interfaces (0.19 sec)
-
cmd/peer-s3-client.go
"github.com/minio/minio/internal/grid" "github.com/minio/pkg/v2/sync/errgroup" "golang.org/x/exp/slices" ) var errPeerOffline = errors.New("peer is offline") type peerS3Client interface { ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error) HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
cmd/tier.go
binary.LittleEndian.PutUint16(data[2:4], tierConfigVersion) // Marshal the tier config return config.MarshalMsg(data) } // getDriver returns a warmBackend interface object initialized with remote tier config matching tierName func (config *TierConfigMgr) getDriver(ctx context.Context, tierName string) (d WarmBackend, err error) { config.Lock() defer config.Unlock() var ok bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
internal/logger/reqinfo.go
func (r *ReqInfo) GetTagsMap() map[string]interface{} { if r == nil { return nil } r.RLock() defer r.RUnlock() m := make(map[string]interface{}, len(r.tags)) for _, t := range r.tags { m[t.Key] = t.Val } return m } // PopulateTagsMap - returns the user defined tags in a map structure func (r *ReqInfo) PopulateTagsMap(tagsMap map[string]interface{}) { if r == nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/encryption-v1.go
return nil, err } return objectKey[:], nil default: return nil, errObjectTampered } } // Adding support for reader based interface // DecryptRequestWithSequenceNumberR - same as // DecryptRequestWithSequenceNumber but with a reader
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
internal/http/check_port_linux.go
Control: func(network, address string, c syscall.RawConn) error { c.Control(func(fdPtr uintptr) { if opts.Interface != "" { // When interface is specified look for specifically port availability on // the specified interface if any. _ = syscall.SetsockoptString(int(fdPtr), syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, opts.Interface) } }) return nil }, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.9K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
return err } defer res.Body.Close() var v map[string]interface{} found := false if err := json.NewDecoder(res.Body).Decode(&v); err != nil { return fmt.Errorf("Error parsing response body: %v", err) } indices, ok := v["indices"].([]interface{}) if ok { for _, index := range indices { name := index.(map[string]interface{})["name"] if name == args.Index { found = true break
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
cmd/consolelogger.go
func (sys *HTTPConsoleLoggerSys) Init(_ context.Context) error { return nil } // Endpoint - dummy function for interface compatibility func (sys *HTTPConsoleLoggerSys) Endpoint() string { return sys.console.Endpoint() } // String - stringer function for interface compatibility func (sys *HTTPConsoleLoggerSys) String() string { return logger.ConsoleLoggerTgt }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/storage-rest-server.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
internal/http/listener.go
RecvBufSize int // SO_RECVBUF size for the socket connection, NOTE: this sets server and client connection Interface string // This is a VRF device passed via `--interface` flag Trace func(msg string) // Trace when starting. } // newHTTPListener - creates new httpListener object which is interface compatible to net.Listener. // httpListener is capable to // * listen to multiple addresses
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/config/identity/openid/jwt_test.go
"github.com/minio/minio/internal/config" jwtm "github.com/minio/minio/internal/jwt" xnet "github.com/minio/pkg/v2/net" ) func TestUpdateClaimsExpiry(t *testing.T) { testCases := []struct { exp interface{} dsecs string expectedFailure bool }{ {"", "", true}, {"-1", "0", true}, {"-1", "900", true}, {"1574812326", "900", false}, {1574812326, "900", false},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.3K bytes - Viewed (0)