v1alpha1

package
v1.5.0-rc2 Latest Latest
Warning

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

Go to latest
Published: Feb 18, 2022 License: Apache-2.0 Imports: 29 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
	ZoneTag = "kuma.io/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"

	// Listener tag is used to select Gateway listeners
	ListenerTag = "gateways.kuma.io/listener-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 = "*"
View Source
const ZoneEgressServiceName = "zone-egress"

Variables

View Source
var (
	Dataplane_Networking_Gateway_GatewayType_name = map[int32]string{
		0: "DELEGATED",
		1: "BUILTIN",
	}
	Dataplane_Networking_Gateway_GatewayType_value = map[string]int32{
		"DELEGATED": 0,
		"BUILTIN":   1,
	}
)

Enum value maps for Dataplane_Networking_Gateway_GatewayType.

View Source
var (
	MeshGateway_TLS_Mode_name = map[int32]string{
		0: "NONE",
		1: "TERMINATE",
		2: "PASSTHROUGH",
	}
	MeshGateway_TLS_Mode_value = map[string]int32{
		"NONE":        0,
		"TERMINATE":   1,
		"PASSTHROUGH": 2,
	}
)

Enum value maps for MeshGateway_TLS_Mode.

View Source
var (
	MeshGateway_Listener_Protocol_name = map[int32]string{
		0: "NONE",
		1: "TCP",
		2: "UDP",
		3: "TLS",
		4: "HTTP",
		5: "HTTPS",
	}
	MeshGateway_Listener_Protocol_value = map[string]int32{
		"NONE":  0,
		"TCP":   1,
		"UDP":   2,
		"TLS":   3,
		"HTTP":  4,
		"HTTPS": 5,
	}
)

Enum value maps for MeshGateway_Listener_Protocol.

View Source
var (
	MeshGatewayRoute_HttpRoute_Match_Path_MatchType_name = map[int32]string{
		0: "EXACT",
		1: "PREFIX",
		2: "REGEX",
	}
	MeshGatewayRoute_HttpRoute_Match_Path_MatchType_value = map[string]int32{
		"EXACT":  0,
		"PREFIX": 1,
		"REGEX":  2,
	}
)

Enum value maps for MeshGatewayRoute_HttpRoute_Match_Path_MatchType.

View Source
var (
	MeshGatewayRoute_HttpRoute_Match_Header_MatchType_name = map[int32]string{
		0: "EXACT",
		1: "REGEX",
	}
	MeshGatewayRoute_HttpRoute_Match_Header_MatchType_value = map[string]int32{
		"EXACT": 0,
		"REGEX": 1,
	}
)

Enum value maps for MeshGatewayRoute_HttpRoute_Match_Header_MatchType.

View Source
var (
	MeshGatewayRoute_HttpRoute_Match_Query_MatchType_name = map[int32]string{
		0: "EXACT",
		1: "REGEX",
	}
	MeshGatewayRoute_HttpRoute_Match_Query_MatchType_value = map[string]int32{
		"EXACT": 0,
		"REGEX": 1,
	}
)

Enum value maps for MeshGatewayRoute_HttpRoute_Match_Query_MatchType.

View Source
var (
	HttpMethod_name = map[int32]string{
		0: "NONE",
		1: "CONNECT",
		2: "DELETE",
		3: "GET",
		4: "HEAD",
		5: "OPTIONS",
		6: "PATCH",
		7: "POST",
		8: "PUT",
		9: "TRACE",
	}
	HttpMethod_value = map[string]int32{
		"NONE":    0,
		"CONNECT": 1,
		"DELETE":  2,
		"GET":     3,
		"HEAD":    4,
		"OPTIONS": 5,
		"PATCH":   6,
		"POST":    7,
		"PUT":     8,
		"TRACE":   9,
	}
)

Enum value maps for HttpMethod.

View Source
var (
	CertificateAuthorityBackend_Mode_name = map[int32]string{
		0: "STRICT",
		1: "PERMISSIVE",
	}
	CertificateAuthorityBackend_Mode_value = map[string]int32{
		"STRICT":     0,
		"PERMISSIVE": 1,
	}
)

Enum value maps for CertificateAuthorityBackend_Mode.

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_envoy_admin_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_gateway_proto protoreflect.FileDescriptor
View Source
var File_mesh_v1alpha1_gateway_route_proto protoreflect.FileDescriptor
View Source
var File_mesh_v1alpha1_health_check_proto protoreflect.FileDescriptor
View Source
var File_mesh_v1alpha1_http_method_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_virtual_outbound_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_zoneegress_proto protoreflect.FileDescriptor
View Source
var File_mesh_v1alpha1_zoneegressinsight_proto protoreflect.FileDescriptor
View Source
var File_mesh_v1alpha1_zoneegressoverview_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"`
	// Mode defines the behaviour of inbound listeners with regard to traffic
	// encryption
	Mode CertificateAuthorityBackend_Mode `protobuf:"varint,5,opt,name=mode,proto3,enum=kuma.mesh.v1alpha1.CertificateAuthorityBackend_Mode" json:"mode,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 (*CertificateAuthorityBackend) GetDpCert

func (*CertificateAuthorityBackend) GetMode

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 (*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 (*CertificateAuthorityBackend_DpCert) ProtoMessage

func (*CertificateAuthorityBackend_DpCert) ProtoMessage()

func (*CertificateAuthorityBackend_DpCert) ProtoReflect

func (*CertificateAuthorityBackend_DpCert) Reset

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

Deprecated: Use CertificateAuthorityBackend_DpCert_Rotation.ProtoReflect.Descriptor instead.

func (*CertificateAuthorityBackend_DpCert_Rotation) GetExpiration

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoReflect

func (*CertificateAuthorityBackend_DpCert_Rotation) Reset

func (*CertificateAuthorityBackend_DpCert_Rotation) String

type CertificateAuthorityBackend_Mode

type CertificateAuthorityBackend_Mode int32
const (
	// A STRICT mode implies that the server validates the connection and
	// accepts only encrypted TLS traffic
	CertificateAuthorityBackend_STRICT CertificateAuthorityBackend_Mode = 0
	// A PERMISSIVE mode implies that the outbounds encrypt traffic the same way
	// it happens in strict mode, but inbounds accept both TLS and plaintext
	// traffic. This allows applications residing in the mesh to accept requests
	// from outside of the mesh.
	CertificateAuthorityBackend_PERMISSIVE CertificateAuthorityBackend_Mode = 1
)

func (CertificateAuthorityBackend_Mode) Descriptor

func (CertificateAuthorityBackend_Mode) Enum

func (CertificateAuthorityBackend_Mode) EnumDescriptor deprecated

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

Deprecated: Use CertificateAuthorityBackend_Mode.Descriptor instead.

func (CertificateAuthorityBackend_Mode) Number

func (CertificateAuthorityBackend_Mode) String

func (CertificateAuthorityBackend_Mode) Type

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 (*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 (*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 (*CircuitBreaker_Conf_Detectors) GetGatewayErrors

func (*CircuitBreaker_Conf_Detectors) GetLocalErrors

func (*CircuitBreaker_Conf_Detectors) GetStandardDeviation

func (*CircuitBreaker_Conf_Detectors) GetTotalErrors

func (*CircuitBreaker_Conf_Detectors) ProtoMessage

func (*CircuitBreaker_Conf_Detectors) ProtoMessage()

func (*CircuitBreaker_Conf_Detectors) ProtoReflect

func (*CircuitBreaker_Conf_Detectors) Reset

func (x *CircuitBreaker_Conf_Detectors) Reset()

func (*CircuitBreaker_Conf_Detectors) 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 (*CircuitBreaker_Conf_Detectors_Errors) ProtoMessage

func (*CircuitBreaker_Conf_Detectors_Errors) ProtoMessage()

func (*CircuitBreaker_Conf_Detectors_Errors) ProtoReflect

func (*CircuitBreaker_Conf_Detectors_Errors) Reset

func (*CircuitBreaker_Conf_Detectors_Errors) 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 (*CircuitBreaker_Conf_Detectors_Failure) GetRequestVolume

func (*CircuitBreaker_Conf_Detectors_Failure) GetThreshold

func (*CircuitBreaker_Conf_Detectors_Failure) ProtoMessage

func (*CircuitBreaker_Conf_Detectors_Failure) ProtoMessage()

func (*CircuitBreaker_Conf_Detectors_Failure) ProtoReflect

func (*CircuitBreaker_Conf_Detectors_Failure) Reset

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

Deprecated: Use CircuitBreaker_Conf_Detectors_StandardDeviation.ProtoReflect.Descriptor instead.

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) GetFactor

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) GetMinimumHosts

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) GetRequestVolume

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) ProtoMessage

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) ProtoReflect

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) Reset

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) 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 (*CircuitBreaker_Conf_Thresholds) GetMaxRetries

func (*CircuitBreaker_Conf_Thresholds) ProtoMessage

func (*CircuitBreaker_Conf_Thresholds) ProtoMessage()

func (*CircuitBreaker_Conf_Thresholds) ProtoReflect

func (*CircuitBreaker_Conf_Thresholds) Reset

func (x *CircuitBreaker_Conf_Thresholds) Reset()

func (*CircuitBreaker_Conf_Thresholds) 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 (*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) IsBuiltinGateway

func (d *Dataplane) IsBuiltinGateway() bool

func (*Dataplane) IsDelegatedGateway

func (d *Dataplane) IsDelegatedGateway() 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) SingleValueTagSets

func (d *Dataplane) SingleValueTagSets() []SingleValueTagSet

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

func (x *DataplaneInsight) GetLastSubscription() generic.Subscription

func (*DataplaneInsight) GetMTLS

func (*DataplaneInsight) GetSubscription

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

func (*DataplaneInsight) GetSubscriptions

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

func (*DataplaneInsight) IsOnline

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

func (x *DataplaneInsight) UpdateCert(generation time.Time, expiration time.Time, issuedBackend string, supportedBackends []string) error

func (*DataplaneInsight) UpdateSubscription

func (x *DataplaneInsight) UpdateSubscription(s generic.Subscription) error

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 */
	// Backend that was used to generate current certificate
	IssuedBackend string `protobuf:"bytes,4,opt,name=issuedBackend,proto3" json:"issuedBackend,omitempty"`
	// Supported backends (CA).
	SupportedBackends []string `protobuf:"bytes,5,rep,name=supportedBackends,proto3" json:"supportedBackends,omitempty"`
	// 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) GetIssuedBackend

func (x *DataplaneInsight_MTLS) GetIssuedBackend() string

func (*DataplaneInsight_MTLS) GetLastCertificateRegeneration

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

func (*DataplaneInsight_MTLS) GetSupportedBackends

func (x *DataplaneInsight_MTLS) GetSupportedBackends() []string

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 {

	// 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"`
	// Admin contains configuration related to Envoy Admin API
	Admin *EnvoyAdmin `protobuf:"bytes,8,opt,name=admin,proto3" json:"admin,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) GetAdmin

func (x *Dataplane_Networking) GetAdmin() *EnvoyAdmin

func (*Dataplane_Networking) GetAdvertisedAddress

func (x *Dataplane_Networking) GetAdvertisedAddress() string

func (*Dataplane_Networking) GetGateway

func (*Dataplane_Networking) GetHealthyInbounds

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

func (*Dataplane_Networking) GetInbound

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

func (*Dataplane_Networking) GetOutboundInterfaces

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

func (*Dataplane_Networking) GetTransparentProxying

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 */
	// Type of gateway this dataplane manages. The default is a DELEGATED
	// gateway, which is an external proxy. The BUILTIN gateway type causes
	// the dataplane proxy itself to be configured as a gateway.
	Type Dataplane_Networking_Gateway_GatewayType `` /* 127-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) GetType

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 (*Dataplane_Networking_Gateway) Reset

func (x *Dataplane_Networking_Gateway) Reset()

func (*Dataplane_Networking_Gateway) String

type Dataplane_Networking_Gateway_GatewayType

type Dataplane_Networking_Gateway_GatewayType int32
const (
	// A DELEGATED gateway is a independently deployed proxy that
	// receives inbound traffic that is not proxied by Kuma, and
	// sends outbound traffic into the Kuma dataplane proxy.
	Dataplane_Networking_Gateway_DELEGATED Dataplane_Networking_Gateway_GatewayType = 0
	// The BUILTIN gateway type is experimental and unsupported.
	Dataplane_Networking_Gateway_BUILTIN Dataplane_Networking_Gateway_GatewayType = 1
)

func (Dataplane_Networking_Gateway_GatewayType) Descriptor

func (Dataplane_Networking_Gateway_GatewayType) Enum

func (Dataplane_Networking_Gateway_GatewayType) EnumDescriptor deprecated

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

Deprecated: Use Dataplane_Networking_Gateway_GatewayType.Descriptor instead.

func (Dataplane_Networking_Gateway_GatewayType) Number

func (Dataplane_Networking_Gateway_GatewayType) String

func (Dataplane_Networking_Gateway_GatewayType) Type

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 (*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 (*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 (*Dataplane_Networking_Inbound) Reset

func (x *Dataplane_Networking_Inbound) Reset()

func (*Dataplane_Networking_Inbound) 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 (*Dataplane_Networking_Inbound_Health) ProtoMessage

func (*Dataplane_Networking_Inbound_Health) ProtoMessage()

func (*Dataplane_Networking_Inbound_Health) ProtoReflect

func (*Dataplane_Networking_Inbound_Health) Reset

func (*Dataplane_Networking_Inbound_Health) 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 (*Dataplane_Networking_Inbound_ServiceProbe) GetInterval

func (*Dataplane_Networking_Inbound_ServiceProbe) GetTcp

func (*Dataplane_Networking_Inbound_ServiceProbe) GetTimeout

func (*Dataplane_Networking_Inbound_ServiceProbe) GetUnhealthyThreshold

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoMessage

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoReflect

func (*Dataplane_Networking_Inbound_ServiceProbe) Reset

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

Deprecated: Use Dataplane_Networking_Inbound_ServiceProbe_Tcp.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoMessage

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoReflect

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) Reset

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) 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 (*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 (*Dataplane_Networking_Outbound) Reset

func (x *Dataplane_Networking_Outbound) Reset()

func (*Dataplane_Networking_Outbound) 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 */
	// List of reachable services (represented by the value of
	// kuma.io/service) via transparent proxying. Setting an explicit list can
	// dramatically improve the performance of the mesh. If not specified, all
	// services in the mesh are reachable.
	ReachableServices []string `protobuf:"bytes,5,rep,name=reachable_services,json=reachableServices,proto3" json:"reachable_services,omitempty"`
	// 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) GetReachableServices

func (x *Dataplane_Networking_TransparentProxying) GetReachableServices() []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) ProtoReflect

func (*Dataplane_Networking_TransparentProxying) Reset

func (*Dataplane_Networking_TransparentProxying) 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 (*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"`
	// Generation is an integer number which is periodically increased by the
	// status sink
	Generation uint32 `protobuf:"varint,7,opt,name=generation,proto3" json:"generation,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) GetGeneration

func (x *DiscoverySubscription) GetGeneration() uint32

func (*DiscoverySubscription) GetId

func (x *DiscoverySubscription) GetId() string

func (*DiscoverySubscription) GetStatus

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

func (x *DiscoverySubscription) SetDisconnectTime(t time.Time)

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 (*DiscoverySubscriptionStatus) GetEds

func (*DiscoverySubscriptionStatus) GetLastUpdateTime

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

func (*DiscoverySubscriptionStatus) GetLds

func (*DiscoverySubscriptionStatus) GetRds

func (*DiscoverySubscriptionStatus) GetTotal

func (*DiscoverySubscriptionStatus) ProtoMessage

func (*DiscoverySubscriptionStatus) ProtoMessage()

func (*DiscoverySubscriptionStatus) ProtoReflect

func (*DiscoverySubscriptionStatus) Reset

func (x *DiscoverySubscriptionStatus) Reset()

func (*DiscoverySubscriptionStatus) StatsOf

func (*DiscoverySubscriptionStatus) String

func (x *DiscoverySubscriptionStatus) String() string

type EnvoyAdmin

type EnvoyAdmin struct {

	// Port on which Envoy Admin API server will be listening
	Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvoyAdmin) Descriptor deprecated

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

Deprecated: Use EnvoyAdmin.ProtoReflect.Descriptor instead.

func (*EnvoyAdmin) GetPort

func (x *EnvoyAdmin) GetPort() uint32

func (*EnvoyAdmin) ProtoMessage

func (*EnvoyAdmin) ProtoMessage()

func (*EnvoyAdmin) ProtoReflect

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

func (*EnvoyAdmin) Reset

func (x *EnvoyAdmin) Reset()

func (*EnvoyAdmin) String

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

func (x *EnvoyVersion) ParseVersion() (version, label 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 (*ExternalService_Networking) ProtoMessage

func (*ExternalService_Networking) ProtoMessage()

func (*ExternalService_Networking) ProtoReflect

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"`
	// ServerName overrides the default Server Name Indicator set by Kuma.
	// The default value is set to "address" specified in "networking".
	ServerName *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=server_name,json=serverName,proto3" json:"server_name,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 (*ExternalService_Networking_TLS) GetClientCert

func (*ExternalService_Networking_TLS) GetClientKey

func (*ExternalService_Networking_TLS) GetEnabled

func (x *ExternalService_Networking_TLS) GetEnabled() bool

func (*ExternalService_Networking_TLS) GetServerName

func (*ExternalService_Networking_TLS) ProtoMessage

func (*ExternalService_Networking_TLS) ProtoMessage()

func (*ExternalService_Networking_TLS) ProtoReflect

func (*ExternalService_Networking_TLS) Reset

func (x *ExternalService_Networking_TLS) Reset()

func (*ExternalService_Networking_TLS) 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 (*FaultInjection_Conf) GetDelay

func (*FaultInjection_Conf) GetResponseBandwidth

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 (*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 (*FaultInjection_Conf_Delay) ProtoMessage

func (*FaultInjection_Conf_Delay) ProtoMessage()

func (*FaultInjection_Conf_Delay) ProtoReflect

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 (*FaultInjection_Conf_ResponseBandwidth) GetPercentage

func (*FaultInjection_Conf_ResponseBandwidth) ProtoMessage

func (*FaultInjection_Conf_ResponseBandwidth) ProtoMessage()

func (*FaultInjection_Conf_ResponseBandwidth) ProtoReflect

func (*FaultInjection_Conf_ResponseBandwidth) Reset

func (*FaultInjection_Conf_ResponseBandwidth) 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) DeepCopy

func (t *HealthCheck) DeepCopy() *HealthCheck

func (*HealthCheck) DeepCopyInto

func (t *HealthCheck) DeepCopyInto(out *HealthCheck)

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

func (m *HealthCheck) MarshalJSON() ([]byte, error)

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

func (*HealthCheck) UnmarshalJSON

func (m *HealthCheck) UnmarshalJSON(data []byte) error

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 (*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 (*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 (*HealthCheck_Conf_Http_HeaderValue) GetValue

func (*HealthCheck_Conf_Http_HeaderValue) ProtoMessage

func (*HealthCheck_Conf_Http_HeaderValue) ProtoMessage()

func (*HealthCheck_Conf_Http_HeaderValue) ProtoReflect

func (*HealthCheck_Conf_Http_HeaderValue) Reset

func (*HealthCheck_Conf_Http_HeaderValue) 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 (*HealthCheck_Conf_Http_HeaderValueOption) GetHeader

func (*HealthCheck_Conf_Http_HeaderValueOption) ProtoMessage

func (*HealthCheck_Conf_Http_HeaderValueOption) ProtoReflect

func (*HealthCheck_Conf_Http_HeaderValueOption) Reset

func (*HealthCheck_Conf_Http_HeaderValueOption) 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 (*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 HttpMethod

type HttpMethod int32
const (
	HttpMethod_NONE    HttpMethod = 0
	HttpMethod_CONNECT HttpMethod = 1
	HttpMethod_DELETE  HttpMethod = 2
	HttpMethod_GET     HttpMethod = 3
	HttpMethod_HEAD    HttpMethod = 4
	HttpMethod_OPTIONS HttpMethod = 5
	HttpMethod_PATCH   HttpMethod = 6
	HttpMethod_POST    HttpMethod = 7
	HttpMethod_PUT     HttpMethod = 8
	HttpMethod_TRACE   HttpMethod = 9
)

func (HttpMethod) Descriptor

func (HttpMethod) Descriptor() protoreflect.EnumDescriptor

func (HttpMethod) Enum

func (x HttpMethod) Enum() *HttpMethod

func (HttpMethod) EnumDescriptor deprecated

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

Deprecated: Use HttpMethod.Descriptor instead.

func (HttpMethod) Number

func (x HttpMethod) Number() protoreflect.EnumNumber

func (HttpMethod) String

func (x HttpMethod) String() string

func (HttpMethod) Type

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

func (i InboundInterface) MarshalText() ([]byte, error)

func (InboundInterface) String

func (i InboundInterface) String() string

type KumaDiscoveryServiceClient

type KumaDiscoveryServiceClient interface {
	StreamKumaResources(ctx context.Context, opts ...grpc.CallOption) (KumaDiscoveryService_StreamKumaResourcesClient, 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.

type KumaDiscoveryServiceServer

type KumaDiscoveryServiceServer interface {
	StreamKumaResources(KumaDiscoveryService_StreamKumaResourcesServer) error
}

KumaDiscoveryServiceServer is the server API for KumaDiscoveryService service.

type KumaDiscoveryService_StreamKumaResourcesClient

type KumaDiscoveryService_StreamKumaResourcesClient interface {
	Send(*v3.DiscoveryRequest) error
	Recv() (*v3.DiscoveryResponse, error)
	grpc.ClientStream
}

type KumaDiscoveryService_StreamKumaResourcesServer

type KumaDiscoveryService_StreamKumaResourcesServer interface {
	Send(*v3.DiscoveryResponse) error
	Recv() (*v3.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"`
	// Constraints that applies to the mesh and its entities
	Constraints *Mesh_Constraints `protobuf:"bytes,7,opt,name=constraints,proto3" json:"constraints,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) GetConstraints

func (x *Mesh) GetConstraints() *Mesh_Constraints

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 MeshGateway

type MeshGateway struct {

	// Selectors is a list of selectors that are used to match builtin
	// gateway dataplanes that will receive this MeshGateway configuration.
	Selectors []*Selector `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// Tags is the set of tags common to all of the gateway's listeners.
	//
	// This field must not include a `kuma.io/service` tag (the service is always
	// defined on the dataplanes).
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// The desired configuration of the MeshGateway.
	Conf *MeshGateway_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

MeshGateway is a virtual proxy.

Each MeshGateway is bound to a set of builtin gateway dataplanes. Each builtin dataplane instance can host exactly one Gateway proxy configuration.

Gateway aligns with the Kubernetes Gateway API v1alpha2. See that spec for detailed documentation.

func (*MeshGateway) DeepCopy

func (t *MeshGateway) DeepCopy() *MeshGateway

func (*MeshGateway) DeepCopyInto

func (t *MeshGateway) DeepCopyInto(out *MeshGateway)

func (*MeshGateway) Descriptor deprecated

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

Deprecated: Use MeshGateway.ProtoReflect.Descriptor instead.

func (*MeshGateway) GetConf

func (x *MeshGateway) GetConf() *MeshGateway_Conf

func (*MeshGateway) GetSelectors

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

func (*MeshGateway) GetTags

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

func (*MeshGateway) MarshalJSON

func (m *MeshGateway) MarshalJSON() ([]byte, error)

func (*MeshGateway) ProtoMessage

func (*MeshGateway) ProtoMessage()

func (*MeshGateway) ProtoReflect

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

func (*MeshGateway) Reset

func (x *MeshGateway) Reset()

func (*MeshGateway) String

func (x *MeshGateway) String() string

func (*MeshGateway) UnmarshalJSON

func (m *MeshGateway) UnmarshalJSON(data []byte) error

type MeshGatewayRoute

type MeshGatewayRoute struct {

	// Selectors is used to match this resource to MeshGateway listener.
	Selectors []*Selector `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// Conf specifies the route configuration.
	Conf *MeshGatewayRoute_Conf `protobuf:"bytes,2,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

func (*MeshGatewayRoute) DeepCopy

func (t *MeshGatewayRoute) DeepCopy() *MeshGatewayRoute

func (*MeshGatewayRoute) DeepCopyInto

func (t *MeshGatewayRoute) DeepCopyInto(out *MeshGatewayRoute)

func (*MeshGatewayRoute) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute) GetConf

func (*MeshGatewayRoute) GetSelectors

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

func (*MeshGatewayRoute) MarshalJSON

func (m *MeshGatewayRoute) MarshalJSON() ([]byte, error)

func (*MeshGatewayRoute) ProtoMessage

func (*MeshGatewayRoute) ProtoMessage()

func (*MeshGatewayRoute) ProtoReflect

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

func (*MeshGatewayRoute) Reset

func (x *MeshGatewayRoute) Reset()

func (*MeshGatewayRoute) String

func (x *MeshGatewayRoute) String() string

func (*MeshGatewayRoute) UnmarshalJSON

func (m *MeshGatewayRoute) UnmarshalJSON(data []byte) error

type MeshGatewayRoute_Backend

type MeshGatewayRoute_Backend struct {

	// Weight is the proportion of requests this backend will receive
	// when a forwarding rules specifies multiple backends. Traffic
	// weight is computed as "weight/sum(all weights)".
	//
	// A weight of 0 means that the destination will be ignored.
	Weight uint32 `protobuf:"varint,1,opt,name=weight,proto3" json:"weight,omitempty"`
	// Destination is a selector to match the individual endpoints to
	// which the gateway will forward.
	Destination map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

Backend selects a target for HTTP request forwarding.

func (*MeshGatewayRoute_Backend) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_Backend.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_Backend) GetDestination

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

func (*MeshGatewayRoute_Backend) GetWeight

func (x *MeshGatewayRoute_Backend) GetWeight() uint32

func (*MeshGatewayRoute_Backend) ProtoMessage

func (*MeshGatewayRoute_Backend) ProtoMessage()

func (*MeshGatewayRoute_Backend) ProtoReflect

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

func (*MeshGatewayRoute_Backend) Reset

func (x *MeshGatewayRoute_Backend) Reset()

func (*MeshGatewayRoute_Backend) String

func (x *MeshGatewayRoute_Backend) String() string

type MeshGatewayRoute_Conf

type MeshGatewayRoute_Conf struct {

	// Each route resource may contain routing table entries for exactly one
	// protocol type.
	//
	// Types that are assignable to Route:
	//	*MeshGatewayRoute_Conf_Udp
	//	*MeshGatewayRoute_Conf_Tcp
	//	*MeshGatewayRoute_Conf_Tls
	//	*MeshGatewayRoute_Conf_Http
	Route isMeshGatewayRoute_Conf_Route `protobuf_oneof:"route"`
	// contains filtered or unexported fields
}

func (*MeshGatewayRoute_Conf) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_Conf.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_Conf) GetHttp

func (*MeshGatewayRoute_Conf) GetRoute

func (m *MeshGatewayRoute_Conf) GetRoute() isMeshGatewayRoute_Conf_Route

func (*MeshGatewayRoute_Conf) GetTcp

func (*MeshGatewayRoute_Conf) GetTls

func (*MeshGatewayRoute_Conf) GetUdp

func (*MeshGatewayRoute_Conf) ProtoMessage

func (*MeshGatewayRoute_Conf) ProtoMessage()

func (*MeshGatewayRoute_Conf) ProtoReflect

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

func (*MeshGatewayRoute_Conf) Reset

func (x *MeshGatewayRoute_Conf) Reset()

func (*MeshGatewayRoute_Conf) String

func (x *MeshGatewayRoute_Conf) String() string

type MeshGatewayRoute_Conf_Http

type MeshGatewayRoute_Conf_Http struct {
	Http *MeshGatewayRoute_HttpRoute `protobuf:"bytes,4,opt,name=http,proto3,oneof"`
}

type MeshGatewayRoute_Conf_Tcp

type MeshGatewayRoute_Conf_Tcp struct {
	Tcp *MeshGatewayRoute_TcpRoute `protobuf:"bytes,2,opt,name=tcp,proto3,oneof"`
}

type MeshGatewayRoute_Conf_Tls

type MeshGatewayRoute_Conf_Tls struct {
	Tls *MeshGatewayRoute_TlsRoute `protobuf:"bytes,3,opt,name=tls,proto3,oneof"`
}

type MeshGatewayRoute_Conf_Udp

type MeshGatewayRoute_Conf_Udp struct {
	Udp *MeshGatewayRoute_UdpRoute `protobuf:"bytes,1,opt,name=udp,proto3,oneof"`
}

type MeshGatewayRoute_HttpRoute

type MeshGatewayRoute_HttpRoute struct {

	// Hostnames lists the server names for which this route is valid. The
	// hostnames are matched against the TLS Server Name Indication extension
	// if this is a TLS session. They are also matched against the HTTP host
	// (authority) header in the client's HTTP request.
	Hostnames []string `protobuf:"bytes,1,rep,name=hostnames,proto3" json:"hostnames,omitempty"`
	// Rules specifies how the gateway should match and process HTTP requests.
	Rules []*MeshGatewayRoute_HttpRoute_Rule `protobuf:"bytes,2,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

HTTP routes are valid for listeners that accept HTTP/1.1 and HTTP/2 over both TCP and TLS.

func (*MeshGatewayRoute_HttpRoute) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_HttpRoute.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_HttpRoute) GetHostnames

func (x *MeshGatewayRoute_HttpRoute) GetHostnames() []string

func (*MeshGatewayRoute_HttpRoute) GetRules

func (*MeshGatewayRoute_HttpRoute) ProtoMessage

func (*MeshGatewayRoute_HttpRoute) ProtoMessage()

func (*MeshGatewayRoute_HttpRoute) ProtoReflect

func (*MeshGatewayRoute_HttpRoute) Reset

func (x *MeshGatewayRoute_HttpRoute) Reset()

func (*MeshGatewayRoute_HttpRoute) String

func (x *MeshGatewayRoute_HttpRoute) String() string

type MeshGatewayRoute_HttpRoute_Filter

type MeshGatewayRoute_HttpRoute_Filter struct {

	// Types that are assignable to Filter:
	//	*MeshGatewayRoute_HttpRoute_Filter_RequestHeader_
	//	*MeshGatewayRoute_HttpRoute_Filter_Mirror_
	//	*MeshGatewayRoute_HttpRoute_Filter_Redirect_
	Filter isMeshGatewayRoute_HttpRoute_Filter_Filter `protobuf_oneof:"filter"`
	// contains filtered or unexported fields
}

func (*MeshGatewayRoute_HttpRoute_Filter) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_HttpRoute_Filter.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_HttpRoute_Filter) GetFilter

func (m *MeshGatewayRoute_HttpRoute_Filter) GetFilter() isMeshGatewayRoute_HttpRoute_Filter_Filter

func (*MeshGatewayRoute_HttpRoute_Filter) GetMirror

func (*MeshGatewayRoute_HttpRoute_Filter) GetRedirect

func (*MeshGatewayRoute_HttpRoute_Filter) GetRequestHeader

func (*MeshGatewayRoute_HttpRoute_Filter) ProtoMessage

func (*MeshGatewayRoute_HttpRoute_Filter) ProtoMessage()

func (*MeshGatewayRoute_HttpRoute_Filter) ProtoReflect

func (*MeshGatewayRoute_HttpRoute_Filter) Reset

func (*MeshGatewayRoute_HttpRoute_Filter) String

type MeshGatewayRoute_HttpRoute_Filter_Mirror

type MeshGatewayRoute_HttpRoute_Filter_Mirror struct {

	// Backend denotes the service to which requests will be mirrored. The
	// "weight" field must not be given.
	Backend *MeshGatewayRoute_Backend `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
	// Percentage specifies the percentage of requests to mirror to
	// the backend (in the range 0.0 - 100.0, inclusive).
	Percentage *wrapperspb.DoubleValue `protobuf:"bytes,2,opt,name=percentage,proto3" json:"percentage,omitempty"`
	// contains filtered or unexported fields
}

The mirror filter sends a percentage of HTTP requests to the given backend. The gateway ignores any responses to these requests.

func (*MeshGatewayRoute_HttpRoute_Filter_Mirror) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_HttpRoute_Filter_Mirror.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_HttpRoute_Filter_Mirror) GetBackend

func (*MeshGatewayRoute_HttpRoute_Filter_Mirror) GetPercentage

func (*MeshGatewayRoute_HttpRoute_Filter_Mirror) ProtoMessage

func (*MeshGatewayRoute_HttpRoute_Filter_Mirror) ProtoReflect

func (*MeshGatewayRoute_HttpRoute_Filter_Mirror) Reset

func (*MeshGatewayRoute_HttpRoute_Filter_Mirror) String

type MeshGatewayRoute_HttpRoute_Filter_Mirror_

type MeshGatewayRoute_HttpRoute_Filter_Mirror_ struct {
	Mirror *MeshGatewayRoute_HttpRoute_Filter_Mirror `protobuf:"bytes,2,opt,name=mirror,proto3,oneof"`
}

type MeshGatewayRoute_HttpRoute_Filter_Redirect

type MeshGatewayRoute_HttpRoute_Filter_Redirect struct {

	// The scheme for the redirect URL. Usually "http" or "https".
	Scheme string `protobuf:"bytes,1,opt,name=scheme,proto3" json:"scheme,omitempty"`
	// The hostname to redirect to.
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// The port to redirect to.
	Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// The HTTP response status code. This must be in the range 300 - 308.
	StatusCode uint32 `protobuf:"varint,4,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// contains filtered or unexported fields
}

The redirect filter responds to the HTTP request immediately, without forwarding it to any backend. The response is a HTTP redirect message.

func (*MeshGatewayRoute_HttpRoute_Filter_Redirect) Descriptor deprecated

Deprecated: Use MeshGatewayRoute_HttpRoute_Filter_Redirect.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_HttpRoute_Filter_Redirect) GetHostname

func (*MeshGatewayRoute_HttpRoute_Filter_Redirect) GetPort

func (*MeshGatewayRoute_HttpRoute_Filter_Redirect) GetScheme

func (*MeshGatewayRoute_HttpRoute_Filter_Redirect) GetStatusCode

func (*MeshGatewayRoute_HttpRoute_Filter_Redirect) ProtoMessage

func (*MeshGatewayRoute_HttpRoute_Filter_Redirect) ProtoReflect

func (*MeshGatewayRoute_HttpRoute_Filter_Redirect) Reset

func (*MeshGatewayRoute_HttpRoute_Filter_Redirect) String

type MeshGatewayRoute_HttpRoute_Filter_Redirect_

type MeshGatewayRoute_HttpRoute_Filter_Redirect_ struct {
	Redirect *MeshGatewayRoute_HttpRoute_Filter_Redirect `protobuf:"bytes,3,opt,name=redirect,proto3,oneof"`
}

type MeshGatewayRoute_HttpRoute_Filter_RequestHeader

type MeshGatewayRoute_HttpRoute_Filter_RequestHeader struct {
	Set    []*MeshGatewayRoute_HttpRoute_Filter_RequestHeader_Header `protobuf:"bytes,1,rep,name=set,proto3" json:"set,omitempty"`
	Add    []*MeshGatewayRoute_HttpRoute_Filter_RequestHeader_Header `protobuf:"bytes,2,rep,name=add,proto3" json:"add,omitempty"`
	Remove []string                                                  `protobuf:"bytes,3,rep,name=remove,proto3" json:"remove,omitempty"`
	// contains filtered or unexported fields
}

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader) Descriptor deprecated

Deprecated: Use MeshGatewayRoute_HttpRoute_Filter_RequestHeader.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader) GetAdd

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader) GetRemove

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader) GetSet

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader) ProtoMessage

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader) ProtoReflect

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader) Reset

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader) String

type MeshGatewayRoute_HttpRoute_Filter_RequestHeader_

type MeshGatewayRoute_HttpRoute_Filter_RequestHeader_ struct {
	RequestHeader *MeshGatewayRoute_HttpRoute_Filter_RequestHeader `protobuf:"bytes,1,opt,name=request_header,json=requestHeader,proto3,oneof"`
}

type MeshGatewayRoute_HttpRoute_Filter_RequestHeader_Header

type MeshGatewayRoute_HttpRoute_Filter_RequestHeader_Header struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader_Header) Descriptor deprecated

Deprecated: Use MeshGatewayRoute_HttpRoute_Filter_RequestHeader_Header.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader_Header) GetName

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader_Header) GetValue

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader_Header) ProtoMessage

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader_Header) ProtoReflect

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader_Header) Reset

func (*MeshGatewayRoute_HttpRoute_Filter_RequestHeader_Header) String

type MeshGatewayRoute_HttpRoute_Match

type MeshGatewayRoute_HttpRoute_Match struct {
	Path            *MeshGatewayRoute_HttpRoute_Match_Path     `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Method          HttpMethod                                 `protobuf:"varint,2,opt,name=method,proto3,enum=kuma.mesh.v1alpha1.HttpMethod" json:"method,omitempty"`
	Headers         []*MeshGatewayRoute_HttpRoute_Match_Header `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	QueryParameters []*MeshGatewayRoute_HttpRoute_Match_Query  `protobuf:"bytes,4,rep,name=query_parameters,json=queryParameters,proto3" json:"query_parameters,omitempty"`
	// contains filtered or unexported fields
}

Match specifies the criteria for when a HTTP request matches a rule. The match is only considered successful if all of the specified conditions succeed (AND semantics). At least one match condition must be given.

func (*MeshGatewayRoute_HttpRoute_Match) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_HttpRoute_Match.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_HttpRoute_Match) GetHeaders

func (*MeshGatewayRoute_HttpRoute_Match) GetMethod

func (*MeshGatewayRoute_HttpRoute_Match) GetPath

func (*MeshGatewayRoute_HttpRoute_Match) GetQueryParameters

func (*MeshGatewayRoute_HttpRoute_Match) ProtoMessage

func (*MeshGatewayRoute_HttpRoute_Match) ProtoMessage()

func (*MeshGatewayRoute_HttpRoute_Match) ProtoReflect

func (*MeshGatewayRoute_HttpRoute_Match) Reset

func (*MeshGatewayRoute_HttpRoute_Match) String

type MeshGatewayRoute_HttpRoute_Match_Header

type MeshGatewayRoute_HttpRoute_Match_Header struct {
	Match MeshGatewayRoute_HttpRoute_Match_Header_MatchType `` /* 138-byte string literal not displayed */
	// Name of the HTTP header containing the value to match.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Value that the HTTP header value should be matched against.
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Header matches a value in a HTTP request header. Not that if the header is defined to have multiple values, a REGEX match must be used to match a specific value.

func (*MeshGatewayRoute_HttpRoute_Match_Header) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_HttpRoute_Match_Header.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_HttpRoute_Match_Header) GetMatch

func (*MeshGatewayRoute_HttpRoute_Match_Header) GetName

func (*MeshGatewayRoute_HttpRoute_Match_Header) GetValue

func (*MeshGatewayRoute_HttpRoute_Match_Header) ProtoMessage

func (*MeshGatewayRoute_HttpRoute_Match_Header) ProtoReflect

func (*MeshGatewayRoute_HttpRoute_Match_Header) Reset

func (*MeshGatewayRoute_HttpRoute_Match_Header) String

type MeshGatewayRoute_HttpRoute_Match_Header_MatchType

type MeshGatewayRoute_HttpRoute_Match_Header_MatchType int32
const (
	MeshGatewayRoute_HttpRoute_Match_Header_EXACT MeshGatewayRoute_HttpRoute_Match_Header_MatchType = 0
	MeshGatewayRoute_HttpRoute_Match_Header_REGEX MeshGatewayRoute_HttpRoute_Match_Header_MatchType = 1
)

func (MeshGatewayRoute_HttpRoute_Match_Header_MatchType) Descriptor

func (MeshGatewayRoute_HttpRoute_Match_Header_MatchType) Enum

func (MeshGatewayRoute_HttpRoute_Match_Header_MatchType) EnumDescriptor deprecated

Deprecated: Use MeshGatewayRoute_HttpRoute_Match_Header_MatchType.Descriptor instead.

func (MeshGatewayRoute_HttpRoute_Match_Header_MatchType) Number

func (MeshGatewayRoute_HttpRoute_Match_Header_MatchType) String

func (MeshGatewayRoute_HttpRoute_Match_Header_MatchType) Type

type MeshGatewayRoute_HttpRoute_Match_Path

type MeshGatewayRoute_HttpRoute_Match_Path struct {
	Match MeshGatewayRoute_HttpRoute_Match_Path_MatchType `` /* 136-byte string literal not displayed */
	// Value is the path to match against. For EXACT and PREFIX match
	// types, it must be a HTTP URI path. For the REGEX match type,
	// it must be a RE2 regular expression.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Path matches may be "EXACT", "PREFIX", or "REGEX" matches. If the match type is not specified, "EXACT" is the default.

func (*MeshGatewayRoute_HttpRoute_Match_Path) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_HttpRoute_Match_Path.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_HttpRoute_Match_Path) GetMatch

func (*MeshGatewayRoute_HttpRoute_Match_Path) GetValue

func (*MeshGatewayRoute_HttpRoute_Match_Path) ProtoMessage

func (*MeshGatewayRoute_HttpRoute_Match_Path) ProtoMessage()

func (*MeshGatewayRoute_HttpRoute_Match_Path) ProtoReflect

func (*MeshGatewayRoute_HttpRoute_Match_Path) Reset

func (*MeshGatewayRoute_HttpRoute_Match_Path) String

type MeshGatewayRoute_HttpRoute_Match_Path_MatchType

type MeshGatewayRoute_HttpRoute_Match_Path_MatchType int32
const (
	MeshGatewayRoute_HttpRoute_Match_Path_EXACT  MeshGatewayRoute_HttpRoute_Match_Path_MatchType = 0
	MeshGatewayRoute_HttpRoute_Match_Path_PREFIX MeshGatewayRoute_HttpRoute_Match_Path_MatchType = 1
	MeshGatewayRoute_HttpRoute_Match_Path_REGEX  MeshGatewayRoute_HttpRoute_Match_Path_MatchType = 2
)

func (MeshGatewayRoute_HttpRoute_Match_Path_MatchType) Descriptor

func (MeshGatewayRoute_HttpRoute_Match_Path_MatchType) Enum

func (MeshGatewayRoute_HttpRoute_Match_Path_MatchType) EnumDescriptor deprecated

Deprecated: Use MeshGatewayRoute_HttpRoute_Match_Path_MatchType.Descriptor instead.

func (MeshGatewayRoute_HttpRoute_Match_Path_MatchType) Number

func (MeshGatewayRoute_HttpRoute_Match_Path_MatchType) String

func (MeshGatewayRoute_HttpRoute_Match_Path_MatchType) Type

type MeshGatewayRoute_HttpRoute_Match_Query

type MeshGatewayRoute_HttpRoute_Match_Query struct {
	Match MeshGatewayRoute_HttpRoute_Match_Query_MatchType `` /* 137-byte string literal not displayed */
	// Name of the query parameter containing the value to match.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Value that the query parameter value should be matched against.
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Query matches against HTTP request query parameters.

func (*MeshGatewayRoute_HttpRoute_Match_Query) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_HttpRoute_Match_Query.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_HttpRoute_Match_Query) GetMatch

func (*MeshGatewayRoute_HttpRoute_Match_Query) GetName

func (*MeshGatewayRoute_HttpRoute_Match_Query) GetValue

func (*MeshGatewayRoute_HttpRoute_Match_Query) ProtoMessage

func (*MeshGatewayRoute_HttpRoute_Match_Query) ProtoReflect

func (*MeshGatewayRoute_HttpRoute_Match_Query) Reset

func (*MeshGatewayRoute_HttpRoute_Match_Query) String

type MeshGatewayRoute_HttpRoute_Match_Query_MatchType

type MeshGatewayRoute_HttpRoute_Match_Query_MatchType int32
const (
	MeshGatewayRoute_HttpRoute_Match_Query_EXACT MeshGatewayRoute_HttpRoute_Match_Query_MatchType = 0
	MeshGatewayRoute_HttpRoute_Match_Query_REGEX MeshGatewayRoute_HttpRoute_Match_Query_MatchType = 1
)

func (MeshGatewayRoute_HttpRoute_Match_Query_MatchType) Descriptor

func (MeshGatewayRoute_HttpRoute_Match_Query_MatchType) Enum

func (MeshGatewayRoute_HttpRoute_Match_Query_MatchType) EnumDescriptor deprecated

Deprecated: Use MeshGatewayRoute_HttpRoute_Match_Query_MatchType.Descriptor instead.

func (MeshGatewayRoute_HttpRoute_Match_Query_MatchType) Number

func (MeshGatewayRoute_HttpRoute_Match_Query_MatchType) String

func (MeshGatewayRoute_HttpRoute_Match_Query_MatchType) Type

type MeshGatewayRoute_HttpRoute_Rule

type MeshGatewayRoute_HttpRoute_Rule struct {

	// Matches are checked in order. If any match is successful, the
	// rule is selected (OR semantics).
	Matches []*MeshGatewayRoute_HttpRoute_Match `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
	// Filters are request processing steps that are applied to
	// matched requests.
	//
	// If the redirect filter is specified, it must be the only
	// filter given.
	Filters []*MeshGatewayRoute_HttpRoute_Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
	// Backends is the set of services to which the gateway will
	// forward requests. If a redirect filter is specified, no
	// backends are allowed. Otherwise, at least one backend
	// must be given.
	Backends []*MeshGatewayRoute_Backend `protobuf:"bytes,3,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

func (*MeshGatewayRoute_HttpRoute_Rule) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_HttpRoute_Rule.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_HttpRoute_Rule) GetBackends

func (*MeshGatewayRoute_HttpRoute_Rule) GetFilters

func (*MeshGatewayRoute_HttpRoute_Rule) GetMatches

func (*MeshGatewayRoute_HttpRoute_Rule) ProtoMessage

func (*MeshGatewayRoute_HttpRoute_Rule) ProtoMessage()

func (*MeshGatewayRoute_HttpRoute_Rule) ProtoReflect

func (*MeshGatewayRoute_HttpRoute_Rule) Reset

func (*MeshGatewayRoute_HttpRoute_Rule) String

type MeshGatewayRoute_TcpRoute

type MeshGatewayRoute_TcpRoute struct {
	Rules []*MeshGatewayRoute_TcpRoute_Rule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

TLS routes are valid for listeners that accept connections over TLS.

func (*MeshGatewayRoute_TcpRoute) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_TcpRoute.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_TcpRoute) GetRules

func (*MeshGatewayRoute_TcpRoute) ProtoMessage

func (*MeshGatewayRoute_TcpRoute) ProtoMessage()

func (*MeshGatewayRoute_TcpRoute) ProtoReflect

func (*MeshGatewayRoute_TcpRoute) Reset

func (x *MeshGatewayRoute_TcpRoute) Reset()

func (*MeshGatewayRoute_TcpRoute) String

func (x *MeshGatewayRoute_TcpRoute) String() string

type MeshGatewayRoute_TcpRoute_Match

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

func (*MeshGatewayRoute_TcpRoute_Match) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_TcpRoute_Match.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_TcpRoute_Match) ProtoMessage

func (*MeshGatewayRoute_TcpRoute_Match) ProtoMessage()

func (*MeshGatewayRoute_TcpRoute_Match) ProtoReflect

func (*MeshGatewayRoute_TcpRoute_Match) Reset

func (*MeshGatewayRoute_TcpRoute_Match) String

type MeshGatewayRoute_TcpRoute_Rule

type MeshGatewayRoute_TcpRoute_Rule struct {
	Matches  []*MeshGatewayRoute_TcpRoute_Match `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
	Backends []*MeshGatewayRoute_Backend        `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

func (*MeshGatewayRoute_TcpRoute_Rule) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_TcpRoute_Rule.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_TcpRoute_Rule) GetBackends

func (*MeshGatewayRoute_TcpRoute_Rule) GetMatches

func (*MeshGatewayRoute_TcpRoute_Rule) ProtoMessage

func (*MeshGatewayRoute_TcpRoute_Rule) ProtoMessage()

func (*MeshGatewayRoute_TcpRoute_Rule) ProtoReflect

func (*MeshGatewayRoute_TcpRoute_Rule) Reset

func (x *MeshGatewayRoute_TcpRoute_Rule) Reset()

func (*MeshGatewayRoute_TcpRoute_Rule) String

type MeshGatewayRoute_TlsRoute

type MeshGatewayRoute_TlsRoute struct {

	// Hostnames lists the server names for which this route is valid. The
	// hostnames are matched against the TLS Server Name Indication extension
	// send by the client.
	Hostnames []string                          `protobuf:"bytes,1,rep,name=hostnames,proto3" json:"hostnames,omitempty"`
	Rules     []*MeshGatewayRoute_TlsRoute_Rule `protobuf:"bytes,2,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

TLS routes are valid for listeners that accept connections over TLS. This can be a raw TLS connection, but can also be used to forward HTTP and other protocols that layer on top of TLS.

func (*MeshGatewayRoute_TlsRoute) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_TlsRoute.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_TlsRoute) GetHostnames

func (x *MeshGatewayRoute_TlsRoute) GetHostnames() []string

func (*MeshGatewayRoute_TlsRoute) GetRules

func (*MeshGatewayRoute_TlsRoute) ProtoMessage

func (*MeshGatewayRoute_TlsRoute) ProtoMessage()

func (*MeshGatewayRoute_TlsRoute) ProtoReflect

func (*MeshGatewayRoute_TlsRoute) Reset

func (x *MeshGatewayRoute_TlsRoute) Reset()

func (*MeshGatewayRoute_TlsRoute) String

func (x *MeshGatewayRoute_TlsRoute) String() string

type MeshGatewayRoute_TlsRoute_Match

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

func (*MeshGatewayRoute_TlsRoute_Match) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_TlsRoute_Match.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_TlsRoute_Match) ProtoMessage

func (*MeshGatewayRoute_TlsRoute_Match) ProtoMessage()

func (*MeshGatewayRoute_TlsRoute_Match) ProtoReflect

func (*MeshGatewayRoute_TlsRoute_Match) Reset

func (*MeshGatewayRoute_TlsRoute_Match) String

type MeshGatewayRoute_TlsRoute_Rule

type MeshGatewayRoute_TlsRoute_Rule struct {
	Matches  []*MeshGatewayRoute_TlsRoute_Match `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
	Backends []*MeshGatewayRoute_Backend        `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

func (*MeshGatewayRoute_TlsRoute_Rule) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_TlsRoute_Rule.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_TlsRoute_Rule) GetBackends

func (*MeshGatewayRoute_TlsRoute_Rule) GetMatches

func (*MeshGatewayRoute_TlsRoute_Rule) ProtoMessage

func (*MeshGatewayRoute_TlsRoute_Rule) ProtoMessage()

func (*MeshGatewayRoute_TlsRoute_Rule) ProtoReflect

func (*MeshGatewayRoute_TlsRoute_Rule) Reset

func (x *MeshGatewayRoute_TlsRoute_Rule) Reset()

func (*MeshGatewayRoute_TlsRoute_Rule) String

type MeshGatewayRoute_UdpRoute

type MeshGatewayRoute_UdpRoute struct {
	Rules []*MeshGatewayRoute_UdpRoute_Rule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

UDP routes are valid for UDP listeners.

func (*MeshGatewayRoute_UdpRoute) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_UdpRoute.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_UdpRoute) GetRules

func (*MeshGatewayRoute_UdpRoute) ProtoMessage

func (*MeshGatewayRoute_UdpRoute) ProtoMessage()

func (*MeshGatewayRoute_UdpRoute) ProtoReflect

func (*MeshGatewayRoute_UdpRoute) Reset

func (x *MeshGatewayRoute_UdpRoute) Reset()

func (*MeshGatewayRoute_UdpRoute) String

func (x *MeshGatewayRoute_UdpRoute) String() string

type MeshGatewayRoute_UdpRoute_Match

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

func (*MeshGatewayRoute_UdpRoute_Match) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_UdpRoute_Match.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_UdpRoute_Match) ProtoMessage

func (*MeshGatewayRoute_UdpRoute_Match) ProtoMessage()

func (*MeshGatewayRoute_UdpRoute_Match) ProtoReflect

func (*MeshGatewayRoute_UdpRoute_Match) Reset

func (*MeshGatewayRoute_UdpRoute_Match) String

type MeshGatewayRoute_UdpRoute_Rule

type MeshGatewayRoute_UdpRoute_Rule struct {
	Matches  []*MeshGatewayRoute_UdpRoute_Match `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
	Backends []*MeshGatewayRoute_Backend        `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

func (*MeshGatewayRoute_UdpRoute_Rule) Descriptor deprecated

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

Deprecated: Use MeshGatewayRoute_UdpRoute_Rule.ProtoReflect.Descriptor instead.

func (*MeshGatewayRoute_UdpRoute_Rule) GetBackends

func (*MeshGatewayRoute_UdpRoute_Rule) GetMatches

func (*MeshGatewayRoute_UdpRoute_Rule) ProtoMessage

func (*MeshGatewayRoute_UdpRoute_Rule) ProtoMessage()

func (*MeshGatewayRoute_UdpRoute_Rule) ProtoReflect

func (*MeshGatewayRoute_UdpRoute_Rule) Reset

func (x *MeshGatewayRoute_UdpRoute_Rule) Reset()

func (*MeshGatewayRoute_UdpRoute_Rule) String

type MeshGateway_Conf

type MeshGateway_Conf struct {

	// Listeners define logical endpoints that are bound on this MeshGateway's
	// address(es).
	Listeners []*MeshGateway_Listener `protobuf:"bytes,2,rep,name=listeners,proto3" json:"listeners,omitempty"`
	// contains filtered or unexported fields
}

Conf defines the desired state of MeshGateway.

Aligns with MeshGatewaySpec.

func (*MeshGateway_Conf) Descriptor deprecated

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

Deprecated: Use MeshGateway_Conf.ProtoReflect.Descriptor instead.

func (*MeshGateway_Conf) GetListeners

func (x *MeshGateway_Conf) GetListeners() []*MeshGateway_Listener

func (*MeshGateway_Conf) ProtoMessage

func (*MeshGateway_Conf) ProtoMessage()

func (*MeshGateway_Conf) ProtoReflect

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

func (*MeshGateway_Conf) Reset

func (x *MeshGateway_Conf) Reset()

func (*MeshGateway_Conf) String

func (x *MeshGateway_Conf) String() string

type MeshGateway_Listener

type MeshGateway_Listener struct {

	// Hostname specifies the virtual hostname to match for protocol types that
	// define this concept. When unspecified, "", or `*`, all hostnames are
	// matched. This field can be omitted for protocols that don't require
	// hostname based matching.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Port is the network port. Multiple listeners may use the
	// same port, subject to the Listener compatibility rules.
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Protocol specifies the network protocol this listener expects to receive.
	Protocol MeshGateway_Listener_Protocol `protobuf:"varint,3,opt,name=protocol,proto3,enum=kuma.mesh.v1alpha1.MeshGateway_Listener_Protocol" json:"protocol,omitempty"`
	// TLS is the TLS configuration for the Listener. This field
	// is required if the Protocol field is "HTTPS" or "TLS" and
	// ignored otherwise.
	Tls *MeshGateway_TLS_Conf `protobuf:"bytes,4,opt,name=tls,proto3" json:"tls,omitempty"`
	// Tags specifies a unique combination of tags that routes can use
	// to match themselves to this listener.
	//
	// When matching routes to listeners, the control plane constructs a
	// set of matching tags for each listener by forming the union of the
	// gateway tags and the listener tags. A route will be attached to the
	// listener if all of the route's tags are preset in the matching tags
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MeshGateway_Listener) Descriptor deprecated

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

Deprecated: Use MeshGateway_Listener.ProtoReflect.Descriptor instead.

func (*MeshGateway_Listener) GetHostname

func (x *MeshGateway_Listener) GetHostname() string

func (*MeshGateway_Listener) GetPort

func (x *MeshGateway_Listener) GetPort() uint32

func (*MeshGateway_Listener) GetProtocol

func (*MeshGateway_Listener) GetTags

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

func (*MeshGateway_Listener) GetTls

func (*MeshGateway_Listener) ProtoMessage

func (*MeshGateway_Listener) ProtoMessage()

func (*MeshGateway_Listener) ProtoReflect

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

func (*MeshGateway_Listener) Reset

func (x *MeshGateway_Listener) Reset()

func (*MeshGateway_Listener) String

func (x *MeshGateway_Listener) String() string

type MeshGateway_Listener_Protocol

type MeshGateway_Listener_Protocol int32
const (
	MeshGateway_Listener_NONE  MeshGateway_Listener_Protocol = 0
	MeshGateway_Listener_TCP   MeshGateway_Listener_Protocol = 1
	MeshGateway_Listener_UDP   MeshGateway_Listener_Protocol = 2
	MeshGateway_Listener_TLS   MeshGateway_Listener_Protocol = 3
	MeshGateway_Listener_HTTP  MeshGateway_Listener_Protocol = 4
	MeshGateway_Listener_HTTPS MeshGateway_Listener_Protocol = 5
)

func (MeshGateway_Listener_Protocol) Descriptor

func (MeshGateway_Listener_Protocol) Enum

func (MeshGateway_Listener_Protocol) EnumDescriptor deprecated

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

Deprecated: Use MeshGateway_Listener_Protocol.Descriptor instead.

func (MeshGateway_Listener_Protocol) Number

func (MeshGateway_Listener_Protocol) String

func (MeshGateway_Listener_Protocol) Type

type MeshGateway_TLS

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

TLSConfig describes a TLS configuration.

func (*MeshGateway_TLS) Descriptor deprecated

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

Deprecated: Use MeshGateway_TLS.ProtoReflect.Descriptor instead.

func (*MeshGateway_TLS) ProtoMessage

func (*MeshGateway_TLS) ProtoMessage()

func (*MeshGateway_TLS) ProtoReflect

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

func (*MeshGateway_TLS) Reset

func (x *MeshGateway_TLS) Reset()

func (*MeshGateway_TLS) String

func (x *MeshGateway_TLS) String() string

type MeshGateway_TLS_Conf

type MeshGateway_TLS_Conf struct {

	// Mode defines the TLS behavior for the TLS session initiated
	// by the client.
	Mode MeshGateway_TLS_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=kuma.mesh.v1alpha1.MeshGateway_TLS_Mode" json:"mode,omitempty"`
	// Certificates is an array of datasources that contain TLS
	// certificates and private keys.  Each datasource must contain a
	// sequence of PEM-encoded objects. The server certificate and private
	// key are required, but additional certificates are allowed and will
	// be added to the certificate chain.  The server certificate must
	// be the first certificate in the datasource.
	//
	// When multiple certificate datasources are configured, they must have
	// different key types. In practice, this means that one datasource
	// should contain an RSA key and certificate, and the other an
	// ECDSA key and certificate.
	Certificates []*v1alpha1.DataSource `protobuf:"bytes,2,rep,name=certificates,proto3" json:"certificates,omitempty"`
	// Options should eventually configure how TLS is configured. This
	// is where cipher suite and version configuration can be specified,
	// client certificates enforced, and so on.
	Options *MeshGateway_TLS_Options `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

Aligns with MeshGatewayTLSConfig.

func (*MeshGateway_TLS_Conf) Descriptor deprecated

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

Deprecated: Use MeshGateway_TLS_Conf.ProtoReflect.Descriptor instead.

func (*MeshGateway_TLS_Conf) GetCertificates

func (x *MeshGateway_TLS_Conf) GetCertificates() []*v1alpha1.DataSource

func (*MeshGateway_TLS_Conf) GetMode

func (*MeshGateway_TLS_Conf) GetOptions

func (*MeshGateway_TLS_Conf) ProtoMessage

func (*MeshGateway_TLS_Conf) ProtoMessage()

func (*MeshGateway_TLS_Conf) ProtoReflect

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

func (*MeshGateway_TLS_Conf) Reset

func (x *MeshGateway_TLS_Conf) Reset()

func (*MeshGateway_TLS_Conf) String

func (x *MeshGateway_TLS_Conf) String() string

type MeshGateway_TLS_Mode

type MeshGateway_TLS_Mode int32
const (
	// NONE is not a valid TLS mode. Ether TERMINATE or PASSTHROUGH must
	// be explicitly configured.
	MeshGateway_TLS_NONE MeshGateway_TLS_Mode = 0
	// The TLS session between the downstream client and the MeshGateway
	// is terminated at the MeshGateway. This mode requires the certificate
	// field to be set.
	MeshGateway_TLS_TERMINATE MeshGateway_TLS_Mode = 1
	// The TLS session is NOT terminated by the MeshGateway. This implies
	// that the MeshGateway can't decipher the TLS stream except for the
	// ClientHello message of the TLS protocol. The certificate field
	// is ignored in this mode.
	MeshGateway_TLS_PASSTHROUGH MeshGateway_TLS_Mode = 2
)

func (MeshGateway_TLS_Mode) Descriptor

func (MeshGateway_TLS_Mode) Enum

func (MeshGateway_TLS_Mode) EnumDescriptor deprecated

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

Deprecated: Use MeshGateway_TLS_Mode.Descriptor instead.

func (MeshGateway_TLS_Mode) Number

func (MeshGateway_TLS_Mode) String

func (x MeshGateway_TLS_Mode) String() string

func (MeshGateway_TLS_Mode) Type

type MeshGateway_TLS_Options

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

func (*MeshGateway_TLS_Options) Descriptor deprecated

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

Deprecated: Use MeshGateway_TLS_Options.ProtoReflect.Descriptor instead.

func (*MeshGateway_TLS_Options) ProtoMessage

func (*MeshGateway_TLS_Options) ProtoMessage()

func (*MeshGateway_TLS_Options) ProtoReflect

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

func (*MeshGateway_TLS_Options) Reset

func (x *MeshGateway_TLS_Options) Reset()

func (*MeshGateway_TLS_Options) String

func (x *MeshGateway_TLS_Options) String() string

type MeshInsight

type MeshInsight struct {
	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"`
	// mTLS statistics
	MTLS             *MeshInsight_MTLS             `protobuf:"bytes,5,opt,name=mTLS,proto3" json:"mTLS,omitempty"`
	Services         *MeshInsight_ServiceStat      `protobuf:"bytes,6,opt,name=services,proto3" json:"services,omitempty"`
	DataplanesByType *MeshInsight_DataplanesByType `protobuf:"bytes,7,opt,name=dataplanesByType,proto3" json:"dataplanesByType,omitempty"`
	// contains filtered or unexported fields
}

MeshInsight defines the observed state of a Mesh.

func (*MeshInsight) DeepCopy

func (t *MeshInsight) DeepCopy() *MeshInsight

func (*MeshInsight) DeepCopyInto

func (t *MeshInsight) DeepCopyInto(out *MeshInsight)

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

func (x *MeshInsight) GetDataplanesByType() *MeshInsight_DataplanesByType

func (*MeshInsight) GetDpVersions

func (x *MeshInsight) GetDpVersions() *MeshInsight_DpVersions

func (*MeshInsight) GetMTLS

func (x *MeshInsight) GetMTLS() *MeshInsight_MTLS

func (*MeshInsight) GetPolicies

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

func (*MeshInsight) GetServices

func (x *MeshInsight) GetServices() *MeshInsight_ServiceStat

func (*MeshInsight) MarshalJSON

func (m *MeshInsight) MarshalJSON() ([]byte, error)

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

func (*MeshInsight) UnmarshalJSON

func (m *MeshInsight) UnmarshalJSON(data []byte) error

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 (*MeshInsight_DataplaneStat) Reset

func (x *MeshInsight_DataplaneStat) Reset()

func (*MeshInsight_DataplaneStat) String

func (x *MeshInsight_DataplaneStat) String() string

type MeshInsight_DataplanesByType

type MeshInsight_DataplanesByType struct {
	Standard *MeshInsight_DataplaneStat `protobuf:"bytes,1,opt,name=standard,proto3" json:"standard,omitempty"`
	Gateway  *MeshInsight_DataplaneStat `protobuf:"bytes,2,opt,name=gateway,proto3" json:"gateway,omitempty"`
	// contains filtered or unexported fields
}

DataplanesByType defines statistics splitted by dataplane types

func (*MeshInsight_DataplanesByType) Descriptor deprecated

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

Deprecated: Use MeshInsight_DataplanesByType.ProtoReflect.Descriptor instead.

func (*MeshInsight_DataplanesByType) GetGateway

func (*MeshInsight_DataplanesByType) GetStandard

func (*MeshInsight_DataplanesByType) ProtoMessage

func (*MeshInsight_DataplanesByType) ProtoMessage()

func (*MeshInsight_DataplanesByType) ProtoReflect

func (*MeshInsight_DataplanesByType) Reset

func (x *MeshInsight_DataplanesByType) Reset()

func (*MeshInsight_DataplanesByType) 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 */
	// Dataplane 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 (*MeshInsight_DpVersions) GetKumaDp

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_MTLS

type MeshInsight_MTLS struct {

	// Dataplanes grouped by issued backends.
	IssuedBackends map[string]*MeshInsight_DataplaneStat `` /* 169-byte string literal not displayed */
	// Dataplanes grouped by supported backends.
	SupportedBackends map[string]*MeshInsight_DataplaneStat `` /* 175-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MeshInsight_MTLS) Descriptor deprecated

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

Deprecated: Use MeshInsight_MTLS.ProtoReflect.Descriptor instead.

func (*MeshInsight_MTLS) GetIssuedBackends

func (x *MeshInsight_MTLS) GetIssuedBackends() map[string]*MeshInsight_DataplaneStat

func (*MeshInsight_MTLS) GetSupportedBackends

func (x *MeshInsight_MTLS) GetSupportedBackends() map[string]*MeshInsight_DataplaneStat

func (*MeshInsight_MTLS) ProtoMessage

func (*MeshInsight_MTLS) ProtoMessage()

func (*MeshInsight_MTLS) ProtoReflect

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

func (*MeshInsight_MTLS) Reset

func (x *MeshInsight_MTLS) Reset()

func (*MeshInsight_MTLS) String

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

type MeshInsight_ServiceStat struct {
	Total    uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Internal uint32 `protobuf:"varint,2,opt,name=internal,proto3" json:"internal,omitempty"`
	External uint32 `protobuf:"varint,3,opt,name=external,proto3" json:"external,omitempty"`
	// contains filtered or unexported fields
}

ServiceStat defines statistics of mesh services

func (*MeshInsight_ServiceStat) Descriptor deprecated

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

Deprecated: Use MeshInsight_ServiceStat.ProtoReflect.Descriptor instead.

func (*MeshInsight_ServiceStat) GetExternal

func (x *MeshInsight_ServiceStat) GetExternal() uint32

func (*MeshInsight_ServiceStat) GetInternal

func (x *MeshInsight_ServiceStat) GetInternal() uint32

func (*MeshInsight_ServiceStat) GetTotal

func (x *MeshInsight_ServiceStat) GetTotal() uint32

func (*MeshInsight_ServiceStat) ProtoMessage

func (*MeshInsight_ServiceStat) ProtoMessage()

func (*MeshInsight_ServiceStat) ProtoReflect

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

func (*MeshInsight_ServiceStat) Reset

func (x *MeshInsight_ServiceStat) Reset()

func (*MeshInsight_ServiceStat) String

func (x *MeshInsight_ServiceStat) String() string

type Mesh_Constraints

type Mesh_Constraints struct {

	// DataplaneProxyMembership defines a set of requirements for data plane
	// proxies to be a member of the mesh.
	DataplaneProxy *Mesh_DataplaneProxyConstraints `protobuf:"bytes,1,opt,name=dataplaneProxy,proto3" json:"dataplaneProxy,omitempty"`
	// contains filtered or unexported fields
}

Constraints to apply to the mesh and its entities

func (*Mesh_Constraints) Descriptor deprecated

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

Deprecated: Use Mesh_Constraints.ProtoReflect.Descriptor instead.

func (*Mesh_Constraints) GetDataplaneProxy

func (x *Mesh_Constraints) GetDataplaneProxy() *Mesh_DataplaneProxyConstraints

func (*Mesh_Constraints) ProtoMessage

func (*Mesh_Constraints) ProtoMessage()

func (*Mesh_Constraints) ProtoReflect

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

func (*Mesh_Constraints) Reset

func (x *Mesh_Constraints) Reset()

func (*Mesh_Constraints) String

func (x *Mesh_Constraints) String() string

type Mesh_DataplaneProxyConstraints

type Mesh_DataplaneProxyConstraints struct {

	// Requirements defines a set of requirements that data plane proxies must
	// fulfill in order to join the mesh. A data plane proxy must fulfill at
	// least one requirement in order to join the mesh. Empty list of allowed
	// requirements means that any proxy that is not explicitly denied can join.
	Requirements []*Mesh_DataplaneProxyConstraints_Rules `protobuf:"bytes,1,rep,name=requirements,proto3" json:"requirements,omitempty"`
	// Restrictions defines a set of restrictions that data plane proxies cannot
	// fulfill in order to join the mesh. A data plane proxy cannot fulfill any
	// requirement in order to join the mesh.
	// Restrictions takes precedence over requirements.
	Restrictions []*Mesh_DataplaneProxyConstraints_Rules `protobuf:"bytes,2,rep,name=restrictions,proto3" json:"restrictions,omitempty"`
	// contains filtered or unexported fields
}

func (*Mesh_DataplaneProxyConstraints) Descriptor deprecated

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

Deprecated: Use Mesh_DataplaneProxyConstraints.ProtoReflect.Descriptor instead.

func (*Mesh_DataplaneProxyConstraints) GetRequirements

func (*Mesh_DataplaneProxyConstraints) GetRestrictions

func (*Mesh_DataplaneProxyConstraints) ProtoMessage

func (*Mesh_DataplaneProxyConstraints) ProtoMessage()

func (*Mesh_DataplaneProxyConstraints) ProtoReflect

func (*Mesh_DataplaneProxyConstraints) Reset

func (x *Mesh_DataplaneProxyConstraints) Reset()

func (*Mesh_DataplaneProxyConstraints) String

type Mesh_DataplaneProxyConstraints_Rules

type Mesh_DataplaneProxyConstraints_Rules struct {

	// Tags defines set of required tags. You can specify '*' in value to
	// require non empty value of tag
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

Rules defines a set of rules for data plane proxies to be member of the mesh.

func (*Mesh_DataplaneProxyConstraints_Rules) Descriptor deprecated

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

Deprecated: Use Mesh_DataplaneProxyConstraints_Rules.ProtoReflect.Descriptor instead.

func (*Mesh_DataplaneProxyConstraints_Rules) GetTags

func (*Mesh_DataplaneProxyConstraints_Rules) ProtoMessage

func (*Mesh_DataplaneProxyConstraints_Rules) ProtoMessage()

func (*Mesh_DataplaneProxyConstraints_Rules) ProtoReflect

func (*Mesh_DataplaneProxyConstraints_Rules) Reset

func (*Mesh_DataplaneProxyConstraints_Rules) 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_LegacyRequest
	//	*Message_LegacyResponse
	//	*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) GetLegacyRequest

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

func (*Message) GetLegacyResponse

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

func (*Message) GetRequest

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

func (*Message) GetResponse

func (x *Message) GetResponse() *v3.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_LegacyRequest

type Message_LegacyRequest struct {
	LegacyRequest *v2.DiscoveryRequest `protobuf:"bytes,1,opt,name=legacy_request,json=legacyRequest,proto3,oneof"`
}

type Message_LegacyResponse

type Message_LegacyResponse struct {
	LegacyResponse *v2.DiscoveryResponse `protobuf:"bytes,2,opt,name=legacy_response,json=legacyResponse,proto3,oneof"`
}

type Message_Request

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

type Message_Response

type Message_Response struct {
	Response *v3.DiscoveryResponse `protobuf:"bytes,4,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.

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

func (i OutboundInterface) MarshalText() ([]byte, error)

func (OutboundInterface) String

func (i OutboundInterface) String() string

type PrometheusMetricsBackendConfig

type PrometheusMetricsBackendConfig struct {

	// Port on which a dataplane should expose HTTP endpoint with Prometheus
	// metrics.
	Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// Path on which a dataplane should expose HTTP endpoint with Prometheus
	// metrics.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Tags associated with an application this dataplane is deployed next to,
	// e.g. service=web, version=1.0.
	// `service` tag is mandatory.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// If true then endpoints for scraping metrics won't require mTLS even if mTLS
	// is enabled in Mesh. If nil, then it is treated as false.
	SkipMTLS *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 (*PrometheusMetricsBackendConfig) GetPort

func (*PrometheusMetricsBackendConfig) GetSkipMTLS

func (*PrometheusMetricsBackendConfig) GetTags

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

func (*PrometheusMetricsBackendConfig) ProtoMessage

func (*PrometheusMetricsBackendConfig) ProtoMessage()

func (*PrometheusMetricsBackendConfig) ProtoReflect

func (*PrometheusMetricsBackendConfig) Reset

func (x *PrometheusMetricsBackendConfig) Reset()

func (*PrometheusMetricsBackendConfig) String

type ProxyTemplate

type ProxyTemplate struct {

	// List of Dataplane selectors.
	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) DeepCopy

func (t *ProxyTemplate) DeepCopy() *ProxyTemplate

func (*ProxyTemplate) DeepCopyInto

func (t *ProxyTemplate) DeepCopyInto(out *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) MarshalJSON

func (m *ProxyTemplate) MarshalJSON() ([]byte, error)

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

func (*ProxyTemplate) UnmarshalJSON

func (m *ProxyTemplate) UnmarshalJSON(data []byte) error

type ProxyTemplateProfileSource

type ProxyTemplateProfileSource struct {

	// Profile name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Profile params if any.
	// +optional
	Params map[string]string `` /* 153-byte string literal not displayed */
	// 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 (*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 (*ProxyTemplateSource) GetRaw

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 (*ProxyTemplate_Modifications) GetHttpFilter

func (*ProxyTemplate_Modifications) GetListener

func (*ProxyTemplate_Modifications) GetNetworkFilter

func (*ProxyTemplate_Modifications) GetType

func (m *ProxyTemplate_Modifications) GetType() isProxyTemplate_Modifications_Type

func (*ProxyTemplate_Modifications) GetVirtualHost

func (*ProxyTemplate_Modifications) ProtoMessage

func (*ProxyTemplate_Modifications) ProtoMessage()

func (*ProxyTemplate_Modifications) ProtoReflect

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 (*ProxyTemplate_Modifications_Cluster) GetOperation

func (x *ProxyTemplate_Modifications_Cluster) GetOperation() string

func (*ProxyTemplate_Modifications_Cluster) GetValue

func (*ProxyTemplate_Modifications_Cluster) ProtoMessage

func (*ProxyTemplate_Modifications_Cluster) ProtoMessage()

func (*ProxyTemplate_Modifications_Cluster) ProtoReflect

func (*ProxyTemplate_Modifications_Cluster) Reset

func (*ProxyTemplate_Modifications_Cluster) 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 (*ProxyTemplate_Modifications_Cluster_Match) GetOrigin

func (*ProxyTemplate_Modifications_Cluster_Match) ProtoMessage

func (*ProxyTemplate_Modifications_Cluster_Match) ProtoReflect

func (*ProxyTemplate_Modifications_Cluster_Match) Reset

func (*ProxyTemplate_Modifications_Cluster_Match) 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 (*ProxyTemplate_Modifications_HttpFilter) GetOperation

func (*ProxyTemplate_Modifications_HttpFilter) GetValue

func (*ProxyTemplate_Modifications_HttpFilter) ProtoMessage

func (*ProxyTemplate_Modifications_HttpFilter) ProtoReflect

func (*ProxyTemplate_Modifications_HttpFilter) Reset

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

Deprecated: Use ProxyTemplate_Modifications_HttpFilter_Match.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_HttpFilter_Match) GetListenerName

func (*ProxyTemplate_Modifications_HttpFilter_Match) GetName

func (*ProxyTemplate_Modifications_HttpFilter_Match) GetOrigin

func (*ProxyTemplate_Modifications_HttpFilter_Match) ProtoMessage

func (*ProxyTemplate_Modifications_HttpFilter_Match) ProtoReflect

func (*ProxyTemplate_Modifications_HttpFilter_Match) Reset

func (*ProxyTemplate_Modifications_HttpFilter_Match) 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 (*ProxyTemplate_Modifications_Listener) GetOperation

func (x *ProxyTemplate_Modifications_Listener) GetOperation() string

func (*ProxyTemplate_Modifications_Listener) GetValue

func (*ProxyTemplate_Modifications_Listener) ProtoMessage

func (*ProxyTemplate_Modifications_Listener) ProtoMessage()

func (*ProxyTemplate_Modifications_Listener) ProtoReflect

func (*ProxyTemplate_Modifications_Listener) Reset

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

Deprecated: Use ProxyTemplate_Modifications_Listener_Match.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_Listener_Match) GetName

func (*ProxyTemplate_Modifications_Listener_Match) GetOrigin

func (*ProxyTemplate_Modifications_Listener_Match) ProtoMessage

func (*ProxyTemplate_Modifications_Listener_Match) ProtoReflect

func (*ProxyTemplate_Modifications_Listener_Match) Reset

func (*ProxyTemplate_Modifications_Listener_Match) 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 (*ProxyTemplate_Modifications_NetworkFilter) GetOperation

func (*ProxyTemplate_Modifications_NetworkFilter) GetValue

func (*ProxyTemplate_Modifications_NetworkFilter) ProtoMessage

func (*ProxyTemplate_Modifications_NetworkFilter) ProtoReflect

func (*ProxyTemplate_Modifications_NetworkFilter) Reset

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

Deprecated: Use ProxyTemplate_Modifications_NetworkFilter_Match.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_NetworkFilter_Match) GetListenerName

func (*ProxyTemplate_Modifications_NetworkFilter_Match) GetName

func (*ProxyTemplate_Modifications_NetworkFilter_Match) GetOrigin

func (*ProxyTemplate_Modifications_NetworkFilter_Match) ProtoMessage

func (*ProxyTemplate_Modifications_NetworkFilter_Match) ProtoReflect

func (*ProxyTemplate_Modifications_NetworkFilter_Match) Reset

func (*ProxyTemplate_Modifications_NetworkFilter_Match) 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 (*ProxyTemplate_Modifications_VirtualHost) GetOperation

func (*ProxyTemplate_Modifications_VirtualHost) GetValue

func (*ProxyTemplate_Modifications_VirtualHost) ProtoMessage

func (*ProxyTemplate_Modifications_VirtualHost) ProtoReflect

func (*ProxyTemplate_Modifications_VirtualHost) Reset

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

Deprecated: Use ProxyTemplate_Modifications_VirtualHost_Match.ProtoReflect.Descriptor instead.

func (*ProxyTemplate_Modifications_VirtualHost_Match) GetName

func (*ProxyTemplate_Modifications_VirtualHost_Match) GetOrigin

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

func (*ProxyTemplate_Modifications_VirtualHost_Match) Reset

func (*ProxyTemplate_Modifications_VirtualHost_Match) String

type ProxyType

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

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 (*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 (*RateLimit_Conf_Http_OnRateLimit) GetStatus

func (*RateLimit_Conf_Http_OnRateLimit) ProtoMessage

func (*RateLimit_Conf_Http_OnRateLimit) ProtoMessage()

func (*RateLimit_Conf_Http_OnRateLimit) ProtoReflect

func (*RateLimit_Conf_Http_OnRateLimit) Reset

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

Deprecated: Use RateLimit_Conf_Http_OnRateLimit_HeaderValue.ProtoReflect.Descriptor instead.

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) GetAppend

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) GetKey

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) GetValue

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) ProtoMessage

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) ProtoReflect

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) Reset

func (*RateLimit_Conf_Http_OnRateLimit_HeaderValue) 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) DeepCopy

func (t *Retry) DeepCopy() *Retry

func (*Retry) DeepCopyInto

func (t *Retry) DeepCopyInto(out *Retry)

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

func (m *Retry) MarshalJSON() ([]byte, error)

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

func (*Retry) UnmarshalJSON

func (m *Retry) UnmarshalJSON(data []byte) error

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

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 (Retry_Conf_Grpc_RetryOn) String

func (x Retry_Conf_Grpc_RetryOn) String() string

func (Retry_Conf_Grpc_RetryOn) Type

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 */
	//  +optional
	RetriableMethods []HttpMethod `` /* 152-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) GetRetriableMethods

func (x *Retry_Conf_Http) GetRetriableMethods() []HttpMethod

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 {
	Services map[string]*ServiceInsight_Service `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ServiceInsight) DeepCopy

func (t *ServiceInsight) DeepCopy() *ServiceInsight

func (*ServiceInsight) DeepCopyInto

func (t *ServiceInsight) DeepCopyInto(out *ServiceInsight)

func (*ServiceInsight) Descriptor deprecated

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

Deprecated: Use ServiceInsight.ProtoReflect.Descriptor instead.

func (*ServiceInsight) GetServices

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

func (*ServiceInsight) MarshalJSON

func (m *ServiceInsight) MarshalJSON() ([]byte, error)

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

func (*ServiceInsight) UnmarshalJSON

func (m *ServiceInsight) UnmarshalJSON(data []byte) error

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"`
	IssuedBackends map[string]uint32                     `` /* 170-byte string literal not displayed */
	// 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 (*ServiceInsight_Service) GetIssuedBackends

func (x *ServiceInsight_Service) GetIssuedBackends() map[string]uint32

func (*ServiceInsight_Service) GetStatus

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 (*ServiceInsight_Service_DataplaneStat) GetOnline

func (*ServiceInsight_Service_DataplaneStat) GetTotal

func (*ServiceInsight_Service_DataplaneStat) ProtoMessage

func (*ServiceInsight_Service_DataplaneStat) ProtoMessage()

func (*ServiceInsight_Service_DataplaneStat) ProtoReflect

func (*ServiceInsight_Service_DataplaneStat) Reset

func (*ServiceInsight_Service_DataplaneStat) 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) Enum

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 (ServiceInsight_Service_Status) String

func (ServiceInsight_Service_Status) Type

type SingleValueTagSet

type SingleValueTagSet map[string]string

Set of tags that only allows a single value per key.

func (SingleValueTagSet) Exclude

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

func (t *TrafficLog) DeepCopy() *TrafficLog

func (*TrafficLog) DeepCopyInto

func (t *TrafficLog) DeepCopyInto(out *TrafficLog)

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

func (m *TrafficLog) MarshalJSON() ([]byte, error)

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

func (*TrafficLog) UnmarshalJSON

func (m *TrafficLog) UnmarshalJSON(data []byte) error

type TrafficLog_Conf

type TrafficLog_Conf struct {

	// Backend defined in the Mesh entity.
	Backend string `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
	// 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 (*TrafficRoute_Http) GetModify

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 (*TrafficRoute_Http_Match) GetMethod

func (*TrafficRoute_Http_Match) GetPath

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 (*TrafficRoute_Http_Match_StringMatcher) GetMatcherType

func (m *TrafficRoute_Http_Match_StringMatcher) GetMatcherType() isTrafficRoute_Http_Match_StringMatcher_MatcherType

func (*TrafficRoute_Http_Match_StringMatcher) GetPrefix

func (*TrafficRoute_Http_Match_StringMatcher) GetRegex

func (*TrafficRoute_Http_Match_StringMatcher) ProtoMessage

func (*TrafficRoute_Http_Match_StringMatcher) ProtoMessage()

func (*TrafficRoute_Http_Match_StringMatcher) ProtoReflect

func (*TrafficRoute_Http_Match_StringMatcher) Reset

func (*TrafficRoute_Http_Match_StringMatcher) 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 (*TrafficRoute_Http_Modify) GetPath

func (*TrafficRoute_Http_Modify) GetRequestHeaders

func (*TrafficRoute_Http_Modify) GetResponseHeaders

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 (*TrafficRoute_Http_Modify_Headers) GetRemove

func (*TrafficRoute_Http_Modify_Headers) ProtoMessage

func (*TrafficRoute_Http_Modify_Headers) ProtoMessage()

func (*TrafficRoute_Http_Modify_Headers) ProtoReflect

func (*TrafficRoute_Http_Modify_Headers) Reset

func (*TrafficRoute_Http_Modify_Headers) 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 (*TrafficRoute_Http_Modify_Headers_Add) GetName

func (*TrafficRoute_Http_Modify_Headers_Add) GetValue

func (*TrafficRoute_Http_Modify_Headers_Add) ProtoMessage

func (*TrafficRoute_Http_Modify_Headers_Add) ProtoMessage()

func (*TrafficRoute_Http_Modify_Headers_Add) ProtoReflect

func (*TrafficRoute_Http_Modify_Headers_Add) Reset

func (*TrafficRoute_Http_Modify_Headers_Add) 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 (*TrafficRoute_Http_Modify_Headers_Remove) ProtoMessage

func (*TrafficRoute_Http_Modify_Headers_Remove) ProtoReflect

func (*TrafficRoute_Http_Modify_Headers_Remove) Reset

func (*TrafficRoute_Http_Modify_Headers_Remove) 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 (*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 (*TrafficRoute_Http_Modify_Host) Reset

func (x *TrafficRoute_Http_Modify_Host) Reset()

func (*TrafficRoute_Http_Modify_Host) 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 (*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 (*TrafficRoute_Http_Modify_Path) Reset

func (x *TrafficRoute_Http_Modify_Path) Reset()

func (*TrafficRoute_Http_Modify_Path) 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 (*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 (*TrafficRoute_Http_Modify_RegexReplace) Reset

func (*TrafficRoute_Http_Modify_RegexReplace) 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 (*TrafficRoute_LoadBalancer) GetMaglev

func (*TrafficRoute_LoadBalancer) GetRandom

func (*TrafficRoute_LoadBalancer) GetRingHash

func (*TrafficRoute_LoadBalancer) GetRoundRobin

func (*TrafficRoute_LoadBalancer) ProtoMessage

func (*TrafficRoute_LoadBalancer) ProtoMessage()

func (*TrafficRoute_LoadBalancer) ProtoReflect

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

func (*TrafficRoute_LoadBalancer_LeastRequest) Reset

func (*TrafficRoute_LoadBalancer_LeastRequest) 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 (*TrafficRoute_LoadBalancer_Maglev) Reset

func (*TrafficRoute_LoadBalancer_Maglev) 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 (*TrafficRoute_LoadBalancer_Random) Reset

func (*TrafficRoute_LoadBalancer_Random) 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 (*TrafficRoute_LoadBalancer_RingHash) Reset

func (*TrafficRoute_LoadBalancer_RingHash) 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 (*TrafficRoute_LoadBalancer_RoundRobin) Reset

func (*TrafficRoute_LoadBalancer_RoundRobin) 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) StreamKumaResources

type UnimplementedMultiplexServiceServer

type UnimplementedMultiplexServiceServer struct {
}

UnimplementedMultiplexServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMultiplexServiceServer) StreamMessage

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"`
	// Versions of other dependencies, i.e. CoreDNS
	Dependencies map[string]string `` /* 165-byte string literal not displayed */
	// 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) GetDependencies

func (x *Version) GetDependencies() map[string]string

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 VirtualOutbound

type VirtualOutbound struct {

	// List of selectors to match dataplanes that this policy applies to
	Selectors []*Selector           `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	Conf      *VirtualOutbound_Conf `protobuf:"bytes,2,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

VirtualOutbound defines how to generate hostname ports combination.

func (*VirtualOutbound) Descriptor deprecated

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

Deprecated: Use VirtualOutbound.ProtoReflect.Descriptor instead.

func (*VirtualOutbound) GetConf

func (x *VirtualOutbound) GetConf() *VirtualOutbound_Conf

func (*VirtualOutbound) GetSelectors

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

func (*VirtualOutbound) ProtoMessage

func (*VirtualOutbound) ProtoMessage()

func (*VirtualOutbound) ProtoReflect

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

func (*VirtualOutbound) Reset

func (x *VirtualOutbound) Reset()

func (*VirtualOutbound) String

func (x *VirtualOutbound) String() string

type VirtualOutbound_Conf

type VirtualOutbound_Conf struct {

	// Host the gotemplate to generate the hostname from the Parameters map
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Port the gotemplate to generate the port from the Parameters map
	Port string `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	// Parameters a mapping between tag keys and template parameter key. This
	// must always contain at least `kuma.io/service`
	Parameters []*VirtualOutbound_Conf_TemplateParameter `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

func (*VirtualOutbound_Conf) Descriptor deprecated

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

Deprecated: Use VirtualOutbound_Conf.ProtoReflect.Descriptor instead.

func (*VirtualOutbound_Conf) GetHost

func (x *VirtualOutbound_Conf) GetHost() string

func (*VirtualOutbound_Conf) GetParameters

func (*VirtualOutbound_Conf) GetPort

func (x *VirtualOutbound_Conf) GetPort() string

func (*VirtualOutbound_Conf) ProtoMessage

func (*VirtualOutbound_Conf) ProtoMessage()

func (*VirtualOutbound_Conf) ProtoReflect

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

func (*VirtualOutbound_Conf) Reset

func (x *VirtualOutbound_Conf) Reset()

func (*VirtualOutbound_Conf) String

func (x *VirtualOutbound_Conf) String() string

type VirtualOutbound_Conf_TemplateParameter

type VirtualOutbound_Conf_TemplateParameter struct {

	// Name the name of the template parameter (must be alphanumeric).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// TagKey the name of the tag in the Kuma outbound (optional if absent it
	// will use Name).
	TagKey string `protobuf:"bytes,2,opt,name=tag_key,json=tagKey,proto3" json:"tag_key,omitempty"`
	// contains filtered or unexported fields
}

A mapping between a template parameter and a dataplane outbound tag name.

func (*VirtualOutbound_Conf_TemplateParameter) Descriptor deprecated

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

Deprecated: Use VirtualOutbound_Conf_TemplateParameter.ProtoReflect.Descriptor instead.

func (*VirtualOutbound_Conf_TemplateParameter) GetName

func (*VirtualOutbound_Conf_TemplateParameter) GetTagKey

func (*VirtualOutbound_Conf_TemplateParameter) ProtoMessage

func (*VirtualOutbound_Conf_TemplateParameter) ProtoReflect

func (*VirtualOutbound_Conf_TemplateParameter) Reset

func (*VirtualOutbound_Conf_TemplateParameter) 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 (*ZipkinTracingBackendConfig) Reset

func (x *ZipkinTracingBackendConfig) Reset()

func (*ZipkinTracingBackendConfig) String

func (x *ZipkinTracingBackendConfig) String() string

type ZoneEgress

type ZoneEgress struct {

	// Zone field contains Zone name where egress 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 Egress to listen on.
	Networking *ZoneEgress_Networking `protobuf:"bytes,2,opt,name=networking,proto3" json:"networking,omitempty"`
	// contains filtered or unexported fields
}

ZoneEgress allows us to configure dataplane in the Egress mode.

func (*ZoneEgress) Descriptor deprecated

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

Deprecated: Use ZoneEgress.ProtoReflect.Descriptor instead.

func (*ZoneEgress) GetNetworking

func (x *ZoneEgress) GetNetworking() *ZoneEgress_Networking

func (*ZoneEgress) GetZone

func (x *ZoneEgress) GetZone() string

func (*ZoneEgress) ProtoMessage

func (*ZoneEgress) ProtoMessage()

func (*ZoneEgress) ProtoReflect

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

func (*ZoneEgress) Reset

func (x *ZoneEgress) Reset()

func (*ZoneEgress) String

func (x *ZoneEgress) String() string

type ZoneEgressInsight

type ZoneEgressInsight 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
}

ZoneEgressInsight defines the observed state of a Zone Egress.

func (*ZoneEgressInsight) Descriptor deprecated

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

Deprecated: Use ZoneEgressInsight.ProtoReflect.Descriptor instead.

func (*ZoneEgressInsight) GetLastSubscription

func (x *ZoneEgressInsight) GetLastSubscription() generic.Subscription

func (*ZoneEgressInsight) GetSubscription

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

func (*ZoneEgressInsight) GetSubscriptions

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

func (*ZoneEgressInsight) IsOnline

func (x *ZoneEgressInsight) IsOnline() bool

func (*ZoneEgressInsight) ProtoMessage

func (*ZoneEgressInsight) ProtoMessage()

func (*ZoneEgressInsight) ProtoReflect

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

func (*ZoneEgressInsight) Reset

func (x *ZoneEgressInsight) Reset()

func (*ZoneEgressInsight) String

func (x *ZoneEgressInsight) String() string

func (*ZoneEgressInsight) Sum

func (*ZoneEgressInsight) UpdateSubscription

func (x *ZoneEgressInsight) UpdateSubscription(s generic.Subscription) error

type ZoneEgressOverview

type ZoneEgressOverview struct {
	ZoneEgress        *ZoneEgress        `protobuf:"bytes,1,opt,name=zoneEgress,proto3" json:"zoneEgress,omitempty"`
	ZoneEgressInsight *ZoneEgressInsight `protobuf:"bytes,2,opt,name=zoneEgressInsight,proto3" json:"zoneEgressInsight,omitempty"`
	// contains filtered or unexported fields
}

ZoneEgressOverview defines the projected state of a ZoneEgress.

func (*ZoneEgressOverview) Descriptor deprecated

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

Deprecated: Use ZoneEgressOverview.ProtoReflect.Descriptor instead.

func (*ZoneEgressOverview) GetZoneEgress

func (x *ZoneEgressOverview) GetZoneEgress() *ZoneEgress

func (*ZoneEgressOverview) GetZoneEgressInsight

func (x *ZoneEgressOverview) GetZoneEgressInsight() *ZoneEgressInsight

func (*ZoneEgressOverview) ProtoMessage

func (*ZoneEgressOverview) ProtoMessage()

func (*ZoneEgressOverview) ProtoReflect

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

func (*ZoneEgressOverview) Reset

func (x *ZoneEgressOverview) Reset()

func (*ZoneEgressOverview) String

func (x *ZoneEgressOverview) String() string

type ZoneEgress_Networking

type ZoneEgress_Networking struct {

	// Address on which inbound listener will be exposed
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Port of the inbound interface that will forward requests to the service.
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Admin contains configuration related to Envoy Admin API
	Admin *EnvoyAdmin `protobuf:"bytes,3,opt,name=admin,proto3" json:"admin,omitempty"`
	// contains filtered or unexported fields
}

func (*ZoneEgress_Networking) Descriptor deprecated

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

Deprecated: Use ZoneEgress_Networking.ProtoReflect.Descriptor instead.

func (*ZoneEgress_Networking) GetAddress

func (x *ZoneEgress_Networking) GetAddress() string

func (*ZoneEgress_Networking) GetAdmin

func (x *ZoneEgress_Networking) GetAdmin() *EnvoyAdmin

func (*ZoneEgress_Networking) GetPort

func (x *ZoneEgress_Networking) GetPort() uint32

func (*ZoneEgress_Networking) ProtoMessage

func (*ZoneEgress_Networking) ProtoMessage()

func (*ZoneEgress_Networking) ProtoReflect

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

func (*ZoneEgress_Networking) Reset

func (x *ZoneEgress_Networking) Reset()

func (*ZoneEgress_Networking) String

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

func (x *ZoneIngressInsight) GetLastSubscription() generic.Subscription

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 (*ZoneIngressInsight) UpdateSubscription

func (x *ZoneIngressInsight) UpdateSubscription(s generic.Subscription) error

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 (*ZoneIngress_AvailableService) Reset

func (x *ZoneIngress_AvailableService) Reset()

func (*ZoneIngress_AvailableService) 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"`
	// Admin contains configuration related to Envoy Admin API
	Admin *EnvoyAdmin `protobuf:"bytes,5,opt,name=admin,proto3" json:"admin,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) GetAdmin

func (x *ZoneIngress_Networking) GetAdmin() *EnvoyAdmin

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL