- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 57 for Retriever (0.14 sec)
-
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
common := new(commonFlags) cmd := &cobra.Command{ Use: "certificate", Short: "Retrieves certificate for the specified Ztunnel pod.", Long: `Retrieve information about certificates for the Ztunnel instance.`, Example: ` # Retrieve summary about workload configuration for a randomly chosen ztunnel. istioctl x ztunnel-config certificates # Retrieve full certificate dump of workloads for a given Ztunnel instance.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
istioctl/pkg/util/configdump/route.go
route "github.com/envoyproxy/go-control-plane/envoy/config/route/v3" "istio.io/istio/pilot/pkg/util/protoconv" v3 "istio.io/istio/pilot/pkg/xds/v3" ) // GetLastUpdatedDynamicRouteTime retrieves the LastUpdated timestamp of the // most recently updated DynamicRouteConfig func (w *Wrapper) GetLastUpdatedDynamicRouteTime() (*time.Time, error) { routeDump, err := w.GetRouteConfigDump() if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 3.2K bytes - Viewed (0) -
istioctl/pkg/util/configdump/cluster.go
"sort" admin "github.com/envoyproxy/go-control-plane/envoy/admin/v3" cluster "github.com/envoyproxy/go-control-plane/envoy/config/cluster/v3" v3 "istio.io/istio/pilot/pkg/xds/v3" ) // GetDynamicClusterDump retrieves a cluster dump with just dynamic active clusters in it func (w *Wrapper) GetDynamicClusterDump(stripVersions bool) (*admin.ClustersConfigDump, error) { clusterDump, err := w.GetClusterConfigDump() if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 2.1K bytes - Viewed (0) -
internal/bpool/bpool_test.go
} // Check with width cap if bufPool.WidthCap() != capWidth { t.Fatalf("bytepool capWidth invalid: got %v want %v", bufPool.WidthCap(), capWidth) } // Check that retrieved buffer are of the expected width b := bufPool.Get() if len(b) != width { t.Fatalf("bytepool length invalid: got %v want %v", len(b), width) } if cap(b) != capWidth {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 19:13:27 GMT 2024 - 2.6K bytes - Viewed (0) -
docs/site-replication/gen-oidc-sts-cred.go
STSEndpoint: endpoint, GetWebIDTokenExpiry: func() (*cr.WebIdentityToken, error) { return &cr.WebIdentityToken{ Token: oidcToken, }, nil }, RoleARN: roleARN, } value, err := webID.Retrieve() if err != nil { log.Fatalf("Expected to generate credentials: %v", err) } // Print credentials separated by colons: fmt.Printf("%s:%s:%s\n", value.AccessKeyID, value.SecretAccessKey, value.SessionToken)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 29 01:27:09 GMT 2022 - 2.3K bytes - Viewed (0) -
cmd/admin-handlers-config-kv.go
if err = saveServerConfig(ctx, objectAPI, cfg); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } // freshly retrieve the config so that default values are loaded for reset config if cfg, err = getValidConfig(objectAPI); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.7K bytes - Viewed (0) -
cmd/storage-rest-client.go
type storageRESTClient struct { endpoint Endpoint restClient *rest.Client gridConn *grid.Subroute diskID atomic.Pointer[string] diskInfoCache *cachevalue.Cache[DiskInfo] } // Retrieve location indexes. func (client *storageRESTClient) GetDiskLoc() (poolIdx, setIdx, diskIdx int) { return client.endpoint.PoolIdx, client.endpoint.SetIdx, client.endpoint.DiskIdx }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
istioctl/pkg/version/version.go
return err } return nil } versionCmd.Example = ` # Retrieve version information directly from the control plane, using token security # (This is the usual way to get the control plane version with an out-of-cluster control plane.) istioctl x version --xds-address istio.cloudprovider.example.com:15012 # Retrieve version information via Kubernetes config, using token security
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.3K bytes - Viewed (0) -
cmd/sts-handlers_test.go
STSEndpoint: s.endPoint, Options: cr.STSAssumeRoleOptions{ AccessKey: "dillon", SecretKey: "dillon-123", Location: "", }, } value, err := assumeRole.Retrieve() if err != nil { c.Fatalf("Expected to generate STS creds, got err: %#v", err) } // Check that the LDAP sts cred is actually working. minioClient, err := minio.New(s.endpoint, &minio.Options{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
istioctl/pkg/cli/mock_client.go
results, ok := c.Results[podName] if !ok { return nil, fmt.Errorf("unable to retrieve Pod: pods %q not found", podName) } return results, nil } func (c MockClient) EnvoyDoWithPort(ctx context.Context, podName, podNamespace, method, path string, port int) ([]byte, error) { results, ok := c.Results[podName] if !ok { return nil, fmt.Errorf("unable to retrieve Pod: pods %q not found", podName) } return results, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 2.1K bytes - Viewed (0)