Documentation ¶
Index ¶
- Constants
- func ParseIP(text string) (string, error)
- func ParsePort(text string) (uint32, error)
- func RegisterKumaDiscoveryServiceServer(s *grpc.Server, srv KumaDiscoveryServiceServer)
- type CertificateAuthorityBackend
- func (*CertificateAuthorityBackend) Descriptor() ([]byte, []int)
- func (m *CertificateAuthorityBackend) GetConf() *_struct.Struct
- func (m *CertificateAuthorityBackend) GetDpCert() *CertificateAuthorityBackend_DpCert
- func (m *CertificateAuthorityBackend) GetName() string
- func (m *CertificateAuthorityBackend) GetType() string
- func (*CertificateAuthorityBackend) ProtoMessage()
- func (m *CertificateAuthorityBackend) Reset()
- func (m *CertificateAuthorityBackend) String() string
- func (m *CertificateAuthorityBackend) Validate() error
- func (m *CertificateAuthorityBackend) XXX_DiscardUnknown()
- func (m *CertificateAuthorityBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CertificateAuthorityBackend) XXX_Merge(src proto.Message)
- func (m *CertificateAuthorityBackend) XXX_Size() int
- func (m *CertificateAuthorityBackend) XXX_Unmarshal(b []byte) error
- type CertificateAuthorityBackendValidationError
- func (e CertificateAuthorityBackendValidationError) Cause() error
- func (e CertificateAuthorityBackendValidationError) Error() string
- func (e CertificateAuthorityBackendValidationError) ErrorName() string
- func (e CertificateAuthorityBackendValidationError) Field() string
- func (e CertificateAuthorityBackendValidationError) Key() bool
- func (e CertificateAuthorityBackendValidationError) Reason() string
- type CertificateAuthorityBackend_DpCert
- func (*CertificateAuthorityBackend_DpCert) Descriptor() ([]byte, []int)
- func (m *CertificateAuthorityBackend_DpCert) GetRotation() *CertificateAuthorityBackend_DpCert_Rotation
- func (*CertificateAuthorityBackend_DpCert) ProtoMessage()
- func (m *CertificateAuthorityBackend_DpCert) Reset()
- func (m *CertificateAuthorityBackend_DpCert) String() string
- func (m *CertificateAuthorityBackend_DpCert) Validate() error
- func (m *CertificateAuthorityBackend_DpCert) XXX_DiscardUnknown()
- func (m *CertificateAuthorityBackend_DpCert) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CertificateAuthorityBackend_DpCert) XXX_Merge(src proto.Message)
- func (m *CertificateAuthorityBackend_DpCert) XXX_Size() int
- func (m *CertificateAuthorityBackend_DpCert) XXX_Unmarshal(b []byte) error
- type CertificateAuthorityBackend_DpCertValidationError
- func (e CertificateAuthorityBackend_DpCertValidationError) Cause() error
- func (e CertificateAuthorityBackend_DpCertValidationError) Error() string
- func (e CertificateAuthorityBackend_DpCertValidationError) ErrorName() string
- func (e CertificateAuthorityBackend_DpCertValidationError) Field() string
- func (e CertificateAuthorityBackend_DpCertValidationError) Key() bool
- func (e CertificateAuthorityBackend_DpCertValidationError) Reason() string
- type CertificateAuthorityBackend_DpCert_Rotation
- func (*CertificateAuthorityBackend_DpCert_Rotation) Descriptor() ([]byte, []int)
- func (m *CertificateAuthorityBackend_DpCert_Rotation) GetExpiration() string
- func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage()
- func (m *CertificateAuthorityBackend_DpCert_Rotation) Reset()
- func (m *CertificateAuthorityBackend_DpCert_Rotation) String() string
- func (m *CertificateAuthorityBackend_DpCert_Rotation) Validate() error
- func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_DiscardUnknown()
- func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_Merge(src proto.Message)
- func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_Size() int
- func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_Unmarshal(b []byte) error
- type CertificateAuthorityBackend_DpCert_RotationValidationError
- func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Cause() error
- func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Error() string
- func (e CertificateAuthorityBackend_DpCert_RotationValidationError) ErrorName() string
- func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Field() string
- func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Key() bool
- func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Reason() string
- type CircuitBreaker
- func (*CircuitBreaker) Descriptor() ([]byte, []int)
- func (m *CircuitBreaker) GetConf() *CircuitBreaker_Conf
- func (m *CircuitBreaker) GetDestinations() []*Selector
- func (m *CircuitBreaker) GetSources() []*Selector
- func (*CircuitBreaker) ProtoMessage()
- func (m *CircuitBreaker) Reset()
- func (m *CircuitBreaker) String() string
- func (m *CircuitBreaker) XXX_DiscardUnknown()
- func (m *CircuitBreaker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CircuitBreaker) XXX_Merge(src proto.Message)
- func (m *CircuitBreaker) XXX_Size() int
- func (m *CircuitBreaker) XXX_Unmarshal(b []byte) error
- type CircuitBreaker_Conf
- func (*CircuitBreaker_Conf) Descriptor() ([]byte, []int)
- func (m *CircuitBreaker_Conf) GetBaseEjectionTime() *duration.Duration
- func (m *CircuitBreaker_Conf) GetDetectors() *CircuitBreaker_Conf_Detectors
- func (m *CircuitBreaker_Conf) GetInterval() *duration.Duration
- func (m *CircuitBreaker_Conf) GetMaxEjectionPercent() *wrappers.UInt32Value
- func (m *CircuitBreaker_Conf) GetSplitExternalAndLocalErrors() bool
- func (*CircuitBreaker_Conf) ProtoMessage()
- func (m *CircuitBreaker_Conf) Reset()
- func (m *CircuitBreaker_Conf) String() string
- func (m *CircuitBreaker_Conf) XXX_DiscardUnknown()
- func (m *CircuitBreaker_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CircuitBreaker_Conf) XXX_Merge(src proto.Message)
- func (m *CircuitBreaker_Conf) XXX_Size() int
- func (m *CircuitBreaker_Conf) XXX_Unmarshal(b []byte) error
- type CircuitBreaker_Conf_Detectors
- func (*CircuitBreaker_Conf_Detectors) Descriptor() ([]byte, []int)
- func (m *CircuitBreaker_Conf_Detectors) GetFailure() *CircuitBreaker_Conf_Detectors_Failure
- func (m *CircuitBreaker_Conf_Detectors) GetGatewayErrors() *CircuitBreaker_Conf_Detectors_Errors
- func (m *CircuitBreaker_Conf_Detectors) GetLocalErrors() *CircuitBreaker_Conf_Detectors_Errors
- func (m *CircuitBreaker_Conf_Detectors) GetStandardDeviation() *CircuitBreaker_Conf_Detectors_StandardDeviation
- func (m *CircuitBreaker_Conf_Detectors) GetTotalErrors() *CircuitBreaker_Conf_Detectors_Errors
- func (*CircuitBreaker_Conf_Detectors) ProtoMessage()
- func (m *CircuitBreaker_Conf_Detectors) Reset()
- func (m *CircuitBreaker_Conf_Detectors) String() string
- func (m *CircuitBreaker_Conf_Detectors) XXX_DiscardUnknown()
- func (m *CircuitBreaker_Conf_Detectors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CircuitBreaker_Conf_Detectors) XXX_Merge(src proto.Message)
- func (m *CircuitBreaker_Conf_Detectors) XXX_Size() int
- func (m *CircuitBreaker_Conf_Detectors) XXX_Unmarshal(b []byte) error
- type CircuitBreaker_Conf_Detectors_Errors
- func (*CircuitBreaker_Conf_Detectors_Errors) Descriptor() ([]byte, []int)
- func (m *CircuitBreaker_Conf_Detectors_Errors) GetConsecutive() *wrappers.UInt32Value
- func (*CircuitBreaker_Conf_Detectors_Errors) ProtoMessage()
- func (m *CircuitBreaker_Conf_Detectors_Errors) Reset()
- func (m *CircuitBreaker_Conf_Detectors_Errors) String() string
- func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_DiscardUnknown()
- func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_Merge(src proto.Message)
- func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_Size() int
- func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_Unmarshal(b []byte) error
- type CircuitBreaker_Conf_Detectors_Failure
- func (*CircuitBreaker_Conf_Detectors_Failure) Descriptor() ([]byte, []int)
- func (m *CircuitBreaker_Conf_Detectors_Failure) GetMinimumHosts() *wrappers.UInt32Value
- func (m *CircuitBreaker_Conf_Detectors_Failure) GetRequestVolume() *wrappers.UInt32Value
- func (m *CircuitBreaker_Conf_Detectors_Failure) GetThreshold() *wrappers.UInt32Value
- func (*CircuitBreaker_Conf_Detectors_Failure) ProtoMessage()
- func (m *CircuitBreaker_Conf_Detectors_Failure) Reset()
- func (m *CircuitBreaker_Conf_Detectors_Failure) String() string
- func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_DiscardUnknown()
- func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_Merge(src proto.Message)
- func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_Size() int
- func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_Unmarshal(b []byte) error
- type CircuitBreaker_Conf_Detectors_StandardDeviation
- func (*CircuitBreaker_Conf_Detectors_StandardDeviation) Descriptor() ([]byte, []int)
- func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) GetFactor() *wrappers.DoubleValue
- func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) GetMinimumHosts() *wrappers.UInt32Value
- func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) GetRequestVolume() *wrappers.UInt32Value
- func (*CircuitBreaker_Conf_Detectors_StandardDeviation) ProtoMessage()
- func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) Reset()
- func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) String() string
- func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_DiscardUnknown()
- func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Merge(src proto.Message)
- func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Size() int
- func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Unmarshal(b []byte) error
- type Dataplane
- func (*Dataplane) Descriptor() ([]byte, []int)
- func (d *Dataplane) GetIdentifyingService() string
- func (m *Dataplane) GetMetrics() *MetricsBackend
- func (m *Dataplane) GetNetworking() *Dataplane_Networking
- func (d *Dataplane) HasAvailableServices() bool
- func (d *Dataplane) IsIngress() bool
- func (d *Dataplane) IsRemoteIngress(localZone string) bool
- func (d *Dataplane) MatchTags(selector TagSelector) bool
- func (d *Dataplane) Matches(selector TagSelector) bool
- func (*Dataplane) ProtoMessage()
- func (m *Dataplane) Reset()
- func (m *Dataplane) String() string
- func (d *Dataplane) Tags() MultiValueTagSet
- func (m *Dataplane) Validate() error
- func (m *Dataplane) XXX_DiscardUnknown()
- func (m *Dataplane) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Dataplane) XXX_Merge(src proto.Message)
- func (m *Dataplane) XXX_Size() int
- func (m *Dataplane) XXX_Unmarshal(b []byte) error
- type DataplaneInsight
- func (*DataplaneInsight) Descriptor() ([]byte, []int)
- func (ds *DataplaneInsight) GetLatestSubscription() (*DiscoverySubscription, *time.Time)
- func (m *DataplaneInsight) GetMTLS() *DataplaneInsight_MTLS
- func (ds *DataplaneInsight) GetSubscription(id string) (int, *DiscoverySubscription)
- func (m *DataplaneInsight) GetSubscriptions() []*DiscoverySubscription
- func (ds *DataplaneInsight) IsOnline() bool
- func (*DataplaneInsight) ProtoMessage()
- func (m *DataplaneInsight) Reset()
- func (m *DataplaneInsight) String() string
- func (ds *DataplaneInsight) Sum(v func(*DiscoverySubscription) uint64) uint64
- func (ds *DataplaneInsight) UpdateCert(generation time.Time, expiration time.Time) error
- func (ds *DataplaneInsight) UpdateSubscription(s *DiscoverySubscription)
- func (m *DataplaneInsight) XXX_DiscardUnknown()
- func (m *DataplaneInsight) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataplaneInsight) XXX_Merge(src proto.Message)
- func (m *DataplaneInsight) XXX_Size() int
- func (m *DataplaneInsight) XXX_Unmarshal(b []byte) error
- type DataplaneInsight_MTLS
- func (*DataplaneInsight_MTLS) Descriptor() ([]byte, []int)
- func (m *DataplaneInsight_MTLS) GetCertificateExpirationTime() *timestamp.Timestamp
- func (m *DataplaneInsight_MTLS) GetCertificateRegenerations() uint32
- func (m *DataplaneInsight_MTLS) GetLastCertificateRegeneration() *timestamp.Timestamp
- func (*DataplaneInsight_MTLS) ProtoMessage()
- func (m *DataplaneInsight_MTLS) Reset()
- func (m *DataplaneInsight_MTLS) String() string
- func (m *DataplaneInsight_MTLS) XXX_DiscardUnknown()
- func (m *DataplaneInsight_MTLS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataplaneInsight_MTLS) XXX_Merge(src proto.Message)
- func (m *DataplaneInsight_MTLS) XXX_Size() int
- func (m *DataplaneInsight_MTLS) XXX_Unmarshal(b []byte) error
- type DataplaneOverview
- func (*DataplaneOverview) Descriptor() ([]byte, []int)
- func (m *DataplaneOverview) GetDataplane() *Dataplane
- func (m *DataplaneOverview) GetDataplaneInsight() *DataplaneInsight
- func (*DataplaneOverview) ProtoMessage()
- func (m *DataplaneOverview) Reset()
- func (m *DataplaneOverview) String() string
- func (m *DataplaneOverview) XXX_DiscardUnknown()
- func (m *DataplaneOverview) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataplaneOverview) XXX_Merge(src proto.Message)
- func (m *DataplaneOverview) XXX_Size() int
- func (m *DataplaneOverview) XXX_Unmarshal(b []byte) error
- type DataplaneValidationError
- type Dataplane_Networking
- func (*Dataplane_Networking) Descriptor() ([]byte, []int)
- func (m *Dataplane_Networking) GetAddress() string
- func (m *Dataplane_Networking) GetGateway() *Dataplane_Networking_Gateway
- func (m *Dataplane_Networking) GetInbound() []*Dataplane_Networking_Inbound
- func (n *Dataplane_Networking) GetInboundInterface(service string) (*InboundInterface, error)
- func (n *Dataplane_Networking) GetInboundInterfaces() ([]InboundInterface, error)
- func (m *Dataplane_Networking) GetIngress() *Dataplane_Networking_Ingress
- func (m *Dataplane_Networking) GetOutbound() []*Dataplane_Networking_Outbound
- func (n *Dataplane_Networking) GetOutboundInterfaces() ([]OutboundInterface, error)
- func (m *Dataplane_Networking) GetTransparentProxying() *Dataplane_Networking_TransparentProxying
- func (*Dataplane_Networking) ProtoMessage()
- func (m *Dataplane_Networking) Reset()
- func (m *Dataplane_Networking) String() string
- func (n *Dataplane_Networking) ToInboundInterface(inbound *Dataplane_Networking_Inbound) InboundInterface
- func (n *Dataplane_Networking) ToOutboundInterface(outbound *Dataplane_Networking_Outbound) OutboundInterface
- func (m *Dataplane_Networking) Validate() error
- func (m *Dataplane_Networking) XXX_DiscardUnknown()
- func (m *Dataplane_Networking) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Dataplane_Networking) XXX_Merge(src proto.Message)
- func (m *Dataplane_Networking) XXX_Size() int
- func (m *Dataplane_Networking) XXX_Unmarshal(b []byte) error
- type Dataplane_NetworkingValidationError
- func (e Dataplane_NetworkingValidationError) Cause() error
- func (e Dataplane_NetworkingValidationError) Error() string
- func (e Dataplane_NetworkingValidationError) ErrorName() string
- func (e Dataplane_NetworkingValidationError) Field() string
- func (e Dataplane_NetworkingValidationError) Key() bool
- func (e Dataplane_NetworkingValidationError) Reason() string
- type Dataplane_Networking_Gateway
- func (*Dataplane_Networking_Gateway) Descriptor() ([]byte, []int)
- func (m *Dataplane_Networking_Gateway) GetTags() map[string]string
- func (d *Dataplane_Networking_Gateway) MatchTags(selector TagSelector) bool
- func (*Dataplane_Networking_Gateway) ProtoMessage()
- func (m *Dataplane_Networking_Gateway) Reset()
- func (m *Dataplane_Networking_Gateway) String() string
- func (m *Dataplane_Networking_Gateway) Validate() error
- func (m *Dataplane_Networking_Gateway) XXX_DiscardUnknown()
- func (m *Dataplane_Networking_Gateway) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Dataplane_Networking_Gateway) XXX_Merge(src proto.Message)
- func (m *Dataplane_Networking_Gateway) XXX_Size() int
- func (m *Dataplane_Networking_Gateway) XXX_Unmarshal(b []byte) error
- type Dataplane_Networking_GatewayValidationError
- func (e Dataplane_Networking_GatewayValidationError) Cause() error
- func (e Dataplane_Networking_GatewayValidationError) Error() string
- func (e Dataplane_Networking_GatewayValidationError) ErrorName() string
- func (e Dataplane_Networking_GatewayValidationError) Field() string
- func (e Dataplane_Networking_GatewayValidationError) Key() bool
- func (e Dataplane_Networking_GatewayValidationError) Reason() string
- type Dataplane_Networking_Inbound
- func (*Dataplane_Networking_Inbound) Descriptor() ([]byte, []int)
- func (m *Dataplane_Networking_Inbound) GetAddress() string
- func (m *Dataplane_Networking_Inbound) GetPort() uint32
- func (d *Dataplane_Networking_Inbound) GetProtocol() string
- func (d *Dataplane_Networking_Inbound) GetService() string
- func (m *Dataplane_Networking_Inbound) GetServicePort() uint32
- func (m *Dataplane_Networking_Inbound) GetTags() map[string]string
- func (d *Dataplane_Networking_Inbound) MatchTags(selector TagSelector) bool
- func (*Dataplane_Networking_Inbound) ProtoMessage()
- func (m *Dataplane_Networking_Inbound) Reset()
- func (m *Dataplane_Networking_Inbound) String() string
- func (m *Dataplane_Networking_Inbound) Validate() error
- func (m *Dataplane_Networking_Inbound) XXX_DiscardUnknown()
- func (m *Dataplane_Networking_Inbound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Dataplane_Networking_Inbound) XXX_Merge(src proto.Message)
- func (m *Dataplane_Networking_Inbound) XXX_Size() int
- func (m *Dataplane_Networking_Inbound) XXX_Unmarshal(b []byte) error
- type Dataplane_Networking_InboundValidationError
- func (e Dataplane_Networking_InboundValidationError) Cause() error
- func (e Dataplane_Networking_InboundValidationError) Error() string
- func (e Dataplane_Networking_InboundValidationError) ErrorName() string
- func (e Dataplane_Networking_InboundValidationError) Field() string
- func (e Dataplane_Networking_InboundValidationError) Key() bool
- func (e Dataplane_Networking_InboundValidationError) Reason() string
- type Dataplane_Networking_Ingress
- func (*Dataplane_Networking_Ingress) Descriptor() ([]byte, []int)
- func (m *Dataplane_Networking_Ingress) GetAvailableServices() []*Dataplane_Networking_Ingress_AvailableService
- func (*Dataplane_Networking_Ingress) ProtoMessage()
- func (m *Dataplane_Networking_Ingress) Reset()
- func (m *Dataplane_Networking_Ingress) String() string
- func (m *Dataplane_Networking_Ingress) Validate() error
- func (m *Dataplane_Networking_Ingress) XXX_DiscardUnknown()
- func (m *Dataplane_Networking_Ingress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Dataplane_Networking_Ingress) XXX_Merge(src proto.Message)
- func (m *Dataplane_Networking_Ingress) XXX_Size() int
- func (m *Dataplane_Networking_Ingress) XXX_Unmarshal(b []byte) error
- type Dataplane_Networking_IngressValidationError
- func (e Dataplane_Networking_IngressValidationError) Cause() error
- func (e Dataplane_Networking_IngressValidationError) Error() string
- func (e Dataplane_Networking_IngressValidationError) ErrorName() string
- func (e Dataplane_Networking_IngressValidationError) Field() string
- func (e Dataplane_Networking_IngressValidationError) Key() bool
- func (e Dataplane_Networking_IngressValidationError) Reason() string
- type Dataplane_Networking_Ingress_AvailableService
- func (*Dataplane_Networking_Ingress_AvailableService) Descriptor() ([]byte, []int)
- func (m *Dataplane_Networking_Ingress_AvailableService) GetInstances() uint32
- func (m *Dataplane_Networking_Ingress_AvailableService) GetTags() map[string]string
- func (*Dataplane_Networking_Ingress_AvailableService) ProtoMessage()
- func (m *Dataplane_Networking_Ingress_AvailableService) Reset()
- func (m *Dataplane_Networking_Ingress_AvailableService) String() string
- func (m *Dataplane_Networking_Ingress_AvailableService) Validate() error
- func (m *Dataplane_Networking_Ingress_AvailableService) XXX_DiscardUnknown()
- func (m *Dataplane_Networking_Ingress_AvailableService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Dataplane_Networking_Ingress_AvailableService) XXX_Merge(src proto.Message)
- func (m *Dataplane_Networking_Ingress_AvailableService) XXX_Size() int
- func (m *Dataplane_Networking_Ingress_AvailableService) XXX_Unmarshal(b []byte) error
- type Dataplane_Networking_Ingress_AvailableServiceValidationError
- func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Cause() error
- func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Error() string
- func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) ErrorName() string
- func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Field() string
- func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Key() bool
- func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Reason() string
- type Dataplane_Networking_Outbound
- func (*Dataplane_Networking_Outbound) Descriptor() ([]byte, []int)
- func (m *Dataplane_Networking_Outbound) GetAddress() string
- func (m *Dataplane_Networking_Outbound) GetPort() uint32
- func (m *Dataplane_Networking_Outbound) GetService() string
- func (m *Dataplane_Networking_Outbound) GetTags() map[string]string
- func (d *Dataplane_Networking_Outbound) GetTagsIncludingLegacy() map[string]string
- func (d *Dataplane_Networking_Outbound) MatchTags(selector TagSelector) bool
- func (*Dataplane_Networking_Outbound) ProtoMessage()
- func (m *Dataplane_Networking_Outbound) Reset()
- func (m *Dataplane_Networking_Outbound) String() string
- func (m *Dataplane_Networking_Outbound) Validate() error
- func (m *Dataplane_Networking_Outbound) XXX_DiscardUnknown()
- func (m *Dataplane_Networking_Outbound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Dataplane_Networking_Outbound) XXX_Merge(src proto.Message)
- func (m *Dataplane_Networking_Outbound) XXX_Size() int
- func (m *Dataplane_Networking_Outbound) XXX_Unmarshal(b []byte) error
- type Dataplane_Networking_OutboundValidationError
- func (e Dataplane_Networking_OutboundValidationError) Cause() error
- func (e Dataplane_Networking_OutboundValidationError) Error() string
- func (e Dataplane_Networking_OutboundValidationError) ErrorName() string
- func (e Dataplane_Networking_OutboundValidationError) Field() string
- func (e Dataplane_Networking_OutboundValidationError) Key() bool
- func (e Dataplane_Networking_OutboundValidationError) Reason() string
- type Dataplane_Networking_TransparentProxying
- func (*Dataplane_Networking_TransparentProxying) Descriptor() ([]byte, []int)
- func (m *Dataplane_Networking_TransparentProxying) GetDirectAccessServices() []string
- func (m *Dataplane_Networking_TransparentProxying) GetRedirectPort() uint32
- func (*Dataplane_Networking_TransparentProxying) ProtoMessage()
- func (m *Dataplane_Networking_TransparentProxying) Reset()
- func (m *Dataplane_Networking_TransparentProxying) String() string
- func (m *Dataplane_Networking_TransparentProxying) Validate() error
- func (m *Dataplane_Networking_TransparentProxying) XXX_DiscardUnknown()
- func (m *Dataplane_Networking_TransparentProxying) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Dataplane_Networking_TransparentProxying) XXX_Merge(src proto.Message)
- func (m *Dataplane_Networking_TransparentProxying) XXX_Size() int
- func (m *Dataplane_Networking_TransparentProxying) XXX_Unmarshal(b []byte) error
- type Dataplane_Networking_TransparentProxyingValidationError
- func (e Dataplane_Networking_TransparentProxyingValidationError) Cause() error
- func (e Dataplane_Networking_TransparentProxyingValidationError) Error() string
- func (e Dataplane_Networking_TransparentProxyingValidationError) ErrorName() string
- func (e Dataplane_Networking_TransparentProxyingValidationError) Field() string
- func (e Dataplane_Networking_TransparentProxyingValidationError) Key() bool
- func (e Dataplane_Networking_TransparentProxyingValidationError) Reason() string
- type DiscoveryServiceStats
- func (*DiscoveryServiceStats) Descriptor() ([]byte, []int)
- func (m *DiscoveryServiceStats) GetResponsesAcknowledged() uint64
- func (m *DiscoveryServiceStats) GetResponsesRejected() uint64
- func (m *DiscoveryServiceStats) GetResponsesSent() uint64
- func (*DiscoveryServiceStats) ProtoMessage()
- func (m *DiscoveryServiceStats) Reset()
- func (m *DiscoveryServiceStats) String() string
- func (m *DiscoveryServiceStats) XXX_DiscardUnknown()
- func (m *DiscoveryServiceStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DiscoveryServiceStats) XXX_Merge(src proto.Message)
- func (m *DiscoveryServiceStats) XXX_Size() int
- func (m *DiscoveryServiceStats) XXX_Unmarshal(b []byte) error
- type DiscoverySubscription
- func (*DiscoverySubscription) Descriptor() ([]byte, []int)
- func (m *DiscoverySubscription) GetConnectTime() *timestamp.Timestamp
- func (m *DiscoverySubscription) GetControlPlaneInstanceId() string
- func (m *DiscoverySubscription) GetDisconnectTime() *timestamp.Timestamp
- func (m *DiscoverySubscription) GetId() string
- func (m *DiscoverySubscription) GetStatus() *DiscoverySubscriptionStatus
- func (*DiscoverySubscription) ProtoMessage()
- func (m *DiscoverySubscription) Reset()
- func (m *DiscoverySubscription) String() string
- func (m *DiscoverySubscription) XXX_DiscardUnknown()
- func (m *DiscoverySubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DiscoverySubscription) XXX_Merge(src proto.Message)
- func (m *DiscoverySubscription) XXX_Size() int
- func (m *DiscoverySubscription) XXX_Unmarshal(b []byte) error
- type DiscoverySubscriptionStatus
- func (*DiscoverySubscriptionStatus) Descriptor() ([]byte, []int)
- func (m *DiscoverySubscriptionStatus) GetCds() *DiscoveryServiceStats
- func (m *DiscoverySubscriptionStatus) GetEds() *DiscoveryServiceStats
- func (m *DiscoverySubscriptionStatus) GetLastUpdateTime() *timestamp.Timestamp
- func (m *DiscoverySubscriptionStatus) GetLds() *DiscoveryServiceStats
- func (m *DiscoverySubscriptionStatus) GetRds() *DiscoveryServiceStats
- func (m *DiscoverySubscriptionStatus) GetTotal() *DiscoveryServiceStats
- func (*DiscoverySubscriptionStatus) ProtoMessage()
- func (m *DiscoverySubscriptionStatus) Reset()
- func (s *DiscoverySubscriptionStatus) StatsOf(typeUrl string) *DiscoveryServiceStats
- func (m *DiscoverySubscriptionStatus) String() string
- func (m *DiscoverySubscriptionStatus) XXX_DiscardUnknown()
- func (m *DiscoverySubscriptionStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DiscoverySubscriptionStatus) XXX_Merge(src proto.Message)
- func (m *DiscoverySubscriptionStatus) XXX_Size() int
- func (m *DiscoverySubscriptionStatus) XXX_Unmarshal(b []byte) error
- type FaultInjection
- func (*FaultInjection) Descriptor() ([]byte, []int)
- func (m *FaultInjection) GetConf() *FaultInjection_Conf
- func (m *FaultInjection) GetDestinations() []*Selector
- func (m *FaultInjection) GetSources() []*Selector
- func (*FaultInjection) ProtoMessage()
- func (m *FaultInjection) Reset()
- func (m *FaultInjection) SourceTags() (setList []SingleValueTagSet)
- func (m *FaultInjection) String() string
- func (m *FaultInjection) XXX_DiscardUnknown()
- func (m *FaultInjection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FaultInjection) XXX_Merge(src proto.Message)
- func (m *FaultInjection) XXX_Size() int
- func (m *FaultInjection) XXX_Unmarshal(b []byte) error
- type FaultInjection_Conf
- func (*FaultInjection_Conf) Descriptor() ([]byte, []int)
- func (m *FaultInjection_Conf) GetAbort() *FaultInjection_Conf_Abort
- func (m *FaultInjection_Conf) GetDelay() *FaultInjection_Conf_Delay
- func (m *FaultInjection_Conf) GetResponseBandwidth() *FaultInjection_Conf_ResponseBandwidth
- func (*FaultInjection_Conf) ProtoMessage()
- func (m *FaultInjection_Conf) Reset()
- func (m *FaultInjection_Conf) String() string
- func (m *FaultInjection_Conf) XXX_DiscardUnknown()
- func (m *FaultInjection_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FaultInjection_Conf) XXX_Merge(src proto.Message)
- func (m *FaultInjection_Conf) XXX_Size() int
- func (m *FaultInjection_Conf) XXX_Unmarshal(b []byte) error
- type FaultInjection_Conf_Abort
- func (*FaultInjection_Conf_Abort) Descriptor() ([]byte, []int)
- func (m *FaultInjection_Conf_Abort) GetHttpStatus() *wrappers.UInt32Value
- func (m *FaultInjection_Conf_Abort) GetPercentage() *wrappers.DoubleValue
- func (*FaultInjection_Conf_Abort) ProtoMessage()
- func (m *FaultInjection_Conf_Abort) Reset()
- func (m *FaultInjection_Conf_Abort) String() string
- func (m *FaultInjection_Conf_Abort) XXX_DiscardUnknown()
- func (m *FaultInjection_Conf_Abort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FaultInjection_Conf_Abort) XXX_Merge(src proto.Message)
- func (m *FaultInjection_Conf_Abort) XXX_Size() int
- func (m *FaultInjection_Conf_Abort) XXX_Unmarshal(b []byte) error
- type FaultInjection_Conf_Delay
- func (*FaultInjection_Conf_Delay) Descriptor() ([]byte, []int)
- func (m *FaultInjection_Conf_Delay) GetPercentage() *wrappers.DoubleValue
- func (m *FaultInjection_Conf_Delay) GetValue() *duration.Duration
- func (*FaultInjection_Conf_Delay) ProtoMessage()
- func (m *FaultInjection_Conf_Delay) Reset()
- func (m *FaultInjection_Conf_Delay) String() string
- func (m *FaultInjection_Conf_Delay) XXX_DiscardUnknown()
- func (m *FaultInjection_Conf_Delay) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FaultInjection_Conf_Delay) XXX_Merge(src proto.Message)
- func (m *FaultInjection_Conf_Delay) XXX_Size() int
- func (m *FaultInjection_Conf_Delay) XXX_Unmarshal(b []byte) error
- type FaultInjection_Conf_ResponseBandwidth
- func (*FaultInjection_Conf_ResponseBandwidth) Descriptor() ([]byte, []int)
- func (m *FaultInjection_Conf_ResponseBandwidth) GetLimit() *wrappers.StringValue
- func (m *FaultInjection_Conf_ResponseBandwidth) GetPercentage() *wrappers.DoubleValue
- func (*FaultInjection_Conf_ResponseBandwidth) ProtoMessage()
- func (m *FaultInjection_Conf_ResponseBandwidth) Reset()
- func (m *FaultInjection_Conf_ResponseBandwidth) String() string
- func (m *FaultInjection_Conf_ResponseBandwidth) XXX_DiscardUnknown()
- func (m *FaultInjection_Conf_ResponseBandwidth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FaultInjection_Conf_ResponseBandwidth) XXX_Merge(src proto.Message)
- func (m *FaultInjection_Conf_ResponseBandwidth) XXX_Size() int
- func (m *FaultInjection_Conf_ResponseBandwidth) XXX_Unmarshal(b []byte) error
- type FileLoggingBackendConfig
- func (*FileLoggingBackendConfig) Descriptor() ([]byte, []int)
- func (m *FileLoggingBackendConfig) GetPath() string
- func (*FileLoggingBackendConfig) ProtoMessage()
- func (m *FileLoggingBackendConfig) Reset()
- func (m *FileLoggingBackendConfig) String() string
- func (m *FileLoggingBackendConfig) Validate() error
- func (m *FileLoggingBackendConfig) XXX_DiscardUnknown()
- func (m *FileLoggingBackendConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FileLoggingBackendConfig) XXX_Merge(src proto.Message)
- func (m *FileLoggingBackendConfig) XXX_Size() int
- func (m *FileLoggingBackendConfig) XXX_Unmarshal(b []byte) error
- type FileLoggingBackendConfigValidationError
- func (e FileLoggingBackendConfigValidationError) Cause() error
- func (e FileLoggingBackendConfigValidationError) Error() string
- func (e FileLoggingBackendConfigValidationError) ErrorName() string
- func (e FileLoggingBackendConfigValidationError) Field() string
- func (e FileLoggingBackendConfigValidationError) Key() bool
- func (e FileLoggingBackendConfigValidationError) Reason() string
- type HealthCheck
- func (*HealthCheck) Descriptor() ([]byte, []int)
- func (m *HealthCheck) GetConf() *HealthCheck_Conf
- func (m *HealthCheck) GetDestinations() []*Selector
- func (m *HealthCheck) GetSources() []*Selector
- func (*HealthCheck) ProtoMessage()
- func (m *HealthCheck) Reset()
- func (m *HealthCheck) String() string
- func (m *HealthCheck) Validate() error
- func (m *HealthCheck) XXX_DiscardUnknown()
- func (m *HealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthCheck) XXX_Merge(src proto.Message)
- func (m *HealthCheck) XXX_Size() int
- func (m *HealthCheck) XXX_Unmarshal(b []byte) error
- type HealthCheckValidationError
- func (e HealthCheckValidationError) Cause() error
- func (e HealthCheckValidationError) Error() string
- func (e HealthCheckValidationError) ErrorName() string
- func (e HealthCheckValidationError) Field() string
- func (e HealthCheckValidationError) Key() bool
- func (e HealthCheckValidationError) Reason() string
- type HealthCheck_Conf
- func (*HealthCheck_Conf) Descriptor() ([]byte, []int)
- func (m *HealthCheck_Conf) GetHealthyThreshold() uint32
- func (m *HealthCheck_Conf) GetInterval() *duration.Duration
- func (m *HealthCheck_Conf) GetTimeout() *duration.Duration
- func (m *HealthCheck_Conf) GetUnhealthyThreshold() uint32
- func (*HealthCheck_Conf) ProtoMessage()
- func (m *HealthCheck_Conf) Reset()
- func (m *HealthCheck_Conf) String() string
- func (m *HealthCheck_Conf) Validate() error
- func (m *HealthCheck_Conf) XXX_DiscardUnknown()
- func (m *HealthCheck_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthCheck_Conf) XXX_Merge(src proto.Message)
- func (m *HealthCheck_Conf) XXX_Size() int
- func (m *HealthCheck_Conf) XXX_Unmarshal(b []byte) error
- type HealthCheck_ConfValidationError
- func (e HealthCheck_ConfValidationError) Cause() error
- func (e HealthCheck_ConfValidationError) Error() string
- func (e HealthCheck_ConfValidationError) ErrorName() string
- func (e HealthCheck_ConfValidationError) Field() string
- func (e HealthCheck_ConfValidationError) Key() bool
- func (e HealthCheck_ConfValidationError) Reason() string
- type InboundInterface
- type KumaDiscoveryServiceClient
- type KumaDiscoveryServiceServer
- type KumaDiscoveryService_DeltaKumaResourcesClient
- type KumaDiscoveryService_DeltaKumaResourcesServer
- type KumaDiscoveryService_StreamKumaResourcesClient
- type KumaDiscoveryService_StreamKumaResourcesServer
- type KumaResource
- func (*KumaResource) Descriptor() ([]byte, []int)
- func (m *KumaResource) GetMeta() *KumaResource_Meta
- func (m *KumaResource) GetSpec() *any.Any
- func (*KumaResource) ProtoMessage()
- func (m *KumaResource) Reset()
- func (m *KumaResource) String() string
- func (m *KumaResource) Validate() error
- func (m *KumaResource) XXX_DiscardUnknown()
- func (m *KumaResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KumaResource) XXX_Merge(src proto.Message)
- func (m *KumaResource) XXX_Size() int
- func (m *KumaResource) XXX_Unmarshal(b []byte) error
- type KumaResourceValidationError
- func (e KumaResourceValidationError) Cause() error
- func (e KumaResourceValidationError) Error() string
- func (e KumaResourceValidationError) ErrorName() string
- func (e KumaResourceValidationError) Field() string
- func (e KumaResourceValidationError) Key() bool
- func (e KumaResourceValidationError) Reason() string
- type KumaResource_Meta
- func (*KumaResource_Meta) Descriptor() ([]byte, []int)
- func (m *KumaResource_Meta) GetCreationTime() *timestamp.Timestamp
- func (m *KumaResource_Meta) GetMesh() string
- func (m *KumaResource_Meta) GetModificationTime() *timestamp.Timestamp
- func (m *KumaResource_Meta) GetName() string
- func (m *KumaResource_Meta) GetVersion() string
- func (*KumaResource_Meta) ProtoMessage()
- func (m *KumaResource_Meta) Reset()
- func (m *KumaResource_Meta) String() string
- func (m *KumaResource_Meta) Validate() error
- func (m *KumaResource_Meta) XXX_DiscardUnknown()
- func (m *KumaResource_Meta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KumaResource_Meta) XXX_Merge(src proto.Message)
- func (m *KumaResource_Meta) XXX_Size() int
- func (m *KumaResource_Meta) XXX_Unmarshal(b []byte) error
- type KumaResource_MetaValidationError
- func (e KumaResource_MetaValidationError) Cause() error
- func (e KumaResource_MetaValidationError) Error() string
- func (e KumaResource_MetaValidationError) ErrorName() string
- func (e KumaResource_MetaValidationError) Field() string
- func (e KumaResource_MetaValidationError) Key() bool
- func (e KumaResource_MetaValidationError) Reason() string
- type Logging
- func (*Logging) Descriptor() ([]byte, []int)
- func (m *Logging) GetBackends() []*LoggingBackend
- func (m *Logging) GetDefaultBackend() string
- func (*Logging) ProtoMessage()
- func (m *Logging) Reset()
- func (m *Logging) String() string
- func (m *Logging) Validate() error
- func (m *Logging) XXX_DiscardUnknown()
- func (m *Logging) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Logging) XXX_Merge(src proto.Message)
- func (m *Logging) XXX_Size() int
- func (m *Logging) XXX_Unmarshal(b []byte) error
- type LoggingBackend
- func (*LoggingBackend) Descriptor() ([]byte, []int)
- func (m *LoggingBackend) GetConf() *_struct.Struct
- func (m *LoggingBackend) GetFormat() string
- func (m *LoggingBackend) GetName() string
- func (m *LoggingBackend) GetType() string
- func (*LoggingBackend) ProtoMessage()
- func (m *LoggingBackend) Reset()
- func (m *LoggingBackend) String() string
- func (m *LoggingBackend) Validate() error
- func (m *LoggingBackend) XXX_DiscardUnknown()
- func (m *LoggingBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoggingBackend) XXX_Merge(src proto.Message)
- func (m *LoggingBackend) XXX_Size() int
- func (m *LoggingBackend) XXX_Unmarshal(b []byte) error
- type LoggingBackendValidationError
- func (e LoggingBackendValidationError) Cause() error
- func (e LoggingBackendValidationError) Error() string
- func (e LoggingBackendValidationError) ErrorName() string
- func (e LoggingBackendValidationError) Field() string
- func (e LoggingBackendValidationError) Key() bool
- func (e LoggingBackendValidationError) Reason() string
- type LoggingValidationError
- type Mesh
- func (*Mesh) Descriptor() ([]byte, []int)
- func (m *Mesh) GetLogging() *Logging
- func (m *Mesh) GetMetrics() *Metrics
- func (m *Mesh) GetMtls() *Mesh_Mtls
- func (m *Mesh) GetTracing() *Tracing
- func (*Mesh) ProtoMessage()
- func (m *Mesh) Reset()
- func (m *Mesh) String() string
- func (m *Mesh) Validate() error
- func (m *Mesh) XXX_DiscardUnknown()
- func (m *Mesh) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Mesh) XXX_Merge(src proto.Message)
- func (m *Mesh) XXX_Size() int
- func (m *Mesh) XXX_Unmarshal(b []byte) error
- type MeshValidationError
- type Mesh_Mtls
- func (*Mesh_Mtls) Descriptor() ([]byte, []int)
- func (m *Mesh_Mtls) GetBackends() []*CertificateAuthorityBackend
- func (m *Mesh_Mtls) GetEnabledBackend() string
- func (*Mesh_Mtls) ProtoMessage()
- func (m *Mesh_Mtls) Reset()
- func (m *Mesh_Mtls) String() string
- func (m *Mesh_Mtls) Validate() error
- func (m *Mesh_Mtls) XXX_DiscardUnknown()
- func (m *Mesh_Mtls) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Mesh_Mtls) XXX_Merge(src proto.Message)
- func (m *Mesh_Mtls) XXX_Size() int
- func (m *Mesh_Mtls) XXX_Unmarshal(b []byte) error
- type Mesh_MtlsValidationError
- type Metrics
- func (*Metrics) Descriptor() ([]byte, []int)
- func (m *Metrics) GetBackends() []*MetricsBackend
- func (m *Metrics) GetEnabledBackend() string
- func (*Metrics) ProtoMessage()
- func (m *Metrics) Reset()
- func (m *Metrics) String() string
- func (m *Metrics) XXX_DiscardUnknown()
- func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Metrics) XXX_Merge(src proto.Message)
- func (m *Metrics) XXX_Size() int
- func (m *Metrics) XXX_Unmarshal(b []byte) error
- type MetricsBackend
- func (*MetricsBackend) Descriptor() ([]byte, []int)
- func (m *MetricsBackend) GetConf() *_struct.Struct
- func (m *MetricsBackend) GetName() string
- func (m *MetricsBackend) GetType() string
- func (*MetricsBackend) ProtoMessage()
- func (m *MetricsBackend) Reset()
- func (m *MetricsBackend) String() string
- func (m *MetricsBackend) XXX_DiscardUnknown()
- func (m *MetricsBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MetricsBackend) XXX_Merge(src proto.Message)
- func (m *MetricsBackend) XXX_Size() int
- func (m *MetricsBackend) XXX_Unmarshal(b []byte) error
- type MultiValueTagSet
- type OutboundInterface
- type PrometheusMetricsBackendConfig
- func (*PrometheusMetricsBackendConfig) Descriptor() ([]byte, []int)
- func (m *PrometheusMetricsBackendConfig) GetPath() string
- func (m *PrometheusMetricsBackendConfig) GetPort() uint32
- func (m *PrometheusMetricsBackendConfig) GetSkipMTLS() *wrappers.BoolValue
- func (m *PrometheusMetricsBackendConfig) GetTags() map[string]string
- func (*PrometheusMetricsBackendConfig) ProtoMessage()
- func (m *PrometheusMetricsBackendConfig) Reset()
- func (m *PrometheusMetricsBackendConfig) String() string
- func (m *PrometheusMetricsBackendConfig) XXX_DiscardUnknown()
- func (m *PrometheusMetricsBackendConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrometheusMetricsBackendConfig) XXX_Merge(src proto.Message)
- func (m *PrometheusMetricsBackendConfig) XXX_Size() int
- func (m *PrometheusMetricsBackendConfig) XXX_Unmarshal(b []byte) error
- type ProxyTemplate
- func (*ProxyTemplate) Descriptor() ([]byte, []int)
- func (m *ProxyTemplate) GetConf() *ProxyTemplate_Conf
- func (m *ProxyTemplate) GetSelectors() []*Selector
- func (*ProxyTemplate) ProtoMessage()
- func (m *ProxyTemplate) Reset()
- func (m *ProxyTemplate) String() string
- func (m *ProxyTemplate) XXX_DiscardUnknown()
- func (m *ProxyTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProxyTemplate) XXX_Merge(src proto.Message)
- func (m *ProxyTemplate) XXX_Size() int
- func (m *ProxyTemplate) XXX_Unmarshal(b []byte) error
- type ProxyTemplateProfileSource
- func (*ProxyTemplateProfileSource) Descriptor() ([]byte, []int)
- func (m *ProxyTemplateProfileSource) GetName() string
- func (m *ProxyTemplateProfileSource) GetParams() map[string]string
- func (*ProxyTemplateProfileSource) ProtoMessage()
- func (m *ProxyTemplateProfileSource) Reset()
- func (m *ProxyTemplateProfileSource) String() string
- func (m *ProxyTemplateProfileSource) XXX_DiscardUnknown()
- func (m *ProxyTemplateProfileSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProxyTemplateProfileSource) XXX_Merge(src proto.Message)
- func (m *ProxyTemplateProfileSource) XXX_Size() int
- func (m *ProxyTemplateProfileSource) XXX_Unmarshal(b []byte) error
- type ProxyTemplateRawResource
- func (*ProxyTemplateRawResource) Descriptor() ([]byte, []int)
- func (m *ProxyTemplateRawResource) GetName() string
- func (m *ProxyTemplateRawResource) GetResource() string
- func (m *ProxyTemplateRawResource) GetVersion() string
- func (*ProxyTemplateRawResource) ProtoMessage()
- func (m *ProxyTemplateRawResource) Reset()
- func (m *ProxyTemplateRawResource) String() string
- func (m *ProxyTemplateRawResource) XXX_DiscardUnknown()
- func (m *ProxyTemplateRawResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProxyTemplateRawResource) XXX_Merge(src proto.Message)
- func (m *ProxyTemplateRawResource) XXX_Size() int
- func (m *ProxyTemplateRawResource) XXX_Unmarshal(b []byte) error
- type ProxyTemplateRawSource
- func (*ProxyTemplateRawSource) Descriptor() ([]byte, []int)
- func (m *ProxyTemplateRawSource) GetResources() []*ProxyTemplateRawResource
- func (*ProxyTemplateRawSource) ProtoMessage()
- func (m *ProxyTemplateRawSource) Reset()
- func (m *ProxyTemplateRawSource) String() string
- func (m *ProxyTemplateRawSource) XXX_DiscardUnknown()
- func (m *ProxyTemplateRawSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProxyTemplateRawSource) XXX_Merge(src proto.Message)
- func (m *ProxyTemplateRawSource) XXX_Size() int
- func (m *ProxyTemplateRawSource) XXX_Unmarshal(b []byte) error
- type ProxyTemplateSource
- func (*ProxyTemplateSource) Descriptor() ([]byte, []int)
- func (m *ProxyTemplateSource) GetName() string
- func (m *ProxyTemplateSource) GetProfile() *ProxyTemplateProfileSource
- func (m *ProxyTemplateSource) GetRaw() *ProxyTemplateRawSource
- func (m *ProxyTemplateSource) GetType() isProxyTemplateSource_Type
- func (*ProxyTemplateSource) ProtoMessage()
- func (m *ProxyTemplateSource) Reset()
- func (m *ProxyTemplateSource) String() string
- func (m *ProxyTemplateSource) XXX_DiscardUnknown()
- func (m *ProxyTemplateSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProxyTemplateSource) XXX_Merge(src proto.Message)
- func (*ProxyTemplateSource) XXX_OneofWrappers() []interface{}
- func (m *ProxyTemplateSource) XXX_Size() int
- func (m *ProxyTemplateSource) XXX_Unmarshal(b []byte) error
- type ProxyTemplateSource_Profile
- type ProxyTemplateSource_Raw
- type ProxyTemplate_Conf
- func (*ProxyTemplate_Conf) Descriptor() ([]byte, []int)
- func (m *ProxyTemplate_Conf) GetImports() []string
- func (m *ProxyTemplate_Conf) GetResources() []*ProxyTemplateRawResource
- func (*ProxyTemplate_Conf) ProtoMessage()
- func (m *ProxyTemplate_Conf) Reset()
- func (m *ProxyTemplate_Conf) String() string
- func (m *ProxyTemplate_Conf) XXX_DiscardUnknown()
- func (m *ProxyTemplate_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProxyTemplate_Conf) XXX_Merge(src proto.Message)
- func (m *ProxyTemplate_Conf) XXX_Size() int
- func (m *ProxyTemplate_Conf) XXX_Unmarshal(b []byte) error
- type Selector
- func (*Selector) Descriptor() ([]byte, []int)
- func (m *Selector) GetMatch() map[string]string
- func (*Selector) ProtoMessage()
- func (m *Selector) Reset()
- func (m *Selector) String() string
- func (m *Selector) XXX_DiscardUnknown()
- func (m *Selector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Selector) XXX_Merge(src proto.Message)
- func (m *Selector) XXX_Size() int
- func (m *Selector) XXX_Unmarshal(b []byte) error
- type SingleValueTagSet
- type TagSelector
- type TagSelectorRank
- type TcpLoggingBackendConfig
- func (*TcpLoggingBackendConfig) Descriptor() ([]byte, []int)
- func (m *TcpLoggingBackendConfig) GetAddress() string
- func (*TcpLoggingBackendConfig) ProtoMessage()
- func (m *TcpLoggingBackendConfig) Reset()
- func (m *TcpLoggingBackendConfig) String() string
- func (m *TcpLoggingBackendConfig) Validate() error
- func (m *TcpLoggingBackendConfig) XXX_DiscardUnknown()
- func (m *TcpLoggingBackendConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TcpLoggingBackendConfig) XXX_Merge(src proto.Message)
- func (m *TcpLoggingBackendConfig) XXX_Size() int
- func (m *TcpLoggingBackendConfig) XXX_Unmarshal(b []byte) error
- type TcpLoggingBackendConfigValidationError
- func (e TcpLoggingBackendConfigValidationError) Cause() error
- func (e TcpLoggingBackendConfigValidationError) Error() string
- func (e TcpLoggingBackendConfigValidationError) ErrorName() string
- func (e TcpLoggingBackendConfigValidationError) Field() string
- func (e TcpLoggingBackendConfigValidationError) Key() bool
- func (e TcpLoggingBackendConfigValidationError) Reason() string
- type Tracing
- func (*Tracing) Descriptor() ([]byte, []int)
- func (m *Tracing) GetBackends() []*TracingBackend
- func (m *Tracing) GetDefaultBackend() string
- func (*Tracing) ProtoMessage()
- func (m *Tracing) Reset()
- func (m *Tracing) String() string
- func (m *Tracing) Validate() error
- func (m *Tracing) XXX_DiscardUnknown()
- func (m *Tracing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Tracing) XXX_Merge(src proto.Message)
- func (m *Tracing) XXX_Size() int
- func (m *Tracing) XXX_Unmarshal(b []byte) error
- type TracingBackend
- func (*TracingBackend) Descriptor() ([]byte, []int)
- func (m *TracingBackend) GetConf() *_struct.Struct
- func (m *TracingBackend) GetName() string
- func (m *TracingBackend) GetSampling() *wrappers.DoubleValue
- func (m *TracingBackend) GetType() string
- func (*TracingBackend) ProtoMessage()
- func (m *TracingBackend) Reset()
- func (m *TracingBackend) String() string
- func (m *TracingBackend) Validate() error
- func (m *TracingBackend) XXX_DiscardUnknown()
- func (m *TracingBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TracingBackend) XXX_Merge(src proto.Message)
- func (m *TracingBackend) XXX_Size() int
- func (m *TracingBackend) XXX_Unmarshal(b []byte) error
- type TracingBackendValidationError
- func (e TracingBackendValidationError) Cause() error
- func (e TracingBackendValidationError) Error() string
- func (e TracingBackendValidationError) ErrorName() string
- func (e TracingBackendValidationError) Field() string
- func (e TracingBackendValidationError) Key() bool
- func (e TracingBackendValidationError) Reason() string
- type TracingValidationError
- type TrafficLog
- func (*TrafficLog) Descriptor() ([]byte, []int)
- func (m *TrafficLog) GetConf() *TrafficLog_Conf
- func (m *TrafficLog) GetDestinations() []*Selector
- func (m *TrafficLog) GetSources() []*Selector
- func (*TrafficLog) ProtoMessage()
- func (m *TrafficLog) Reset()
- func (m *TrafficLog) String() string
- func (m *TrafficLog) XXX_DiscardUnknown()
- func (m *TrafficLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TrafficLog) XXX_Merge(src proto.Message)
- func (m *TrafficLog) XXX_Size() int
- func (m *TrafficLog) XXX_Unmarshal(b []byte) error
- type TrafficLog_Conf
- func (*TrafficLog_Conf) Descriptor() ([]byte, []int)
- func (m *TrafficLog_Conf) GetBackend() string
- func (*TrafficLog_Conf) ProtoMessage()
- func (m *TrafficLog_Conf) Reset()
- func (m *TrafficLog_Conf) String() string
- func (m *TrafficLog_Conf) XXX_DiscardUnknown()
- func (m *TrafficLog_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TrafficLog_Conf) XXX_Merge(src proto.Message)
- func (m *TrafficLog_Conf) XXX_Size() int
- func (m *TrafficLog_Conf) XXX_Unmarshal(b []byte) error
- type TrafficPermission
- func (*TrafficPermission) Descriptor() ([]byte, []int)
- func (m *TrafficPermission) GetDestinations() []*Selector
- func (m *TrafficPermission) GetSources() []*Selector
- func (*TrafficPermission) ProtoMessage()
- func (m *TrafficPermission) Reset()
- func (m *TrafficPermission) String() string
- func (m *TrafficPermission) XXX_DiscardUnknown()
- func (m *TrafficPermission) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TrafficPermission) XXX_Merge(src proto.Message)
- func (m *TrafficPermission) XXX_Size() int
- func (m *TrafficPermission) XXX_Unmarshal(b []byte) error
- type TrafficRoute
- func (*TrafficRoute) Descriptor() ([]byte, []int)
- func (m *TrafficRoute) GetConf() []*TrafficRoute_WeightedDestination
- func (m *TrafficRoute) GetDestinations() []*Selector
- func (m *TrafficRoute) GetSources() []*Selector
- func (*TrafficRoute) ProtoMessage()
- func (m *TrafficRoute) Reset()
- func (m *TrafficRoute) String() string
- func (m *TrafficRoute) Validate() error
- func (m *TrafficRoute) XXX_DiscardUnknown()
- func (m *TrafficRoute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TrafficRoute) XXX_Merge(src proto.Message)
- func (m *TrafficRoute) XXX_Size() int
- func (m *TrafficRoute) XXX_Unmarshal(b []byte) error
- type TrafficRouteValidationError
- func (e TrafficRouteValidationError) Cause() error
- func (e TrafficRouteValidationError) Error() string
- func (e TrafficRouteValidationError) ErrorName() string
- func (e TrafficRouteValidationError) Field() string
- func (e TrafficRouteValidationError) Key() bool
- func (e TrafficRouteValidationError) Reason() string
- type TrafficRoute_WeightedDestination
- func (*TrafficRoute_WeightedDestination) Descriptor() ([]byte, []int)
- func (m *TrafficRoute_WeightedDestination) GetDestination() map[string]string
- func (m *TrafficRoute_WeightedDestination) GetWeight() uint32
- func (*TrafficRoute_WeightedDestination) ProtoMessage()
- func (m *TrafficRoute_WeightedDestination) Reset()
- func (m *TrafficRoute_WeightedDestination) String() string
- func (m *TrafficRoute_WeightedDestination) Validate() error
- func (m *TrafficRoute_WeightedDestination) XXX_DiscardUnknown()
- func (m *TrafficRoute_WeightedDestination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TrafficRoute_WeightedDestination) XXX_Merge(src proto.Message)
- func (m *TrafficRoute_WeightedDestination) XXX_Size() int
- func (m *TrafficRoute_WeightedDestination) XXX_Unmarshal(b []byte) error
- type TrafficRoute_WeightedDestinationValidationError
- func (e TrafficRoute_WeightedDestinationValidationError) Cause() error
- func (e TrafficRoute_WeightedDestinationValidationError) Error() string
- func (e TrafficRoute_WeightedDestinationValidationError) ErrorName() string
- func (e TrafficRoute_WeightedDestinationValidationError) Field() string
- func (e TrafficRoute_WeightedDestinationValidationError) Key() bool
- func (e TrafficRoute_WeightedDestinationValidationError) Reason() string
- type TrafficTrace
- func (*TrafficTrace) Descriptor() ([]byte, []int)
- func (m *TrafficTrace) GetConf() *TrafficTrace_Conf
- func (m *TrafficTrace) GetSelectors() []*Selector
- func (*TrafficTrace) ProtoMessage()
- func (m *TrafficTrace) Reset()
- func (m *TrafficTrace) String() string
- func (m *TrafficTrace) XXX_DiscardUnknown()
- func (m *TrafficTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TrafficTrace) XXX_Merge(src proto.Message)
- func (m *TrafficTrace) XXX_Size() int
- func (m *TrafficTrace) XXX_Unmarshal(b []byte) error
- type TrafficTrace_Conf
- func (*TrafficTrace_Conf) Descriptor() ([]byte, []int)
- func (m *TrafficTrace_Conf) GetBackend() string
- func (*TrafficTrace_Conf) ProtoMessage()
- func (m *TrafficTrace_Conf) Reset()
- func (m *TrafficTrace_Conf) String() string
- func (m *TrafficTrace_Conf) XXX_DiscardUnknown()
- func (m *TrafficTrace_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TrafficTrace_Conf) XXX_Merge(src proto.Message)
- func (m *TrafficTrace_Conf) XXX_Size() int
- func (m *TrafficTrace_Conf) XXX_Unmarshal(b []byte) error
- type UnimplementedKumaDiscoveryServiceServer
- func (*UnimplementedKumaDiscoveryServiceServer) DeltaKumaResources(srv KumaDiscoveryService_DeltaKumaResourcesServer) error
- func (*UnimplementedKumaDiscoveryServiceServer) FetchKumaResources(ctx context.Context, req *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
- func (*UnimplementedKumaDiscoveryServiceServer) StreamKumaResources(srv KumaDiscoveryService_StreamKumaResourcesServer) error
- type ZipkinTracingBackendConfig
- func (*ZipkinTracingBackendConfig) Descriptor() ([]byte, []int)
- func (m *ZipkinTracingBackendConfig) GetApiVersion() string
- func (m *ZipkinTracingBackendConfig) GetTraceId128Bit() bool
- func (m *ZipkinTracingBackendConfig) GetUrl() string
- func (*ZipkinTracingBackendConfig) ProtoMessage()
- func (m *ZipkinTracingBackendConfig) Reset()
- func (m *ZipkinTracingBackendConfig) String() string
- func (m *ZipkinTracingBackendConfig) Validate() error
- func (m *ZipkinTracingBackendConfig) XXX_DiscardUnknown()
- func (m *ZipkinTracingBackendConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ZipkinTracingBackendConfig) XXX_Merge(src proto.Message)
- func (m *ZipkinTracingBackendConfig) XXX_Size() int
- func (m *ZipkinTracingBackendConfig) XXX_Unmarshal(b []byte) error
- type ZipkinTracingBackendConfigValidationError
- func (e ZipkinTracingBackendConfigValidationError) Cause() error
- func (e ZipkinTracingBackendConfigValidationError) Error() string
- func (e ZipkinTracingBackendConfigValidationError) ErrorName() string
- func (e ZipkinTracingBackendConfigValidationError) Field() string
- func (e ZipkinTracingBackendConfigValidationError) Key() bool
- func (e ZipkinTracingBackendConfigValidationError) Reason() string
Constants ¶
const ( // Mandatory tag that has a reserved meaning in Kuma. ServiceTag = "service" ServiceUnknown = "unknown" // Mandatory tag that has a reserved meaning in Kuma. ZoneTag = "zone" // Optional tag that has a reserved meaning in Kuma. // If absent, Kuma will treat application's protocol as opaque TCP. ProtocolTag = "protocol" )
const ( LoggingTcpType = "tcp" LoggingFileType = "file" TracingZipkinType = "zipkin" MetricsPrometheusType = "prometheus" )
const MatchAllTag = "*"
Variables ¶
This section is empty.
Functions ¶
func RegisterKumaDiscoveryServiceServer ¶
func RegisterKumaDiscoveryServiceServer(s *grpc.Server, srv KumaDiscoveryServiceServer)
Types ¶
type CertificateAuthorityBackend ¶
type CertificateAuthorityBackend struct { // Name of the backend Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Type of the backend. Has to be one of the loaded plugins (Kuma ships with // builtin and provided) Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // Dataplane certificate settings DpCert *CertificateAuthorityBackend_DpCert `protobuf:"bytes,3,opt,name=dpCert,proto3" json:"dpCert,omitempty"` // Configuration of the backend Conf *_struct.Struct `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CertificateAuthorityBackend defines Certificate Authority backend
func (*CertificateAuthorityBackend) Descriptor ¶
func (*CertificateAuthorityBackend) Descriptor() ([]byte, []int)
func (*CertificateAuthorityBackend) GetConf ¶
func (m *CertificateAuthorityBackend) GetConf() *_struct.Struct
func (*CertificateAuthorityBackend) GetDpCert ¶
func (m *CertificateAuthorityBackend) GetDpCert() *CertificateAuthorityBackend_DpCert
func (*CertificateAuthorityBackend) GetName ¶
func (m *CertificateAuthorityBackend) GetName() string
func (*CertificateAuthorityBackend) GetType ¶
func (m *CertificateAuthorityBackend) GetType() string
func (*CertificateAuthorityBackend) ProtoMessage ¶
func (*CertificateAuthorityBackend) ProtoMessage()
func (*CertificateAuthorityBackend) Reset ¶
func (m *CertificateAuthorityBackend) Reset()
func (*CertificateAuthorityBackend) String ¶
func (m *CertificateAuthorityBackend) String() string
func (*CertificateAuthorityBackend) Validate ¶
func (m *CertificateAuthorityBackend) Validate() error
Validate checks the field values on CertificateAuthorityBackend with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*CertificateAuthorityBackend) XXX_DiscardUnknown ¶
func (m *CertificateAuthorityBackend) XXX_DiscardUnknown()
func (*CertificateAuthorityBackend) XXX_Marshal ¶
func (m *CertificateAuthorityBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CertificateAuthorityBackend) XXX_Merge ¶
func (m *CertificateAuthorityBackend) XXX_Merge(src proto.Message)
func (*CertificateAuthorityBackend) XXX_Size ¶
func (m *CertificateAuthorityBackend) XXX_Size() int
func (*CertificateAuthorityBackend) XXX_Unmarshal ¶
func (m *CertificateAuthorityBackend) XXX_Unmarshal(b []byte) error
type CertificateAuthorityBackendValidationError ¶
type CertificateAuthorityBackendValidationError struct {
// contains filtered or unexported fields
}
CertificateAuthorityBackendValidationError is the validation error returned by CertificateAuthorityBackend.Validate if the designated constraints aren't met.
func (CertificateAuthorityBackendValidationError) Cause ¶
func (e CertificateAuthorityBackendValidationError) Cause() error
Cause function returns cause value.
func (CertificateAuthorityBackendValidationError) Error ¶
func (e CertificateAuthorityBackendValidationError) Error() string
Error satisfies the builtin error interface
func (CertificateAuthorityBackendValidationError) ErrorName ¶
func (e CertificateAuthorityBackendValidationError) ErrorName() string
ErrorName returns error name.
func (CertificateAuthorityBackendValidationError) Field ¶
func (e CertificateAuthorityBackendValidationError) Field() string
Field function returns field value.
func (CertificateAuthorityBackendValidationError) Key ¶
func (e CertificateAuthorityBackendValidationError) Key() bool
Key function returns key value.
func (CertificateAuthorityBackendValidationError) Reason ¶
func (e CertificateAuthorityBackendValidationError) Reason() string
Reason function returns reason value.
type CertificateAuthorityBackend_DpCert ¶
type CertificateAuthorityBackend_DpCert struct { // Rotation settings Rotation *CertificateAuthorityBackend_DpCert_Rotation `protobuf:"bytes,1,opt,name=rotation,proto3" json:"rotation,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
DpCert defines settings for certificates generated for Dataplanes
func (*CertificateAuthorityBackend_DpCert) Descriptor ¶
func (*CertificateAuthorityBackend_DpCert) Descriptor() ([]byte, []int)
func (*CertificateAuthorityBackend_DpCert) GetRotation ¶
func (m *CertificateAuthorityBackend_DpCert) GetRotation() *CertificateAuthorityBackend_DpCert_Rotation
func (*CertificateAuthorityBackend_DpCert) ProtoMessage ¶
func (*CertificateAuthorityBackend_DpCert) ProtoMessage()
func (*CertificateAuthorityBackend_DpCert) Reset ¶
func (m *CertificateAuthorityBackend_DpCert) Reset()
func (*CertificateAuthorityBackend_DpCert) String ¶
func (m *CertificateAuthorityBackend_DpCert) String() string
func (*CertificateAuthorityBackend_DpCert) Validate ¶
func (m *CertificateAuthorityBackend_DpCert) Validate() error
Validate checks the field values on CertificateAuthorityBackend_DpCert with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*CertificateAuthorityBackend_DpCert) XXX_DiscardUnknown ¶
func (m *CertificateAuthorityBackend_DpCert) XXX_DiscardUnknown()
func (*CertificateAuthorityBackend_DpCert) XXX_Marshal ¶
func (m *CertificateAuthorityBackend_DpCert) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CertificateAuthorityBackend_DpCert) XXX_Merge ¶
func (m *CertificateAuthorityBackend_DpCert) XXX_Merge(src proto.Message)
func (*CertificateAuthorityBackend_DpCert) XXX_Size ¶
func (m *CertificateAuthorityBackend_DpCert) XXX_Size() int
func (*CertificateAuthorityBackend_DpCert) XXX_Unmarshal ¶
func (m *CertificateAuthorityBackend_DpCert) XXX_Unmarshal(b []byte) error
type CertificateAuthorityBackend_DpCertValidationError ¶
type CertificateAuthorityBackend_DpCertValidationError struct {
// contains filtered or unexported fields
}
CertificateAuthorityBackend_DpCertValidationError is the validation error returned by CertificateAuthorityBackend_DpCert.Validate if the designated constraints aren't met.
func (CertificateAuthorityBackend_DpCertValidationError) Cause ¶
func (e CertificateAuthorityBackend_DpCertValidationError) Cause() error
Cause function returns cause value.
func (CertificateAuthorityBackend_DpCertValidationError) Error ¶
func (e CertificateAuthorityBackend_DpCertValidationError) Error() string
Error satisfies the builtin error interface
func (CertificateAuthorityBackend_DpCertValidationError) ErrorName ¶
func (e CertificateAuthorityBackend_DpCertValidationError) ErrorName() string
ErrorName returns error name.
func (CertificateAuthorityBackend_DpCertValidationError) Field ¶
func (e CertificateAuthorityBackend_DpCertValidationError) Field() string
Field function returns field value.
func (CertificateAuthorityBackend_DpCertValidationError) Key ¶
func (e CertificateAuthorityBackend_DpCertValidationError) Key() bool
Key function returns key value.
func (CertificateAuthorityBackend_DpCertValidationError) Reason ¶
func (e CertificateAuthorityBackend_DpCertValidationError) Reason() string
Reason function returns reason value.
type CertificateAuthorityBackend_DpCert_Rotation ¶
type CertificateAuthorityBackend_DpCert_Rotation struct { // Time after which generated certificate for Dataplane will expire Expiration string `protobuf:"bytes,1,opt,name=expiration,proto3" json:"expiration,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Rotation defines rotation settings for Dataplane certificate
func (*CertificateAuthorityBackend_DpCert_Rotation) Descriptor ¶
func (*CertificateAuthorityBackend_DpCert_Rotation) Descriptor() ([]byte, []int)
func (*CertificateAuthorityBackend_DpCert_Rotation) GetExpiration ¶
func (m *CertificateAuthorityBackend_DpCert_Rotation) GetExpiration() string
func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage ¶
func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage()
func (*CertificateAuthorityBackend_DpCert_Rotation) Reset ¶
func (m *CertificateAuthorityBackend_DpCert_Rotation) Reset()
func (*CertificateAuthorityBackend_DpCert_Rotation) String ¶
func (m *CertificateAuthorityBackend_DpCert_Rotation) String() string
func (*CertificateAuthorityBackend_DpCert_Rotation) Validate ¶
func (m *CertificateAuthorityBackend_DpCert_Rotation) Validate() error
Validate checks the field values on CertificateAuthorityBackend_DpCert_Rotation with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*CertificateAuthorityBackend_DpCert_Rotation) XXX_DiscardUnknown ¶
func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_DiscardUnknown()
func (*CertificateAuthorityBackend_DpCert_Rotation) XXX_Marshal ¶
func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CertificateAuthorityBackend_DpCert_Rotation) XXX_Merge ¶
func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_Merge(src proto.Message)
func (*CertificateAuthorityBackend_DpCert_Rotation) XXX_Size ¶
func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_Size() int
func (*CertificateAuthorityBackend_DpCert_Rotation) XXX_Unmarshal ¶
func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_Unmarshal(b []byte) error
type CertificateAuthorityBackend_DpCert_RotationValidationError ¶
type CertificateAuthorityBackend_DpCert_RotationValidationError struct {
// contains filtered or unexported fields
}
CertificateAuthorityBackend_DpCert_RotationValidationError is the validation error returned by CertificateAuthorityBackend_DpCert_Rotation.Validate if the designated constraints aren't met.
func (CertificateAuthorityBackend_DpCert_RotationValidationError) Cause ¶
func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Cause() error
Cause function returns cause value.
func (CertificateAuthorityBackend_DpCert_RotationValidationError) Error ¶
func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Error() string
Error satisfies the builtin error interface
func (CertificateAuthorityBackend_DpCert_RotationValidationError) ErrorName ¶
func (e CertificateAuthorityBackend_DpCert_RotationValidationError) ErrorName() string
ErrorName returns error name.
func (CertificateAuthorityBackend_DpCert_RotationValidationError) Field ¶
func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Field() string
Field function returns field value.
func (CertificateAuthorityBackend_DpCert_RotationValidationError) Key ¶
func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Key() bool
Key function returns key value.
func (CertificateAuthorityBackend_DpCert_RotationValidationError) Reason ¶
func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Reason() string
Reason function returns reason value.
type CircuitBreaker ¶
type CircuitBreaker struct { // List of selectors to match dataplanes that are sources of traffic. Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"` // List of selectors to match services that are destinations of traffic. Destinations []*Selector `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"` Conf *CircuitBreaker_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CircuitBreaker defines circuit breaking policy for dataplane's outbound
func (*CircuitBreaker) Descriptor ¶
func (*CircuitBreaker) Descriptor() ([]byte, []int)
func (*CircuitBreaker) GetConf ¶
func (m *CircuitBreaker) GetConf() *CircuitBreaker_Conf
func (*CircuitBreaker) GetDestinations ¶
func (m *CircuitBreaker) GetDestinations() []*Selector
func (*CircuitBreaker) GetSources ¶
func (m *CircuitBreaker) GetSources() []*Selector
func (*CircuitBreaker) ProtoMessage ¶
func (*CircuitBreaker) ProtoMessage()
func (*CircuitBreaker) Reset ¶
func (m *CircuitBreaker) Reset()
func (*CircuitBreaker) String ¶
func (m *CircuitBreaker) String() string
func (*CircuitBreaker) XXX_DiscardUnknown ¶
func (m *CircuitBreaker) XXX_DiscardUnknown()
func (*CircuitBreaker) XXX_Marshal ¶
func (m *CircuitBreaker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CircuitBreaker) XXX_Merge ¶
func (m *CircuitBreaker) XXX_Merge(src proto.Message)
func (*CircuitBreaker) XXX_Size ¶
func (m *CircuitBreaker) XXX_Size() int
func (*CircuitBreaker) XXX_Unmarshal ¶
func (m *CircuitBreaker) XXX_Unmarshal(b []byte) error
type CircuitBreaker_Conf ¶
type CircuitBreaker_Conf struct { // Time interval between ejection analysis sweeps Interval *duration.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"` // The base time that a host is ejected for. The real time is equal to the // base time multiplied by the number of times the host has been ejected BaseEjectionTime *duration.Duration `protobuf:"bytes,2,opt,name=baseEjectionTime,proto3" json:"baseEjectionTime,omitempty"` // The maximum percent of an upstream cluster that can be ejected due to // outlier detection, has to be in [0 - 100] range MaxEjectionPercent *wrappers.UInt32Value `protobuf:"bytes,3,opt,name=maxEjectionPercent,proto3" json:"maxEjectionPercent,omitempty"` // Enables Split Mode in which local and external errors are distinguished SplitExternalAndLocalErrors bool `protobuf:"varint,4,opt,name=splitExternalAndLocalErrors,proto3" json:"splitExternalAndLocalErrors,omitempty"` Detectors *CircuitBreaker_Conf_Detectors `protobuf:"bytes,5,opt,name=detectors,proto3" json:"detectors,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CircuitBreaker_Conf) Descriptor ¶
func (*CircuitBreaker_Conf) Descriptor() ([]byte, []int)
func (*CircuitBreaker_Conf) GetBaseEjectionTime ¶
func (m *CircuitBreaker_Conf) GetBaseEjectionTime() *duration.Duration
func (*CircuitBreaker_Conf) GetDetectors ¶
func (m *CircuitBreaker_Conf) GetDetectors() *CircuitBreaker_Conf_Detectors
func (*CircuitBreaker_Conf) GetInterval ¶
func (m *CircuitBreaker_Conf) GetInterval() *duration.Duration
func (*CircuitBreaker_Conf) GetMaxEjectionPercent ¶
func (m *CircuitBreaker_Conf) GetMaxEjectionPercent() *wrappers.UInt32Value
func (*CircuitBreaker_Conf) GetSplitExternalAndLocalErrors ¶
func (m *CircuitBreaker_Conf) GetSplitExternalAndLocalErrors() bool
func (*CircuitBreaker_Conf) ProtoMessage ¶
func (*CircuitBreaker_Conf) ProtoMessage()
func (*CircuitBreaker_Conf) Reset ¶
func (m *CircuitBreaker_Conf) Reset()
func (*CircuitBreaker_Conf) String ¶
func (m *CircuitBreaker_Conf) String() string
func (*CircuitBreaker_Conf) XXX_DiscardUnknown ¶
func (m *CircuitBreaker_Conf) XXX_DiscardUnknown()
func (*CircuitBreaker_Conf) XXX_Marshal ¶
func (m *CircuitBreaker_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CircuitBreaker_Conf) XXX_Merge ¶
func (m *CircuitBreaker_Conf) XXX_Merge(src proto.Message)
func (*CircuitBreaker_Conf) XXX_Size ¶
func (m *CircuitBreaker_Conf) XXX_Size() int
func (*CircuitBreaker_Conf) XXX_Unmarshal ¶
func (m *CircuitBreaker_Conf) XXX_Unmarshal(b []byte) error
type CircuitBreaker_Conf_Detectors ¶
type CircuitBreaker_Conf_Detectors struct { // Errors with status code 5xx and locally originated errors, in Split // Mode - just errors with status code 5xx TotalErrors *CircuitBreaker_Conf_Detectors_Errors `protobuf:"bytes,1,opt,name=totalErrors,proto3" json:"totalErrors,omitempty"` // Subset of 'total' related to gateway errors (502, 503 or 504 status // code) GatewayErrors *CircuitBreaker_Conf_Detectors_Errors `protobuf:"bytes,2,opt,name=gatewayErrors,proto3" json:"gatewayErrors,omitempty"` // Takes into account only in Split Mode, number of locally originated // errors LocalErrors *CircuitBreaker_Conf_Detectors_Errors `protobuf:"bytes,3,opt,name=localErrors,proto3" json:"localErrors,omitempty"` StandardDeviation *CircuitBreaker_Conf_Detectors_StandardDeviation `protobuf:"bytes,4,opt,name=standardDeviation,proto3" json:"standardDeviation,omitempty"` Failure *CircuitBreaker_Conf_Detectors_Failure `protobuf:"bytes,5,opt,name=failure,proto3" json:"failure,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CircuitBreaker_Conf_Detectors) Descriptor ¶
func (*CircuitBreaker_Conf_Detectors) Descriptor() ([]byte, []int)
func (*CircuitBreaker_Conf_Detectors) GetFailure ¶
func (m *CircuitBreaker_Conf_Detectors) GetFailure() *CircuitBreaker_Conf_Detectors_Failure
func (*CircuitBreaker_Conf_Detectors) GetGatewayErrors ¶
func (m *CircuitBreaker_Conf_Detectors) GetGatewayErrors() *CircuitBreaker_Conf_Detectors_Errors
func (*CircuitBreaker_Conf_Detectors) GetLocalErrors ¶
func (m *CircuitBreaker_Conf_Detectors) GetLocalErrors() *CircuitBreaker_Conf_Detectors_Errors
func (*CircuitBreaker_Conf_Detectors) GetStandardDeviation ¶
func (m *CircuitBreaker_Conf_Detectors) GetStandardDeviation() *CircuitBreaker_Conf_Detectors_StandardDeviation
func (*CircuitBreaker_Conf_Detectors) GetTotalErrors ¶
func (m *CircuitBreaker_Conf_Detectors) GetTotalErrors() *CircuitBreaker_Conf_Detectors_Errors
func (*CircuitBreaker_Conf_Detectors) ProtoMessage ¶
func (*CircuitBreaker_Conf_Detectors) ProtoMessage()
func (*CircuitBreaker_Conf_Detectors) Reset ¶
func (m *CircuitBreaker_Conf_Detectors) Reset()
func (*CircuitBreaker_Conf_Detectors) String ¶
func (m *CircuitBreaker_Conf_Detectors) String() string
func (*CircuitBreaker_Conf_Detectors) XXX_DiscardUnknown ¶
func (m *CircuitBreaker_Conf_Detectors) XXX_DiscardUnknown()
func (*CircuitBreaker_Conf_Detectors) XXX_Marshal ¶
func (m *CircuitBreaker_Conf_Detectors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CircuitBreaker_Conf_Detectors) XXX_Merge ¶
func (m *CircuitBreaker_Conf_Detectors) XXX_Merge(src proto.Message)
func (*CircuitBreaker_Conf_Detectors) XXX_Size ¶
func (m *CircuitBreaker_Conf_Detectors) XXX_Size() int
func (*CircuitBreaker_Conf_Detectors) XXX_Unmarshal ¶
func (m *CircuitBreaker_Conf_Detectors) XXX_Unmarshal(b []byte) error
type CircuitBreaker_Conf_Detectors_Errors ¶
type CircuitBreaker_Conf_Detectors_Errors struct { Consecutive *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=consecutive,proto3" json:"consecutive,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Detector based on counting consecutive number of errors
func (*CircuitBreaker_Conf_Detectors_Errors) Descriptor ¶
func (*CircuitBreaker_Conf_Detectors_Errors) Descriptor() ([]byte, []int)
func (*CircuitBreaker_Conf_Detectors_Errors) GetConsecutive ¶
func (m *CircuitBreaker_Conf_Detectors_Errors) GetConsecutive() *wrappers.UInt32Value
func (*CircuitBreaker_Conf_Detectors_Errors) ProtoMessage ¶
func (*CircuitBreaker_Conf_Detectors_Errors) ProtoMessage()
func (*CircuitBreaker_Conf_Detectors_Errors) Reset ¶
func (m *CircuitBreaker_Conf_Detectors_Errors) Reset()
func (*CircuitBreaker_Conf_Detectors_Errors) String ¶
func (m *CircuitBreaker_Conf_Detectors_Errors) String() string
func (*CircuitBreaker_Conf_Detectors_Errors) XXX_DiscardUnknown ¶
func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_DiscardUnknown()
func (*CircuitBreaker_Conf_Detectors_Errors) XXX_Marshal ¶
func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CircuitBreaker_Conf_Detectors_Errors) XXX_Merge ¶
func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_Merge(src proto.Message)
func (*CircuitBreaker_Conf_Detectors_Errors) XXX_Size ¶
func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_Size() int
func (*CircuitBreaker_Conf_Detectors_Errors) XXX_Unmarshal ¶
func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_Unmarshal(b []byte) error
type CircuitBreaker_Conf_Detectors_Failure ¶
type CircuitBreaker_Conf_Detectors_Failure struct { // Ignore hosts with less number of requests than 'requestVolume' RequestVolume *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=requestVolume,proto3" json:"requestVolume,omitempty"` // Won't count success rate for cluster if number of hosts with required // 'requestVolume' is less than 'minimumHosts' MinimumHosts *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=minimumHosts,proto3" json:"minimumHosts,omitempty"` // Eject host if failure percentage of a given host is greater than or // equal to this value, has to be in [0 - 100] range Threshold *wrappers.UInt32Value `protobuf:"bytes,3,opt,name=threshold,proto3" json:"threshold,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Detection based on success rate, but threshold is set explicitly (unlike 'standardDeviation')
func (*CircuitBreaker_Conf_Detectors_Failure) Descriptor ¶
func (*CircuitBreaker_Conf_Detectors_Failure) Descriptor() ([]byte, []int)
func (*CircuitBreaker_Conf_Detectors_Failure) GetMinimumHosts ¶
func (m *CircuitBreaker_Conf_Detectors_Failure) GetMinimumHosts() *wrappers.UInt32Value
func (*CircuitBreaker_Conf_Detectors_Failure) GetRequestVolume ¶
func (m *CircuitBreaker_Conf_Detectors_Failure) GetRequestVolume() *wrappers.UInt32Value
func (*CircuitBreaker_Conf_Detectors_Failure) GetThreshold ¶
func (m *CircuitBreaker_Conf_Detectors_Failure) GetThreshold() *wrappers.UInt32Value
func (*CircuitBreaker_Conf_Detectors_Failure) ProtoMessage ¶
func (*CircuitBreaker_Conf_Detectors_Failure) ProtoMessage()
func (*CircuitBreaker_Conf_Detectors_Failure) Reset ¶
func (m *CircuitBreaker_Conf_Detectors_Failure) Reset()
func (*CircuitBreaker_Conf_Detectors_Failure) String ¶
func (m *CircuitBreaker_Conf_Detectors_Failure) String() string
func (*CircuitBreaker_Conf_Detectors_Failure) XXX_DiscardUnknown ¶
func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_DiscardUnknown()
func (*CircuitBreaker_Conf_Detectors_Failure) XXX_Marshal ¶
func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CircuitBreaker_Conf_Detectors_Failure) XXX_Merge ¶
func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_Merge(src proto.Message)
func (*CircuitBreaker_Conf_Detectors_Failure) XXX_Size ¶
func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_Size() int
func (*CircuitBreaker_Conf_Detectors_Failure) XXX_Unmarshal ¶
func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_Unmarshal(b []byte) error
type CircuitBreaker_Conf_Detectors_StandardDeviation ¶
type CircuitBreaker_Conf_Detectors_StandardDeviation struct { // Ignore hosts with less number of requests than 'requestVolume' RequestVolume *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=requestVolume,proto3" json:"requestVolume,omitempty"` // Won't count success rate for cluster if number of hosts with required // 'requestVolume' is less than 'minimumHosts' MinimumHosts *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=minimumHosts,proto3" json:"minimumHosts,omitempty"` // Resulting threshold = mean - (stdev * factor) Factor *wrappers.DoubleValue `protobuf:"bytes,3,opt,name=factor,proto3" json:"factor,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Detection based on success rate, aggregated from every host in the cluser
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) Descriptor ¶
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) Descriptor() ([]byte, []int)
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) GetFactor ¶
func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) GetFactor() *wrappers.DoubleValue
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) GetMinimumHosts ¶
func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) GetMinimumHosts() *wrappers.UInt32Value
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) GetRequestVolume ¶
func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) GetRequestVolume() *wrappers.UInt32Value
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) ProtoMessage ¶
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) ProtoMessage()
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) Reset ¶
func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) Reset()
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) String ¶
func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) String() string
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_DiscardUnknown ¶
func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_DiscardUnknown()
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Marshal ¶
func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Merge ¶
func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Merge(src proto.Message)
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Size ¶
func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Size() int
func (*CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Unmarshal ¶
func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Unmarshal(b []byte) error
type Dataplane ¶
type Dataplane struct { // Networking describes inbound and outbound interfaces of the dataplane. Networking *Dataplane_Networking `protobuf:"bytes,1,opt,name=networking,proto3" json:"networking,omitempty"` // Configuration for metrics that should be collected and exposed by the // dataplane. // // Settings defined here will override their respective defaults // defined at a Mesh level. Metrics *MetricsBackend `protobuf:"bytes,2,opt,name=metrics,proto3" json:"metrics,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Dataplane defines configuration of a side-car proxy.
func (*Dataplane) Descriptor ¶
func (*Dataplane) GetIdentifyingService ¶
func (*Dataplane) GetMetrics ¶
func (m *Dataplane) GetMetrics() *MetricsBackend
func (*Dataplane) GetNetworking ¶
func (m *Dataplane) GetNetworking() *Dataplane_Networking
func (*Dataplane) HasAvailableServices ¶
func (*Dataplane) IsRemoteIngress ¶
func (*Dataplane) MatchTags ¶
func (d *Dataplane) MatchTags(selector TagSelector) bool
func (*Dataplane) Matches ¶
func (d *Dataplane) Matches(selector TagSelector) bool
Matches is simply an alias for MatchTags to make source code more aesthetic.
func (*Dataplane) ProtoMessage ¶
func (*Dataplane) ProtoMessage()
func (*Dataplane) Tags ¶
func (d *Dataplane) Tags() MultiValueTagSet
func (*Dataplane) Validate ¶
Validate checks the field values on Dataplane with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Dataplane) XXX_DiscardUnknown ¶
func (m *Dataplane) XXX_DiscardUnknown()
func (*Dataplane) XXX_Marshal ¶
func (*Dataplane) XXX_Unmarshal ¶
type DataplaneInsight ¶
type DataplaneInsight struct { // List of ADS subscriptions created by a given Dataplane. Subscriptions []*DiscoverySubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` // Insights about mTLS for Dataplane. MTLS *DataplaneInsight_MTLS `protobuf:"bytes,2,opt,name=mTLS,proto3" json:"mTLS,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
DataplaneInsight defines the observed state of a Dataplane.
func (*DataplaneInsight) Descriptor ¶
func (*DataplaneInsight) Descriptor() ([]byte, []int)
func (*DataplaneInsight) GetLatestSubscription ¶
func (ds *DataplaneInsight) GetLatestSubscription() (*DiscoverySubscription, *time.Time)
func (*DataplaneInsight) GetMTLS ¶
func (m *DataplaneInsight) GetMTLS() *DataplaneInsight_MTLS
func (*DataplaneInsight) GetSubscription ¶
func (ds *DataplaneInsight) GetSubscription(id string) (int, *DiscoverySubscription)
func (*DataplaneInsight) GetSubscriptions ¶
func (m *DataplaneInsight) GetSubscriptions() []*DiscoverySubscription
func (*DataplaneInsight) IsOnline ¶
func (ds *DataplaneInsight) IsOnline() bool
func (*DataplaneInsight) ProtoMessage ¶
func (*DataplaneInsight) ProtoMessage()
func (*DataplaneInsight) Reset ¶
func (m *DataplaneInsight) Reset()
func (*DataplaneInsight) String ¶
func (m *DataplaneInsight) String() string
func (*DataplaneInsight) Sum ¶
func (ds *DataplaneInsight) Sum(v func(*DiscoverySubscription) uint64) uint64
func (*DataplaneInsight) UpdateCert ¶
func (*DataplaneInsight) UpdateSubscription ¶
func (ds *DataplaneInsight) UpdateSubscription(s *DiscoverySubscription)
func (*DataplaneInsight) XXX_DiscardUnknown ¶
func (m *DataplaneInsight) XXX_DiscardUnknown()
func (*DataplaneInsight) XXX_Marshal ¶
func (m *DataplaneInsight) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataplaneInsight) XXX_Merge ¶
func (m *DataplaneInsight) XXX_Merge(src proto.Message)
func (*DataplaneInsight) XXX_Size ¶
func (m *DataplaneInsight) XXX_Size() int
func (*DataplaneInsight) XXX_Unmarshal ¶
func (m *DataplaneInsight) XXX_Unmarshal(b []byte) error
type DataplaneInsight_MTLS ¶
type DataplaneInsight_MTLS struct { // Expiration time of the last certificate that was generated for a // Dataplane. CertificateExpirationTime *timestamp.Timestamp `` /* 138-byte string literal not displayed */ // Time on which the last certificate was generated. LastCertificateRegeneration *timestamp.Timestamp `` /* 144-byte string literal not displayed */ // Number of certificate regenerations for a Dataplane. CertificateRegenerations uint32 `` /* 134-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
MTLS defines insights for mTLS
func (*DataplaneInsight_MTLS) Descriptor ¶
func (*DataplaneInsight_MTLS) Descriptor() ([]byte, []int)
func (*DataplaneInsight_MTLS) GetCertificateExpirationTime ¶
func (m *DataplaneInsight_MTLS) GetCertificateExpirationTime() *timestamp.Timestamp
func (*DataplaneInsight_MTLS) GetCertificateRegenerations ¶
func (m *DataplaneInsight_MTLS) GetCertificateRegenerations() uint32
func (*DataplaneInsight_MTLS) GetLastCertificateRegeneration ¶
func (m *DataplaneInsight_MTLS) GetLastCertificateRegeneration() *timestamp.Timestamp
func (*DataplaneInsight_MTLS) ProtoMessage ¶
func (*DataplaneInsight_MTLS) ProtoMessage()
func (*DataplaneInsight_MTLS) Reset ¶
func (m *DataplaneInsight_MTLS) Reset()
func (*DataplaneInsight_MTLS) String ¶
func (m *DataplaneInsight_MTLS) String() string
func (*DataplaneInsight_MTLS) XXX_DiscardUnknown ¶
func (m *DataplaneInsight_MTLS) XXX_DiscardUnknown()
func (*DataplaneInsight_MTLS) XXX_Marshal ¶
func (m *DataplaneInsight_MTLS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataplaneInsight_MTLS) XXX_Merge ¶
func (m *DataplaneInsight_MTLS) XXX_Merge(src proto.Message)
func (*DataplaneInsight_MTLS) XXX_Size ¶
func (m *DataplaneInsight_MTLS) XXX_Size() int
func (*DataplaneInsight_MTLS) XXX_Unmarshal ¶
func (m *DataplaneInsight_MTLS) XXX_Unmarshal(b []byte) error
type DataplaneOverview ¶
type DataplaneOverview struct { Dataplane *Dataplane `protobuf:"bytes,1,opt,name=dataplane,proto3" json:"dataplane,omitempty"` DataplaneInsight *DataplaneInsight `protobuf:"bytes,2,opt,name=dataplane_insight,json=dataplaneInsight,proto3" json:"dataplane_insight,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
DataplaneOverview defines the projected state of a Dataplane.
func (*DataplaneOverview) Descriptor ¶
func (*DataplaneOverview) Descriptor() ([]byte, []int)
func (*DataplaneOverview) GetDataplane ¶
func (m *DataplaneOverview) GetDataplane() *Dataplane
func (*DataplaneOverview) GetDataplaneInsight ¶
func (m *DataplaneOverview) GetDataplaneInsight() *DataplaneInsight
func (*DataplaneOverview) ProtoMessage ¶
func (*DataplaneOverview) ProtoMessage()
func (*DataplaneOverview) Reset ¶
func (m *DataplaneOverview) Reset()
func (*DataplaneOverview) String ¶
func (m *DataplaneOverview) String() string
func (*DataplaneOverview) XXX_DiscardUnknown ¶
func (m *DataplaneOverview) XXX_DiscardUnknown()
func (*DataplaneOverview) XXX_Marshal ¶
func (m *DataplaneOverview) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataplaneOverview) XXX_Merge ¶
func (m *DataplaneOverview) XXX_Merge(src proto.Message)
func (*DataplaneOverview) XXX_Size ¶
func (m *DataplaneOverview) XXX_Size() int
func (*DataplaneOverview) XXX_Unmarshal ¶
func (m *DataplaneOverview) XXX_Unmarshal(b []byte) error
type DataplaneValidationError ¶
type DataplaneValidationError struct {
// contains filtered or unexported fields
}
DataplaneValidationError is the validation error returned by Dataplane.Validate if the designated constraints aren't met.
func (DataplaneValidationError) Cause ¶
func (e DataplaneValidationError) Cause() error
Cause function returns cause value.
func (DataplaneValidationError) Error ¶
func (e DataplaneValidationError) Error() string
Error satisfies the builtin error interface
func (DataplaneValidationError) ErrorName ¶
func (e DataplaneValidationError) ErrorName() string
ErrorName returns error name.
func (DataplaneValidationError) Field ¶
func (e DataplaneValidationError) Field() string
Field function returns field value.
func (DataplaneValidationError) Key ¶
func (e DataplaneValidationError) Key() bool
Key function returns key value.
func (DataplaneValidationError) Reason ¶
func (e DataplaneValidationError) Reason() string
Reason function returns reason value.
type Dataplane_Networking ¶
type Dataplane_Networking struct { // Ingress if not nil, dataplane will be work in the Ingress mode Ingress *Dataplane_Networking_Ingress `protobuf:"bytes,6,opt,name=ingress,proto3" json:"ingress,omitempty"` // Public IP on which the dataplane is accessible in the network. // Host names and DNS are not allowed. Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"` // Gateway describes configuration of gateway of the dataplane. Gateway *Dataplane_Networking_Gateway `protobuf:"bytes,3,opt,name=gateway,proto3" json:"gateway,omitempty"` // Inbound describes a list of inbound interfaces of the dataplane. Inbound []*Dataplane_Networking_Inbound `protobuf:"bytes,1,rep,name=inbound,proto3" json:"inbound,omitempty"` // Outbound describes a list of outbound interfaces of the dataplane. Outbound []*Dataplane_Networking_Outbound `protobuf:"bytes,2,rep,name=outbound,proto3" json:"outbound,omitempty"` // TransparentProxying describes configuration for transparent proxying. TransparentProxying *Dataplane_Networking_TransparentProxying `protobuf:"bytes,4,opt,name=transparent_proxying,json=transparentProxying,proto3" json:"transparent_proxying,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Networking describes inbound and outbound interfaces of a dataplane.
func (*Dataplane_Networking) Descriptor ¶
func (*Dataplane_Networking) Descriptor() ([]byte, []int)
func (*Dataplane_Networking) GetAddress ¶
func (m *Dataplane_Networking) GetAddress() string
func (*Dataplane_Networking) GetGateway ¶
func (m *Dataplane_Networking) GetGateway() *Dataplane_Networking_Gateway
func (*Dataplane_Networking) GetInbound ¶
func (m *Dataplane_Networking) GetInbound() []*Dataplane_Networking_Inbound
func (*Dataplane_Networking) GetInboundInterface ¶
func (n *Dataplane_Networking) GetInboundInterface(service string) (*InboundInterface, error)
func (*Dataplane_Networking) GetInboundInterfaces ¶
func (n *Dataplane_Networking) GetInboundInterfaces() ([]InboundInterface, error)
func (*Dataplane_Networking) GetIngress ¶
func (m *Dataplane_Networking) GetIngress() *Dataplane_Networking_Ingress
func (*Dataplane_Networking) GetOutbound ¶
func (m *Dataplane_Networking) GetOutbound() []*Dataplane_Networking_Outbound
func (*Dataplane_Networking) GetOutboundInterfaces ¶
func (n *Dataplane_Networking) GetOutboundInterfaces() ([]OutboundInterface, error)
func (*Dataplane_Networking) GetTransparentProxying ¶
func (m *Dataplane_Networking) GetTransparentProxying() *Dataplane_Networking_TransparentProxying
func (*Dataplane_Networking) ProtoMessage ¶
func (*Dataplane_Networking) ProtoMessage()
func (*Dataplane_Networking) Reset ¶
func (m *Dataplane_Networking) Reset()
func (*Dataplane_Networking) String ¶
func (m *Dataplane_Networking) String() string
func (*Dataplane_Networking) ToInboundInterface ¶
func (n *Dataplane_Networking) ToInboundInterface(inbound *Dataplane_Networking_Inbound) InboundInterface
func (*Dataplane_Networking) ToOutboundInterface ¶
func (n *Dataplane_Networking) ToOutboundInterface(outbound *Dataplane_Networking_Outbound) OutboundInterface
func (*Dataplane_Networking) Validate ¶
func (m *Dataplane_Networking) Validate() error
Validate checks the field values on Dataplane_Networking with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Dataplane_Networking) XXX_DiscardUnknown ¶
func (m *Dataplane_Networking) XXX_DiscardUnknown()
func (*Dataplane_Networking) XXX_Marshal ¶
func (m *Dataplane_Networking) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Dataplane_Networking) XXX_Merge ¶
func (m *Dataplane_Networking) XXX_Merge(src proto.Message)
func (*Dataplane_Networking) XXX_Size ¶
func (m *Dataplane_Networking) XXX_Size() int
func (*Dataplane_Networking) XXX_Unmarshal ¶
func (m *Dataplane_Networking) XXX_Unmarshal(b []byte) error
type Dataplane_NetworkingValidationError ¶
type Dataplane_NetworkingValidationError struct {
// contains filtered or unexported fields
}
Dataplane_NetworkingValidationError is the validation error returned by Dataplane_Networking.Validate if the designated constraints aren't met.
func (Dataplane_NetworkingValidationError) Cause ¶
func (e Dataplane_NetworkingValidationError) Cause() error
Cause function returns cause value.
func (Dataplane_NetworkingValidationError) Error ¶
func (e Dataplane_NetworkingValidationError) Error() string
Error satisfies the builtin error interface
func (Dataplane_NetworkingValidationError) ErrorName ¶
func (e Dataplane_NetworkingValidationError) ErrorName() string
ErrorName returns error name.
func (Dataplane_NetworkingValidationError) Field ¶
func (e Dataplane_NetworkingValidationError) Field() string
Field function returns field value.
func (Dataplane_NetworkingValidationError) Key ¶
func (e Dataplane_NetworkingValidationError) Key() bool
Key function returns key value.
func (Dataplane_NetworkingValidationError) Reason ¶
func (e Dataplane_NetworkingValidationError) Reason() string
Reason function returns reason value.
type Dataplane_Networking_Gateway ¶
type Dataplane_Networking_Gateway struct { // Tags associated with a gateway (e.g., Kong, Contour, etc) this // dataplane is deployed next to, e.g. service=gateway, env=prod. // `service` tag is mandatory. Tags map[string]string `` /* 149-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Gateway describes a service that ingress should not be proxied.
func (*Dataplane_Networking_Gateway) Descriptor ¶
func (*Dataplane_Networking_Gateway) Descriptor() ([]byte, []int)
func (*Dataplane_Networking_Gateway) GetTags ¶
func (m *Dataplane_Networking_Gateway) GetTags() map[string]string
func (*Dataplane_Networking_Gateway) MatchTags ¶
func (d *Dataplane_Networking_Gateway) MatchTags(selector TagSelector) bool
func (*Dataplane_Networking_Gateway) ProtoMessage ¶
func (*Dataplane_Networking_Gateway) ProtoMessage()
func (*Dataplane_Networking_Gateway) Reset ¶
func (m *Dataplane_Networking_Gateway) Reset()
func (*Dataplane_Networking_Gateway) String ¶
func (m *Dataplane_Networking_Gateway) String() string
func (*Dataplane_Networking_Gateway) Validate ¶
func (m *Dataplane_Networking_Gateway) Validate() error
Validate checks the field values on Dataplane_Networking_Gateway with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Dataplane_Networking_Gateway) XXX_DiscardUnknown ¶
func (m *Dataplane_Networking_Gateway) XXX_DiscardUnknown()
func (*Dataplane_Networking_Gateway) XXX_Marshal ¶
func (m *Dataplane_Networking_Gateway) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Dataplane_Networking_Gateway) XXX_Merge ¶
func (m *Dataplane_Networking_Gateway) XXX_Merge(src proto.Message)
func (*Dataplane_Networking_Gateway) XXX_Size ¶
func (m *Dataplane_Networking_Gateway) XXX_Size() int
func (*Dataplane_Networking_Gateway) XXX_Unmarshal ¶
func (m *Dataplane_Networking_Gateway) XXX_Unmarshal(b []byte) error
type Dataplane_Networking_GatewayValidationError ¶
type Dataplane_Networking_GatewayValidationError struct {
// contains filtered or unexported fields
}
Dataplane_Networking_GatewayValidationError is the validation error returned by Dataplane_Networking_Gateway.Validate if the designated constraints aren't met.
func (Dataplane_Networking_GatewayValidationError) Cause ¶
func (e Dataplane_Networking_GatewayValidationError) Cause() error
Cause function returns cause value.
func (Dataplane_Networking_GatewayValidationError) Error ¶
func (e Dataplane_Networking_GatewayValidationError) Error() string
Error satisfies the builtin error interface
func (Dataplane_Networking_GatewayValidationError) ErrorName ¶
func (e Dataplane_Networking_GatewayValidationError) ErrorName() string
ErrorName returns error name.
func (Dataplane_Networking_GatewayValidationError) Field ¶
func (e Dataplane_Networking_GatewayValidationError) Field() string
Field function returns field value.
func (Dataplane_Networking_GatewayValidationError) Key ¶
func (e Dataplane_Networking_GatewayValidationError) Key() bool
Key function returns key value.
func (Dataplane_Networking_GatewayValidationError) Reason ¶
func (e Dataplane_Networking_GatewayValidationError) Reason() string
Reason function returns reason value.
type Dataplane_Networking_Inbound ¶
type Dataplane_Networking_Inbound struct { // Port of the inbound interface that will forward requests to the // service. Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` // Port of the service that requests will be forwarded to. ServicePort uint32 `protobuf:"varint,4,opt,name=servicePort,proto3" json:"servicePort,omitempty"` // Address on which inbound listener will be exposed. Defaults to // networking.address. Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"` // Tags associated with an application this dataplane is deployed next to, // e.g. service=web, version=1.0. // `service` tag is mandatory. Tags map[string]string `` /* 149-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Inbound describes a service implemented by the dataplane.
func (*Dataplane_Networking_Inbound) Descriptor ¶
func (*Dataplane_Networking_Inbound) Descriptor() ([]byte, []int)
func (*Dataplane_Networking_Inbound) GetAddress ¶
func (m *Dataplane_Networking_Inbound) GetAddress() string
func (*Dataplane_Networking_Inbound) GetPort ¶
func (m *Dataplane_Networking_Inbound) GetPort() uint32
func (*Dataplane_Networking_Inbound) GetProtocol ¶
func (d *Dataplane_Networking_Inbound) GetProtocol() string
GetProtocol returns a protocol supported by this inbound interface.
The purpose of this method is to encapsulate implementation detail that protocol is modeled as a tag rather than a separate field.
func (*Dataplane_Networking_Inbound) GetService ¶
func (d *Dataplane_Networking_Inbound) GetService() string
GetService returns a service represented by this inbound interface.
The purpose of this method is to encapsulate implementation detail that service is modeled as a tag rather than a separate field.
func (*Dataplane_Networking_Inbound) GetServicePort ¶
func (m *Dataplane_Networking_Inbound) GetServicePort() uint32
func (*Dataplane_Networking_Inbound) GetTags ¶
func (m *Dataplane_Networking_Inbound) GetTags() map[string]string
func (*Dataplane_Networking_Inbound) MatchTags ¶
func (d *Dataplane_Networking_Inbound) MatchTags(selector TagSelector) bool
func (*Dataplane_Networking_Inbound) ProtoMessage ¶
func (*Dataplane_Networking_Inbound) ProtoMessage()
func (*Dataplane_Networking_Inbound) Reset ¶
func (m *Dataplane_Networking_Inbound) Reset()
func (*Dataplane_Networking_Inbound) String ¶
func (m *Dataplane_Networking_Inbound) String() string
func (*Dataplane_Networking_Inbound) Validate ¶
func (m *Dataplane_Networking_Inbound) Validate() error
Validate checks the field values on Dataplane_Networking_Inbound with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Dataplane_Networking_Inbound) XXX_DiscardUnknown ¶
func (m *Dataplane_Networking_Inbound) XXX_DiscardUnknown()
func (*Dataplane_Networking_Inbound) XXX_Marshal ¶
func (m *Dataplane_Networking_Inbound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Dataplane_Networking_Inbound) XXX_Merge ¶
func (m *Dataplane_Networking_Inbound) XXX_Merge(src proto.Message)
func (*Dataplane_Networking_Inbound) XXX_Size ¶
func (m *Dataplane_Networking_Inbound) XXX_Size() int
func (*Dataplane_Networking_Inbound) XXX_Unmarshal ¶
func (m *Dataplane_Networking_Inbound) XXX_Unmarshal(b []byte) error
type Dataplane_Networking_InboundValidationError ¶
type Dataplane_Networking_InboundValidationError struct {
// contains filtered or unexported fields
}
Dataplane_Networking_InboundValidationError is the validation error returned by Dataplane_Networking_Inbound.Validate if the designated constraints aren't met.
func (Dataplane_Networking_InboundValidationError) Cause ¶
func (e Dataplane_Networking_InboundValidationError) Cause() error
Cause function returns cause value.
func (Dataplane_Networking_InboundValidationError) Error ¶
func (e Dataplane_Networking_InboundValidationError) Error() string
Error satisfies the builtin error interface
func (Dataplane_Networking_InboundValidationError) ErrorName ¶
func (e Dataplane_Networking_InboundValidationError) ErrorName() string
ErrorName returns error name.
func (Dataplane_Networking_InboundValidationError) Field ¶
func (e Dataplane_Networking_InboundValidationError) Field() string
Field function returns field value.
func (Dataplane_Networking_InboundValidationError) Key ¶
func (e Dataplane_Networking_InboundValidationError) Key() bool
Key function returns key value.
func (Dataplane_Networking_InboundValidationError) Reason ¶
func (e Dataplane_Networking_InboundValidationError) Reason() string
Reason function returns reason value.
type Dataplane_Networking_Ingress ¶
type Dataplane_Networking_Ingress struct { AvailableServices []*Dataplane_Networking_Ingress_AvailableService `protobuf:"bytes,1,rep,name=availableServices,proto3" json:"availableServices,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Ingress allows us to configure dataplane in the Ingress mode. In this mode, dataplane has only inbound interfaces (outbound and gateway prohibited). Every inbound interface matches with services that reside in that cluster.
func (*Dataplane_Networking_Ingress) Descriptor ¶
func (*Dataplane_Networking_Ingress) Descriptor() ([]byte, []int)
func (*Dataplane_Networking_Ingress) GetAvailableServices ¶
func (m *Dataplane_Networking_Ingress) GetAvailableServices() []*Dataplane_Networking_Ingress_AvailableService
func (*Dataplane_Networking_Ingress) ProtoMessage ¶
func (*Dataplane_Networking_Ingress) ProtoMessage()
func (*Dataplane_Networking_Ingress) Reset ¶
func (m *Dataplane_Networking_Ingress) Reset()
func (*Dataplane_Networking_Ingress) String ¶
func (m *Dataplane_Networking_Ingress) String() string
func (*Dataplane_Networking_Ingress) Validate ¶
func (m *Dataplane_Networking_Ingress) Validate() error
Validate checks the field values on Dataplane_Networking_Ingress with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Dataplane_Networking_Ingress) XXX_DiscardUnknown ¶
func (m *Dataplane_Networking_Ingress) XXX_DiscardUnknown()
func (*Dataplane_Networking_Ingress) XXX_Marshal ¶
func (m *Dataplane_Networking_Ingress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Dataplane_Networking_Ingress) XXX_Merge ¶
func (m *Dataplane_Networking_Ingress) XXX_Merge(src proto.Message)
func (*Dataplane_Networking_Ingress) XXX_Size ¶
func (m *Dataplane_Networking_Ingress) XXX_Size() int
func (*Dataplane_Networking_Ingress) XXX_Unmarshal ¶
func (m *Dataplane_Networking_Ingress) XXX_Unmarshal(b []byte) error
type Dataplane_Networking_IngressValidationError ¶
type Dataplane_Networking_IngressValidationError struct {
// contains filtered or unexported fields
}
Dataplane_Networking_IngressValidationError is the validation error returned by Dataplane_Networking_Ingress.Validate if the designated constraints aren't met.
func (Dataplane_Networking_IngressValidationError) Cause ¶
func (e Dataplane_Networking_IngressValidationError) Cause() error
Cause function returns cause value.
func (Dataplane_Networking_IngressValidationError) Error ¶
func (e Dataplane_Networking_IngressValidationError) Error() string
Error satisfies the builtin error interface
func (Dataplane_Networking_IngressValidationError) ErrorName ¶
func (e Dataplane_Networking_IngressValidationError) ErrorName() string
ErrorName returns error name.
func (Dataplane_Networking_IngressValidationError) Field ¶
func (e Dataplane_Networking_IngressValidationError) Field() string
Field function returns field value.
func (Dataplane_Networking_IngressValidationError) Key ¶
func (e Dataplane_Networking_IngressValidationError) Key() bool
Key function returns key value.
func (Dataplane_Networking_IngressValidationError) Reason ¶
func (e Dataplane_Networking_IngressValidationError) Reason() string
Reason function returns reason value.
type Dataplane_Networking_Ingress_AvailableService ¶
type Dataplane_Networking_Ingress_AvailableService struct { // tags of the service Tags map[string]string `` /* 149-byte string literal not displayed */ // number of instances available for given tags Instances uint32 `protobuf:"varint,2,opt,name=instances,proto3" json:"instances,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
AvailableService contains tags that represent unique subset of endpoints
func (*Dataplane_Networking_Ingress_AvailableService) Descriptor ¶
func (*Dataplane_Networking_Ingress_AvailableService) Descriptor() ([]byte, []int)
func (*Dataplane_Networking_Ingress_AvailableService) GetInstances ¶
func (m *Dataplane_Networking_Ingress_AvailableService) GetInstances() uint32
func (*Dataplane_Networking_Ingress_AvailableService) GetTags ¶
func (m *Dataplane_Networking_Ingress_AvailableService) GetTags() map[string]string
func (*Dataplane_Networking_Ingress_AvailableService) ProtoMessage ¶
func (*Dataplane_Networking_Ingress_AvailableService) ProtoMessage()
func (*Dataplane_Networking_Ingress_AvailableService) Reset ¶
func (m *Dataplane_Networking_Ingress_AvailableService) Reset()
func (*Dataplane_Networking_Ingress_AvailableService) String ¶
func (m *Dataplane_Networking_Ingress_AvailableService) String() string
func (*Dataplane_Networking_Ingress_AvailableService) Validate ¶
func (m *Dataplane_Networking_Ingress_AvailableService) Validate() error
Validate checks the field values on Dataplane_Networking_Ingress_AvailableService with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Dataplane_Networking_Ingress_AvailableService) XXX_DiscardUnknown ¶
func (m *Dataplane_Networking_Ingress_AvailableService) XXX_DiscardUnknown()
func (*Dataplane_Networking_Ingress_AvailableService) XXX_Marshal ¶
func (m *Dataplane_Networking_Ingress_AvailableService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Dataplane_Networking_Ingress_AvailableService) XXX_Merge ¶
func (m *Dataplane_Networking_Ingress_AvailableService) XXX_Merge(src proto.Message)
func (*Dataplane_Networking_Ingress_AvailableService) XXX_Size ¶
func (m *Dataplane_Networking_Ingress_AvailableService) XXX_Size() int
func (*Dataplane_Networking_Ingress_AvailableService) XXX_Unmarshal ¶
func (m *Dataplane_Networking_Ingress_AvailableService) XXX_Unmarshal(b []byte) error
type Dataplane_Networking_Ingress_AvailableServiceValidationError ¶
type Dataplane_Networking_Ingress_AvailableServiceValidationError struct {
// contains filtered or unexported fields
}
Dataplane_Networking_Ingress_AvailableServiceValidationError is the validation error returned by Dataplane_Networking_Ingress_AvailableService.Validate if the designated constraints aren't met.
func (Dataplane_Networking_Ingress_AvailableServiceValidationError) Cause ¶
func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Cause() error
Cause function returns cause value.
func (Dataplane_Networking_Ingress_AvailableServiceValidationError) Error ¶
func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Error() string
Error satisfies the builtin error interface
func (Dataplane_Networking_Ingress_AvailableServiceValidationError) ErrorName ¶
func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) ErrorName() string
ErrorName returns error name.
func (Dataplane_Networking_Ingress_AvailableServiceValidationError) Field ¶
func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Field() string
Field function returns field value.
func (Dataplane_Networking_Ingress_AvailableServiceValidationError) Key ¶
func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Key() bool
Key function returns key value.
func (Dataplane_Networking_Ingress_AvailableServiceValidationError) Reason ¶
func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Reason() string
Reason function returns reason value.
type Dataplane_Networking_Outbound ¶
type Dataplane_Networking_Outbound struct { // Address on which the service will be available to this dataplane. // Defaults to 127.0.0.1 Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` // Port on which the service will be available to this dataplane. Port uint32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"` // DEPRECATED: use networking.outbound[].tags // Service name. Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"` // Tags Tags map[string]string `` /* 149-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Outbound describes a service consumed by the dataplane.
func (*Dataplane_Networking_Outbound) Descriptor ¶
func (*Dataplane_Networking_Outbound) Descriptor() ([]byte, []int)
func (*Dataplane_Networking_Outbound) GetAddress ¶
func (m *Dataplane_Networking_Outbound) GetAddress() string
func (*Dataplane_Networking_Outbound) GetPort ¶
func (m *Dataplane_Networking_Outbound) GetPort() uint32
func (*Dataplane_Networking_Outbound) GetService ¶
func (m *Dataplane_Networking_Outbound) GetService() string
func (*Dataplane_Networking_Outbound) GetTags ¶
func (m *Dataplane_Networking_Outbound) GetTags() map[string]string
func (*Dataplane_Networking_Outbound) GetTagsIncludingLegacy ¶
func (d *Dataplane_Networking_Outbound) GetTagsIncludingLegacy() map[string]string
GetTagsIncludingLegacy returns tags but taking on account old legacy format of "service" field in outbound Remove it and migrate to GetTags() once "service" field is removed.
func (*Dataplane_Networking_Outbound) MatchTags ¶
func (d *Dataplane_Networking_Outbound) MatchTags(selector TagSelector) bool
func (*Dataplane_Networking_Outbound) ProtoMessage ¶
func (*Dataplane_Networking_Outbound) ProtoMessage()
func (*Dataplane_Networking_Outbound) Reset ¶
func (m *Dataplane_Networking_Outbound) Reset()
func (*Dataplane_Networking_Outbound) String ¶
func (m *Dataplane_Networking_Outbound) String() string
func (*Dataplane_Networking_Outbound) Validate ¶
func (m *Dataplane_Networking_Outbound) Validate() error
Validate checks the field values on Dataplane_Networking_Outbound with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Dataplane_Networking_Outbound) XXX_DiscardUnknown ¶
func (m *Dataplane_Networking_Outbound) XXX_DiscardUnknown()
func (*Dataplane_Networking_Outbound) XXX_Marshal ¶
func (m *Dataplane_Networking_Outbound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Dataplane_Networking_Outbound) XXX_Merge ¶
func (m *Dataplane_Networking_Outbound) XXX_Merge(src proto.Message)
func (*Dataplane_Networking_Outbound) XXX_Size ¶
func (m *Dataplane_Networking_Outbound) XXX_Size() int
func (*Dataplane_Networking_Outbound) XXX_Unmarshal ¶
func (m *Dataplane_Networking_Outbound) XXX_Unmarshal(b []byte) error
type Dataplane_Networking_OutboundValidationError ¶
type Dataplane_Networking_OutboundValidationError struct {
// contains filtered or unexported fields
}
Dataplane_Networking_OutboundValidationError is the validation error returned by Dataplane_Networking_Outbound.Validate if the designated constraints aren't met.
func (Dataplane_Networking_OutboundValidationError) Cause ¶
func (e Dataplane_Networking_OutboundValidationError) Cause() error
Cause function returns cause value.
func (Dataplane_Networking_OutboundValidationError) Error ¶
func (e Dataplane_Networking_OutboundValidationError) Error() string
Error satisfies the builtin error interface
func (Dataplane_Networking_OutboundValidationError) ErrorName ¶
func (e Dataplane_Networking_OutboundValidationError) ErrorName() string
ErrorName returns error name.
func (Dataplane_Networking_OutboundValidationError) Field ¶
func (e Dataplane_Networking_OutboundValidationError) Field() string
Field function returns field value.
func (Dataplane_Networking_OutboundValidationError) Key ¶
func (e Dataplane_Networking_OutboundValidationError) Key() bool
Key function returns key value.
func (Dataplane_Networking_OutboundValidationError) Reason ¶
func (e Dataplane_Networking_OutboundValidationError) Reason() string
Reason function returns reason value.
type Dataplane_Networking_TransparentProxying ¶
type Dataplane_Networking_TransparentProxying struct { // Port on which all traffic is being transparently redirected. RedirectPort uint32 `protobuf:"varint,1,opt,name=redirect_port,json=redirectPort,proto3" json:"redirect_port,omitempty"` // List of services that will be access directly via IP:PORT DirectAccessServices []string `protobuf:"bytes,2,rep,name=direct_access_services,json=directAccessServices,proto3" json:"direct_access_services,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
TransparentProxying describes configuration for transparent proxying.
func (*Dataplane_Networking_TransparentProxying) Descriptor ¶
func (*Dataplane_Networking_TransparentProxying) Descriptor() ([]byte, []int)
func (*Dataplane_Networking_TransparentProxying) GetDirectAccessServices ¶
func (m *Dataplane_Networking_TransparentProxying) GetDirectAccessServices() []string
func (*Dataplane_Networking_TransparentProxying) GetRedirectPort ¶
func (m *Dataplane_Networking_TransparentProxying) GetRedirectPort() uint32
func (*Dataplane_Networking_TransparentProxying) ProtoMessage ¶
func (*Dataplane_Networking_TransparentProxying) ProtoMessage()
func (*Dataplane_Networking_TransparentProxying) Reset ¶
func (m *Dataplane_Networking_TransparentProxying) Reset()
func (*Dataplane_Networking_TransparentProxying) String ¶
func (m *Dataplane_Networking_TransparentProxying) String() string
func (*Dataplane_Networking_TransparentProxying) Validate ¶
func (m *Dataplane_Networking_TransparentProxying) Validate() error
Validate checks the field values on Dataplane_Networking_TransparentProxying with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Dataplane_Networking_TransparentProxying) XXX_DiscardUnknown ¶
func (m *Dataplane_Networking_TransparentProxying) XXX_DiscardUnknown()
func (*Dataplane_Networking_TransparentProxying) XXX_Marshal ¶
func (m *Dataplane_Networking_TransparentProxying) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Dataplane_Networking_TransparentProxying) XXX_Merge ¶
func (m *Dataplane_Networking_TransparentProxying) XXX_Merge(src proto.Message)
func (*Dataplane_Networking_TransparentProxying) XXX_Size ¶
func (m *Dataplane_Networking_TransparentProxying) XXX_Size() int
func (*Dataplane_Networking_TransparentProxying) XXX_Unmarshal ¶
func (m *Dataplane_Networking_TransparentProxying) XXX_Unmarshal(b []byte) error
type Dataplane_Networking_TransparentProxyingValidationError ¶
type Dataplane_Networking_TransparentProxyingValidationError struct {
// contains filtered or unexported fields
}
Dataplane_Networking_TransparentProxyingValidationError is the validation error returned by Dataplane_Networking_TransparentProxying.Validate if the designated constraints aren't met.
func (Dataplane_Networking_TransparentProxyingValidationError) Cause ¶
func (e Dataplane_Networking_TransparentProxyingValidationError) Cause() error
Cause function returns cause value.
func (Dataplane_Networking_TransparentProxyingValidationError) Error ¶
func (e Dataplane_Networking_TransparentProxyingValidationError) Error() string
Error satisfies the builtin error interface
func (Dataplane_Networking_TransparentProxyingValidationError) ErrorName ¶
func (e Dataplane_Networking_TransparentProxyingValidationError) ErrorName() string
ErrorName returns error name.
func (Dataplane_Networking_TransparentProxyingValidationError) Field ¶
func (e Dataplane_Networking_TransparentProxyingValidationError) Field() string
Field function returns field value.
func (Dataplane_Networking_TransparentProxyingValidationError) Key ¶
func (e Dataplane_Networking_TransparentProxyingValidationError) Key() bool
Key function returns key value.
func (Dataplane_Networking_TransparentProxyingValidationError) Reason ¶
func (e Dataplane_Networking_TransparentProxyingValidationError) Reason() string
Reason function returns reason value.
type DiscoveryServiceStats ¶
type DiscoveryServiceStats struct { // Number of xDS responses sent to the Dataplane. ResponsesSent uint64 `protobuf:"varint,1,opt,name=responses_sent,json=responsesSent,proto3" json:"responses_sent,omitempty"` // Number of xDS responses ACKed by the Dataplane. ResponsesAcknowledged uint64 `protobuf:"varint,2,opt,name=responses_acknowledged,json=responsesAcknowledged,proto3" json:"responses_acknowledged,omitempty"` // Number of xDS responses NACKed by the Dataplane. ResponsesRejected uint64 `protobuf:"varint,3,opt,name=responses_rejected,json=responsesRejected,proto3" json:"responses_rejected,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
DiscoveryServiceStats defines all stats over a single xDS service.
func (*DiscoveryServiceStats) Descriptor ¶
func (*DiscoveryServiceStats) Descriptor() ([]byte, []int)
func (*DiscoveryServiceStats) GetResponsesAcknowledged ¶
func (m *DiscoveryServiceStats) GetResponsesAcknowledged() uint64
func (*DiscoveryServiceStats) GetResponsesRejected ¶
func (m *DiscoveryServiceStats) GetResponsesRejected() uint64
func (*DiscoveryServiceStats) GetResponsesSent ¶
func (m *DiscoveryServiceStats) GetResponsesSent() uint64
func (*DiscoveryServiceStats) ProtoMessage ¶
func (*DiscoveryServiceStats) ProtoMessage()
func (*DiscoveryServiceStats) Reset ¶
func (m *DiscoveryServiceStats) Reset()
func (*DiscoveryServiceStats) String ¶
func (m *DiscoveryServiceStats) String() string
func (*DiscoveryServiceStats) XXX_DiscardUnknown ¶
func (m *DiscoveryServiceStats) XXX_DiscardUnknown()
func (*DiscoveryServiceStats) XXX_Marshal ¶
func (m *DiscoveryServiceStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DiscoveryServiceStats) XXX_Merge ¶
func (m *DiscoveryServiceStats) XXX_Merge(src proto.Message)
func (*DiscoveryServiceStats) XXX_Size ¶
func (m *DiscoveryServiceStats) XXX_Size() int
func (*DiscoveryServiceStats) XXX_Unmarshal ¶
func (m *DiscoveryServiceStats) XXX_Unmarshal(b []byte) error
type DiscoverySubscription ¶
type DiscoverySubscription struct { // Unique id per ADS subscription. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Control Plane instance that handled given subscription. ControlPlaneInstanceId string `` /* 131-byte string literal not displayed */ // Time when a given Dataplane connected to the Control Plane. ConnectTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=connect_time,json=connectTime,proto3" json:"connect_time,omitempty"` // Time when a given Dataplane disconnected from the Control Plane. DisconnectTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=disconnect_time,json=disconnectTime,proto3" json:"disconnect_time,omitempty"` // Status of the ADS subscription. Status *DiscoverySubscriptionStatus `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
DiscoverySubscription describes a single ADS subscription created by a Dataplane to the Control Plane. Ideally, there should be only one such subscription per Dataplane lifecycle. Presence of multiple subscriptions might indicate one of the following events: - transient loss of network connection between Dataplane and Control Plane - Dataplane restart (i.e. hot restart or crash) - Control Plane restart (i.e. rolling update or crash) - etc
func (*DiscoverySubscription) Descriptor ¶
func (*DiscoverySubscription) Descriptor() ([]byte, []int)
func (*DiscoverySubscription) GetConnectTime ¶
func (m *DiscoverySubscription) GetConnectTime() *timestamp.Timestamp
func (*DiscoverySubscription) GetControlPlaneInstanceId ¶
func (m *DiscoverySubscription) GetControlPlaneInstanceId() string
func (*DiscoverySubscription) GetDisconnectTime ¶
func (m *DiscoverySubscription) GetDisconnectTime() *timestamp.Timestamp
func (*DiscoverySubscription) GetId ¶
func (m *DiscoverySubscription) GetId() string
func (*DiscoverySubscription) GetStatus ¶
func (m *DiscoverySubscription) GetStatus() *DiscoverySubscriptionStatus
func (*DiscoverySubscription) ProtoMessage ¶
func (*DiscoverySubscription) ProtoMessage()
func (*DiscoverySubscription) Reset ¶
func (m *DiscoverySubscription) Reset()
func (*DiscoverySubscription) String ¶
func (m *DiscoverySubscription) String() string
func (*DiscoverySubscription) XXX_DiscardUnknown ¶
func (m *DiscoverySubscription) XXX_DiscardUnknown()
func (*DiscoverySubscription) XXX_Marshal ¶
func (m *DiscoverySubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DiscoverySubscription) XXX_Merge ¶
func (m *DiscoverySubscription) XXX_Merge(src proto.Message)
func (*DiscoverySubscription) XXX_Size ¶
func (m *DiscoverySubscription) XXX_Size() int
func (*DiscoverySubscription) XXX_Unmarshal ¶
func (m *DiscoverySubscription) XXX_Unmarshal(b []byte) error
type DiscoverySubscriptionStatus ¶
type DiscoverySubscriptionStatus struct { // Time when status of a given ADS subscription was most recently updated. LastUpdateTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"` // Total defines an aggregate over individual xDS stats. Total *DiscoveryServiceStats `protobuf:"bytes,2,opt,name=total,proto3" json:"total,omitempty"` // CDS defines all CDS stats. Cds *DiscoveryServiceStats `protobuf:"bytes,3,opt,name=cds,proto3" json:"cds,omitempty"` // EDS defines all EDS stats. Eds *DiscoveryServiceStats `protobuf:"bytes,4,opt,name=eds,proto3" json:"eds,omitempty"` // LDS defines all LDS stats. Lds *DiscoveryServiceStats `protobuf:"bytes,5,opt,name=lds,proto3" json:"lds,omitempty"` // RDS defines all RDS stats. Rds *DiscoveryServiceStats `protobuf:"bytes,6,opt,name=rds,proto3" json:"rds,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
DiscoverySubscriptionStatus defines status of an ADS subscription.
func NewSubscriptionStatus ¶
func NewSubscriptionStatus() *DiscoverySubscriptionStatus
func (*DiscoverySubscriptionStatus) Descriptor ¶
func (*DiscoverySubscriptionStatus) Descriptor() ([]byte, []int)
func (*DiscoverySubscriptionStatus) GetCds ¶
func (m *DiscoverySubscriptionStatus) GetCds() *DiscoveryServiceStats
func (*DiscoverySubscriptionStatus) GetEds ¶
func (m *DiscoverySubscriptionStatus) GetEds() *DiscoveryServiceStats
func (*DiscoverySubscriptionStatus) GetLastUpdateTime ¶
func (m *DiscoverySubscriptionStatus) GetLastUpdateTime() *timestamp.Timestamp
func (*DiscoverySubscriptionStatus) GetLds ¶
func (m *DiscoverySubscriptionStatus) GetLds() *DiscoveryServiceStats
func (*DiscoverySubscriptionStatus) GetRds ¶
func (m *DiscoverySubscriptionStatus) GetRds() *DiscoveryServiceStats
func (*DiscoverySubscriptionStatus) GetTotal ¶
func (m *DiscoverySubscriptionStatus) GetTotal() *DiscoveryServiceStats
func (*DiscoverySubscriptionStatus) ProtoMessage ¶
func (*DiscoverySubscriptionStatus) ProtoMessage()
func (*DiscoverySubscriptionStatus) Reset ¶
func (m *DiscoverySubscriptionStatus) Reset()
func (*DiscoverySubscriptionStatus) StatsOf ¶
func (s *DiscoverySubscriptionStatus) StatsOf(typeUrl string) *DiscoveryServiceStats
func (*DiscoverySubscriptionStatus) String ¶
func (m *DiscoverySubscriptionStatus) String() string
func (*DiscoverySubscriptionStatus) XXX_DiscardUnknown ¶
func (m *DiscoverySubscriptionStatus) XXX_DiscardUnknown()
func (*DiscoverySubscriptionStatus) XXX_Marshal ¶
func (m *DiscoverySubscriptionStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DiscoverySubscriptionStatus) XXX_Merge ¶
func (m *DiscoverySubscriptionStatus) XXX_Merge(src proto.Message)
func (*DiscoverySubscriptionStatus) XXX_Size ¶
func (m *DiscoverySubscriptionStatus) XXX_Size() int
func (*DiscoverySubscriptionStatus) XXX_Unmarshal ¶
func (m *DiscoverySubscriptionStatus) XXX_Unmarshal(b []byte) error
type FaultInjection ¶
type FaultInjection struct { // List of selectors to match dataplanes that are sources of traffic. Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"` // List of selectors to match services that are destinations of traffic. Destinations []*Selector `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"` // Configuration of FaultInjection Conf *FaultInjection_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
FaultInjection defines the configuration of faults between dataplanes.
func (*FaultInjection) Descriptor ¶
func (*FaultInjection) Descriptor() ([]byte, []int)
func (*FaultInjection) GetConf ¶
func (m *FaultInjection) GetConf() *FaultInjection_Conf
func (*FaultInjection) GetDestinations ¶
func (m *FaultInjection) GetDestinations() []*Selector
func (*FaultInjection) GetSources ¶
func (m *FaultInjection) GetSources() []*Selector
func (*FaultInjection) ProtoMessage ¶
func (*FaultInjection) ProtoMessage()
func (*FaultInjection) Reset ¶
func (m *FaultInjection) Reset()
func (*FaultInjection) SourceTags ¶
func (m *FaultInjection) SourceTags() (setList []SingleValueTagSet)
func (*FaultInjection) String ¶
func (m *FaultInjection) String() string
func (*FaultInjection) XXX_DiscardUnknown ¶
func (m *FaultInjection) XXX_DiscardUnknown()
func (*FaultInjection) XXX_Marshal ¶
func (m *FaultInjection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FaultInjection) XXX_Merge ¶
func (m *FaultInjection) XXX_Merge(src proto.Message)
func (*FaultInjection) XXX_Size ¶
func (m *FaultInjection) XXX_Size() int
func (*FaultInjection) XXX_Unmarshal ¶
func (m *FaultInjection) XXX_Unmarshal(b []byte) error
type FaultInjection_Conf ¶
type FaultInjection_Conf struct { // Delay if specified then response from the destination will be delivered // with a delay Delay *FaultInjection_Conf_Delay `protobuf:"bytes,1,opt,name=delay,proto3" json:"delay,omitempty"` // Abort if specified makes source side to receive specified httpStatus code Abort *FaultInjection_Conf_Abort `protobuf:"bytes,2,opt,name=abort,proto3" json:"abort,omitempty"` // ResponseBandwidth if specified limits the speed of sending response body ResponseBandwidth *FaultInjection_Conf_ResponseBandwidth `protobuf:"bytes,3,opt,name=response_bandwidth,json=responseBandwidth,proto3" json:"response_bandwidth,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Conf defines several types of faults, at least one fault should be specified
func (*FaultInjection_Conf) Descriptor ¶
func (*FaultInjection_Conf) Descriptor() ([]byte, []int)
func (*FaultInjection_Conf) GetAbort ¶
func (m *FaultInjection_Conf) GetAbort() *FaultInjection_Conf_Abort
func (*FaultInjection_Conf) GetDelay ¶
func (m *FaultInjection_Conf) GetDelay() *FaultInjection_Conf_Delay
func (*FaultInjection_Conf) GetResponseBandwidth ¶
func (m *FaultInjection_Conf) GetResponseBandwidth() *FaultInjection_Conf_ResponseBandwidth
func (*FaultInjection_Conf) ProtoMessage ¶
func (*FaultInjection_Conf) ProtoMessage()
func (*FaultInjection_Conf) Reset ¶
func (m *FaultInjection_Conf) Reset()
func (*FaultInjection_Conf) String ¶
func (m *FaultInjection_Conf) String() string
func (*FaultInjection_Conf) XXX_DiscardUnknown ¶
func (m *FaultInjection_Conf) XXX_DiscardUnknown()
func (*FaultInjection_Conf) XXX_Marshal ¶
func (m *FaultInjection_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FaultInjection_Conf) XXX_Merge ¶
func (m *FaultInjection_Conf) XXX_Merge(src proto.Message)
func (*FaultInjection_Conf) XXX_Size ¶
func (m *FaultInjection_Conf) XXX_Size() int
func (*FaultInjection_Conf) XXX_Unmarshal ¶
func (m *FaultInjection_Conf) XXX_Unmarshal(b []byte) error
type FaultInjection_Conf_Abort ¶
type FaultInjection_Conf_Abort struct { // Percentage of requests on which abort will be injected, has to be in // [0.0 - 100.0] range Percentage *wrappers.DoubleValue `protobuf:"bytes,1,opt,name=percentage,proto3" json:"percentage,omitempty"` // HTTP status code which will be returned to source side HttpStatus *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=httpStatus,proto3" json:"httpStatus,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Abort defines a configuration of not delivering requests to destination service and replacing the responses from destination dataplane by predefined status code
func (*FaultInjection_Conf_Abort) Descriptor ¶
func (*FaultInjection_Conf_Abort) Descriptor() ([]byte, []int)
func (*FaultInjection_Conf_Abort) GetHttpStatus ¶
func (m *FaultInjection_Conf_Abort) GetHttpStatus() *wrappers.UInt32Value
func (*FaultInjection_Conf_Abort) GetPercentage ¶
func (m *FaultInjection_Conf_Abort) GetPercentage() *wrappers.DoubleValue
func (*FaultInjection_Conf_Abort) ProtoMessage ¶
func (*FaultInjection_Conf_Abort) ProtoMessage()
func (*FaultInjection_Conf_Abort) Reset ¶
func (m *FaultInjection_Conf_Abort) Reset()
func (*FaultInjection_Conf_Abort) String ¶
func (m *FaultInjection_Conf_Abort) String() string
func (*FaultInjection_Conf_Abort) XXX_DiscardUnknown ¶
func (m *FaultInjection_Conf_Abort) XXX_DiscardUnknown()
func (*FaultInjection_Conf_Abort) XXX_Marshal ¶
func (m *FaultInjection_Conf_Abort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FaultInjection_Conf_Abort) XXX_Merge ¶
func (m *FaultInjection_Conf_Abort) XXX_Merge(src proto.Message)
func (*FaultInjection_Conf_Abort) XXX_Size ¶
func (m *FaultInjection_Conf_Abort) XXX_Size() int
func (*FaultInjection_Conf_Abort) XXX_Unmarshal ¶
func (m *FaultInjection_Conf_Abort) XXX_Unmarshal(b []byte) error
type FaultInjection_Conf_Delay ¶
type FaultInjection_Conf_Delay struct { // Percentage of requests on which delay will be injected, has to be in // [0.0 - 100.0] range Percentage *wrappers.DoubleValue `protobuf:"bytes,1,opt,name=percentage,proto3" json:"percentage,omitempty"` // The duration during which the response will be delayed Value *duration.Duration `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Delay defines configuration of delaying a response from a destination
func (*FaultInjection_Conf_Delay) Descriptor ¶
func (*FaultInjection_Conf_Delay) Descriptor() ([]byte, []int)
func (*FaultInjection_Conf_Delay) GetPercentage ¶
func (m *FaultInjection_Conf_Delay) GetPercentage() *wrappers.DoubleValue
func (*FaultInjection_Conf_Delay) GetValue ¶
func (m *FaultInjection_Conf_Delay) GetValue() *duration.Duration
func (*FaultInjection_Conf_Delay) ProtoMessage ¶
func (*FaultInjection_Conf_Delay) ProtoMessage()
func (*FaultInjection_Conf_Delay) Reset ¶
func (m *FaultInjection_Conf_Delay) Reset()
func (*FaultInjection_Conf_Delay) String ¶
func (m *FaultInjection_Conf_Delay) String() string
func (*FaultInjection_Conf_Delay) XXX_DiscardUnknown ¶
func (m *FaultInjection_Conf_Delay) XXX_DiscardUnknown()
func (*FaultInjection_Conf_Delay) XXX_Marshal ¶
func (m *FaultInjection_Conf_Delay) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FaultInjection_Conf_Delay) XXX_Merge ¶
func (m *FaultInjection_Conf_Delay) XXX_Merge(src proto.Message)
func (*FaultInjection_Conf_Delay) XXX_Size ¶
func (m *FaultInjection_Conf_Delay) XXX_Size() int
func (*FaultInjection_Conf_Delay) XXX_Unmarshal ¶
func (m *FaultInjection_Conf_Delay) XXX_Unmarshal(b []byte) error
type FaultInjection_Conf_ResponseBandwidth ¶
type FaultInjection_Conf_ResponseBandwidth struct { // Percentage of requests on which response bandwidth limit will be // injected, has to be in [0.0 - 100.0] range Percentage *wrappers.DoubleValue `protobuf:"bytes,1,opt,name=percentage,proto3" json:"percentage,omitempty"` // Limit is represented by value measure in gbps, mbps, kbps or bps, e.g. // 10kbps Limit *wrappers.StringValue `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ResponseBandwidth defines a configuration to limit the speed of responding to the requests
func (*FaultInjection_Conf_ResponseBandwidth) Descriptor ¶
func (*FaultInjection_Conf_ResponseBandwidth) Descriptor() ([]byte, []int)
func (*FaultInjection_Conf_ResponseBandwidth) GetLimit ¶
func (m *FaultInjection_Conf_ResponseBandwidth) GetLimit() *wrappers.StringValue
func (*FaultInjection_Conf_ResponseBandwidth) GetPercentage ¶
func (m *FaultInjection_Conf_ResponseBandwidth) GetPercentage() *wrappers.DoubleValue
func (*FaultInjection_Conf_ResponseBandwidth) ProtoMessage ¶
func (*FaultInjection_Conf_ResponseBandwidth) ProtoMessage()
func (*FaultInjection_Conf_ResponseBandwidth) Reset ¶
func (m *FaultInjection_Conf_ResponseBandwidth) Reset()
func (*FaultInjection_Conf_ResponseBandwidth) String ¶
func (m *FaultInjection_Conf_ResponseBandwidth) String() string
func (*FaultInjection_Conf_ResponseBandwidth) XXX_DiscardUnknown ¶
func (m *FaultInjection_Conf_ResponseBandwidth) XXX_DiscardUnknown()
func (*FaultInjection_Conf_ResponseBandwidth) XXX_Marshal ¶
func (m *FaultInjection_Conf_ResponseBandwidth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FaultInjection_Conf_ResponseBandwidth) XXX_Merge ¶
func (m *FaultInjection_Conf_ResponseBandwidth) XXX_Merge(src proto.Message)
func (*FaultInjection_Conf_ResponseBandwidth) XXX_Size ¶
func (m *FaultInjection_Conf_ResponseBandwidth) XXX_Size() int
func (*FaultInjection_Conf_ResponseBandwidth) XXX_Unmarshal ¶
func (m *FaultInjection_Conf_ResponseBandwidth) XXX_Unmarshal(b []byte) error
type FileLoggingBackendConfig ¶
type FileLoggingBackendConfig struct { // Path to a file that logs will be written to Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
FileLoggingBackendConfig defines configuration for file based access logs
func (*FileLoggingBackendConfig) Descriptor ¶
func (*FileLoggingBackendConfig) Descriptor() ([]byte, []int)
func (*FileLoggingBackendConfig) GetPath ¶
func (m *FileLoggingBackendConfig) GetPath() string
func (*FileLoggingBackendConfig) ProtoMessage ¶
func (*FileLoggingBackendConfig) ProtoMessage()
func (*FileLoggingBackendConfig) Reset ¶
func (m *FileLoggingBackendConfig) Reset()
func (*FileLoggingBackendConfig) String ¶
func (m *FileLoggingBackendConfig) String() string
func (*FileLoggingBackendConfig) Validate ¶
func (m *FileLoggingBackendConfig) Validate() error
Validate checks the field values on FileLoggingBackendConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*FileLoggingBackendConfig) XXX_DiscardUnknown ¶
func (m *FileLoggingBackendConfig) XXX_DiscardUnknown()
func (*FileLoggingBackendConfig) XXX_Marshal ¶
func (m *FileLoggingBackendConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FileLoggingBackendConfig) XXX_Merge ¶
func (m *FileLoggingBackendConfig) XXX_Merge(src proto.Message)
func (*FileLoggingBackendConfig) XXX_Size ¶
func (m *FileLoggingBackendConfig) XXX_Size() int
func (*FileLoggingBackendConfig) XXX_Unmarshal ¶
func (m *FileLoggingBackendConfig) XXX_Unmarshal(b []byte) error
type FileLoggingBackendConfigValidationError ¶
type FileLoggingBackendConfigValidationError struct {
// contains filtered or unexported fields
}
FileLoggingBackendConfigValidationError is the validation error returned by FileLoggingBackendConfig.Validate if the designated constraints aren't met.
func (FileLoggingBackendConfigValidationError) Cause ¶
func (e FileLoggingBackendConfigValidationError) Cause() error
Cause function returns cause value.
func (FileLoggingBackendConfigValidationError) Error ¶
func (e FileLoggingBackendConfigValidationError) Error() string
Error satisfies the builtin error interface
func (FileLoggingBackendConfigValidationError) ErrorName ¶
func (e FileLoggingBackendConfigValidationError) ErrorName() string
ErrorName returns error name.
func (FileLoggingBackendConfigValidationError) Field ¶
func (e FileLoggingBackendConfigValidationError) Field() string
Field function returns field value.
func (FileLoggingBackendConfigValidationError) Key ¶
func (e FileLoggingBackendConfigValidationError) Key() bool
Key function returns key value.
func (FileLoggingBackendConfigValidationError) Reason ¶
func (e FileLoggingBackendConfigValidationError) Reason() string
Reason function returns reason value.
type HealthCheck ¶
type HealthCheck struct { // List of selectors to match dataplanes that should be configured to do // health checks. Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"` // List of selectors to match services that need to be health checked. Destinations []*Selector `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"` // Configuration for various types of health checking. Conf *HealthCheck_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
HealthCheck defines configuration for health checking.
func (*HealthCheck) Descriptor ¶
func (*HealthCheck) Descriptor() ([]byte, []int)
func (*HealthCheck) GetConf ¶
func (m *HealthCheck) GetConf() *HealthCheck_Conf
func (*HealthCheck) GetDestinations ¶
func (m *HealthCheck) GetDestinations() []*Selector
func (*HealthCheck) GetSources ¶
func (m *HealthCheck) GetSources() []*Selector
func (*HealthCheck) ProtoMessage ¶
func (*HealthCheck) ProtoMessage()
func (*HealthCheck) Reset ¶
func (m *HealthCheck) Reset()
func (*HealthCheck) String ¶
func (m *HealthCheck) String() string
func (*HealthCheck) Validate ¶
func (m *HealthCheck) Validate() error
Validate checks the field values on HealthCheck with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*HealthCheck) XXX_DiscardUnknown ¶
func (m *HealthCheck) XXX_DiscardUnknown()
func (*HealthCheck) XXX_Marshal ¶
func (m *HealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthCheck) XXX_Merge ¶
func (m *HealthCheck) XXX_Merge(src proto.Message)
func (*HealthCheck) XXX_Size ¶
func (m *HealthCheck) XXX_Size() int
func (*HealthCheck) XXX_Unmarshal ¶
func (m *HealthCheck) XXX_Unmarshal(b []byte) error
type HealthCheckValidationError ¶
type HealthCheckValidationError struct {
// contains filtered or unexported fields
}
HealthCheckValidationError is the validation error returned by HealthCheck.Validate if the designated constraints aren't met.
func (HealthCheckValidationError) Cause ¶
func (e HealthCheckValidationError) Cause() error
Cause function returns cause value.
func (HealthCheckValidationError) Error ¶
func (e HealthCheckValidationError) Error() string
Error satisfies the builtin error interface
func (HealthCheckValidationError) ErrorName ¶
func (e HealthCheckValidationError) ErrorName() string
ErrorName returns error name.
func (HealthCheckValidationError) Field ¶
func (e HealthCheckValidationError) Field() string
Field function returns field value.
func (HealthCheckValidationError) Key ¶
func (e HealthCheckValidationError) Key() bool
Key function returns key value.
func (HealthCheckValidationError) Reason ¶
func (e HealthCheckValidationError) Reason() string
Reason function returns reason value.
type HealthCheck_Conf ¶
type HealthCheck_Conf struct { // Interval between consecutive health checks. Interval *duration.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"` // Maximum time to wait for a health check response. Timeout *duration.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"` // Number of consecutive unhealthy checks before considering a host // unhealthy. UnhealthyThreshold uint32 `protobuf:"varint,3,opt,name=unhealthy_threshold,json=unhealthyThreshold,proto3" json:"unhealthy_threshold,omitempty"` // Number of consecutive healthy checks before considering a host healthy. HealthyThreshold uint32 `protobuf:"varint,4,opt,name=healthy_threshold,json=healthyThreshold,proto3" json:"healthy_threshold,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Conf defines configuration for various types of health checking.
func (*HealthCheck_Conf) Descriptor ¶
func (*HealthCheck_Conf) Descriptor() ([]byte, []int)
func (*HealthCheck_Conf) GetHealthyThreshold ¶
func (m *HealthCheck_Conf) GetHealthyThreshold() uint32
func (*HealthCheck_Conf) GetInterval ¶
func (m *HealthCheck_Conf) GetInterval() *duration.Duration
func (*HealthCheck_Conf) GetTimeout ¶
func (m *HealthCheck_Conf) GetTimeout() *duration.Duration
func (*HealthCheck_Conf) GetUnhealthyThreshold ¶
func (m *HealthCheck_Conf) GetUnhealthyThreshold() uint32
func (*HealthCheck_Conf) ProtoMessage ¶
func (*HealthCheck_Conf) ProtoMessage()
func (*HealthCheck_Conf) Reset ¶
func (m *HealthCheck_Conf) Reset()
func (*HealthCheck_Conf) String ¶
func (m *HealthCheck_Conf) String() string
func (*HealthCheck_Conf) Validate ¶
func (m *HealthCheck_Conf) Validate() error
Validate checks the field values on HealthCheck_Conf with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*HealthCheck_Conf) XXX_DiscardUnknown ¶
func (m *HealthCheck_Conf) XXX_DiscardUnknown()
func (*HealthCheck_Conf) XXX_Marshal ¶
func (m *HealthCheck_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthCheck_Conf) XXX_Merge ¶
func (m *HealthCheck_Conf) XXX_Merge(src proto.Message)
func (*HealthCheck_Conf) XXX_Size ¶
func (m *HealthCheck_Conf) XXX_Size() int
func (*HealthCheck_Conf) XXX_Unmarshal ¶
func (m *HealthCheck_Conf) XXX_Unmarshal(b []byte) error
type HealthCheck_ConfValidationError ¶
type HealthCheck_ConfValidationError struct {
// contains filtered or unexported fields
}
HealthCheck_ConfValidationError is the validation error returned by HealthCheck_Conf.Validate if the designated constraints aren't met.
func (HealthCheck_ConfValidationError) Cause ¶
func (e HealthCheck_ConfValidationError) Cause() error
Cause function returns cause value.
func (HealthCheck_ConfValidationError) Error ¶
func (e HealthCheck_ConfValidationError) Error() string
Error satisfies the builtin error interface
func (HealthCheck_ConfValidationError) ErrorName ¶
func (e HealthCheck_ConfValidationError) ErrorName() string
ErrorName returns error name.
func (HealthCheck_ConfValidationError) Field ¶
func (e HealthCheck_ConfValidationError) Field() string
Field function returns field value.
func (HealthCheck_ConfValidationError) Key ¶
func (e HealthCheck_ConfValidationError) Key() bool
Key function returns key value.
func (HealthCheck_ConfValidationError) Reason ¶
func (e HealthCheck_ConfValidationError) Reason() string
Reason function returns reason value.
type InboundInterface ¶
func ParseInboundInterface ¶
func ParseInboundInterface(text string) (InboundInterface, error)
func (InboundInterface) String ¶
func (i InboundInterface) String() string
type KumaDiscoveryServiceClient ¶
type KumaDiscoveryServiceClient interface { DeltaKumaResources(ctx context.Context, opts ...grpc.CallOption) (KumaDiscoveryService_DeltaKumaResourcesClient, error) StreamKumaResources(ctx context.Context, opts ...grpc.CallOption) (KumaDiscoveryService_StreamKumaResourcesClient, error) FetchKumaResources(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error) }
KumaDiscoveryServiceClient is the client API for KumaDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewKumaDiscoveryServiceClient ¶
func NewKumaDiscoveryServiceClient(cc *grpc.ClientConn) KumaDiscoveryServiceClient
type KumaDiscoveryServiceServer ¶
type KumaDiscoveryServiceServer interface { DeltaKumaResources(KumaDiscoveryService_DeltaKumaResourcesServer) error StreamKumaResources(KumaDiscoveryService_StreamKumaResourcesServer) error FetchKumaResources(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error) }
KumaDiscoveryServiceServer is the server API for KumaDiscoveryService service.
type KumaDiscoveryService_DeltaKumaResourcesClient ¶
type KumaDiscoveryService_DeltaKumaResourcesClient interface { Send(*v2.DeltaDiscoveryRequest) error Recv() (*v2.DeltaDiscoveryResponse, error) grpc.ClientStream }
type KumaDiscoveryService_DeltaKumaResourcesServer ¶
type KumaDiscoveryService_DeltaKumaResourcesServer interface { Send(*v2.DeltaDiscoveryResponse) error Recv() (*v2.DeltaDiscoveryRequest, error) grpc.ServerStream }
type KumaDiscoveryService_StreamKumaResourcesClient ¶
type KumaDiscoveryService_StreamKumaResourcesClient interface { Send(*v2.DiscoveryRequest) error Recv() (*v2.DiscoveryResponse, error) grpc.ClientStream }
type KumaDiscoveryService_StreamKumaResourcesServer ¶
type KumaDiscoveryService_StreamKumaResourcesServer interface { Send(*v2.DiscoveryResponse) error Recv() (*v2.DiscoveryRequest, error) grpc.ServerStream }
type KumaResource ¶
type KumaResource struct { Meta *KumaResource_Meta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` Spec *any.Any `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*KumaResource) Descriptor ¶
func (*KumaResource) Descriptor() ([]byte, []int)
func (*KumaResource) GetMeta ¶
func (m *KumaResource) GetMeta() *KumaResource_Meta
func (*KumaResource) GetSpec ¶
func (m *KumaResource) GetSpec() *any.Any
func (*KumaResource) ProtoMessage ¶
func (*KumaResource) ProtoMessage()
func (*KumaResource) Reset ¶
func (m *KumaResource) Reset()
func (*KumaResource) String ¶
func (m *KumaResource) String() string
func (*KumaResource) Validate ¶
func (m *KumaResource) Validate() error
Validate checks the field values on KumaResource with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*KumaResource) XXX_DiscardUnknown ¶
func (m *KumaResource) XXX_DiscardUnknown()
func (*KumaResource) XXX_Marshal ¶
func (m *KumaResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KumaResource) XXX_Merge ¶
func (m *KumaResource) XXX_Merge(src proto.Message)
func (*KumaResource) XXX_Size ¶
func (m *KumaResource) XXX_Size() int
func (*KumaResource) XXX_Unmarshal ¶
func (m *KumaResource) XXX_Unmarshal(b []byte) error
type KumaResourceValidationError ¶
type KumaResourceValidationError struct {
// contains filtered or unexported fields
}
KumaResourceValidationError is the validation error returned by KumaResource.Validate if the designated constraints aren't met.
func (KumaResourceValidationError) Cause ¶
func (e KumaResourceValidationError) Cause() error
Cause function returns cause value.
func (KumaResourceValidationError) Error ¶
func (e KumaResourceValidationError) Error() string
Error satisfies the builtin error interface
func (KumaResourceValidationError) ErrorName ¶
func (e KumaResourceValidationError) ErrorName() string
ErrorName returns error name.
func (KumaResourceValidationError) Field ¶
func (e KumaResourceValidationError) Field() string
Field function returns field value.
func (KumaResourceValidationError) Key ¶
func (e KumaResourceValidationError) Key() bool
Key function returns key value.
func (KumaResourceValidationError) Reason ¶
func (e KumaResourceValidationError) Reason() string
Reason function returns reason value.
type KumaResource_Meta ¶
type KumaResource_Meta struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Mesh string `protobuf:"bytes,2,opt,name=mesh,proto3" json:"mesh,omitempty"` CreationTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"` ModificationTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=modification_time,json=modificationTime,proto3" json:"modification_time,omitempty"` Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*KumaResource_Meta) Descriptor ¶
func (*KumaResource_Meta) Descriptor() ([]byte, []int)
func (*KumaResource_Meta) GetCreationTime ¶
func (m *KumaResource_Meta) GetCreationTime() *timestamp.Timestamp
func (*KumaResource_Meta) GetMesh ¶
func (m *KumaResource_Meta) GetMesh() string
func (*KumaResource_Meta) GetModificationTime ¶
func (m *KumaResource_Meta) GetModificationTime() *timestamp.Timestamp
func (*KumaResource_Meta) GetName ¶
func (m *KumaResource_Meta) GetName() string
func (*KumaResource_Meta) GetVersion ¶
func (m *KumaResource_Meta) GetVersion() string
func (*KumaResource_Meta) ProtoMessage ¶
func (*KumaResource_Meta) ProtoMessage()
func (*KumaResource_Meta) Reset ¶
func (m *KumaResource_Meta) Reset()
func (*KumaResource_Meta) String ¶
func (m *KumaResource_Meta) String() string
func (*KumaResource_Meta) Validate ¶
func (m *KumaResource_Meta) Validate() error
Validate checks the field values on KumaResource_Meta with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*KumaResource_Meta) XXX_DiscardUnknown ¶
func (m *KumaResource_Meta) XXX_DiscardUnknown()
func (*KumaResource_Meta) XXX_Marshal ¶
func (m *KumaResource_Meta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KumaResource_Meta) XXX_Merge ¶
func (m *KumaResource_Meta) XXX_Merge(src proto.Message)
func (*KumaResource_Meta) XXX_Size ¶
func (m *KumaResource_Meta) XXX_Size() int
func (*KumaResource_Meta) XXX_Unmarshal ¶
func (m *KumaResource_Meta) XXX_Unmarshal(b []byte) error
type KumaResource_MetaValidationError ¶
type KumaResource_MetaValidationError struct {
// contains filtered or unexported fields
}
KumaResource_MetaValidationError is the validation error returned by KumaResource_Meta.Validate if the designated constraints aren't met.
func (KumaResource_MetaValidationError) Cause ¶
func (e KumaResource_MetaValidationError) Cause() error
Cause function returns cause value.
func (KumaResource_MetaValidationError) Error ¶
func (e KumaResource_MetaValidationError) Error() string
Error satisfies the builtin error interface
func (KumaResource_MetaValidationError) ErrorName ¶
func (e KumaResource_MetaValidationError) ErrorName() string
ErrorName returns error name.
func (KumaResource_MetaValidationError) Field ¶
func (e KumaResource_MetaValidationError) Field() string
Field function returns field value.
func (KumaResource_MetaValidationError) Key ¶
func (e KumaResource_MetaValidationError) Key() bool
Key function returns key value.
func (KumaResource_MetaValidationError) Reason ¶
func (e KumaResource_MetaValidationError) Reason() string
Reason function returns reason value.
type Logging ¶
type Logging struct { // Name of the default backend DefaultBackend string `protobuf:"bytes,1,opt,name=defaultBackend,proto3" json:"defaultBackend,omitempty"` // List of available logging backends Backends []*LoggingBackend `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Logging) Descriptor ¶
func (*Logging) GetBackends ¶
func (m *Logging) GetBackends() []*LoggingBackend
func (*Logging) GetDefaultBackend ¶
func (*Logging) ProtoMessage ¶
func (*Logging) ProtoMessage()
func (*Logging) Validate ¶
Validate checks the field values on Logging with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Logging) XXX_DiscardUnknown ¶
func (m *Logging) XXX_DiscardUnknown()
func (*Logging) XXX_Marshal ¶
func (*Logging) XXX_Unmarshal ¶
type LoggingBackend ¶
type LoggingBackend struct { // Name of the backend, can be then used in Mesh.logging.defaultBackend or in // TrafficLogging Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Format of access logs. Placehodlers available on // https://www.envoyproxy.io/docs/envoy/latest/configuration/observability/access_log Format string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"` // Type of the backend (Kuma ships with 'tcp' and 'file') Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // Configuration of the backend Conf *_struct.Struct `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
LoggingBackend defines logging backend available to mesh. Backends can be used in TrafficLog rules.
func (*LoggingBackend) Descriptor ¶
func (*LoggingBackend) Descriptor() ([]byte, []int)
func (*LoggingBackend) GetConf ¶
func (m *LoggingBackend) GetConf() *_struct.Struct
func (*LoggingBackend) GetFormat ¶
func (m *LoggingBackend) GetFormat() string
func (*LoggingBackend) GetName ¶
func (m *LoggingBackend) GetName() string
func (*LoggingBackend) GetType ¶
func (m *LoggingBackend) GetType() string
func (*LoggingBackend) ProtoMessage ¶
func (*LoggingBackend) ProtoMessage()
func (*LoggingBackend) Reset ¶
func (m *LoggingBackend) Reset()
func (*LoggingBackend) String ¶
func (m *LoggingBackend) String() string
func (*LoggingBackend) Validate ¶
func (m *LoggingBackend) Validate() error
Validate checks the field values on LoggingBackend with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*LoggingBackend) XXX_DiscardUnknown ¶
func (m *LoggingBackend) XXX_DiscardUnknown()
func (*LoggingBackend) XXX_Marshal ¶
func (m *LoggingBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoggingBackend) XXX_Merge ¶
func (m *LoggingBackend) XXX_Merge(src proto.Message)
func (*LoggingBackend) XXX_Size ¶
func (m *LoggingBackend) XXX_Size() int
func (*LoggingBackend) XXX_Unmarshal ¶
func (m *LoggingBackend) XXX_Unmarshal(b []byte) error
type LoggingBackendValidationError ¶
type LoggingBackendValidationError struct {
// contains filtered or unexported fields
}
LoggingBackendValidationError is the validation error returned by LoggingBackend.Validate if the designated constraints aren't met.
func (LoggingBackendValidationError) Cause ¶
func (e LoggingBackendValidationError) Cause() error
Cause function returns cause value.
func (LoggingBackendValidationError) Error ¶
func (e LoggingBackendValidationError) Error() string
Error satisfies the builtin error interface
func (LoggingBackendValidationError) ErrorName ¶
func (e LoggingBackendValidationError) ErrorName() string
ErrorName returns error name.
func (LoggingBackendValidationError) Field ¶
func (e LoggingBackendValidationError) Field() string
Field function returns field value.
func (LoggingBackendValidationError) Key ¶
func (e LoggingBackendValidationError) Key() bool
Key function returns key value.
func (LoggingBackendValidationError) Reason ¶
func (e LoggingBackendValidationError) Reason() string
Reason function returns reason value.
type LoggingValidationError ¶
type LoggingValidationError struct {
// contains filtered or unexported fields
}
LoggingValidationError is the validation error returned by Logging.Validate if the designated constraints aren't met.
func (LoggingValidationError) Cause ¶
func (e LoggingValidationError) Cause() error
Cause function returns cause value.
func (LoggingValidationError) Error ¶
func (e LoggingValidationError) Error() string
Error satisfies the builtin error interface
func (LoggingValidationError) ErrorName ¶
func (e LoggingValidationError) ErrorName() string
ErrorName returns error name.
func (LoggingValidationError) Field ¶
func (e LoggingValidationError) Field() string
Field function returns field value.
func (LoggingValidationError) Key ¶
func (e LoggingValidationError) Key() bool
Key function returns key value.
func (LoggingValidationError) Reason ¶
func (e LoggingValidationError) Reason() string
Reason function returns reason value.
type Mesh ¶
type Mesh struct { // mTLS settings. // +optional Mtls *Mesh_Mtls `protobuf:"bytes,1,opt,name=mtls,proto3" json:"mtls,omitempty"` // Tracing settings. // +optional Tracing *Tracing `protobuf:"bytes,2,opt,name=tracing,proto3" json:"tracing,omitempty"` // Logging settings. // +optional Logging *Logging `protobuf:"bytes,3,opt,name=logging,proto3" json:"logging,omitempty"` // Configuration for metrics collected and exposed by dataplanes. // // Settings defined here become defaults for every dataplane in a given Mesh. // Additionally, it is also possible to further customize this configuration // for each dataplane individually using Dataplane resource. // +optional Metrics *Metrics `protobuf:"bytes,4,opt,name=metrics,proto3" json:"metrics,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Mesh defines configuration of a single mesh.
func (*Mesh) Descriptor ¶
func (*Mesh) GetLogging ¶
func (*Mesh) GetMetrics ¶
func (*Mesh) GetTracing ¶
func (*Mesh) ProtoMessage ¶
func (*Mesh) ProtoMessage()
func (*Mesh) Validate ¶
Validate checks the field values on Mesh with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Mesh) XXX_DiscardUnknown ¶
func (m *Mesh) XXX_DiscardUnknown()
func (*Mesh) XXX_Unmarshal ¶
type MeshValidationError ¶
type MeshValidationError struct {
// contains filtered or unexported fields
}
MeshValidationError is the validation error returned by Mesh.Validate if the designated constraints aren't met.
func (MeshValidationError) Cause ¶
func (e MeshValidationError) Cause() error
Cause function returns cause value.
func (MeshValidationError) Error ¶
func (e MeshValidationError) Error() string
Error satisfies the builtin error interface
func (MeshValidationError) ErrorName ¶
func (e MeshValidationError) ErrorName() string
ErrorName returns error name.
func (MeshValidationError) Field ¶
func (e MeshValidationError) Field() string
Field function returns field value.
func (MeshValidationError) Key ¶
func (e MeshValidationError) Key() bool
Key function returns key value.
func (MeshValidationError) Reason ¶
func (e MeshValidationError) Reason() string
Reason function returns reason value.
type Mesh_Mtls ¶
type Mesh_Mtls struct { // Name of the enabled backend EnabledBackend string `protobuf:"bytes,1,opt,name=enabledBackend,proto3" json:"enabledBackend,omitempty"` // List of available Certificate Authority backends Backends []*CertificateAuthorityBackend `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
mTLS settings of a Mesh.
func (*Mesh_Mtls) Descriptor ¶
func (*Mesh_Mtls) GetBackends ¶
func (m *Mesh_Mtls) GetBackends() []*CertificateAuthorityBackend
func (*Mesh_Mtls) GetEnabledBackend ¶
func (*Mesh_Mtls) ProtoMessage ¶
func (*Mesh_Mtls) ProtoMessage()
func (*Mesh_Mtls) Validate ¶
Validate checks the field values on Mesh_Mtls with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Mesh_Mtls) XXX_DiscardUnknown ¶
func (m *Mesh_Mtls) XXX_DiscardUnknown()
func (*Mesh_Mtls) XXX_Marshal ¶
func (*Mesh_Mtls) XXX_Unmarshal ¶
type Mesh_MtlsValidationError ¶
type Mesh_MtlsValidationError struct {
// contains filtered or unexported fields
}
Mesh_MtlsValidationError is the validation error returned by Mesh_Mtls.Validate if the designated constraints aren't met.
func (Mesh_MtlsValidationError) Cause ¶
func (e Mesh_MtlsValidationError) Cause() error
Cause function returns cause value.
func (Mesh_MtlsValidationError) Error ¶
func (e Mesh_MtlsValidationError) Error() string
Error satisfies the builtin error interface
func (Mesh_MtlsValidationError) ErrorName ¶
func (e Mesh_MtlsValidationError) ErrorName() string
ErrorName returns error name.
func (Mesh_MtlsValidationError) Field ¶
func (e Mesh_MtlsValidationError) Field() string
Field function returns field value.
func (Mesh_MtlsValidationError) Key ¶
func (e Mesh_MtlsValidationError) Key() bool
Key function returns key value.
func (Mesh_MtlsValidationError) Reason ¶
func (e Mesh_MtlsValidationError) Reason() string
Reason function returns reason value.
type Metrics ¶
type Metrics struct { // Name of the enabled backend EnabledBackend string `protobuf:"bytes,1,opt,name=enabledBackend,proto3" json:"enabledBackend,omitempty"` // List of available Metrics backends Backends []*MetricsBackend `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Metrics defines configuration for metrics that should be collected and exposed by dataplanes.
func (*Metrics) Descriptor ¶
func (*Metrics) GetBackends ¶
func (m *Metrics) GetBackends() []*MetricsBackend
func (*Metrics) GetEnabledBackend ¶
func (*Metrics) ProtoMessage ¶
func (*Metrics) ProtoMessage()
func (*Metrics) XXX_DiscardUnknown ¶
func (m *Metrics) XXX_DiscardUnknown()
func (*Metrics) XXX_Marshal ¶
func (*Metrics) XXX_Unmarshal ¶
type MetricsBackend ¶
type MetricsBackend struct { // Name of the backend, can be then used in Mesh.metrics.enabledBackend Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Type of the backend (Kuma ships with 'prometheus') Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // Configuration of the backend Conf *_struct.Struct `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
MetricsBackend defines metric backends
func (*MetricsBackend) Descriptor ¶
func (*MetricsBackend) Descriptor() ([]byte, []int)
func (*MetricsBackend) GetConf ¶
func (m *MetricsBackend) GetConf() *_struct.Struct
func (*MetricsBackend) GetName ¶
func (m *MetricsBackend) GetName() string
func (*MetricsBackend) GetType ¶
func (m *MetricsBackend) GetType() string
func (*MetricsBackend) ProtoMessage ¶
func (*MetricsBackend) ProtoMessage()
func (*MetricsBackend) Reset ¶
func (m *MetricsBackend) Reset()
func (*MetricsBackend) String ¶
func (m *MetricsBackend) String() string
func (*MetricsBackend) XXX_DiscardUnknown ¶
func (m *MetricsBackend) XXX_DiscardUnknown()
func (*MetricsBackend) XXX_Marshal ¶
func (m *MetricsBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MetricsBackend) XXX_Merge ¶
func (m *MetricsBackend) XXX_Merge(src proto.Message)
func (*MetricsBackend) XXX_Size ¶
func (m *MetricsBackend) XXX_Size() int
func (*MetricsBackend) XXX_Unmarshal ¶
func (m *MetricsBackend) XXX_Unmarshal(b []byte) error
type MultiValueTagSet ¶
Set of tags that allows multiple values per key.
func (MultiValueTagSet) Keys ¶
func (t MultiValueTagSet) Keys() []string
func (MultiValueTagSet) String ¶
func (t MultiValueTagSet) String() string
func (MultiValueTagSet) Values ¶
func (t MultiValueTagSet) Values(key string) []string
type OutboundInterface ¶
func ParseOutboundInterface ¶
func ParseOutboundInterface(text string) (OutboundInterface, error)
func (OutboundInterface) String ¶
func (i OutboundInterface) String() string
type PrometheusMetricsBackendConfig ¶
type PrometheusMetricsBackendConfig struct { // Port on which a dataplane should expose HTTP endpoint with Prometheus // metrics. Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"` // Path on which a dataplane should expose HTTP endpoint with Prometheus // metrics. Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // Tags associated with an application this dataplane is deployed next to, // e.g. service=web, version=1.0. // `service` tag is mandatory. Tags map[string]string `` /* 149-byte string literal not displayed */ // If true then endpoints for scraping metrics won't require mTLS even if mTLS // is enabled in Mesh. If nil, then it is treated as false. SkipMTLS *wrappers.BoolValue `protobuf:"bytes,4,opt,name=skipMTLS,proto3" json:"skipMTLS,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PrometheusMetricsBackendConfig defines configuration of Prometheus backend
func (*PrometheusMetricsBackendConfig) Descriptor ¶
func (*PrometheusMetricsBackendConfig) Descriptor() ([]byte, []int)
func (*PrometheusMetricsBackendConfig) GetPath ¶
func (m *PrometheusMetricsBackendConfig) GetPath() string
func (*PrometheusMetricsBackendConfig) GetPort ¶
func (m *PrometheusMetricsBackendConfig) GetPort() uint32
func (*PrometheusMetricsBackendConfig) GetSkipMTLS ¶
func (m *PrometheusMetricsBackendConfig) GetSkipMTLS() *wrappers.BoolValue
func (*PrometheusMetricsBackendConfig) GetTags ¶
func (m *PrometheusMetricsBackendConfig) GetTags() map[string]string
func (*PrometheusMetricsBackendConfig) ProtoMessage ¶
func (*PrometheusMetricsBackendConfig) ProtoMessage()
func (*PrometheusMetricsBackendConfig) Reset ¶
func (m *PrometheusMetricsBackendConfig) Reset()
func (*PrometheusMetricsBackendConfig) String ¶
func (m *PrometheusMetricsBackendConfig) String() string
func (*PrometheusMetricsBackendConfig) XXX_DiscardUnknown ¶
func (m *PrometheusMetricsBackendConfig) XXX_DiscardUnknown()
func (*PrometheusMetricsBackendConfig) XXX_Marshal ¶
func (m *PrometheusMetricsBackendConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrometheusMetricsBackendConfig) XXX_Merge ¶
func (m *PrometheusMetricsBackendConfig) XXX_Merge(src proto.Message)
func (*PrometheusMetricsBackendConfig) XXX_Size ¶
func (m *PrometheusMetricsBackendConfig) XXX_Size() int
func (*PrometheusMetricsBackendConfig) XXX_Unmarshal ¶
func (m *PrometheusMetricsBackendConfig) XXX_Unmarshal(b []byte) error
type ProxyTemplate ¶
type ProxyTemplate struct { // List of Dataplane selectors. // +optional Selectors []*Selector `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"` // Configuration for ProxyTemplate Conf *ProxyTemplate_Conf `protobuf:"bytes,2,opt,name=conf,proto3" json:"conf,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ProxyTemplate defines the desired state of ProxyTemplate
func (*ProxyTemplate) Descriptor ¶
func (*ProxyTemplate) Descriptor() ([]byte, []int)
func (*ProxyTemplate) GetConf ¶
func (m *ProxyTemplate) GetConf() *ProxyTemplate_Conf
func (*ProxyTemplate) GetSelectors ¶
func (m *ProxyTemplate) GetSelectors() []*Selector
func (*ProxyTemplate) ProtoMessage ¶
func (*ProxyTemplate) ProtoMessage()
func (*ProxyTemplate) Reset ¶
func (m *ProxyTemplate) Reset()
func (*ProxyTemplate) String ¶
func (m *ProxyTemplate) String() string
func (*ProxyTemplate) XXX_DiscardUnknown ¶
func (m *ProxyTemplate) XXX_DiscardUnknown()
func (*ProxyTemplate) XXX_Marshal ¶
func (m *ProxyTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProxyTemplate) XXX_Merge ¶
func (m *ProxyTemplate) XXX_Merge(src proto.Message)
func (*ProxyTemplate) XXX_Size ¶
func (m *ProxyTemplate) XXX_Size() int
func (*ProxyTemplate) XXX_Unmarshal ¶
func (m *ProxyTemplate) XXX_Unmarshal(b []byte) error
type ProxyTemplateProfileSource ¶
type ProxyTemplateProfileSource struct { // Profile name. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Profile params if any. // +optional Params map[string]string `` /* 153-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProxyTemplateProfileSource) Descriptor ¶
func (*ProxyTemplateProfileSource) Descriptor() ([]byte, []int)
func (*ProxyTemplateProfileSource) GetName ¶
func (m *ProxyTemplateProfileSource) GetName() string
func (*ProxyTemplateProfileSource) GetParams ¶
func (m *ProxyTemplateProfileSource) GetParams() map[string]string
func (*ProxyTemplateProfileSource) ProtoMessage ¶
func (*ProxyTemplateProfileSource) ProtoMessage()
func (*ProxyTemplateProfileSource) Reset ¶
func (m *ProxyTemplateProfileSource) Reset()
func (*ProxyTemplateProfileSource) String ¶
func (m *ProxyTemplateProfileSource) String() string
func (*ProxyTemplateProfileSource) XXX_DiscardUnknown ¶
func (m *ProxyTemplateProfileSource) XXX_DiscardUnknown()
func (*ProxyTemplateProfileSource) XXX_Marshal ¶
func (m *ProxyTemplateProfileSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProxyTemplateProfileSource) XXX_Merge ¶
func (m *ProxyTemplateProfileSource) XXX_Merge(src proto.Message)
func (*ProxyTemplateProfileSource) XXX_Size ¶
func (m *ProxyTemplateProfileSource) XXX_Size() int
func (*ProxyTemplateProfileSource) XXX_Unmarshal ¶
func (m *ProxyTemplateProfileSource) XXX_Unmarshal(b []byte) error
type ProxyTemplateRawResource ¶
type ProxyTemplateRawResource struct { // The resource's name, to distinguish it from others of the same type of // resource. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The resource level version. It allows xDS to track the state of individual // resources. Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // xDS resource. Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProxyTemplateRawResource) Descriptor ¶
func (*ProxyTemplateRawResource) Descriptor() ([]byte, []int)
func (*ProxyTemplateRawResource) GetName ¶
func (m *ProxyTemplateRawResource) GetName() string
func (*ProxyTemplateRawResource) GetResource ¶
func (m *ProxyTemplateRawResource) GetResource() string
func (*ProxyTemplateRawResource) GetVersion ¶
func (m *ProxyTemplateRawResource) GetVersion() string
func (*ProxyTemplateRawResource) ProtoMessage ¶
func (*ProxyTemplateRawResource) ProtoMessage()
func (*ProxyTemplateRawResource) Reset ¶
func (m *ProxyTemplateRawResource) Reset()
func (*ProxyTemplateRawResource) String ¶
func (m *ProxyTemplateRawResource) String() string
func (*ProxyTemplateRawResource) XXX_DiscardUnknown ¶
func (m *ProxyTemplateRawResource) XXX_DiscardUnknown()
func (*ProxyTemplateRawResource) XXX_Marshal ¶
func (m *ProxyTemplateRawResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProxyTemplateRawResource) XXX_Merge ¶
func (m *ProxyTemplateRawResource) XXX_Merge(src proto.Message)
func (*ProxyTemplateRawResource) XXX_Size ¶
func (m *ProxyTemplateRawResource) XXX_Size() int
func (*ProxyTemplateRawResource) XXX_Unmarshal ¶
func (m *ProxyTemplateRawResource) XXX_Unmarshal(b []byte) error
type ProxyTemplateRawSource ¶
type ProxyTemplateRawSource struct { // List of raw xDS resources. // +optional Resources []*ProxyTemplateRawResource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProxyTemplateRawSource) Descriptor ¶
func (*ProxyTemplateRawSource) Descriptor() ([]byte, []int)
func (*ProxyTemplateRawSource) GetResources ¶
func (m *ProxyTemplateRawSource) GetResources() []*ProxyTemplateRawResource
func (*ProxyTemplateRawSource) ProtoMessage ¶
func (*ProxyTemplateRawSource) ProtoMessage()
func (*ProxyTemplateRawSource) Reset ¶
func (m *ProxyTemplateRawSource) Reset()
func (*ProxyTemplateRawSource) String ¶
func (m *ProxyTemplateRawSource) String() string
func (*ProxyTemplateRawSource) XXX_DiscardUnknown ¶
func (m *ProxyTemplateRawSource) XXX_DiscardUnknown()
func (*ProxyTemplateRawSource) XXX_Marshal ¶
func (m *ProxyTemplateRawSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProxyTemplateRawSource) XXX_Merge ¶
func (m *ProxyTemplateRawSource) XXX_Merge(src proto.Message)
func (*ProxyTemplateRawSource) XXX_Size ¶
func (m *ProxyTemplateRawSource) XXX_Size() int
func (*ProxyTemplateRawSource) XXX_Unmarshal ¶
func (m *ProxyTemplateRawSource) XXX_Unmarshal(b []byte) error
type ProxyTemplateSource ¶
type ProxyTemplateSource struct { // Name of a configuration source. // +optional Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Types that are valid to be assigned to Type: // *ProxyTemplateSource_Profile // *ProxyTemplateSource_Raw Type isProxyTemplateSource_Type `protobuf_oneof:"type"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProxyTemplateSource) Descriptor ¶
func (*ProxyTemplateSource) Descriptor() ([]byte, []int)
func (*ProxyTemplateSource) GetName ¶
func (m *ProxyTemplateSource) GetName() string
func (*ProxyTemplateSource) GetProfile ¶
func (m *ProxyTemplateSource) GetProfile() *ProxyTemplateProfileSource
func (*ProxyTemplateSource) GetRaw ¶
func (m *ProxyTemplateSource) GetRaw() *ProxyTemplateRawSource
func (*ProxyTemplateSource) GetType ¶
func (m *ProxyTemplateSource) GetType() isProxyTemplateSource_Type
func (*ProxyTemplateSource) ProtoMessage ¶
func (*ProxyTemplateSource) ProtoMessage()
func (*ProxyTemplateSource) Reset ¶
func (m *ProxyTemplateSource) Reset()
func (*ProxyTemplateSource) String ¶
func (m *ProxyTemplateSource) String() string
func (*ProxyTemplateSource) XXX_DiscardUnknown ¶
func (m *ProxyTemplateSource) XXX_DiscardUnknown()
func (*ProxyTemplateSource) XXX_Marshal ¶
func (m *ProxyTemplateSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProxyTemplateSource) XXX_Merge ¶
func (m *ProxyTemplateSource) XXX_Merge(src proto.Message)
func (*ProxyTemplateSource) XXX_OneofWrappers ¶
func (*ProxyTemplateSource) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ProxyTemplateSource) XXX_Size ¶
func (m *ProxyTemplateSource) XXX_Size() int
func (*ProxyTemplateSource) XXX_Unmarshal ¶
func (m *ProxyTemplateSource) XXX_Unmarshal(b []byte) error
type ProxyTemplateSource_Profile ¶
type ProxyTemplateSource_Profile struct {
Profile *ProxyTemplateProfileSource `protobuf:"bytes,2,opt,name=profile,proto3,oneof"`
}
type ProxyTemplateSource_Raw ¶
type ProxyTemplateSource_Raw struct {
Raw *ProxyTemplateRawSource `protobuf:"bytes,3,opt,name=raw,proto3,oneof"`
}
type ProxyTemplate_Conf ¶
type ProxyTemplate_Conf struct { // List of imported profiles. // +optional Imports []string `protobuf:"bytes,1,rep,name=imports,proto3" json:"imports,omitempty"` // List of raw xDS resources. // +optional Resources []*ProxyTemplateRawResource `protobuf:"bytes,2,rep,name=resources,proto3" json:"resources,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProxyTemplate_Conf) Descriptor ¶
func (*ProxyTemplate_Conf) Descriptor() ([]byte, []int)
func (*ProxyTemplate_Conf) GetImports ¶
func (m *ProxyTemplate_Conf) GetImports() []string
func (*ProxyTemplate_Conf) GetResources ¶
func (m *ProxyTemplate_Conf) GetResources() []*ProxyTemplateRawResource
func (*ProxyTemplate_Conf) ProtoMessage ¶
func (*ProxyTemplate_Conf) ProtoMessage()
func (*ProxyTemplate_Conf) Reset ¶
func (m *ProxyTemplate_Conf) Reset()
func (*ProxyTemplate_Conf) String ¶
func (m *ProxyTemplate_Conf) String() string
func (*ProxyTemplate_Conf) XXX_DiscardUnknown ¶
func (m *ProxyTemplate_Conf) XXX_DiscardUnknown()
func (*ProxyTemplate_Conf) XXX_Marshal ¶
func (m *ProxyTemplate_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProxyTemplate_Conf) XXX_Merge ¶
func (m *ProxyTemplate_Conf) XXX_Merge(src proto.Message)
func (*ProxyTemplate_Conf) XXX_Size ¶
func (m *ProxyTemplate_Conf) XXX_Size() int
func (*ProxyTemplate_Conf) XXX_Unmarshal ¶
func (m *ProxyTemplate_Conf) XXX_Unmarshal(b []byte) error
type Selector ¶
type Selector struct { // Tags to match, can be used for both source and destinations Match map[string]string `` /* 151-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Selector defines structure for selecting tags for given dataplane
func (*Selector) Descriptor ¶
func (*Selector) ProtoMessage ¶
func (*Selector) ProtoMessage()
func (*Selector) XXX_DiscardUnknown ¶
func (m *Selector) XXX_DiscardUnknown()
func (*Selector) XXX_Marshal ¶
func (*Selector) XXX_Unmarshal ¶
type SingleValueTagSet ¶
Set of tags that only allows a single value per key.
func (SingleValueTagSet) Exclude ¶
func (t SingleValueTagSet) Exclude(key string) SingleValueTagSet
func (SingleValueTagSet) Keys ¶
func (t SingleValueTagSet) Keys() []string
type TagSelector ¶
func MatchAll ¶
func MatchAll() TagSelector
func MatchAnyService ¶
func MatchAnyService() TagSelector
func MatchService ¶
func MatchService(service string) TagSelector
func MatchTags ¶
func MatchTags(tags map[string]string) TagSelector
func (TagSelector) Equal ¶
func (s TagSelector) Equal(other TagSelector) bool
func (TagSelector) Rank ¶
func (s TagSelector) Rank() (r TagSelectorRank)
type TagSelectorRank ¶
type TagSelectorRank struct { // Number of tags that match by the exact value. ExactMatches int // Number of tags that match by a wildcard ('*'). WildcardMatches int }
TagSelectorRank helps to decide which of 2 selectors is more specific.
func (TagSelectorRank) CombinedWith ¶
func (r TagSelectorRank) CombinedWith(other TagSelectorRank) TagSelectorRank
func (TagSelectorRank) CompareTo ¶
func (r TagSelectorRank) CompareTo(other TagSelectorRank) int
type TcpLoggingBackendConfig ¶
type TcpLoggingBackendConfig struct { // Address to TCP service that will receive logs Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
TcpLoggingBackendConfig defines configuration for TCP based access logs
func (*TcpLoggingBackendConfig) Descriptor ¶
func (*TcpLoggingBackendConfig) Descriptor() ([]byte, []int)
func (*TcpLoggingBackendConfig) GetAddress ¶
func (m *TcpLoggingBackendConfig) GetAddress() string
func (*TcpLoggingBackendConfig) ProtoMessage ¶
func (*TcpLoggingBackendConfig) ProtoMessage()
func (*TcpLoggingBackendConfig) Reset ¶
func (m *TcpLoggingBackendConfig) Reset()
func (*TcpLoggingBackendConfig) String ¶
func (m *TcpLoggingBackendConfig) String() string
func (*TcpLoggingBackendConfig) Validate ¶
func (m *TcpLoggingBackendConfig) Validate() error
Validate checks the field values on TcpLoggingBackendConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*TcpLoggingBackendConfig) XXX_DiscardUnknown ¶
func (m *TcpLoggingBackendConfig) XXX_DiscardUnknown()
func (*TcpLoggingBackendConfig) XXX_Marshal ¶
func (m *TcpLoggingBackendConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TcpLoggingBackendConfig) XXX_Merge ¶
func (m *TcpLoggingBackendConfig) XXX_Merge(src proto.Message)
func (*TcpLoggingBackendConfig) XXX_Size ¶
func (m *TcpLoggingBackendConfig) XXX_Size() int
func (*TcpLoggingBackendConfig) XXX_Unmarshal ¶
func (m *TcpLoggingBackendConfig) XXX_Unmarshal(b []byte) error
type TcpLoggingBackendConfigValidationError ¶
type TcpLoggingBackendConfigValidationError struct {
// contains filtered or unexported fields
}
TcpLoggingBackendConfigValidationError is the validation error returned by TcpLoggingBackendConfig.Validate if the designated constraints aren't met.
func (TcpLoggingBackendConfigValidationError) Cause ¶
func (e TcpLoggingBackendConfigValidationError) Cause() error
Cause function returns cause value.
func (TcpLoggingBackendConfigValidationError) Error ¶
func (e TcpLoggingBackendConfigValidationError) Error() string
Error satisfies the builtin error interface
func (TcpLoggingBackendConfigValidationError) ErrorName ¶
func (e TcpLoggingBackendConfigValidationError) ErrorName() string
ErrorName returns error name.
func (TcpLoggingBackendConfigValidationError) Field ¶
func (e TcpLoggingBackendConfigValidationError) Field() string
Field function returns field value.
func (TcpLoggingBackendConfigValidationError) Key ¶
func (e TcpLoggingBackendConfigValidationError) Key() bool
Key function returns key value.
func (TcpLoggingBackendConfigValidationError) Reason ¶
func (e TcpLoggingBackendConfigValidationError) Reason() string
Reason function returns reason value.
type Tracing ¶
type Tracing struct { // Name of the default backend DefaultBackend string `protobuf:"bytes,1,opt,name=defaultBackend,proto3" json:"defaultBackend,omitempty"` // List of available tracing backends Backends []*TracingBackend `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Tracing defines tracing configuration of the mesh.
func (*Tracing) Descriptor ¶
func (*Tracing) GetBackends ¶
func (m *Tracing) GetBackends() []*TracingBackend
func (*Tracing) GetDefaultBackend ¶
func (*Tracing) ProtoMessage ¶
func (*Tracing) ProtoMessage()
func (*Tracing) Validate ¶
Validate checks the field values on Tracing with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Tracing) XXX_DiscardUnknown ¶
func (m *Tracing) XXX_DiscardUnknown()
func (*Tracing) XXX_Marshal ¶
func (*Tracing) XXX_Unmarshal ¶
type TracingBackend ¶
type TracingBackend struct { // Name of the backend, can be then used in Mesh.tracing.defaultBackend or in // TrafficTrace Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Percentage of traces that will be sent to the backend (range 0.0 - 100.0). // Empty value defaults to 100.0% Sampling *wrappers.DoubleValue `protobuf:"bytes,2,opt,name=sampling,proto3" json:"sampling,omitempty"` // Type of the backend (Kuma ships with 'zipkin') Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // Configuration of the backend Conf *_struct.Struct `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
TracingBackend defines tracing backend available to mesh. Backends can be used in TrafficTrace rules.
func (*TracingBackend) Descriptor ¶
func (*TracingBackend) Descriptor() ([]byte, []int)
func (*TracingBackend) GetConf ¶
func (m *TracingBackend) GetConf() *_struct.Struct
func (*TracingBackend) GetName ¶
func (m *TracingBackend) GetName() string
func (*TracingBackend) GetSampling ¶
func (m *TracingBackend) GetSampling() *wrappers.DoubleValue
func (*TracingBackend) GetType ¶
func (m *TracingBackend) GetType() string
func (*TracingBackend) ProtoMessage ¶
func (*TracingBackend) ProtoMessage()
func (*TracingBackend) Reset ¶
func (m *TracingBackend) Reset()
func (*TracingBackend) String ¶
func (m *TracingBackend) String() string
func (*TracingBackend) Validate ¶
func (m *TracingBackend) Validate() error
Validate checks the field values on TracingBackend with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*TracingBackend) XXX_DiscardUnknown ¶
func (m *TracingBackend) XXX_DiscardUnknown()
func (*TracingBackend) XXX_Marshal ¶
func (m *TracingBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TracingBackend) XXX_Merge ¶
func (m *TracingBackend) XXX_Merge(src proto.Message)
func (*TracingBackend) XXX_Size ¶
func (m *TracingBackend) XXX_Size() int
func (*TracingBackend) XXX_Unmarshal ¶
func (m *TracingBackend) XXX_Unmarshal(b []byte) error
type TracingBackendValidationError ¶
type TracingBackendValidationError struct {
// contains filtered or unexported fields
}
TracingBackendValidationError is the validation error returned by TracingBackend.Validate if the designated constraints aren't met.
func (TracingBackendValidationError) Cause ¶
func (e TracingBackendValidationError) Cause() error
Cause function returns cause value.
func (TracingBackendValidationError) Error ¶
func (e TracingBackendValidationError) Error() string
Error satisfies the builtin error interface
func (TracingBackendValidationError) ErrorName ¶
func (e TracingBackendValidationError) ErrorName() string
ErrorName returns error name.
func (TracingBackendValidationError) Field ¶
func (e TracingBackendValidationError) Field() string
Field function returns field value.
func (TracingBackendValidationError) Key ¶
func (e TracingBackendValidationError) Key() bool
Key function returns key value.
func (TracingBackendValidationError) Reason ¶
func (e TracingBackendValidationError) Reason() string
Reason function returns reason value.
type TracingValidationError ¶
type TracingValidationError struct {
// contains filtered or unexported fields
}
TracingValidationError is the validation error returned by Tracing.Validate if the designated constraints aren't met.
func (TracingValidationError) Cause ¶
func (e TracingValidationError) Cause() error
Cause function returns cause value.
func (TracingValidationError) Error ¶
func (e TracingValidationError) Error() string
Error satisfies the builtin error interface
func (TracingValidationError) ErrorName ¶
func (e TracingValidationError) ErrorName() string
ErrorName returns error name.
func (TracingValidationError) Field ¶
func (e TracingValidationError) Field() string
Field function returns field value.
func (TracingValidationError) Key ¶
func (e TracingValidationError) Key() bool
Key function returns key value.
func (TracingValidationError) Reason ¶
func (e TracingValidationError) Reason() string
Reason function returns reason value.
type TrafficLog ¶
type TrafficLog struct { // List of selectors to match dataplanes that are sources of traffic. Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"` // List of selectors to match services that are destinations of traffic. Destinations []*Selector `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"` // Configuration of the logging. Conf *TrafficLog_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
TrafficLog defines log for traffic between dataplanes.
func (*TrafficLog) Descriptor ¶
func (*TrafficLog) Descriptor() ([]byte, []int)
func (*TrafficLog) GetConf ¶
func (m *TrafficLog) GetConf() *TrafficLog_Conf
func (*TrafficLog) GetDestinations ¶
func (m *TrafficLog) GetDestinations() []*Selector
func (*TrafficLog) GetSources ¶
func (m *TrafficLog) GetSources() []*Selector
func (*TrafficLog) ProtoMessage ¶
func (*TrafficLog) ProtoMessage()
func (*TrafficLog) Reset ¶
func (m *TrafficLog) Reset()
func (*TrafficLog) String ¶
func (m *TrafficLog) String() string
func (*TrafficLog) XXX_DiscardUnknown ¶
func (m *TrafficLog) XXX_DiscardUnknown()
func (*TrafficLog) XXX_Marshal ¶
func (m *TrafficLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TrafficLog) XXX_Merge ¶
func (m *TrafficLog) XXX_Merge(src proto.Message)
func (*TrafficLog) XXX_Size ¶
func (m *TrafficLog) XXX_Size() int
func (*TrafficLog) XXX_Unmarshal ¶
func (m *TrafficLog) XXX_Unmarshal(b []byte) error
type TrafficLog_Conf ¶
type TrafficLog_Conf struct { // Backend defined in the Mesh entity. Backend string `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Configuration defines settings of the logging.
func (*TrafficLog_Conf) Descriptor ¶
func (*TrafficLog_Conf) Descriptor() ([]byte, []int)
func (*TrafficLog_Conf) GetBackend ¶
func (m *TrafficLog_Conf) GetBackend() string
func (*TrafficLog_Conf) ProtoMessage ¶
func (*TrafficLog_Conf) ProtoMessage()
func (*TrafficLog_Conf) Reset ¶
func (m *TrafficLog_Conf) Reset()
func (*TrafficLog_Conf) String ¶
func (m *TrafficLog_Conf) String() string
func (*TrafficLog_Conf) XXX_DiscardUnknown ¶
func (m *TrafficLog_Conf) XXX_DiscardUnknown()
func (*TrafficLog_Conf) XXX_Marshal ¶
func (m *TrafficLog_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TrafficLog_Conf) XXX_Merge ¶
func (m *TrafficLog_Conf) XXX_Merge(src proto.Message)
func (*TrafficLog_Conf) XXX_Size ¶
func (m *TrafficLog_Conf) XXX_Size() int
func (*TrafficLog_Conf) XXX_Unmarshal ¶
func (m *TrafficLog_Conf) XXX_Unmarshal(b []byte) error
type TrafficPermission ¶
type TrafficPermission struct { // List of selectors to match dataplanes that are sources of traffic. Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"` // List of selectors to match services that are destinations of traffic. Destinations []*Selector `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
TrafficPermission defines permission for traffic between dataplanes.
func (*TrafficPermission) Descriptor ¶
func (*TrafficPermission) Descriptor() ([]byte, []int)
func (*TrafficPermission) GetDestinations ¶
func (m *TrafficPermission) GetDestinations() []*Selector
func (*TrafficPermission) GetSources ¶
func (m *TrafficPermission) GetSources() []*Selector
func (*TrafficPermission) ProtoMessage ¶
func (*TrafficPermission) ProtoMessage()
func (*TrafficPermission) Reset ¶
func (m *TrafficPermission) Reset()
func (*TrafficPermission) String ¶
func (m *TrafficPermission) String() string
func (*TrafficPermission) XXX_DiscardUnknown ¶
func (m *TrafficPermission) XXX_DiscardUnknown()
func (*TrafficPermission) XXX_Marshal ¶
func (m *TrafficPermission) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TrafficPermission) XXX_Merge ¶
func (m *TrafficPermission) XXX_Merge(src proto.Message)
func (*TrafficPermission) XXX_Size ¶
func (m *TrafficPermission) XXX_Size() int
func (*TrafficPermission) XXX_Unmarshal ¶
func (m *TrafficPermission) XXX_Unmarshal(b []byte) error
type TrafficRoute ¶
type TrafficRoute struct { // List of selectors to match dataplanes that are sources of traffic. Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"` // List of selectors to match services that are destinations of traffic. // // Notice the difference between sources and destinations. // While the source of traffic is always a dataplane within a mesh, // the destination is a service that could be either within or outside // of a mesh. Destinations []*Selector `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"` // List of destinations with weights assigned to them. Conf []*TrafficRoute_WeightedDestination `protobuf:"bytes,3,rep,name=conf,proto3" json:"conf,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
TrafficRoute defines routing rules for L4 traffic.
func (*TrafficRoute) Descriptor ¶
func (*TrafficRoute) Descriptor() ([]byte, []int)
func (*TrafficRoute) GetConf ¶
func (m *TrafficRoute) GetConf() []*TrafficRoute_WeightedDestination
func (*TrafficRoute) GetDestinations ¶
func (m *TrafficRoute) GetDestinations() []*Selector
func (*TrafficRoute) GetSources ¶
func (m *TrafficRoute) GetSources() []*Selector
func (*TrafficRoute) ProtoMessage ¶
func (*TrafficRoute) ProtoMessage()
func (*TrafficRoute) Reset ¶
func (m *TrafficRoute) Reset()
func (*TrafficRoute) String ¶
func (m *TrafficRoute) String() string
func (*TrafficRoute) Validate ¶
func (m *TrafficRoute) Validate() error
Validate checks the field values on TrafficRoute with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*TrafficRoute) XXX_DiscardUnknown ¶
func (m *TrafficRoute) XXX_DiscardUnknown()
func (*TrafficRoute) XXX_Marshal ¶
func (m *TrafficRoute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TrafficRoute) XXX_Merge ¶
func (m *TrafficRoute) XXX_Merge(src proto.Message)
func (*TrafficRoute) XXX_Size ¶
func (m *TrafficRoute) XXX_Size() int
func (*TrafficRoute) XXX_Unmarshal ¶
func (m *TrafficRoute) XXX_Unmarshal(b []byte) error
type TrafficRouteValidationError ¶
type TrafficRouteValidationError struct {
// contains filtered or unexported fields
}
TrafficRouteValidationError is the validation error returned by TrafficRoute.Validate if the designated constraints aren't met.
func (TrafficRouteValidationError) Cause ¶
func (e TrafficRouteValidationError) Cause() error
Cause function returns cause value.
func (TrafficRouteValidationError) Error ¶
func (e TrafficRouteValidationError) Error() string
Error satisfies the builtin error interface
func (TrafficRouteValidationError) ErrorName ¶
func (e TrafficRouteValidationError) ErrorName() string
ErrorName returns error name.
func (TrafficRouteValidationError) Field ¶
func (e TrafficRouteValidationError) Field() string
Field function returns field value.
func (TrafficRouteValidationError) Key ¶
func (e TrafficRouteValidationError) Key() bool
Key function returns key value.
func (TrafficRouteValidationError) Reason ¶
func (e TrafficRouteValidationError) Reason() string
Reason function returns reason value.
type TrafficRoute_WeightedDestination ¶
type TrafficRoute_WeightedDestination struct { // Weight assigned to that destination. Weight uint32 `protobuf:"varint,1,opt,name=weight,proto3" json:"weight,omitempty"` // Selector to match individual endpoints that comprise that destination. // // Notice that an endpoint can be either inside or outside the mesh. // In the former case an endpoint corresponds to a dataplane, // in the latter case an endpoint is a black box. Destination map[string]string `` /* 163-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
WeightedDestination defines a destination with a weight assigned to it.
func (*TrafficRoute_WeightedDestination) Descriptor ¶
func (*TrafficRoute_WeightedDestination) Descriptor() ([]byte, []int)
func (*TrafficRoute_WeightedDestination) GetDestination ¶
func (m *TrafficRoute_WeightedDestination) GetDestination() map[string]string
func (*TrafficRoute_WeightedDestination) GetWeight ¶
func (m *TrafficRoute_WeightedDestination) GetWeight() uint32
func (*TrafficRoute_WeightedDestination) ProtoMessage ¶
func (*TrafficRoute_WeightedDestination) ProtoMessage()
func (*TrafficRoute_WeightedDestination) Reset ¶
func (m *TrafficRoute_WeightedDestination) Reset()
func (*TrafficRoute_WeightedDestination) String ¶
func (m *TrafficRoute_WeightedDestination) String() string
func (*TrafficRoute_WeightedDestination) Validate ¶
func (m *TrafficRoute_WeightedDestination) Validate() error
Validate checks the field values on TrafficRoute_WeightedDestination with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*TrafficRoute_WeightedDestination) XXX_DiscardUnknown ¶
func (m *TrafficRoute_WeightedDestination) XXX_DiscardUnknown()
func (*TrafficRoute_WeightedDestination) XXX_Marshal ¶
func (m *TrafficRoute_WeightedDestination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TrafficRoute_WeightedDestination) XXX_Merge ¶
func (m *TrafficRoute_WeightedDestination) XXX_Merge(src proto.Message)
func (*TrafficRoute_WeightedDestination) XXX_Size ¶
func (m *TrafficRoute_WeightedDestination) XXX_Size() int
func (*TrafficRoute_WeightedDestination) XXX_Unmarshal ¶
func (m *TrafficRoute_WeightedDestination) XXX_Unmarshal(b []byte) error
type TrafficRoute_WeightedDestinationValidationError ¶
type TrafficRoute_WeightedDestinationValidationError struct {
// contains filtered or unexported fields
}
TrafficRoute_WeightedDestinationValidationError is the validation error returned by TrafficRoute_WeightedDestination.Validate if the designated constraints aren't met.
func (TrafficRoute_WeightedDestinationValidationError) Cause ¶
func (e TrafficRoute_WeightedDestinationValidationError) Cause() error
Cause function returns cause value.
func (TrafficRoute_WeightedDestinationValidationError) Error ¶
func (e TrafficRoute_WeightedDestinationValidationError) Error() string
Error satisfies the builtin error interface
func (TrafficRoute_WeightedDestinationValidationError) ErrorName ¶
func (e TrafficRoute_WeightedDestinationValidationError) ErrorName() string
ErrorName returns error name.
func (TrafficRoute_WeightedDestinationValidationError) Field ¶
func (e TrafficRoute_WeightedDestinationValidationError) Field() string
Field function returns field value.
func (TrafficRoute_WeightedDestinationValidationError) Key ¶
func (e TrafficRoute_WeightedDestinationValidationError) Key() bool
Key function returns key value.
func (TrafficRoute_WeightedDestinationValidationError) Reason ¶
func (e TrafficRoute_WeightedDestinationValidationError) Reason() string
Reason function returns reason value.
type TrafficTrace ¶
type TrafficTrace struct { // List of selectors to match dataplanes. Selectors []*Selector `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"` // Configuration of the tracing. Conf *TrafficTrace_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
TrafficTrace defines trace configuration for selected dataplanes.
func (*TrafficTrace) Descriptor ¶
func (*TrafficTrace) Descriptor() ([]byte, []int)
func (*TrafficTrace) GetConf ¶
func (m *TrafficTrace) GetConf() *TrafficTrace_Conf
func (*TrafficTrace) GetSelectors ¶
func (m *TrafficTrace) GetSelectors() []*Selector
func (*TrafficTrace) ProtoMessage ¶
func (*TrafficTrace) ProtoMessage()
func (*TrafficTrace) Reset ¶
func (m *TrafficTrace) Reset()
func (*TrafficTrace) String ¶
func (m *TrafficTrace) String() string
func (*TrafficTrace) XXX_DiscardUnknown ¶
func (m *TrafficTrace) XXX_DiscardUnknown()
func (*TrafficTrace) XXX_Marshal ¶
func (m *TrafficTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TrafficTrace) XXX_Merge ¶
func (m *TrafficTrace) XXX_Merge(src proto.Message)
func (*TrafficTrace) XXX_Size ¶
func (m *TrafficTrace) XXX_Size() int
func (*TrafficTrace) XXX_Unmarshal ¶
func (m *TrafficTrace) XXX_Unmarshal(b []byte) error
type TrafficTrace_Conf ¶
type TrafficTrace_Conf struct { // Backend defined in the Mesh entity. Backend string `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Configuration defines settings of the tracing.
func (*TrafficTrace_Conf) Descriptor ¶
func (*TrafficTrace_Conf) Descriptor() ([]byte, []int)
func (*TrafficTrace_Conf) GetBackend ¶
func (m *TrafficTrace_Conf) GetBackend() string
func (*TrafficTrace_Conf) ProtoMessage ¶
func (*TrafficTrace_Conf) ProtoMessage()
func (*TrafficTrace_Conf) Reset ¶
func (m *TrafficTrace_Conf) Reset()
func (*TrafficTrace_Conf) String ¶
func (m *TrafficTrace_Conf) String() string
func (*TrafficTrace_Conf) XXX_DiscardUnknown ¶
func (m *TrafficTrace_Conf) XXX_DiscardUnknown()
func (*TrafficTrace_Conf) XXX_Marshal ¶
func (m *TrafficTrace_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TrafficTrace_Conf) XXX_Merge ¶
func (m *TrafficTrace_Conf) XXX_Merge(src proto.Message)
func (*TrafficTrace_Conf) XXX_Size ¶
func (m *TrafficTrace_Conf) XXX_Size() int
func (*TrafficTrace_Conf) XXX_Unmarshal ¶
func (m *TrafficTrace_Conf) XXX_Unmarshal(b []byte) error
type UnimplementedKumaDiscoveryServiceServer ¶
type UnimplementedKumaDiscoveryServiceServer struct { }
UnimplementedKumaDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedKumaDiscoveryServiceServer) DeltaKumaResources ¶
func (*UnimplementedKumaDiscoveryServiceServer) DeltaKumaResources(srv KumaDiscoveryService_DeltaKumaResourcesServer) error
func (*UnimplementedKumaDiscoveryServiceServer) FetchKumaResources ¶
func (*UnimplementedKumaDiscoveryServiceServer) FetchKumaResources(ctx context.Context, req *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
func (*UnimplementedKumaDiscoveryServiceServer) StreamKumaResources ¶
func (*UnimplementedKumaDiscoveryServiceServer) StreamKumaResources(srv KumaDiscoveryService_StreamKumaResourcesServer) error
type ZipkinTracingBackendConfig ¶
type ZipkinTracingBackendConfig struct { // Address of Zipkin collector. Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` // Generate 128bit traces. Default: false TraceId128Bit bool `protobuf:"varint,2,opt,name=traceId128bit,proto3" json:"traceId128bit,omitempty"` // Version of the API. values: httpJson, httpJsonV1, httpProto. Default: // httpJson see // https://www.envoyproxy.io/docs/envoy/latest/api-v3/config/trace/v3/trace.proto#envoy-v3-api-enum-config-trace-v3-zipkinconfig-collectorendpointversion ApiVersion string `protobuf:"bytes,3,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ZipkinTracingBackendConfig) Descriptor ¶
func (*ZipkinTracingBackendConfig) Descriptor() ([]byte, []int)
func (*ZipkinTracingBackendConfig) GetApiVersion ¶
func (m *ZipkinTracingBackendConfig) GetApiVersion() string
func (*ZipkinTracingBackendConfig) GetTraceId128Bit ¶
func (m *ZipkinTracingBackendConfig) GetTraceId128Bit() bool
func (*ZipkinTracingBackendConfig) GetUrl ¶
func (m *ZipkinTracingBackendConfig) GetUrl() string
func (*ZipkinTracingBackendConfig) ProtoMessage ¶
func (*ZipkinTracingBackendConfig) ProtoMessage()
func (*ZipkinTracingBackendConfig) Reset ¶
func (m *ZipkinTracingBackendConfig) Reset()
func (*ZipkinTracingBackendConfig) String ¶
func (m *ZipkinTracingBackendConfig) String() string
func (*ZipkinTracingBackendConfig) Validate ¶
func (m *ZipkinTracingBackendConfig) Validate() error
Validate checks the field values on ZipkinTracingBackendConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*ZipkinTracingBackendConfig) XXX_DiscardUnknown ¶
func (m *ZipkinTracingBackendConfig) XXX_DiscardUnknown()
func (*ZipkinTracingBackendConfig) XXX_Marshal ¶
func (m *ZipkinTracingBackendConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ZipkinTracingBackendConfig) XXX_Merge ¶
func (m *ZipkinTracingBackendConfig) XXX_Merge(src proto.Message)
func (*ZipkinTracingBackendConfig) XXX_Size ¶
func (m *ZipkinTracingBackendConfig) XXX_Size() int
func (*ZipkinTracingBackendConfig) XXX_Unmarshal ¶
func (m *ZipkinTracingBackendConfig) XXX_Unmarshal(b []byte) error
type ZipkinTracingBackendConfigValidationError ¶
type ZipkinTracingBackendConfigValidationError struct {
// contains filtered or unexported fields
}
ZipkinTracingBackendConfigValidationError is the validation error returned by ZipkinTracingBackendConfig.Validate if the designated constraints aren't met.
func (ZipkinTracingBackendConfigValidationError) Cause ¶
func (e ZipkinTracingBackendConfigValidationError) Cause() error
Cause function returns cause value.
func (ZipkinTracingBackendConfigValidationError) Error ¶
func (e ZipkinTracingBackendConfigValidationError) Error() string
Error satisfies the builtin error interface
func (ZipkinTracingBackendConfigValidationError) ErrorName ¶
func (e ZipkinTracingBackendConfigValidationError) ErrorName() string
ErrorName returns error name.
func (ZipkinTracingBackendConfigValidationError) Field ¶
func (e ZipkinTracingBackendConfigValidationError) Field() string
Field function returns field value.
func (ZipkinTracingBackendConfigValidationError) Key ¶
func (e ZipkinTracingBackendConfigValidationError) Key() bool
Key function returns key value.
func (ZipkinTracingBackendConfigValidationError) Reason ¶
func (e ZipkinTracingBackendConfigValidationError) Reason() string
Reason function returns reason value.
Source Files ¶
- circuit_breaker.pb.go
- dataplane.pb.go
- dataplane.pb.validate.go
- dataplane_helpers.go
- dataplane_insight.pb.go
- dataplane_insight_helpers.go
- dataplane_overview.pb.go
- fault_injection.pb.go
- fault_injection_helpers.go
- health_check.pb.go
- health_check.pb.validate.go
- kds.pb.go
- kds.pb.validate.go
- known_backends.go
- mesh.pb.go
- mesh.pb.validate.go
- metrics.pb.go
- proxy_template.pb.go
- selector.pb.go
- traffic_log.pb.go
- traffic_permission.pb.go
- traffic_route.pb.go
- traffic_route.pb.validate.go
- traffic_trace.pb.go