- Sort Score
- Result 10 results
- Languages All
Results 21 - 27 of 27 for Messages (0.09 sec)
-
pkg/config/model.go
} // Config is a configuration unit consisting of the type of configuration, the // key identifier that is unique per type, and the content represented as a // protobuf message. type Config struct { Meta // Spec holds the configuration object as a gogo protobuf message Spec Spec // Status holds long-running status. Status Status } func LabelsInRevision(lbls map[string]string, rev string) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 12.6K bytes - Viewed (0) -
pkg/test/echo/proto/echo.pb.go
} func (x *EchoRequest) GetMessage() string { if x != nil { return x.Message } return "" } type EchoResponse struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` } func (x *EchoResponse) Reset() { *x = EchoResponse{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 02:27:10 UTC 2024 - 33.3K bytes - Viewed (0) -
pkg/dns/proto/nds.pb.go
ms.StoreMessageInfo(mi) } } func (x *NameTable) String() string { return protoimpl.X.MessageStringOf(x) } func (*NameTable) ProtoMessage() {} func (x *NameTable) ProtoReflect() protoreflect.Message { mi := &file_dns_proto_nds_proto_msgTypes[0] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 02:27:10 UTC 2024 - 10.2K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client_test.go
} return nil }, retry.Timeout(time.Second*5), retry.Converge(5)) retry.UntilOrFail(t, func() bool { return store.Get(r.GroupVersionKind(), configMeta.Name, configMeta.Namespace) == nil }, retry.Message("expected no items returned for unknown CRD"), retry.Timeout(time.Second*5), retry.Converge(5)) } // Ensure that the client can run without CRDs present, but then added later func TestClientDelayedCRDs(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/config/constants/constants.go
// This used to use the no longer supported default K8S signer. // Deprecated - used to detect the old setting and generate the error message. CertProviderKubernetes = "kubernetes" // CertProviderKubernetesSignerPrefix uses the Kubernetes CSR API and the specified signer to generate a DNS certificate for the control plane
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 10K bytes - Viewed (0) -
pkg/kube/inject/webhook.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
Healthy: true, }) checkHealthOrFail(t, store, p, true) }) t.Run("auto registered unhealthy health", func(t *testing.T) { ig.QueueWorkloadEntryHealth(p, HealthEvent{ Healthy: false, Message: "lol health bad", }) checkHealthOrFail(t, store, p, false) }) } func TestWorkloadEntryFromGroup(t *testing.T) { group := config.Config{ Meta: config.Meta{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0)