- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 60 for service (0.3 sec)
-
istioctl/pkg/wait/wait_test.go
}, { execClientConfig: cannedResponseMap, args: strings.Split("--generation=1 not-service foo.default", " "), wantException: true, expectedOutput: "type not-service is not recognized", }, { execClientConfig: cannedResponseMap, args: strings.Split("--timeout 20ms virtual-service bar.default", " "), wantException: true,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 6.8K bytes - Viewed (0) -
cmd/signature-v4-parser.go
type credentialHeader struct { accessKey string scope struct { date time.Time region string service string request string } } // Return scope string. func (c credentialHeader) getScope() string { return strings.Join([]string{ c.scope.date.Format(yyyymmdd), c.scope.region, c.scope.service, c.scope.request, }, SlashSeparator) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
internal/dsync/locker.go
ForceUnlock(ctx context.Context, args LockArgs) (bool, error) // Returns underlying endpoint of this lock client instance. String() string // Close closes any underlying connection to the service endpoint Close() error // Is the underlying connection online? (is always true for any local lockers) IsOnline() bool // Is the underlying locker local to this server? IsLocal() bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 18 20:44:38 GMT 2022 - 2.7K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
package pilot import ( "encoding/json" "fmt" "io" "sort" "text/tabwriter" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" xdsstatus "github.com/envoyproxy/go-control-plane/envoy/service/status/v3" "istio.io/istio/istioctl/pkg/multixds" "istio.io/istio/pilot/pkg/model" xdsresource "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/log" )
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/policies.go
import ( "cmp" "encoding/json" "fmt" "strings" "sigs.k8s.io/yaml" "istio.io/istio/pkg/maps" "istio.io/istio/pkg/slices" ) // PolicyFilter is used to pass filter information into service based config writer print functions type PolicyFilter struct { Namespace string } // Verify returns true if the passed workload matches the filter fields func (wf *PolicyFilter) Verify(pol *ZtunnelPolicy) bool {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.5K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator.go
package compare import ( "encoding/json" "fmt" "io" "strings" admin "github.com/envoyproxy/go-control-plane/envoy/admin/v3" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" legacyproto "github.com/golang/protobuf/proto" // nolint: staticcheck exprpb "google.golang.org/genproto/googleapis/api/expr/v1alpha1" "google.golang.org/protobuf/reflect/protoreflect"
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) -
cmd/signals.go
case serviceRestart: logger.Info("Restarting on service signal") daemon.SdNotify(false, daemon.SdNotifyReloading) stop := stopProcess() rerr := restartProcess() if rerr == nil { daemon.SdNotify(false, daemon.SdNotifyReady) } shutdownLogIf(context.Background(), rerr) exit(stop && rerr == nil) case serviceStop: logger.Info("Stopping on service signal")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/config/identity/openid/providercfg.go
} // UserInfo returns claims for authenticated user from userInfo endpoint. // // Some OIDC implementations such as GitLab do not support // claims as part of the normal oauth2 flow, instead rely // on service providers making calls to IDP to fetch additional // claims available from the UserInfo endpoint func (p *providerCfg) UserInfo(ctx context.Context, accessToken string, transport http.RoundTripper) (map[string]interface{}, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.6K bytes - Viewed (0) -
istioctl/pkg/version/version.go
import ( "context" "encoding/json" "fmt" "os" core "github.com/envoyproxy/go-control-plane/envoy/config/core/v3" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" statusv3 "github.com/envoyproxy/go-control-plane/envoy/service/status/v3" "github.com/spf13/cobra" "github.com/spf13/pflag" "google.golang.org/protobuf/types/known/structpb" "istio.io/istio/istioctl/pkg/cli"
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) -
cni/pkg/install/kubeconfig.go
func createKubeConfig(cfg *config.InstallConfig) (kubeconfig, error) { if len(cfg.K8sServiceHost) == 0 { return kubeconfig{}, fmt.Errorf("KUBERNETES_SERVICE_HOST not set. Is this not running within a pod?") } if len(cfg.K8sServicePort) == 0 { return kubeconfig{}, fmt.Errorf("KUBERNETES_SERVICE_PORT not set. Is this not running within a pod?") } protocol := model.GetOrDefault(cfg.K8sServiceProtocol, "https") cluster := &api.Cluster{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Aug 11 01:19:03 GMT 2023 - 4.9K bytes - Viewed (0)