- Sort Score
- Result 10 results
- Languages All
Results 911 - 920 of 1,349 for Struct (0.12 sec)
-
architecture/networking/pilot.md
#### ConfigStore The `ConfigStore` reads a variety of resources and exposes them over a standard interface (Get, List, etc). These types are wrapped in a common `config.Config` struct, contrasting with typical Kubernetes clients which use per-resource types. The most common is reading from Kubernetes via the `crdclient` package. ```mermaid graph TD subgraph ConfigStore xcs(XDS Client)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Feb 07 17:53:24 UTC 2024 - 19.1K bytes - Viewed (0) -
cmd/server_test.go
) // API suite container common to both ErasureSD and Erasure. type TestSuiteCommon struct { serverType string testServer TestServer endPoint string accessKey string secretKey string signer signerType secure bool client *http.Client } type check struct { *testing.T testType string }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 15 16:28:02 UTC 2024 - 116.3K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
) ) type K8sHandlers interface { GetPodIfAmbient(podName, podNamespace string) (*corev1.Pod, error) GetActiveAmbientPodSnapshot() []*corev1.Pod Start() } type InformerHandlers struct { ctx context.Context dataplane MeshDataplane systemNamespace string queue controllers.Queue pods kclient.Client[*corev1.Pod] namespaces kclient.Client[*corev1.Namespace] }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 11.7K bytes - Viewed (0) -
cmd/sftp-server.go
return subtle.ConstantTimeCompare(caPublicKey.Marshal(), k.Marshal()) == 1 } _, err = checker.Authenticate(c, clientKey) return } type sftpLogger struct{} func (s *sftpLogger) Info(tag xsftp.LogType, msg string) { logger.Info(msg) } func (s *sftpLogger) Error(tag xsftp.LogType, err error) { switch tag { case xsftp.AcceptNetworkError:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 20 20:00:29 UTC 2024 - 16K bytes - Viewed (0) -
internal/grid/benchmark_test.go
b.ReportMetric(float64(n)*float64(ops)/spent.Seconds(), "vops/s") b.ReportMetric(latency/float64(ops), "ms/op") } }) } }) } func BenchmarkStream(b *testing.B) { tests := []struct { name string fn func(b *testing.B, n int) }{ {name: "request", fn: benchmarkGridStreamReqOnly}, {name: "responses", fn: benchmarkGridStreamRespOnly}, {name: "twoway", fn: benchmarkGridStreamTwoway},
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.7K bytes - Viewed (0) -
internal/kms/config.go
) const ( tlsClientSessionCacheSize = 100 ) // ConnectionOptions is a structure containing options for connecting // to a KMS. type ConnectionOptions struct { CADir string // Path to directory (or file) containing CA certificates } // Connect returns a new Conn to a KMS. It uses configuration from the // environment and returns a: //
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 11:46:39 UTC 2024 - 14.2K bytes - Viewed (0) -
internal/hash/checksum.go
ChecksumIncludesMultipart // ChecksumNone indicates no checksum. ChecksumNone ChecksumType = 0 ) // Checksum is a type and base 64 encoded value. type Checksum struct { Type ChecksumType Encoded string Raw []byte WantParts int } // Is returns if c is all of t. func (c ChecksumType) Is(t ChecksumType) bool { if t == ChecksumNone {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 19 12:59:07 UTC 2024 - 12.7K bytes - Viewed (0) -
src/cmd/asm/internal/lex/input.go
) // Input is the main input: a stack of readers and some macro definitions. // It also handles #include processing (by pushing onto the input stack) // and parses and instantiates macro definitions. type Input struct { Stack includes []string beginningOfLine bool ifdefStack []bool macros map[string]*Macro text string // Text of last token returned by Next. peek bool
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Sep 06 13:17:27 UTC 2024 - 12.5K bytes - Viewed (0) -
cmd/bucket-metadata.go
// Only changing meaning of fields requires a version bump. // bucketMetadataFormat refers to the format. // bucketMetadataVersion can be used to track a rolling upgrade of a field. type BucketMetadata struct { Name string Created time.Time LockEnabled bool // legacy not used anymore. PolicyConfigJSON []byte NotificationConfigXML []byte
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 18.2K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
healingTrackerFilename = ".healing.bin" ) //go:generate msgp -file $GOFILE -unexported // healingTracker is used to persist healing information during a heal. type healingTracker struct { disk StorageAPI `msg:"-"` mu *sync.RWMutex `msg:"-"` ID string PoolIndex int SetIndex int DiskIndex int Path string Endpoint string Started time.Time
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0)