v1alpha1

package
v0.0.0-...-7118e27 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 26, 2021 License: Apache-2.0 Imports: 25 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	// Mandatory tag that has a reserved meaning in Kuma.
	ServiceTag     = "kuma.io/service"
	ServiceUnknown = "unknown"

	// Locality related tags
	RegionTag  = "kuma.io/region"
	ZoneTag    = "kuma.io/zone"
	SubZoneTag = "kuma.io/sub-zone"

	// Optional tag that has a reserved meaning in Kuma.
	// If absent, Kuma will treat application's protocol as opaque TCP.
	ProtocolTag = "kuma.io/protocol"
	// InstanceTag is set only for Dataplanes that implements headless services
	InstanceTag = "kuma.io/instance"

	// External service tag
	ExternalServiceTag = "kuma.io/external-service-name"

	// Used for Service-less dataplanes
	TCPPortReserved = 49151 // IANA Reserved
)
View Source 
const (
	LoggingTcpType  = "tcp"
	LoggingFileType = "file"

	TracingZipkinType  = "zipkin"
	TracingDatadogType = "datadog"

	MetricsPrometheusType = "prometheus"
)
View Source 
const (
	OpAdd       = "add"
	OpAddFirst  = "addFirst"
	OpAddLast   = "addLast"
	OpAddBefore = "addBefore"
	OpAddAfter  = "addAfter"
	OpRemove    = "remove"
	OpPatch     = "patch"
)
View Source 
const MatchAllTag = "*"

Variables

View Source 
var (
	Retry_Conf_Grpc_RetryOn_name = map[int32]string{
		0: "cancelled",
		1: "deadline_exceeded",
		2: "internal",
		3: "resource_exhausted",
		4: "unavailable",
	}
	Retry_Conf_Grpc_RetryOn_value = map[string]int32{
		"cancelled":          0,
		"deadline_exceeded":  1,
		"internal":           2,
		"resource_exhausted": 3,
		"unavailable":        4,
	}
)

Enum value maps for Retry_Conf_Grpc_RetryOn.

View Source 
var (
	ServiceInsight_Service_Status_name = map[int32]string{
		0: "none",
		1: "offline",
		2: "partially_degraded",
		3: "online",
	}
	ServiceInsight_Service_Status_value = map[string]int32{
		"none":               0,
		"offline":            1,
		"partially_degraded": 2,
		"online":             3,
	}
)

Enum value maps for ServiceInsight_Service_Status.

View Source 
var File_mesh_v1alpha1_circuit_breaker_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_dataplane_insight_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_dataplane_overview_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_dataplane_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_externalservice_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_fault_injection_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_health_check_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_kds_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_mesh_insight_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_mesh_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_metrics_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_mux_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_proxy_template_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_rate_limit_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_retry_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_selector_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_service_insight_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_timeout_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_traffic_log_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_traffic_permission_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_traffic_route_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_traffic_trace_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_zone_ingress_insight_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_zone_ingress_proto protoreflect.FileDescriptor
View Source 
var File_mesh_v1alpha1_zoneingress_overview_proto protoreflect.FileDescriptor

Functions

func RegisterKumaDiscoveryServiceServer 

func RegisterKumaDiscoveryServiceServer(s *grpc.Server, srv KumaDiscoveryServiceServer)

func RegisterMultiplexServiceServer 

func RegisterMultiplexServiceServer(s *grpc.Server, srv MultiplexServiceServer)

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 *structpb.Struct `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

CertificateAuthorityBackend defines Certificate Authority backend

func (*CertificateAuthorityBackend) Descriptor deprecated 

func (*CertificateAuthorityBackend) Descriptor() ([]byte, []int)

Deprecated: Use CertificateAuthorityBackend.ProtoReflect.Descriptor instead.

func (*CertificateAuthorityBackend) GetConf 

func (x *CertificateAuthorityBackend) GetConf() *structpb.Struct

func (*CertificateAuthorityBackend) GetDpCert 

func (x *CertificateAuthorityBackend) GetDpCert() *CertificateAuthorityBackend_DpCert

func (*CertificateAuthorityBackend) GetName 

func (x *CertificateAuthorityBackend) GetName() string

func (*CertificateAuthorityBackend) GetType 

func (x *CertificateAuthorityBackend) GetType() string

func (*CertificateAuthorityBackend) ProtoMessage 

func (*CertificateAuthorityBackend) ProtoMessage()

func (*CertificateAuthorityBackend) ProtoReflect 

func (x *CertificateAuthorityBackend) ProtoReflect() protoreflect.Message

func (*CertificateAuthorityBackend) Reset 

func (x *CertificateAuthorityBackend) Reset()

func (*CertificateAuthorityBackend) String 

func (x *CertificateAuthorityBackend) String() string

type CertificateAuthorityBackend_DpCert 

type CertificateAuthorityBackend_DpCert struct {

	// Rotation settings
	Rotation *CertificateAuthorityBackend_DpCert_Rotation `protobuf:"bytes,1,opt,name=rotation,proto3" json:"rotation,omitempty"`
	// contains filtered or unexported fields
}

DpCert defines settings for certificates generated for Dataplanes

func (*CertificateAuthorityBackend_DpCert) Descriptor deprecated 

func (*CertificateAuthorityBackend_DpCert) Descriptor() ([]byte, []int)

Deprecated: Use CertificateAuthorityBackend_DpCert.ProtoReflect.Descriptor instead.

func (*CertificateAuthorityBackend_DpCert) GetRotation 

func (x *CertificateAuthorityBackend_DpCert) GetRotation() *CertificateAuthorityBackend_DpCert_Rotation

func (*CertificateAuthorityBackend_DpCert) ProtoMessage 

func (*CertificateAuthorityBackend_DpCert) ProtoMessage()

func (*CertificateAuthorityBackend_DpCert) ProtoReflect 

func (x *CertificateAuthorityBackend_DpCert) ProtoReflect() protoreflect.Message

func (*CertificateAuthorityBackend_DpCert) Reset 

func (x *CertificateAuthorityBackend_DpCert) Reset()

func (*CertificateAuthorityBackend_DpCert) String 

func (x *CertificateAuthorityBackend_DpCert) String() string

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"`
	// contains filtered or unexported fields
}

Rotation defines rotation settings for Dataplane certificate

func (*CertificateAuthorityBackend_DpCert_Rotation) Descriptor deprecated 

func (*CertificateAuthorityBackend_DpCert_Rotation) Descriptor() ([]byte, []int)

Deprecated: Use CertificateAuthorityBackend_DpCert_Rotation.ProtoReflect.Descriptor instead.

func (*CertificateAuthorityBackend_DpCert_Rotation) GetExpiration 

func (x *CertificateAuthorityBackend_DpCert_Rotation) GetExpiration() string

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage 

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage()

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoReflect 

func (x *CertificateAuthorityBackend_DpCert_Rotation) ProtoReflect() protoreflect.Message

func (*CertificateAuthorityBackend_DpCert_Rotation) Reset 

func (x *CertificateAuthorityBackend_DpCert_Rotation) Reset()

func (*CertificateAuthorityBackend_DpCert_Rotation) String 

func (x *CertificateAuthorityBackend_DpCert_Rotation) String() string

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"`
	// contains filtered or unexported fields
}

CircuitBreaker defines circuit breaking policy for dataplane's outbound

func (*CircuitBreaker) Descriptor deprecated 

func (*CircuitBreaker) Descriptor() ([]byte, []int)

Deprecated: Use CircuitBreaker.ProtoReflect.Descriptor instead.

func (*CircuitBreaker) GetConf 

func (x *CircuitBreaker) GetConf() *CircuitBreaker_Conf

func (*CircuitBreaker) GetDestinations 

func (x *CircuitBreaker) GetDestinations() []*Selector

func (*CircuitBreaker) GetSources 

func (x *CircuitBreaker) GetSources() []*Selector

func (*CircuitBreaker) ProtoMessage 

func (*CircuitBreaker) ProtoMessage()

func (*CircuitBreaker) ProtoReflect 

func (x *CircuitBreaker) ProtoReflect() protoreflect.Message

func (*CircuitBreaker) Reset 

func (x *CircuitBreaker) Reset()

func (*CircuitBreaker) String 

func (x *CircuitBreaker) String() string

type CircuitBreaker_Conf 

type CircuitBreaker_Conf struct {

	// Time interval between ejection analysis sweeps
	Interval *durationpb.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 *durationpb.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 *wrapperspb.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"`
	Thresholds                  *CircuitBreaker_Conf_Thresholds `protobuf:"bytes,6,opt,name=thresholds,proto3" json:"thresholds,omitempty"`
	// contains filtered or unexported fields
}

func (*CircuitBreaker_Conf) Descriptor deprecated 

func (*CircuitBreaker_Conf) Descriptor() ([]byte, []int)

Deprecated: Use CircuitBreaker_Conf.ProtoReflect.Descriptor instead.

func (*CircuitBreaker_Conf) GetBaseEjectionTime 

func (x *CircuitBreaker_Conf) GetBaseEjectionTime() *durationpb.Duration

func (*CircuitBreaker_Conf) GetDetectors 

func (x *CircuitBreaker_Conf) GetDetectors() *CircuitBreaker_Conf_Detectors

func (*CircuitBreaker_Conf) GetInterval 

func (x *CircuitBreaker_Conf) GetInterval() *durationpb.Duration

func (*CircuitBreaker_Conf) GetMaxEjectionPercent 

func (x *CircuitBreaker_Conf) GetMaxEjectionPercent() *wrapperspb.UInt32Value

func (*CircuitBreaker_Conf) GetSplitExternalAndLocalErrors 

func (x *CircuitBreaker_Conf) GetSplitExternalAndLocalErrors() bool

func (*CircuitBreaker_Conf) GetThresholds 

func (x *CircuitBreaker_Conf) GetThresholds() *CircuitBreaker_Conf_Thresholds

func (*CircuitBreaker_Conf) ProtoMessage 

func (*CircuitBreaker_Conf) ProtoMessage()

func (*CircuitBreaker_Conf) ProtoReflect 

func (x *CircuitBreaker_Conf) ProtoReflect() protoreflect.Message

func (*CircuitBreaker_Conf) Reset 

func (x *CircuitBreaker_Conf) Reset()

func (*CircuitBreaker_Conf) String 

func (x *CircuitBreaker_Conf) String() string

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"`
	// contains filtered or unexported fields
}

func (*CircuitBreaker_Conf_Detectors) Descriptor deprecated 

func (*CircuitBreaker_Conf_Detectors) Descriptor() ([]byte, []int)

Deprecated: Use CircuitBreaker_Conf_Detectors.ProtoReflect.Descriptor instead.

func (*CircuitBreaker_Conf_Detectors) GetFailure 

func (x *CircuitBreaker_Conf_Detectors) GetFailure() *CircuitBreaker_Conf_Detectors_Failure

func (*CircuitBreaker_Conf_Detectors) GetGatewayErrors 

func (x *CircuitBreaker_Conf_Detectors) GetGatewayErrors() *CircuitBreaker_Conf_Detectors_Errors

func (*CircuitBreaker_Conf_Detectors) GetLocalErrors 

func (x *CircuitBreaker_Conf_Detectors) GetLocalErrors() *CircuitBreaker_Conf_Detectors_Errors

func (*CircuitBreaker_Conf_Detectors) GetStandardDeviation 

func (x *CircuitBreaker_Conf_Detectors) GetStandardDeviation() *CircuitBreaker_Conf_Detectors_StandardDeviation

func (*CircuitBreaker_Conf_Detectors) GetTotalErrors 

func (x *CircuitBreaker_Conf_Detectors) GetTotalErrors() *CircuitBreaker_Conf_Detectors_Errors

func (*CircuitBreaker_Conf_Detectors) ProtoMessage 

func (*CircuitBreaker_Conf_Detectors) ProtoMessage()

func (*CircuitBreaker_Conf_Detectors) ProtoReflect 

func (x *CircuitBreaker_Conf_Detectors) ProtoReflect() protoreflect.Message

func (*CircuitBreaker_Conf_Detectors) Reset 

func (x *CircuitBreaker_Conf_Detectors) Reset()

func (*CircuitBreaker_Conf_Detectors) String 

func (x *CircuitBreaker_Conf_Detectors) String() string

type CircuitBreaker_Conf_Detectors_Errors 

type CircuitBreaker_Conf_Detectors_Errors struct {
	Consecutive *wrapperspb.UInt32Value `protobuf:"bytes,1,opt,name=consecutive,proto3" json:"consecutive,omitempty"`
	// contains filtered or unexported fields
}

Detector based on counting consecutive number of errors

func (*CircuitBreaker_Conf_Detectors_Errors) Descriptor deprecated 

func (*CircuitBreaker_Conf_Detectors_Errors) Descriptor() ([]byte, []int)

Deprecated: Use CircuitBreaker_Conf_Detectors_Errors.ProtoReflect.Descriptor instead.

func (*CircuitBreaker_Conf_Detectors_Errors) GetConsecutive 

func (x *CircuitBreaker_Conf_Detectors_Errors) GetConsecutive() *wrapperspb.UInt32Value

func (*CircuitBreaker_Conf_Detectors_Errors) ProtoMessage 

func (*CircuitBreaker_Conf_Detectors_Errors) ProtoMessage()

func (*CircuitBreaker_Conf_Detectors_Errors) ProtoReflect 

func (x *CircuitBreaker_Conf_Detectors_Errors) ProtoReflect() protoreflect.Message

func (*CircuitBreaker_Conf_Detectors_Errors) Reset 

func (x *CircuitBreaker_Conf_Detectors_Errors) Reset()

func (*CircuitBreaker_Conf_Detectors_Errors) String 

func (x *CircuitBreaker_Conf_Detectors_Errors) String() string

type CircuitBreaker_Conf_Detectors_Failure 

type CircuitBreaker_Conf_Detectors_Failure struct {

	// Ignore hosts with less number of requests than 'requestVolume'
	RequestVolume *wrapperspb.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 *wrapperspb.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 *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=threshold,proto3" json:"threshold,omitempty"`
	// contains filtered or unexported fields
}

Detection based on success rate, but threshold is set explicitly (unlike 'standardDeviation')

func (*CircuitBreaker_Conf_Detectors_Failure) Descriptor deprecated 

func (*CircuitBreaker_Conf_Detectors_Failure) Descriptor() ([]byte, []int)

Deprecated: Use CircuitBreaker_Conf_Detectors_Failure.ProtoReflect.Descriptor instead.

func (*CircuitBreaker_Conf_Detectors_Failure) GetMinimumHosts 

func (x *CircuitBreaker_Conf_Detectors_Failure) GetMinimumHosts() *wrapperspb.UInt32Value

func (*CircuitBreaker_Conf_Detectors_Failure) GetRequestVolume 

func (x *CircuitBreaker_Conf_Detectors_Failure) GetRequestVolume() *wrapperspb.UInt32Value

func (*CircuitBreaker_Conf_Detectors_Failure) GetThreshold 

func (x *CircuitBreaker_Conf_Detectors_Failure) GetThreshold() *wrapperspb.UInt32Value

func (*CircuitBreaker_Conf_Detectors_Failure) ProtoMessage 

func (*CircuitBreaker_Conf_Detectors_Failure) ProtoMessage()

func (*CircuitBreaker_Conf_Detectors_Failure) ProtoReflect 

func (x *CircuitBreaker_Conf_Detectors_Failure) ProtoReflect() protoreflect.Message

func (*CircuitBreaker_Conf_Detectors_Failure) Reset 

func (x *CircuitBreaker_Conf_Detectors_Failure) Reset()

func (*CircuitBreaker_Conf_Detectors_Failure) String 

func (x *CircuitBreaker_Conf_Detectors_Failure) String() string

type CircuitBreaker_Conf_Detectors_StandardDeviation 

type CircuitBreaker_Conf_Detectors_StandardDeviation struct {

	// Ignore hosts with less number of requests than 'requestVolume'
	RequestVolume *wrapperspb.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 *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=minimumHosts,proto3" json:"minimumHosts,omitempty"`
	// Resulting threshold = mean - (stdev * factor)
	Factor *wrapperspb.DoubleValue `protobuf:"bytes,3,opt,name=factor,proto3" json:"factor,omitempty"`
	// contains filtered or unexported fields
}

Detection based on success rate, aggregated from every host in the cluser

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) Descriptor deprecated 

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) Descriptor() ([]byte, []int)

Deprecated: Use CircuitBreaker_Conf_Detectors_StandardDeviation.ProtoReflect.Descriptor instead.

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) GetFactor 

func (x *CircuitBreaker_Conf_Detectors_StandardDeviation) GetFactor() *wrapperspb.DoubleValue

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) GetMinimumHosts 

func (x *CircuitBreaker_Conf_Detectors_StandardDeviation) GetMinimumHosts() *wrapperspb.UInt32Value

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) GetRequestVolume 

func (x *CircuitBreaker_Conf_Detectors_StandardDeviation) GetRequestVolume() *wrapperspb.UInt32Value

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) ProtoMessage 

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) ProtoMessage()

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) ProtoReflect 

func (x *CircuitBreaker_Conf_Detectors_StandardDeviation) ProtoReflect() protoreflect.Message

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) Reset 

func (x *CircuitBreaker_Conf_Detectors_StandardDeviation) Reset()

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) String 

func (x *CircuitBreaker_Conf_Detectors_StandardDeviation) String() string

type CircuitBreaker_Conf_Thresholds 

type CircuitBreaker_Conf_Thresholds struct {

	// The maximum number of connections that Envoy will make to the upstream
	// cluster. If not specified, the default is 1024.
	MaxConnections *wrapperspb.UInt32Value `protobuf:"bytes,1,opt,name=maxConnections,proto3" json:"maxConnections,omitempty"`
	// The maximum number of pending requests that Envoy will allow to the
	// upstream cluster. If not specified, the default is 1024.
	MaxPendingRequests *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=maxPendingRequests,proto3" json:"maxPendingRequests,omitempty"`
	// The maximum number of parallel retries that Envoy will allow to the
	// upstream cluster. If not specified, the default is 3.
	MaxRetries *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=maxRetries,proto3" json:"maxRetries,omitempty"`
	// The maximum number of parallel requests that Envoy will make to the
	// upstream cluster. If not specified, the default is 1024.
	MaxRequests *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=maxRequests,proto3" json:"maxRequests,omitempty"`
	// contains filtered or unexported fields
}

func (*CircuitBreaker_Conf_Thresholds) Descriptor deprecated 

func (*CircuitBreaker_Conf_Thresholds) Descriptor() ([]byte, []int)

Deprecated: Use CircuitBreaker_Conf_Thresholds.ProtoReflect.Descriptor instead.

func (*CircuitBreaker_Conf_Thresholds) GetMaxConnections 

func (x *CircuitBreaker_Conf_Thresholds) GetMaxConnections() *wrapperspb.UInt32Value

func (*CircuitBreaker_Conf_Thresholds) GetMaxPendingRequests 

func (x *CircuitBreaker_Conf_Thresholds) GetMaxPendingRequests() *wrapperspb.UInt32Value

func (*CircuitBreaker_Conf_Thresholds) GetMaxRequests 

func (x *CircuitBreaker_Conf_Thresholds) GetMaxRequests() *wrapperspb.UInt32Value

func (*CircuitBreaker_Conf_Thresholds) GetMaxRetries 

func (x *CircuitBreaker_Conf_Thresholds) GetMaxRetries() *wrapperspb.UInt32Value

func (*CircuitBreaker_Conf_Thresholds) ProtoMessage 

func (*CircuitBreaker_Conf_Thresholds) ProtoMessage()

func (*CircuitBreaker_Conf_Thresholds) ProtoReflect 

func (x *CircuitBreaker_Conf_Thresholds) ProtoReflect() protoreflect.Message

func (*CircuitBreaker_Conf_Thresholds) Reset 

func (x *CircuitBreaker_Conf_Thresholds) Reset()

func (*CircuitBreaker_Conf_Thresholds) String 

func (x *CircuitBreaker_Conf_Thresholds) String() string

type DatadogTracingBackendConfig 

type DatadogTracingBackendConfig struct {

	// Address of datadog collector.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Port of datadog collector
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*DatadogTracingBackendConfig) Descriptor deprecated 

func (*DatadogTracingBackendConfig) Descriptor() ([]byte, []int)

Deprecated: Use DatadogTracingBackendConfig.ProtoReflect.Descriptor instead.

func (*DatadogTracingBackendConfig) GetAddress 

func (x *DatadogTracingBackendConfig) GetAddress() string

func (*DatadogTracingBackendConfig) GetPort 

func (x *DatadogTracingBackendConfig) GetPort() uint32

func (*DatadogTracingBackendConfig) ProtoMessage 

func (*DatadogTracingBackendConfig) ProtoMessage()

func (*DatadogTracingBackendConfig) ProtoReflect 

func (x *DatadogTracingBackendConfig) ProtoReflect() protoreflect.Message

func (*DatadogTracingBackendConfig) Reset 

func (x *DatadogTracingBackendConfig) Reset()

func (*DatadogTracingBackendConfig) String 

func (x *DatadogTracingBackendConfig) String() string

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"`
	// Probes describes list of endpoints which will redirect traffic from
	// insecure port to localhost path
	Probes *Dataplane_Probes `protobuf:"bytes,3,opt,name=probes,proto3" json:"probes,omitempty"`
	// contains filtered or unexported fields
}

Dataplane defines configuration of a side-car proxy.

func (*Dataplane) Descriptor deprecated 

func (*Dataplane) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane.ProtoReflect.Descriptor instead.

func (*Dataplane) GetIdentifyingService 

func (d *Dataplane) GetIdentifyingService() string

func (*Dataplane) GetMetrics 

func (x *Dataplane) GetMetrics() *MetricsBackend

func (*Dataplane) GetNetworking 

func (x *Dataplane) GetNetworking() *Dataplane_Networking

func (*Dataplane) GetProbes 

func (x *Dataplane) GetProbes() *Dataplane_Probes

func (*Dataplane) HasAvailableServices 

func (d *Dataplane) HasAvailableServices() bool

func (*Dataplane) HasPublicAddress 

func (d *Dataplane) HasPublicAddress() bool

func (*Dataplane) IsGateway 

func (d *Dataplane) IsGateway() bool

IsDataplane returns true if this Dataplane specifies a gateway configuration.

func (*Dataplane) IsIngress 

func (d *Dataplane) IsIngress() bool

IsIngress returns true if this Dataplane specifies an ingress configuration.

Deprecated in favor of ZoneIngress.

func (*Dataplane) IsZoneIngress 

func (d *Dataplane) IsZoneIngress(localZone string) bool

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) ProtoReflect 

func (x *Dataplane) ProtoReflect() protoreflect.Message

func (*Dataplane) Reset 

func (x *Dataplane) Reset()

func (*Dataplane) String 

func (x *Dataplane) String() string

func (*Dataplane) TagSet 

func (d *Dataplane) TagSet() MultiValueTagSet

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"`
	// contains filtered or unexported fields
}

DataplaneInsight defines the observed state of a Dataplane.

func (*DataplaneInsight) Descriptor deprecated 

func (*DataplaneInsight) Descriptor() ([]byte, []int)

Deprecated: Use DataplaneInsight.ProtoReflect.Descriptor instead.

func (*DataplaneInsight) GetLatestSubscription 

func (ds *DataplaneInsight) GetLatestSubscription() (*DiscoverySubscription, *time.Time)

func (*DataplaneInsight) GetMTLS 

func (x *DataplaneInsight) GetMTLS() *DataplaneInsight_MTLS

func (*DataplaneInsight) GetSubscription 

func (ds *DataplaneInsight) GetSubscription(id string) (int, *DiscoverySubscription)

func (*DataplaneInsight) GetSubscriptions 

func (x *DataplaneInsight) GetSubscriptions() []*DiscoverySubscription

func (*DataplaneInsight) IsOnline 

func (ds *DataplaneInsight) IsOnline() bool

func (*DataplaneInsight) ProtoMessage 

func (*DataplaneInsight) ProtoMessage()

func (*DataplaneInsight) ProtoReflect 

func (x *DataplaneInsight) ProtoReflect() protoreflect.Message

func (*DataplaneInsight) Reset 

func (x *DataplaneInsight) Reset()

func (*DataplaneInsight) String 

func (x *DataplaneInsight) String() string

func (*DataplaneInsight) Sum 

func (ds *DataplaneInsight) Sum(v func(*DiscoverySubscription) uint64) uint64

func (*DataplaneInsight) UpdateCert 

func (ds *DataplaneInsight) UpdateCert(generation time.Time, expiration time.Time) error

func (*DataplaneInsight) UpdateSubscription 

func (ds *DataplaneInsight) UpdateSubscription(s *DiscoverySubscription)

type DataplaneInsight_MTLS 

type DataplaneInsight_MTLS struct {

	// Expiration time of the last certificate that was generated for a
	// Dataplane.
	CertificateExpirationTime *timestamppb.Timestamp `` /* 138-byte string literal not displayed */
	// Time on which the last certificate was generated.
	LastCertificateRegeneration *timestamppb.Timestamp `` /* 144-byte string literal not displayed */
	// Number of certificate regenerations for a Dataplane.
	CertificateRegenerations uint32 `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

MTLS defines insights for mTLS

func (*DataplaneInsight_MTLS) Descriptor deprecated 

func (*DataplaneInsight_MTLS) Descriptor() ([]byte, []int)

Deprecated: Use DataplaneInsight_MTLS.ProtoReflect.Descriptor instead.

func (*DataplaneInsight_MTLS) GetCertificateExpirationTime 

func (x *DataplaneInsight_MTLS) GetCertificateExpirationTime() *timestamppb.Timestamp

func (*DataplaneInsight_MTLS) GetCertificateRegenerations 

func (x *DataplaneInsight_MTLS) GetCertificateRegenerations() uint32

func (*DataplaneInsight_MTLS) GetLastCertificateRegeneration 

func (x *DataplaneInsight_MTLS) GetLastCertificateRegeneration() *timestamppb.Timestamp

func (*DataplaneInsight_MTLS) ProtoMessage 

func (*DataplaneInsight_MTLS) ProtoMessage()

func (*DataplaneInsight_MTLS) ProtoReflect 

func (x *DataplaneInsight_MTLS) ProtoReflect() protoreflect.Message

func (*DataplaneInsight_MTLS) Reset 

func (x *DataplaneInsight_MTLS) Reset()

func (*DataplaneInsight_MTLS) String 

func (x *DataplaneInsight_MTLS) String() string

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"`
	// contains filtered or unexported fields
}

DataplaneOverview defines the projected state of a Dataplane.

func (*DataplaneOverview) Descriptor deprecated 

func (*DataplaneOverview) Descriptor() ([]byte, []int)

Deprecated: Use DataplaneOverview.ProtoReflect.Descriptor instead.

func (*DataplaneOverview) GetDataplane 

func (x *DataplaneOverview) GetDataplane() *Dataplane

func (*DataplaneOverview) GetDataplaneInsight 

func (x *DataplaneOverview) GetDataplaneInsight() *DataplaneInsight

func (*DataplaneOverview) ProtoMessage 

func (*DataplaneOverview) ProtoMessage()

func (*DataplaneOverview) ProtoReflect 

func (x *DataplaneOverview) ProtoReflect() protoreflect.Message

func (*DataplaneOverview) Reset 

func (x *DataplaneOverview) Reset()

func (*DataplaneOverview) String 

func (x *DataplaneOverview) String() string

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.
	Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// In some situation, dataplane resides in a private network and not
	// reachable via 'address'. advertisedAddress is configured with public
	// routable address for such dataplane so that other dataplanes in the mesh
	// can connect to it over advertisedAddress and not via address
	// Note: Envoy binds to the address not advertisedAddress
	AdvertisedAddress string `protobuf:"bytes,7,opt,name=advertisedAddress,proto3" json:"advertisedAddress,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"`
	// contains filtered or unexported fields
}

Networking describes inbound and outbound interfaces of a dataplane.

func (*Dataplane_Networking) Descriptor deprecated 

func (*Dataplane_Networking) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane_Networking.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking) GetAddress 

func (x *Dataplane_Networking) GetAddress() string

func (*Dataplane_Networking) GetAdvertisedAddress 

func (x *Dataplane_Networking) GetAdvertisedAddress() string

func (*Dataplane_Networking) GetGateway 

func (x *Dataplane_Networking) GetGateway() *Dataplane_Networking_Gateway

func (*Dataplane_Networking) GetHealthyInbounds 

func (n *Dataplane_Networking) GetHealthyInbounds() (inbounds []*Dataplane_Networking_Inbound)

func (*Dataplane_Networking) GetInbound 

func (x *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 (x *Dataplane_Networking) GetIngress() *Dataplane_Networking_Ingress

func (*Dataplane_Networking) GetOutbound 

func (x *Dataplane_Networking) GetOutbound() []*Dataplane_Networking_Outbound

func (*Dataplane_Networking) GetOutboundInterfaces 

func (n *Dataplane_Networking) GetOutboundInterfaces() ([]OutboundInterface, error)

func (*Dataplane_Networking) GetTransparentProxying 

func (x *Dataplane_Networking) GetTransparentProxying() *Dataplane_Networking_TransparentProxying

func (*Dataplane_Networking) ProtoMessage 

func (*Dataplane_Networking) ProtoMessage()

func (*Dataplane_Networking) ProtoReflect 

func (x *Dataplane_Networking) ProtoReflect() protoreflect.Message

func (*Dataplane_Networking) Reset 

func (x *Dataplane_Networking) Reset()

func (*Dataplane_Networking) String 

func (x *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

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 */
	// contains filtered or unexported fields
}

Gateway describes a service that ingress should not be proxied.

func (*Dataplane_Networking_Gateway) Descriptor deprecated 

func (*Dataplane_Networking_Gateway) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane_Networking_Gateway.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Gateway) GetTags 

func (x *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) ProtoReflect 

func (x *Dataplane_Networking_Gateway) ProtoReflect() protoreflect.Message

func (*Dataplane_Networking_Gateway) Reset 

func (x *Dataplane_Networking_Gateway) Reset()

func (*Dataplane_Networking_Gateway) String 

func (x *Dataplane_Networking_Gateway) String() string

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 of the service that requests will be forwarded to.
	// Empty value defaults to '127.0.0.1', since Kuma DP should be deployed
	// next to service.
	ServiceAddress string `protobuf:"bytes,6,opt,name=serviceAddress,proto3" json:"serviceAddress,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. kuma.io/service=web, version=1.0.
	// `kuma.io/service` tag is mandatory.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// Health is an optional field filled automatically by Kuma Control Plane
	// on Kubernetes if Pod has ReadinessProbe configured. If 'health' is
	// equal to nil we consider dataplane as healthy. Unhealthy dataplanes
	// will be excluded from Endpoints Discovery Service (EDS)
	Health *Dataplane_Networking_Inbound_Health `protobuf:"bytes,7,opt,name=health,proto3" json:"health,omitempty"`
	// ServiceProbe defines parameters for probing service's port
	ServiceProbe *Dataplane_Networking_Inbound_ServiceProbe `protobuf:"bytes,8,opt,name=serviceProbe,proto3" json:"serviceProbe,omitempty"`
	// contains filtered or unexported fields
}

Inbound describes a service implemented by the dataplane.

func (*Dataplane_Networking_Inbound) Descriptor deprecated 

func (*Dataplane_Networking_Inbound) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane_Networking_Inbound.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound) GetAddress 

func (x *Dataplane_Networking_Inbound) GetAddress() string

func (*Dataplane_Networking_Inbound) GetHealth 

func (x *Dataplane_Networking_Inbound) GetHealth() *Dataplane_Networking_Inbound_Health

func (*Dataplane_Networking_Inbound) GetPort 

func (x *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) GetServiceAddress 

func (x *Dataplane_Networking_Inbound) GetServiceAddress() string

func (*Dataplane_Networking_Inbound) GetServicePort 

func (x *Dataplane_Networking_Inbound) GetServicePort() uint32

func (*Dataplane_Networking_Inbound) GetServiceProbe 

func (x *Dataplane_Networking_Inbound) GetServiceProbe() *Dataplane_Networking_Inbound_ServiceProbe

func (*Dataplane_Networking_Inbound) GetTags 

func (x *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) ProtoReflect 

func (x *Dataplane_Networking_Inbound) ProtoReflect() protoreflect.Message

func (*Dataplane_Networking_Inbound) Reset 

func (x *Dataplane_Networking_Inbound) Reset()

func (*Dataplane_Networking_Inbound) String 

func (x *Dataplane_Networking_Inbound) String() string

type Dataplane_Networking_Inbound_Health 

type Dataplane_Networking_Inbound_Health struct {
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

Health describes the status of an inbound

func (*Dataplane_Networking_Inbound_Health) Descriptor deprecated 

func (*Dataplane_Networking_Inbound_Health) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane_Networking_Inbound_Health.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound_Health) GetReady 

func (x *Dataplane_Networking_Inbound_Health) GetReady() bool

func (*Dataplane_Networking_Inbound_Health) ProtoMessage 

func (*Dataplane_Networking_Inbound_Health) ProtoMessage()

func (*Dataplane_Networking_Inbound_Health) ProtoReflect 

func (x *Dataplane_Networking_Inbound_Health) ProtoReflect() protoreflect.Message

func (*Dataplane_Networking_Inbound_Health) Reset 

func (x *Dataplane_Networking_Inbound_Health) Reset()

func (*Dataplane_Networking_Inbound_Health) String 

func (x *Dataplane_Networking_Inbound_Health) String() string

type Dataplane_Networking_Inbound_ServiceProbe 

type Dataplane_Networking_Inbound_ServiceProbe struct {

	// Interval between consecutive health checks.
	Interval *durationpb.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// Maximum time to wait for a health check response.
	Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Number of consecutive unhealthy checks before considering a host
	// unhealthy.
	UnhealthyThreshold *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=unhealthy_threshold,json=unhealthyThreshold,proto3" json:"unhealthy_threshold,omitempty"`
	// Number of consecutive healthy checks before considering a host
	// healthy.
	HealthyThreshold *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=healthy_threshold,json=healthyThreshold,proto3" json:"healthy_threshold,omitempty"`
	// Tcp checker tries to establish tcp connection with destination
	Tcp *Dataplane_Networking_Inbound_ServiceProbe_Tcp `protobuf:"bytes,5,opt,name=tcp,proto3" json:"tcp,omitempty"`
	// contains filtered or unexported fields
}

ServiceProbe defines parameters for probing service's port

func (*Dataplane_Networking_Inbound_ServiceProbe) Descriptor deprecated 

func (*Dataplane_Networking_Inbound_ServiceProbe) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane_Networking_Inbound_ServiceProbe.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound_ServiceProbe) GetHealthyThreshold 

func (x *Dataplane_Networking_Inbound_ServiceProbe) GetHealthyThreshold() *wrapperspb.UInt32Value

func (*Dataplane_Networking_Inbound_ServiceProbe) GetInterval 

func (x *Dataplane_Networking_Inbound_ServiceProbe) GetInterval() *durationpb.Duration

func (*Dataplane_Networking_Inbound_ServiceProbe) GetTcp 

func (x *Dataplane_Networking_Inbound_ServiceProbe) GetTcp() *Dataplane_Networking_Inbound_ServiceProbe_Tcp

func (*Dataplane_Networking_Inbound_ServiceProbe) GetTimeout 

func (x *Dataplane_Networking_Inbound_ServiceProbe) GetTimeout() *durationpb.Duration

func (*Dataplane_Networking_Inbound_ServiceProbe) GetUnhealthyThreshold 

func (x *Dataplane_Networking_Inbound_ServiceProbe) GetUnhealthyThreshold() *wrapperspb.UInt32Value

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoMessage 

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoMessage()

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoReflect 

func (x *Dataplane_Networking_Inbound_ServiceProbe) ProtoReflect() protoreflect.Message

func (*Dataplane_Networking_Inbound_ServiceProbe) Reset 

func (x *Dataplane_Networking_Inbound_ServiceProbe) Reset()

func (*Dataplane_Networking_Inbound_ServiceProbe) String 

func (x *Dataplane_Networking_Inbound_ServiceProbe) String() string

type Dataplane_Networking_Inbound_ServiceProbe_Tcp 

type Dataplane_Networking_Inbound_ServiceProbe_Tcp struct {
	// contains filtered or unexported fields
}

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) Descriptor deprecated 

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane_Networking_Inbound_ServiceProbe_Tcp.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoMessage 

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoMessage()

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoReflect 

func (x *Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoReflect() protoreflect.Message

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) Reset 

func (x *Dataplane_Networking_Inbound_ServiceProbe_Tcp) Reset()

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) String 

func (x *Dataplane_Networking_Inbound_ServiceProbe_Tcp) String() string

type Dataplane_Networking_Ingress 

type Dataplane_Networking_Ingress struct {
	AvailableServices []*Dataplane_Networking_Ingress_AvailableService `protobuf:"bytes,1,rep,name=availableServices,proto3" json:"availableServices,omitempty"`
	// PublicAddress defines IP or DNS name on which Ingress is accessible to
	// other Kuma clusters.
	PublicAddress string `protobuf:"bytes,2,opt,name=publicAddress,proto3" json:"publicAddress,omitempty"`
	// PublicPort defines port on which Ingress is accessible to other Kuma
	// clusters.
	PublicPort uint32 `protobuf:"varint,3,opt,name=publicPort,proto3" json:"publicPort,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated 

func (*Dataplane_Networking_Ingress) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane_Networking_Ingress.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Ingress) GetAvailableServices 

func (x *Dataplane_Networking_Ingress) GetAvailableServices() []*Dataplane_Networking_Ingress_AvailableService

func (*Dataplane_Networking_Ingress) GetPublicAddress 

func (x *Dataplane_Networking_Ingress) GetPublicAddress() string

func (*Dataplane_Networking_Ingress) GetPublicPort 

func (x *Dataplane_Networking_Ingress) GetPublicPort() uint32

func (*Dataplane_Networking_Ingress) ProtoMessage 

func (*Dataplane_Networking_Ingress) ProtoMessage()

func (*Dataplane_Networking_Ingress) ProtoReflect 

func (x *Dataplane_Networking_Ingress) ProtoReflect() protoreflect.Message

func (*Dataplane_Networking_Ingress) Reset 

func (x *Dataplane_Networking_Ingress) Reset()

func (*Dataplane_Networking_Ingress) String 

func (x *Dataplane_Networking_Ingress) String() string

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"`
	// mesh of the instances available for given tags
	Mesh string `protobuf:"bytes,3,opt,name=mesh,proto3" json:"mesh,omitempty"`
	// contains filtered or unexported fields
}

AvailableService contains tags that represent unique subset of endpoints

func (*Dataplane_Networking_Ingress_AvailableService) Descriptor deprecated 

func (*Dataplane_Networking_Ingress_AvailableService) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane_Networking_Ingress_AvailableService.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Ingress_AvailableService) GetInstances 

func (x *Dataplane_Networking_Ingress_AvailableService) GetInstances() uint32

func (*Dataplane_Networking_Ingress_AvailableService) GetMesh 

func (x *Dataplane_Networking_Ingress_AvailableService) GetMesh() string

func (*Dataplane_Networking_Ingress_AvailableService) GetTags 

func (x *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) ProtoReflect 

func (x *Dataplane_Networking_Ingress_AvailableService) ProtoReflect() protoreflect.Message

func (*Dataplane_Networking_Ingress_AvailableService) Reset 

func (x *Dataplane_Networking_Ingress_AvailableService) Reset()

func (*Dataplane_Networking_Ingress_AvailableService) String 

func (x *Dataplane_Networking_Ingress_AvailableService) String() string

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.
	//
	// Deprecated: Do not use.
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// Tags
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

Outbound describes a service consumed by the dataplane.

func (*Dataplane_Networking_Outbound) Descriptor deprecated 

func (*Dataplane_Networking_Outbound) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane_Networking_Outbound.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Outbound) GetAddress 

func (x *Dataplane_Networking_Outbound) GetAddress() string

func (*Dataplane_Networking_Outbound) GetPort 

func (x *Dataplane_Networking_Outbound) GetPort() uint32

func (*Dataplane_Networking_Outbound) GetService deprecated 

func (x *Dataplane_Networking_Outbound) GetService() string

Deprecated: Do not use.

func (*Dataplane_Networking_Outbound) GetTags 

func (x *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 "kuma.io/service" field in outbound Remove it and migrate to GetTags() once "kuma.io/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) ProtoReflect 

func (x *Dataplane_Networking_Outbound) ProtoReflect() protoreflect.Message

func (*Dataplane_Networking_Outbound) Reset 

func (x *Dataplane_Networking_Outbound) Reset()

func (*Dataplane_Networking_Outbound) String 

func (x *Dataplane_Networking_Outbound) String() string

type Dataplane_Networking_TransparentProxying 

type Dataplane_Networking_TransparentProxying struct {

	// Port on which all inbound traffic is being transparently redirected.
	RedirectPortInbound uint32 `protobuf:"varint,1,opt,name=redirect_port_inbound,json=redirectPortInbound,proto3" json:"redirect_port_inbound,omitempty"`
	// Port on which all outbound traffic is being transparently redirected.
	RedirectPortOutbound uint32 `protobuf:"varint,2,opt,name=redirect_port_outbound,json=redirectPortOutbound,proto3" json:"redirect_port_outbound,omitempty"`
	// List of services that will be access directly via IP:PORT
	DirectAccessServices []string `protobuf:"bytes,3,rep,name=direct_access_services,json=directAccessServices,proto3" json:"direct_access_services,omitempty"`
	// Port on which all IPv6 inbound traffic is being transparently
	// redirected.
	RedirectPortInboundV6 uint32 `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

TransparentProxying describes configuration for transparent proxying.

func (*Dataplane_Networking_TransparentProxying) Descriptor deprecated 

func (*Dataplane_Networking_TransparentProxying) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane_Networking_TransparentProxying.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_TransparentProxying) GetDirectAccessServices 

func (x *Dataplane_Networking_TransparentProxying) GetDirectAccessServices() []string

func (*Dataplane_Networking_TransparentProxying) GetRedirectPortInbound 

func (x *Dataplane_Networking_TransparentProxying) GetRedirectPortInbound() uint32

func (*Dataplane_Networking_TransparentProxying) GetRedirectPortInboundV6 

func (x *Dataplane_Networking_TransparentProxying) GetRedirectPortInboundV6() uint32

func (*Dataplane_Networking_TransparentProxying) GetRedirectPortOutbound 

func (x *Dataplane_Networking_TransparentProxying) GetRedirectPortOutbound() uint32

func (*Dataplane_Networking_TransparentProxying) ProtoMessage 

func (*Dataplane_Networking_TransparentProxying) ProtoMessage()

func (*Dataplane_Networking_TransparentProxying) ProtoReflect 

func (x *Dataplane_Networking_TransparentProxying) ProtoReflect() protoreflect.Message

func (*Dataplane_Networking_TransparentProxying) Reset 

func (x *Dataplane_Networking_TransparentProxying) Reset()

func (*Dataplane_Networking_TransparentProxying) String 

func (x *Dataplane_Networking_TransparentProxying) String() string

type Dataplane_Probes 

type Dataplane_Probes struct {
	Port      uint32                       `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	Endpoints []*Dataplane_Probes_Endpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*Dataplane_Probes) Descriptor deprecated 

func (*Dataplane_Probes) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane_Probes.ProtoReflect.Descriptor instead.

func (*Dataplane_Probes) GetEndpoints 

func (x *Dataplane_Probes) GetEndpoints() []*Dataplane_Probes_Endpoint

func (*Dataplane_Probes) GetPort 

func (x *Dataplane_Probes) GetPort() uint32

func (*Dataplane_Probes) ProtoMessage 

func (*Dataplane_Probes) ProtoMessage()

func (*Dataplane_Probes) ProtoReflect 

func (x *Dataplane_Probes) ProtoReflect() protoreflect.Message

func (*Dataplane_Probes) Reset 

func (x *Dataplane_Probes) Reset()

func (*Dataplane_Probes) String 

func (x *Dataplane_Probes) String() string

type Dataplane_Probes_Endpoint 

type Dataplane_Probes_Endpoint struct {
	InboundPort uint32 `protobuf:"varint,1,opt,name=inbound_port,json=inboundPort,proto3" json:"inbound_port,omitempty"`
	InboundPath string `protobuf:"bytes,2,opt,name=inbound_path,json=inboundPath,proto3" json:"inbound_path,omitempty"`
	Path        string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*Dataplane_Probes_Endpoint) Descriptor deprecated 

func (*Dataplane_Probes_Endpoint) Descriptor() ([]byte, []int)

Deprecated: Use Dataplane_Probes_Endpoint.ProtoReflect.Descriptor instead.

func (*Dataplane_Probes_Endpoint) GetInboundPath 

func (x *Dataplane_Probes_Endpoint) GetInboundPath() string

func (*Dataplane_Probes_Endpoint) GetInboundPort 

func (x *Dataplane_Probes_Endpoint) GetInboundPort() uint32

func (*Dataplane_Probes_Endpoint) GetPath 

func (x *Dataplane_Probes_Endpoint) GetPath() string

func (*Dataplane_Probes_Endpoint) ProtoMessage 

func (*Dataplane_Probes_Endpoint) ProtoMessage()

func (*Dataplane_Probes_Endpoint) ProtoReflect 

func (x *Dataplane_Probes_Endpoint) ProtoReflect() protoreflect.Message

func (*Dataplane_Probes_Endpoint) Reset 

func (x *Dataplane_Probes_Endpoint) Reset()

func (*Dataplane_Probes_Endpoint) String 

func (x *Dataplane_Probes_Endpoint) String() string

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"`
	// contains filtered or unexported fields
}

DiscoveryServiceStats defines all stats over a single xDS service.

func (*DiscoveryServiceStats) Descriptor deprecated 

func (*DiscoveryServiceStats) Descriptor() ([]byte, []int)

Deprecated: Use DiscoveryServiceStats.ProtoReflect.Descriptor instead.

func (*DiscoveryServiceStats) GetResponsesAcknowledged 

func (x *DiscoveryServiceStats) GetResponsesAcknowledged() uint64

func (*DiscoveryServiceStats) GetResponsesRejected 

func (x *DiscoveryServiceStats) GetResponsesRejected() uint64

func (*DiscoveryServiceStats) GetResponsesSent 

func (x *DiscoveryServiceStats) GetResponsesSent() uint64

func (*DiscoveryServiceStats) ProtoMessage 

func (*DiscoveryServiceStats) ProtoMessage()

func (*DiscoveryServiceStats) ProtoReflect 

func (x *DiscoveryServiceStats) ProtoReflect() protoreflect.Message

func (*DiscoveryServiceStats) Reset 

func (x *DiscoveryServiceStats) Reset()

func (*DiscoveryServiceStats) String 

func (x *DiscoveryServiceStats) String() string

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 *timestamppb.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 *timestamppb.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"`
	// Version of Envoy and Kuma dataplane
	Version *Version `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated 

func (*DiscoverySubscription) Descriptor() ([]byte, []int)

Deprecated: Use DiscoverySubscription.ProtoReflect.Descriptor instead.

func (*DiscoverySubscription) GetConnectTime 

func (x *DiscoverySubscription) GetConnectTime() *timestamppb.Timestamp

func (*DiscoverySubscription) GetControlPlaneInstanceId 

func (x *DiscoverySubscription) GetControlPlaneInstanceId() string

func (*DiscoverySubscription) GetDisconnectTime 

func (x *DiscoverySubscription) GetDisconnectTime() *timestamppb.Timestamp

func (*DiscoverySubscription) GetId 

func (x *DiscoverySubscription) GetId() string

func (*DiscoverySubscription) GetStatus 

func (x *DiscoverySubscription) GetStatus() *DiscoverySubscriptionStatus

func (*DiscoverySubscription) GetVersion 

func (x *DiscoverySubscription) GetVersion() *Version

func (*DiscoverySubscription) ProtoMessage 

func (*DiscoverySubscription) ProtoMessage()

func (*DiscoverySubscription) ProtoReflect 

func (x *DiscoverySubscription) ProtoReflect() protoreflect.Message

func (*DiscoverySubscription) Reset 

func (x *DiscoverySubscription) Reset()

func (*DiscoverySubscription) String 

func (x *DiscoverySubscription) String() string

type DiscoverySubscriptionStatus 

type DiscoverySubscriptionStatus struct {

	// Time when status of a given ADS subscription was most recently updated.
	LastUpdateTime *timestamppb.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"`
	// contains filtered or unexported fields
}

DiscoverySubscriptionStatus defines status of an ADS subscription.

func NewSubscriptionStatus 

func NewSubscriptionStatus() *DiscoverySubscriptionStatus

func (*DiscoverySubscriptionStatus) Descriptor deprecated 

func (*DiscoverySubscriptionStatus) Descriptor() ([]byte, []int)

Deprecated: Use DiscoverySubscriptionStatus.ProtoReflect.Descriptor instead.

func (*DiscoverySubscriptionStatus) GetCds 

func (x *DiscoverySubscriptionStatus) GetCds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetEds 

func (x *DiscoverySubscriptionStatus) GetEds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetLastUpdateTime 

func (x *DiscoverySubscriptionStatus) GetLastUpdateTime() *timestamppb.Timestamp

func (*DiscoverySubscriptionStatus) GetLds 

func (x *DiscoverySubscriptionStatus) GetLds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetRds 

func (x *DiscoverySubscriptionStatus) GetRds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetTotal 

func (x *DiscoverySubscriptionStatus) GetTotal() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) ProtoMessage 

func (*DiscoverySubscriptionStatus) ProtoMessage()

func (*DiscoverySubscriptionStatus) ProtoReflect 

func (x *DiscoverySubscriptionStatus) ProtoReflect() protoreflect.Message

func (*DiscoverySubscriptionStatus) Reset 

func (x *DiscoverySubscriptionStatus) Reset()

func (*DiscoverySubscriptionStatus) StatsOf 

func (s *DiscoverySubscriptionStatus) StatsOf(typeUrl string) *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) String 

func (x *DiscoverySubscriptionStatus) String() string

type EnvoyVersion 

type EnvoyVersion struct {

	// Version number of Envoy
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Full build tag of Envoy version
	Build string `protobuf:"bytes,2,opt,name=build,proto3" json:"build,omitempty"`
	// contains filtered or unexported fields
}

EnvoyVersion describes details of Envoy version

func (*EnvoyVersion) Descriptor deprecated 

func (*EnvoyVersion) Descriptor() ([]byte, []int)

Deprecated: Use EnvoyVersion.ProtoReflect.Descriptor instead.

func (*EnvoyVersion) GetBuild 

func (x *EnvoyVersion) GetBuild() string

func (*EnvoyVersion) GetVersion 

func (x *EnvoyVersion) GetVersion() string

func (*EnvoyVersion) ProtoMessage 

func (*EnvoyVersion) ProtoMessage()

func (*EnvoyVersion) ProtoReflect 

func (x *EnvoyVersion) ProtoReflect() protoreflect.Message

func (*EnvoyVersion) Reset 

func (x *EnvoyVersion) Reset()

func (*EnvoyVersion) String 

func (x *EnvoyVersion) String() string

type ExternalService 

type ExternalService struct {
	Networking *ExternalService_Networking `protobuf:"bytes,1,opt,name=networking,proto3" json:"networking,omitempty"`
	// Tags associated with the external service,
	// e.g. kuma.io/service=web, kuma.io/protocol, version=1.0.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

ExternalService defines configuration of the externally accessible service

func (*ExternalService) Descriptor deprecated 

func (*ExternalService) Descriptor() ([]byte, []int)

Deprecated: Use ExternalService.ProtoReflect.Descriptor instead.

func (*ExternalService) GetHost 

func (es *ExternalService) GetHost() string

func (*ExternalService) GetNetworking 

func (x *ExternalService) GetNetworking() *ExternalService_Networking

func (*ExternalService) GetPort 

func (es *ExternalService) GetPort() string

func (*ExternalService) GetPortUInt32 

func (es *ExternalService) GetPortUInt32() uint32

func (*ExternalService) GetProtocol 

func (es *ExternalService) GetProtocol() string

func (*ExternalService) GetService 

func (es *ExternalService) GetService() string

func (*ExternalService) GetTags 

func (x *ExternalService) GetTags() map[string]string

func (*ExternalService) MatchTags 

func (es *ExternalService) MatchTags(selector TagSelector) bool

func (*ExternalService) Matches 

func (es *ExternalService) Matches(selector TagSelector) bool

Matches is simply an alias for MatchTags to make source code more aesthetic.

func (*ExternalService) ProtoMessage 

func (*ExternalService) ProtoMessage()

func (*ExternalService) ProtoReflect 

func (x *ExternalService) ProtoReflect() protoreflect.Message

func (*ExternalService) Reset 

func (x *ExternalService) Reset()

func (*ExternalService) String 

func (x *ExternalService) String() string

func (*ExternalService) TagSet 

func (es *ExternalService) TagSet() SingleValueTagSet

type ExternalService_Networking 

type ExternalService_Networking struct {

	// Address of the external service
	Address string                          `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Tls     *ExternalService_Networking_TLS `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"`
	// contains filtered or unexported fields
}

Networking describes the properties of the external service connectivity

func (*ExternalService_Networking) Descriptor deprecated 

func (*ExternalService_Networking) Descriptor() ([]byte, []int)

Deprecated: Use ExternalService_Networking.ProtoReflect.Descriptor instead.

func (*ExternalService_Networking) GetAddress 

func (x *ExternalService_Networking) GetAddress() string

func (*ExternalService_Networking) GetTls 

func (x *ExternalService_Networking) GetTls() *ExternalService_Networking_TLS

func (*ExternalService_Networking) ProtoMessage 

func (*ExternalService_Networking) ProtoMessage()

func (*ExternalService_Networking) ProtoReflect 

func (x *ExternalService_Networking) ProtoReflect() protoreflect.Message

func (*ExternalService_Networking) Reset 

func (x *ExternalService_Networking) Reset()

func (*ExternalService_Networking) String 

func (x *ExternalService_Networking) String() string

type ExternalService_Networking_TLS 

type ExternalService_Networking_TLS struct {

	// denotes that the external service uses TLS
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Data source for the certificate of CA
	CaCert *v1alpha1.DataSource `protobuf:"bytes,2,opt,name=ca_cert,json=caCert,proto3" json:"ca_cert,omitempty"`
	// Data source for the authentication
	ClientCert *v1alpha1.DataSource `protobuf:"bytes,3,opt,name=client_cert,json=clientCert,proto3" json:"client_cert,omitempty"`
	// Data source for the authentication
	ClientKey *v1alpha1.DataSource `protobuf:"bytes,4,opt,name=client_key,json=clientKey,proto3" json:"client_key,omitempty"`
	// If true then TLS session will allow renegotiation.
	// It's not recommended to set this to true because of security reasons.
	// However, some servers requires this setting, especially when using
	// mTLS.
	AllowRenegotiation *wrapperspb.BoolValue `protobuf:"bytes,5,opt,name=allowRenegotiation,proto3" json:"allowRenegotiation,omitempty"`
	// contains filtered or unexported fields
}

TLS

func (*ExternalService_Networking_TLS) Descriptor deprecated 

func (*ExternalService_Networking_TLS) Descriptor() ([]byte, []int)

Deprecated: Use ExternalService_Networking_TLS.ProtoReflect.Descriptor instead.

func (*ExternalService_Networking_TLS) GetAllowRenegotiation 

func (x *ExternalService_Networking_TLS) GetAllowRenegotiation() *wrapperspb.BoolValue

func (*ExternalService_Networking_TLS) GetCaCert 

func (x *ExternalService_Networking_TLS) GetCaCert() *v1alpha1.DataSource

func (*ExternalService_Networking_TLS) GetClientCert 

func (x *ExternalService_Networking_TLS) GetClientCert() *v1alpha1.DataSource

func (*ExternalService_Networking_TLS) GetClientKey 

func (x *ExternalService_Networking_TLS) GetClientKey() *v1alpha1.DataSource

func (*ExternalService_Networking_TLS) GetEnabled 

func (x *ExternalService_Networking_TLS) GetEnabled() bool

func (*ExternalService_Networking_TLS) ProtoMessage 

func (*ExternalService_Networking_TLS) ProtoMessage()

func (*ExternalService_Networking_TLS) ProtoReflect 

func (x *ExternalService_Networking_TLS) ProtoReflect() protoreflect.Message

func (*ExternalService_Networking_TLS) Reset 

func (x *ExternalService_Networking_TLS) Reset()

func (*ExternalService_Networking_TLS) String 

func (x *ExternalService_Networking_TLS) String() string

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"`
	// contains filtered or unexported fields
}

FaultInjection defines the configuration of faults between dataplanes.

func (*FaultInjection) Descriptor deprecated 

func (*FaultInjection) Descriptor() ([]byte, []int)

Deprecated: Use FaultInjection.ProtoReflect.Descriptor instead.

func (*FaultInjection) GetConf 

func (x *FaultInjection) GetConf() *FaultInjection_Conf

func (*FaultInjection) GetDestinations 

func (x *FaultInjection) GetDestinations() []*Selector

func (*FaultInjection) GetSources 

func (x *FaultInjection) GetSources() []*Selector

func (*FaultInjection) ProtoMessage 

func (*FaultInjection) ProtoMessage()

func (*FaultInjection) ProtoReflect 

func (x *FaultInjection) ProtoReflect() protoreflect.Message

func (*FaultInjection) Reset 

func (x *FaultInjection) Reset()

func (*FaultInjection) SourceTags 

func (m *FaultInjection) SourceTags() (setList []SingleValueTagSet)

func (*FaultInjection) String 

func (x *FaultInjection) String() string

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"`
	// contains filtered or unexported fields
}

Conf defines several types of faults, at least one fault should be specified

func (*FaultInjection_Conf) Descriptor deprecated 

func (*FaultInjection_Conf) Descriptor() ([]byte, []int)

Deprecated: Use FaultInjection_Conf.ProtoReflect.Descriptor instead.

func (*FaultInjection_Conf) GetAbort 

func (x *FaultInjection_Conf) GetAbort() *FaultInjection_Conf_Abort

func (*FaultInjection_Conf) GetDelay 

func (x *FaultInjection_Conf) GetDelay() *FaultInjection_Conf_Delay

func (*FaultInjection_Conf) GetResponseBandwidth 

func (x *FaultInjection_Conf) GetResponseBandwidth() *FaultInjection_Conf_ResponseBandwidth

func (*FaultInjection_Conf) ProtoMessage 

func (*FaultInjection_Conf) ProtoMessage()

func (*FaultInjection_Conf) ProtoReflect 

func (x *FaultInjection_Conf) ProtoReflect() protoreflect.Message

func (*FaultInjection_Conf) Reset 

func (x *FaultInjection_Conf) Reset()

func (*FaultInjection_Conf) String 

func (x *FaultInjection_Conf) String() string

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 *wrapperspb.DoubleValue `protobuf:"bytes,1,opt,name=percentage,proto3" json:"percentage,omitempty"`
	// HTTP status code which will be returned to source side
	HttpStatus *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=httpStatus,proto3" json:"httpStatus,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated 

func (*FaultInjection_Conf_Abort) Descriptor() ([]byte, []int)

Deprecated: Use FaultInjection_Conf_Abort.ProtoReflect.Descriptor instead.

func (*FaultInjection_Conf_Abort) GetHttpStatus 

func (x *FaultInjection_Conf_Abort) GetHttpStatus() *wrapperspb.UInt32Value

func (*FaultInjection_Conf_Abort) GetPercentage 

func (x *FaultInjection_Conf_Abort) GetPercentage() *wrapperspb.DoubleValue

func (*FaultInjection_Conf_Abort) ProtoMessage 

func (*FaultInjection_Conf_Abort) ProtoMessage()

func (*FaultInjection_Conf_Abort) ProtoReflect 

func (x *FaultInjection_Conf_Abort) ProtoReflect() protoreflect.Message

func (*FaultInjection_Conf_Abort) Reset 

func (x *FaultInjection_Conf_Abort) Reset()

func (*FaultInjection_Conf_Abort) String 

func (x *FaultInjection_Conf_Abort) String() string

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 *wrapperspb.DoubleValue `protobuf:"bytes,1,opt,name=percentage,proto3" json:"percentage,omitempty"`
	// The duration during which the response will be delayed
	Value *durationpb.Duration `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Delay defines configuration of delaying a response from a destination

func (*FaultInjection_Conf_Delay) Descriptor deprecated 

func (*FaultInjection_Conf_Delay) Descriptor() ([]byte, []int)

Deprecated: Use FaultInjection_Conf_Delay.ProtoReflect.Descriptor instead.

func (*FaultInjection_Conf_Delay) GetPercentage 

func (x *FaultInjection_Conf_Delay) GetPercentage() *wrapperspb.DoubleValue

func (*FaultInjection_Conf_Delay) GetValue 

func (x *FaultInjection_Conf_Delay) GetValue() *durationpb.Duration

func (*FaultInjection_Conf_Delay) ProtoMessage 

func (*FaultInjection_Conf_Delay) ProtoMessage()

func (*FaultInjection_Conf_Delay) ProtoReflect 

func (x *FaultInjection_Conf_Delay) ProtoReflect() protoreflect.Message

func (*FaultInjection_Conf_Delay) Reset 

func (x *FaultInjection_Conf_Delay) Reset()

func (*FaultInjection_Conf_Delay) String 

func (x *FaultInjection_Conf_Delay) String() string

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 *wrapperspb.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 *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

ResponseBandwidth defines a configuration to limit the speed of responding to the requests

func (*FaultInjection_Conf_ResponseBandwidth) Descriptor deprecated 

func (*FaultInjection_Conf_ResponseBandwidth) Descriptor() ([]byte, []int)

Deprecated: Use FaultInjection_Conf_ResponseBandwidth.ProtoReflect.Descriptor instead.

func (*FaultInjection_Conf_ResponseBandwidth) GetLimit 

func (x *FaultInjection_Conf_ResponseBandwidth) GetLimit() *wrapperspb.StringValue

func (*FaultInjection_Conf_ResponseBandwidth) GetPercentage 

func (x *FaultInjection_Conf_ResponseBandwidth) GetPercentage() *wrapperspb.DoubleValue

func (*FaultInjection_Conf_ResponseBandwidth) ProtoMessage 

func (*FaultInjection_Conf_ResponseBandwidth) ProtoMessage()

func (*FaultInjection_Conf_ResponseBandwidth) ProtoReflect 

func (x *FaultInjection_Conf_ResponseBandwidth) ProtoReflect() protoreflect.Message

func (*FaultInjection_Conf_ResponseBandwidth) Reset 

func (x *FaultInjection_Conf_ResponseBandwidth) Reset()

func (*FaultInjection_Conf_ResponseBandwidth) String 

func (x *FaultInjection_Conf_ResponseBandwidth) String() string

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"`
	// contains filtered or unexported fields
}

FileLoggingBackendConfig defines configuration for file based access logs

func (*FileLoggingBackendConfig) Descriptor deprecated 

func (*FileLoggingBackendConfig) Descriptor() ([]byte, []int)

Deprecated: Use FileLoggingBackendConfig.ProtoReflect.Descriptor instead.

func (*FileLoggingBackendConfig) GetPath 

func (x *FileLoggingBackendConfig) GetPath() string

func (*FileLoggingBackendConfig) ProtoMessage 

func (*FileLoggingBackendConfig) ProtoMessage()

func (*FileLoggingBackendConfig) ProtoReflect 

func (x *FileLoggingBackendConfig) ProtoReflect() protoreflect.Message

func (*FileLoggingBackendConfig) Reset 

func (x *FileLoggingBackendConfig) Reset()

func (*FileLoggingBackendConfig) String 

func (x *FileLoggingBackendConfig) String() string

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"`
	// contains filtered or unexported fields
}

HealthCheck defines configuration for health checking.

func (*HealthCheck) Descriptor deprecated 

func (*HealthCheck) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheck.ProtoReflect.Descriptor instead.

func (*HealthCheck) GetConf 

func (x *HealthCheck) GetConf() *HealthCheck_Conf

func (*HealthCheck) GetDestinations 

func (x *HealthCheck) GetDestinations() []*Selector

func (*HealthCheck) GetSources 

func (x *HealthCheck) GetSources() []*Selector

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) ProtoReflect 

func (x *HealthCheck) ProtoReflect() protoreflect.Message

func (*HealthCheck) Reset 

func (x *HealthCheck) Reset()

func (*HealthCheck) String 

func (x *HealthCheck) String() string

type HealthCheck_Conf 

type HealthCheck_Conf struct {

	// Interval between consecutive health checks.
	Interval *durationpb.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// Maximum time to wait for a health check response.
	Timeout *durationpb.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"`
	// If specified, Envoy will start health checking after for a random time in
	// ms between 0 and initial_jitter. This only applies to the first health
	// check.
	InitialJitter *durationpb.Duration `protobuf:"bytes,7,opt,name=initial_jitter,json=initialJitter,proto3" json:"initial_jitter,omitempty"`
	// If specified, during every interval Envoy will add interval_jitter to the
	// wait time.
	IntervalJitter *durationpb.Duration `protobuf:"bytes,8,opt,name=interval_jitter,json=intervalJitter,proto3" json:"interval_jitter,omitempty"`
	// If specified, during every interval Envoy will add interval_ms *
	// interval_jitter_percent / 100 to the wait time. If interval_jitter_ms and
	// interval_jitter_percent are both set, both of them will be used to
	// increase the wait time.
	IntervalJitterPercent uint32 `` /* 127-byte string literal not displayed */
	// Allows to configure panic threshold for Envoy cluster. If not specified,
	// the default is 50%. To disable panic mode, set to 0%.
	HealthyPanicThreshold *wrapperspb.FloatValue `` /* 127-byte string literal not displayed */
	// If set to true, Envoy will not consider any hosts when the cluster is in
	// 'panic mode'. Instead, the cluster will fail all requests as if all hosts
	// are unhealthy. This can help avoid potentially overwhelming a failing
	// service.
	FailTrafficOnPanic *wrapperspb.BoolValue `protobuf:"bytes,11,opt,name=fail_traffic_on_panic,json=failTrafficOnPanic,proto3" json:"fail_traffic_on_panic,omitempty"`
	// Specifies the path to the file where Envoy can log health check events.
	// If empty, no event log will be written.
	EventLogPath string `protobuf:"bytes,12,opt,name=event_log_path,json=eventLogPath,proto3" json:"event_log_path,omitempty"`
	// If set to true, health check failure events will always be logged. If set
	// to false, only the initial health check failure event will be logged. The
	// default value is false.
	AlwaysLogHealthCheckFailures *wrapperspb.BoolValue `` /* 152-byte string literal not displayed */
	// The "no traffic interval" is a special health check interval that is used
	// when a cluster has never had traffic routed to it. This lower interval
	// allows cluster information to be kept up to date, without sending a
	// potentially large amount of active health checking traffic for no reason.
	// Once a cluster has been used for traffic routing, Envoy will shift back
	// to using the standard health check interval that is defined. Note that
	// this interval takes precedence over any other. The default value for "no
	// traffic interval" is 60 seconds.
	NoTrafficInterval *durationpb.Duration   `protobuf:"bytes,14,opt,name=no_traffic_interval,json=noTrafficInterval,proto3" json:"no_traffic_interval,omitempty"`
	Tcp               *HealthCheck_Conf_Tcp  `protobuf:"bytes,5,opt,name=tcp,proto3" json:"tcp,omitempty"`
	Http              *HealthCheck_Conf_Http `protobuf:"bytes,6,opt,name=http,proto3" json:"http,omitempty"`
	// Reuse health check connection between health checks. Default is true.
	ReuseConnection *wrapperspb.BoolValue `protobuf:"bytes,15,opt,name=reuse_connection,json=reuseConnection,proto3" json:"reuse_connection,omitempty"`
	// contains filtered or unexported fields
}

Conf defines configuration for various types of health checking.

func (*HealthCheck_Conf) Descriptor deprecated 

func (*HealthCheck_Conf) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheck_Conf.ProtoReflect.Descriptor instead.

func (*HealthCheck_Conf) GetAlwaysLogHealthCheckFailures 

func (x *HealthCheck_Conf) GetAlwaysLogHealthCheckFailures() *wrapperspb.BoolValue

func (*HealthCheck_Conf) GetEventLogPath 

func (x *HealthCheck_Conf) GetEventLogPath() string

func (*HealthCheck_Conf) GetFailTrafficOnPanic 

func (x *HealthCheck_Conf) GetFailTrafficOnPanic() *wrapperspb.BoolValue

func (*HealthCheck_Conf) GetHealthyPanicThreshold 

func (x *HealthCheck_Conf) GetHealthyPanicThreshold() *wrapperspb.FloatValue

func (*HealthCheck_Conf) GetHealthyThreshold 

func (x *HealthCheck_Conf) GetHealthyThreshold() uint32

func (*HealthCheck_Conf) GetHttp 

func (x *HealthCheck_Conf) GetHttp() *HealthCheck_Conf_Http

func (*HealthCheck_Conf) GetInitialJitter 

func (x *HealthCheck_Conf) GetInitialJitter() *durationpb.Duration

func (*HealthCheck_Conf) GetInterval 

func (x *HealthCheck_Conf) GetInterval() *durationpb.Duration

func (*HealthCheck_Conf) GetIntervalJitter 

func (x *HealthCheck_Conf) GetIntervalJitter() *durationpb.Duration

func (*HealthCheck_Conf) GetIntervalJitterPercent 

func (x *HealthCheck_Conf) GetIntervalJitterPercent() uint32

func (*HealthCheck_Conf) GetNoTrafficInterval 

func (x *HealthCheck_Conf) GetNoTrafficInterval() *durationpb.Duration

func (*HealthCheck_Conf) GetReuseConnection 

func (x *HealthCheck_Conf) GetReuseConnection() *wrapperspb.BoolValue

func (*HealthCheck_Conf) GetTcp 

func (x *HealthCheck_Conf) GetTcp() *HealthCheck_Conf_Tcp

func (*HealthCheck_Conf) GetTimeout 

func (x *HealthCheck_Conf) GetTimeout() *durationpb.Duration

func (*HealthCheck_Conf) GetUnhealthyThreshold 

func (x *HealthCheck_Conf) GetUnhealthyThreshold() uint32

func (*HealthCheck_Conf) ProtoMessage 

func (*HealthCheck_Conf) ProtoMessage()

func (*HealthCheck_Conf) ProtoReflect 

func (x *HealthCheck_Conf) ProtoReflect() protoreflect.Message

func (*HealthCheck_Conf) Reset 

func (x *HealthCheck_Conf) Reset()

func (*HealthCheck_Conf) String 

func (x *HealthCheck_Conf) String() string

type HealthCheck_Conf_Http 

type HealthCheck_Conf_Http struct {

	// The HTTP path which will be requested during the health check
	// (ie. /health)
	//  +required
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` //
	// The list of HTTP headers which should be added to each health check
	// request
	//  +optional
	RequestHeadersToAdd []*HealthCheck_Conf_Http_HeaderValueOption `protobuf:"bytes,2,rep,name=request_headers_to_add,json=requestHeadersToAdd,proto3" json:"request_headers_to_add,omitempty"`
	// List of HTTP response statuses which are considered healthy
	//  +optional
	ExpectedStatuses []*wrapperspb.UInt32Value `protobuf:"bytes,3,rep,name=expected_statuses,json=expectedStatuses,proto3" json:"expected_statuses,omitempty"`
	// contains filtered or unexported fields
}

Http defines optional Http configuration which will instruct the service the health check will be made for is an http service. It's mutually exclusive with the Tcp block so when provided you can't provide the Tcp configuration

func (*HealthCheck_Conf_Http) Descriptor deprecated 

func (*HealthCheck_Conf_Http) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheck_Conf_Http.ProtoReflect.Descriptor instead.

func (*HealthCheck_Conf_Http) GetExpectedStatuses 

func (x *HealthCheck_Conf_Http) GetExpectedStatuses() []*wrapperspb.UInt32Value

func (*HealthCheck_Conf_Http) GetPath 

func (x *HealthCheck_Conf_Http) GetPath() string

func (*HealthCheck_Conf_Http) GetRequestHeadersToAdd 

func (x *HealthCheck_Conf_Http) GetRequestHeadersToAdd() []*HealthCheck_Conf_Http_HeaderValueOption

func (*HealthCheck_Conf_Http) ProtoMessage 

func (*HealthCheck_Conf_Http) ProtoMessage()

func (*HealthCheck_Conf_Http) ProtoReflect 

func (x *HealthCheck_Conf_Http) ProtoReflect() protoreflect.Message

func (*HealthCheck_Conf_Http) Reset 

func (x *HealthCheck_Conf_Http) Reset()

func (*HealthCheck_Conf_Http) String 

func (x *HealthCheck_Conf_Http) String() string

type HealthCheck_Conf_Http_HeaderValue 

type HealthCheck_Conf_Http_HeaderValue struct {

	// Header name
	//  +required
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Header value
	//  +optional
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheck_Conf_Http_HeaderValue) Descriptor deprecated 

func (*HealthCheck_Conf_Http_HeaderValue) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheck_Conf_Http_HeaderValue.ProtoReflect.Descriptor instead.

func (*HealthCheck_Conf_Http_HeaderValue) GetKey 

func (x *HealthCheck_Conf_Http_HeaderValue) GetKey() string

func (*HealthCheck_Conf_Http_HeaderValue) GetValue 

func (x *HealthCheck_Conf_Http_HeaderValue) GetValue() string

func (*HealthCheck_Conf_Http_HeaderValue) ProtoMessage 

func (*HealthCheck_Conf_Http_HeaderValue) ProtoMessage()

func (*HealthCheck_Conf_Http_HeaderValue) ProtoReflect 

func (x *HealthCheck_Conf_Http_HeaderValue) ProtoReflect() protoreflect.Message

func (*HealthCheck_Conf_Http_HeaderValue) Reset 

func (x *HealthCheck_Conf_Http_HeaderValue) Reset()

func (*HealthCheck_Conf_Http_HeaderValue) String 

func (x *HealthCheck_Conf_Http_HeaderValue) String() string

type HealthCheck_Conf_Http_HeaderValueOption 

type HealthCheck_Conf_Http_HeaderValueOption struct {

	// Key/Value representation of the HTTP header
	//  +required
	Header *HealthCheck_Conf_Http_HeaderValue `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// The bool value which if true (default) will mean the header values
	// should be appended to already present ones
	//  +optional
	Append *wrapperspb.BoolValue `protobuf:"bytes,2,opt,name=append,proto3" json:"append,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheck_Conf_Http_HeaderValueOption) Descriptor deprecated 

func (*HealthCheck_Conf_Http_HeaderValueOption) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheck_Conf_Http_HeaderValueOption.ProtoReflect.Descriptor instead.

func (*HealthCheck_Conf_Http_HeaderValueOption) GetAppend 

func (x *HealthCheck_Conf_Http_HeaderValueOption) GetAppend() *wrapperspb.BoolValue

func (*HealthCheck_Conf_Http_HeaderValueOption) GetHeader 

func (x *HealthCheck_Conf_Http_HeaderValueOption) GetHeader() *HealthCheck_Conf_Http_HeaderValue

func (*HealthCheck_Conf_Http_HeaderValueOption) ProtoMessage 

func (*HealthCheck_Conf_Http_HeaderValueOption) ProtoMessage()

func (*HealthCheck_Conf_Http_HeaderValueOption) ProtoReflect 

func (x *HealthCheck_Conf_Http_HeaderValueOption) ProtoReflect() protoreflect.Message

func (*HealthCheck_Conf_Http_HeaderValueOption) Reset 

func (x *HealthCheck_Conf_Http_HeaderValueOption) Reset()

func (*HealthCheck_Conf_Http_HeaderValueOption) String 

func (x *HealthCheck_Conf_Http_HeaderValueOption) String() string

type HealthCheck_Conf_Tcp 

type HealthCheck_Conf_Tcp struct {

	// Bytes which will be send during the health check to the target
	Send *wrapperspb.BytesValue `protobuf:"bytes,1,opt,name=send,proto3" json:"send,omitempty"`
	// Bytes blocks expected as a response. When checking the response,
	// “fuzzy” matching is performed such that each block must be found, and
	// in the order specified, but not necessarily contiguous.
	Receive []*wrapperspb.BytesValue `protobuf:"bytes,2,rep,name=receive,proto3" json:"receive,omitempty"`
	// contains filtered or unexported fields
}

Tcp defines optional configuration for specifying bytes to send and expected response during the health check

func (*HealthCheck_Conf_Tcp) Descriptor deprecated 

func (*HealthCheck_Conf_Tcp) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheck_Conf_Tcp.ProtoReflect.Descriptor instead.

func (*HealthCheck_Conf_Tcp) GetReceive 

func (x *HealthCheck_Conf_Tcp) GetReceive() []*wrapperspb.BytesValue

func (*HealthCheck_Conf_Tcp) GetSend 

func (x *HealthCheck_Conf_Tcp) GetSend() *wrapperspb.BytesValue

func (*HealthCheck_Conf_Tcp) ProtoMessage 

func (*HealthCheck_Conf_Tcp) ProtoMessage()

func (*HealthCheck_Conf_Tcp) ProtoReflect 

func (x *HealthCheck_Conf_Tcp) ProtoReflect() protoreflect.Message

func (*HealthCheck_Conf_Tcp) Reset 

func (x *HealthCheck_Conf_Tcp) Reset()

func (*HealthCheck_Conf_Tcp) String 

func (x *HealthCheck_Conf_Tcp) String() string

type InboundInterface 

type InboundInterface struct {
	DataplaneAdvertisedIP string
	DataplaneIP           string
	DataplanePort         uint32
	WorkloadIP            string
	WorkloadPort          uint32
}

func (*InboundInterface) IsServiceLess 

func (i *InboundInterface) IsServiceLess() bool

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.ClientConnInterface) 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 KumaDpVersion 

type KumaDpVersion struct {

	// Version number of Kuma Dataplane
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Git tag of Kuma Dataplane version
	GitTag string `protobuf:"bytes,2,opt,name=gitTag,proto3" json:"gitTag,omitempty"`
	// Git commit of Kuma Dataplane version
	GitCommit string `protobuf:"bytes,3,opt,name=gitCommit,proto3" json:"gitCommit,omitempty"`
	// Build date of Kuma Dataplane version
	BuildDate string `protobuf:"bytes,4,opt,name=buildDate,proto3" json:"buildDate,omitempty"`
	// contains filtered or unexported fields
}

KumaDpVersion describes details of Kuma Dataplane version

func (*KumaDpVersion) Descriptor deprecated 

func (*KumaDpVersion) Descriptor() ([]byte, []int)

Deprecated: Use KumaDpVersion.ProtoReflect.Descriptor instead.

func (*KumaDpVersion) GetBuildDate 

func (x *KumaDpVersion) GetBuildDate() string

func (*KumaDpVersion) GetGitCommit 

func (x *KumaDpVersion) GetGitCommit() string

func (*KumaDpVersion) GetGitTag 

func (x *KumaDpVersion) GetGitTag() string

func (*KumaDpVersion) GetVersion 

func (x *KumaDpVersion) GetVersion() string

func (*KumaDpVersion) ProtoMessage 

func (*KumaDpVersion) ProtoMessage()

func (*KumaDpVersion) ProtoReflect 

func (x *KumaDpVersion) ProtoReflect() protoreflect.Message

func (*KumaDpVersion) Reset 

func (x *KumaDpVersion) Reset()

func (*KumaDpVersion) String 

func (x *KumaDpVersion) String() string

type KumaResource 

type KumaResource struct {
	Meta *KumaResource_Meta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Spec *anypb.Any         `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*KumaResource) Descriptor deprecated 

func (*KumaResource) Descriptor() ([]byte, []int)

Deprecated: Use KumaResource.ProtoReflect.Descriptor instead.

func (*KumaResource) GetMeta 

func (x *KumaResource) GetMeta() *KumaResource_Meta

func (*KumaResource) GetSpec 

func (x *KumaResource) GetSpec() *anypb.Any

func (*KumaResource) ProtoMessage 

func (*KumaResource) ProtoMessage()

func (*KumaResource) ProtoReflect 

func (x *KumaResource) ProtoReflect() protoreflect.Message

func (*KumaResource) Reset 

func (x *KumaResource) Reset()

func (*KumaResource) String 

func (x *KumaResource) String() string

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     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	ModificationTime *timestamppb.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"`
	// contains filtered or unexported fields
}

func (*KumaResource_Meta) Descriptor deprecated 

func (*KumaResource_Meta) Descriptor() ([]byte, []int)

Deprecated: Use KumaResource_Meta.ProtoReflect.Descriptor instead.

func (*KumaResource_Meta) GetCreationTime 

func (x *KumaResource_Meta) GetCreationTime() *timestamppb.Timestamp

func (*KumaResource_Meta) GetMesh 

func (x *KumaResource_Meta) GetMesh() string

func (*KumaResource_Meta) GetModificationTime 

func (x *KumaResource_Meta) GetModificationTime() *timestamppb.Timestamp

func (*KumaResource_Meta) GetName 

func (x *KumaResource_Meta) GetName() string

func (*KumaResource_Meta) GetVersion 

func (x *KumaResource_Meta) GetVersion() string

func (*KumaResource_Meta) ProtoMessage 

func (*KumaResource_Meta) ProtoMessage()

func (*KumaResource_Meta) ProtoReflect 

func (x *KumaResource_Meta) ProtoReflect() protoreflect.Message

func (*KumaResource_Meta) Reset 

func (x *KumaResource_Meta) Reset()

func (*KumaResource_Meta) String 

func (x *KumaResource_Meta) String() string

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"`
	// contains filtered or unexported fields
}

func (*Logging) Descriptor deprecated 

func (*Logging) Descriptor() ([]byte, []int)

Deprecated: Use Logging.ProtoReflect.Descriptor instead.

func (*Logging) GetBackends 

func (x *Logging) GetBackends() []*LoggingBackend

func (*Logging) GetDefaultBackend 

func (x *Logging) GetDefaultBackend() string

func (*Logging) ProtoMessage 

func (*Logging) ProtoMessage()

func (*Logging) ProtoReflect 

func (x *Logging) ProtoReflect() protoreflect.Message

func (*Logging) Reset 

func (x *Logging) Reset()

func (*Logging) String 

func (x *Logging) String() string

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 *structpb.Struct `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

LoggingBackend defines logging backend available to mesh. Backends can be used in TrafficLog rules.

func (*LoggingBackend) Descriptor deprecated 

func (*LoggingBackend) Descriptor() ([]byte, []int)

Deprecated: Use LoggingBackend.ProtoReflect.Descriptor instead.

func (*LoggingBackend) GetConf 

func (x *LoggingBackend) GetConf() *structpb.Struct

func (*LoggingBackend) GetFormat 

func (x *LoggingBackend) GetFormat() string

func (*LoggingBackend) GetName 

func (x *LoggingBackend) GetName() string

func (*LoggingBackend) GetType 

func (x *LoggingBackend) GetType() string

func (*LoggingBackend) ProtoMessage 

func (*LoggingBackend) ProtoMessage()

func (*LoggingBackend) ProtoReflect 

func (x *LoggingBackend) ProtoReflect() protoreflect.Message

func (*LoggingBackend) Reset 

func (x *LoggingBackend) Reset()

func (*LoggingBackend) String 

func (x *LoggingBackend) String() string

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"`
	// Networking settings of the mesh
	Networking *Networking `protobuf:"bytes,5,opt,name=networking,proto3" json:"networking,omitempty"`
	// Routing settings of the mesh
	Routing *Routing `protobuf:"bytes,6,opt,name=routing,proto3" json:"routing,omitempty"`
	// contains filtered or unexported fields
}

Mesh defines configuration of a single mesh.

func (*Mesh) Descriptor deprecated 

func (*Mesh) Descriptor() ([]byte, []int)

Deprecated: Use Mesh.ProtoReflect.Descriptor instead.

func (*Mesh) GetLogging 

func (x *Mesh) GetLogging() *Logging

func (*Mesh) GetMetrics 

func (x *Mesh) GetMetrics() *Metrics

func (*Mesh) GetMtls 

func (x *Mesh) GetMtls() *Mesh_Mtls

func (*Mesh) GetNetworking 

func (x *Mesh) GetNetworking() *Networking

func (*Mesh) GetRouting 

func (x *Mesh) GetRouting() *Routing

func (*Mesh) GetTracing 

func (x *Mesh) GetTracing() *Tracing

func (*Mesh) IsPassthrough 

func (m *Mesh) IsPassthrough() bool

func (*Mesh) ProtoMessage 

func (*Mesh) ProtoMessage()

func (*Mesh) ProtoReflect 

func (x *Mesh) ProtoReflect() protoreflect.Message

func (*Mesh) Reset 

func (x *Mesh) Reset()

func (*Mesh) String 

func (x *Mesh) String() string

type MeshInsight 

type MeshInsight struct {

	// last_sync is a time of the last synchronization
	LastSync   *timestamppb.Timestamp             `protobuf:"bytes,1,opt,name=last_sync,json=lastSync,proto3" json:"last_sync,omitempty"`
	Dataplanes *MeshInsight_DataplaneStat         `protobuf:"bytes,2,opt,name=dataplanes,proto3" json:"dataplanes,omitempty"`
	Policies   map[string]*MeshInsight_PolicyStat `` /* 157-byte string literal not displayed */
	DpVersions *MeshInsight_DpVersions            `protobuf:"bytes,4,opt,name=dpVersions,proto3" json:"dpVersions,omitempty"`
	// contains filtered or unexported fields
}

MeshInsight defines the observed state of a Mesh.

func (*MeshInsight) Descriptor deprecated 

func (*MeshInsight) Descriptor() ([]byte, []int)

Deprecated: Use MeshInsight.ProtoReflect.Descriptor instead.

func (*MeshInsight) GetDataplanes 

func (x *MeshInsight) GetDataplanes() *MeshInsight_DataplaneStat

func (*MeshInsight) GetDpVersions 

func (x *MeshInsight) GetDpVersions() *MeshInsight_DpVersions

func (*MeshInsight) GetLastSync 

func (x *MeshInsight) GetLastSync() *timestamppb.Timestamp

func (*MeshInsight) GetPolicies 

func (x *MeshInsight) GetPolicies() map[string]*MeshInsight_PolicyStat

func (*MeshInsight) ProtoMessage 

func (*MeshInsight) ProtoMessage()

func (*MeshInsight) ProtoReflect 

func (x *MeshInsight) ProtoReflect() protoreflect.Message

func (*MeshInsight) Reset 

func (x *MeshInsight) Reset()

func (*MeshInsight) String 

func (x *MeshInsight) String() string

type MeshInsight_DataplaneStat 

type MeshInsight_DataplaneStat struct {
	Total             uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Online            uint32 `protobuf:"varint,2,opt,name=online,proto3" json:"online,omitempty"`
	Offline           uint32 `protobuf:"varint,3,opt,name=offline,proto3" json:"offline,omitempty"`
	PartiallyDegraded uint32 `protobuf:"varint,4,opt,name=partially_degraded,json=partiallyDegraded,proto3" json:"partially_degraded,omitempty"`
	// contains filtered or unexported fields
}

DataplaneStat defines statistic specifically for Dataplane

func (*MeshInsight_DataplaneStat) Descriptor deprecated 

func (*MeshInsight_DataplaneStat) Descriptor() ([]byte, []int)

Deprecated: Use MeshInsight_DataplaneStat.ProtoReflect.Descriptor instead.

func (*MeshInsight_DataplaneStat) GetOffline 

func (x *MeshInsight_DataplaneStat) GetOffline() uint32

func (*MeshInsight_DataplaneStat) GetOnline 

func (x *MeshInsight_DataplaneStat) GetOnline() uint32

func (*MeshInsight_DataplaneStat) GetPartiallyDegraded 

func (x *MeshInsight_DataplaneStat) GetPartiallyDegraded() uint32

func (*MeshInsight_DataplaneStat) GetTotal 

func (x *MeshInsight_DataplaneStat) GetTotal() uint32

func (*MeshInsight_DataplaneStat) ProtoMessage 

func (*MeshInsight_DataplaneStat) ProtoMessage()

func (*MeshInsight_DataplaneStat) ProtoReflect 

func (x *MeshInsight_DataplaneStat) ProtoReflect() protoreflect.Message

func (*MeshInsight_DataplaneStat) Reset 

func (x *MeshInsight_DataplaneStat) Reset()

func (*MeshInsight_DataplaneStat) String 

func (x *MeshInsight_DataplaneStat) String() string

type MeshInsight_DpVersions 

type MeshInsight_DpVersions struct {

	// Dataplane stats grouped by KumaDP version
	KumaDp map[string]*MeshInsight_DataplaneStat `` /* 153-byte string literal not displayed */
	// Dataplan stats grouped by Envoy version
	Envoy map[string]*MeshInsight_DataplaneStat `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

DpVersions defines statistics grouped by dataplane versions

func (*MeshInsight_DpVersions) Descriptor deprecated 

func (*MeshInsight_DpVersions) Descriptor() ([]byte, []int)

Deprecated: Use MeshInsight_DpVersions.ProtoReflect.Descriptor instead.

func (*MeshInsight_DpVersions) GetEnvoy 

func (x *MeshInsight_DpVersions) GetEnvoy() map[string]*MeshInsight_DataplaneStat

func (*MeshInsight_DpVersions) GetKumaDp 

func (x *MeshInsight_DpVersions) GetKumaDp() map[string]*MeshInsight_DataplaneStat

func (*MeshInsight_DpVersions) ProtoMessage 

func (*MeshInsight_DpVersions) ProtoMessage()

func (*MeshInsight_DpVersions) ProtoReflect 

func (x *MeshInsight_DpVersions) ProtoReflect() protoreflect.Message

func (*MeshInsight_DpVersions) Reset 

func (x *MeshInsight_DpVersions) Reset()

func (*MeshInsight_DpVersions) String 

func (x *MeshInsight_DpVersions) String() string

type MeshInsight_PolicyStat 

type MeshInsight_PolicyStat struct {
	Total uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

PolicyStat defines statistic for all policies in general

func (*MeshInsight_PolicyStat) Descriptor deprecated 

func (*MeshInsight_PolicyStat) Descriptor() ([]byte, []int)

Deprecated: Use MeshInsight_PolicyStat.ProtoReflect.Descriptor instead.

func (*MeshInsight_PolicyStat) GetTotal 

func (x *MeshInsight_PolicyStat) GetTotal() uint32

func (*MeshInsight_PolicyStat) ProtoMessage 

func (*MeshInsight_PolicyStat) ProtoMessage()

func (*MeshInsight_PolicyStat) ProtoReflect 

func (x *MeshInsight_PolicyStat) ProtoReflect() protoreflect.Message

func (*MeshInsight_PolicyStat) Reset 

func (x *MeshInsight_PolicyStat) Reset()

func (*MeshInsight_PolicyStat) String 

func (x *MeshInsight_PolicyStat) String() string

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"`
	// contains filtered or unexported fields
}

mTLS settings of a Mesh.

func (*Mesh_Mtls) Descriptor deprecated 

func (*Mesh_Mtls) Descriptor() ([]byte, []int)

Deprecated: Use Mesh_Mtls.ProtoReflect.Descriptor instead.

func (*Mesh_Mtls) GetBackends 

func (x *Mesh_Mtls) GetBackends() []*CertificateAuthorityBackend

func (*Mesh_Mtls) GetEnabledBackend 

func (x *Mesh_Mtls) GetEnabledBackend() string

func (*Mesh_Mtls) ProtoMessage 

func (*Mesh_Mtls) ProtoMessage()

func (*Mesh_Mtls) ProtoReflect 

func (x *Mesh_Mtls) ProtoReflect() protoreflect.Message

func (*Mesh_Mtls) Reset 

func (x *Mesh_Mtls) Reset()

func (*Mesh_Mtls) String 

func (x *Mesh_Mtls) String() string

type Message 

type Message struct {

	// Types that are assignable to Value:
	//	*Message_Request
	//	*Message_Response
	Value isMessage_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

func (*Message) Descriptor() ([]byte, []int)

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetRequest 

func (x *Message) GetRequest() *v2.DiscoveryRequest

func (*Message) GetResponse 

func (x *Message) GetResponse() *v2.DiscoveryResponse

func (*Message) GetValue 

func (m *Message) GetValue() isMessage_Value

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type Message_Request 

type Message_Request struct {
	Request *v2.DiscoveryRequest `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}

type Message_Response 

type Message_Response struct {
	Response *v2.DiscoveryResponse `protobuf:"bytes,2,opt,name=response,proto3,oneof"`
}

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"`
	// contains filtered or unexported fields
}

Metrics defines configuration for metrics that should be collected and exposed by dataplanes.

func (*Metrics) Descriptor deprecated 

func (*Metrics) Descriptor() ([]byte, []int)

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetBackends 

func (x *Metrics) GetBackends() []*MetricsBackend

func (*Metrics) GetEnabledBackend 

func (x *Metrics) GetEnabledBackend() string

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect 

func (x *Metrics) ProtoReflect() protoreflect.Message

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

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 *structpb.Struct `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

MetricsBackend defines metric backends

func (*MetricsBackend) Descriptor deprecated 

func (*MetricsBackend) Descriptor() ([]byte, []int)

Deprecated: Use MetricsBackend.ProtoReflect.Descriptor instead.

func (*MetricsBackend) GetConf 

func (x *MetricsBackend) GetConf() *structpb.Struct

func (*MetricsBackend) GetName 

func (x *MetricsBackend) GetName() string

func (*MetricsBackend) GetType 

func (x *MetricsBackend) GetType() string

func (*MetricsBackend) ProtoMessage 

func (*MetricsBackend) ProtoMessage()

func (*MetricsBackend) ProtoReflect 

func (x *MetricsBackend) ProtoReflect() protoreflect.Message

func (*MetricsBackend) Reset 

func (x *MetricsBackend) Reset()

func (*MetricsBackend) String 

func (x *MetricsBackend) String() string

type MultiValueTagSet 

type MultiValueTagSet map[string]map[string]bool

Set of tags that allows multiple values per key.

func MultiValueTagSetFrom 

func MultiValueTagSetFrom(data map[string][]string) MultiValueTagSet

func (MultiValueTagSet) Keys 

func (t MultiValueTagSet) Keys() []string

func (MultiValueTagSet) String 

func (t MultiValueTagSet) String() string

func (MultiValueTagSet) UniqueValues 

func (t MultiValueTagSet) UniqueValues(key string) []string

func (MultiValueTagSet) Values 

func (t MultiValueTagSet) Values(key string) []string

type MultiplexServiceClient 

type MultiplexServiceClient interface {
	StreamMessage(ctx context.Context, opts ...grpc.CallOption) (MultiplexService_StreamMessageClient, error)
}

MultiplexServiceClient is the client API for MultiplexService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMultiplexServiceClient 

func NewMultiplexServiceClient(cc grpc.ClientConnInterface) MultiplexServiceClient

type MultiplexServiceServer 

type MultiplexServiceServer interface {
	StreamMessage(MultiplexService_StreamMessageServer) error
}

MultiplexServiceServer is the server API for MultiplexService service.

type MultiplexService_StreamMessageClient 

type MultiplexService_StreamMessageClient interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ClientStream
}

type MultiplexService_StreamMessageServer 

type MultiplexService_StreamMessageServer interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type Networking 

type Networking struct {

	// Outbound settings
	Outbound *Networking_Outbound `protobuf:"bytes,1,opt,name=outbound,proto3" json:"outbound,omitempty"`
	// contains filtered or unexported fields
}

Networking defines the networking configuration of the mesh

func (*Networking) Descriptor deprecated 

func (*Networking) Descriptor() ([]byte, []int)

Deprecated: Use Networking.ProtoReflect.Descriptor instead.

func (*Networking) GetOutbound 

func (x *Networking) GetOutbound() *Networking_Outbound

func (*Networking) ProtoMessage 

func (*Networking) ProtoMessage()

func (*Networking) ProtoReflect 

func (x *Networking) ProtoReflect() protoreflect.Message

func (*Networking) Reset 

func (x *Networking) Reset()

func (*Networking) String 

func (x *Networking) String() string

type Networking_Outbound 

type Networking_Outbound struct {

	// Control the passthrough cluster
	Passthrough *wrapperspb.BoolValue `protobuf:"bytes,1,opt,name=passthrough,proto3" json:"passthrough,omitempty"`
	// contains filtered or unexported fields
}

Outbound describes the common mesh outbound settings

func (*Networking_Outbound) Descriptor deprecated 

func (*Networking_Outbound) Descriptor() ([]byte, []int)

Deprecated: Use Networking_Outbound.ProtoReflect.Descriptor instead.

func (*Networking_Outbound) GetPassthrough 

func (x *Networking_Outbound) GetPassthrough() *wrapperspb.BoolValue

func (*Networking_Outbound) ProtoMessage 

func (*Networking_Outbound) ProtoMessage()

func (*Networking_Outbound) ProtoReflect 

func (x *Networking_Outbound) ProtoReflect() protoreflect.Message

func (*Networking_Outbound) Reset 

func (x *Networking_Outbound) Reset()

func (*Networking_Outbound) String 

func (x *Networking_Outbound) String() string

type OutboundInterface 

type OutboundInterface struct {
	DataplaneIP   string
	DataplanePort uint32
}

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 *wrapperspb.BoolValue `protobuf:"bytes,4,opt,name=skipMTLS,proto3" json:"skipMTLS,omitempty"`
	// contains filtered or unexported fields
}

PrometheusMetricsBackendConfig defines configuration of Prometheus backend

func (*PrometheusMetricsBackendConfig) Descriptor deprecated 

func (*PrometheusMetricsBackendConfig) Descriptor() ([]byte, []int)

Deprecated: Use PrometheusMetricsBackendConfig.ProtoReflect.Descriptor instead.

func (*PrometheusMetricsBackendConfig) GetPath 

func (x *PrometheusMetricsBackendConfig) GetPath() string

func (*PrometheusMetricsBackendConfig) GetPort 

func (x *PrometheusMetricsBackendConfig) GetPort() uint32

func (*PrometheusMetricsBackendConfig) GetSkipMTLS 

func (x *PrometheusMetricsBackendConfig) GetSkipMTLS() *wrapperspb.BoolValue

func (*PrometheusMetricsBackendConfig) GetTags 

func (x *PrometheusMetricsBackendConfig) GetTags() map[string]string

func (*PrometheusMetricsBackendConfig) ProtoMessage 

func (*PrometheusMetricsBackendConfig) ProtoMessage()

func (*PrometheusMetricsBackendConfig) ProtoReflect 

func (x *PrometheusMetricsBackendConfig) ProtoReflect() protoreflect.Message

func (*PrometheusMetricsBackendConfig) Reset 

func (x *PrometheusMetricsBackendConfig) Reset()

func (*PrometheusMetricsBackendConfig) String 

func (x *PrometheusMetricsBackendConfig) String() string

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"`
	// contains filtered or unexported fields
}

ProxyTemplate defines the desired state of ProxyTemplate

func (*ProxyTemplate) Descriptor deprecated 

func (*ProxyTemplate) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate.ProtoReflect.Descriptor instead.

func (*ProxyTemplate) GetConf 

func (x *ProxyTemplate) GetConf() *ProxyTemplate_Conf

func (*ProxyTemplate) GetSelectors 

func (x *ProxyTemplate) GetSelectors() []*Selector

func (*ProxyTemplate) ProtoMessage 

func (*ProxyTemplate) ProtoMessage()

func (*ProxyTemplate) ProtoReflect 

func (x *ProxyTemplate) ProtoReflect() protoreflect.Message

func (*ProxyTemplate) Reset 

func (x *ProxyTemplate) Reset()

func (*ProxyTemplate) String 

func (x *ProxyTemplate) String() string

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 */
	// contains filtered or unexported fields
}

func (*ProxyTemplateProfileSource) Descriptor deprecated 

func (*ProxyTemplateProfileSource) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplateProfileSource.ProtoReflect.Descriptor instead.

func (*ProxyTemplateProfileSource) GetName 

func (x *ProxyTemplateProfileSource) GetName() string

func (*ProxyTemplateProfileSource) GetParams 

func (x *ProxyTemplateProfileSource) GetParams() map[string]string

func (*ProxyTemplateProfileSource) ProtoMessage 

func (*ProxyTemplateProfileSource) ProtoMessage()

func (*ProxyTemplateProfileSource) ProtoReflect 

func (x *ProxyTemplateProfileSource) ProtoReflect() protoreflect.Message

func (*ProxyTemplateProfileSource) Reset 

func (x *ProxyTemplateProfileSource) Reset()

func (*ProxyTemplateProfileSource) String 

func (x *ProxyTemplateProfileSource) String() string

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"`
	// contains filtered or unexported fields
}

func (*ProxyTemplateRawResource) Descriptor deprecated 

func (*ProxyTemplateRawResource) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplateRawResource.ProtoReflect.Descriptor instead.

func (*ProxyTemplateRawResource) GetName 

func (x *ProxyTemplateRawResource) GetName() string

func (*ProxyTemplateRawResource) GetResource 

func (x *ProxyTemplateRawResource) GetResource() string

func (*ProxyTemplateRawResource) GetVersion 

func (x *ProxyTemplateRawResource) GetVersion() string

func (*ProxyTemplateRawResource) ProtoMessage 

func (*ProxyTemplateRawResource) ProtoMessage()

func (*ProxyTemplateRawResource) ProtoReflect 

func (x *ProxyTemplateRawResource) ProtoReflect() protoreflect.Message

func (*ProxyTemplateRawResource) Reset 

func (x *ProxyTemplateRawResource) Reset()

func (*ProxyTemplateRawResource) String 

func (x *ProxyTemplateRawResource) String() string

type ProxyTemplateRawSource 

type ProxyTemplateRawSource struct {

	// List of raw xDS resources.
	// +optional
	Resources []*ProxyTemplateRawResource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyTemplateRawSource) Descriptor deprecated 

func (*ProxyTemplateRawSource) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplateRawSource.ProtoReflect.Descriptor instead.

func (*ProxyTemplateRawSource) GetResources 

func (x *ProxyTemplateRawSource) GetResources() []*ProxyTemplateRawResource

func (*ProxyTemplateRawSource) ProtoMessage 

func (*ProxyTemplateRawSource) ProtoMessage()

func (*ProxyTemplateRawSource) ProtoReflect 

func (x *ProxyTemplateRawSource) ProtoReflect() protoreflect.Message

func (*ProxyTemplateRawSource) Reset 

func (x *ProxyTemplateRawSource) Reset()

func (*ProxyTemplateRawSource) String 

func (x *ProxyTemplateRawSource) String() string

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 assignable to Type:
	//	*ProxyTemplateSource_Profile
	//	*ProxyTemplateSource_Raw
	Type isProxyTemplateSource_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*ProxyTemplateSource) Descriptor deprecated 

func (*ProxyTemplateSource) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplateSource.ProtoReflect.Descriptor instead.

func (*ProxyTemplateSource) GetName 

func (x *ProxyTemplateSource) GetName() string

func (*ProxyTemplateSource) GetProfile 

func (x *ProxyTemplateSource) GetProfile() *ProxyTemplateProfileSource

func (*ProxyTemplateSource) GetRaw 

func (x *ProxyTemplateSource) GetRaw() *ProxyTemplateRawSource

func (*ProxyTemplateSource) GetType 

func (m *ProxyTemplateSource) GetType() isProxyTemplateSource_Type

func (*ProxyTemplateSource) ProtoMessage 

func (*ProxyTemplateSource) ProtoMessage()

func (*ProxyTemplateSource) ProtoReflect 

func (x *ProxyTemplateSource) ProtoReflect() protoreflect.Message

func (*ProxyTemplateSource) Reset 

func (x *ProxyTemplateSource) Reset()

func (*ProxyTemplateSource) String 

func (x *ProxyTemplateSource) String() string

type ProxyTemplateSource_Profile 

type ProxyTemplateSource_Profile struct {
	// Profile, e.g. `default-proxy`.
	// +optional
	Profile *ProxyTemplateProfileSource `protobuf:"bytes,2,opt,name=profile,proto3,oneof"`
}

type ProxyTemplateSource_Raw 

type ProxyTemplateSource_Raw struct {
	// Raw xDS resources.
	// +optional
	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"`
	// List of config modifications
	Modifications []*ProxyTemplate_Modifications `protobuf:"bytes,3,rep,name=modifications,proto3" json:"modifications,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyTemplate_Conf) Descriptor deprecated 

func (*ProxyTemplate_Conf) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate_Conf.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Conf) GetImports 

func (x *ProxyTemplate_Conf) GetImports() []string

func (*ProxyTemplate_Conf) GetModifications 

func (x *ProxyTemplate_Conf) GetModifications() []*ProxyTemplate_Modifications

func (*ProxyTemplate_Conf) GetResources 

func (x *ProxyTemplate_Conf) GetResources() []*ProxyTemplateRawResource

func (*ProxyTemplate_Conf) ProtoMessage 

func (*ProxyTemplate_Conf) ProtoMessage()

func (*ProxyTemplate_Conf) ProtoReflect 

func (x *ProxyTemplate_Conf) ProtoReflect() protoreflect.Message

func (*ProxyTemplate_Conf) Reset 

func (x *ProxyTemplate_Conf) Reset()

func (*ProxyTemplate_Conf) String 

func (x *ProxyTemplate_Conf) String() string

type ProxyTemplate_Modifications 

type ProxyTemplate_Modifications struct {

	// Types that are assignable to Type:
	//	*ProxyTemplate_Modifications_Cluster_
	//	*ProxyTemplate_Modifications_Listener_
	//	*ProxyTemplate_Modifications_NetworkFilter_
	//	*ProxyTemplate_Modifications_HttpFilter_
	//	*ProxyTemplate_Modifications_VirtualHost_
	Type isProxyTemplate_Modifications_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

Modifications to xDS config generated by Proxy Template

func (*ProxyTemplate_Modifications) Descriptor deprecated 

func (*ProxyTemplate_Modifications) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate_Modifications.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications) GetCluster 

func (x *ProxyTemplate_Modifications) GetCluster() *ProxyTemplate_Modifications_Cluster

func (*ProxyTemplate_Modifications) GetHttpFilter 

func (x *ProxyTemplate_Modifications) GetHttpFilter() *ProxyTemplate_Modifications_HttpFilter

func (*ProxyTemplate_Modifications) GetListener 

func (x *ProxyTemplate_Modifications) GetListener() *ProxyTemplate_Modifications_Listener

func (*ProxyTemplate_Modifications) GetNetworkFilter 

func (x *ProxyTemplate_Modifications) GetNetworkFilter() *ProxyTemplate_Modifications_NetworkFilter

func (*ProxyTemplate_Modifications) GetType 

func (m *ProxyTemplate_Modifications) GetType() isProxyTemplate_Modifications_Type

func (*ProxyTemplate_Modifications) GetVirtualHost 

func (x *ProxyTemplate_Modifications) GetVirtualHost() *ProxyTemplate_Modifications_VirtualHost

func (*ProxyTemplate_Modifications) ProtoMessage 

func (*ProxyTemplate_Modifications) ProtoMessage()

func (*ProxyTemplate_Modifications) ProtoReflect 

func (x *ProxyTemplate_Modifications) ProtoReflect() protoreflect.Message

func (*ProxyTemplate_Modifications) Reset 

func (x *ProxyTemplate_Modifications) Reset()

func (*ProxyTemplate_Modifications) String 

func (x *ProxyTemplate_Modifications) String() string

type ProxyTemplate_Modifications_Cluster 

type ProxyTemplate_Modifications_Cluster struct {

	// Only clusters that match will be modified
	Match *ProxyTemplate_Modifications_Cluster_Match `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// Operation to apply on a cluster (add, remove, patch)
	Operation string `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	// xDS cluster
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Cluster defines modifications to generated clusters

func (*ProxyTemplate_Modifications_Cluster) Descriptor deprecated 

func (*ProxyTemplate_Modifications_Cluster) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate_Modifications_Cluster.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_Cluster) GetMatch 

func (x *ProxyTemplate_Modifications_Cluster) GetMatch() *ProxyTemplate_Modifications_Cluster_Match

func (*ProxyTemplate_Modifications_Cluster) GetOperation 

func (x *ProxyTemplate_Modifications_Cluster) GetOperation() string

func (*ProxyTemplate_Modifications_Cluster) GetValue 

func (x *ProxyTemplate_Modifications_Cluster) GetValue() string

func (*ProxyTemplate_Modifications_Cluster) ProtoMessage 

func (*ProxyTemplate_Modifications_Cluster) ProtoMessage()

func (*ProxyTemplate_Modifications_Cluster) ProtoReflect 

func (x *ProxyTemplate_Modifications_Cluster) ProtoReflect() protoreflect.Message

func (*ProxyTemplate_Modifications_Cluster) Reset 

func (x *ProxyTemplate_Modifications_Cluster) Reset()

func (*ProxyTemplate_Modifications_Cluster) String 

func (x *ProxyTemplate_Modifications_Cluster) String() string

type ProxyTemplate_Modifications_Cluster_ 

type ProxyTemplate_Modifications_Cluster_ struct {
	// Cluster modification
	Cluster *ProxyTemplate_Modifications_Cluster `protobuf:"bytes,1,opt,name=cluster,proto3,oneof"`
}

type ProxyTemplate_Modifications_Cluster_Match 

type ProxyTemplate_Modifications_Cluster_Match struct {

	// Origin of the resource generation. (inbound, outbound, prometheus,
	// transparent, ingress)
	Origin string `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
	// Name of the cluster to match
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Match defines match for cluster

func (*ProxyTemplate_Modifications_Cluster_Match) Descriptor deprecated 

func (*ProxyTemplate_Modifications_Cluster_Match) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate_Modifications_Cluster_Match.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_Cluster_Match) GetName 

func (x *ProxyTemplate_Modifications_Cluster_Match) GetName() string

func (*ProxyTemplate_Modifications_Cluster_Match) GetOrigin 

func (x *ProxyTemplate_Modifications_Cluster_Match) GetOrigin() string

func (*ProxyTemplate_Modifications_Cluster_Match) ProtoMessage 

func (*ProxyTemplate_Modifications_Cluster_Match) ProtoMessage()

func (*ProxyTemplate_Modifications_Cluster_Match) ProtoReflect 

func (x *ProxyTemplate_Modifications_Cluster_Match) ProtoReflect() protoreflect.Message

func (*ProxyTemplate_Modifications_Cluster_Match) Reset 

func (x *ProxyTemplate_Modifications_Cluster_Match) Reset()

func (*ProxyTemplate_Modifications_Cluster_Match) String 

func (x *ProxyTemplate_Modifications_Cluster_Match) String() string

type ProxyTemplate_Modifications_HttpFilter 

type ProxyTemplate_Modifications_HttpFilter struct {

	// Only HTTP filters that match will be modified
	Match *ProxyTemplate_Modifications_HttpFilter_Match `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// Operation to apply on network filter (addFirst, addLast, addBefore,
	// addAfter, remove, patch)
	Operation string `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	// xDS HTTP filter
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

HttpFilter defines modifications to generated HTTP filters

func (*ProxyTemplate_Modifications_HttpFilter) Descriptor deprecated 

func (*ProxyTemplate_Modifications_HttpFilter) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate_Modifications_HttpFilter.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_HttpFilter) GetMatch 

func (x *ProxyTemplate_Modifications_HttpFilter) GetMatch() *ProxyTemplate_Modifications_HttpFilter_Match

func (*ProxyTemplate_Modifications_HttpFilter) GetOperation 

func (x *ProxyTemplate_Modifications_HttpFilter) GetOperation() string

func (*ProxyTemplate_Modifications_HttpFilter) GetValue 

func (x *ProxyTemplate_Modifications_HttpFilter) GetValue() string

func (*ProxyTemplate_Modifications_HttpFilter) ProtoMessage 

func (*ProxyTemplate_Modifications_HttpFilter) ProtoMessage()

func (*ProxyTemplate_Modifications_HttpFilter) ProtoReflect 

func (x *ProxyTemplate_Modifications_HttpFilter) ProtoReflect() protoreflect.Message

func (*ProxyTemplate_Modifications_HttpFilter) Reset 

func (x *ProxyTemplate_Modifications_HttpFilter) Reset()

func (*ProxyTemplate_Modifications_HttpFilter) String 

func (x *ProxyTemplate_Modifications_HttpFilter) String() string

type ProxyTemplate_Modifications_HttpFilter_ 

type ProxyTemplate_Modifications_HttpFilter_ struct {
	// HTTP Filter modification
	HttpFilter *ProxyTemplate_Modifications_HttpFilter `protobuf:"bytes,4,opt,name=httpFilter,proto3,oneof"`
}

type ProxyTemplate_Modifications_HttpFilter_Match 

type ProxyTemplate_Modifications_HttpFilter_Match struct {

	// Origin of the resource generation. (inbound, outbound, prometheus,
	// transparent, ingress)
	Origin string `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
	// Name of the network filter
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Name of the listener that http filter modifications will be applied
	// to
	ListenerName string `protobuf:"bytes,3,opt,name=listenerName,proto3" json:"listenerName,omitempty"`
	// contains filtered or unexported fields
}

Match defines match for http filter

func (*ProxyTemplate_Modifications_HttpFilter_Match) Descriptor deprecated 

func (*ProxyTemplate_Modifications_HttpFilter_Match) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate_Modifications_HttpFilter_Match.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_HttpFilter_Match) GetListenerName 

func (x *ProxyTemplate_Modifications_HttpFilter_Match) GetListenerName() string

func (*ProxyTemplate_Modifications_HttpFilter_Match) GetName 

func (x *ProxyTemplate_Modifications_HttpFilter_Match) GetName() string

func (*ProxyTemplate_Modifications_HttpFilter_Match) GetOrigin 

func (x *ProxyTemplate_Modifications_HttpFilter_Match) GetOrigin() string

func (*ProxyTemplate_Modifications_HttpFilter_Match) ProtoMessage 

func (*ProxyTemplate_Modifications_HttpFilter_Match) ProtoMessage()

func (*ProxyTemplate_Modifications_HttpFilter_Match) ProtoReflect 

func (x *ProxyTemplate_Modifications_HttpFilter_Match) ProtoReflect() protoreflect.Message

func (*ProxyTemplate_Modifications_HttpFilter_Match) Reset 

func (x *ProxyTemplate_Modifications_HttpFilter_Match) Reset()

func (*ProxyTemplate_Modifications_HttpFilter_Match) String 

func (x *ProxyTemplate_Modifications_HttpFilter_Match) String() string

type ProxyTemplate_Modifications_Listener 

type ProxyTemplate_Modifications_Listener struct {

	// Only listeners that match will be modified
	Match *ProxyTemplate_Modifications_Listener_Match `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// Operation to apply on a listener (add, remove, patch)
	Operation string `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	// xDS listener
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Listener defines modification to generated listeners

func (*ProxyTemplate_Modifications_Listener) Descriptor deprecated 

func (*ProxyTemplate_Modifications_Listener) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate_Modifications_Listener.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_Listener) GetMatch 

func (x *ProxyTemplate_Modifications_Listener) GetMatch() *ProxyTemplate_Modifications_Listener_Match

func (*ProxyTemplate_Modifications_Listener) GetOperation 

func (x *ProxyTemplate_Modifications_Listener) GetOperation() string

func (*ProxyTemplate_Modifications_Listener) GetValue 

func (x *ProxyTemplate_Modifications_Listener) GetValue() string

func (*ProxyTemplate_Modifications_Listener) ProtoMessage 

func (*ProxyTemplate_Modifications_Listener) ProtoMessage()

func (*ProxyTemplate_Modifications_Listener) ProtoReflect 

func (x *ProxyTemplate_Modifications_Listener) ProtoReflect() protoreflect.Message

func (*ProxyTemplate_Modifications_Listener) Reset 

func (x *ProxyTemplate_Modifications_Listener) Reset()

func (*ProxyTemplate_Modifications_Listener) String 

func (x *ProxyTemplate_Modifications_Listener) String() string

type ProxyTemplate_Modifications_Listener_ 

type ProxyTemplate_Modifications_Listener_ struct {
	// Listener modification
	Listener *ProxyTemplate_Modifications_Listener `protobuf:"bytes,2,opt,name=listener,proto3,oneof"`
}

type ProxyTemplate_Modifications_Listener_Match 

type ProxyTemplate_Modifications_Listener_Match struct {

	// Origin of the resource generation. (inbound, outbound, prometheus,
	// transparent, ingress)
	Origin string `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
	// Name of the listener to match
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Match defines match for listener

func (*ProxyTemplate_Modifications_Listener_Match) Descriptor deprecated 

func (*ProxyTemplate_Modifications_Listener_Match) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate_Modifications_Listener_Match.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_Listener_Match) GetName 

func (x *ProxyTemplate_Modifications_Listener_Match) GetName() string

func (*ProxyTemplate_Modifications_Listener_Match) GetOrigin 

func (x *ProxyTemplate_Modifications_Listener_Match) GetOrigin() string

func (*ProxyTemplate_Modifications_Listener_Match) ProtoMessage 

func (*ProxyTemplate_Modifications_Listener_Match) ProtoMessage()

func (*ProxyTemplate_Modifications_Listener_Match) ProtoReflect 

func (x *ProxyTemplate_Modifications_Listener_Match) ProtoReflect() protoreflect.Message

func (*ProxyTemplate_Modifications_Listener_Match) Reset 

func (x *ProxyTemplate_Modifications_Listener_Match) Reset()

func (*ProxyTemplate_Modifications_Listener_Match) String 

func (x *ProxyTemplate_Modifications_Listener_Match) String() string

type ProxyTemplate_Modifications_NetworkFilter 

type ProxyTemplate_Modifications_NetworkFilter struct {

	// Only network filters that match will be modified
	Match *ProxyTemplate_Modifications_NetworkFilter_Match `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// Operation to apply on network filter (addFirst, addLast, addBefore,
	// addAfter, remove, patch)
	Operation string `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	// xDS network filter
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Listener defines modification to generated network filters

func (*ProxyTemplate_Modifications_NetworkFilter) Descriptor deprecated 

func (*ProxyTemplate_Modifications_NetworkFilter) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate_Modifications_NetworkFilter.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_NetworkFilter) GetMatch 

func (x *ProxyTemplate_Modifications_NetworkFilter) GetMatch() *ProxyTemplate_Modifications_NetworkFilter_Match

func (*ProxyTemplate_Modifications_NetworkFilter) GetOperation 

func (x *ProxyTemplate_Modifications_NetworkFilter) GetOperation() string

func (*ProxyTemplate_Modifications_NetworkFilter) GetValue 

func (x *ProxyTemplate_Modifications_NetworkFilter) GetValue() string

func (*ProxyTemplate_Modifications_NetworkFilter) ProtoMessage 

func (*ProxyTemplate_Modifications_NetworkFilter) ProtoMessage()

func (*ProxyTemplate_Modifications_NetworkFilter) ProtoReflect 

func (x *ProxyTemplate_Modifications_NetworkFilter) ProtoReflect() protoreflect.Message

func (*ProxyTemplate_Modifications_NetworkFilter) Reset 

func (x *ProxyTemplate_Modifications_NetworkFilter) Reset()

func (*ProxyTemplate_Modifications_NetworkFilter) String 

func (x *ProxyTemplate_Modifications_NetworkFilter) String() string

type ProxyTemplate_Modifications_NetworkFilter_ 

type ProxyTemplate_Modifications_NetworkFilter_ struct {
	// Network Filter modification
	NetworkFilter *ProxyTemplate_Modifications_NetworkFilter `protobuf:"bytes,3,opt,name=networkFilter,proto3,oneof"`
}

type ProxyTemplate_Modifications_NetworkFilter_Match 

type ProxyTemplate_Modifications_NetworkFilter_Match struct {

	// Origin of the resource generation. (inbound, outbound, prometheus,
	// transparent, ingress)
	Origin string `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
	// Name of the network filter
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Name of the listener that network filter modifications will be
	// applied to
	ListenerName string `protobuf:"bytes,3,opt,name=listenerName,proto3" json:"listenerName,omitempty"`
	// contains filtered or unexported fields
}

Match defines match for network filter

func (*ProxyTemplate_Modifications_NetworkFilter_Match) Descriptor deprecated 

func (*ProxyTemplate_Modifications_NetworkFilter_Match) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate_Modifications_NetworkFilter_Match.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_NetworkFilter_Match) GetListenerName 

func (x *ProxyTemplate_Modifications_NetworkFilter_Match) GetListenerName() string

func (*ProxyTemplate_Modifications_NetworkFilter_Match) GetName 

func (x *ProxyTemplate_Modifications_NetworkFilter_Match) GetName() string

func (*ProxyTemplate_Modifications_NetworkFilter_Match) GetOrigin 

func (x *ProxyTemplate_Modifications_NetworkFilter_Match) GetOrigin() string

func (*ProxyTemplate_Modifications_NetworkFilter_Match) ProtoMessage 

func (*ProxyTemplate_Modifications_NetworkFilter_Match) ProtoMessage()

func (*ProxyTemplate_Modifications_NetworkFilter_Match) ProtoReflect 

func (x *ProxyTemplate_Modifications_NetworkFilter_Match) ProtoReflect() protoreflect.Message

func (*ProxyTemplate_Modifications_NetworkFilter_Match) Reset 

func (x *ProxyTemplate_Modifications_NetworkFilter_Match) Reset()

func (*ProxyTemplate_Modifications_NetworkFilter_Match) String 

func (x *ProxyTemplate_Modifications_NetworkFilter_Match) String() string

type ProxyTemplate_Modifications_VirtualHost 

type ProxyTemplate_Modifications_VirtualHost struct {

	// Only virtual hosts that match will be modified
	Match *ProxyTemplate_Modifications_VirtualHost_Match `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// Operation to apply on a virtual hosts (add, remove, patch)
	Operation string `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	// xDS virtual host
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

VirtualHost defines modification to generated virtual hosts

func (*ProxyTemplate_Modifications_VirtualHost) Descriptor deprecated 

func (*ProxyTemplate_Modifications_VirtualHost) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate_Modifications_VirtualHost.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_VirtualHost) GetMatch 

func (x *ProxyTemplate_Modifications_VirtualHost) GetMatch() *ProxyTemplate_Modifications_VirtualHost_Match

func (*ProxyTemplate_Modifications_VirtualHost) GetOperation 

func (x *ProxyTemplate_Modifications_VirtualHost) GetOperation() string

func (*ProxyTemplate_Modifications_VirtualHost) GetValue 

func (x *ProxyTemplate_Modifications_VirtualHost) GetValue() string

func (*ProxyTemplate_Modifications_VirtualHost) ProtoMessage 

func (*ProxyTemplate_Modifications_VirtualHost) ProtoMessage()

func (*ProxyTemplate_Modifications_VirtualHost) ProtoReflect 

func (x *ProxyTemplate_Modifications_VirtualHost) ProtoReflect() protoreflect.Message

func (*ProxyTemplate_Modifications_VirtualHost) Reset 

func (x *ProxyTemplate_Modifications_VirtualHost) Reset()

func (*ProxyTemplate_Modifications_VirtualHost) String 

func (x *ProxyTemplate_Modifications_VirtualHost) String() string

type ProxyTemplate_Modifications_VirtualHost_ 

type ProxyTemplate_Modifications_VirtualHost_ struct {
	// Virtual Host modifications
	VirtualHost *ProxyTemplate_Modifications_VirtualHost `protobuf:"bytes,5,opt,name=virtualHost,proto3,oneof"`
}

type ProxyTemplate_Modifications_VirtualHost_Match 

type ProxyTemplate_Modifications_VirtualHost_Match struct {

	// Origin of the resource generation. (inbound, outbound, prometheus,
	// transparent, ingress)
	Origin string `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
	// Name of the virtual host to match
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Name of the route configuration
	RouteConfigurationName string `protobuf:"bytes,3,opt,name=routeConfigurationName,proto3" json:"routeConfigurationName,omitempty"`
	// contains filtered or unexported fields
}

Match defines match for virtual host

func (*ProxyTemplate_Modifications_VirtualHost_Match) Descriptor deprecated 

func (*ProxyTemplate_Modifications_VirtualHost_Match) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTemplate_Modifications_VirtualHost_Match.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_VirtualHost_Match) GetName 

func (x *ProxyTemplate_Modifications_VirtualHost_Match) GetName() string

func (*ProxyTemplate_Modifications_VirtualHost_Match) GetOrigin 

func (x *ProxyTemplate_Modifications_VirtualHost_Match) GetOrigin() string

func (*ProxyTemplate_Modifications_VirtualHost_Match) GetRouteConfigurationName 

func (x *ProxyTemplate_Modifications_VirtualHost_Match) GetRouteConfigurationName() string

func (*ProxyTemplate_Modifications_VirtualHost_Match) ProtoMessage 

func (*ProxyTemplate_Modifications_VirtualHost_Match) ProtoMessage()

func (*ProxyTemplate_Modifications_VirtualHost_Match) ProtoReflect 

func (x *ProxyTemplate_Modifications_VirtualHost_Match) ProtoReflect() protoreflect.Message

func (*ProxyTemplate_Modifications_VirtualHost_Match) Reset 

func (x *ProxyTemplate_Modifications_VirtualHost_Match) Reset()

func (*ProxyTemplate_Modifications_VirtualHost_Match) String 

func (x *ProxyTemplate_Modifications_VirtualHost_Match) String() string

type ProxyType 

type ProxyType string
const (
	DataplaneProxyType ProxyType = "dataplane"
	IngressProxyType   ProxyType = "ingress"
)

func (ProxyType) IsValid 

func (t ProxyType) IsValid() error

type RateLimit 

type RateLimit struct {

	// List of selectors to match dataplanes that rate limit will be applied for
	Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	// List of selectors to match services that need to be rate limited.
	Destinations []*Selector `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"`
	// Configuration for RateLimit
	// +required
	Conf *RateLimit_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

func (*RateLimit) Descriptor deprecated 

func (*RateLimit) Descriptor() ([]byte, []int)

Deprecated: Use RateLimit.ProtoReflect.Descriptor instead.

func (*RateLimit) GetConf 

func (x *RateLimit) GetConf() *RateLimit_Conf

func (*RateLimit) GetDestinations 

func (x *RateLimit) GetDestinations() []*Selector

func (*RateLimit) GetSources 

func (x *RateLimit) GetSources() []*Selector

func (*RateLimit) ProtoMessage 

func (*RateLimit) ProtoMessage()

func (*RateLimit) ProtoReflect 

func (x *RateLimit) ProtoReflect() protoreflect.Message

func (*RateLimit) Reset 

func (x *RateLimit) Reset()

func (*RateLimit) SourceTags 

func (rl *RateLimit) SourceTags() (setList []SingleValueTagSet)

func (*RateLimit) String 

func (x *RateLimit) String() string

type RateLimit_Conf 

type RateLimit_Conf struct {

	// The HTTP RateLimit configuration
	// +optional
	Http *RateLimit_Conf_Http `protobuf:"bytes,1,opt,name=http,proto3" json:"http,omitempty"`
	// contains filtered or unexported fields
}

func (*RateLimit_Conf) Descriptor deprecated 

func (*RateLimit_Conf) Descriptor() ([]byte, []int)

Deprecated: Use RateLimit_Conf.ProtoReflect.Descriptor instead.

func (*RateLimit_Conf) GetHttp 

func (x *RateLimit_Conf) GetHttp() *RateLimit_Conf_Http

func (*RateLimit_Conf) ProtoMessage 

func (*RateLimit_Conf) ProtoMessage()

func (*RateLimit_Conf) ProtoReflect 

func (x *RateLimit_Conf) ProtoReflect() protoreflect.Message

func (*RateLimit_Conf) Reset 

func (x *RateLimit_Conf) Reset()

func (*RateLimit_Conf) String 

func (x *RateLimit_Conf) String() string

type RateLimit_Conf_Http 

type RateLimit_Conf_Http struct {

	// The number of HTTP requests this RateLimiter allows
	// +required
	Requests uint32 `protobuf:"varint,1,opt,name=requests,proto3" json:"requests,omitempty"`
	// The the interval for which `requests` will be accounted.
	// +required
	Interval *durationpb.Duration `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"`
	// Describes the actions to take on RatelLimiter event
	// +optional
	OnRateLimit *RateLimit_Conf_Http_OnRateLimit `protobuf:"bytes,3,opt,name=onRateLimit,proto3" json:"onRateLimit,omitempty"`
	// contains filtered or unexported fields
}

func (*RateLimit_Conf_Http) Descriptor deprecated 

func (*RateLimit_Conf_Http) Descriptor() ([]byte, []int)

Deprecated: Use RateLimit_Conf_Http.ProtoReflect.Descriptor instead.

func (*RateLimit_Conf_Http) GetInterval 

func (x *RateLimit_Conf_Http) GetInterval() *durationpb.Duration

func (*RateLimit_Conf_Http) GetOnRateLimit 

func (x *RateLimit_Conf_Http) GetOnRateLimit() *RateLimit_Conf_Http_OnRateLimit

func (*RateLimit_Conf_Http) GetRequests 

func (x *RateLimit_Conf_Http) GetRequests() uint32

func (*RateLimit_Conf_Http) ProtoMessage 

func (*RateLimit_Conf_Http) ProtoMessage()

func (*RateLimit_Conf_Http) ProtoReflect 

func (x *RateLimit_Conf_Http) ProtoReflect() protoreflect.Message

func (*RateLimit_Conf_Http) Reset 

func (x *RateLimit_Conf_Http) Reset()

func (*RateLimit_Conf_Http) String 

func (x *RateLimit_Conf_Http) String() string

type RateLimit_Conf_Http_OnRateLimit 

type RateLimit_Conf_Http_OnRateLimit struct {

	// The HTTP status code to be set on a RateLimit event
	// +optional
	Status *wrapperspb.UInt32Value `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// The Headers to be added to the HTTP response on a RateLimit event
	// +optional
	Headers []*RateLimit_Conf_Http_OnRateLimit_HeaderValue `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

func (*RateLimit_Conf_Http_OnRateLimit) Descriptor deprecated 

func (*RateLimit_Conf_Http_OnRateLimit) Descriptor() ([]byte, []int)

Deprecated: Use RateLimit_Conf_Http_OnRateLimit.ProtoReflect.Descriptor instead.

func (*RateLimit_Conf_Http_OnRateLimit) GetHeaders 

func (x *RateLimit_Conf_Http_OnRateLimit) GetHeaders() []*RateLimit_Conf_Http_OnRateLimit_HeaderValue

func (*RateLimit_Conf_Http_OnRateLimit) GetStatus 

func (x *RateLimit_Conf_Http_OnRateLimit) GetStatus() *wrapperspb.UInt32Value

func (*RateLimit_Conf_Http_OnRateLimit) ProtoMessage 

func (*RateLimit_Conf_Http_OnRateLimit) ProtoMessage()

func (*RateLimit_Conf_Http_OnRateLimit) ProtoReflect 

func (x *RateLimit_Conf_Http_OnRateLimit) ProtoReflect() protoreflect.Message

func (*RateLimit_Conf_Http_OnRateLimit) Reset 

func (x *RateLimit_Conf_Http_OnRateLimit) Reset()

func (*RateLimit_Conf_Http_OnRateLimit) String 

func (x *RateLimit_Conf_Http_OnRateLimit) String() string

type RateLimit_Conf_Http_OnRateLimit_HeaderValue 

type RateLimit_Conf_Http_OnRateLimit_HeaderValue struct {

	// Header name
	// +optional
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Header value
	// +optional
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// Should the header be appended
	// +optional
	Append *wrapperspb.BoolValue `protobuf:"bytes,3,opt,name=append,proto3" json:"append,omitempty"`
	// contains filtered or unexported fields
}

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) Descriptor deprecated 

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) Descriptor() ([]byte, []int)

Deprecated: Use RateLimit_Conf_Http_OnRateLimit_HeaderValue.ProtoReflect.Descriptor instead.

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) GetAppend 

func (x *RateLimit_Conf_Http_OnRateLimit_HeaderValue) GetAppend() *wrapperspb.BoolValue

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) GetKey 

func (x *RateLimit_Conf_Http_OnRateLimit_HeaderValue) GetKey() string

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) GetValue 

func (x *RateLimit_Conf_Http_OnRateLimit_HeaderValue) GetValue() string

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) ProtoMessage 

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) ProtoMessage()

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) ProtoReflect 

func (x *RateLimit_Conf_Http_OnRateLimit_HeaderValue) ProtoReflect() protoreflect.Message

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) Reset 

func (x *RateLimit_Conf_Http_OnRateLimit_HeaderValue) Reset()

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) String 

func (x *RateLimit_Conf_Http_OnRateLimit_HeaderValue) String() string

type Retry 

type Retry struct {

	// List of selectors to match dataplanes that retry policy should be
	// configured for
	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"`
	//  +required
	Conf *Retry_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

func (*Retry) Descriptor deprecated 

func (*Retry) Descriptor() ([]byte, []int)

Deprecated: Use Retry.ProtoReflect.Descriptor instead.

func (*Retry) GetConf 

func (x *Retry) GetConf() *Retry_Conf

func (*Retry) GetDestinations 

func (x *Retry) GetDestinations() []*Selector

func (*Retry) GetSources 

func (x *Retry) GetSources() []*Selector

func (*Retry) ProtoMessage 

func (*Retry) ProtoMessage()

func (*Retry) ProtoReflect 

func (x *Retry) ProtoReflect() protoreflect.Message

func (*Retry) Reset 

func (x *Retry) Reset()

func (*Retry) String 

func (x *Retry) String() string

type Retry_Conf 

type Retry_Conf struct {
	Http *Retry_Conf_Http `protobuf:"bytes,1,opt,name=http,proto3" json:"http,omitempty"`
	Tcp  *Retry_Conf_Tcp  `protobuf:"bytes,2,opt,name=tcp,proto3" json:"tcp,omitempty"`
	Grpc *Retry_Conf_Grpc `protobuf:"bytes,3,opt,name=grpc,proto3" json:"grpc,omitempty"`
	// contains filtered or unexported fields
}

func (*Retry_Conf) Descriptor deprecated 

func (*Retry_Conf) Descriptor() ([]byte, []int)

Deprecated: Use Retry_Conf.ProtoReflect.Descriptor instead.

func (*Retry_Conf) GetGrpc 

func (x *Retry_Conf) GetGrpc() *Retry_Conf_Grpc

func (*Retry_Conf) GetHttp 

func (x *Retry_Conf) GetHttp() *Retry_Conf_Http

func (*Retry_Conf) GetTcp 

func (x *Retry_Conf) GetTcp() *Retry_Conf_Tcp

func (*Retry_Conf) ProtoMessage 

func (*Retry_Conf) ProtoMessage()

func (*Retry_Conf) ProtoReflect 

func (x *Retry_Conf) ProtoReflect() protoreflect.Message

func (*Retry_Conf) Reset 

func (x *Retry_Conf) Reset()

func (*Retry_Conf) String 

func (x *Retry_Conf) String() string

type Retry_Conf_BackOff 

type Retry_Conf_BackOff struct {

	//  +required
	BaseInterval *durationpb.Duration `protobuf:"bytes,1,opt,name=base_interval,json=baseInterval,proto3" json:"base_interval,omitempty"`
	//  +optional
	MaxInterval *durationpb.Duration `protobuf:"bytes,2,opt,name=max_interval,json=maxInterval,proto3" json:"max_interval,omitempty"`
	// contains filtered or unexported fields
}

func (*Retry_Conf_BackOff) Descriptor deprecated 

func (*Retry_Conf_BackOff) Descriptor() ([]byte, []int)

Deprecated: Use Retry_Conf_BackOff.ProtoReflect.Descriptor instead.

func (*Retry_Conf_BackOff) GetBaseInterval 

func (x *Retry_Conf_BackOff) GetBaseInterval() *durationpb.Duration

func (*Retry_Conf_BackOff) GetMaxInterval 

func (x *Retry_Conf_BackOff) GetMaxInterval() *durationpb.Duration

func (*Retry_Conf_BackOff) ProtoMessage 

func (*Retry_Conf_BackOff) ProtoMessage()

func (*Retry_Conf_BackOff) ProtoReflect 

func (x *Retry_Conf_BackOff) ProtoReflect() protoreflect.Message

func (*Retry_Conf_BackOff) Reset 

func (x *Retry_Conf_BackOff) Reset()

func (*Retry_Conf_BackOff) String 

func (x *Retry_Conf_BackOff) String() string

type Retry_Conf_Grpc 

type Retry_Conf_Grpc struct {

	//  +optional
	RetryOn []Retry_Conf_Grpc_RetryOn `` /* 138-byte string literal not displayed */
	//  +optional
	NumRetries *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=num_retries,json=numRetries,proto3" json:"num_retries,omitempty"`
	//  +optional
	PerTryTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=per_try_timeout,json=perTryTimeout,proto3" json:"per_try_timeout,omitempty"`
	//  +optional
	BackOff *Retry_Conf_BackOff `protobuf:"bytes,4,opt,name=back_off,json=backOff,proto3" json:"back_off,omitempty"`
	// contains filtered or unexported fields
}

func (*Retry_Conf_Grpc) Descriptor deprecated 

func (*Retry_Conf_Grpc) Descriptor() ([]byte, []int)

Deprecated: Use Retry_Conf_Grpc.ProtoReflect.Descriptor instead.

func (*Retry_Conf_Grpc) GetBackOff 

func (x *Retry_Conf_Grpc) GetBackOff() *Retry_Conf_BackOff

func (*Retry_Conf_Grpc) GetNumRetries 

func (x *Retry_Conf_Grpc) GetNumRetries() *wrapperspb.UInt32Value

func (*Retry_Conf_Grpc) GetPerTryTimeout 

func (x *Retry_Conf_Grpc) GetPerTryTimeout() *durationpb.Duration

func (*Retry_Conf_Grpc) GetRetryOn 

func (x *Retry_Conf_Grpc) GetRetryOn() []Retry_Conf_Grpc_RetryOn

func (*Retry_Conf_Grpc) ProtoMessage 

func (*Retry_Conf_Grpc) ProtoMessage()

func (*Retry_Conf_Grpc) ProtoReflect 

func (x *Retry_Conf_Grpc) ProtoReflect() protoreflect.Message

func (*Retry_Conf_Grpc) Reset 

func (x *Retry_Conf_Grpc) Reset()

func (*Retry_Conf_Grpc) String 

func (x *Retry_Conf_Grpc) String() string

type Retry_Conf_Grpc_RetryOn 

type Retry_Conf_Grpc_RetryOn int32
const (
	Retry_Conf_Grpc_cancelled          Retry_Conf_Grpc_RetryOn = 0
	Retry_Conf_Grpc_deadline_exceeded  Retry_Conf_Grpc_RetryOn = 1
	Retry_Conf_Grpc_internal           Retry_Conf_Grpc_RetryOn = 2
	Retry_Conf_Grpc_resource_exhausted Retry_Conf_Grpc_RetryOn = 3
	Retry_Conf_Grpc_unavailable        Retry_Conf_Grpc_RetryOn = 4
)

func (Retry_Conf_Grpc_RetryOn) Descriptor 

func (Retry_Conf_Grpc_RetryOn) Descriptor() protoreflect.EnumDescriptor

func (Retry_Conf_Grpc_RetryOn) Enum 

func (x Retry_Conf_Grpc_RetryOn) Enum() *Retry_Conf_Grpc_RetryOn

func (Retry_Conf_Grpc_RetryOn) EnumDescriptor deprecated 

func (Retry_Conf_Grpc_RetryOn) EnumDescriptor() ([]byte, []int)

Deprecated: Use Retry_Conf_Grpc_RetryOn.Descriptor instead.

func (Retry_Conf_Grpc_RetryOn) Number 

func (x Retry_Conf_Grpc_RetryOn) Number() protoreflect.EnumNumber

func (Retry_Conf_Grpc_RetryOn) String 

func (x Retry_Conf_Grpc_RetryOn) String() string

func (Retry_Conf_Grpc_RetryOn) Type 

func (Retry_Conf_Grpc_RetryOn) Type() protoreflect.EnumType

type Retry_Conf_Http 

type Retry_Conf_Http struct {

	//  +optional
	NumRetries *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=num_retries,json=numRetries,proto3" json:"num_retries,omitempty"`
	//  +optional
	PerTryTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=per_try_timeout,json=perTryTimeout,proto3" json:"per_try_timeout,omitempty"`
	//  +optional
	BackOff *Retry_Conf_BackOff `protobuf:"bytes,4,opt,name=back_off,json=backOff,proto3" json:"back_off,omitempty"`
	//  +optional
	RetriableStatusCodes []uint32 `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Retry_Conf_Http) Descriptor deprecated 

func (*Retry_Conf_Http) Descriptor() ([]byte, []int)

Deprecated: Use Retry_Conf_Http.ProtoReflect.Descriptor instead.

func (*Retry_Conf_Http) GetBackOff 

func (x *Retry_Conf_Http) GetBackOff() *Retry_Conf_BackOff

func (*Retry_Conf_Http) GetNumRetries 

func (x *Retry_Conf_Http) GetNumRetries() *wrapperspb.UInt32Value

func (*Retry_Conf_Http) GetPerTryTimeout 

func (x *Retry_Conf_Http) GetPerTryTimeout() *durationpb.Duration

func (*Retry_Conf_Http) GetRetriableStatusCodes 

func (x *Retry_Conf_Http) GetRetriableStatusCodes() []uint32

func (*Retry_Conf_Http) ProtoMessage 

func (*Retry_Conf_Http) ProtoMessage()

func (*Retry_Conf_Http) ProtoReflect 

func (x *Retry_Conf_Http) ProtoReflect() protoreflect.Message

func (*Retry_Conf_Http) Reset 

func (x *Retry_Conf_Http) Reset()

func (*Retry_Conf_Http) String 

func (x *Retry_Conf_Http) String() string

type Retry_Conf_Tcp 

type Retry_Conf_Tcp struct {

	//  +optional
	MaxConnectAttempts uint32 `protobuf:"varint,1,opt,name=max_connect_attempts,json=maxConnectAttempts,proto3" json:"max_connect_attempts,omitempty"`
	// contains filtered or unexported fields
}

func (*Retry_Conf_Tcp) Descriptor deprecated 

func (*Retry_Conf_Tcp) Descriptor() ([]byte, []int)

Deprecated: Use Retry_Conf_Tcp.ProtoReflect.Descriptor instead.

func (*Retry_Conf_Tcp) GetMaxConnectAttempts 

func (x *Retry_Conf_Tcp) GetMaxConnectAttempts() uint32

func (*Retry_Conf_Tcp) ProtoMessage 

func (*Retry_Conf_Tcp) ProtoMessage()

func (*Retry_Conf_Tcp) ProtoReflect 

func (x *Retry_Conf_Tcp) ProtoReflect() protoreflect.Message

func (*Retry_Conf_Tcp) Reset 

func (x *Retry_Conf_Tcp) Reset()

func (*Retry_Conf_Tcp) String 

func (x *Retry_Conf_Tcp) String() string

type Routing 

type Routing struct {

	// Enable the Locality Aware Load Balancing
	LocalityAwareLoadBalancing bool `protobuf:"varint,1,opt,name=localityAwareLoadBalancing,proto3" json:"localityAwareLoadBalancing,omitempty"`
	// contains filtered or unexported fields
}

Routing defines configuration for the routing in the mesh

func (*Routing) Descriptor deprecated 

func (*Routing) Descriptor() ([]byte, []int)

Deprecated: Use Routing.ProtoReflect.Descriptor instead.

func (*Routing) GetLocalityAwareLoadBalancing 

func (x *Routing) GetLocalityAwareLoadBalancing() bool

func (*Routing) ProtoMessage 

func (*Routing) ProtoMessage()

func (*Routing) ProtoReflect 

func (x *Routing) ProtoReflect() protoreflect.Message

func (*Routing) Reset 

func (x *Routing) Reset()

func (*Routing) String 

func (x *Routing) String() string

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 */
	// contains filtered or unexported fields
}

Selector defines structure for selecting tags for given dataplane

func (*Selector) Descriptor deprecated 

func (*Selector) Descriptor() ([]byte, []int)

Deprecated: Use Selector.ProtoReflect.Descriptor instead.

func (*Selector) GetMatch 

func (x *Selector) GetMatch() map[string]string

func (*Selector) ProtoMessage 

func (*Selector) ProtoMessage()

func (*Selector) ProtoReflect 

func (x *Selector) ProtoReflect() protoreflect.Message

func (*Selector) Reset 

func (x *Selector) Reset()

func (*Selector) String 

func (x *Selector) String() string

type ServiceInsight 

type ServiceInsight struct {
	LastSync *timestamppb.Timestamp             `protobuf:"bytes,1,opt,name=last_sync,json=lastSync,proto3" json:"last_sync,omitempty"`
	Services map[string]*ServiceInsight_Service `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ServiceInsight) Descriptor deprecated 

func (*ServiceInsight) Descriptor() ([]byte, []int)

Deprecated: Use ServiceInsight.ProtoReflect.Descriptor instead.

func (*ServiceInsight) GetLastSync 

func (x *ServiceInsight) GetLastSync() *timestamppb.Timestamp

func (*ServiceInsight) GetServices 

func (x *ServiceInsight) GetServices() map[string]*ServiceInsight_Service

func (*ServiceInsight) ProtoMessage 

func (*ServiceInsight) ProtoMessage()

func (*ServiceInsight) ProtoReflect 

func (x *ServiceInsight) ProtoReflect() protoreflect.Message

func (*ServiceInsight) Reset 

func (x *ServiceInsight) Reset()

func (*ServiceInsight) String 

func (x *ServiceInsight) String() string

type ServiceInsight_Service 

type ServiceInsight_Service struct {
	Status     ServiceInsight_Service_Status         `protobuf:"varint,1,opt,name=status,proto3,enum=kuma.mesh.v1alpha1.ServiceInsight_Service_Status" json:"status,omitempty"`
	Dataplanes *ServiceInsight_Service_DataplaneStat `protobuf:"bytes,2,opt,name=dataplanes,proto3" json:"dataplanes,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceInsight_Service) Descriptor deprecated 

func (*ServiceInsight_Service) Descriptor() ([]byte, []int)

Deprecated: Use ServiceInsight_Service.ProtoReflect.Descriptor instead.

func (*ServiceInsight_Service) GetDataplanes 

func (x *ServiceInsight_Service) GetDataplanes() *ServiceInsight_Service_DataplaneStat

func (*ServiceInsight_Service) GetStatus 

func (x *ServiceInsight_Service) GetStatus() ServiceInsight_Service_Status

func (*ServiceInsight_Service) ProtoMessage 

func (*ServiceInsight_Service) ProtoMessage()

func (*ServiceInsight_Service) ProtoReflect 

func (x *ServiceInsight_Service) ProtoReflect() protoreflect.Message

func (*ServiceInsight_Service) Reset 

func (x *ServiceInsight_Service) Reset()

func (*ServiceInsight_Service) String 

func (x *ServiceInsight_Service) String() string

type ServiceInsight_Service_DataplaneStat 

type ServiceInsight_Service_DataplaneStat struct {
	Total   uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Online  uint32 `protobuf:"varint,2,opt,name=online,proto3" json:"online,omitempty"`
	Offline uint32 `protobuf:"varint,3,opt,name=offline,proto3" json:"offline,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceInsight_Service_DataplaneStat) Descriptor deprecated 

func (*ServiceInsight_Service_DataplaneStat) Descriptor() ([]byte, []int)

Deprecated: Use ServiceInsight_Service_DataplaneStat.ProtoReflect.Descriptor instead.

func (*ServiceInsight_Service_DataplaneStat) GetOffline 

func (x *ServiceInsight_Service_DataplaneStat) GetOffline() uint32

func (*ServiceInsight_Service_DataplaneStat) GetOnline 

func (x *ServiceInsight_Service_DataplaneStat) GetOnline() uint32

func (*ServiceInsight_Service_DataplaneStat) GetTotal 

func (x *ServiceInsight_Service_DataplaneStat) GetTotal() uint32

func (*ServiceInsight_Service_DataplaneStat) ProtoMessage 

func (*ServiceInsight_Service_DataplaneStat) ProtoMessage()

func (*ServiceInsight_Service_DataplaneStat) ProtoReflect 

func (x *ServiceInsight_Service_DataplaneStat) ProtoReflect() protoreflect.Message

func (*ServiceInsight_Service_DataplaneStat) Reset 

func (x *ServiceInsight_Service_DataplaneStat) Reset()

func (*ServiceInsight_Service_DataplaneStat) String 

func (x *ServiceInsight_Service_DataplaneStat) String() string

type ServiceInsight_Service_Status 

type ServiceInsight_Service_Status int32
const (
	ServiceInsight_Service_none               ServiceInsight_Service_Status = 0 // should not be used
	ServiceInsight_Service_offline            ServiceInsight_Service_Status = 1
	ServiceInsight_Service_partially_degraded ServiceInsight_Service_Status = 2
	ServiceInsight_Service_online             ServiceInsight_Service_Status = 3
)

func (ServiceInsight_Service_Status) Descriptor 

func (ServiceInsight_Service_Status) Descriptor() protoreflect.EnumDescriptor

func (ServiceInsight_Service_Status) Enum 

func (x ServiceInsight_Service_Status) Enum() *ServiceInsight_Service_Status

func (ServiceInsight_Service_Status) EnumDescriptor deprecated 

func (ServiceInsight_Service_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use ServiceInsight_Service_Status.Descriptor instead.

func (ServiceInsight_Service_Status) Number 

func (x ServiceInsight_Service_Status) Number() protoreflect.EnumNumber

func (ServiceInsight_Service_Status) String 

func (x ServiceInsight_Service_Status) String() string

func (ServiceInsight_Service_Status) Type 

func (ServiceInsight_Service_Status) Type() protoreflect.EnumType

type SingleValueTagSet 

type SingleValueTagSet map[string]string

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

func (SingleValueTagSet) String 

func (t SingleValueTagSet) String() string

type SortedSplit 

type SortedSplit []*TrafficRoute_Split

func (SortedSplit) Len 

func (s SortedSplit) Len() int

func (SortedSplit) Less 

func (s SortedSplit) Less(i, j int) bool

func (SortedSplit) Swap 

func (s SortedSplit) Swap(i, j int)

type TagSelector 

type TagSelector map[string]string

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) Matches 

func (s TagSelector) Matches(tags map[string]string) 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"`
	// contains filtered or unexported fields
}

TcpLoggingBackendConfig defines configuration for TCP based access logs

func (*TcpLoggingBackendConfig) Descriptor deprecated 

func (*TcpLoggingBackendConfig) Descriptor() ([]byte, []int)

Deprecated: Use TcpLoggingBackendConfig.ProtoReflect.Descriptor instead.

func (*TcpLoggingBackendConfig) GetAddress 

func (x *TcpLoggingBackendConfig) GetAddress() string

func (*TcpLoggingBackendConfig) ProtoMessage 

func (*TcpLoggingBackendConfig) ProtoMessage()

func (*TcpLoggingBackendConfig) ProtoReflect 

func (x *TcpLoggingBackendConfig) ProtoReflect() protoreflect.Message

func (*TcpLoggingBackendConfig) Reset 

func (x *TcpLoggingBackendConfig) Reset()

func (*TcpLoggingBackendConfig) String 

func (x *TcpLoggingBackendConfig) String() string

type Timeout 

type Timeout 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         *Timeout_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

func (*Timeout) Descriptor deprecated 

func (*Timeout) Descriptor() ([]byte, []int)

Deprecated: Use Timeout.ProtoReflect.Descriptor instead.

func (*Timeout) GetConf 

func (x *Timeout) GetConf() *Timeout_Conf

func (*Timeout) GetDestinations 

func (x *Timeout) GetDestinations() []*Selector

func (*Timeout) GetSources 

func (x *Timeout) GetSources() []*Selector

func (*Timeout) ProtoMessage 

func (*Timeout) ProtoMessage()

func (*Timeout) ProtoReflect 

func (x *Timeout) ProtoReflect() protoreflect.Message

func (*Timeout) Reset 

func (x *Timeout) Reset()

func (*Timeout) String 

func (x *Timeout) String() string

type Timeout_Conf 

type Timeout_Conf struct {

	// ConnectTimeout defines time to establish connection
	ConnectTimeout *durationpb.Duration `protobuf:"bytes,1,opt,name=connect_timeout,json=connectTimeout,proto3" json:"connect_timeout,omitempty"`
	Tcp            *Timeout_Conf_Tcp    `protobuf:"bytes,2,opt,name=tcp,proto3" json:"tcp,omitempty"`
	Http           *Timeout_Conf_Http   `protobuf:"bytes,3,opt,name=http,proto3" json:"http,omitempty"`
	Grpc           *Timeout_Conf_Grpc   `protobuf:"bytes,4,opt,name=grpc,proto3" json:"grpc,omitempty"`
	// contains filtered or unexported fields
}

func (*Timeout_Conf) Descriptor deprecated 

func (*Timeout_Conf) Descriptor() ([]byte, []int)

Deprecated: Use Timeout_Conf.ProtoReflect.Descriptor instead.

func (*Timeout_Conf) GetConnectTimeout 

func (x *Timeout_Conf) GetConnectTimeout() *durationpb.Duration

func (*Timeout_Conf) GetConnectTimeoutOrDefault 

func (x *Timeout_Conf) GetConnectTimeoutOrDefault(defaultConnectTimeout time.Duration) time.Duration

func (*Timeout_Conf) GetGrpc 

func (x *Timeout_Conf) GetGrpc() *Timeout_Conf_Grpc

func (*Timeout_Conf) GetHttp 

func (x *Timeout_Conf) GetHttp() *Timeout_Conf_Http

func (*Timeout_Conf) GetTcp 

func (x *Timeout_Conf) GetTcp() *Timeout_Conf_Tcp

func (*Timeout_Conf) ProtoMessage 

func (*Timeout_Conf) ProtoMessage()

func (*Timeout_Conf) ProtoReflect 

func (x *Timeout_Conf) ProtoReflect() protoreflect.Message

func (*Timeout_Conf) Reset 

func (x *Timeout_Conf) Reset()

func (*Timeout_Conf) String 

func (x *Timeout_Conf) String() string

type Timeout_Conf_Grpc 

type Timeout_Conf_Grpc struct {

	// StreamIdleTimeout is the amount of time that the connection manager
	// will allow a stream to exist with no upstream or downstream activity
	StreamIdleTimeout *durationpb.Duration `protobuf:"bytes,1,opt,name=stream_idle_timeout,json=streamIdleTimeout,proto3" json:"stream_idle_timeout,omitempty"`
	// MaxStreamDuration is the maximum time that a stream’s lifetime will
	// span
	MaxStreamDuration *durationpb.Duration `protobuf:"bytes,2,opt,name=max_stream_duration,json=maxStreamDuration,proto3" json:"max_stream_duration,omitempty"`
	// contains filtered or unexported fields
}

Grpc defines timeouts that are applied when the protocol is GRPC

func (*Timeout_Conf_Grpc) Descriptor deprecated 

func (*Timeout_Conf_Grpc) Descriptor() ([]byte, []int)

Deprecated: Use Timeout_Conf_Grpc.ProtoReflect.Descriptor instead.

func (*Timeout_Conf_Grpc) GetMaxStreamDuration 

func (x *Timeout_Conf_Grpc) GetMaxStreamDuration() *durationpb.Duration

func (*Timeout_Conf_Grpc) GetStreamIdleTimeout 

func (x *Timeout_Conf_Grpc) GetStreamIdleTimeout() *durationpb.Duration

func (*Timeout_Conf_Grpc) ProtoMessage 

func (*Timeout_Conf_Grpc) ProtoMessage()

func (*Timeout_Conf_Grpc) ProtoReflect 

func (x *Timeout_Conf_Grpc) ProtoReflect() protoreflect.Message

func (*Timeout_Conf_Grpc) Reset 

func (x *Timeout_Conf_Grpc) Reset()

func (*Timeout_Conf_Grpc) String 

func (x *Timeout_Conf_Grpc) String() string

type Timeout_Conf_Http 

type Timeout_Conf_Http struct {

	// RequestTimeout is a span between the point at which the entire
	// downstream request (i.e. end-of-stream) has been processed and when the
	// upstream response has been completely processed
	RequestTimeout *durationpb.Duration `protobuf:"bytes,1,opt,name=request_timeout,json=requestTimeout,proto3" json:"request_timeout,omitempty"`
	// IdleTimeout is the time at which a downstream or upstream connection
	// will be terminated if there are no active streams
	IdleTimeout *durationpb.Duration `protobuf:"bytes,2,opt,name=idle_timeout,json=idleTimeout,proto3" json:"idle_timeout,omitempty"`
	// contains filtered or unexported fields
}

Http defines timeouts that are applied when the protocol is HTTP

func (*Timeout_Conf_Http) Descriptor deprecated 

func (*Timeout_Conf_Http) Descriptor() ([]byte, []int)

Deprecated: Use Timeout_Conf_Http.ProtoReflect.Descriptor instead.

func (*Timeout_Conf_Http) GetIdleTimeout 

func (x *Timeout_Conf_Http) GetIdleTimeout() *durationpb.Duration

func (*Timeout_Conf_Http) GetRequestTimeout 

func (x *Timeout_Conf_Http) GetRequestTimeout() *durationpb.Duration

func (*Timeout_Conf_Http) ProtoMessage 

func (*Timeout_Conf_Http) ProtoMessage()

func (*Timeout_Conf_Http) ProtoReflect 

func (x *Timeout_Conf_Http) ProtoReflect() protoreflect.Message

func (*Timeout_Conf_Http) Reset 

func (x *Timeout_Conf_Http) Reset()

func (*Timeout_Conf_Http) String 

func (x *Timeout_Conf_Http) String() string

type Timeout_Conf_Tcp 

type Timeout_Conf_Tcp struct {

	// IdleTimeout is defined as the period in which there are no bytes sent
	// or received on either the upstream or downstream connection
	IdleTimeout *durationpb.Duration `protobuf:"bytes,1,opt,name=idle_timeout,json=idleTimeout,proto3" json:"idle_timeout,omitempty"`
	// contains filtered or unexported fields
}

Tcp defines timeouts that are applied when the protocol is TCP

func (*Timeout_Conf_Tcp) Descriptor deprecated 

func (*Timeout_Conf_Tcp) Descriptor() ([]byte, []int)

Deprecated: Use Timeout_Conf_Tcp.ProtoReflect.Descriptor instead.

func (*Timeout_Conf_Tcp) GetIdleTimeout 

func (x *Timeout_Conf_Tcp) GetIdleTimeout() *durationpb.Duration

func (*Timeout_Conf_Tcp) ProtoMessage 

func (*Timeout_Conf_Tcp) ProtoMessage()

func (*Timeout_Conf_Tcp) ProtoReflect 

func (x *Timeout_Conf_Tcp) ProtoReflect() protoreflect.Message

func (*Timeout_Conf_Tcp) Reset 

func (x *Timeout_Conf_Tcp) Reset()

func (*Timeout_Conf_Tcp) String 

func (x *Timeout_Conf_Tcp) String() string

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"`
	// contains filtered or unexported fields
}

Tracing defines tracing configuration of the mesh.

func (*Tracing) Descriptor deprecated 

func (*Tracing) Descriptor() ([]byte, []int)

Deprecated: Use Tracing.ProtoReflect.Descriptor instead.

func (*Tracing) GetBackends 

func (x *Tracing) GetBackends() []*TracingBackend

func (*Tracing) GetDefaultBackend 

func (x *Tracing) GetDefaultBackend() string

func (*Tracing) ProtoMessage 

func (*Tracing) ProtoMessage()

func (*Tracing) ProtoReflect 

func (x *Tracing) ProtoReflect() protoreflect.Message

func (*Tracing) Reset 

func (x *Tracing) Reset()

func (*Tracing) String 

func (x *Tracing) String() string

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 *wrapperspb.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 *structpb.Struct `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

TracingBackend defines tracing backend available to mesh. Backends can be used in TrafficTrace rules.

func (*TracingBackend) Descriptor deprecated 

func (*TracingBackend) Descriptor() ([]byte, []int)

Deprecated: Use TracingBackend.ProtoReflect.Descriptor instead.

func (*TracingBackend) GetConf 

func (x *TracingBackend) GetConf() *structpb.Struct

func (*TracingBackend) GetName 

func (x *TracingBackend) GetName() string

func (*TracingBackend) GetSampling 

func (x *TracingBackend) GetSampling() *wrapperspb.DoubleValue

func (*TracingBackend) GetType 

func (x *TracingBackend) GetType() string

func (*TracingBackend) ProtoMessage 

func (*TracingBackend) ProtoMessage()

func (*TracingBackend) ProtoReflect 

func (x *TracingBackend) ProtoReflect() protoreflect.Message

func (*TracingBackend) Reset 

func (x *TracingBackend) Reset()

func (*TracingBackend) String 

func (x *TracingBackend) String() string

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"`
	// contains filtered or unexported fields
}

TrafficLog defines log for traffic between dataplanes.

func (*TrafficLog) Descriptor deprecated 

func (*TrafficLog) Descriptor() ([]byte, []int)

Deprecated: Use TrafficLog.ProtoReflect.Descriptor instead.

func (*TrafficLog) GetConf 

func (x *TrafficLog) GetConf() *TrafficLog_Conf

func (*TrafficLog) GetDestinations 

func (x *TrafficLog) GetDestinations() []*Selector

func (*TrafficLog) GetSources 

func (x *TrafficLog) GetSources() []*Selector

func (*TrafficLog) ProtoMessage 

func (*TrafficLog) ProtoMessage()

func (*TrafficLog) ProtoReflect 

func (x *TrafficLog) ProtoReflect() protoreflect.Message

func (*TrafficLog) Reset 

func (x *TrafficLog) Reset()

func (*TrafficLog) String 

func (x *TrafficLog) String() string

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"`
	// contains filtered or unexported fields
}

Configuration defines settings of the logging.

func (*TrafficLog_Conf) Descriptor deprecated 

func (*TrafficLog_Conf) Descriptor() ([]byte, []int)

Deprecated: Use TrafficLog_Conf.ProtoReflect.Descriptor instead.

func (*TrafficLog_Conf) GetBackend 

func (x *TrafficLog_Conf) GetBackend() string

func (*TrafficLog_Conf) ProtoMessage 

func (*TrafficLog_Conf) ProtoMessage()

func (*TrafficLog_Conf) ProtoReflect 

func (x *TrafficLog_Conf) ProtoReflect() protoreflect.Message

func (*TrafficLog_Conf) Reset 

func (x *TrafficLog_Conf) Reset()

func (*TrafficLog_Conf) String 

func (x *TrafficLog_Conf) String() string

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"`
	// contains filtered or unexported fields
}

TrafficPermission defines permission for traffic between dataplanes.

func (*TrafficPermission) Descriptor deprecated 

func (*TrafficPermission) Descriptor() ([]byte, []int)

Deprecated: Use TrafficPermission.ProtoReflect.Descriptor instead.

func (*TrafficPermission) GetDestinations 

func (x *TrafficPermission) GetDestinations() []*Selector

func (*TrafficPermission) GetSources 

func (x *TrafficPermission) GetSources() []*Selector

func (*TrafficPermission) ProtoMessage 

func (*TrafficPermission) ProtoMessage()

func (*TrafficPermission) ProtoReflect 

func (x *TrafficPermission) ProtoReflect() protoreflect.Message

func (*TrafficPermission) Reset 

func (x *TrafficPermission) Reset()

func (*TrafficPermission) String 

func (x *TrafficPermission) String() string

type TrafficRoute 

type TrafficRoute struct {

	// List of selectors to match data plane proxies 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 data plane proxy 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"`
	// Configuration for the route.
	Conf *TrafficRoute_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

TrafficRoute defines routing rules for the traffic in the mesh.

func (*TrafficRoute) Descriptor deprecated 

func (*TrafficRoute) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute.ProtoReflect.Descriptor instead.

func (*TrafficRoute) GetConf 

func (x *TrafficRoute) GetConf() *TrafficRoute_Conf

func (*TrafficRoute) GetDestinations 

func (x *TrafficRoute) GetDestinations() []*Selector

func (*TrafficRoute) GetSources 

func (x *TrafficRoute) GetSources() []*Selector

func (*TrafficRoute) ProtoMessage 

func (*TrafficRoute) ProtoMessage()

func (*TrafficRoute) ProtoReflect 

func (x *TrafficRoute) ProtoReflect() protoreflect.Message

func (*TrafficRoute) Reset 

func (x *TrafficRoute) Reset()

func (*TrafficRoute) String 

func (x *TrafficRoute) String() string

type TrafficRoute_Conf 

type TrafficRoute_Conf struct {

	// List of destinations with weights assigned to them.
	// When used, "destination" is not allowed.
	Split []*TrafficRoute_Split `protobuf:"bytes,1,rep,name=split,proto3" json:"split,omitempty"`
	// Load balancer configuration for given "split" or "destination"
	LoadBalancer *TrafficRoute_LoadBalancer `protobuf:"bytes,2,opt,name=load_balancer,json=loadBalancer,proto3" json:"load_balancer,omitempty"`
	// One destination that the traffic will be redirected to.
	// When used, "split" is not allowed.
	Destination map[string]string `` /* 163-byte string literal not displayed */
	// Configuration of HTTP traffic. Traffic is matched one by one with the
	// order defined in the list. If the request does not match any criteria
	// then "split" or "destination" outside of "http" section is executed.
	Http []*TrafficRoute_Http `protobuf:"bytes,4,rep,name=http,proto3" json:"http,omitempty"`
	// contains filtered or unexported fields
}

Conf defines the destination configuration.

func (*TrafficRoute_Conf) Descriptor deprecated 

func (*TrafficRoute_Conf) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_Conf.ProtoReflect.Descriptor instead.

func (*TrafficRoute_Conf) GetDestination 

func (x *TrafficRoute_Conf) GetDestination() map[string]string

func (*TrafficRoute_Conf) GetHttp 

func (x *TrafficRoute_Conf) GetHttp() []*TrafficRoute_Http

func (*TrafficRoute_Conf) GetLoadBalancer 

func (x *TrafficRoute_Conf) GetLoadBalancer() *TrafficRoute_LoadBalancer

func (*TrafficRoute_Conf) GetSplit 

func (x *TrafficRoute_Conf) GetSplit() []*TrafficRoute_Split

func (*TrafficRoute_Conf) GetSplitOrdered 

func (x *TrafficRoute_Conf) GetSplitOrdered() []*TrafficRoute_Split

func (*TrafficRoute_Conf) GetSplitWithDestination 

func (x *TrafficRoute_Conf) GetSplitWithDestination() []*TrafficRoute_Split

GetSplitWithDestination returns unified list of split regardless if split or destination is used Destination is a syntax sugar over single split with weight of 1.

func (*TrafficRoute_Conf) ProtoMessage 

func (*TrafficRoute_Conf) ProtoMessage()

func (*TrafficRoute_Conf) ProtoReflect 

func (x *TrafficRoute_Conf) ProtoReflect() protoreflect.Message

func (*TrafficRoute_Conf) Reset 

func (x *TrafficRoute_Conf) Reset()

func (*TrafficRoute_Conf) String 

func (x *TrafficRoute_Conf) String() string

type TrafficRoute_Http 

type TrafficRoute_Http struct {

	// If request matches against defined criteria then "split" or "destination"
	// is executed.
	Match *TrafficRoute_Http_Match `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// Modifications to the traffic matched by the match section.
	Modify *TrafficRoute_Http_Modify `protobuf:"bytes,2,opt,name=modify,proto3" json:"modify,omitempty"`
	// List of destinations with weights assigned to them.
	// When used, "destination" is not allowed.
	Split []*TrafficRoute_Split `protobuf:"bytes,3,rep,name=split,proto3" json:"split,omitempty"`
	// One destination that the traffic will be redirected to.
	// When used, "split" is not allowed.
	Destination map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

Http defines configuration for HTTP traffic.

func (*TrafficRoute_Http) Descriptor deprecated 

func (*TrafficRoute_Http) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_Http.ProtoReflect.Descriptor instead.

func (*TrafficRoute_Http) GetDestination 

func (x *TrafficRoute_Http) GetDestination() map[string]string

func (*TrafficRoute_Http) GetMatch 

func (x *TrafficRoute_Http) GetMatch() *TrafficRoute_Http_Match

func (*TrafficRoute_Http) GetModify 

func (x *TrafficRoute_Http) GetModify() *TrafficRoute_Http_Modify

func (*TrafficRoute_Http) GetSplit 

func (x *TrafficRoute_Http) GetSplit() []*TrafficRoute_Split

func (*TrafficRoute_Http) GetSplitWithDestination 

func (x *TrafficRoute_Http) GetSplitWithDestination() []*TrafficRoute_Split

func (*TrafficRoute_Http) ProtoMessage 

func (*TrafficRoute_Http) ProtoMessage()

func (*TrafficRoute_Http) ProtoReflect 

func (x *TrafficRoute_Http) ProtoReflect() protoreflect.Message

func (*TrafficRoute_Http) Reset 

func (x *TrafficRoute_Http) Reset()

func (*TrafficRoute_Http) String 

func (x *TrafficRoute_Http) String() string

type TrafficRoute_Http_Match 

type TrafficRoute_Http_Match struct {

	// Method matches method of HTTP request.
	Method *TrafficRoute_Http_Match_StringMatcher `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// Path matches HTTP path.
	Path *TrafficRoute_Http_Match_StringMatcher `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Headers match HTTP request headers.
	Headers map[string]*TrafficRoute_Http_Match_StringMatcher `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

Match defines a series of matching criteria to apply modification and reroute the traffic.

func (*TrafficRoute_Http_Match) Descriptor deprecated 

func (*TrafficRoute_Http_Match) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_Http_Match.ProtoReflect.Descriptor instead.

func (*TrafficRoute_Http_Match) GetHeaders 

func (x *TrafficRoute_Http_Match) GetHeaders() map[string]*TrafficRoute_Http_Match_StringMatcher

func (*TrafficRoute_Http_Match) GetMethod 

func (x *TrafficRoute_Http_Match) GetMethod() *TrafficRoute_Http_Match_StringMatcher

func (*TrafficRoute_Http_Match) GetPath 

func (x *TrafficRoute_Http_Match) GetPath() *TrafficRoute_Http_Match_StringMatcher

func (*TrafficRoute_Http_Match) ProtoMessage 

func (*TrafficRoute_Http_Match) ProtoMessage()

func (*TrafficRoute_Http_Match) ProtoReflect 

func (x *TrafficRoute_Http_Match) ProtoReflect() protoreflect.Message

func (*TrafficRoute_Http_Match) Reset 

func (x *TrafficRoute_Http_Match) Reset()

func (*TrafficRoute_Http_Match) String 

func (x *TrafficRoute_Http_Match) String() string

type TrafficRoute_Http_Match_StringMatcher 

type TrafficRoute_Http_Match_StringMatcher struct {

	// Types that are assignable to MatcherType:
	//	*TrafficRoute_Http_Match_StringMatcher_Prefix
	//	*TrafficRoute_Http_Match_StringMatcher_Exact
	//	*TrafficRoute_Http_Match_StringMatcher_Regex
	MatcherType isTrafficRoute_Http_Match_StringMatcher_MatcherType `protobuf_oneof:"matcherType"`
	// contains filtered or unexported fields
}

StringMatcher matches the string value.

func (*TrafficRoute_Http_Match_StringMatcher) Descriptor deprecated 

func (*TrafficRoute_Http_Match_StringMatcher) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_Http_Match_StringMatcher.ProtoReflect.Descriptor instead.

func (*TrafficRoute_Http_Match_StringMatcher) GetExact 

func (x *TrafficRoute_Http_Match_StringMatcher) GetExact() string

func (*TrafficRoute_Http_Match_StringMatcher) GetMatcherType 

func (m *TrafficRoute_Http_Match_StringMatcher) GetMatcherType() isTrafficRoute_Http_Match_StringMatcher_MatcherType

func (*TrafficRoute_Http_Match_StringMatcher) GetPrefix 

func (x *TrafficRoute_Http_Match_StringMatcher) GetPrefix() string

func (*TrafficRoute_Http_Match_StringMatcher) GetRegex 

func (x *TrafficRoute_Http_Match_StringMatcher) GetRegex() string

func (*TrafficRoute_Http_Match_StringMatcher) ProtoMessage 

func (*TrafficRoute_Http_Match_StringMatcher) ProtoMessage()

func (*TrafficRoute_Http_Match_StringMatcher) ProtoReflect 

func (x *TrafficRoute_Http_Match_StringMatcher) ProtoReflect() protoreflect.Message

func (*TrafficRoute_Http_Match_StringMatcher) Reset 

func (x *TrafficRoute_Http_Match_StringMatcher) Reset()

func (*TrafficRoute_Http_Match_StringMatcher) String 

func (x *TrafficRoute_Http_Match_StringMatcher) String() string

type TrafficRoute_Http_Match_StringMatcher_Exact 

type TrafficRoute_Http_Match_StringMatcher_Exact struct {
	// Exact checks that strings are equal to each other.
	Exact string `protobuf:"bytes,2,opt,name=exact,proto3,oneof"`
}

type TrafficRoute_Http_Match_StringMatcher_Prefix 

type TrafficRoute_Http_Match_StringMatcher_Prefix struct {
	// Prefix matches the string against defined prefix.
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3,oneof"`
}

type TrafficRoute_Http_Match_StringMatcher_Regex 

type TrafficRoute_Http_Match_StringMatcher_Regex struct {
	// Regex checks the string using RE2 syntax.
	// https://github.com/google/re2/wiki/Syntax
	Regex string `protobuf:"bytes,3,opt,name=regex,proto3,oneof"`
}

type TrafficRoute_Http_Modify 

type TrafficRoute_Http_Modify struct {

	// Path modifications.
	Path *TrafficRoute_Http_Modify_Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Host modifications.
	Host *TrafficRoute_Http_Modify_Host `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// Request headers modifications.
	RequestHeaders *TrafficRoute_Http_Modify_Headers `protobuf:"bytes,3,opt,name=requestHeaders,proto3" json:"requestHeaders,omitempty"`
	// Response headers modifications.
	ResponseHeaders *TrafficRoute_Http_Modify_Headers `protobuf:"bytes,4,opt,name=responseHeaders,proto3" json:"responseHeaders,omitempty"`
	// contains filtered or unexported fields
}

Modify defines modifications of matched HTTP messages.

func (*TrafficRoute_Http_Modify) Descriptor deprecated 

func (*TrafficRoute_Http_Modify) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_Http_Modify.ProtoReflect.Descriptor instead.

func (*TrafficRoute_Http_Modify) GetHost 

func (x *TrafficRoute_Http_Modify) GetHost() *TrafficRoute_Http_Modify_Host

func (*TrafficRoute_Http_Modify) GetPath 

func (x *TrafficRoute_Http_Modify) GetPath() *TrafficRoute_Http_Modify_Path

func (*TrafficRoute_Http_Modify) GetRequestHeaders 

func (x *TrafficRoute_Http_Modify) GetRequestHeaders() *TrafficRoute_Http_Modify_Headers

func (*TrafficRoute_Http_Modify) GetResponseHeaders 

func (x *TrafficRoute_Http_Modify) GetResponseHeaders() *TrafficRoute_Http_Modify_Headers

func (*TrafficRoute_Http_Modify) ProtoMessage 

func (*TrafficRoute_Http_Modify) ProtoMessage()

func (*TrafficRoute_Http_Modify) ProtoReflect 

func (x *TrafficRoute_Http_Modify) ProtoReflect() protoreflect.Message

func (*TrafficRoute_Http_Modify) Reset 

func (x *TrafficRoute_Http_Modify) Reset()

func (*TrafficRoute_Http_Modify) String 

func (x *TrafficRoute_Http_Modify) String() string

type TrafficRoute_Http_Modify_Headers 

type TrafficRoute_Http_Modify_Headers struct {

	// List of add header operations.
	Add []*TrafficRoute_Http_Modify_Headers_Add `protobuf:"bytes,1,rep,name=add,proto3" json:"add,omitempty"`
	// List of remove header operations.
	Remove []*TrafficRoute_Http_Modify_Headers_Remove `protobuf:"bytes,2,rep,name=remove,proto3" json:"remove,omitempty"`
	// contains filtered or unexported fields
}

Headers defines modification of HTTP headers.

func (*TrafficRoute_Http_Modify_Headers) Descriptor deprecated 

func (*TrafficRoute_Http_Modify_Headers) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_Http_Modify_Headers.ProtoReflect.Descriptor instead.

func (*TrafficRoute_Http_Modify_Headers) GetAdd 

func (x *TrafficRoute_Http_Modify_Headers) GetAdd() []*TrafficRoute_Http_Modify_Headers_Add

func (*TrafficRoute_Http_Modify_Headers) GetRemove 

func (x *TrafficRoute_Http_Modify_Headers) GetRemove() []*TrafficRoute_Http_Modify_Headers_Remove

func (*TrafficRoute_Http_Modify_Headers) ProtoMessage 

func (*TrafficRoute_Http_Modify_Headers) ProtoMessage()

func (*TrafficRoute_Http_Modify_Headers) ProtoReflect 

func (x *TrafficRoute_Http_Modify_Headers) ProtoReflect() protoreflect.Message

func (*TrafficRoute_Http_Modify_Headers) Reset 

func (x *TrafficRoute_Http_Modify_Headers) Reset()

func (*TrafficRoute_Http_Modify_Headers) String 

func (x *TrafficRoute_Http_Modify_Headers) String() string

type TrafficRoute_Http_Modify_Headers_Add 

type TrafficRoute_Http_Modify_Headers_Add struct {

	// Name of the header.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value of the header.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// If true, it appends the value if there is already a value.
	// Otherwise, value of existing header will be replaced.
	Append bool `protobuf:"varint,3,opt,name=append,proto3" json:"append,omitempty"`
	// contains filtered or unexported fields
}

Add defines operation of adding new HTTP header.

func (*TrafficRoute_Http_Modify_Headers_Add) Descriptor deprecated 

func (*TrafficRoute_Http_Modify_Headers_Add) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_Http_Modify_Headers_Add.ProtoReflect.Descriptor instead.

func (*TrafficRoute_Http_Modify_Headers_Add) GetAppend 

func (x *TrafficRoute_Http_Modify_Headers_Add) GetAppend() bool

func (*TrafficRoute_Http_Modify_Headers_Add) GetName 

func (x *TrafficRoute_Http_Modify_Headers_Add) GetName() string

func (*TrafficRoute_Http_Modify_Headers_Add) GetValue 

func (x *TrafficRoute_Http_Modify_Headers_Add) GetValue() string

func (*TrafficRoute_Http_Modify_Headers_Add) ProtoMessage 

func (*TrafficRoute_Http_Modify_Headers_Add) ProtoMessage()

func (*TrafficRoute_Http_Modify_Headers_Add) ProtoReflect 

func (x *TrafficRoute_Http_Modify_Headers_Add) ProtoReflect() protoreflect.Message

func (*TrafficRoute_Http_Modify_Headers_Add) Reset 

func (x *TrafficRoute_Http_Modify_Headers_Add) Reset()

func (*TrafficRoute_Http_Modify_Headers_Add) String 

func (x *TrafficRoute_Http_Modify_Headers_Add) String() string

type TrafficRoute_Http_Modify_Headers_Remove 

type TrafficRoute_Http_Modify_Headers_Remove struct {

	// Name of the header to remove.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Remove defines operation of removing an HTTP header.

func (*TrafficRoute_Http_Modify_Headers_Remove) Descriptor deprecated 

func (*TrafficRoute_Http_Modify_Headers_Remove) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_Http_Modify_Headers_Remove.ProtoReflect.Descriptor instead.

func (*TrafficRoute_Http_Modify_Headers_Remove) GetName 

func (x *TrafficRoute_Http_Modify_Headers_Remove) GetName() string

func (*TrafficRoute_Http_Modify_Headers_Remove) ProtoMessage 

func (*TrafficRoute_Http_Modify_Headers_Remove) ProtoMessage()

func (*TrafficRoute_Http_Modify_Headers_Remove) ProtoReflect 

func (x *TrafficRoute_Http_Modify_Headers_Remove) ProtoReflect() protoreflect.Message

func (*TrafficRoute_Http_Modify_Headers_Remove) Reset 

func (x *TrafficRoute_Http_Modify_Headers_Remove) Reset()

func (*TrafficRoute_Http_Modify_Headers_Remove) String 

func (x *TrafficRoute_Http_Modify_Headers_Remove) String() string

type TrafficRoute_Http_Modify_Host 

type TrafficRoute_Http_Modify_Host struct {

	// Types that are assignable to Type:
	//	*TrafficRoute_Http_Modify_Host_Value
	//	*TrafficRoute_Http_Modify_Host_FromPath
	Type isTrafficRoute_Http_Modify_Host_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

Host defines modification of the HTTP Host header

func (*TrafficRoute_Http_Modify_Host) Descriptor deprecated 

func (*TrafficRoute_Http_Modify_Host) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_Http_Modify_Host.ProtoReflect.Descriptor instead.

func (*TrafficRoute_Http_Modify_Host) GetFromPath 

func (x *TrafficRoute_Http_Modify_Host) GetFromPath() *TrafficRoute_Http_Modify_RegexReplace

func (*TrafficRoute_Http_Modify_Host) GetType 

func (m *TrafficRoute_Http_Modify_Host) GetType() isTrafficRoute_Http_Modify_Host_Type

func (*TrafficRoute_Http_Modify_Host) GetValue 

func (x *TrafficRoute_Http_Modify_Host) GetValue() string

func (*TrafficRoute_Http_Modify_Host) ProtoMessage 

func (*TrafficRoute_Http_Modify_Host) ProtoMessage()

func (*TrafficRoute_Http_Modify_Host) ProtoReflect 

func (x *TrafficRoute_Http_Modify_Host) ProtoReflect() protoreflect.Message

func (*TrafficRoute_Http_Modify_Host) Reset 

func (x *TrafficRoute_Http_Modify_Host) Reset()

func (*TrafficRoute_Http_Modify_Host) String 

func (x *TrafficRoute_Http_Modify_Host) String() string

type TrafficRoute_Http_Modify_Host_FromPath 

type TrafficRoute_Http_Modify_Host_FromPath struct {
	// FromPath replaces the host header from path using regex.
	FromPath *TrafficRoute_Http_Modify_RegexReplace `protobuf:"bytes,2,opt,name=fromPath,proto3,oneof"`
}

type TrafficRoute_Http_Modify_Host_Value 

type TrafficRoute_Http_Modify_Host_Value struct {
	// Value replaces the host header with given value.
	Value string `protobuf:"bytes,1,opt,name=value,proto3,oneof"`
}

type TrafficRoute_Http_Modify_Path 

type TrafficRoute_Http_Modify_Path struct {

	// Types that are assignable to Type:
	//	*TrafficRoute_Http_Modify_Path_RewritePrefix
	//	*TrafficRoute_Http_Modify_Path_Regex
	Type isTrafficRoute_Http_Modify_Path_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

Path defines modification of path of the HTTP request.

func (*TrafficRoute_Http_Modify_Path) Descriptor deprecated 

func (*TrafficRoute_Http_Modify_Path) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_Http_Modify_Path.ProtoReflect.Descriptor instead.

func (*TrafficRoute_Http_Modify_Path) GetRegex 

func (x *TrafficRoute_Http_Modify_Path) GetRegex() *TrafficRoute_Http_Modify_RegexReplace

func (*TrafficRoute_Http_Modify_Path) GetRewritePrefix 

func (x *TrafficRoute_Http_Modify_Path) GetRewritePrefix() string

func (*TrafficRoute_Http_Modify_Path) GetType 

func (m *TrafficRoute_Http_Modify_Path) GetType() isTrafficRoute_Http_Modify_Path_Type

func (*TrafficRoute_Http_Modify_Path) ProtoMessage 

func (*TrafficRoute_Http_Modify_Path) ProtoMessage()

func (*TrafficRoute_Http_Modify_Path) ProtoReflect 

func (x *TrafficRoute_Http_Modify_Path) ProtoReflect() protoreflect.Message

func (*TrafficRoute_Http_Modify_Path) Reset 

func (x *TrafficRoute_Http_Modify_Path) Reset()

func (*TrafficRoute_Http_Modify_Path) String 

func (x *TrafficRoute_Http_Modify_Path) String() string

type TrafficRoute_Http_Modify_Path_Regex 

type TrafficRoute_Http_Modify_Path_Regex struct {
	// Regex rewrites prefix using regex with substitution.
	Regex *TrafficRoute_Http_Modify_RegexReplace `protobuf:"bytes,2,opt,name=regex,proto3,oneof"`
}

type TrafficRoute_Http_Modify_Path_RewritePrefix 

type TrafficRoute_Http_Modify_Path_RewritePrefix struct {
	// RewritePrefix rewrites previously matched prefix in match section.
	RewritePrefix string `protobuf:"bytes,1,opt,name=rewritePrefix,proto3,oneof"`
}

type TrafficRoute_Http_Modify_RegexReplace 

type TrafficRoute_Http_Modify_RegexReplace struct {

	// Pattern of the regex using RE2 syntax.
	// https://github.com/google/re2/wiki/Syntax
	Pattern string `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"`
	// Substitution using regex groups. E.g. use \\1 as a first matched
	// group.
	Substitution string `protobuf:"bytes,2,opt,name=substitution,proto3" json:"substitution,omitempty"`
	// contains filtered or unexported fields
}

RegexReplace defines a way to match string using regex and build a new one using substitution section.

func (*TrafficRoute_Http_Modify_RegexReplace) Descriptor deprecated 

func (*TrafficRoute_Http_Modify_RegexReplace) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_Http_Modify_RegexReplace.ProtoReflect.Descriptor instead.

func (*TrafficRoute_Http_Modify_RegexReplace) GetPattern 

func (x *TrafficRoute_Http_Modify_RegexReplace) GetPattern() string

func (*TrafficRoute_Http_Modify_RegexReplace) GetSubstitution 

func (x *TrafficRoute_Http_Modify_RegexReplace) GetSubstitution() string

func (*TrafficRoute_Http_Modify_RegexReplace) ProtoMessage 

func (*TrafficRoute_Http_Modify_RegexReplace) ProtoMessage()

func (*TrafficRoute_Http_Modify_RegexReplace) ProtoReflect 

func (x *TrafficRoute_Http_Modify_RegexReplace) ProtoReflect() protoreflect.Message

func (*TrafficRoute_Http_Modify_RegexReplace) Reset 

func (x *TrafficRoute_Http_Modify_RegexReplace) Reset()

func (*TrafficRoute_Http_Modify_RegexReplace) String 

func (x *TrafficRoute_Http_Modify_RegexReplace) String() string

type TrafficRoute_LoadBalancer 

type TrafficRoute_LoadBalancer struct {

	// Types that are assignable to LbType:
	//	*TrafficRoute_LoadBalancer_RoundRobin_
	//	*TrafficRoute_LoadBalancer_LeastRequest_
	//	*TrafficRoute_LoadBalancer_RingHash_
	//	*TrafficRoute_LoadBalancer_Random_
	//	*TrafficRoute_LoadBalancer_Maglev_
	LbType isTrafficRoute_LoadBalancer_LbType `protobuf_oneof:"lb_type"`
	// contains filtered or unexported fields
}

LoadBalancer defines the load balancing policy and configuration.

func (*TrafficRoute_LoadBalancer) Descriptor deprecated 

func (*TrafficRoute_LoadBalancer) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_LoadBalancer.ProtoReflect.Descriptor instead.

func (*TrafficRoute_LoadBalancer) GetLbType 

func (m *TrafficRoute_LoadBalancer) GetLbType() isTrafficRoute_LoadBalancer_LbType

func (*TrafficRoute_LoadBalancer) GetLeastRequest 

func (x *TrafficRoute_LoadBalancer) GetLeastRequest() *TrafficRoute_LoadBalancer_LeastRequest

func (*TrafficRoute_LoadBalancer) GetMaglev 

func (x *TrafficRoute_LoadBalancer) GetMaglev() *TrafficRoute_LoadBalancer_Maglev

func (*TrafficRoute_LoadBalancer) GetRandom 

func (x *TrafficRoute_LoadBalancer) GetRandom() *TrafficRoute_LoadBalancer_Random

func (*TrafficRoute_LoadBalancer) GetRingHash 

func (x *TrafficRoute_LoadBalancer) GetRingHash() *TrafficRoute_LoadBalancer_RingHash

func (*TrafficRoute_LoadBalancer) GetRoundRobin 

func (x *TrafficRoute_LoadBalancer) GetRoundRobin() *TrafficRoute_LoadBalancer_RoundRobin

func (*TrafficRoute_LoadBalancer) ProtoMessage 

func (*TrafficRoute_LoadBalancer) ProtoMessage()

func (*TrafficRoute_LoadBalancer) ProtoReflect 

func (x *TrafficRoute_LoadBalancer) ProtoReflect() protoreflect.Message

func (*TrafficRoute_LoadBalancer) Reset 

func (x *TrafficRoute_LoadBalancer) Reset()

func (*TrafficRoute_LoadBalancer) String 

func (x *TrafficRoute_LoadBalancer) String() string

type TrafficRoute_LoadBalancer_LeastRequest 

type TrafficRoute_LoadBalancer_LeastRequest struct {

	// The number of random healthy hosts from which the host with the fewest
	// active requests will be chosen. Defaults to 2 so that we perform
	// two-choice selection if the field is not set.
	ChoiceCount uint32 `protobuf:"varint,1,opt,name=choice_count,json=choiceCount,proto3" json:"choice_count,omitempty"`
	// contains filtered or unexported fields
}

LeastRequest uses different algorithms depending on whether hosts have the same or different weights.

func (*TrafficRoute_LoadBalancer_LeastRequest) Descriptor deprecated 

func (*TrafficRoute_LoadBalancer_LeastRequest) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_LoadBalancer_LeastRequest.ProtoReflect.Descriptor instead.

func (*TrafficRoute_LoadBalancer_LeastRequest) GetChoiceCount 

func (x *TrafficRoute_LoadBalancer_LeastRequest) GetChoiceCount() uint32

func (*TrafficRoute_LoadBalancer_LeastRequest) ProtoMessage 

func (*TrafficRoute_LoadBalancer_LeastRequest) ProtoMessage()

func (*TrafficRoute_LoadBalancer_LeastRequest) ProtoReflect 

func (x *TrafficRoute_LoadBalancer_LeastRequest) ProtoReflect() protoreflect.Message

func (*TrafficRoute_LoadBalancer_LeastRequest) Reset 

func (x *TrafficRoute_LoadBalancer_LeastRequest) Reset()

func (*TrafficRoute_LoadBalancer_LeastRequest) String 

func (x *TrafficRoute_LoadBalancer_LeastRequest) String() string

type TrafficRoute_LoadBalancer_LeastRequest_ 

type TrafficRoute_LoadBalancer_LeastRequest_ struct {
	LeastRequest *TrafficRoute_LoadBalancer_LeastRequest `protobuf:"bytes,2,opt,name=least_request,json=leastRequest,proto3,oneof"`
}

type TrafficRoute_LoadBalancer_Maglev 

type TrafficRoute_LoadBalancer_Maglev struct {
	// contains filtered or unexported fields
}

Maglev implements consistent hashing to upstream hosts.

func (*TrafficRoute_LoadBalancer_Maglev) Descriptor deprecated 

func (*TrafficRoute_LoadBalancer_Maglev) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_LoadBalancer_Maglev.ProtoReflect.Descriptor instead.

func (*TrafficRoute_LoadBalancer_Maglev) ProtoMessage 

func (*TrafficRoute_LoadBalancer_Maglev) ProtoMessage()

func (*TrafficRoute_LoadBalancer_Maglev) ProtoReflect 

func (x *TrafficRoute_LoadBalancer_Maglev) ProtoReflect() protoreflect.Message

func (*TrafficRoute_LoadBalancer_Maglev) Reset 

func (x *TrafficRoute_LoadBalancer_Maglev) Reset()

func (*TrafficRoute_LoadBalancer_Maglev) String 

func (x *TrafficRoute_LoadBalancer_Maglev) String() string

type TrafficRoute_LoadBalancer_Maglev_ 

type TrafficRoute_LoadBalancer_Maglev_ struct {
	Maglev *TrafficRoute_LoadBalancer_Maglev `protobuf:"bytes,5,opt,name=maglev,proto3,oneof"`
}

type TrafficRoute_LoadBalancer_Random 

type TrafficRoute_LoadBalancer_Random struct {
	// contains filtered or unexported fields
}

Random selects a random available host.

func (*TrafficRoute_LoadBalancer_Random) Descriptor deprecated 

func (*TrafficRoute_LoadBalancer_Random) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_LoadBalancer_Random.ProtoReflect.Descriptor instead.

func (*TrafficRoute_LoadBalancer_Random) ProtoMessage 

func (*TrafficRoute_LoadBalancer_Random) ProtoMessage()

func (*TrafficRoute_LoadBalancer_Random) ProtoReflect 

func (x *TrafficRoute_LoadBalancer_Random) ProtoReflect() protoreflect.Message

func (*TrafficRoute_LoadBalancer_Random) Reset 

func (x *TrafficRoute_LoadBalancer_Random) Reset()

func (*TrafficRoute_LoadBalancer_Random) String 

func (x *TrafficRoute_LoadBalancer_Random) String() string

type TrafficRoute_LoadBalancer_Random_ 

type TrafficRoute_LoadBalancer_Random_ struct {
	Random *TrafficRoute_LoadBalancer_Random `protobuf:"bytes,4,opt,name=random,proto3,oneof"`
}

type TrafficRoute_LoadBalancer_RingHash 

type TrafficRoute_LoadBalancer_RingHash struct {

	// The hash function used to hash hosts onto the ketama ring. The value
	// defaults to 'XX_HASH'.
	HashFunction string `protobuf:"bytes,1,opt,name=hash_function,json=hashFunction,proto3" json:"hash_function,omitempty"`
	// Minimum hash ring size.
	MinRingSize uint64 `protobuf:"varint,2,opt,name=min_ring_size,json=minRingSize,proto3" json:"min_ring_size,omitempty"`
	// Maximum hash ring size.
	MaxRingSize uint64 `protobuf:"varint,3,opt,name=max_ring_size,json=maxRingSize,proto3" json:"max_ring_size,omitempty"`
	// contains filtered or unexported fields
}

RingHash implements consistent hashing to upstream hosts.

func (*TrafficRoute_LoadBalancer_RingHash) Descriptor deprecated 

func (*TrafficRoute_LoadBalancer_RingHash) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_LoadBalancer_RingHash.ProtoReflect.Descriptor instead.

func (*TrafficRoute_LoadBalancer_RingHash) GetHashFunction 

func (x *TrafficRoute_LoadBalancer_RingHash) GetHashFunction() string

func (*TrafficRoute_LoadBalancer_RingHash) GetMaxRingSize 

func (x *TrafficRoute_LoadBalancer_RingHash) GetMaxRingSize() uint64

func (*TrafficRoute_LoadBalancer_RingHash) GetMinRingSize 

func (x *TrafficRoute_LoadBalancer_RingHash) GetMinRingSize() uint64

func (*TrafficRoute_LoadBalancer_RingHash) ProtoMessage 

func (*TrafficRoute_LoadBalancer_RingHash) ProtoMessage()

func (*TrafficRoute_LoadBalancer_RingHash) ProtoReflect 

func (x *TrafficRoute_LoadBalancer_RingHash) ProtoReflect() protoreflect.Message

func (*TrafficRoute_LoadBalancer_RingHash) Reset 

func (x *TrafficRoute_LoadBalancer_RingHash) Reset()

func (*TrafficRoute_LoadBalancer_RingHash) String 

func (x *TrafficRoute_LoadBalancer_RingHash) String() string

type TrafficRoute_LoadBalancer_RingHash_ 

type TrafficRoute_LoadBalancer_RingHash_ struct {
	RingHash *TrafficRoute_LoadBalancer_RingHash `protobuf:"bytes,3,opt,name=ring_hash,json=ringHash,proto3,oneof"`
}

type TrafficRoute_LoadBalancer_RoundRobin 

type TrafficRoute_LoadBalancer_RoundRobin struct {
	// contains filtered or unexported fields
}

RoundRobin is a simple policy in which each available upstream host is selected in round robin order.

func (*TrafficRoute_LoadBalancer_RoundRobin) Descriptor deprecated 

func (*TrafficRoute_LoadBalancer_RoundRobin) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_LoadBalancer_RoundRobin.ProtoReflect.Descriptor instead.

func (*TrafficRoute_LoadBalancer_RoundRobin) ProtoMessage 

func (*TrafficRoute_LoadBalancer_RoundRobin) ProtoMessage()

func (*TrafficRoute_LoadBalancer_RoundRobin) ProtoReflect 

func (x *TrafficRoute_LoadBalancer_RoundRobin) ProtoReflect() protoreflect.Message

func (*TrafficRoute_LoadBalancer_RoundRobin) Reset 

func (x *TrafficRoute_LoadBalancer_RoundRobin) Reset()

func (*TrafficRoute_LoadBalancer_RoundRobin) String 

func (x *TrafficRoute_LoadBalancer_RoundRobin) String() string

type TrafficRoute_LoadBalancer_RoundRobin_ 

type TrafficRoute_LoadBalancer_RoundRobin_ struct {
	RoundRobin *TrafficRoute_LoadBalancer_RoundRobin `protobuf:"bytes,1,opt,name=round_robin,json=roundRobin,proto3,oneof"`
}

type TrafficRoute_Split 

type TrafficRoute_Split struct {

	// Weight assigned to that destination.
	// Weights are not percentages. For example two destinations with
	// weights the same weight "1" will receive both same amount of the traffic.
	// 0 means that the destination will be ignored.
	Weight *wrapperspb.UInt32Value `protobuf:"bytes,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 data plane proxy,
	// in the latter case an endpoint is an External Service.
	Destination map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

Split defines a destination with a weight assigned to it.

func (*TrafficRoute_Split) Descriptor deprecated 

func (*TrafficRoute_Split) Descriptor() ([]byte, []int)

Deprecated: Use TrafficRoute_Split.ProtoReflect.Descriptor instead.

func (*TrafficRoute_Split) GetDestination 

func (x *TrafficRoute_Split) GetDestination() map[string]string

func (*TrafficRoute_Split) GetWeight 

func (x *TrafficRoute_Split) GetWeight() *wrapperspb.UInt32Value

func (*TrafficRoute_Split) ProtoMessage 

func (*TrafficRoute_Split) ProtoMessage()

func (*TrafficRoute_Split) ProtoReflect 

func (x *TrafficRoute_Split) ProtoReflect() protoreflect.Message

func (*TrafficRoute_Split) Reset 

func (x *TrafficRoute_Split) Reset()

func (*TrafficRoute_Split) String 

func (x *TrafficRoute_Split) String() string

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"`
	// contains filtered or unexported fields
}

TrafficTrace defines trace configuration for selected dataplanes.

func (*TrafficTrace) Descriptor deprecated 

func (*TrafficTrace) Descriptor() ([]byte, []int)

Deprecated: Use TrafficTrace.ProtoReflect.Descriptor instead.

func (*TrafficTrace) GetConf 

func (x *TrafficTrace) GetConf() *TrafficTrace_Conf

func (*TrafficTrace) GetSelectors 

func (x *TrafficTrace) GetSelectors() []*Selector

func (*TrafficTrace) ProtoMessage 

func (*TrafficTrace) ProtoMessage()

func (*TrafficTrace) ProtoReflect 

func (x *TrafficTrace) ProtoReflect() protoreflect.Message

func (*TrafficTrace) Reset 

func (x *TrafficTrace) Reset()

func (*TrafficTrace) String 

func (x *TrafficTrace) String() string

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"`
	// contains filtered or unexported fields
}

Configuration defines settings of the tracing.

func (*TrafficTrace_Conf) Descriptor deprecated 

func (*TrafficTrace_Conf) Descriptor() ([]byte, []int)

Deprecated: Use TrafficTrace_Conf.ProtoReflect.Descriptor instead.

func (*TrafficTrace_Conf) GetBackend 

func (x *TrafficTrace_Conf) GetBackend() string

func (*TrafficTrace_Conf) ProtoMessage 

func (*TrafficTrace_Conf) ProtoMessage()

func (*TrafficTrace_Conf) ProtoReflect 

func (x *TrafficTrace_Conf) ProtoReflect() protoreflect.Message

func (*TrafficTrace_Conf) Reset 

func (x *TrafficTrace_Conf) Reset()

func (*TrafficTrace_Conf) String 

func (x *TrafficTrace_Conf) String() string

type UnimplementedKumaDiscoveryServiceServer 

type UnimplementedKumaDiscoveryServiceServer struct {
}

UnimplementedKumaDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedKumaDiscoveryServiceServer) DeltaKumaResources 

func (*UnimplementedKumaDiscoveryServiceServer) DeltaKumaResources(KumaDiscoveryService_DeltaKumaResourcesServer) error

func (*UnimplementedKumaDiscoveryServiceServer) FetchKumaResources 

func (*UnimplementedKumaDiscoveryServiceServer) FetchKumaResources(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

func (*UnimplementedKumaDiscoveryServiceServer) StreamKumaResources 

func (*UnimplementedKumaDiscoveryServiceServer) StreamKumaResources(KumaDiscoveryService_StreamKumaResourcesServer) error

type UnimplementedMultiplexServiceServer 

type UnimplementedMultiplexServiceServer struct {
}

UnimplementedMultiplexServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMultiplexServiceServer) StreamMessage 

func (*UnimplementedMultiplexServiceServer) StreamMessage(MultiplexService_StreamMessageServer) error

type Version 

type Version struct {

	// Version of Kuma Dataplane
	KumaDp *KumaDpVersion `protobuf:"bytes,1,opt,name=kumaDp,proto3" json:"kumaDp,omitempty"`
	// Version of Envoy
	Envoy *EnvoyVersion `protobuf:"bytes,2,opt,name=envoy,proto3" json:"envoy,omitempty"`
	// contains filtered or unexported fields
}

Version defines version of Kuma Dataplane and Envoy

func NewVersion 

func NewVersion() *Version

func (*Version) Descriptor deprecated 

func (*Version) Descriptor() ([]byte, []int)

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetEnvoy 

func (x *Version) GetEnvoy() *EnvoyVersion

func (*Version) GetKumaDp 

func (x *Version) GetKumaDp() *KumaDpVersion

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) ProtoReflect 

func (x *Version) ProtoReflect() protoreflect.Message

func (*Version) Reset 

func (x *Version) Reset()

func (*Version) String 

func (x *Version) String() string

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"`
	// Determines whether client and server spans will share the same span
	// context. Default: true.
	// https://www.envoyproxy.io/docs/envoy/latest/api-v3/config/trace/v3/zipkin.proto#config-trace-v3-zipkinconfig
	SharedSpanContext *wrapperspb.BoolValue `protobuf:"bytes,4,opt,name=sharedSpanContext,proto3" json:"sharedSpanContext,omitempty"`
	// contains filtered or unexported fields
}

func (*ZipkinTracingBackendConfig) Descriptor deprecated 

func (*ZipkinTracingBackendConfig) Descriptor() ([]byte, []int)

Deprecated: Use ZipkinTracingBackendConfig.ProtoReflect.Descriptor instead.

func (*ZipkinTracingBackendConfig) GetApiVersion 

func (x *ZipkinTracingBackendConfig) GetApiVersion() string

func (*ZipkinTracingBackendConfig) GetSharedSpanContext 

func (x *ZipkinTracingBackendConfig) GetSharedSpanContext() *wrapperspb.BoolValue

func (*ZipkinTracingBackendConfig) GetTraceId128Bit 

func (x *ZipkinTracingBackendConfig) GetTraceId128Bit() bool

func (*ZipkinTracingBackendConfig) GetUrl 

func (x *ZipkinTracingBackendConfig) GetUrl() string

func (*ZipkinTracingBackendConfig) ProtoMessage 

func (*ZipkinTracingBackendConfig) ProtoMessage()

func (*ZipkinTracingBackendConfig) ProtoReflect 

func (x *ZipkinTracingBackendConfig) ProtoReflect() protoreflect.Message

func (*ZipkinTracingBackendConfig) Reset 

func (x *ZipkinTracingBackendConfig) Reset()

func (*ZipkinTracingBackendConfig) String 

func (x *ZipkinTracingBackendConfig) String() string

type ZoneIngress 

type ZoneIngress struct {

	// Zone field contains Zone name where ingress is serving, field will be
	// automatically set by Global Kuma CP
	Zone string `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
	// Networking defines the address and port of the Ingress to listen on.
	// Additionally publicly advertised address and port could be specified.
	Networking *ZoneIngress_Networking `protobuf:"bytes,2,opt,name=networking,proto3" json:"networking,omitempty"`
	// AvailableService contains tags that represent unique subset of
	// endpoints
	AvailableServices []*ZoneIngress_AvailableService `protobuf:"bytes,3,rep,name=availableServices,proto3" json:"availableServices,omitempty"`
	// contains filtered or unexported fields
}

ZoneIngress allows us to configure dataplane in the Ingress mode. In this mode, dataplane has only inbound interfaces. Every inbound interface matches with services that reside in that cluster.

func (*ZoneIngress) Descriptor deprecated 

func (*ZoneIngress) Descriptor() ([]byte, []int)

Deprecated: Use ZoneIngress.ProtoReflect.Descriptor instead.

func (*ZoneIngress) GetAvailableServices 

func (x *ZoneIngress) GetAvailableServices() []*ZoneIngress_AvailableService

func (*ZoneIngress) GetNetworking 

func (x *ZoneIngress) GetNetworking() *ZoneIngress_Networking

func (*ZoneIngress) GetZone 

func (x *ZoneIngress) GetZone() string

func (*ZoneIngress) ProtoMessage 

func (*ZoneIngress) ProtoMessage()

func (*ZoneIngress) ProtoReflect 

func (x *ZoneIngress) ProtoReflect() protoreflect.Message

func (*ZoneIngress) Reset 

func (x *ZoneIngress) Reset()

func (*ZoneIngress) String 

func (x *ZoneIngress) String() string

type ZoneIngressInsight 

type ZoneIngressInsight struct {

	// List of ADS subscriptions created by a given Zone Kuma CP.
	Subscriptions []*DiscoverySubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

ZoneIngressInsight defines the observed state of a Zone Ingress.

func (*ZoneIngressInsight) Descriptor deprecated 

func (*ZoneIngressInsight) Descriptor() ([]byte, []int)

Deprecated: Use ZoneIngressInsight.ProtoReflect.Descriptor instead.

func (*ZoneIngressInsight) GetLatestSubscription 

func (x *ZoneIngressInsight) GetLatestSubscription() (*DiscoverySubscription, *time.Time)

func (*ZoneIngressInsight) GetSubscription 

func (x *ZoneIngressInsight) GetSubscription(id string) (int, *DiscoverySubscription)

func (*ZoneIngressInsight) GetSubscriptions 

func (x *ZoneIngressInsight) GetSubscriptions() []*DiscoverySubscription

func (*ZoneIngressInsight) IsOnline 

func (x *ZoneIngressInsight) IsOnline() bool

func (*ZoneIngressInsight) ProtoMessage 

func (*ZoneIngressInsight) ProtoMessage()

func (*ZoneIngressInsight) ProtoReflect 

func (x *ZoneIngressInsight) ProtoReflect() protoreflect.Message

func (*ZoneIngressInsight) Reset 

func (x *ZoneIngressInsight) Reset()

func (*ZoneIngressInsight) String 

func (x *ZoneIngressInsight) String() string

func (*ZoneIngressInsight) Sum 

func (x *ZoneIngressInsight) Sum(v func(*DiscoverySubscription) uint64) uint64

func (*ZoneIngressInsight) UpdateSubscription 

func (x *ZoneIngressInsight) UpdateSubscription(s *DiscoverySubscription)

type ZoneIngressOverview 

type ZoneIngressOverview struct {
	ZoneIngress        *ZoneIngress        `protobuf:"bytes,1,opt,name=zone_ingress,json=zoneIngress,proto3" json:"zone_ingress,omitempty"`
	ZoneIngressInsight *ZoneIngressInsight `protobuf:"bytes,2,opt,name=zone_ingress_insight,json=zoneIngressInsight,proto3" json:"zone_ingress_insight,omitempty"`
	// contains filtered or unexported fields
}

ZoneIngressOverview defines the projected state of a ZoneIngress.

func (*ZoneIngressOverview) Descriptor deprecated 

func (*ZoneIngressOverview) Descriptor() ([]byte, []int)

Deprecated: Use ZoneIngressOverview.ProtoReflect.Descriptor instead.

func (*ZoneIngressOverview) GetZoneIngress 

func (x *ZoneIngressOverview) GetZoneIngress() *ZoneIngress

func (*ZoneIngressOverview) GetZoneIngressInsight 

func (x *ZoneIngressOverview) GetZoneIngressInsight() *ZoneIngressInsight

func (*ZoneIngressOverview) ProtoMessage 

func (*ZoneIngressOverview) ProtoMessage()

func (*ZoneIngressOverview) ProtoReflect 

func (x *ZoneIngressOverview) ProtoReflect() protoreflect.Message

func (*ZoneIngressOverview) Reset 

func (x *ZoneIngressOverview) Reset()

func (*ZoneIngressOverview) String 

func (x *ZoneIngressOverview) String() string

type ZoneIngress_AvailableService 

type ZoneIngress_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"`
	// mesh of the instances available for given tags
	Mesh string `protobuf:"bytes,3,opt,name=mesh,proto3" json:"mesh,omitempty"`
	// contains filtered or unexported fields
}

func (*ZoneIngress_AvailableService) Descriptor deprecated 

func (*ZoneIngress_AvailableService) Descriptor() ([]byte, []int)

Deprecated: Use ZoneIngress_AvailableService.ProtoReflect.Descriptor instead.

func (*ZoneIngress_AvailableService) GetInstances 

func (x *ZoneIngress_AvailableService) GetInstances() uint32

func (*ZoneIngress_AvailableService) GetMesh 

func (x *ZoneIngress_AvailableService) GetMesh() string

func (*ZoneIngress_AvailableService) GetTags 

func (x *ZoneIngress_AvailableService) GetTags() map[string]string

func (*ZoneIngress_AvailableService) ProtoMessage 

func (*ZoneIngress_AvailableService) ProtoMessage()

func (*ZoneIngress_AvailableService) ProtoReflect 

func (x *ZoneIngress_AvailableService) ProtoReflect() protoreflect.Message

func (*ZoneIngress_AvailableService) Reset 

func (x *ZoneIngress_AvailableService) Reset()

func (*ZoneIngress_AvailableService) String 

func (x *ZoneIngress_AvailableService) String() string

type ZoneIngress_Networking 

type ZoneIngress_Networking struct {

	// Address on which inbound listener will be exposed
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// AdvertisedAddress defines IP or DNS name on which ZoneIngress is
	// accessible to other Kuma clusters.
	AdvertisedAddress string `protobuf:"bytes,2,opt,name=advertisedAddress,proto3" json:"advertisedAddress,omitempty"`
	// Port of the inbound interface that will forward requests to the service.
	Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// AdvertisedPort defines port on which ZoneIngress is accessible to other
	// Kuma clusters.
	AdvertisedPort uint32 `protobuf:"varint,4,opt,name=advertisedPort,proto3" json:"advertisedPort,omitempty"`
	// contains filtered or unexported fields
}

func (*ZoneIngress_Networking) Descriptor deprecated 

func (*ZoneIngress_Networking) Descriptor() ([]byte, []int)

Deprecated: Use ZoneIngress_Networking.ProtoReflect.Descriptor instead.

func (*ZoneIngress_Networking) GetAddress 

func (x *ZoneIngress_Networking) GetAddress() string

func (*ZoneIngress_Networking) GetAdvertisedAddress 

func (x *ZoneIngress_Networking) GetAdvertisedAddress() string

func (*ZoneIngress_Networking) GetAdvertisedPort 

func (x *ZoneIngress_Networking) GetAdvertisedPort() uint32

func (*ZoneIngress_Networking) GetPort 

func (x *ZoneIngress_Networking) GetPort() uint32

func (*ZoneIngress_Networking) ProtoMessage 

func (*ZoneIngress_Networking) ProtoMessage()

func (*ZoneIngress_Networking) ProtoReflect 

func (x *ZoneIngress_Networking) ProtoReflect() protoreflect.Message

func (*ZoneIngress_Networking) Reset 

func (x *ZoneIngress_Networking) Reset()

func (*ZoneIngress_Networking) String 

func (x *ZoneIngress_Networking) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.