- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for construct (0.46 sec)
-
cni/pkg/nodeagent/server.go
s.kubeClient.RunAndWait(s.ctx.Done()) log.Info("CNI ambient server kubeclient started") pods := s.handlers.GetAmbientPods() err := s.dataplane.ConstructInitialSnapshot(pods) if err != nil { log.Warnf("failed to construct initial snapshot: %v", err) } log.Info("CNI ambient server marking ready") s.Ready() s.dataplane.Start(s.ctx) s.handlers.Start() } func (s *Server) Stop() {
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) -
cni/pkg/repair/repair.go
repairLog.Info("CNI repair is disable.") return } repairLog.Info("Start CNI race condition repair.") client, err := clientSetup() if err != nil { repairLog.Fatalf("CNI repair could not construct clientSet: %s", err) } rc, err := NewRepairController(client, cfg) if err != nil { repairLog.Fatalf("Fatal error constructing repair controller: %+v", err) } go rc.Run(ctx.Done())
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.5K bytes - Viewed (0) -
cmd/config-migrate.go
return quick.LoadConfig(configFile, globalEtcdClient, data) } func readConfigWithoutMigrate(ctx context.Context, objAPI ObjectLayer) (config.Config, error) { // Construct path to config.json for the given bucket. configFile := path.Join(minioConfigPrefix, minioConfigFile) configFiles := []string{ getConfigFile(), getConfigFile() + ".deprecated", configFile, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:05:24 GMT 2023 - 5.4K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator.go
type Comparator struct { envoy, istiod *configdump.Wrapper w io.Writer context int location string } // NewComparator is a comparator constructor func NewComparator(w io.Writer, istiodResponses map[string][]byte, envoyResponse []byte) (*Comparator, error) { c := &Comparator{} for _, resp := range istiodResponses { istiodDump := &configdump.Wrapper{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 3.7K bytes - Viewed (1) -
cni/pkg/plugin/sidecar_intercept_rule_mgr.go
// InterceptRuleMgr configures networking tables (e.g. iptables or nftables) for // redirecting traffic to an Istio proxy. type InterceptRuleMgr interface { Program(podName, netns string, redirect *Redirect) error } // Constructor for iptables InterceptRuleMgr func IptablesInterceptRuleMgr() InterceptRuleMgr { return newIPTables()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 940 bytes - Viewed (0) -
istioctl/pkg/xds/client.go
} err = adscConn.Send(dr) if err != nil { return nil, err } response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "") return response, err } // DialOptions constructs gRPC dial options from command line configuration func DialOptions(opts clioptions.CentralControlPlaneOptions, ns, serviceAccount string, kubeClient kube.CLIClient, ) ([]grpc.DialOption, error) { ctx := context.TODO()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
internal/logger/message/audit/entry.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.2K bytes - Viewed (0) -
cmd/erasure_test.go
if test.reconstructParity { for j := range decoded { if decoded[j] == nil { t.Errorf("Test %d: failed to reconstruct shard %d", i, j) } } } else { for j := range decoded[:test.dataBlocks] { if decoded[j] == nil { t.Errorf("Test %d: failed to reconstruct data shard %d", i, j) } } } decodedData := new(bytes.Buffer)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 25 19:37:26 GMT 2022 - 4.8K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
) // ReconnectRESTClient is a wrapper type for rest.Client which provides reconnect on first failure. type ReconnectRESTClient struct { u *url.URL rest *rest.Client } // newClient constructs a ReconnectRESTClient object with addr and endpoint initialized. // It _doesn't_ connect to the remote endpoint. See Call method to see when the // connect happens. func newClient(endpoint string) NetLocker {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 20 17:36:09 GMT 2022 - 4.4K bytes - Viewed (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
// each authentication attempt. type XDGSCRAMClient struct { *scram.Client *scram.ClientConversation scram.HashGeneratorFcn } // Begin constructs a SCRAM client component based on a given hash.Hash // factory receiver. This constructor will normalize the username, password // and authzID via the SASLprep algorithm, as recommended by RFC-5802. If // SASLprep fails, the method returns an error.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.3K bytes - Viewed (1)