- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 1,425 for Func (0.04 sec)
-
internal/bucket/lifecycle/lifecycle.go
ActionCount ) // DeleteRestored - Returns true if action demands delete on restored objects func (a Action) DeleteRestored() bool { return a == DeleteRestoredAction || a == DeleteRestoredVersionAction } // DeleteVersioned - Returns true if action demands delete on a versioned object func (a Action) DeleteVersioned() bool { return a == DeleteVersionAction || a == DeleteRestoredVersionAction }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 23 01:12:48 UTC 2024 - 17.9K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
} } // Close closes the underlying socket file descriptor. func (restClient *ReconnectRESTClient) IsOnline() bool { // If rest client has not connected yet there is nothing to close. return restClient.rest != nil } func (restClient *ReconnectRESTClient) IsLocal() bool { return false } // Close closes the underlying socket file descriptor. func (restClient *ReconnectRESTClient) Close() error { return nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 20 17:36:09 UTC 2022 - 4.4K bytes - Viewed (0) -
internal/event/targetidset.go
// IsEmpty returns true if the set is empty. func (set TargetIDSet) IsEmpty() bool { return len(set) != 0 } // Clone - returns copy of this set. func (set TargetIDSet) Clone() TargetIDSet { setCopy := NewTargetIDSet() for k, v := range set { setCopy[k] = v } return setCopy } // add - adds TargetID to the set. func (set TargetIDSet) add(targetID TargetID) { set[targetID] = struct{}{} }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 1.9K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list.go
needsRestart int } func Cmd(cliContext cli.Context) *cobra.Command { cmd := &cobra.Command{ Use: "injector", Short: "List sidecar injector and sidecar versions", Long: `List sidecar injector and sidecar versions`, Example: ` istioctl experimental injector list`, Args: func(cmd *cobra.Command, args []string) error { if len(args) != 0 {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Oct 18 11:39:52 UTC 2024 - 10.6K bytes - Viewed (0) -
cmd/iam-object-store.go
usersSysType UsersSysType objAPI ObjectLayer } func newIAMObjectStore(objAPI ObjectLayer, usersSysType UsersSysType) *IAMObjectStore { return &IAMObjectStore{ iamCache: newIamCache(), objAPI: objAPI, usersSysType: usersSysType, } } func (iamOS *IAMObjectStore) rlock() *iamCache { iamOS.RLock() return iamOS.iamCache } func (iamOS *IAMObjectStore) runlock() { iamOS.RUnlock() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 23:40:37 UTC 2024 - 26.6K bytes - Viewed (0) -
internal/logger/logger.go
var ( quietFlag, jsonFlag, anonFlag bool // Custom function to format error errorFmtFunc func(string, error, bool) string ) // EnableQuiet - turns quiet option on. func EnableQuiet() { color.TurnOff() // no colored outputs necessary in quiet mode. quietFlag = true } // EnableJSON - outputs logs in json format. func EnableJSON() { color.TurnOff() // no colored outputs necessary in JSON mode. jsonFlag = true
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 22 09:43:48 UTC 2024 - 12.4K bytes - Viewed (0) -
cmd/erasure-healing-common.go
return checkPartDiskNotFound default: return checkPartUnknown } } func partNeedsHealing(partErrs []int) bool { return slices.IndexFunc(partErrs, func(i int) bool { return i != checkPartSuccess && i != checkPartUnknown }) > -1 } func hasPartErr(partErrs []int) bool { return slices.IndexFunc(partErrs, func(i int) bool { return i != checkPartSuccess }) > -1 }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/sftp-server_test.go
) type MockConnMeta struct { username string } func (m *MockConnMeta) User() string { return m.username } func (m *MockConnMeta) SessionID() []byte { return []byte{} } func (m *MockConnMeta) ClientVersion() []byte { return []byte{} } func (m *MockConnMeta) ServerVersion() []byte { return []byte{} } func (m *MockConnMeta) RemoteAddr() net.Addr { return nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 28 09:06:25 UTC 2024 - 8.3K bytes - Viewed (0) -
tests/serializer_test.go
} return nil } func (es EncryptedString) Value(ctx context.Context, field *schema.Field, dst reflect.Value, fieldValue interface{}) (interface{}, error) { return "hello" + string(es), nil } type CustomSerializer struct { prefix []byte } func NewCustomSerializer(prefix string) *CustomSerializer { return &CustomSerializer{prefix: []byte(prefix)} }
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Fri Apr 21 14:09:38 UTC 2023 - 7.6K bytes - Viewed (0) -
internal/store/batch_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package store import ( "context" "sync" "testing" "time" ) func TestBatchCommit(t *testing.T) { defer func() { if err := tearDownQueueStore(); err != nil { t.Fatalf("Failed to tear down store; %v", err) } }() store, err := setUpQueueStore(queueDir, 100) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 5.6K bytes - Viewed (0)