v1alpha1

package
v0.0.0-...-2fe0608 Latest Latest
Warning

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

 Go to latest Published: Jun 30, 2020 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Mandatory tag that has a reserved meaning in Kuma.
	ServiceTag     = "service"
	ServiceUnknown = "unknown"
	// Mandatory tag that has a reserved meaning in Kuma.
	ZoneTag = "zone"
	// Optional tag that has a reserved meaning in Kuma.
	// If absent, Kuma will treat application's protocol as opaque TCP.
	ProtocolTag = "protocol"
)
View Source 
const (
	LoggingTcpType  = "tcp"
	LoggingFileType = "file"

	TracingZipkinType = "zipkin"

	MetricsPrometheusType = "prometheus"
)
View Source 
const MatchAllTag = "*"

Variables

This section is empty.

Functions

func ParseIP 

func ParseIP(text string) (string, error)

func ParsePort 

func ParsePort(text string) (uint32, error)

func RegisterKumaDiscoveryServiceServer 

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

Types

type CertificateAuthorityBackend 

type CertificateAuthorityBackend struct {
	// Name of the backend
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the backend. Has to be one of the loaded plugins (Kuma ships with
	// builtin and provided)
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Dataplane certificate settings
	DpCert *CertificateAuthorityBackend_DpCert `protobuf:"bytes,3,opt,name=dpCert,proto3" json:"dpCert,omitempty"`
	// Configuration of the backend
	Conf                 *_struct.Struct `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

CertificateAuthorityBackend defines Certificate Authority backend

func (*CertificateAuthorityBackend) Descriptor 

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

func (*CertificateAuthorityBackend) GetConf 

func (m *CertificateAuthorityBackend) GetConf() *_struct.Struct

func (*CertificateAuthorityBackend) GetDpCert 

func (m *CertificateAuthorityBackend) GetDpCert() *CertificateAuthorityBackend_DpCert

func (*CertificateAuthorityBackend) GetName 

func (m *CertificateAuthorityBackend) GetName() string

func (*CertificateAuthorityBackend) GetType 

func (m *CertificateAuthorityBackend) GetType() string

func (*CertificateAuthorityBackend) ProtoMessage 

func (*CertificateAuthorityBackend) ProtoMessage()

func (*CertificateAuthorityBackend) Reset 

func (m *CertificateAuthorityBackend) Reset()

func (*CertificateAuthorityBackend) String 

func (m *CertificateAuthorityBackend) String() string

func (*CertificateAuthorityBackend) Validate 

func (m *CertificateAuthorityBackend) Validate() error

Validate checks the field values on CertificateAuthorityBackend with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*CertificateAuthorityBackend) XXX_DiscardUnknown 

func (m *CertificateAuthorityBackend) XXX_DiscardUnknown()

func (*CertificateAuthorityBackend) XXX_Marshal 

func (m *CertificateAuthorityBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CertificateAuthorityBackend) XXX_Merge 

func (m *CertificateAuthorityBackend) XXX_Merge(src proto.Message)

func (*CertificateAuthorityBackend) XXX_Size 

func (m *CertificateAuthorityBackend) XXX_Size() int

func (*CertificateAuthorityBackend) XXX_Unmarshal 

func (m *CertificateAuthorityBackend) XXX_Unmarshal(b []byte) error

type CertificateAuthorityBackendValidationError 

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

CertificateAuthorityBackendValidationError is the validation error returned by CertificateAuthorityBackend.Validate if the designated constraints aren't met.

func (CertificateAuthorityBackendValidationError) Cause 

func (e CertificateAuthorityBackendValidationError) Cause() error

Cause function returns cause value.

func (CertificateAuthorityBackendValidationError) Error 

func (e CertificateAuthorityBackendValidationError) Error() string

Error satisfies the builtin error interface

func (CertificateAuthorityBackendValidationError) ErrorName 

func (e CertificateAuthorityBackendValidationError) ErrorName() string

ErrorName returns error name.

func (CertificateAuthorityBackendValidationError) Field 

func (e CertificateAuthorityBackendValidationError) Field() string

Field function returns field value.

func (CertificateAuthorityBackendValidationError) Key 

func (e CertificateAuthorityBackendValidationError) Key() bool

Key function returns key value.

func (CertificateAuthorityBackendValidationError) Reason 

func (e CertificateAuthorityBackendValidationError) Reason() string

Reason function returns reason value.

type CertificateAuthorityBackend_DpCert 

type CertificateAuthorityBackend_DpCert struct {
	// Rotation settings
	Rotation             *CertificateAuthorityBackend_DpCert_Rotation `protobuf:"bytes,1,opt,name=rotation,proto3" json:"rotation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                     `json:"-"`
	XXX_unrecognized     []byte                                       `json:"-"`
	XXX_sizecache        int32                                        `json:"-"`
}

DpCert defines settings for certificates generated for Dataplanes

func (*CertificateAuthorityBackend_DpCert) Descriptor 

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

func (*CertificateAuthorityBackend_DpCert) GetRotation 

func (m *CertificateAuthorityBackend_DpCert) GetRotation() *CertificateAuthorityBackend_DpCert_Rotation

func (*CertificateAuthorityBackend_DpCert) ProtoMessage 

func (*CertificateAuthorityBackend_DpCert) ProtoMessage()

func (*CertificateAuthorityBackend_DpCert) Reset 

func (m *CertificateAuthorityBackend_DpCert) Reset()

func (*CertificateAuthorityBackend_DpCert) String 

func (m *CertificateAuthorityBackend_DpCert) String() string

func (*CertificateAuthorityBackend_DpCert) Validate 

func (m *CertificateAuthorityBackend_DpCert) Validate() error

Validate checks the field values on CertificateAuthorityBackend_DpCert with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*CertificateAuthorityBackend_DpCert) XXX_DiscardUnknown 

func (m *CertificateAuthorityBackend_DpCert) XXX_DiscardUnknown()

func (*CertificateAuthorityBackend_DpCert) XXX_Marshal 

func (m *CertificateAuthorityBackend_DpCert) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CertificateAuthorityBackend_DpCert) XXX_Merge 

func (m *CertificateAuthorityBackend_DpCert) XXX_Merge(src proto.Message)

func (*CertificateAuthorityBackend_DpCert) XXX_Size 

func (m *CertificateAuthorityBackend_DpCert) XXX_Size() int

func (*CertificateAuthorityBackend_DpCert) XXX_Unmarshal 

func (m *CertificateAuthorityBackend_DpCert) XXX_Unmarshal(b []byte) error

type CertificateAuthorityBackend_DpCertValidationError 

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

CertificateAuthorityBackend_DpCertValidationError is the validation error returned by CertificateAuthorityBackend_DpCert.Validate if the designated constraints aren't met.

func (CertificateAuthorityBackend_DpCertValidationError) Cause 

func (e CertificateAuthorityBackend_DpCertValidationError) Cause() error

Cause function returns cause value.

func (CertificateAuthorityBackend_DpCertValidationError) Error 

func (e CertificateAuthorityBackend_DpCertValidationError) Error() string

Error satisfies the builtin error interface

func (CertificateAuthorityBackend_DpCertValidationError) ErrorName 

func (e CertificateAuthorityBackend_DpCertValidationError) ErrorName() string

ErrorName returns error name.

func (CertificateAuthorityBackend_DpCertValidationError) Field 

func (e CertificateAuthorityBackend_DpCertValidationError) Field() string

Field function returns field value.

func (CertificateAuthorityBackend_DpCertValidationError) Key 

func (e CertificateAuthorityBackend_DpCertValidationError) Key() bool

Key function returns key value.

func (CertificateAuthorityBackend_DpCertValidationError) Reason 

func (e CertificateAuthorityBackend_DpCertValidationError) Reason() string

Reason function returns reason value.

type CertificateAuthorityBackend_DpCert_Rotation 

type CertificateAuthorityBackend_DpCert_Rotation struct {
	// Time after which generated certificate for Dataplane will expire
	Expiration           string   `protobuf:"bytes,1,opt,name=expiration,proto3" json:"expiration,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Rotation defines rotation settings for Dataplane certificate

func (*CertificateAuthorityBackend_DpCert_Rotation) Descriptor 

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

func (*CertificateAuthorityBackend_DpCert_Rotation) GetExpiration 

func (m *CertificateAuthorityBackend_DpCert_Rotation) GetExpiration() string

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage 

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage()

func (*CertificateAuthorityBackend_DpCert_Rotation) Reset 

func (m *CertificateAuthorityBackend_DpCert_Rotation) Reset()

func (*CertificateAuthorityBackend_DpCert_Rotation) String 

func (m *CertificateAuthorityBackend_DpCert_Rotation) String() string

func (*CertificateAuthorityBackend_DpCert_Rotation) Validate 

func (m *CertificateAuthorityBackend_DpCert_Rotation) Validate() error

Validate checks the field values on CertificateAuthorityBackend_DpCert_Rotation with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*CertificateAuthorityBackend_DpCert_Rotation) XXX_DiscardUnknown 

func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_DiscardUnknown()

func (*CertificateAuthorityBackend_DpCert_Rotation) XXX_Marshal 

func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CertificateAuthorityBackend_DpCert_Rotation) XXX_Merge 

func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_Merge(src proto.Message)

func (*CertificateAuthorityBackend_DpCert_Rotation) XXX_Size 

func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_Size() int

func (*CertificateAuthorityBackend_DpCert_Rotation) XXX_Unmarshal 

func (m *CertificateAuthorityBackend_DpCert_Rotation) XXX_Unmarshal(b []byte) error

type CertificateAuthorityBackend_DpCert_RotationValidationError 

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

CertificateAuthorityBackend_DpCert_RotationValidationError is the validation error returned by CertificateAuthorityBackend_DpCert_Rotation.Validate if the designated constraints aren't met.

func (CertificateAuthorityBackend_DpCert_RotationValidationError) Cause 

func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Cause() error

Cause function returns cause value.

func (CertificateAuthorityBackend_DpCert_RotationValidationError) Error 

func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Error() string

Error satisfies the builtin error interface

func (CertificateAuthorityBackend_DpCert_RotationValidationError) ErrorName 

func (e CertificateAuthorityBackend_DpCert_RotationValidationError) ErrorName() string

ErrorName returns error name.

func (CertificateAuthorityBackend_DpCert_RotationValidationError) Field 

func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Field() string

Field function returns field value.

func (CertificateAuthorityBackend_DpCert_RotationValidationError) Key 

func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Key() bool

Key function returns key value.

func (CertificateAuthorityBackend_DpCert_RotationValidationError) Reason 

func (e CertificateAuthorityBackend_DpCert_RotationValidationError) Reason() string

Reason function returns reason value.

type CircuitBreaker 

type CircuitBreaker struct {
	// List of selectors to match dataplanes that are sources of traffic.
	Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	// List of selectors to match services that are destinations of traffic.
	Destinations         []*Selector          `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"`
	Conf                 *CircuitBreaker_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

CircuitBreaker defines circuit breaking policy for dataplane's outbound

func (*CircuitBreaker) Descriptor 

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

func (*CircuitBreaker) GetConf 

func (m *CircuitBreaker) GetConf() *CircuitBreaker_Conf

func (*CircuitBreaker) GetDestinations 

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

func (*CircuitBreaker) GetSources 

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

func (*CircuitBreaker) ProtoMessage 

func (*CircuitBreaker) ProtoMessage()

func (*CircuitBreaker) Reset 

func (m *CircuitBreaker) Reset()

func (*CircuitBreaker) String 

func (m *CircuitBreaker) String() string

func (*CircuitBreaker) XXX_DiscardUnknown 

func (m *CircuitBreaker) XXX_DiscardUnknown()

func (*CircuitBreaker) XXX_Marshal 

func (m *CircuitBreaker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CircuitBreaker) XXX_Merge 

func (m *CircuitBreaker) XXX_Merge(src proto.Message)

func (*CircuitBreaker) XXX_Size 

func (m *CircuitBreaker) XXX_Size() int

func (*CircuitBreaker) XXX_Unmarshal 

func (m *CircuitBreaker) XXX_Unmarshal(b []byte) error

type CircuitBreaker_Conf 

type CircuitBreaker_Conf struct {
	// Time interval between ejection analysis sweeps
	Interval *duration.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// The base time that a host is ejected for. The real time is equal to the
	// base time multiplied by the number of times the host has been ejected
	BaseEjectionTime *duration.Duration `protobuf:"bytes,2,opt,name=baseEjectionTime,proto3" json:"baseEjectionTime,omitempty"`
	// The maximum percent of an upstream cluster that can be ejected due to
	// outlier detection, has to be in [0 - 100] range
	MaxEjectionPercent *wrappers.UInt32Value `protobuf:"bytes,3,opt,name=maxEjectionPercent,proto3" json:"maxEjectionPercent,omitempty"`
	// Enables Split Mode in which local and external errors are distinguished
	SplitExternalAndLocalErrors bool                           `protobuf:"varint,4,opt,name=splitExternalAndLocalErrors,proto3" json:"splitExternalAndLocalErrors,omitempty"`
	Detectors                   *CircuitBreaker_Conf_Detectors `protobuf:"bytes,5,opt,name=detectors,proto3" json:"detectors,omitempty"`
	XXX_NoUnkeyedLiteral        struct{}                       `json:"-"`
	XXX_unrecognized            []byte                         `json:"-"`
	XXX_sizecache               int32                          `json:"-"`
}

func (*CircuitBreaker_Conf) Descriptor 

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

func (*CircuitBreaker_Conf) GetBaseEjectionTime 

func (m *CircuitBreaker_Conf) GetBaseEjectionTime() *duration.Duration

func (*CircuitBreaker_Conf) GetDetectors 

func (m *CircuitBreaker_Conf) GetDetectors() *CircuitBreaker_Conf_Detectors

func (*CircuitBreaker_Conf) GetInterval 

func (m *CircuitBreaker_Conf) GetInterval() *duration.Duration

func (*CircuitBreaker_Conf) GetMaxEjectionPercent 

func (m *CircuitBreaker_Conf) GetMaxEjectionPercent() *wrappers.UInt32Value

func (*CircuitBreaker_Conf) GetSplitExternalAndLocalErrors 

func (m *CircuitBreaker_Conf) GetSplitExternalAndLocalErrors() bool

func (*CircuitBreaker_Conf) ProtoMessage 

func (*CircuitBreaker_Conf) ProtoMessage()

func (*CircuitBreaker_Conf) Reset 

func (m *CircuitBreaker_Conf) Reset()

func (*CircuitBreaker_Conf) String 

func (m *CircuitBreaker_Conf) String() string

func (*CircuitBreaker_Conf) XXX_DiscardUnknown 

func (m *CircuitBreaker_Conf) XXX_DiscardUnknown()

func (*CircuitBreaker_Conf) XXX_Marshal 

func (m *CircuitBreaker_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CircuitBreaker_Conf) XXX_Merge 

func (m *CircuitBreaker_Conf) XXX_Merge(src proto.Message)

func (*CircuitBreaker_Conf) XXX_Size 

func (m *CircuitBreaker_Conf) XXX_Size() int

func (*CircuitBreaker_Conf) XXX_Unmarshal 

func (m *CircuitBreaker_Conf) XXX_Unmarshal(b []byte) error

type CircuitBreaker_Conf_Detectors 

type CircuitBreaker_Conf_Detectors struct {
	// Errors with status code 5xx and locally originated errors, in Split
	// Mode - just errors with status code 5xx
	TotalErrors *CircuitBreaker_Conf_Detectors_Errors `protobuf:"bytes,1,opt,name=totalErrors,proto3" json:"totalErrors,omitempty"`
	// Subset of 'total' related to gateway errors (502, 503 or 504 status
	// code)
	GatewayErrors *CircuitBreaker_Conf_Detectors_Errors `protobuf:"bytes,2,opt,name=gatewayErrors,proto3" json:"gatewayErrors,omitempty"`
	// Takes into account only in Split Mode, number of locally originated
	// errors
	LocalErrors          *CircuitBreaker_Conf_Detectors_Errors            `protobuf:"bytes,3,opt,name=localErrors,proto3" json:"localErrors,omitempty"`
	StandardDeviation    *CircuitBreaker_Conf_Detectors_StandardDeviation `protobuf:"bytes,4,opt,name=standardDeviation,proto3" json:"standardDeviation,omitempty"`
	Failure              *CircuitBreaker_Conf_Detectors_Failure           `protobuf:"bytes,5,opt,name=failure,proto3" json:"failure,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
	XXX_unrecognized     []byte                                           `json:"-"`
	XXX_sizecache        int32                                            `json:"-"`
}

func (*CircuitBreaker_Conf_Detectors) Descriptor 

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

func (*CircuitBreaker_Conf_Detectors) GetFailure 

func (m *CircuitBreaker_Conf_Detectors) GetFailure() *CircuitBreaker_Conf_Detectors_Failure

func (*CircuitBreaker_Conf_Detectors) GetGatewayErrors 

func (m *CircuitBreaker_Conf_Detectors) GetGatewayErrors() *CircuitBreaker_Conf_Detectors_Errors

func (*CircuitBreaker_Conf_Detectors) GetLocalErrors 

func (m *CircuitBreaker_Conf_Detectors) GetLocalErrors() *CircuitBreaker_Conf_Detectors_Errors

func (*CircuitBreaker_Conf_Detectors) GetStandardDeviation 

func (m *CircuitBreaker_Conf_Detectors) GetStandardDeviation() *CircuitBreaker_Conf_Detectors_StandardDeviation

func (*CircuitBreaker_Conf_Detectors) GetTotalErrors 

func (m *CircuitBreaker_Conf_Detectors) GetTotalErrors() *CircuitBreaker_Conf_Detectors_Errors

func (*CircuitBreaker_Conf_Detectors) ProtoMessage 

func (*CircuitBreaker_Conf_Detectors) ProtoMessage()

func (*CircuitBreaker_Conf_Detectors) Reset 

func (m *CircuitBreaker_Conf_Detectors) Reset()

func (*CircuitBreaker_Conf_Detectors) String 

func (m *CircuitBreaker_Conf_Detectors) String() string

func (*CircuitBreaker_Conf_Detectors) XXX_DiscardUnknown 

func (m *CircuitBreaker_Conf_Detectors) XXX_DiscardUnknown()

func (*CircuitBreaker_Conf_Detectors) XXX_Marshal 

func (m *CircuitBreaker_Conf_Detectors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CircuitBreaker_Conf_Detectors) XXX_Merge 

func (m *CircuitBreaker_Conf_Detectors) XXX_Merge(src proto.Message)

func (*CircuitBreaker_Conf_Detectors) XXX_Size 

func (m *CircuitBreaker_Conf_Detectors) XXX_Size() int

func (*CircuitBreaker_Conf_Detectors) XXX_Unmarshal 

func (m *CircuitBreaker_Conf_Detectors) XXX_Unmarshal(b []byte) error

type CircuitBreaker_Conf_Detectors_Errors 

type CircuitBreaker_Conf_Detectors_Errors struct {
	Consecutive          *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=consecutive,proto3" json:"consecutive,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Detector based on counting consecutive number of errors

func (*CircuitBreaker_Conf_Detectors_Errors) Descriptor 

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

func (*CircuitBreaker_Conf_Detectors_Errors) GetConsecutive 

func (m *CircuitBreaker_Conf_Detectors_Errors) GetConsecutive() *wrappers.UInt32Value

func (*CircuitBreaker_Conf_Detectors_Errors) ProtoMessage 

func (*CircuitBreaker_Conf_Detectors_Errors) ProtoMessage()

func (*CircuitBreaker_Conf_Detectors_Errors) Reset 

func (m *CircuitBreaker_Conf_Detectors_Errors) Reset()

func (*CircuitBreaker_Conf_Detectors_Errors) String 

func (m *CircuitBreaker_Conf_Detectors_Errors) String() string

func (*CircuitBreaker_Conf_Detectors_Errors) XXX_DiscardUnknown 

func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_DiscardUnknown()

func (*CircuitBreaker_Conf_Detectors_Errors) XXX_Marshal 

func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CircuitBreaker_Conf_Detectors_Errors) XXX_Merge 

func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_Merge(src proto.Message)

func (*CircuitBreaker_Conf_Detectors_Errors) XXX_Size 

func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_Size() int

func (*CircuitBreaker_Conf_Detectors_Errors) XXX_Unmarshal 

func (m *CircuitBreaker_Conf_Detectors_Errors) XXX_Unmarshal(b []byte) error

type CircuitBreaker_Conf_Detectors_Failure 

type CircuitBreaker_Conf_Detectors_Failure struct {
	// Ignore hosts with less number of requests than 'requestVolume'
	RequestVolume *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=requestVolume,proto3" json:"requestVolume,omitempty"`
	// Won't count success rate for cluster if number of hosts with required
	// 'requestVolume' is less than 'minimumHosts'
	MinimumHosts *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=minimumHosts,proto3" json:"minimumHosts,omitempty"`
	// Eject host if failure percentage of a given host is greater than or
	// equal to this value, has to be in [0 - 100] range
	Threshold            *wrappers.UInt32Value `protobuf:"bytes,3,opt,name=threshold,proto3" json:"threshold,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

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

func (*CircuitBreaker_Conf_Detectors_Failure) Descriptor 

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

func (*CircuitBreaker_Conf_Detectors_Failure) GetMinimumHosts 

func (m *CircuitBreaker_Conf_Detectors_Failure) GetMinimumHosts() *wrappers.UInt32Value

func (*CircuitBreaker_Conf_Detectors_Failure) GetRequestVolume 

func (m *CircuitBreaker_Conf_Detectors_Failure) GetRequestVolume() *wrappers.UInt32Value

func (*CircuitBreaker_Conf_Detectors_Failure) GetThreshold 

func (m *CircuitBreaker_Conf_Detectors_Failure) GetThreshold() *wrappers.UInt32Value

func (*CircuitBreaker_Conf_Detectors_Failure) ProtoMessage 

func (*CircuitBreaker_Conf_Detectors_Failure) ProtoMessage()

func (*CircuitBreaker_Conf_Detectors_Failure) Reset 

func (m *CircuitBreaker_Conf_Detectors_Failure) Reset()

func (*CircuitBreaker_Conf_Detectors_Failure) String 

func (m *CircuitBreaker_Conf_Detectors_Failure) String() string

func (*CircuitBreaker_Conf_Detectors_Failure) XXX_DiscardUnknown 

func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_DiscardUnknown()

func (*CircuitBreaker_Conf_Detectors_Failure) XXX_Marshal 

func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CircuitBreaker_Conf_Detectors_Failure) XXX_Merge 

func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_Merge(src proto.Message)

func (*CircuitBreaker_Conf_Detectors_Failure) XXX_Size 

func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_Size() int

func (*CircuitBreaker_Conf_Detectors_Failure) XXX_Unmarshal 

func (m *CircuitBreaker_Conf_Detectors_Failure) XXX_Unmarshal(b []byte) error

type CircuitBreaker_Conf_Detectors_StandardDeviation 

type CircuitBreaker_Conf_Detectors_StandardDeviation struct {
	// Ignore hosts with less number of requests than 'requestVolume'
	RequestVolume *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=requestVolume,proto3" json:"requestVolume,omitempty"`
	// Won't count success rate for cluster if number of hosts with required
	// 'requestVolume' is less than 'minimumHosts'
	MinimumHosts *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=minimumHosts,proto3" json:"minimumHosts,omitempty"`
	// Resulting threshold = mean - (stdev * factor)
	Factor               *wrappers.DoubleValue `protobuf:"bytes,3,opt,name=factor,proto3" json:"factor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

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

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) Descriptor 

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

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) GetFactor 

func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) GetFactor() *wrappers.DoubleValue

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) GetMinimumHosts 

func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) GetMinimumHosts() *wrappers.UInt32Value

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) GetRequestVolume 

func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) GetRequestVolume() *wrappers.UInt32Value

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) ProtoMessage 

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) ProtoMessage()

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) Reset 

func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) Reset()

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) String 

func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) String() string

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_DiscardUnknown 

func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_DiscardUnknown()

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Marshal 

func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Merge 

func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Merge(src proto.Message)

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Size 

func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Size() int

func (*CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Unmarshal 

func (m *CircuitBreaker_Conf_Detectors_StandardDeviation) XXX_Unmarshal(b []byte) error

type Dataplane 

type Dataplane struct {
	// Networking describes inbound and outbound interfaces of the dataplane.
	Networking *Dataplane_Networking `protobuf:"bytes,1,opt,name=networking,proto3" json:"networking,omitempty"`
	// Configuration for metrics that should be collected and exposed by the
	// dataplane.
	//
	// Settings defined here will override their respective defaults
	// defined at a Mesh level.
	Metrics              *MetricsBackend `protobuf:"bytes,2,opt,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Dataplane defines configuration of a side-car proxy.

func (*Dataplane) Descriptor 

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

func (*Dataplane) GetIdentifyingService 

func (d *Dataplane) GetIdentifyingService() string

func (*Dataplane) GetMetrics 

func (m *Dataplane) GetMetrics() *MetricsBackend

func (*Dataplane) GetNetworking 

func (m *Dataplane) GetNetworking() *Dataplane_Networking

func (*Dataplane) HasAvailableServices 

func (d *Dataplane) HasAvailableServices() bool

func (*Dataplane) IsIngress 

func (d *Dataplane) IsIngress() bool

func (*Dataplane) IsRemoteIngress 

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

func (*Dataplane) MatchTags 

func (d *Dataplane) MatchTags(selector TagSelector) bool

func (*Dataplane) Matches 

func (d *Dataplane) Matches(selector TagSelector) bool

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

func (*Dataplane) ProtoMessage 

func (*Dataplane) ProtoMessage()

func (*Dataplane) Reset 

func (m *Dataplane) Reset()

func (*Dataplane) String 

func (m *Dataplane) String() string

func (*Dataplane) Tags 

func (d *Dataplane) Tags() MultiValueTagSet

func (*Dataplane) Validate 

func (m *Dataplane) Validate() error

Validate checks the field values on Dataplane with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Dataplane) XXX_DiscardUnknown 

func (m *Dataplane) XXX_DiscardUnknown()

func (*Dataplane) XXX_Marshal 

func (m *Dataplane) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dataplane) XXX_Merge 

func (m *Dataplane) XXX_Merge(src proto.Message)

func (*Dataplane) XXX_Size 

func (m *Dataplane) XXX_Size() int

func (*Dataplane) XXX_Unmarshal 

func (m *Dataplane) XXX_Unmarshal(b []byte) error

type DataplaneInsight 

type DataplaneInsight struct {
	// List of ADS subscriptions created by a given Dataplane.
	Subscriptions []*DiscoverySubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// Insights about mTLS for Dataplane.
	MTLS                 *DataplaneInsight_MTLS `protobuf:"bytes,2,opt,name=mTLS,proto3" json:"mTLS,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

DataplaneInsight defines the observed state of a Dataplane.

func (*DataplaneInsight) Descriptor 

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

func (*DataplaneInsight) GetLatestSubscription 

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

func (*DataplaneInsight) GetMTLS 

func (m *DataplaneInsight) GetMTLS() *DataplaneInsight_MTLS

func (*DataplaneInsight) GetSubscription 

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

func (*DataplaneInsight) GetSubscriptions 

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

func (*DataplaneInsight) IsOnline 

func (ds *DataplaneInsight) IsOnline() bool

func (*DataplaneInsight) ProtoMessage 

func (*DataplaneInsight) ProtoMessage()

func (*DataplaneInsight) Reset 

func (m *DataplaneInsight) Reset()

func (*DataplaneInsight) String 

func (m *DataplaneInsight) String() string

func (*DataplaneInsight) Sum 

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

func (*DataplaneInsight) UpdateCert 

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

func (*DataplaneInsight) UpdateSubscription 

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

func (*DataplaneInsight) XXX_DiscardUnknown 

func (m *DataplaneInsight) XXX_DiscardUnknown()

func (*DataplaneInsight) XXX_Marshal 

func (m *DataplaneInsight) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataplaneInsight) XXX_Merge 

func (m *DataplaneInsight) XXX_Merge(src proto.Message)

func (*DataplaneInsight) XXX_Size 

func (m *DataplaneInsight) XXX_Size() int

func (*DataplaneInsight) XXX_Unmarshal 

func (m *DataplaneInsight) XXX_Unmarshal(b []byte) error

type DataplaneInsight_MTLS 

type DataplaneInsight_MTLS struct {
	// Expiration time of the last certificate that was generated for a
	// Dataplane.
	CertificateExpirationTime *timestamp.Timestamp `` /* 138-byte string literal not displayed */
	// Time on which the last certificate was generated.
	LastCertificateRegeneration *timestamp.Timestamp `` /* 144-byte string literal not displayed */
	// Number of certificate regenerations for a Dataplane.
	CertificateRegenerations uint32   `` /* 134-byte string literal not displayed */
	XXX_NoUnkeyedLiteral     struct{} `json:"-"`
	XXX_unrecognized         []byte   `json:"-"`
	XXX_sizecache            int32    `json:"-"`
}

MTLS defines insights for mTLS

func (*DataplaneInsight_MTLS) Descriptor 

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

func (*DataplaneInsight_MTLS) GetCertificateExpirationTime 

func (m *DataplaneInsight_MTLS) GetCertificateExpirationTime() *timestamp.Timestamp

func (*DataplaneInsight_MTLS) GetCertificateRegenerations 

func (m *DataplaneInsight_MTLS) GetCertificateRegenerations() uint32

func (*DataplaneInsight_MTLS) GetLastCertificateRegeneration 

func (m *DataplaneInsight_MTLS) GetLastCertificateRegeneration() *timestamp.Timestamp

func (*DataplaneInsight_MTLS) ProtoMessage 

func (*DataplaneInsight_MTLS) ProtoMessage()

func (*DataplaneInsight_MTLS) Reset 

func (m *DataplaneInsight_MTLS) Reset()

func (*DataplaneInsight_MTLS) String 

func (m *DataplaneInsight_MTLS) String() string

func (*DataplaneInsight_MTLS) XXX_DiscardUnknown 

func (m *DataplaneInsight_MTLS) XXX_DiscardUnknown()

func (*DataplaneInsight_MTLS) XXX_Marshal 

func (m *DataplaneInsight_MTLS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataplaneInsight_MTLS) XXX_Merge 

func (m *DataplaneInsight_MTLS) XXX_Merge(src proto.Message)

func (*DataplaneInsight_MTLS) XXX_Size 

func (m *DataplaneInsight_MTLS) XXX_Size() int

func (*DataplaneInsight_MTLS) XXX_Unmarshal 

func (m *DataplaneInsight_MTLS) XXX_Unmarshal(b []byte) error

type DataplaneOverview 

type DataplaneOverview struct {
	Dataplane            *Dataplane        `protobuf:"bytes,1,opt,name=dataplane,proto3" json:"dataplane,omitempty"`
	DataplaneInsight     *DataplaneInsight `protobuf:"bytes,2,opt,name=dataplane_insight,json=dataplaneInsight,proto3" json:"dataplane_insight,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

DataplaneOverview defines the projected state of a Dataplane.

func (*DataplaneOverview) Descriptor 

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

func (*DataplaneOverview) GetDataplane 

func (m *DataplaneOverview) GetDataplane() *Dataplane

func (*DataplaneOverview) GetDataplaneInsight 

func (m *DataplaneOverview) GetDataplaneInsight() *DataplaneInsight

func (*DataplaneOverview) ProtoMessage 

func (*DataplaneOverview) ProtoMessage()

func (*DataplaneOverview) Reset 

func (m *DataplaneOverview) Reset()

func (*DataplaneOverview) String 

func (m *DataplaneOverview) String() string

func (*DataplaneOverview) XXX_DiscardUnknown 

func (m *DataplaneOverview) XXX_DiscardUnknown()

func (*DataplaneOverview) XXX_Marshal 

func (m *DataplaneOverview) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataplaneOverview) XXX_Merge 

func (m *DataplaneOverview) XXX_Merge(src proto.Message)

func (*DataplaneOverview) XXX_Size 

func (m *DataplaneOverview) XXX_Size() int

func (*DataplaneOverview) XXX_Unmarshal 

func (m *DataplaneOverview) XXX_Unmarshal(b []byte) error

type DataplaneValidationError 

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

DataplaneValidationError is the validation error returned by Dataplane.Validate if the designated constraints aren't met.

func (DataplaneValidationError) Cause 

func (e DataplaneValidationError) Cause() error

Cause function returns cause value.

func (DataplaneValidationError) Error 

func (e DataplaneValidationError) Error() string

Error satisfies the builtin error interface

func (DataplaneValidationError) ErrorName 

func (e DataplaneValidationError) ErrorName() string

ErrorName returns error name.

func (DataplaneValidationError) Field 

func (e DataplaneValidationError) Field() string

Field function returns field value.

func (DataplaneValidationError) Key 

func (e DataplaneValidationError) Key() bool

Key function returns key value.

func (DataplaneValidationError) Reason 

func (e DataplaneValidationError) Reason() string

Reason function returns reason value.

type Dataplane_Networking 

type Dataplane_Networking struct {
	// Ingress if not nil, dataplane will be work in the Ingress mode
	Ingress *Dataplane_Networking_Ingress `protobuf:"bytes,6,opt,name=ingress,proto3" json:"ingress,omitempty"`
	// Public IP on which the dataplane is accessible in the network.
	// Host names and DNS are not allowed.
	Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// Gateway describes configuration of gateway of the dataplane.
	Gateway *Dataplane_Networking_Gateway `protobuf:"bytes,3,opt,name=gateway,proto3" json:"gateway,omitempty"`
	// Inbound describes a list of inbound interfaces of the dataplane.
	Inbound []*Dataplane_Networking_Inbound `protobuf:"bytes,1,rep,name=inbound,proto3" json:"inbound,omitempty"`
	// Outbound describes a list of outbound interfaces of the dataplane.
	Outbound []*Dataplane_Networking_Outbound `protobuf:"bytes,2,rep,name=outbound,proto3" json:"outbound,omitempty"`
	// TransparentProxying describes configuration for transparent proxying.
	TransparentProxying  *Dataplane_Networking_TransparentProxying `protobuf:"bytes,4,opt,name=transparent_proxying,json=transparentProxying,proto3" json:"transparent_proxying,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                  `json:"-"`
	XXX_unrecognized     []byte                                    `json:"-"`
	XXX_sizecache        int32                                     `json:"-"`
}

Networking describes inbound and outbound interfaces of a dataplane.

func (*Dataplane_Networking) Descriptor 

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

func (*Dataplane_Networking) GetAddress 

func (m *Dataplane_Networking) GetAddress() string

func (*Dataplane_Networking) GetGateway 

func (m *Dataplane_Networking) GetGateway() *Dataplane_Networking_Gateway

func (*Dataplane_Networking) GetInbound 

func (m *Dataplane_Networking) GetInbound() []*Dataplane_Networking_Inbound

func (*Dataplane_Networking) GetInboundInterface 

func (n *Dataplane_Networking) GetInboundInterface(service string) (*InboundInterface, error)

func (*Dataplane_Networking) GetInboundInterfaces 

func (n *Dataplane_Networking) GetInboundInterfaces() ([]InboundInterface, error)

func (*Dataplane_Networking) GetIngress 

func (m *Dataplane_Networking) GetIngress() *Dataplane_Networking_Ingress

func (*Dataplane_Networking) GetOutbound 

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

func (*Dataplane_Networking) GetOutboundInterfaces 

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

func (*Dataplane_Networking) GetTransparentProxying 

func (m *Dataplane_Networking) GetTransparentProxying() *Dataplane_Networking_TransparentProxying

func (*Dataplane_Networking) ProtoMessage 

func (*Dataplane_Networking) ProtoMessage()

func (*Dataplane_Networking) Reset 

func (m *Dataplane_Networking) Reset()

func (*Dataplane_Networking) String 

func (m *Dataplane_Networking) String() string

func (*Dataplane_Networking) ToInboundInterface 

func (n *Dataplane_Networking) ToInboundInterface(inbound *Dataplane_Networking_Inbound) InboundInterface

func (*Dataplane_Networking) ToOutboundInterface 

func (n *Dataplane_Networking) ToOutboundInterface(outbound *Dataplane_Networking_Outbound) OutboundInterface

func (*Dataplane_Networking) Validate 

func (m *Dataplane_Networking) Validate() error

Validate checks the field values on Dataplane_Networking with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Dataplane_Networking) XXX_DiscardUnknown 

func (m *Dataplane_Networking) XXX_DiscardUnknown()

func (*Dataplane_Networking) XXX_Marshal 

func (m *Dataplane_Networking) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dataplane_Networking) XXX_Merge 

func (m *Dataplane_Networking) XXX_Merge(src proto.Message)

func (*Dataplane_Networking) XXX_Size 

func (m *Dataplane_Networking) XXX_Size() int

func (*Dataplane_Networking) XXX_Unmarshal 

func (m *Dataplane_Networking) XXX_Unmarshal(b []byte) error

type Dataplane_NetworkingValidationError 

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

Dataplane_NetworkingValidationError is the validation error returned by Dataplane_Networking.Validate if the designated constraints aren't met.

func (Dataplane_NetworkingValidationError) Cause 

func (e Dataplane_NetworkingValidationError) Cause() error

Cause function returns cause value.

func (Dataplane_NetworkingValidationError) Error 

func (e Dataplane_NetworkingValidationError) Error() string

Error satisfies the builtin error interface

func (Dataplane_NetworkingValidationError) ErrorName 

func (e Dataplane_NetworkingValidationError) ErrorName() string

ErrorName returns error name.

func (Dataplane_NetworkingValidationError) Field 

func (e Dataplane_NetworkingValidationError) Field() string

Field function returns field value.

func (Dataplane_NetworkingValidationError) Key 

func (e Dataplane_NetworkingValidationError) Key() bool

Key function returns key value.

func (Dataplane_NetworkingValidationError) Reason 

func (e Dataplane_NetworkingValidationError) Reason() string

Reason function returns reason value.

type Dataplane_Networking_Gateway 

type Dataplane_Networking_Gateway struct {
	// Tags associated with a gateway (e.g., Kong, Contour, etc) this
	// dataplane is deployed next to, e.g. service=gateway, env=prod.
	// `service` tag is mandatory.
	Tags                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Gateway describes a service that ingress should not be proxied.

func (*Dataplane_Networking_Gateway) Descriptor 

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

func (*Dataplane_Networking_Gateway) GetTags 

func (m *Dataplane_Networking_Gateway) GetTags() map[string]string

func (*Dataplane_Networking_Gateway) MatchTags 

func (d *Dataplane_Networking_Gateway) MatchTags(selector TagSelector) bool

func (*Dataplane_Networking_Gateway) ProtoMessage 

func (*Dataplane_Networking_Gateway) ProtoMessage()

func (*Dataplane_Networking_Gateway) Reset 

func (m *Dataplane_Networking_Gateway) Reset()

func (*Dataplane_Networking_Gateway) String 

func (m *Dataplane_Networking_Gateway) String() string

func (*Dataplane_Networking_Gateway) Validate 

func (m *Dataplane_Networking_Gateway) Validate() error

Validate checks the field values on Dataplane_Networking_Gateway with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Dataplane_Networking_Gateway) XXX_DiscardUnknown 

func (m *Dataplane_Networking_Gateway) XXX_DiscardUnknown()

func (*Dataplane_Networking_Gateway) XXX_Marshal 

func (m *Dataplane_Networking_Gateway) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dataplane_Networking_Gateway) XXX_Merge 

func (m *Dataplane_Networking_Gateway) XXX_Merge(src proto.Message)

func (*Dataplane_Networking_Gateway) XXX_Size 

func (m *Dataplane_Networking_Gateway) XXX_Size() int

func (*Dataplane_Networking_Gateway) XXX_Unmarshal 

func (m *Dataplane_Networking_Gateway) XXX_Unmarshal(b []byte) error

type Dataplane_Networking_GatewayValidationError 

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

Dataplane_Networking_GatewayValidationError is the validation error returned by Dataplane_Networking_Gateway.Validate if the designated constraints aren't met.

func (Dataplane_Networking_GatewayValidationError) Cause 

func (e Dataplane_Networking_GatewayValidationError) Cause() error

Cause function returns cause value.

func (Dataplane_Networking_GatewayValidationError) Error 

func (e Dataplane_Networking_GatewayValidationError) Error() string

Error satisfies the builtin error interface

func (Dataplane_Networking_GatewayValidationError) ErrorName 

func (e Dataplane_Networking_GatewayValidationError) ErrorName() string

ErrorName returns error name.

func (Dataplane_Networking_GatewayValidationError) Field 

func (e Dataplane_Networking_GatewayValidationError) Field() string

Field function returns field value.

func (Dataplane_Networking_GatewayValidationError) Key 

func (e Dataplane_Networking_GatewayValidationError) Key() bool

Key function returns key value.

func (Dataplane_Networking_GatewayValidationError) Reason 

func (e Dataplane_Networking_GatewayValidationError) Reason() string

Reason function returns reason value.

type Dataplane_Networking_Inbound 

type Dataplane_Networking_Inbound struct {
	// Port of the inbound interface that will forward requests to the
	// service.
	Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// Port of the service that requests will be forwarded to.
	ServicePort uint32 `protobuf:"varint,4,opt,name=servicePort,proto3" json:"servicePort,omitempty"`
	// Address on which inbound listener will be exposed. Defaults to
	// networking.address.
	Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// Tags associated with an application this dataplane is deployed next to,
	// e.g. service=web, version=1.0.
	// `service` tag is mandatory.
	Tags                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Inbound describes a service implemented by the dataplane.

func (*Dataplane_Networking_Inbound) Descriptor 

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

func (*Dataplane_Networking_Inbound) GetAddress 

func (m *Dataplane_Networking_Inbound) GetAddress() string

func (*Dataplane_Networking_Inbound) GetPort 

func (m *Dataplane_Networking_Inbound) GetPort() uint32

func (*Dataplane_Networking_Inbound) GetProtocol 

func (d *Dataplane_Networking_Inbound) GetProtocol() string

GetProtocol returns a protocol supported by this inbound interface.

The purpose of this method is to encapsulate implementation detail that protocol is modeled as a tag rather than a separate field.

func (*Dataplane_Networking_Inbound) GetService 

func (d *Dataplane_Networking_Inbound) GetService() string

GetService returns a service represented by this inbound interface.

The purpose of this method is to encapsulate implementation detail that service is modeled as a tag rather than a separate field.

func (*Dataplane_Networking_Inbound) GetServicePort 

func (m *Dataplane_Networking_Inbound) GetServicePort() uint32

func (*Dataplane_Networking_Inbound) GetTags 

func (m *Dataplane_Networking_Inbound) GetTags() map[string]string

func (*Dataplane_Networking_Inbound) MatchTags 

func (d *Dataplane_Networking_Inbound) MatchTags(selector TagSelector) bool

func (*Dataplane_Networking_Inbound) ProtoMessage 

func (*Dataplane_Networking_Inbound) ProtoMessage()

func (*Dataplane_Networking_Inbound) Reset 

func (m *Dataplane_Networking_Inbound) Reset()

func (*Dataplane_Networking_Inbound) String 

func (m *Dataplane_Networking_Inbound) String() string

func (*Dataplane_Networking_Inbound) Validate 

func (m *Dataplane_Networking_Inbound) Validate() error

Validate checks the field values on Dataplane_Networking_Inbound with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Dataplane_Networking_Inbound) XXX_DiscardUnknown 

func (m *Dataplane_Networking_Inbound) XXX_DiscardUnknown()

func (*Dataplane_Networking_Inbound) XXX_Marshal 

func (m *Dataplane_Networking_Inbound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dataplane_Networking_Inbound) XXX_Merge 

func (m *Dataplane_Networking_Inbound) XXX_Merge(src proto.Message)

func (*Dataplane_Networking_Inbound) XXX_Size 

func (m *Dataplane_Networking_Inbound) XXX_Size() int

func (*Dataplane_Networking_Inbound) XXX_Unmarshal 

func (m *Dataplane_Networking_Inbound) XXX_Unmarshal(b []byte) error

type Dataplane_Networking_InboundValidationError 

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

Dataplane_Networking_InboundValidationError is the validation error returned by Dataplane_Networking_Inbound.Validate if the designated constraints aren't met.

func (Dataplane_Networking_InboundValidationError) Cause 

func (e Dataplane_Networking_InboundValidationError) Cause() error

Cause function returns cause value.

func (Dataplane_Networking_InboundValidationError) Error 

func (e Dataplane_Networking_InboundValidationError) Error() string

Error satisfies the builtin error interface

func (Dataplane_Networking_InboundValidationError) ErrorName 

func (e Dataplane_Networking_InboundValidationError) ErrorName() string

ErrorName returns error name.

func (Dataplane_Networking_InboundValidationError) Field 

func (e Dataplane_Networking_InboundValidationError) Field() string

Field function returns field value.

func (Dataplane_Networking_InboundValidationError) Key 

func (e Dataplane_Networking_InboundValidationError) Key() bool

Key function returns key value.

func (Dataplane_Networking_InboundValidationError) Reason 

func (e Dataplane_Networking_InboundValidationError) Reason() string

Reason function returns reason value.

type Dataplane_Networking_Ingress 

type Dataplane_Networking_Ingress struct {
	AvailableServices    []*Dataplane_Networking_Ingress_AvailableService `protobuf:"bytes,1,rep,name=availableServices,proto3" json:"availableServices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
	XXX_unrecognized     []byte                                           `json:"-"`
	XXX_sizecache        int32                                            `json:"-"`
}

Ingress allows us to configure dataplane in the Ingress mode. In this mode, dataplane has only inbound interfaces (outbound and gateway prohibited). Every inbound interface matches with services that reside in that cluster.

func (*Dataplane_Networking_Ingress) Descriptor 

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

func (*Dataplane_Networking_Ingress) GetAvailableServices 

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

func (*Dataplane_Networking_Ingress) ProtoMessage 

func (*Dataplane_Networking_Ingress) ProtoMessage()

func (*Dataplane_Networking_Ingress) Reset 

func (m *Dataplane_Networking_Ingress) Reset()

func (*Dataplane_Networking_Ingress) String 

func (m *Dataplane_Networking_Ingress) String() string

func (*Dataplane_Networking_Ingress) Validate 

func (m *Dataplane_Networking_Ingress) Validate() error

Validate checks the field values on Dataplane_Networking_Ingress with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Dataplane_Networking_Ingress) XXX_DiscardUnknown 

func (m *Dataplane_Networking_Ingress) XXX_DiscardUnknown()

func (*Dataplane_Networking_Ingress) XXX_Marshal 

func (m *Dataplane_Networking_Ingress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dataplane_Networking_Ingress) XXX_Merge 

func (m *Dataplane_Networking_Ingress) XXX_Merge(src proto.Message)

func (*Dataplane_Networking_Ingress) XXX_Size 

func (m *Dataplane_Networking_Ingress) XXX_Size() int

func (*Dataplane_Networking_Ingress) XXX_Unmarshal 

func (m *Dataplane_Networking_Ingress) XXX_Unmarshal(b []byte) error

type Dataplane_Networking_IngressValidationError 

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

Dataplane_Networking_IngressValidationError is the validation error returned by Dataplane_Networking_Ingress.Validate if the designated constraints aren't met.

func (Dataplane_Networking_IngressValidationError) Cause 

func (e Dataplane_Networking_IngressValidationError) Cause() error

Cause function returns cause value.

func (Dataplane_Networking_IngressValidationError) Error 

func (e Dataplane_Networking_IngressValidationError) Error() string

Error satisfies the builtin error interface

func (Dataplane_Networking_IngressValidationError) ErrorName 

func (e Dataplane_Networking_IngressValidationError) ErrorName() string

ErrorName returns error name.

func (Dataplane_Networking_IngressValidationError) Field 

func (e Dataplane_Networking_IngressValidationError) Field() string

Field function returns field value.

func (Dataplane_Networking_IngressValidationError) Key 

func (e Dataplane_Networking_IngressValidationError) Key() bool

Key function returns key value.

func (Dataplane_Networking_IngressValidationError) Reason 

func (e Dataplane_Networking_IngressValidationError) Reason() string

Reason function returns reason value.

type Dataplane_Networking_Ingress_AvailableService 

type Dataplane_Networking_Ingress_AvailableService struct {
	// tags of the service
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// number of instances available for given tags
	Instances            uint32   `protobuf:"varint,2,opt,name=instances,proto3" json:"instances,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AvailableService contains tags that represent unique subset of endpoints

func (*Dataplane_Networking_Ingress_AvailableService) Descriptor 

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

func (*Dataplane_Networking_Ingress_AvailableService) GetInstances 

func (m *Dataplane_Networking_Ingress_AvailableService) GetInstances() uint32

func (*Dataplane_Networking_Ingress_AvailableService) GetTags 

func (m *Dataplane_Networking_Ingress_AvailableService) GetTags() map[string]string

func (*Dataplane_Networking_Ingress_AvailableService) ProtoMessage 

func (*Dataplane_Networking_Ingress_AvailableService) ProtoMessage()

func (*Dataplane_Networking_Ingress_AvailableService) Reset 

func (m *Dataplane_Networking_Ingress_AvailableService) Reset()

func (*Dataplane_Networking_Ingress_AvailableService) String 

func (m *Dataplane_Networking_Ingress_AvailableService) String() string

func (*Dataplane_Networking_Ingress_AvailableService) Validate 

func (m *Dataplane_Networking_Ingress_AvailableService) Validate() error

Validate checks the field values on Dataplane_Networking_Ingress_AvailableService with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Dataplane_Networking_Ingress_AvailableService) XXX_DiscardUnknown 

func (m *Dataplane_Networking_Ingress_AvailableService) XXX_DiscardUnknown()

func (*Dataplane_Networking_Ingress_AvailableService) XXX_Marshal 

func (m *Dataplane_Networking_Ingress_AvailableService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dataplane_Networking_Ingress_AvailableService) XXX_Merge 

func (m *Dataplane_Networking_Ingress_AvailableService) XXX_Merge(src proto.Message)

func (*Dataplane_Networking_Ingress_AvailableService) XXX_Size 

func (m *Dataplane_Networking_Ingress_AvailableService) XXX_Size() int

func (*Dataplane_Networking_Ingress_AvailableService) XXX_Unmarshal 

func (m *Dataplane_Networking_Ingress_AvailableService) XXX_Unmarshal(b []byte) error

type Dataplane_Networking_Ingress_AvailableServiceValidationError 

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

Dataplane_Networking_Ingress_AvailableServiceValidationError is the validation error returned by Dataplane_Networking_Ingress_AvailableService.Validate if the designated constraints aren't met.

func (Dataplane_Networking_Ingress_AvailableServiceValidationError) Cause 

func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Cause() error

Cause function returns cause value.

func (Dataplane_Networking_Ingress_AvailableServiceValidationError) Error 

func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Error() string

Error satisfies the builtin error interface

func (Dataplane_Networking_Ingress_AvailableServiceValidationError) ErrorName 

func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) ErrorName() string

ErrorName returns error name.

func (Dataplane_Networking_Ingress_AvailableServiceValidationError) Field 

func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Field() string

Field function returns field value.

func (Dataplane_Networking_Ingress_AvailableServiceValidationError) Key 

func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Key() bool

Key function returns key value.

func (Dataplane_Networking_Ingress_AvailableServiceValidationError) Reason 

func (e Dataplane_Networking_Ingress_AvailableServiceValidationError) Reason() string

Reason function returns reason value.

type Dataplane_Networking_Outbound 

type Dataplane_Networking_Outbound struct {
	// Address on which the service will be available to this dataplane.
	// Defaults to 127.0.0.1
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// Port on which the service will be available to this dataplane.
	Port uint32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// DEPRECATED: use networking.outbound[].tags
	// Service name.
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// Tags
	Tags                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Outbound describes a service consumed by the dataplane.

func (*Dataplane_Networking_Outbound) Descriptor 

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

func (*Dataplane_Networking_Outbound) GetAddress 

func (m *Dataplane_Networking_Outbound) GetAddress() string

func (*Dataplane_Networking_Outbound) GetPort 

func (m *Dataplane_Networking_Outbound) GetPort() uint32

func (*Dataplane_Networking_Outbound) GetService 

func (m *Dataplane_Networking_Outbound) GetService() string

func (*Dataplane_Networking_Outbound) GetTags 

func (m *Dataplane_Networking_Outbound) GetTags() map[string]string

func (*Dataplane_Networking_Outbound) GetTagsIncludingLegacy 

func (d *Dataplane_Networking_Outbound) GetTagsIncludingLegacy() map[string]string

GetTagsIncludingLegacy returns tags but taking on account old legacy format of "service" field in outbound Remove it and migrate to GetTags() once "service" field is removed.

func (*Dataplane_Networking_Outbound) MatchTags 

func (d *Dataplane_Networking_Outbound) MatchTags(selector TagSelector) bool

func (*Dataplane_Networking_Outbound) ProtoMessage 

func (*Dataplane_Networking_Outbound) ProtoMessage()

func (*Dataplane_Networking_Outbound) Reset 

func (m *Dataplane_Networking_Outbound) Reset()

func (*Dataplane_Networking_Outbound) String 

func (m *Dataplane_Networking_Outbound) String() string

func (*Dataplane_Networking_Outbound) Validate 

func (m *Dataplane_Networking_Outbound) Validate() error

Validate checks the field values on Dataplane_Networking_Outbound with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Dataplane_Networking_Outbound) XXX_DiscardUnknown 

func (m *Dataplane_Networking_Outbound) XXX_DiscardUnknown()

func (*Dataplane_Networking_Outbound) XXX_Marshal 

func (m *Dataplane_Networking_Outbound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dataplane_Networking_Outbound) XXX_Merge 

func (m *Dataplane_Networking_Outbound) XXX_Merge(src proto.Message)

func (*Dataplane_Networking_Outbound) XXX_Size 

func (m *Dataplane_Networking_Outbound) XXX_Size() int

func (*Dataplane_Networking_Outbound) XXX_Unmarshal 

func (m *Dataplane_Networking_Outbound) XXX_Unmarshal(b []byte) error

type Dataplane_Networking_OutboundValidationError 

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

Dataplane_Networking_OutboundValidationError is the validation error returned by Dataplane_Networking_Outbound.Validate if the designated constraints aren't met.

func (Dataplane_Networking_OutboundValidationError) Cause 

func (e Dataplane_Networking_OutboundValidationError) Cause() error

Cause function returns cause value.

func (Dataplane_Networking_OutboundValidationError) Error 

func (e Dataplane_Networking_OutboundValidationError) Error() string

Error satisfies the builtin error interface

func (Dataplane_Networking_OutboundValidationError) ErrorName 

func (e Dataplane_Networking_OutboundValidationError) ErrorName() string

ErrorName returns error name.

func (Dataplane_Networking_OutboundValidationError) Field 

func (e Dataplane_Networking_OutboundValidationError) Field() string

Field function returns field value.

func (Dataplane_Networking_OutboundValidationError) Key 

func (e Dataplane_Networking_OutboundValidationError) Key() bool

Key function returns key value.

func (Dataplane_Networking_OutboundValidationError) Reason 

func (e Dataplane_Networking_OutboundValidationError) Reason() string

Reason function returns reason value.

type Dataplane_Networking_TransparentProxying 

type Dataplane_Networking_TransparentProxying struct {
	// Port on which all traffic is being transparently redirected.
	RedirectPort uint32 `protobuf:"varint,1,opt,name=redirect_port,json=redirectPort,proto3" json:"redirect_port,omitempty"`
	// List of services that will be access directly via IP:PORT
	DirectAccessServices []string `protobuf:"bytes,2,rep,name=direct_access_services,json=directAccessServices,proto3" json:"direct_access_services,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TransparentProxying describes configuration for transparent proxying.

func (*Dataplane_Networking_TransparentProxying) Descriptor 

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

func (*Dataplane_Networking_TransparentProxying) GetDirectAccessServices 

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

func (*Dataplane_Networking_TransparentProxying) GetRedirectPort 

func (m *Dataplane_Networking_TransparentProxying) GetRedirectPort() uint32

func (*Dataplane_Networking_TransparentProxying) ProtoMessage 

func (*Dataplane_Networking_TransparentProxying) ProtoMessage()

func (*Dataplane_Networking_TransparentProxying) Reset 

func (m *Dataplane_Networking_TransparentProxying) Reset()

func (*Dataplane_Networking_TransparentProxying) String 

func (m *Dataplane_Networking_TransparentProxying) String() string

func (*Dataplane_Networking_TransparentProxying) Validate 

func (m *Dataplane_Networking_TransparentProxying) Validate() error

Validate checks the field values on Dataplane_Networking_TransparentProxying with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Dataplane_Networking_TransparentProxying) XXX_DiscardUnknown 

func (m *Dataplane_Networking_TransparentProxying) XXX_DiscardUnknown()

func (*Dataplane_Networking_TransparentProxying) XXX_Marshal 

func (m *Dataplane_Networking_TransparentProxying) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dataplane_Networking_TransparentProxying) XXX_Merge 

func (m *Dataplane_Networking_TransparentProxying) XXX_Merge(src proto.Message)

func (*Dataplane_Networking_TransparentProxying) XXX_Size 

func (m *Dataplane_Networking_TransparentProxying) XXX_Size() int

func (*Dataplane_Networking_TransparentProxying) XXX_Unmarshal 

func (m *Dataplane_Networking_TransparentProxying) XXX_Unmarshal(b []byte) error

type Dataplane_Networking_TransparentProxyingValidationError 

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

Dataplane_Networking_TransparentProxyingValidationError is the validation error returned by Dataplane_Networking_TransparentProxying.Validate if the designated constraints aren't met.

func (Dataplane_Networking_TransparentProxyingValidationError) Cause 

func (e Dataplane_Networking_TransparentProxyingValidationError) Cause() error

Cause function returns cause value.

func (Dataplane_Networking_TransparentProxyingValidationError) Error 

func (e Dataplane_Networking_TransparentProxyingValidationError) Error() string

Error satisfies the builtin error interface

func (Dataplane_Networking_TransparentProxyingValidationError) ErrorName 

func (e Dataplane_Networking_TransparentProxyingValidationError) ErrorName() string

ErrorName returns error name.

func (Dataplane_Networking_TransparentProxyingValidationError) Field 

func (e Dataplane_Networking_TransparentProxyingValidationError) Field() string

Field function returns field value.

func (Dataplane_Networking_TransparentProxyingValidationError) Key 

func (e Dataplane_Networking_TransparentProxyingValidationError) Key() bool

Key function returns key value.

func (Dataplane_Networking_TransparentProxyingValidationError) Reason 

func (e Dataplane_Networking_TransparentProxyingValidationError) Reason() string

Reason function returns reason value.

type DiscoveryServiceStats 

type DiscoveryServiceStats struct {
	// Number of xDS responses sent to the Dataplane.
	ResponsesSent uint64 `protobuf:"varint,1,opt,name=responses_sent,json=responsesSent,proto3" json:"responses_sent,omitempty"`
	// Number of xDS responses ACKed by the Dataplane.
	ResponsesAcknowledged uint64 `protobuf:"varint,2,opt,name=responses_acknowledged,json=responsesAcknowledged,proto3" json:"responses_acknowledged,omitempty"`
	// Number of xDS responses NACKed by the Dataplane.
	ResponsesRejected    uint64   `protobuf:"varint,3,opt,name=responses_rejected,json=responsesRejected,proto3" json:"responses_rejected,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DiscoveryServiceStats defines all stats over a single xDS service.

func (*DiscoveryServiceStats) Descriptor 

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

func (*DiscoveryServiceStats) GetResponsesAcknowledged 

func (m *DiscoveryServiceStats) GetResponsesAcknowledged() uint64

func (*DiscoveryServiceStats) GetResponsesRejected 

func (m *DiscoveryServiceStats) GetResponsesRejected() uint64

func (*DiscoveryServiceStats) GetResponsesSent 

func (m *DiscoveryServiceStats) GetResponsesSent() uint64

func (*DiscoveryServiceStats) ProtoMessage 

func (*DiscoveryServiceStats) ProtoMessage()

func (*DiscoveryServiceStats) Reset 

func (m *DiscoveryServiceStats) Reset()

func (*DiscoveryServiceStats) String 

func (m *DiscoveryServiceStats) String() string

func (*DiscoveryServiceStats) XXX_DiscardUnknown 

func (m *DiscoveryServiceStats) XXX_DiscardUnknown()

func (*DiscoveryServiceStats) XXX_Marshal 

func (m *DiscoveryServiceStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoveryServiceStats) XXX_Merge 

func (m *DiscoveryServiceStats) XXX_Merge(src proto.Message)

func (*DiscoveryServiceStats) XXX_Size 

func (m *DiscoveryServiceStats) XXX_Size() int

func (*DiscoveryServiceStats) XXX_Unmarshal 

func (m *DiscoveryServiceStats) XXX_Unmarshal(b []byte) error

type DiscoverySubscription 

type DiscoverySubscription struct {
	// Unique id per ADS subscription.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Control Plane instance that handled given subscription.
	ControlPlaneInstanceId string `` /* 131-byte string literal not displayed */
	// Time when a given Dataplane connected to the Control Plane.
	ConnectTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=connect_time,json=connectTime,proto3" json:"connect_time,omitempty"`
	// Time when a given Dataplane disconnected from the Control Plane.
	DisconnectTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=disconnect_time,json=disconnectTime,proto3" json:"disconnect_time,omitempty"`
	// Status of the ADS subscription.
	Status               *DiscoverySubscriptionStatus `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

DiscoverySubscription describes a single ADS subscription created by a Dataplane to the Control Plane. Ideally, there should be only one such subscription per Dataplane lifecycle. Presence of multiple subscriptions might indicate one of the following events: - transient loss of network connection between Dataplane and Control Plane - Dataplane restart (i.e. hot restart or crash) - Control Plane restart (i.e. rolling update or crash) - etc

func (*DiscoverySubscription) Descriptor 

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

func (*DiscoverySubscription) GetConnectTime 

func (m *DiscoverySubscription) GetConnectTime() *timestamp.Timestamp

func (*DiscoverySubscription) GetControlPlaneInstanceId 

func (m *DiscoverySubscription) GetControlPlaneInstanceId() string

func (*DiscoverySubscription) GetDisconnectTime 

func (m *DiscoverySubscription) GetDisconnectTime() *timestamp.Timestamp

func (*DiscoverySubscription) GetId 

func (m *DiscoverySubscription) GetId() string

func (*DiscoverySubscription) GetStatus 

func (m *DiscoverySubscription) GetStatus() *DiscoverySubscriptionStatus

func (*DiscoverySubscription) ProtoMessage 

func (*DiscoverySubscription) ProtoMessage()

func (*DiscoverySubscription) Reset 

func (m *DiscoverySubscription) Reset()

func (*DiscoverySubscription) String 

func (m *DiscoverySubscription) String() string

func (*DiscoverySubscription) XXX_DiscardUnknown 

func (m *DiscoverySubscription) XXX_DiscardUnknown()

func (*DiscoverySubscription) XXX_Marshal 

func (m *DiscoverySubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverySubscription) XXX_Merge 

func (m *DiscoverySubscription) XXX_Merge(src proto.Message)

func (*DiscoverySubscription) XXX_Size 

func (m *DiscoverySubscription) XXX_Size() int

func (*DiscoverySubscription) XXX_Unmarshal 

func (m *DiscoverySubscription) XXX_Unmarshal(b []byte) error

type DiscoverySubscriptionStatus 

type DiscoverySubscriptionStatus struct {
	// Time when status of a given ADS subscription was most recently updated.
	LastUpdateTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	// Total defines an aggregate over individual xDS stats.
	Total *DiscoveryServiceStats `protobuf:"bytes,2,opt,name=total,proto3" json:"total,omitempty"`
	// CDS defines all CDS stats.
	Cds *DiscoveryServiceStats `protobuf:"bytes,3,opt,name=cds,proto3" json:"cds,omitempty"`
	// EDS defines all EDS stats.
	Eds *DiscoveryServiceStats `protobuf:"bytes,4,opt,name=eds,proto3" json:"eds,omitempty"`
	// LDS defines all LDS stats.
	Lds *DiscoveryServiceStats `protobuf:"bytes,5,opt,name=lds,proto3" json:"lds,omitempty"`
	// RDS defines all RDS stats.
	Rds                  *DiscoveryServiceStats `protobuf:"bytes,6,opt,name=rds,proto3" json:"rds,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

DiscoverySubscriptionStatus defines status of an ADS subscription.

func NewSubscriptionStatus 

func NewSubscriptionStatus() *DiscoverySubscriptionStatus

func (*DiscoverySubscriptionStatus) Descriptor 

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

func (*DiscoverySubscriptionStatus) GetCds 

func (m *DiscoverySubscriptionStatus) GetCds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetEds 

func (m *DiscoverySubscriptionStatus) GetEds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetLastUpdateTime 

func (m *DiscoverySubscriptionStatus) GetLastUpdateTime() *timestamp.Timestamp

func (*DiscoverySubscriptionStatus) GetLds 

func (m *DiscoverySubscriptionStatus) GetLds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetRds 

func (m *DiscoverySubscriptionStatus) GetRds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetTotal 

func (m *DiscoverySubscriptionStatus) GetTotal() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) ProtoMessage 

func (*DiscoverySubscriptionStatus) ProtoMessage()

func (*DiscoverySubscriptionStatus) Reset 

func (m *DiscoverySubscriptionStatus) Reset()

func (*DiscoverySubscriptionStatus) StatsOf 

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

func (*DiscoverySubscriptionStatus) String 

func (m *DiscoverySubscriptionStatus) String() string

func (*DiscoverySubscriptionStatus) XXX_DiscardUnknown 

func (m *DiscoverySubscriptionStatus) XXX_DiscardUnknown()

func (*DiscoverySubscriptionStatus) XXX_Marshal 

func (m *DiscoverySubscriptionStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverySubscriptionStatus) XXX_Merge 

func (m *DiscoverySubscriptionStatus) XXX_Merge(src proto.Message)

func (*DiscoverySubscriptionStatus) XXX_Size 

func (m *DiscoverySubscriptionStatus) XXX_Size() int

func (*DiscoverySubscriptionStatus) XXX_Unmarshal 

func (m *DiscoverySubscriptionStatus) XXX_Unmarshal(b []byte) error

type FaultInjection 

type FaultInjection struct {
	// List of selectors to match dataplanes that are sources of traffic.
	Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	// List of selectors to match services that are destinations of traffic.
	Destinations []*Selector `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"`
	// Configuration of FaultInjection
	Conf                 *FaultInjection_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

FaultInjection defines the configuration of faults between dataplanes.

func (*FaultInjection) Descriptor 

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

func (*FaultInjection) GetConf 

func (m *FaultInjection) GetConf() *FaultInjection_Conf

func (*FaultInjection) GetDestinations 

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

func (*FaultInjection) GetSources 

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

func (*FaultInjection) ProtoMessage 

func (*FaultInjection) ProtoMessage()

func (*FaultInjection) Reset 

func (m *FaultInjection) Reset()

func (*FaultInjection) SourceTags 

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

func (*FaultInjection) String 

func (m *FaultInjection) String() string

func (*FaultInjection) XXX_DiscardUnknown 

func (m *FaultInjection) XXX_DiscardUnknown()

func (*FaultInjection) XXX_Marshal 

func (m *FaultInjection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FaultInjection) XXX_Merge 

func (m *FaultInjection) XXX_Merge(src proto.Message)

func (*FaultInjection) XXX_Size 

func (m *FaultInjection) XXX_Size() int

func (*FaultInjection) XXX_Unmarshal 

func (m *FaultInjection) XXX_Unmarshal(b []byte) error

type FaultInjection_Conf 

type FaultInjection_Conf struct {
	// Delay if specified then response from the destination will be delivered
	// with a delay
	Delay *FaultInjection_Conf_Delay `protobuf:"bytes,1,opt,name=delay,proto3" json:"delay,omitempty"`
	// Abort if specified makes source side to receive specified httpStatus code
	Abort *FaultInjection_Conf_Abort `protobuf:"bytes,2,opt,name=abort,proto3" json:"abort,omitempty"`
	// ResponseBandwidth if specified limits the speed of sending response body
	ResponseBandwidth    *FaultInjection_Conf_ResponseBandwidth `protobuf:"bytes,3,opt,name=response_bandwidth,json=responseBandwidth,proto3" json:"response_bandwidth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                               `json:"-"`
	XXX_unrecognized     []byte                                 `json:"-"`
	XXX_sizecache        int32                                  `json:"-"`
}

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

func (*FaultInjection_Conf) Descriptor 

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

func (*FaultInjection_Conf) GetAbort 

func (m *FaultInjection_Conf) GetAbort() *FaultInjection_Conf_Abort

func (*FaultInjection_Conf) GetDelay 

func (m *FaultInjection_Conf) GetDelay() *FaultInjection_Conf_Delay

func (*FaultInjection_Conf) GetResponseBandwidth 

func (m *FaultInjection_Conf) GetResponseBandwidth() *FaultInjection_Conf_ResponseBandwidth

func (*FaultInjection_Conf) ProtoMessage 

func (*FaultInjection_Conf) ProtoMessage()

func (*FaultInjection_Conf) Reset 

func (m *FaultInjection_Conf) Reset()

func (*FaultInjection_Conf) String 

func (m *FaultInjection_Conf) String() string

func (*FaultInjection_Conf) XXX_DiscardUnknown 

func (m *FaultInjection_Conf) XXX_DiscardUnknown()

func (*FaultInjection_Conf) XXX_Marshal 

func (m *FaultInjection_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FaultInjection_Conf) XXX_Merge 

func (m *FaultInjection_Conf) XXX_Merge(src proto.Message)

func (*FaultInjection_Conf) XXX_Size 

func (m *FaultInjection_Conf) XXX_Size() int

func (*FaultInjection_Conf) XXX_Unmarshal 

func (m *FaultInjection_Conf) XXX_Unmarshal(b []byte) error

type FaultInjection_Conf_Abort 

type FaultInjection_Conf_Abort struct {
	// Percentage of requests on which abort will be injected, has to be in
	// [0.0 - 100.0] range
	Percentage *wrappers.DoubleValue `protobuf:"bytes,1,opt,name=percentage,proto3" json:"percentage,omitempty"`
	// HTTP status code which will be returned to source side
	HttpStatus           *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=httpStatus,proto3" json:"httpStatus,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Abort defines a configuration of not delivering requests to destination service and replacing the responses from destination dataplane by predefined status code

func (*FaultInjection_Conf_Abort) Descriptor 

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

func (*FaultInjection_Conf_Abort) GetHttpStatus 

func (m *FaultInjection_Conf_Abort) GetHttpStatus() *wrappers.UInt32Value

func (*FaultInjection_Conf_Abort) GetPercentage 

func (m *FaultInjection_Conf_Abort) GetPercentage() *wrappers.DoubleValue

func (*FaultInjection_Conf_Abort) ProtoMessage 

func (*FaultInjection_Conf_Abort) ProtoMessage()

func (*FaultInjection_Conf_Abort) Reset 

func (m *FaultInjection_Conf_Abort) Reset()

func (*FaultInjection_Conf_Abort) String 

func (m *FaultInjection_Conf_Abort) String() string

func (*FaultInjection_Conf_Abort) XXX_DiscardUnknown 

func (m *FaultInjection_Conf_Abort) XXX_DiscardUnknown()

func (*FaultInjection_Conf_Abort) XXX_Marshal 

func (m *FaultInjection_Conf_Abort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FaultInjection_Conf_Abort) XXX_Merge 

func (m *FaultInjection_Conf_Abort) XXX_Merge(src proto.Message)

func (*FaultInjection_Conf_Abort) XXX_Size 

func (m *FaultInjection_Conf_Abort) XXX_Size() int

func (*FaultInjection_Conf_Abort) XXX_Unmarshal 

func (m *FaultInjection_Conf_Abort) XXX_Unmarshal(b []byte) error

type FaultInjection_Conf_Delay 

type FaultInjection_Conf_Delay struct {
	// Percentage of requests on which delay will be injected, has to be in
	// [0.0 - 100.0] range
	Percentage *wrappers.DoubleValue `protobuf:"bytes,1,opt,name=percentage,proto3" json:"percentage,omitempty"`
	// The duration during which the response will be delayed
	Value                *duration.Duration `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Delay defines configuration of delaying a response from a destination

func (*FaultInjection_Conf_Delay) Descriptor 

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

func (*FaultInjection_Conf_Delay) GetPercentage 

func (m *FaultInjection_Conf_Delay) GetPercentage() *wrappers.DoubleValue

func (*FaultInjection_Conf_Delay) GetValue 

func (m *FaultInjection_Conf_Delay) GetValue() *duration.Duration

func (*FaultInjection_Conf_Delay) ProtoMessage 

func (*FaultInjection_Conf_Delay) ProtoMessage()

func (*FaultInjection_Conf_Delay) Reset 

func (m *FaultInjection_Conf_Delay) Reset()

func (*FaultInjection_Conf_Delay) String 

func (m *FaultInjection_Conf_Delay) String() string

func (*FaultInjection_Conf_Delay) XXX_DiscardUnknown 

func (m *FaultInjection_Conf_Delay) XXX_DiscardUnknown()

func (*FaultInjection_Conf_Delay) XXX_Marshal 

func (m *FaultInjection_Conf_Delay) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FaultInjection_Conf_Delay) XXX_Merge 

func (m *FaultInjection_Conf_Delay) XXX_Merge(src proto.Message)

func (*FaultInjection_Conf_Delay) XXX_Size 

func (m *FaultInjection_Conf_Delay) XXX_Size() int

func (*FaultInjection_Conf_Delay) XXX_Unmarshal 

func (m *FaultInjection_Conf_Delay) XXX_Unmarshal(b []byte) error

type FaultInjection_Conf_ResponseBandwidth 

type FaultInjection_Conf_ResponseBandwidth struct {
	// Percentage of requests on which response bandwidth limit will be
	// injected, has to be in [0.0 - 100.0] range
	Percentage *wrappers.DoubleValue `protobuf:"bytes,1,opt,name=percentage,proto3" json:"percentage,omitempty"`
	// Limit is represented by value measure in gbps, mbps, kbps or bps, e.g.
	// 10kbps
	Limit                *wrappers.StringValue `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

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

func (*FaultInjection_Conf_ResponseBandwidth) Descriptor 

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

func (*FaultInjection_Conf_ResponseBandwidth) GetLimit 

func (m *FaultInjection_Conf_ResponseBandwidth) GetLimit() *wrappers.StringValue

func (*FaultInjection_Conf_ResponseBandwidth) GetPercentage 

func (m *FaultInjection_Conf_ResponseBandwidth) GetPercentage() *wrappers.DoubleValue

func (*FaultInjection_Conf_ResponseBandwidth) ProtoMessage 

func (*FaultInjection_Conf_ResponseBandwidth) ProtoMessage()

func (*FaultInjection_Conf_ResponseBandwidth) Reset 

func (m *FaultInjection_Conf_ResponseBandwidth) Reset()

func (*FaultInjection_Conf_ResponseBandwidth) String 

func (m *FaultInjection_Conf_ResponseBandwidth) String() string

func (*FaultInjection_Conf_ResponseBandwidth) XXX_DiscardUnknown 

func (m *FaultInjection_Conf_ResponseBandwidth) XXX_DiscardUnknown()

func (*FaultInjection_Conf_ResponseBandwidth) XXX_Marshal 

func (m *FaultInjection_Conf_ResponseBandwidth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FaultInjection_Conf_ResponseBandwidth) XXX_Merge 

func (m *FaultInjection_Conf_ResponseBandwidth) XXX_Merge(src proto.Message)

func (*FaultInjection_Conf_ResponseBandwidth) XXX_Size 

func (m *FaultInjection_Conf_ResponseBandwidth) XXX_Size() int

func (*FaultInjection_Conf_ResponseBandwidth) XXX_Unmarshal 

func (m *FaultInjection_Conf_ResponseBandwidth) XXX_Unmarshal(b []byte) error

type FileLoggingBackendConfig 

type FileLoggingBackendConfig struct {
	// Path to a file that logs will be written to
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FileLoggingBackendConfig defines configuration for file based access logs

func (*FileLoggingBackendConfig) Descriptor 

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

func (*FileLoggingBackendConfig) GetPath 

func (m *FileLoggingBackendConfig) GetPath() string

func (*FileLoggingBackendConfig) ProtoMessage 

func (*FileLoggingBackendConfig) ProtoMessage()

func (*FileLoggingBackendConfig) Reset 

func (m *FileLoggingBackendConfig) Reset()

func (*FileLoggingBackendConfig) String 

func (m *FileLoggingBackendConfig) String() string

func (*FileLoggingBackendConfig) Validate 

func (m *FileLoggingBackendConfig) Validate() error

Validate checks the field values on FileLoggingBackendConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*FileLoggingBackendConfig) XXX_DiscardUnknown 

func (m *FileLoggingBackendConfig) XXX_DiscardUnknown()

func (*FileLoggingBackendConfig) XXX_Marshal 

func (m *FileLoggingBackendConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileLoggingBackendConfig) XXX_Merge 

func (m *FileLoggingBackendConfig) XXX_Merge(src proto.Message)

func (*FileLoggingBackendConfig) XXX_Size 

func (m *FileLoggingBackendConfig) XXX_Size() int

func (*FileLoggingBackendConfig) XXX_Unmarshal 

func (m *FileLoggingBackendConfig) XXX_Unmarshal(b []byte) error

type FileLoggingBackendConfigValidationError 

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

FileLoggingBackendConfigValidationError is the validation error returned by FileLoggingBackendConfig.Validate if the designated constraints aren't met.

func (FileLoggingBackendConfigValidationError) Cause 

func (e FileLoggingBackendConfigValidationError) Cause() error

Cause function returns cause value.

func (FileLoggingBackendConfigValidationError) Error 

func (e FileLoggingBackendConfigValidationError) Error() string

Error satisfies the builtin error interface

func (FileLoggingBackendConfigValidationError) ErrorName 

func (e FileLoggingBackendConfigValidationError) ErrorName() string

ErrorName returns error name.

func (FileLoggingBackendConfigValidationError) Field 

func (e FileLoggingBackendConfigValidationError) Field() string

Field function returns field value.

func (FileLoggingBackendConfigValidationError) Key 

func (e FileLoggingBackendConfigValidationError) Key() bool

Key function returns key value.

func (FileLoggingBackendConfigValidationError) Reason 

func (e FileLoggingBackendConfigValidationError) Reason() string

Reason function returns reason value.

type HealthCheck 

type HealthCheck struct {
	// List of selectors to match dataplanes that should be configured to do
	// health checks.
	Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	// List of selectors to match services that need to be health checked.
	Destinations []*Selector `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"`
	// Configuration for various types of health checking.
	Conf                 *HealthCheck_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

HealthCheck defines configuration for health checking.

func (*HealthCheck) Descriptor 

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

func (*HealthCheck) GetConf 

func (m *HealthCheck) GetConf() *HealthCheck_Conf

func (*HealthCheck) GetDestinations 

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

func (*HealthCheck) GetSources 

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

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset 

func (m *HealthCheck) Reset()

func (*HealthCheck) String 

func (m *HealthCheck) String() string

func (*HealthCheck) Validate 

func (m *HealthCheck) Validate() error

Validate checks the field values on HealthCheck with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*HealthCheck) XXX_DiscardUnknown 

func (m *HealthCheck) XXX_DiscardUnknown()

func (*HealthCheck) XXX_Marshal 

func (m *HealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheck) XXX_Merge 

func (m *HealthCheck) XXX_Merge(src proto.Message)

func (*HealthCheck) XXX_Size 

func (m *HealthCheck) XXX_Size() int

func (*HealthCheck) XXX_Unmarshal 

func (m *HealthCheck) XXX_Unmarshal(b []byte) error

type HealthCheckValidationError 

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

HealthCheckValidationError is the validation error returned by HealthCheck.Validate if the designated constraints aren't met.

func (HealthCheckValidationError) Cause 

func (e HealthCheckValidationError) Cause() error

Cause function returns cause value.

func (HealthCheckValidationError) Error 

func (e HealthCheckValidationError) Error() string

Error satisfies the builtin error interface

func (HealthCheckValidationError) ErrorName 

func (e HealthCheckValidationError) ErrorName() string

ErrorName returns error name.

func (HealthCheckValidationError) Field 

func (e HealthCheckValidationError) Field() string

Field function returns field value.

func (HealthCheckValidationError) Key 

func (e HealthCheckValidationError) Key() bool

Key function returns key value.

func (HealthCheckValidationError) Reason 

func (e HealthCheckValidationError) Reason() string

Reason function returns reason value.

type HealthCheck_Conf 

type HealthCheck_Conf struct {
	// Interval between consecutive health checks.
	Interval *duration.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// Maximum time to wait for a health check response.
	Timeout *duration.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Number of consecutive unhealthy checks before considering a host
	// unhealthy.
	UnhealthyThreshold uint32 `protobuf:"varint,3,opt,name=unhealthy_threshold,json=unhealthyThreshold,proto3" json:"unhealthy_threshold,omitempty"`
	// Number of consecutive healthy checks before considering a host healthy.
	HealthyThreshold     uint32   `protobuf:"varint,4,opt,name=healthy_threshold,json=healthyThreshold,proto3" json:"healthy_threshold,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Conf defines configuration for various types of health checking.

func (*HealthCheck_Conf) Descriptor 

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

func (*HealthCheck_Conf) GetHealthyThreshold 

func (m *HealthCheck_Conf) GetHealthyThreshold() uint32

func (*HealthCheck_Conf) GetInterval 

func (m *HealthCheck_Conf) GetInterval() *duration.Duration

func (*HealthCheck_Conf) GetTimeout 

func (m *HealthCheck_Conf) GetTimeout() *duration.Duration

func (*HealthCheck_Conf) GetUnhealthyThreshold 

func (m *HealthCheck_Conf) GetUnhealthyThreshold() uint32

func (*HealthCheck_Conf) ProtoMessage 

func (*HealthCheck_Conf) ProtoMessage()

func (*HealthCheck_Conf) Reset 

func (m *HealthCheck_Conf) Reset()

func (*HealthCheck_Conf) String 

func (m *HealthCheck_Conf) String() string

func (*HealthCheck_Conf) Validate 

func (m *HealthCheck_Conf) Validate() error

Validate checks the field values on HealthCheck_Conf with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*HealthCheck_Conf) XXX_DiscardUnknown 

func (m *HealthCheck_Conf) XXX_DiscardUnknown()

func (*HealthCheck_Conf) XXX_Marshal 

func (m *HealthCheck_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheck_Conf) XXX_Merge 

func (m *HealthCheck_Conf) XXX_Merge(src proto.Message)

func (*HealthCheck_Conf) XXX_Size 

func (m *HealthCheck_Conf) XXX_Size() int

func (*HealthCheck_Conf) XXX_Unmarshal 

func (m *HealthCheck_Conf) XXX_Unmarshal(b []byte) error

type HealthCheck_ConfValidationError 

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

HealthCheck_ConfValidationError is the validation error returned by HealthCheck_Conf.Validate if the designated constraints aren't met.

func (HealthCheck_ConfValidationError) Cause 

func (e HealthCheck_ConfValidationError) Cause() error

Cause function returns cause value.

func (HealthCheck_ConfValidationError) Error 

func (e HealthCheck_ConfValidationError) Error() string

Error satisfies the builtin error interface

func (HealthCheck_ConfValidationError) ErrorName 

func (e HealthCheck_ConfValidationError) ErrorName() string

ErrorName returns error name.

func (HealthCheck_ConfValidationError) Field 

func (e HealthCheck_ConfValidationError) Field() string

Field function returns field value.

func (HealthCheck_ConfValidationError) Key 

func (e HealthCheck_ConfValidationError) Key() bool

Key function returns key value.

func (HealthCheck_ConfValidationError) Reason 

func (e HealthCheck_ConfValidationError) Reason() string

Reason function returns reason value.

type InboundInterface 

type InboundInterface struct {
	DataplaneIP   string
	DataplanePort uint32
	WorkloadPort  uint32
}

func ParseInboundInterface 

func ParseInboundInterface(text string) (InboundInterface, error)

func (InboundInterface) String 

func (i InboundInterface) String() string

type KumaDiscoveryServiceClient 

type KumaDiscoveryServiceClient interface {
	DeltaKumaResources(ctx context.Context, opts ...grpc.CallOption) (KumaDiscoveryService_DeltaKumaResourcesClient, error)
	StreamKumaResources(ctx context.Context, opts ...grpc.CallOption) (KumaDiscoveryService_StreamKumaResourcesClient, error)
	FetchKumaResources(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error)
}

KumaDiscoveryServiceClient is the client API for KumaDiscoveryService service.

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

func NewKumaDiscoveryServiceClient 

func NewKumaDiscoveryServiceClient(cc *grpc.ClientConn) KumaDiscoveryServiceClient

type KumaDiscoveryServiceServer 

type KumaDiscoveryServiceServer interface {
	DeltaKumaResources(KumaDiscoveryService_DeltaKumaResourcesServer) error
	StreamKumaResources(KumaDiscoveryService_StreamKumaResourcesServer) error
	FetchKumaResources(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
}

KumaDiscoveryServiceServer is the server API for KumaDiscoveryService service.

type KumaDiscoveryService_DeltaKumaResourcesClient 

type KumaDiscoveryService_DeltaKumaResourcesClient interface {
	Send(*v2.DeltaDiscoveryRequest) error
	Recv() (*v2.DeltaDiscoveryResponse, error)
	grpc.ClientStream
}

type KumaDiscoveryService_DeltaKumaResourcesServer 

type KumaDiscoveryService_DeltaKumaResourcesServer interface {
	Send(*v2.DeltaDiscoveryResponse) error
	Recv() (*v2.DeltaDiscoveryRequest, error)
	grpc.ServerStream
}

type KumaDiscoveryService_StreamKumaResourcesClient 

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

type KumaDiscoveryService_StreamKumaResourcesServer 

type KumaDiscoveryService_StreamKumaResourcesServer interface {
	Send(*v2.DiscoveryResponse) error
	Recv() (*v2.DiscoveryRequest, error)
	grpc.ServerStream
}

type KumaResource 

type KumaResource struct {
	Meta                 *KumaResource_Meta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Spec                 *any.Any           `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*KumaResource) Descriptor 

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

func (*KumaResource) GetMeta 

func (m *KumaResource) GetMeta() *KumaResource_Meta

func (*KumaResource) GetSpec 

func (m *KumaResource) GetSpec() *any.Any

func (*KumaResource) ProtoMessage 

func (*KumaResource) ProtoMessage()

func (*KumaResource) Reset 

func (m *KumaResource) Reset()

func (*KumaResource) String 

func (m *KumaResource) String() string

func (*KumaResource) Validate 

func (m *KumaResource) Validate() error

Validate checks the field values on KumaResource with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*KumaResource) XXX_DiscardUnknown 

func (m *KumaResource) XXX_DiscardUnknown()

func (*KumaResource) XXX_Marshal 

func (m *KumaResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KumaResource) XXX_Merge 

func (m *KumaResource) XXX_Merge(src proto.Message)

func (*KumaResource) XXX_Size 

func (m *KumaResource) XXX_Size() int

func (*KumaResource) XXX_Unmarshal 

func (m *KumaResource) XXX_Unmarshal(b []byte) error

type KumaResourceValidationError 

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

KumaResourceValidationError is the validation error returned by KumaResource.Validate if the designated constraints aren't met.

func (KumaResourceValidationError) Cause 

func (e KumaResourceValidationError) Cause() error

Cause function returns cause value.

func (KumaResourceValidationError) Error 

func (e KumaResourceValidationError) Error() string

Error satisfies the builtin error interface

func (KumaResourceValidationError) ErrorName 

func (e KumaResourceValidationError) ErrorName() string

ErrorName returns error name.

func (KumaResourceValidationError) Field 

func (e KumaResourceValidationError) Field() string

Field function returns field value.

func (KumaResourceValidationError) Key 

func (e KumaResourceValidationError) Key() bool

Key function returns key value.

func (KumaResourceValidationError) Reason 

func (e KumaResourceValidationError) Reason() string

Reason function returns reason value.

type KumaResource_Meta 

type KumaResource_Meta struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Mesh                 string               `protobuf:"bytes,2,opt,name=mesh,proto3" json:"mesh,omitempty"`
	CreationTime         *timestamp.Timestamp `protobuf:"bytes,3,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	ModificationTime     *timestamp.Timestamp `protobuf:"bytes,4,opt,name=modification_time,json=modificationTime,proto3" json:"modification_time,omitempty"`
	Version              string               `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*KumaResource_Meta) Descriptor 

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

func (*KumaResource_Meta) GetCreationTime 

func (m *KumaResource_Meta) GetCreationTime() *timestamp.Timestamp

func (*KumaResource_Meta) GetMesh 

func (m *KumaResource_Meta) GetMesh() string

func (*KumaResource_Meta) GetModificationTime 

func (m *KumaResource_Meta) GetModificationTime() *timestamp.Timestamp

func (*KumaResource_Meta) GetName 

func (m *KumaResource_Meta) GetName() string

func (*KumaResource_Meta) GetVersion 

func (m *KumaResource_Meta) GetVersion() string

func (*KumaResource_Meta) ProtoMessage 

func (*KumaResource_Meta) ProtoMessage()

func (*KumaResource_Meta) Reset 

func (m *KumaResource_Meta) Reset()

func (*KumaResource_Meta) String 

func (m *KumaResource_Meta) String() string

func (*KumaResource_Meta) Validate 

func (m *KumaResource_Meta) Validate() error

Validate checks the field values on KumaResource_Meta with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*KumaResource_Meta) XXX_DiscardUnknown 

func (m *KumaResource_Meta) XXX_DiscardUnknown()

func (*KumaResource_Meta) XXX_Marshal 

func (m *KumaResource_Meta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KumaResource_Meta) XXX_Merge 

func (m *KumaResource_Meta) XXX_Merge(src proto.Message)

func (*KumaResource_Meta) XXX_Size 

func (m *KumaResource_Meta) XXX_Size() int

func (*KumaResource_Meta) XXX_Unmarshal 

func (m *KumaResource_Meta) XXX_Unmarshal(b []byte) error

type KumaResource_MetaValidationError 

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

KumaResource_MetaValidationError is the validation error returned by KumaResource_Meta.Validate if the designated constraints aren't met.

func (KumaResource_MetaValidationError) Cause 

func (e KumaResource_MetaValidationError) Cause() error

Cause function returns cause value.

func (KumaResource_MetaValidationError) Error 

func (e KumaResource_MetaValidationError) Error() string

Error satisfies the builtin error interface

func (KumaResource_MetaValidationError) ErrorName 

func (e KumaResource_MetaValidationError) ErrorName() string

ErrorName returns error name.

func (KumaResource_MetaValidationError) Field 

func (e KumaResource_MetaValidationError) Field() string

Field function returns field value.

func (KumaResource_MetaValidationError) Key 

func (e KumaResource_MetaValidationError) Key() bool

Key function returns key value.

func (KumaResource_MetaValidationError) Reason 

func (e KumaResource_MetaValidationError) Reason() string

Reason function returns reason value.

type Logging 

type Logging struct {
	// Name of the default backend
	DefaultBackend string `protobuf:"bytes,1,opt,name=defaultBackend,proto3" json:"defaultBackend,omitempty"`
	// List of available logging backends
	Backends             []*LoggingBackend `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Logging) Descriptor 

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

func (*Logging) GetBackends 

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

func (*Logging) GetDefaultBackend 

func (m *Logging) GetDefaultBackend() string

func (*Logging) ProtoMessage 

func (*Logging) ProtoMessage()

func (*Logging) Reset 

func (m *Logging) Reset()

func (*Logging) String 

func (m *Logging) String() string

func (*Logging) Validate 

func (m *Logging) Validate() error

Validate checks the field values on Logging with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Logging) XXX_DiscardUnknown 

func (m *Logging) XXX_DiscardUnknown()

func (*Logging) XXX_Marshal 

func (m *Logging) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Logging) XXX_Merge 

func (m *Logging) XXX_Merge(src proto.Message)

func (*Logging) XXX_Size 

func (m *Logging) XXX_Size() int

func (*Logging) XXX_Unmarshal 

func (m *Logging) XXX_Unmarshal(b []byte) error

type LoggingBackend 

type LoggingBackend struct {
	// Name of the backend, can be then used in Mesh.logging.defaultBackend or in
	// TrafficLogging
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Format of access logs. Placehodlers available on
	// https://www.envoyproxy.io/docs/envoy/latest/configuration/observability/access_log
	Format string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	// Type of the backend (Kuma ships with 'tcp' and 'file')
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// Configuration of the backend
	Conf                 *_struct.Struct `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

func (*LoggingBackend) Descriptor 

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

func (*LoggingBackend) GetConf 

func (m *LoggingBackend) GetConf() *_struct.Struct

func (*LoggingBackend) GetFormat 

func (m *LoggingBackend) GetFormat() string

func (*LoggingBackend) GetName 

func (m *LoggingBackend) GetName() string

func (*LoggingBackend) GetType 

func (m *LoggingBackend) GetType() string

func (*LoggingBackend) ProtoMessage 

func (*LoggingBackend) ProtoMessage()

func (*LoggingBackend) Reset 

func (m *LoggingBackend) Reset()

func (*LoggingBackend) String 

func (m *LoggingBackend) String() string

func (*LoggingBackend) Validate 

func (m *LoggingBackend) Validate() error

Validate checks the field values on LoggingBackend with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LoggingBackend) XXX_DiscardUnknown 

func (m *LoggingBackend) XXX_DiscardUnknown()

func (*LoggingBackend) XXX_Marshal 

func (m *LoggingBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoggingBackend) XXX_Merge 

func (m *LoggingBackend) XXX_Merge(src proto.Message)

func (*LoggingBackend) XXX_Size 

func (m *LoggingBackend) XXX_Size() int

func (*LoggingBackend) XXX_Unmarshal 

func (m *LoggingBackend) XXX_Unmarshal(b []byte) error

type LoggingBackendValidationError 

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

LoggingBackendValidationError is the validation error returned by LoggingBackend.Validate if the designated constraints aren't met.

func (LoggingBackendValidationError) Cause 

func (e LoggingBackendValidationError) Cause() error

Cause function returns cause value.

func (LoggingBackendValidationError) Error 

func (e LoggingBackendValidationError) Error() string

Error satisfies the builtin error interface

func (LoggingBackendValidationError) ErrorName 

func (e LoggingBackendValidationError) ErrorName() string

ErrorName returns error name.

func (LoggingBackendValidationError) Field 

func (e LoggingBackendValidationError) Field() string

Field function returns field value.

func (LoggingBackendValidationError) Key 

func (e LoggingBackendValidationError) Key() bool

Key function returns key value.

func (LoggingBackendValidationError) Reason 

func (e LoggingBackendValidationError) Reason() string

Reason function returns reason value.

type LoggingValidationError 

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

LoggingValidationError is the validation error returned by Logging.Validate if the designated constraints aren't met.

func (LoggingValidationError) Cause 

func (e LoggingValidationError) Cause() error

Cause function returns cause value.

func (LoggingValidationError) Error 

func (e LoggingValidationError) Error() string

Error satisfies the builtin error interface

func (LoggingValidationError) ErrorName 

func (e LoggingValidationError) ErrorName() string

ErrorName returns error name.

func (LoggingValidationError) Field 

func (e LoggingValidationError) Field() string

Field function returns field value.

func (LoggingValidationError) Key 

func (e LoggingValidationError) Key() bool

Key function returns key value.

func (LoggingValidationError) Reason 

func (e LoggingValidationError) Reason() string

Reason function returns reason value.

type Mesh 

type Mesh struct {
	// mTLS settings.
	// +optional
	Mtls *Mesh_Mtls `protobuf:"bytes,1,opt,name=mtls,proto3" json:"mtls,omitempty"`
	// Tracing settings.
	// +optional
	Tracing *Tracing `protobuf:"bytes,2,opt,name=tracing,proto3" json:"tracing,omitempty"`
	// Logging settings.
	// +optional
	Logging *Logging `protobuf:"bytes,3,opt,name=logging,proto3" json:"logging,omitempty"`
	// Configuration for metrics collected and exposed by dataplanes.
	//
	// Settings defined here become defaults for every dataplane in a given Mesh.
	// Additionally, it is also possible to further customize this configuration
	// for each dataplane individually using Dataplane resource.
	// +optional
	Metrics              *Metrics `protobuf:"bytes,4,opt,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Mesh defines configuration of a single mesh.

func (*Mesh) Descriptor 

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

func (*Mesh) GetLogging 

func (m *Mesh) GetLogging() *Logging

func (*Mesh) GetMetrics 

func (m *Mesh) GetMetrics() *Metrics

func (*Mesh) GetMtls 

func (m *Mesh) GetMtls() *Mesh_Mtls

func (*Mesh) GetTracing 

func (m *Mesh) GetTracing() *Tracing

func (*Mesh) ProtoMessage 

func (*Mesh) ProtoMessage()

func (*Mesh) Reset 

func (m *Mesh) Reset()

func (*Mesh) String 

func (m *Mesh) String() string

func (*Mesh) Validate 

func (m *Mesh) Validate() error

Validate checks the field values on Mesh with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Mesh) XXX_DiscardUnknown 

func (m *Mesh) XXX_DiscardUnknown()

func (*Mesh) XXX_Marshal 

func (m *Mesh) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Mesh) XXX_Merge 

func (m *Mesh) XXX_Merge(src proto.Message)

func (*Mesh) XXX_Size 

func (m *Mesh) XXX_Size() int

func (*Mesh) XXX_Unmarshal 

func (m *Mesh) XXX_Unmarshal(b []byte) error

type MeshValidationError 

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

MeshValidationError is the validation error returned by Mesh.Validate if the designated constraints aren't met.

func (MeshValidationError) Cause 

func (e MeshValidationError) Cause() error

Cause function returns cause value.

func (MeshValidationError) Error 

func (e MeshValidationError) Error() string

Error satisfies the builtin error interface

func (MeshValidationError) ErrorName 

func (e MeshValidationError) ErrorName() string

ErrorName returns error name.

func (MeshValidationError) Field 

func (e MeshValidationError) Field() string

Field function returns field value.

func (MeshValidationError) Key 

func (e MeshValidationError) Key() bool

Key function returns key value.

func (MeshValidationError) Reason 

func (e MeshValidationError) Reason() string

Reason function returns reason value.

type Mesh_Mtls 

type Mesh_Mtls struct {
	// Name of the enabled backend
	EnabledBackend string `protobuf:"bytes,1,opt,name=enabledBackend,proto3" json:"enabledBackend,omitempty"`
	// List of available Certificate Authority backends
	Backends             []*CertificateAuthorityBackend `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

mTLS settings of a Mesh.

func (*Mesh_Mtls) Descriptor 

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

func (*Mesh_Mtls) GetBackends 

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

func (*Mesh_Mtls) GetEnabledBackend 

func (m *Mesh_Mtls) GetEnabledBackend() string

func (*Mesh_Mtls) ProtoMessage 

func (*Mesh_Mtls) ProtoMessage()

func (*Mesh_Mtls) Reset 

func (m *Mesh_Mtls) Reset()

func (*Mesh_Mtls) String 

func (m *Mesh_Mtls) String() string

func (*Mesh_Mtls) Validate 

func (m *Mesh_Mtls) Validate() error

Validate checks the field values on Mesh_Mtls with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Mesh_Mtls) XXX_DiscardUnknown 

func (m *Mesh_Mtls) XXX_DiscardUnknown()

func (*Mesh_Mtls) XXX_Marshal 

func (m *Mesh_Mtls) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Mesh_Mtls) XXX_Merge 

func (m *Mesh_Mtls) XXX_Merge(src proto.Message)

func (*Mesh_Mtls) XXX_Size 

func (m *Mesh_Mtls) XXX_Size() int

func (*Mesh_Mtls) XXX_Unmarshal 

func (m *Mesh_Mtls) XXX_Unmarshal(b []byte) error

type Mesh_MtlsValidationError 

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

Mesh_MtlsValidationError is the validation error returned by Mesh_Mtls.Validate if the designated constraints aren't met.

func (Mesh_MtlsValidationError) Cause 

func (e Mesh_MtlsValidationError) Cause() error

Cause function returns cause value.

func (Mesh_MtlsValidationError) Error 

func (e Mesh_MtlsValidationError) Error() string

Error satisfies the builtin error interface

func (Mesh_MtlsValidationError) ErrorName 

func (e Mesh_MtlsValidationError) ErrorName() string

ErrorName returns error name.

func (Mesh_MtlsValidationError) Field 

func (e Mesh_MtlsValidationError) Field() string

Field function returns field value.

func (Mesh_MtlsValidationError) Key 

func (e Mesh_MtlsValidationError) Key() bool

Key function returns key value.

func (Mesh_MtlsValidationError) Reason 

func (e Mesh_MtlsValidationError) Reason() string

Reason function returns reason value.

type Metrics 

type Metrics struct {
	// Name of the enabled backend
	EnabledBackend string `protobuf:"bytes,1,opt,name=enabledBackend,proto3" json:"enabledBackend,omitempty"`
	// List of available Metrics backends
	Backends             []*MetricsBackend `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (*Metrics) Descriptor 

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

func (*Metrics) GetBackends 

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

func (*Metrics) GetEnabledBackend 

func (m *Metrics) GetEnabledBackend() string

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) Reset 

func (m *Metrics) Reset()

func (*Metrics) String 

func (m *Metrics) String() string

func (*Metrics) XXX_DiscardUnknown 

func (m *Metrics) XXX_DiscardUnknown()

func (*Metrics) XXX_Marshal 

func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metrics) XXX_Merge 

func (m *Metrics) XXX_Merge(src proto.Message)

func (*Metrics) XXX_Size 

func (m *Metrics) XXX_Size() int

func (*Metrics) XXX_Unmarshal 

func (m *Metrics) XXX_Unmarshal(b []byte) error

type MetricsBackend 

type MetricsBackend struct {
	// Name of the backend, can be then used in Mesh.metrics.enabledBackend
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the backend (Kuma ships with 'prometheus')
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Configuration of the backend
	Conf                 *_struct.Struct `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

MetricsBackend defines metric backends

func (*MetricsBackend) Descriptor 

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

func (*MetricsBackend) GetConf 

func (m *MetricsBackend) GetConf() *_struct.Struct

func (*MetricsBackend) GetName 

func (m *MetricsBackend) GetName() string

func (*MetricsBackend) GetType 

func (m *MetricsBackend) GetType() string

func (*MetricsBackend) ProtoMessage 

func (*MetricsBackend) ProtoMessage()

func (*MetricsBackend) Reset 

func (m *MetricsBackend) Reset()

func (*MetricsBackend) String 

func (m *MetricsBackend) String() string

func (*MetricsBackend) XXX_DiscardUnknown 

func (m *MetricsBackend) XXX_DiscardUnknown()

func (*MetricsBackend) XXX_Marshal 

func (m *MetricsBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsBackend) XXX_Merge 

func (m *MetricsBackend) XXX_Merge(src proto.Message)

func (*MetricsBackend) XXX_Size 

func (m *MetricsBackend) XXX_Size() int

func (*MetricsBackend) XXX_Unmarshal 

func (m *MetricsBackend) XXX_Unmarshal(b []byte) error

type MultiValueTagSet 

type MultiValueTagSet map[string]map[string]bool

Set of tags that allows multiple values per key.

func (MultiValueTagSet) Keys 

func (t MultiValueTagSet) Keys() []string

func (MultiValueTagSet) String 

func (t MultiValueTagSet) String() string

func (MultiValueTagSet) Values 

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

type OutboundInterface 

type OutboundInterface struct {
	DataplaneIP   string
	DataplanePort uint32
}

func ParseOutboundInterface 

func ParseOutboundInterface(text string) (OutboundInterface, error)

func (OutboundInterface) String 

func (i OutboundInterface) String() string

type PrometheusMetricsBackendConfig 

type PrometheusMetricsBackendConfig struct {
	// Port on which a dataplane should expose HTTP endpoint with Prometheus
	// metrics.
	Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// Path on which a dataplane should expose HTTP endpoint with Prometheus
	// metrics.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Tags associated with an application this dataplane is deployed next to,
	// e.g. service=web, version=1.0.
	// `service` tag is mandatory.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// If true then endpoints for scraping metrics won't require mTLS even if mTLS
	// is enabled in Mesh. If nil, then it is treated as false.
	SkipMTLS             *wrappers.BoolValue `protobuf:"bytes,4,opt,name=skipMTLS,proto3" json:"skipMTLS,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

PrometheusMetricsBackendConfig defines configuration of Prometheus backend

func (*PrometheusMetricsBackendConfig) Descriptor 

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

func (*PrometheusMetricsBackendConfig) GetPath 

func (m *PrometheusMetricsBackendConfig) GetPath() string

func (*PrometheusMetricsBackendConfig) GetPort 

func (m *PrometheusMetricsBackendConfig) GetPort() uint32

func (*PrometheusMetricsBackendConfig) GetSkipMTLS 

func (m *PrometheusMetricsBackendConfig) GetSkipMTLS() *wrappers.BoolValue

func (*PrometheusMetricsBackendConfig) GetTags 

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

func (*PrometheusMetricsBackendConfig) ProtoMessage 

func (*PrometheusMetricsBackendConfig) ProtoMessage()

func (*PrometheusMetricsBackendConfig) Reset 

func (m *PrometheusMetricsBackendConfig) Reset()

func (*PrometheusMetricsBackendConfig) String 

func (m *PrometheusMetricsBackendConfig) String() string

func (*PrometheusMetricsBackendConfig) XXX_DiscardUnknown 

func (m *PrometheusMetricsBackendConfig) XXX_DiscardUnknown()

func (*PrometheusMetricsBackendConfig) XXX_Marshal 

func (m *PrometheusMetricsBackendConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrometheusMetricsBackendConfig) XXX_Merge 

func (m *PrometheusMetricsBackendConfig) XXX_Merge(src proto.Message)

func (*PrometheusMetricsBackendConfig) XXX_Size 

func (m *PrometheusMetricsBackendConfig) XXX_Size() int

func (*PrometheusMetricsBackendConfig) XXX_Unmarshal 

func (m *PrometheusMetricsBackendConfig) XXX_Unmarshal(b []byte) error

type ProxyTemplate 

type ProxyTemplate struct {
	// List of Dataplane selectors.
	// +optional
	Selectors []*Selector `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// Configuration for ProxyTemplate
	Conf                 *ProxyTemplate_Conf `protobuf:"bytes,2,opt,name=conf,proto3" json:"conf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

ProxyTemplate defines the desired state of ProxyTemplate

func (*ProxyTemplate) Descriptor 

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

func (*ProxyTemplate) GetConf 

func (m *ProxyTemplate) GetConf() *ProxyTemplate_Conf

func (*ProxyTemplate) GetSelectors 

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

func (*ProxyTemplate) ProtoMessage 

func (*ProxyTemplate) ProtoMessage()

func (*ProxyTemplate) Reset 

func (m *ProxyTemplate) Reset()

func (*ProxyTemplate) String 

func (m *ProxyTemplate) String() string

func (*ProxyTemplate) XXX_DiscardUnknown 

func (m *ProxyTemplate) XXX_DiscardUnknown()

func (*ProxyTemplate) XXX_Marshal 

func (m *ProxyTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyTemplate) XXX_Merge 

func (m *ProxyTemplate) XXX_Merge(src proto.Message)

func (*ProxyTemplate) XXX_Size 

func (m *ProxyTemplate) XXX_Size() int

func (*ProxyTemplate) XXX_Unmarshal 

func (m *ProxyTemplate) XXX_Unmarshal(b []byte) error

type ProxyTemplateProfileSource 

type ProxyTemplateProfileSource struct {
	// Profile name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Profile params if any.
	// +optional
	Params               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ProxyTemplateProfileSource) Descriptor 

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

func (*ProxyTemplateProfileSource) GetName 

func (m *ProxyTemplateProfileSource) GetName() string

func (*ProxyTemplateProfileSource) GetParams 

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

func (*ProxyTemplateProfileSource) ProtoMessage 

func (*ProxyTemplateProfileSource) ProtoMessage()

func (*ProxyTemplateProfileSource) Reset 

func (m *ProxyTemplateProfileSource) Reset()

func (*ProxyTemplateProfileSource) String 

func (m *ProxyTemplateProfileSource) String() string

func (*ProxyTemplateProfileSource) XXX_DiscardUnknown 

func (m *ProxyTemplateProfileSource) XXX_DiscardUnknown()

func (*ProxyTemplateProfileSource) XXX_Marshal 

func (m *ProxyTemplateProfileSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyTemplateProfileSource) XXX_Merge 

func (m *ProxyTemplateProfileSource) XXX_Merge(src proto.Message)

func (*ProxyTemplateProfileSource) XXX_Size 

func (m *ProxyTemplateProfileSource) XXX_Size() int

func (*ProxyTemplateProfileSource) XXX_Unmarshal 

func (m *ProxyTemplateProfileSource) XXX_Unmarshal(b []byte) error

type ProxyTemplateRawResource 

type ProxyTemplateRawResource struct {
	// The resource's name, to distinguish it from others of the same type of
	// resource.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The resource level version. It allows xDS to track the state of individual
	// resources.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// xDS resource.
	Resource             string   `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProxyTemplateRawResource) Descriptor 

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

func (*ProxyTemplateRawResource) GetName 

func (m *ProxyTemplateRawResource) GetName() string

func (*ProxyTemplateRawResource) GetResource 

func (m *ProxyTemplateRawResource) GetResource() string

func (*ProxyTemplateRawResource) GetVersion 

func (m *ProxyTemplateRawResource) GetVersion() string

func (*ProxyTemplateRawResource) ProtoMessage 

func (*ProxyTemplateRawResource) ProtoMessage()

func (*ProxyTemplateRawResource) Reset 

func (m *ProxyTemplateRawResource) Reset()

func (*ProxyTemplateRawResource) String 

func (m *ProxyTemplateRawResource) String() string

func (*ProxyTemplateRawResource) XXX_DiscardUnknown 

func (m *ProxyTemplateRawResource) XXX_DiscardUnknown()

func (*ProxyTemplateRawResource) XXX_Marshal 

func (m *ProxyTemplateRawResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyTemplateRawResource) XXX_Merge 

func (m *ProxyTemplateRawResource) XXX_Merge(src proto.Message)

func (*ProxyTemplateRawResource) XXX_Size 

func (m *ProxyTemplateRawResource) XXX_Size() int

func (*ProxyTemplateRawResource) XXX_Unmarshal 

func (m *ProxyTemplateRawResource) XXX_Unmarshal(b []byte) error

type ProxyTemplateRawSource 

type ProxyTemplateRawSource struct {
	// List of raw xDS resources.
	// +optional
	Resources            []*ProxyTemplateRawResource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ProxyTemplateRawSource) Descriptor 

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

func (*ProxyTemplateRawSource) GetResources 

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

func (*ProxyTemplateRawSource) ProtoMessage 

func (*ProxyTemplateRawSource) ProtoMessage()

func (*ProxyTemplateRawSource) Reset 

func (m *ProxyTemplateRawSource) Reset()

func (*ProxyTemplateRawSource) String 

func (m *ProxyTemplateRawSource) String() string

func (*ProxyTemplateRawSource) XXX_DiscardUnknown 

func (m *ProxyTemplateRawSource) XXX_DiscardUnknown()

func (*ProxyTemplateRawSource) XXX_Marshal 

func (m *ProxyTemplateRawSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyTemplateRawSource) XXX_Merge 

func (m *ProxyTemplateRawSource) XXX_Merge(src proto.Message)

func (*ProxyTemplateRawSource) XXX_Size 

func (m *ProxyTemplateRawSource) XXX_Size() int

func (*ProxyTemplateRawSource) XXX_Unmarshal 

func (m *ProxyTemplateRawSource) XXX_Unmarshal(b []byte) error

type ProxyTemplateSource 

type ProxyTemplateSource struct {
	// Name of a configuration source.
	// +optional
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to Type:
	//	*ProxyTemplateSource_Profile
	//	*ProxyTemplateSource_Raw
	Type                 isProxyTemplateSource_Type `protobuf_oneof:"type"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ProxyTemplateSource) Descriptor 

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

func (*ProxyTemplateSource) GetName 

func (m *ProxyTemplateSource) GetName() string

func (*ProxyTemplateSource) GetProfile 

func (m *ProxyTemplateSource) GetProfile() *ProxyTemplateProfileSource

func (*ProxyTemplateSource) GetRaw 

func (m *ProxyTemplateSource) GetRaw() *ProxyTemplateRawSource

func (*ProxyTemplateSource) GetType 

func (m *ProxyTemplateSource) GetType() isProxyTemplateSource_Type

func (*ProxyTemplateSource) ProtoMessage 

func (*ProxyTemplateSource) ProtoMessage()

func (*ProxyTemplateSource) Reset 

func (m *ProxyTemplateSource) Reset()

func (*ProxyTemplateSource) String 

func (m *ProxyTemplateSource) String() string

func (*ProxyTemplateSource) XXX_DiscardUnknown 

func (m *ProxyTemplateSource) XXX_DiscardUnknown()

func (*ProxyTemplateSource) XXX_Marshal 

func (m *ProxyTemplateSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyTemplateSource) XXX_Merge 

func (m *ProxyTemplateSource) XXX_Merge(src proto.Message)

func (*ProxyTemplateSource) XXX_OneofWrappers 

func (*ProxyTemplateSource) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ProxyTemplateSource) XXX_Size 

func (m *ProxyTemplateSource) XXX_Size() int

func (*ProxyTemplateSource) XXX_Unmarshal 

func (m *ProxyTemplateSource) XXX_Unmarshal(b []byte) error

type ProxyTemplateSource_Profile 

type ProxyTemplateSource_Profile struct {
	Profile *ProxyTemplateProfileSource `protobuf:"bytes,2,opt,name=profile,proto3,oneof"`
}

type ProxyTemplateSource_Raw 

type ProxyTemplateSource_Raw struct {
	Raw *ProxyTemplateRawSource `protobuf:"bytes,3,opt,name=raw,proto3,oneof"`
}

type ProxyTemplate_Conf 

type ProxyTemplate_Conf struct {
	// List of imported profiles.
	// +optional
	Imports []string `protobuf:"bytes,1,rep,name=imports,proto3" json:"imports,omitempty"`
	// List of raw xDS resources.
	// +optional
	Resources            []*ProxyTemplateRawResource `protobuf:"bytes,2,rep,name=resources,proto3" json:"resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ProxyTemplate_Conf) Descriptor 

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

func (*ProxyTemplate_Conf) GetImports 

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

func (*ProxyTemplate_Conf) GetResources 

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

func (*ProxyTemplate_Conf) ProtoMessage 

func (*ProxyTemplate_Conf) ProtoMessage()

func (*ProxyTemplate_Conf) Reset 

func (m *ProxyTemplate_Conf) Reset()

func (*ProxyTemplate_Conf) String 

func (m *ProxyTemplate_Conf) String() string

func (*ProxyTemplate_Conf) XXX_DiscardUnknown 

func (m *ProxyTemplate_Conf) XXX_DiscardUnknown()

func (*ProxyTemplate_Conf) XXX_Marshal 

func (m *ProxyTemplate_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyTemplate_Conf) XXX_Merge 

func (m *ProxyTemplate_Conf) XXX_Merge(src proto.Message)

func (*ProxyTemplate_Conf) XXX_Size 

func (m *ProxyTemplate_Conf) XXX_Size() int

func (*ProxyTemplate_Conf) XXX_Unmarshal 

func (m *ProxyTemplate_Conf) XXX_Unmarshal(b []byte) error

type Selector 

type Selector struct {
	// Tags to match, can be used for both source and destinations
	Match                map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Selector defines structure for selecting tags for given dataplane

func (*Selector) Descriptor 

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

func (*Selector) GetMatch 

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

func (*Selector) ProtoMessage 

func (*Selector) ProtoMessage()

func (*Selector) Reset 

func (m *Selector) Reset()

func (*Selector) String 

func (m *Selector) String() string

func (*Selector) XXX_DiscardUnknown 

func (m *Selector) XXX_DiscardUnknown()

func (*Selector) XXX_Marshal 

func (m *Selector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Selector) XXX_Merge 

func (m *Selector) XXX_Merge(src proto.Message)

func (*Selector) XXX_Size 

func (m *Selector) XXX_Size() int

func (*Selector) XXX_Unmarshal 

func (m *Selector) XXX_Unmarshal(b []byte) error

type SingleValueTagSet 

type SingleValueTagSet map[string]string

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

func (SingleValueTagSet) Exclude 

func (t SingleValueTagSet) Exclude(key string) SingleValueTagSet

func (SingleValueTagSet) Keys 

func (t SingleValueTagSet) Keys() []string

type TagSelector 

type TagSelector map[string]string

func MatchAll 

func MatchAll() TagSelector

func MatchAnyService 

func MatchAnyService() TagSelector

func MatchService 

func MatchService(service string) TagSelector

func MatchTags 

func MatchTags(tags map[string]string) TagSelector

func (TagSelector) Equal 

func (s TagSelector) Equal(other TagSelector) bool

func (TagSelector) Matches 

func (s TagSelector) Matches(tags map[string]string) bool

func (TagSelector) Rank 

func (s TagSelector) Rank() (r TagSelectorRank)

type TagSelectorRank 

type TagSelectorRank struct {
	// Number of tags that match by the exact value.
	ExactMatches int
	// Number of tags that match by a wildcard ('*').
	WildcardMatches int
}

TagSelectorRank helps to decide which of 2 selectors is more specific.

func (TagSelectorRank) CombinedWith 

func (r TagSelectorRank) CombinedWith(other TagSelectorRank) TagSelectorRank

func (TagSelectorRank) CompareTo 

func (r TagSelectorRank) CompareTo(other TagSelectorRank) int

type TcpLoggingBackendConfig 

type TcpLoggingBackendConfig struct {
	// Address to TCP service that will receive logs
	Address              string   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TcpLoggingBackendConfig defines configuration for TCP based access logs

func (*TcpLoggingBackendConfig) Descriptor 

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

func (*TcpLoggingBackendConfig) GetAddress 

func (m *TcpLoggingBackendConfig) GetAddress() string

func (*TcpLoggingBackendConfig) ProtoMessage 

func (*TcpLoggingBackendConfig) ProtoMessage()

func (*TcpLoggingBackendConfig) Reset 

func (m *TcpLoggingBackendConfig) Reset()

func (*TcpLoggingBackendConfig) String 

func (m *TcpLoggingBackendConfig) String() string

func (*TcpLoggingBackendConfig) Validate 

func (m *TcpLoggingBackendConfig) Validate() error

Validate checks the field values on TcpLoggingBackendConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TcpLoggingBackendConfig) XXX_DiscardUnknown 

func (m *TcpLoggingBackendConfig) XXX_DiscardUnknown()

func (*TcpLoggingBackendConfig) XXX_Marshal 

func (m *TcpLoggingBackendConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TcpLoggingBackendConfig) XXX_Merge 

func (m *TcpLoggingBackendConfig) XXX_Merge(src proto.Message)

func (*TcpLoggingBackendConfig) XXX_Size 

func (m *TcpLoggingBackendConfig) XXX_Size() int

func (*TcpLoggingBackendConfig) XXX_Unmarshal 

func (m *TcpLoggingBackendConfig) XXX_Unmarshal(b []byte) error

type TcpLoggingBackendConfigValidationError 

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

TcpLoggingBackendConfigValidationError is the validation error returned by TcpLoggingBackendConfig.Validate if the designated constraints aren't met.

func (TcpLoggingBackendConfigValidationError) Cause 

func (e TcpLoggingBackendConfigValidationError) Cause() error

Cause function returns cause value.

func (TcpLoggingBackendConfigValidationError) Error 

func (e TcpLoggingBackendConfigValidationError) Error() string

Error satisfies the builtin error interface

func (TcpLoggingBackendConfigValidationError) ErrorName 

func (e TcpLoggingBackendConfigValidationError) ErrorName() string

ErrorName returns error name.

func (TcpLoggingBackendConfigValidationError) Field 

func (e TcpLoggingBackendConfigValidationError) Field() string

Field function returns field value.

func (TcpLoggingBackendConfigValidationError) Key 

func (e TcpLoggingBackendConfigValidationError) Key() bool

Key function returns key value.

func (TcpLoggingBackendConfigValidationError) Reason 

func (e TcpLoggingBackendConfigValidationError) Reason() string

Reason function returns reason value.

type Tracing 

type Tracing struct {
	// Name of the default backend
	DefaultBackend string `protobuf:"bytes,1,opt,name=defaultBackend,proto3" json:"defaultBackend,omitempty"`
	// List of available tracing backends
	Backends             []*TracingBackend `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Tracing defines tracing configuration of the mesh.

func (*Tracing) Descriptor 

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

func (*Tracing) GetBackends 

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

func (*Tracing) GetDefaultBackend 

func (m *Tracing) GetDefaultBackend() string

func (*Tracing) ProtoMessage 

func (*Tracing) ProtoMessage()

func (*Tracing) Reset 

func (m *Tracing) Reset()

func (*Tracing) String 

func (m *Tracing) String() string

func (*Tracing) Validate 

func (m *Tracing) Validate() error

Validate checks the field values on Tracing with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Tracing) XXX_DiscardUnknown 

func (m *Tracing) XXX_DiscardUnknown()

func (*Tracing) XXX_Marshal 

func (m *Tracing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tracing) XXX_Merge 

func (m *Tracing) XXX_Merge(src proto.Message)

func (*Tracing) XXX_Size 

func (m *Tracing) XXX_Size() int

func (*Tracing) XXX_Unmarshal 

func (m *Tracing) XXX_Unmarshal(b []byte) error

type TracingBackend 

type TracingBackend struct {
	// Name of the backend, can be then used in Mesh.tracing.defaultBackend or in
	// TrafficTrace
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Percentage of traces that will be sent to the backend (range 0.0 - 100.0).
	// Empty value defaults to 100.0%
	Sampling *wrappers.DoubleValue `protobuf:"bytes,2,opt,name=sampling,proto3" json:"sampling,omitempty"`
	// Type of the backend (Kuma ships with 'zipkin')
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// Configuration of the backend
	Conf                 *_struct.Struct `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

func (*TracingBackend) Descriptor 

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

func (*TracingBackend) GetConf 

func (m *TracingBackend) GetConf() *_struct.Struct

func (*TracingBackend) GetName 

func (m *TracingBackend) GetName() string

func (*TracingBackend) GetSampling 

func (m *TracingBackend) GetSampling() *wrappers.DoubleValue

func (*TracingBackend) GetType 

func (m *TracingBackend) GetType() string

func (*TracingBackend) ProtoMessage 

func (*TracingBackend) ProtoMessage()

func (*TracingBackend) Reset 

func (m *TracingBackend) Reset()

func (*TracingBackend) String 

func (m *TracingBackend) String() string

func (*TracingBackend) Validate 

func (m *TracingBackend) Validate() error

Validate checks the field values on TracingBackend with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TracingBackend) XXX_DiscardUnknown 

func (m *TracingBackend) XXX_DiscardUnknown()

func (*TracingBackend) XXX_Marshal 

func (m *TracingBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TracingBackend) XXX_Merge 

func (m *TracingBackend) XXX_Merge(src proto.Message)

func (*TracingBackend) XXX_Size 

func (m *TracingBackend) XXX_Size() int

func (*TracingBackend) XXX_Unmarshal 

func (m *TracingBackend) XXX_Unmarshal(b []byte) error

type TracingBackendValidationError 

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

TracingBackendValidationError is the validation error returned by TracingBackend.Validate if the designated constraints aren't met.

func (TracingBackendValidationError) Cause 

func (e TracingBackendValidationError) Cause() error

Cause function returns cause value.

func (TracingBackendValidationError) Error 

func (e TracingBackendValidationError) Error() string

Error satisfies the builtin error interface

func (TracingBackendValidationError) ErrorName 

func (e TracingBackendValidationError) ErrorName() string

ErrorName returns error name.

func (TracingBackendValidationError) Field 

func (e TracingBackendValidationError) Field() string

Field function returns field value.

func (TracingBackendValidationError) Key 

func (e TracingBackendValidationError) Key() bool

Key function returns key value.

func (TracingBackendValidationError) Reason 

func (e TracingBackendValidationError) Reason() string

Reason function returns reason value.

type TracingValidationError 

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

TracingValidationError is the validation error returned by Tracing.Validate if the designated constraints aren't met.

func (TracingValidationError) Cause 

func (e TracingValidationError) Cause() error

Cause function returns cause value.

func (TracingValidationError) Error 

func (e TracingValidationError) Error() string

Error satisfies the builtin error interface

func (TracingValidationError) ErrorName 

func (e TracingValidationError) ErrorName() string

ErrorName returns error name.

func (TracingValidationError) Field 

func (e TracingValidationError) Field() string

Field function returns field value.

func (TracingValidationError) Key 

func (e TracingValidationError) Key() bool

Key function returns key value.

func (TracingValidationError) Reason 

func (e TracingValidationError) Reason() string

Reason function returns reason value.

type TrafficLog 

type TrafficLog struct {
	// List of selectors to match dataplanes that are sources of traffic.
	Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	// List of selectors to match services that are destinations of traffic.
	Destinations []*Selector `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"`
	// Configuration of the logging.
	Conf                 *TrafficLog_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

TrafficLog defines log for traffic between dataplanes.

func (*TrafficLog) Descriptor 

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

func (*TrafficLog) GetConf 

func (m *TrafficLog) GetConf() *TrafficLog_Conf

func (*TrafficLog) GetDestinations 

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

func (*TrafficLog) GetSources 

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

func (*TrafficLog) ProtoMessage 

func (*TrafficLog) ProtoMessage()

func (*TrafficLog) Reset 

func (m *TrafficLog) Reset()

func (*TrafficLog) String 

func (m *TrafficLog) String() string

func (*TrafficLog) XXX_DiscardUnknown 

func (m *TrafficLog) XXX_DiscardUnknown()

func (*TrafficLog) XXX_Marshal 

func (m *TrafficLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficLog) XXX_Merge 

func (m *TrafficLog) XXX_Merge(src proto.Message)

func (*TrafficLog) XXX_Size 

func (m *TrafficLog) XXX_Size() int

func (*TrafficLog) XXX_Unmarshal 

func (m *TrafficLog) XXX_Unmarshal(b []byte) error

type TrafficLog_Conf 

type TrafficLog_Conf struct {
	// Backend defined in the Mesh entity.
	Backend              string   `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Configuration defines settings of the logging.

func (*TrafficLog_Conf) Descriptor 

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

func (*TrafficLog_Conf) GetBackend 

func (m *TrafficLog_Conf) GetBackend() string

func (*TrafficLog_Conf) ProtoMessage 

func (*TrafficLog_Conf) ProtoMessage()

func (*TrafficLog_Conf) Reset 

func (m *TrafficLog_Conf) Reset()

func (*TrafficLog_Conf) String 

func (m *TrafficLog_Conf) String() string

func (*TrafficLog_Conf) XXX_DiscardUnknown 

func (m *TrafficLog_Conf) XXX_DiscardUnknown()

func (*TrafficLog_Conf) XXX_Marshal 

func (m *TrafficLog_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficLog_Conf) XXX_Merge 

func (m *TrafficLog_Conf) XXX_Merge(src proto.Message)

func (*TrafficLog_Conf) XXX_Size 

func (m *TrafficLog_Conf) XXX_Size() int

func (*TrafficLog_Conf) XXX_Unmarshal 

func (m *TrafficLog_Conf) XXX_Unmarshal(b []byte) error

type TrafficPermission 

type TrafficPermission struct {
	// List of selectors to match dataplanes that are sources of traffic.
	Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	// List of selectors to match services that are destinations of traffic.
	Destinations         []*Selector `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

TrafficPermission defines permission for traffic between dataplanes.

func (*TrafficPermission) Descriptor 

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

func (*TrafficPermission) GetDestinations 

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

func (*TrafficPermission) GetSources 

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

func (*TrafficPermission) ProtoMessage 

func (*TrafficPermission) ProtoMessage()

func (*TrafficPermission) Reset 

func (m *TrafficPermission) Reset()

func (*TrafficPermission) String 

func (m *TrafficPermission) String() string

func (*TrafficPermission) XXX_DiscardUnknown 

func (m *TrafficPermission) XXX_DiscardUnknown()

func (*TrafficPermission) XXX_Marshal 

func (m *TrafficPermission) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficPermission) XXX_Merge 

func (m *TrafficPermission) XXX_Merge(src proto.Message)

func (*TrafficPermission) XXX_Size 

func (m *TrafficPermission) XXX_Size() int

func (*TrafficPermission) XXX_Unmarshal 

func (m *TrafficPermission) XXX_Unmarshal(b []byte) error

type TrafficRoute 

type TrafficRoute struct {
	// List of selectors to match dataplanes that are sources of traffic.
	Sources []*Selector `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	// List of selectors to match services that are destinations of traffic.
	//
	// Notice the difference between sources and destinations.
	// While the source of traffic is always a dataplane within a mesh,
	// the destination is a service that could be either within or outside
	// of a mesh.
	Destinations []*Selector `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"`
	// List of destinations with weights assigned to them.
	Conf                 []*TrafficRoute_WeightedDestination `protobuf:"bytes,3,rep,name=conf,proto3" json:"conf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

TrafficRoute defines routing rules for L4 traffic.

func (*TrafficRoute) Descriptor 

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

func (*TrafficRoute) GetConf 

func (m *TrafficRoute) GetConf() []*TrafficRoute_WeightedDestination

func (*TrafficRoute) GetDestinations 

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

func (*TrafficRoute) GetSources 

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

func (*TrafficRoute) ProtoMessage 

func (*TrafficRoute) ProtoMessage()

func (*TrafficRoute) Reset 

func (m *TrafficRoute) Reset()

func (*TrafficRoute) String 

func (m *TrafficRoute) String() string

func (*TrafficRoute) Validate 

func (m *TrafficRoute) Validate() error

Validate checks the field values on TrafficRoute with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TrafficRoute) XXX_DiscardUnknown 

func (m *TrafficRoute) XXX_DiscardUnknown()

func (*TrafficRoute) XXX_Marshal 

func (m *TrafficRoute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficRoute) XXX_Merge 

func (m *TrafficRoute) XXX_Merge(src proto.Message)

func (*TrafficRoute) XXX_Size 

func (m *TrafficRoute) XXX_Size() int

func (*TrafficRoute) XXX_Unmarshal 

func (m *TrafficRoute) XXX_Unmarshal(b []byte) error

type TrafficRouteValidationError 

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

TrafficRouteValidationError is the validation error returned by TrafficRoute.Validate if the designated constraints aren't met.

func (TrafficRouteValidationError) Cause 

func (e TrafficRouteValidationError) Cause() error

Cause function returns cause value.

func (TrafficRouteValidationError) Error 

func (e TrafficRouteValidationError) Error() string

Error satisfies the builtin error interface

func (TrafficRouteValidationError) ErrorName 

func (e TrafficRouteValidationError) ErrorName() string

ErrorName returns error name.

func (TrafficRouteValidationError) Field 

func (e TrafficRouteValidationError) Field() string

Field function returns field value.

func (TrafficRouteValidationError) Key 

func (e TrafficRouteValidationError) Key() bool

Key function returns key value.

func (TrafficRouteValidationError) Reason 

func (e TrafficRouteValidationError) Reason() string

Reason function returns reason value.

type TrafficRoute_WeightedDestination 

type TrafficRoute_WeightedDestination struct {
	// Weight assigned to that destination.
	Weight uint32 `protobuf:"varint,1,opt,name=weight,proto3" json:"weight,omitempty"`
	// Selector to match individual endpoints that comprise that destination.
	//
	// Notice that an endpoint can be either inside or outside the mesh.
	// In the former case an endpoint corresponds to a dataplane,
	// in the latter case an endpoint is a black box.
	Destination          map[string]string `` /* 163-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

WeightedDestination defines a destination with a weight assigned to it.

func (*TrafficRoute_WeightedDestination) Descriptor 

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

func (*TrafficRoute_WeightedDestination) GetDestination 

func (m *TrafficRoute_WeightedDestination) GetDestination() map[string]string

func (*TrafficRoute_WeightedDestination) GetWeight 

func (m *TrafficRoute_WeightedDestination) GetWeight() uint32

func (*TrafficRoute_WeightedDestination) ProtoMessage 

func (*TrafficRoute_WeightedDestination) ProtoMessage()

func (*TrafficRoute_WeightedDestination) Reset 

func (m *TrafficRoute_WeightedDestination) Reset()

func (*TrafficRoute_WeightedDestination) String 

func (m *TrafficRoute_WeightedDestination) String() string

func (*TrafficRoute_WeightedDestination) Validate 

func (m *TrafficRoute_WeightedDestination) Validate() error

Validate checks the field values on TrafficRoute_WeightedDestination with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TrafficRoute_WeightedDestination) XXX_DiscardUnknown 

func (m *TrafficRoute_WeightedDestination) XXX_DiscardUnknown()

func (*TrafficRoute_WeightedDestination) XXX_Marshal 

func (m *TrafficRoute_WeightedDestination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficRoute_WeightedDestination) XXX_Merge 

func (m *TrafficRoute_WeightedDestination) XXX_Merge(src proto.Message)

func (*TrafficRoute_WeightedDestination) XXX_Size 

func (m *TrafficRoute_WeightedDestination) XXX_Size() int

func (*TrafficRoute_WeightedDestination) XXX_Unmarshal 

func (m *TrafficRoute_WeightedDestination) XXX_Unmarshal(b []byte) error

type TrafficRoute_WeightedDestinationValidationError 

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

TrafficRoute_WeightedDestinationValidationError is the validation error returned by TrafficRoute_WeightedDestination.Validate if the designated constraints aren't met.

func (TrafficRoute_WeightedDestinationValidationError) Cause 

func (e TrafficRoute_WeightedDestinationValidationError) Cause() error

Cause function returns cause value.

func (TrafficRoute_WeightedDestinationValidationError) Error 

func (e TrafficRoute_WeightedDestinationValidationError) Error() string

Error satisfies the builtin error interface

func (TrafficRoute_WeightedDestinationValidationError) ErrorName 

func (e TrafficRoute_WeightedDestinationValidationError) ErrorName() string

ErrorName returns error name.

func (TrafficRoute_WeightedDestinationValidationError) Field 

func (e TrafficRoute_WeightedDestinationValidationError) Field() string

Field function returns field value.

func (TrafficRoute_WeightedDestinationValidationError) Key 

func (e TrafficRoute_WeightedDestinationValidationError) Key() bool

Key function returns key value.

func (TrafficRoute_WeightedDestinationValidationError) Reason 

func (e TrafficRoute_WeightedDestinationValidationError) Reason() string

Reason function returns reason value.

type TrafficTrace 

type TrafficTrace struct {
	// List of selectors to match dataplanes.
	Selectors []*Selector `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// Configuration of the tracing.
	Conf                 *TrafficTrace_Conf `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

TrafficTrace defines trace configuration for selected dataplanes.

func (*TrafficTrace) Descriptor 

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

func (*TrafficTrace) GetConf 

func (m *TrafficTrace) GetConf() *TrafficTrace_Conf

func (*TrafficTrace) GetSelectors 

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

func (*TrafficTrace) ProtoMessage 

func (*TrafficTrace) ProtoMessage()

func (*TrafficTrace) Reset 

func (m *TrafficTrace) Reset()

func (*TrafficTrace) String 

func (m *TrafficTrace) String() string

func (*TrafficTrace) XXX_DiscardUnknown 

func (m *TrafficTrace) XXX_DiscardUnknown()

func (*TrafficTrace) XXX_Marshal 

func (m *TrafficTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficTrace) XXX_Merge 

func (m *TrafficTrace) XXX_Merge(src proto.Message)

func (*TrafficTrace) XXX_Size 

func (m *TrafficTrace) XXX_Size() int

func (*TrafficTrace) XXX_Unmarshal 

func (m *TrafficTrace) XXX_Unmarshal(b []byte) error

type TrafficTrace_Conf 

type TrafficTrace_Conf struct {
	// Backend defined in the Mesh entity.
	Backend              string   `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Configuration defines settings of the tracing.

func (*TrafficTrace_Conf) Descriptor 

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

func (*TrafficTrace_Conf) GetBackend 

func (m *TrafficTrace_Conf) GetBackend() string

func (*TrafficTrace_Conf) ProtoMessage 

func (*TrafficTrace_Conf) ProtoMessage()

func (*TrafficTrace_Conf) Reset 

func (m *TrafficTrace_Conf) Reset()

func (*TrafficTrace_Conf) String 

func (m *TrafficTrace_Conf) String() string

func (*TrafficTrace_Conf) XXX_DiscardUnknown 

func (m *TrafficTrace_Conf) XXX_DiscardUnknown()

func (*TrafficTrace_Conf) XXX_Marshal 

func (m *TrafficTrace_Conf) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficTrace_Conf) XXX_Merge 

func (m *TrafficTrace_Conf) XXX_Merge(src proto.Message)

func (*TrafficTrace_Conf) XXX_Size 

func (m *TrafficTrace_Conf) XXX_Size() int

func (*TrafficTrace_Conf) XXX_Unmarshal 

func (m *TrafficTrace_Conf) XXX_Unmarshal(b []byte) error

type UnimplementedKumaDiscoveryServiceServer 

type UnimplementedKumaDiscoveryServiceServer struct {
}

UnimplementedKumaDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedKumaDiscoveryServiceServer) DeltaKumaResources 

func (*UnimplementedKumaDiscoveryServiceServer) DeltaKumaResources(srv KumaDiscoveryService_DeltaKumaResourcesServer) error

func (*UnimplementedKumaDiscoveryServiceServer) FetchKumaResources 

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

func (*UnimplementedKumaDiscoveryServiceServer) StreamKumaResources 

func (*UnimplementedKumaDiscoveryServiceServer) StreamKumaResources(srv KumaDiscoveryService_StreamKumaResourcesServer) error

type ZipkinTracingBackendConfig 

type ZipkinTracingBackendConfig struct {
	// Address of Zipkin collector.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Generate 128bit traces. Default: false
	TraceId128Bit bool `protobuf:"varint,2,opt,name=traceId128bit,proto3" json:"traceId128bit,omitempty"`
	// Version of the API. values: httpJson, httpJsonV1, httpProto. Default:
	// httpJson see
	// https://www.envoyproxy.io/docs/envoy/latest/api-v3/config/trace/v3/trace.proto#envoy-v3-api-enum-config-trace-v3-zipkinconfig-collectorendpointversion
	ApiVersion           string   `protobuf:"bytes,3,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ZipkinTracingBackendConfig) Descriptor 

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

func (*ZipkinTracingBackendConfig) GetApiVersion 

func (m *ZipkinTracingBackendConfig) GetApiVersion() string

func (*ZipkinTracingBackendConfig) GetTraceId128Bit 

func (m *ZipkinTracingBackendConfig) GetTraceId128Bit() bool

func (*ZipkinTracingBackendConfig) GetUrl 

func (m *ZipkinTracingBackendConfig) GetUrl() string

func (*ZipkinTracingBackendConfig) ProtoMessage 

func (*ZipkinTracingBackendConfig) ProtoMessage()

func (*ZipkinTracingBackendConfig) Reset 

func (m *ZipkinTracingBackendConfig) Reset()

func (*ZipkinTracingBackendConfig) String 

func (m *ZipkinTracingBackendConfig) String() string

func (*ZipkinTracingBackendConfig) Validate 

func (m *ZipkinTracingBackendConfig) Validate() error

Validate checks the field values on ZipkinTracingBackendConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ZipkinTracingBackendConfig) XXX_DiscardUnknown 

func (m *ZipkinTracingBackendConfig) XXX_DiscardUnknown()

func (*ZipkinTracingBackendConfig) XXX_Marshal 

func (m *ZipkinTracingBackendConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ZipkinTracingBackendConfig) XXX_Merge 

func (m *ZipkinTracingBackendConfig) XXX_Merge(src proto.Message)

func (*ZipkinTracingBackendConfig) XXX_Size 

func (m *ZipkinTracingBackendConfig) XXX_Size() int

func (*ZipkinTracingBackendConfig) XXX_Unmarshal 

func (m *ZipkinTracingBackendConfig) XXX_Unmarshal(b []byte) error

type ZipkinTracingBackendConfigValidationError 

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

ZipkinTracingBackendConfigValidationError is the validation error returned by ZipkinTracingBackendConfig.Validate if the designated constraints aren't met.

func (ZipkinTracingBackendConfigValidationError) Cause 

func (e ZipkinTracingBackendConfigValidationError) Cause() error

Cause function returns cause value.

func (ZipkinTracingBackendConfigValidationError) Error 

func (e ZipkinTracingBackendConfigValidationError) Error() string

Error satisfies the builtin error interface

func (ZipkinTracingBackendConfigValidationError) ErrorName 

func (e ZipkinTracingBackendConfigValidationError) ErrorName() string

ErrorName returns error name.

func (ZipkinTracingBackendConfigValidationError) Field 

func (e ZipkinTracingBackendConfigValidationError) Field() string

Field function returns field value.

func (ZipkinTracingBackendConfigValidationError) Key 

func (e ZipkinTracingBackendConfigValidationError) Key() bool

Key function returns key value.

func (ZipkinTracingBackendConfigValidationError) Reason 

func (e ZipkinTracingBackendConfigValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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