- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 70 for store (0.12 sec)
-
internal/logger/target/testlogger/testlogger.go
return t.setTB(tb, fatalMessage) } func (t *testLogger) setTB(tb testing.TB, action int32) func() { old := t.action.Swap(action) t.current.Store(&tb) return func() { t.current.Store(nil) t.action.Store(old) } } func (t *testLogger) String() string { tb := t.current.Load() if tb != nil { tbb := *tb return tbb.Name() } return "" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 4K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
return nil, fmt.Errorf("error starting cni server: %w", err) } s.cniServerStopFunc = cniServer.Stop return s, nil } func (s *Server) Ready() { s.isReady.Store(true) } func (s *Server) NotReady() { s.isReady.Store(false) } // buildKubeClient creates the kube client func buildKubeClient(kubeConfig string) (kube.Client, error) { // Used by validation
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
lib/time/mkzip.go
log.Fatalf("unexpected file during walk: %s", path) } name := filepath.ToSlash(path) w, err := zw.CreateRaw(&zip.FileHeader{ Name: name, Method: zip.Store, CompressedSize64: uint64(len(data)), UncompressedSize64: uint64(len(data)), CRC32: crc32.ChecksumIEEE(data), }) if err != nil { log.Fatal(err) }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Mar 04 17:32:07 GMT 2024 - 2.1K bytes - Viewed (0) -
src/archive/tar/stat_unix.go
} else if u, err := user.LookupId(strconv.Itoa(h.Uid)); err == nil { h.Uname = u.Username userMap.Store(h.Uid, h.Uname) } if g, ok := groupMap.Load(h.Gid); ok { h.Gname = g.(string) } else if g, err := user.LookupGroupId(strconv.Itoa(h.Gid)); err == nil { h.Gname = g.Name groupMap.Store(h.Gid, h.Gname) } } h.AccessTime = statAtime(sys) h.ChangeTime = statCtime(sys)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 3.2K bytes - Viewed (0) -
internal/config/dns/operator_dns.go
// enforced by the Kubernetes Operator func (c *OperatorDNS) Get(bucket string) (srvRecords []SrvRecord, err error) { return nil, ErrNotImplemented } // String stringer name for this implementation of dns.Store func (c *OperatorDNS) String() string { return "webhookDNS" } // OperatorDNS - represents dns config for MinIO k8s operator. type OperatorDNS struct { httpClient *http.Client Endpoint string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 6.6K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/clusters/clusters.go
} // ConfigWriter is a writer for processing responses from the Envoy Admin config_dump endpoint type ConfigWriter struct { Stdout io.Writer clusters *clusters.Wrapper } // EndpointCluster is used to store the endpoint and cluster type EndpointCluster struct { address string port int cluster string status core.HealthStatus failedOutlierCheck bool }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 5.8K bytes - Viewed (0) -
cmd/grid.go
Incoming: globalConnStats.incInternodeInputBytes, Outgoing: globalConnStats.incInternodeOutputBytes, TraceTo: globalTrace, }) if err != nil { return err } globalGrid.Store(g) return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 2K bytes - Viewed (0) -
internal/config/cache/cache.go
} // Config represents the subnet related configuration type Config struct { // Flag indicating whether cache is enabled. Enable bool `json:"enable"` // Endpoint for caching uses remote mcache server to // store and retrieve pre-condition check entities such as // Etag and ModTime of an object + version Endpoint string `json:"endpoint"` // BlockSize indicates the maximum object size below which
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/store/batch.go
// GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. 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 }
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) -
cni/pkg/nodeagent/fakes_test.go
return f.fd } func (f *fakeNs) Inode() uint64 { return f.inode } // Close simulates closing the file descriptor and returns nil for no error func (f *fakeNs) Close() error { f.closed.Store(true) return nil } func fakeFs() fs.FS { subFs, err := fs.Sub(fakeProc, "testdata") if err != nil { panic(err) } subFs, err = fs.Sub(subFs, "cgroupns") if err != nil { panic(err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0)