- Sort Score
- Result 10 results
- Languages All
Results 1131 - 1140 of 1,384 for funcs (0.03 sec)
-
cmd/object-handlers_test.go
func TestAPIGetObjectHandler(t *testing.T) { globalPolicySys = NewPolicySys() defer func() { globalPolicySys = nil }() defer DetectTestLeak(t)() ExecExtendedObjectLayerAPITest(t, testAPIGetObjectHandler, []string{"GetObject"}) } func testAPIGetObjectHandler(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 20:10:44 UTC 2024 - 163.2K bytes - Viewed (0) -
internal/bucket/replication/datatypes.go
Failed StatusType = "FAILED" // Replica - this is a replica. Replica StatusType = "REPLICA" ) // String returns string representation of status func (s StatusType) String() string { return string(s) } // Empty returns true if this status is not set func (s StatusType) Empty() bool { return string(s) == ""
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Mar 08 19:08:18 UTC 2024 - 1.5K bytes - Viewed (0) -
internal/dsync/locked_rand.go
lk sync.Mutex src rand.Source } // Int63 returns a non-negative pseudo-random 63-bit integer as an int64. func (r *lockedRandSource) Int63() (n int64) { r.lk.Lock() n = r.src.Int63() r.lk.Unlock() return } // Seed uses the provided seed value to initialize the generator to a // deterministic state. func (r *lockedRandSource) Seed(seed int64) { r.lk.Lock() r.src.Seed(seed) r.lk.Unlock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Oct 18 15:39:59 UTC 2021 - 1.3K bytes - Viewed (0) -
clause/from_test.go
package clause_test import ( "fmt" "testing" "gorm.io/gorm/clause" ) func TestFrom(t *testing.T) { results := []struct { Clauses []clause.Interface Result string Vars []interface{} }{ { []clause.Interface{clause.Select{}, clause.From{}}, "SELECT * FROM `users`", nil, }, { []clause.Interface{ clause.Select{}, clause.From{ Tables: []clause.Table{{Name: "users"}},
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Jul 15 02:25:10 UTC 2020 - 1.9K bytes - Viewed (0) -
cmd/os-rename_nolinux.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 15 01:09:38 UTC 2024 - 985 bytes - Viewed (0) -
internal/dsync/dsync.go
package dsync // Dsync represents dsync client object which is initialized with // authenticated clients, used to initiate lock REST calls. type Dsync struct { // List of rest client objects, one per lock server. GetLockers func() ([]NetLocker, string) // Timeouts to apply. Timeouts Timeouts
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 01 19:14:28 UTC 2022 - 1K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_iptables_unspecified.go
var ErrNotImplemented = errors.New("not implemented") // Program defines a method which programs iptables based on the parameters // provided in Redirect. func (ipt *iptables) Program(podName, netns string, rdrct *Redirect) error { return ErrNotImplemented
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 1.1K bytes - Viewed (0) -
istioctl/pkg/multicluster/cluster.go
"k8s.io/client-go/kubernetes" ) // Use UUID of kube-system Namespace as unique identifier for cluster. // (see https://docs.google.com/document/d/1F__vEKeI41P7PPUCMM9PVPYY34pyrvQI5rbTJVnS5c4) func clusterUID(client kubernetes.Interface) (types.UID, error) { kubeSystem, err := client.CoreV1().Namespaces().Get(context.TODO(), "kube-system", metav1.GetOptions{}) if err != nil { return "", err }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Sep 02 03:11:58 UTC 2022 - 1.1K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package bandwidth import ( "reflect" "testing" "time" ) const ( oneMiB uint64 = 1024 * 1024 ) func TestMonitor_GetReport(t *testing.T) { type fields struct { activeBuckets map[BucketOptions]*bucketMeasurement endTime time.Time update2 uint64 endTime2 time.Time } start := time.Now()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 06 03:21:59 UTC 2023 - 4.3K bytes - Viewed (0) -
src/archive/tar/stat_unix.go
import ( "io/fs" "os/user" "runtime" "strconv" "sync" "syscall" ) func init() { sysStat = statUnix } // userMap and groupMap caches UID and GID lookups for performance reasons. // The downside is that renaming uname or gname by the OS never takes effect. var userMap, groupMap sync.Map // map[int]string func statUnix(fi fs.FileInfo, h *Header, doNameLookups bool) error { sys, ok := fi.Sys().(*syscall.Stat_t)
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Mar 15 16:01:50 UTC 2024 - 3.2K bytes - Viewed (0)