- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 95 for interfaces (0.14 sec)
-
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) -
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) -
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) -
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) -
internal/config/identity/openid/providercfg.go
"github.com/minio/minio/internal/config/identity/openid/provider" xhttp "github.com/minio/minio/internal/http" xnet "github.com/minio/pkg/v2/net" ) type providerCfg struct { // Used for user interface like console DisplayName string JWKS struct { URL *xnet.URL } URL *xnet.URL ClaimPrefix string ClaimName string ClaimUserinfo bool RedirectURI string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/dsync/locker.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync import "context" // NetLocker is dsync compatible locker interface. type NetLocker interface { // Do read lock for given LockArgs. It should return // * a boolean to indicate success/failure of the operation // * an error on failure of lock request operation.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 18 20:44:38 GMT 2022 - 2.7K bytes - Viewed (0) -
internal/s3select/simdj/reader_amd64_test.go
"testing" "github.com/klauspost/compress/zstd" "github.com/minio/minio/internal/s3select/json" "github.com/minio/minio/internal/s3select/sql" "github.com/minio/simdjson-go" ) type tester interface { Fatal(args ...interface{}) } func loadCompressed(t tester, file string) (js []byte) { dec, err := zstd.NewReader(nil) if err != nil { t.Fatal(err) } defer dec.Close()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.9K bytes - Viewed (0) -
cmd/namespace-lock.go
"github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/lsync" ) // local lock servers var globalLockServer *localLocker // RWLocker - locker interface to introduce GetRLock, RUnlock. type RWLocker interface { GetLock(ctx context.Context, timeout *dynamicTimeout) (lkCtx LockContext, timedOutErr error) Unlock(lkCtx LockContext)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
internal/s3select/csv/record.go
return json.NewEncoder(writer).Encode(kvs) } // Raw - returns the underlying data with format info. func (r *Record) Raw() (sql.SelectObjectFormat, interface{}) { return sql.SelectFmtCSV, r } // Replace - is not supported for CSV func (r *Record) Replace(_ interface{}) error { return errors.New("Replace is not supported for CSV") } // NewRecord - creates new CSV record. func NewRecord() *Record {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Sep 13 00:00:59 GMT 2022 - 4.1K bytes - Viewed (0)