envoy_service_discovery_v2

package
v0.9.4 Latest Latest
Warning

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

Go to latest
Published: Feb 13, 2020 License: Apache-2.0 Imports: 26 Imported by: 170

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Capability_Protocol_name = map[int32]string{
	0: "HTTP",
	1: "TCP",
	2: "REDIS",
}
View Source
var Capability_Protocol_value = map[string]int32{
	"HTTP":  0,
	"TCP":   1,
	"REDIS": 2,
}

Functions

func RegisterAggregatedDiscoveryServiceServer

func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer)

func RegisterHealthDiscoveryServiceServer

func RegisterHealthDiscoveryServiceServer(s *grpc.Server, srv HealthDiscoveryServiceServer)

func RegisterRuntimeDiscoveryServiceServer added in v0.8.1

func RegisterRuntimeDiscoveryServiceServer(s *grpc.Server, srv RuntimeDiscoveryServiceServer)

func RegisterSecretDiscoveryServiceServer

func RegisterSecretDiscoveryServiceServer(s *grpc.Server, srv SecretDiscoveryServiceServer)

Types

type AdsDummy

type AdsDummy struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AdsDummy) Descriptor

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

func (*AdsDummy) ProtoMessage

func (*AdsDummy) ProtoMessage()

func (*AdsDummy) Reset

func (m *AdsDummy) Reset()

func (*AdsDummy) String

func (m *AdsDummy) String() string

func (*AdsDummy) Validate

func (m *AdsDummy) Validate() error

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

func (*AdsDummy) XXX_DiscardUnknown

func (m *AdsDummy) XXX_DiscardUnknown()

func (*AdsDummy) XXX_Marshal

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

func (*AdsDummy) XXX_Merge

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

func (*AdsDummy) XXX_Size

func (m *AdsDummy) XXX_Size() int

func (*AdsDummy) XXX_Unmarshal

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

type AdsDummyValidationError

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

AdsDummyValidationError is the validation error returned by AdsDummy.Validate if the designated constraints aren't met.

func (AdsDummyValidationError) Cause

func (e AdsDummyValidationError) Cause() error

Cause function returns cause value.

func (AdsDummyValidationError) Error

func (e AdsDummyValidationError) Error() string

Error satisfies the builtin error interface

func (AdsDummyValidationError) ErrorName added in v0.7.0

func (e AdsDummyValidationError) ErrorName() string

ErrorName returns error name.

func (AdsDummyValidationError) Field

func (e AdsDummyValidationError) Field() string

Field function returns field value.

func (AdsDummyValidationError) Key

func (e AdsDummyValidationError) Key() bool

Key function returns key value.

func (AdsDummyValidationError) Reason

func (e AdsDummyValidationError) Reason() string

Reason function returns reason value.

type AggregatedDiscoveryServiceClient

type AggregatedDiscoveryServiceClient interface {
	StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error)
	DeltaAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error)
}

AggregatedDiscoveryServiceClient is the client API for AggregatedDiscoveryService service.

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

func NewAggregatedDiscoveryServiceClient

func NewAggregatedDiscoveryServiceClient(cc *grpc.ClientConn) AggregatedDiscoveryServiceClient

type AggregatedDiscoveryServiceServer

type AggregatedDiscoveryServiceServer interface {
	StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
	DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
}

AggregatedDiscoveryServiceServer is the server API for AggregatedDiscoveryService service.

type AggregatedDiscoveryService_DeltaAggregatedResourcesClient added in v0.6.9

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

type AggregatedDiscoveryService_DeltaAggregatedResourcesServer added in v0.6.9

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

type AggregatedDiscoveryService_StreamAggregatedResourcesClient

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

type AggregatedDiscoveryService_StreamAggregatedResourcesServer

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

type Capability

type Capability struct {
	HealthCheckProtocols []Capability_Protocol `` /* 183-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Capability) Descriptor

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

func (*Capability) GetHealthCheckProtocols

func (m *Capability) GetHealthCheckProtocols() []Capability_Protocol

func (*Capability) ProtoMessage

func (*Capability) ProtoMessage()

func (*Capability) Reset

func (m *Capability) Reset()

func (*Capability) String

func (m *Capability) String() string

func (*Capability) Validate

func (m *Capability) Validate() error

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

func (*Capability) XXX_DiscardUnknown

func (m *Capability) XXX_DiscardUnknown()

func (*Capability) XXX_Marshal

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

func (*Capability) XXX_Merge

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

func (*Capability) XXX_Size

func (m *Capability) XXX_Size() int

func (*Capability) XXX_Unmarshal

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

type CapabilityValidationError

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

CapabilityValidationError is the validation error returned by Capability.Validate if the designated constraints aren't met.

func (CapabilityValidationError) Cause

func (e CapabilityValidationError) Cause() error

Cause function returns cause value.

func (CapabilityValidationError) Error

Error satisfies the builtin error interface

func (CapabilityValidationError) ErrorName added in v0.7.0

func (e CapabilityValidationError) ErrorName() string

ErrorName returns error name.

func (CapabilityValidationError) Field

Field function returns field value.

func (CapabilityValidationError) Key

Key function returns key value.

func (CapabilityValidationError) Reason

func (e CapabilityValidationError) Reason() string

Reason function returns reason value.

type Capability_Protocol

type Capability_Protocol int32
const (
	Capability_HTTP  Capability_Protocol = 0
	Capability_TCP   Capability_Protocol = 1
	Capability_REDIS Capability_Protocol = 2
)

func (Capability_Protocol) EnumDescriptor

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

func (Capability_Protocol) String

func (x Capability_Protocol) String() string

type ClusterHealthCheck

type ClusterHealthCheck struct {
	ClusterName          string               `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	HealthChecks         []*core.HealthCheck  `protobuf:"bytes,2,rep,name=health_checks,json=healthChecks,proto3" json:"health_checks,omitempty"`
	LocalityEndpoints    []*LocalityEndpoints `protobuf:"bytes,3,rep,name=locality_endpoints,json=localityEndpoints,proto3" json:"locality_endpoints,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ClusterHealthCheck) Descriptor

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

func (*ClusterHealthCheck) GetClusterName

func (m *ClusterHealthCheck) GetClusterName() string

func (*ClusterHealthCheck) GetHealthChecks

func (m *ClusterHealthCheck) GetHealthChecks() []*core.HealthCheck

func (*ClusterHealthCheck) GetLocalityEndpoints

func (m *ClusterHealthCheck) GetLocalityEndpoints() []*LocalityEndpoints

func (*ClusterHealthCheck) ProtoMessage

func (*ClusterHealthCheck) ProtoMessage()

func (*ClusterHealthCheck) Reset

func (m *ClusterHealthCheck) Reset()

func (*ClusterHealthCheck) String

func (m *ClusterHealthCheck) String() string

func (*ClusterHealthCheck) Validate

func (m *ClusterHealthCheck) Validate() error

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

func (*ClusterHealthCheck) XXX_DiscardUnknown

func (m *ClusterHealthCheck) XXX_DiscardUnknown()

func (*ClusterHealthCheck) XXX_Marshal

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

func (*ClusterHealthCheck) XXX_Merge

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

func (*ClusterHealthCheck) XXX_Size

func (m *ClusterHealthCheck) XXX_Size() int

func (*ClusterHealthCheck) XXX_Unmarshal

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

type ClusterHealthCheckValidationError

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

ClusterHealthCheckValidationError is the validation error returned by ClusterHealthCheck.Validate if the designated constraints aren't met.

func (ClusterHealthCheckValidationError) Cause

Cause function returns cause value.

func (ClusterHealthCheckValidationError) Error

Error satisfies the builtin error interface

func (ClusterHealthCheckValidationError) ErrorName added in v0.7.0

ErrorName returns error name.

func (ClusterHealthCheckValidationError) Field

Field function returns field value.

func (ClusterHealthCheckValidationError) Key

Key function returns key value.

func (ClusterHealthCheckValidationError) Reason

Reason function returns reason value.

type EndpointHealth

type EndpointHealth struct {
	Endpoint             *endpoint.Endpoint `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	HealthStatus         core.HealthStatus  `` /* 134-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*EndpointHealth) Descriptor

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

func (*EndpointHealth) GetEndpoint

func (m *EndpointHealth) GetEndpoint() *endpoint.Endpoint

func (*EndpointHealth) GetHealthStatus

func (m *EndpointHealth) GetHealthStatus() core.HealthStatus

func (*EndpointHealth) ProtoMessage

func (*EndpointHealth) ProtoMessage()

func (*EndpointHealth) Reset

func (m *EndpointHealth) Reset()

func (*EndpointHealth) String

func (m *EndpointHealth) String() string

func (*EndpointHealth) Validate

func (m *EndpointHealth) Validate() error

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

func (*EndpointHealth) XXX_DiscardUnknown

func (m *EndpointHealth) XXX_DiscardUnknown()

func (*EndpointHealth) XXX_Marshal

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

func (*EndpointHealth) XXX_Merge

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

func (*EndpointHealth) XXX_Size

func (m *EndpointHealth) XXX_Size() int

func (*EndpointHealth) XXX_Unmarshal

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

type EndpointHealthResponse

type EndpointHealthResponse struct {
	EndpointsHealth      []*EndpointHealth `protobuf:"bytes,1,rep,name=endpoints_health,json=endpointsHealth,proto3" json:"endpoints_health,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*EndpointHealthResponse) Descriptor

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

func (*EndpointHealthResponse) GetEndpointsHealth

func (m *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealth

func (*EndpointHealthResponse) ProtoMessage

func (*EndpointHealthResponse) ProtoMessage()

func (*EndpointHealthResponse) Reset

func (m *EndpointHealthResponse) Reset()

func (*EndpointHealthResponse) String

func (m *EndpointHealthResponse) String() string

func (*EndpointHealthResponse) Validate

func (m *EndpointHealthResponse) Validate() error

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

func (*EndpointHealthResponse) XXX_DiscardUnknown

func (m *EndpointHealthResponse) XXX_DiscardUnknown()

func (*EndpointHealthResponse) XXX_Marshal

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

func (*EndpointHealthResponse) XXX_Merge

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

func (*EndpointHealthResponse) XXX_Size

func (m *EndpointHealthResponse) XXX_Size() int

func (*EndpointHealthResponse) XXX_Unmarshal

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

type EndpointHealthResponseValidationError

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

EndpointHealthResponseValidationError is the validation error returned by EndpointHealthResponse.Validate if the designated constraints aren't met.

func (EndpointHealthResponseValidationError) Cause

Cause function returns cause value.

func (EndpointHealthResponseValidationError) Error

Error satisfies the builtin error interface

func (EndpointHealthResponseValidationError) ErrorName added in v0.7.0

ErrorName returns error name.

func (EndpointHealthResponseValidationError) Field

Field function returns field value.

func (EndpointHealthResponseValidationError) Key

Key function returns key value.

func (EndpointHealthResponseValidationError) Reason

Reason function returns reason value.

type EndpointHealthValidationError

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

EndpointHealthValidationError is the validation error returned by EndpointHealth.Validate if the designated constraints aren't met.

func (EndpointHealthValidationError) Cause

Cause function returns cause value.

func (EndpointHealthValidationError) Error

Error satisfies the builtin error interface

func (EndpointHealthValidationError) ErrorName added in v0.7.0

func (e EndpointHealthValidationError) ErrorName() string

ErrorName returns error name.

func (EndpointHealthValidationError) Field

Field function returns field value.

func (EndpointHealthValidationError) Key

Key function returns key value.

func (EndpointHealthValidationError) Reason

Reason function returns reason value.

type HealthCheckRequest

type HealthCheckRequest struct {
	Node                 *core.Node  `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Capability           *Capability `protobuf:"bytes,2,opt,name=capability,proto3" json:"capability,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*HealthCheckRequest) Descriptor

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

func (*HealthCheckRequest) GetCapability

func (m *HealthCheckRequest) GetCapability() *Capability

func (*HealthCheckRequest) GetNode

func (m *HealthCheckRequest) GetNode() *core.Node

func (*HealthCheckRequest) ProtoMessage

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) Reset

func (m *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String

func (m *HealthCheckRequest) String() string

func (*HealthCheckRequest) Validate

func (m *HealthCheckRequest) Validate() error

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

func (*HealthCheckRequest) XXX_DiscardUnknown

func (m *HealthCheckRequest) XXX_DiscardUnknown()

func (*HealthCheckRequest) XXX_Marshal

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

func (*HealthCheckRequest) XXX_Merge

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

func (*HealthCheckRequest) XXX_Size

func (m *HealthCheckRequest) XXX_Size() int

func (*HealthCheckRequest) XXX_Unmarshal

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

type HealthCheckRequestOrEndpointHealthResponse

type HealthCheckRequestOrEndpointHealthResponse struct {
	// Types that are valid to be assigned to RequestType:
	//	*HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest
	//	*HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse
	RequestType          isHealthCheckRequestOrEndpointHealthResponse_RequestType `protobuf_oneof:"request_type"`
	XXX_NoUnkeyedLiteral struct{}                                                 `json:"-"`
	XXX_unrecognized     []byte                                                   `json:"-"`
	XXX_sizecache        int32                                                    `json:"-"`
}

func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor

func (*HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse

func (*HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest

func (*HealthCheckRequestOrEndpointHealthResponse) GetRequestType

func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType

func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage

func (*HealthCheckRequestOrEndpointHealthResponse) Reset

func (*HealthCheckRequestOrEndpointHealthResponse) String

func (*HealthCheckRequestOrEndpointHealthResponse) Validate

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

func (*HealthCheckRequestOrEndpointHealthResponse) XXX_DiscardUnknown

func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_DiscardUnknown()

func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Marshal

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

func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Merge

func (*HealthCheckRequestOrEndpointHealthResponse) XXX_OneofWrappers added in v0.9.0

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Size

func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Unmarshal

type HealthCheckRequestOrEndpointHealthResponseValidationError

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

HealthCheckRequestOrEndpointHealthResponseValidationError is the validation error returned by HealthCheckRequestOrEndpointHealthResponse.Validate if the designated constraints aren't met.

func (HealthCheckRequestOrEndpointHealthResponseValidationError) Cause

Cause function returns cause value.

func (HealthCheckRequestOrEndpointHealthResponseValidationError) Error

Error satisfies the builtin error interface

func (HealthCheckRequestOrEndpointHealthResponseValidationError) ErrorName added in v0.7.0

ErrorName returns error name.

func (HealthCheckRequestOrEndpointHealthResponseValidationError) Field

Field function returns field value.

func (HealthCheckRequestOrEndpointHealthResponseValidationError) Key

Key function returns key value.

func (HealthCheckRequestOrEndpointHealthResponseValidationError) Reason

Reason function returns reason value.

type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse

type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse struct {
	EndpointHealthResponse *EndpointHealthResponse `protobuf:"bytes,2,opt,name=endpoint_health_response,json=endpointHealthResponse,proto3,oneof"`
}

type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest

type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest struct {
	HealthCheckRequest *HealthCheckRequest `protobuf:"bytes,1,opt,name=health_check_request,json=healthCheckRequest,proto3,oneof"`
}

type HealthCheckRequestValidationError

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

HealthCheckRequestValidationError is the validation error returned by HealthCheckRequest.Validate if the designated constraints aren't met.

func (HealthCheckRequestValidationError) Cause

Cause function returns cause value.

func (HealthCheckRequestValidationError) Error

Error satisfies the builtin error interface

func (HealthCheckRequestValidationError) ErrorName added in v0.7.0

ErrorName returns error name.

func (HealthCheckRequestValidationError) Field

Field function returns field value.

func (HealthCheckRequestValidationError) Key

Key function returns key value.

func (HealthCheckRequestValidationError) Reason

Reason function returns reason value.

type HealthCheckSpecifier

type HealthCheckSpecifier struct {
	ClusterHealthChecks  []*ClusterHealthCheck `protobuf:"bytes,1,rep,name=cluster_health_checks,json=clusterHealthChecks,proto3" json:"cluster_health_checks,omitempty"`
	Interval             *duration.Duration    `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*HealthCheckSpecifier) Descriptor

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

func (*HealthCheckSpecifier) GetClusterHealthChecks

func (m *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck

func (*HealthCheckSpecifier) GetInterval

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

func (*HealthCheckSpecifier) ProtoMessage

func (*HealthCheckSpecifier) ProtoMessage()

func (*HealthCheckSpecifier) Reset

func (m *HealthCheckSpecifier) Reset()

func (*HealthCheckSpecifier) String

func (m *HealthCheckSpecifier) String() string

func (*HealthCheckSpecifier) Validate

func (m *HealthCheckSpecifier) Validate() error

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

func (*HealthCheckSpecifier) XXX_DiscardUnknown

func (m *HealthCheckSpecifier) XXX_DiscardUnknown()

func (*HealthCheckSpecifier) XXX_Marshal

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

func (*HealthCheckSpecifier) XXX_Merge

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

func (*HealthCheckSpecifier) XXX_Size

func (m *HealthCheckSpecifier) XXX_Size() int

func (*HealthCheckSpecifier) XXX_Unmarshal

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

type HealthCheckSpecifierValidationError

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

HealthCheckSpecifierValidationError is the validation error returned by HealthCheckSpecifier.Validate if the designated constraints aren't met.

func (HealthCheckSpecifierValidationError) Cause

Cause function returns cause value.

func (HealthCheckSpecifierValidationError) Error

Error satisfies the builtin error interface

func (HealthCheckSpecifierValidationError) ErrorName added in v0.7.0

ErrorName returns error name.

func (HealthCheckSpecifierValidationError) Field

Field function returns field value.

func (HealthCheckSpecifierValidationError) Key

Key function returns key value.

func (HealthCheckSpecifierValidationError) Reason

Reason function returns reason value.

type HealthDiscoveryServiceClient

type HealthDiscoveryServiceClient interface {
	StreamHealthCheck(ctx context.Context, opts ...grpc.CallOption) (HealthDiscoveryService_StreamHealthCheckClient, error)
	FetchHealthCheck(ctx context.Context, in *HealthCheckRequestOrEndpointHealthResponse, opts ...grpc.CallOption) (*HealthCheckSpecifier, error)
}

HealthDiscoveryServiceClient is the client API for HealthDiscoveryService service.

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

func NewHealthDiscoveryServiceClient

func NewHealthDiscoveryServiceClient(cc *grpc.ClientConn) HealthDiscoveryServiceClient

type HealthDiscoveryServiceServer

type HealthDiscoveryServiceServer interface {
	StreamHealthCheck(HealthDiscoveryService_StreamHealthCheckServer) error
	FetchHealthCheck(context.Context, *HealthCheckRequestOrEndpointHealthResponse) (*HealthCheckSpecifier, error)
}

HealthDiscoveryServiceServer is the server API for HealthDiscoveryService service.

type HealthDiscoveryService_StreamHealthCheckClient

type HealthDiscoveryService_StreamHealthCheckClient interface {
	Send(*HealthCheckRequestOrEndpointHealthResponse) error
	Recv() (*HealthCheckSpecifier, error)
	grpc.ClientStream
}

type HealthDiscoveryService_StreamHealthCheckServer

type HealthDiscoveryService_StreamHealthCheckServer interface {
	Send(*HealthCheckSpecifier) error
	Recv() (*HealthCheckRequestOrEndpointHealthResponse, error)
	grpc.ServerStream
}

type LocalityEndpoints

type LocalityEndpoints struct {
	Locality             *core.Locality       `protobuf:"bytes,1,opt,name=locality,proto3" json:"locality,omitempty"`
	Endpoints            []*endpoint.Endpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*LocalityEndpoints) Descriptor

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

func (*LocalityEndpoints) GetEndpoints

func (m *LocalityEndpoints) GetEndpoints() []*endpoint.Endpoint

func (*LocalityEndpoints) GetLocality

func (m *LocalityEndpoints) GetLocality() *core.Locality

func (*LocalityEndpoints) ProtoMessage

func (*LocalityEndpoints) ProtoMessage()

func (*LocalityEndpoints) Reset

func (m *LocalityEndpoints) Reset()

func (*LocalityEndpoints) String

func (m *LocalityEndpoints) String() string

func (*LocalityEndpoints) Validate

func (m *LocalityEndpoints) Validate() error

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

func (*LocalityEndpoints) XXX_DiscardUnknown

func (m *LocalityEndpoints) XXX_DiscardUnknown()

func (*LocalityEndpoints) XXX_Marshal

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

func (*LocalityEndpoints) XXX_Merge

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

func (*LocalityEndpoints) XXX_Size

func (m *LocalityEndpoints) XXX_Size() int

func (*LocalityEndpoints) XXX_Unmarshal

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

type LocalityEndpointsValidationError

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

LocalityEndpointsValidationError is the validation error returned by LocalityEndpoints.Validate if the designated constraints aren't met.

func (LocalityEndpointsValidationError) Cause

Cause function returns cause value.

func (LocalityEndpointsValidationError) Error

Error satisfies the builtin error interface

func (LocalityEndpointsValidationError) ErrorName added in v0.7.0

ErrorName returns error name.

func (LocalityEndpointsValidationError) Field

Field function returns field value.

func (LocalityEndpointsValidationError) Key

Key function returns key value.

func (LocalityEndpointsValidationError) Reason

Reason function returns reason value.

type RtdsDummy added in v0.8.2

type RtdsDummy struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RtdsDummy) Descriptor added in v0.8.2

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

func (*RtdsDummy) ProtoMessage added in v0.8.2

func (*RtdsDummy) ProtoMessage()

func (*RtdsDummy) Reset added in v0.8.2

func (m *RtdsDummy) Reset()

func (*RtdsDummy) String added in v0.8.2

func (m *RtdsDummy) String() string

func (*RtdsDummy) Validate added in v0.8.2

func (m *RtdsDummy) Validate() error

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

func (*RtdsDummy) XXX_DiscardUnknown added in v0.8.2

func (m *RtdsDummy) XXX_DiscardUnknown()

func (*RtdsDummy) XXX_Marshal added in v0.8.2

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

func (*RtdsDummy) XXX_Merge added in v0.8.2

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

func (*RtdsDummy) XXX_Size added in v0.8.2

func (m *RtdsDummy) XXX_Size() int

func (*RtdsDummy) XXX_Unmarshal added in v0.8.2

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

type RtdsDummyValidationError added in v0.8.2

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

RtdsDummyValidationError is the validation error returned by RtdsDummy.Validate if the designated constraints aren't met.

func (RtdsDummyValidationError) Cause added in v0.8.2

func (e RtdsDummyValidationError) Cause() error

Cause function returns cause value.

func (RtdsDummyValidationError) Error added in v0.8.2

func (e RtdsDummyValidationError) Error() string

Error satisfies the builtin error interface

func (RtdsDummyValidationError) ErrorName added in v0.8.2

func (e RtdsDummyValidationError) ErrorName() string

ErrorName returns error name.

func (RtdsDummyValidationError) Field added in v0.8.2

func (e RtdsDummyValidationError) Field() string

Field function returns field value.

func (RtdsDummyValidationError) Key added in v0.8.2

Key function returns key value.

func (RtdsDummyValidationError) Reason added in v0.8.2

func (e RtdsDummyValidationError) Reason() string

Reason function returns reason value.

type Runtime added in v0.8.1

type Runtime struct {
	Name                 string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Layer                *_struct.Struct `protobuf:"bytes,2,opt,name=layer,proto3" json:"layer,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Runtime) Descriptor added in v0.8.1

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

func (*Runtime) GetLayer added in v0.8.1

func (m *Runtime) GetLayer() *_struct.Struct

func (*Runtime) GetName added in v0.8.2

func (m *Runtime) GetName() string

func (*Runtime) ProtoMessage added in v0.8.1

func (*Runtime) ProtoMessage()

func (*Runtime) Reset added in v0.8.1

func (m *Runtime) Reset()

func (*Runtime) String added in v0.8.1

func (m *Runtime) String() string

func (*Runtime) Validate added in v0.8.1

func (m *Runtime) Validate() error

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

func (*Runtime) XXX_DiscardUnknown added in v0.8.1

func (m *Runtime) XXX_DiscardUnknown()

func (*Runtime) XXX_Marshal added in v0.8.1

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

func (*Runtime) XXX_Merge added in v0.8.1

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

func (*Runtime) XXX_Size added in v0.8.1

func (m *Runtime) XXX_Size() int

func (*Runtime) XXX_Unmarshal added in v0.8.1

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

type RuntimeDiscoveryServiceClient added in v0.8.1

type RuntimeDiscoveryServiceClient interface {
	StreamRuntime(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_StreamRuntimeClient, error)
	DeltaRuntime(ctx context.Context, opts ...grpc.CallOption) (RuntimeDiscoveryService_DeltaRuntimeClient, error)
	FetchRuntime(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error)
}

RuntimeDiscoveryServiceClient is the client API for RuntimeDiscoveryService service.

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

func NewRuntimeDiscoveryServiceClient added in v0.8.1

func NewRuntimeDiscoveryServiceClient(cc *grpc.ClientConn) RuntimeDiscoveryServiceClient

type RuntimeDiscoveryServiceServer added in v0.8.1

type RuntimeDiscoveryServiceServer interface {
	StreamRuntime(RuntimeDiscoveryService_StreamRuntimeServer) error
	DeltaRuntime(RuntimeDiscoveryService_DeltaRuntimeServer) error
	FetchRuntime(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
}

RuntimeDiscoveryServiceServer is the server API for RuntimeDiscoveryService service.

type RuntimeDiscoveryService_DeltaRuntimeClient added in v0.8.2

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

type RuntimeDiscoveryService_DeltaRuntimeServer added in v0.8.2

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

type RuntimeDiscoveryService_StreamRuntimeClient added in v0.8.1

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

type RuntimeDiscoveryService_StreamRuntimeServer added in v0.8.1

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

type RuntimeValidationError added in v0.8.1

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

RuntimeValidationError is the validation error returned by Runtime.Validate if the designated constraints aren't met.

func (RuntimeValidationError) Cause added in v0.8.1

func (e RuntimeValidationError) Cause() error

Cause function returns cause value.

func (RuntimeValidationError) Error added in v0.8.1

func (e RuntimeValidationError) Error() string

Error satisfies the builtin error interface

func (RuntimeValidationError) ErrorName added in v0.8.1

func (e RuntimeValidationError) ErrorName() string

ErrorName returns error name.

func (RuntimeValidationError) Field added in v0.8.1

func (e RuntimeValidationError) Field() string

Field function returns field value.

func (RuntimeValidationError) Key added in v0.8.1

func (e RuntimeValidationError) Key() bool

Key function returns key value.

func (RuntimeValidationError) Reason added in v0.8.1

func (e RuntimeValidationError) Reason() string

Reason function returns reason value.

type SdsDummy

type SdsDummy struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SdsDummy) Descriptor

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

func (*SdsDummy) ProtoMessage

func (*SdsDummy) ProtoMessage()

func (*SdsDummy) Reset

func (m *SdsDummy) Reset()

func (*SdsDummy) String

func (m *SdsDummy) String() string

func (*SdsDummy) Validate

func (m *SdsDummy) Validate() error

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

func (*SdsDummy) XXX_DiscardUnknown

func (m *SdsDummy) XXX_DiscardUnknown()

func (*SdsDummy) XXX_Marshal

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

func (*SdsDummy) XXX_Merge

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

func (*SdsDummy) XXX_Size

func (m *SdsDummy) XXX_Size() int

func (*SdsDummy) XXX_Unmarshal

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

type SdsDummyValidationError

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

SdsDummyValidationError is the validation error returned by SdsDummy.Validate if the designated constraints aren't met.

func (SdsDummyValidationError) Cause

func (e SdsDummyValidationError) Cause() error

Cause function returns cause value.

func (SdsDummyValidationError) Error

func (e SdsDummyValidationError) Error() string

Error satisfies the builtin error interface

func (SdsDummyValidationError) ErrorName added in v0.7.0

func (e SdsDummyValidationError) ErrorName() string

ErrorName returns error name.

func (SdsDummyValidationError) Field

func (e SdsDummyValidationError) Field() string

Field function returns field value.

func (SdsDummyValidationError) Key

func (e SdsDummyValidationError) Key() bool

Key function returns key value.

func (SdsDummyValidationError) Reason

func (e SdsDummyValidationError) Reason() string

Reason function returns reason value.

type SecretDiscoveryServiceClient

type SecretDiscoveryServiceClient interface {
	DeltaSecrets(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_DeltaSecretsClient, error)
	StreamSecrets(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_StreamSecretsClient, error)
	FetchSecrets(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error)
}

SecretDiscoveryServiceClient is the client API for SecretDiscoveryService service.

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

func NewSecretDiscoveryServiceClient

func NewSecretDiscoveryServiceClient(cc *grpc.ClientConn) SecretDiscoveryServiceClient

type SecretDiscoveryServiceServer

type SecretDiscoveryServiceServer interface {
	DeltaSecrets(SecretDiscoveryService_DeltaSecretsServer) error
	StreamSecrets(SecretDiscoveryService_StreamSecretsServer) error
	FetchSecrets(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
}

SecretDiscoveryServiceServer is the server API for SecretDiscoveryService service.

type SecretDiscoveryService_DeltaSecretsClient added in v0.8.1

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

type SecretDiscoveryService_DeltaSecretsServer added in v0.8.1

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

type SecretDiscoveryService_StreamSecretsClient

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

type SecretDiscoveryService_StreamSecretsServer

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

type UnimplementedAggregatedDiscoveryServiceServer added in v0.9.1

type UnimplementedAggregatedDiscoveryServiceServer struct {
}

UnimplementedAggregatedDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources added in v0.9.1

func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources added in v0.9.1

type UnimplementedHealthDiscoveryServiceServer added in v0.9.1

type UnimplementedHealthDiscoveryServiceServer struct {
}

UnimplementedHealthDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedHealthDiscoveryServiceServer) FetchHealthCheck added in v0.9.1

func (*UnimplementedHealthDiscoveryServiceServer) StreamHealthCheck added in v0.9.1

type UnimplementedRuntimeDiscoveryServiceServer added in v0.9.1

type UnimplementedRuntimeDiscoveryServiceServer struct {
}

UnimplementedRuntimeDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRuntimeDiscoveryServiceServer) DeltaRuntime added in v0.9.1

func (*UnimplementedRuntimeDiscoveryServiceServer) FetchRuntime added in v0.9.1

func (*UnimplementedRuntimeDiscoveryServiceServer) StreamRuntime added in v0.9.1

type UnimplementedSecretDiscoveryServiceServer added in v0.9.1

type UnimplementedSecretDiscoveryServiceServer struct {
}

UnimplementedSecretDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSecretDiscoveryServiceServer) DeltaSecrets added in v0.9.1

func (*UnimplementedSecretDiscoveryServiceServer) FetchSecrets added in v0.9.1

func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets added in v0.9.1

Jump to

Keyboard shortcuts

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