Documentation ¶
Index ¶
- Variables
- func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer)
- func RegisterHealthDiscoveryServiceServer(s *grpc.Server, srv HealthDiscoveryServiceServer)
- func RegisterRuntimeDiscoveryServiceServer(s *grpc.Server, srv RuntimeDiscoveryServiceServer)
- func RegisterSecretDiscoveryServiceServer(s *grpc.Server, srv SecretDiscoveryServiceServer)
- type AdsDummy
- func (*AdsDummy) Descriptor() ([]byte, []int)
- func (*AdsDummy) ProtoMessage()
- func (m *AdsDummy) Reset()
- func (m *AdsDummy) String() string
- func (m *AdsDummy) XXX_DiscardUnknown()
- func (m *AdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AdsDummy) XXX_Merge(src proto.Message)
- func (m *AdsDummy) XXX_Size() int
- func (m *AdsDummy) XXX_Unmarshal(b []byte) error
- type AggregatedDiscoveryServiceClient
- type AggregatedDiscoveryServiceServer
- type AggregatedDiscoveryService_DeltaAggregatedResourcesClient
- type AggregatedDiscoveryService_DeltaAggregatedResourcesServer
- type AggregatedDiscoveryService_StreamAggregatedResourcesClient
- type AggregatedDiscoveryService_StreamAggregatedResourcesServer
- type Capability
- func (*Capability) Descriptor() ([]byte, []int)
- func (m *Capability) GetHealthCheckProtocols() []Capability_Protocol
- func (*Capability) ProtoMessage()
- func (m *Capability) Reset()
- func (m *Capability) String() string
- func (m *Capability) XXX_DiscardUnknown()
- func (m *Capability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Capability) XXX_Merge(src proto.Message)
- func (m *Capability) XXX_Size() int
- func (m *Capability) XXX_Unmarshal(b []byte) error
- type Capability_Protocol
- type ClusterHealthCheck
- func (*ClusterHealthCheck) Descriptor() ([]byte, []int)
- func (m *ClusterHealthCheck) GetClusterName() string
- func (m *ClusterHealthCheck) GetHealthChecks() []*core.HealthCheck
- func (m *ClusterHealthCheck) GetLocalityEndpoints() []*LocalityEndpoints
- func (*ClusterHealthCheck) ProtoMessage()
- func (m *ClusterHealthCheck) Reset()
- func (m *ClusterHealthCheck) String() string
- func (m *ClusterHealthCheck) XXX_DiscardUnknown()
- func (m *ClusterHealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterHealthCheck) XXX_Merge(src proto.Message)
- func (m *ClusterHealthCheck) XXX_Size() int
- func (m *ClusterHealthCheck) XXX_Unmarshal(b []byte) error
- type EndpointHealth
- func (*EndpointHealth) Descriptor() ([]byte, []int)
- func (m *EndpointHealth) GetEndpoint() *endpoint.Endpoint
- func (m *EndpointHealth) GetHealthStatus() core.HealthStatus
- func (*EndpointHealth) ProtoMessage()
- func (m *EndpointHealth) Reset()
- func (m *EndpointHealth) String() string
- func (m *EndpointHealth) XXX_DiscardUnknown()
- func (m *EndpointHealth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EndpointHealth) XXX_Merge(src proto.Message)
- func (m *EndpointHealth) XXX_Size() int
- func (m *EndpointHealth) XXX_Unmarshal(b []byte) error
- type EndpointHealthResponse
- func (*EndpointHealthResponse) Descriptor() ([]byte, []int)
- func (m *EndpointHealthResponse) GetEndpointsHealth() []*EndpointHealth
- func (*EndpointHealthResponse) ProtoMessage()
- func (m *EndpointHealthResponse) Reset()
- func (m *EndpointHealthResponse) String() string
- func (m *EndpointHealthResponse) XXX_DiscardUnknown()
- func (m *EndpointHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EndpointHealthResponse) XXX_Merge(src proto.Message)
- func (m *EndpointHealthResponse) XXX_Size() int
- func (m *EndpointHealthResponse) XXX_Unmarshal(b []byte) error
- type HealthCheckRequest
- func (*HealthCheckRequest) Descriptor() ([]byte, []int)
- func (m *HealthCheckRequest) GetCapability() *Capability
- func (m *HealthCheckRequest) GetNode() *core.Node
- func (*HealthCheckRequest) ProtoMessage()
- func (m *HealthCheckRequest) Reset()
- func (m *HealthCheckRequest) String() string
- func (m *HealthCheckRequest) XXX_DiscardUnknown()
- func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthCheckRequest) XXX_Merge(src proto.Message)
- func (m *HealthCheckRequest) XXX_Size() int
- func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error
- type HealthCheckRequestOrEndpointHealthResponse
- func (*HealthCheckRequestOrEndpointHealthResponse) Descriptor() ([]byte, []int)
- func (m *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse
- func (m *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest
- func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType
- func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage()
- func (m *HealthCheckRequestOrEndpointHealthResponse) Reset()
- func (m *HealthCheckRequestOrEndpointHealthResponse) String() string
- func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_DiscardUnknown()
- func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Merge(src proto.Message)
- func (*HealthCheckRequestOrEndpointHealthResponse) XXX_OneofWrappers() []interface{}
- func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Size() int
- func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Unmarshal(b []byte) error
- type HealthCheckRequestOrEndpointHealthResponse_EndpointHealthResponse
- type HealthCheckRequestOrEndpointHealthResponse_HealthCheckRequest
- type HealthCheckSpecifier
- func (*HealthCheckSpecifier) Descriptor() ([]byte, []int)
- func (m *HealthCheckSpecifier) GetClusterHealthChecks() []*ClusterHealthCheck
- func (m *HealthCheckSpecifier) GetInterval() *types.Duration
- func (*HealthCheckSpecifier) ProtoMessage()
- func (m *HealthCheckSpecifier) Reset()
- func (m *HealthCheckSpecifier) String() string
- func (m *HealthCheckSpecifier) XXX_DiscardUnknown()
- func (m *HealthCheckSpecifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthCheckSpecifier) XXX_Merge(src proto.Message)
- func (m *HealthCheckSpecifier) XXX_Size() int
- func (m *HealthCheckSpecifier) XXX_Unmarshal(b []byte) error
- type HealthDiscoveryServiceClient
- type HealthDiscoveryServiceServer
- type HealthDiscoveryService_StreamHealthCheckClient
- type HealthDiscoveryService_StreamHealthCheckServer
- type LocalityEndpoints
- func (*LocalityEndpoints) Descriptor() ([]byte, []int)
- func (m *LocalityEndpoints) GetEndpoints() []*endpoint.Endpoint
- func (m *LocalityEndpoints) GetLocality() *core.Locality
- func (*LocalityEndpoints) ProtoMessage()
- func (m *LocalityEndpoints) Reset()
- func (m *LocalityEndpoints) String() string
- func (m *LocalityEndpoints) XXX_DiscardUnknown()
- func (m *LocalityEndpoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LocalityEndpoints) XXX_Merge(src proto.Message)
- func (m *LocalityEndpoints) XXX_Size() int
- func (m *LocalityEndpoints) XXX_Unmarshal(b []byte) error
- type RtdsDummy
- func (*RtdsDummy) Descriptor() ([]byte, []int)
- func (*RtdsDummy) ProtoMessage()
- func (m *RtdsDummy) Reset()
- func (m *RtdsDummy) String() string
- func (m *RtdsDummy) XXX_DiscardUnknown()
- func (m *RtdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RtdsDummy) XXX_Merge(src proto.Message)
- func (m *RtdsDummy) XXX_Size() int
- func (m *RtdsDummy) XXX_Unmarshal(b []byte) error
- type Runtime
- func (*Runtime) Descriptor() ([]byte, []int)
- func (m *Runtime) GetLayer() *types.Struct
- func (m *Runtime) GetName() string
- func (*Runtime) ProtoMessage()
- func (m *Runtime) Reset()
- func (m *Runtime) String() string
- func (m *Runtime) XXX_DiscardUnknown()
- func (m *Runtime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Runtime) XXX_Merge(src proto.Message)
- func (m *Runtime) XXX_Size() int
- func (m *Runtime) XXX_Unmarshal(b []byte) error
- type RuntimeDiscoveryServiceClient
- type RuntimeDiscoveryServiceServer
- type RuntimeDiscoveryService_DeltaRuntimeClient
- type RuntimeDiscoveryService_DeltaRuntimeServer
- type RuntimeDiscoveryService_StreamRuntimeClient
- type RuntimeDiscoveryService_StreamRuntimeServer
- type SdsDummy
- func (*SdsDummy) Descriptor() ([]byte, []int)
- func (*SdsDummy) ProtoMessage()
- func (m *SdsDummy) Reset()
- func (m *SdsDummy) String() string
- func (m *SdsDummy) XXX_DiscardUnknown()
- func (m *SdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SdsDummy) XXX_Merge(src proto.Message)
- func (m *SdsDummy) XXX_Size() int
- func (m *SdsDummy) XXX_Unmarshal(b []byte) error
- type SecretDiscoveryServiceClient
- type SecretDiscoveryServiceServer
- type SecretDiscoveryService_DeltaSecretsClient
- type SecretDiscoveryService_DeltaSecretsServer
- type SecretDiscoveryService_StreamSecretsClient
- type SecretDiscoveryService_StreamSecretsServer
Constants ¶
This section is empty.
Variables ¶
var Capability_Protocol_name = map[int32]string{
0: "HTTP",
1: "TCP",
2: "REDIS",
}
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 ¶
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:"-"` }
[#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing services: https://github.com/google/protobuf/issues/4221
func (*AdsDummy) Descriptor ¶
func (*AdsDummy) ProtoMessage ¶
func (*AdsDummy) ProtoMessage()
func (*AdsDummy) XXX_DiscardUnknown ¶
func (m *AdsDummy) XXX_DiscardUnknown()
func (*AdsDummy) XXX_Marshal ¶
func (*AdsDummy) XXX_Unmarshal ¶
type AggregatedDiscoveryServiceClient ¶
type AggregatedDiscoveryServiceClient interface { // This is a gRPC-only API. 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 { // This is a gRPC-only API. StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error }
AggregatedDiscoveryServiceServer is the server API for AggregatedDiscoveryService service.
type AggregatedDiscoveryService_DeltaAggregatedResourcesClient ¶
type AggregatedDiscoveryService_DeltaAggregatedResourcesClient interface { Send(*v2.DeltaDiscoveryRequest) error Recv() (*v2.DeltaDiscoveryResponse, error) grpc.ClientStream }
type AggregatedDiscoveryService_DeltaAggregatedResourcesServer ¶
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:"-"` }
Defines supported protocols etc, so the management server can assign proper endpoints to healthcheck.
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) 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 Capability_Protocol ¶
type Capability_Protocol int32
Different Envoy instances may have different capabilities (e.g. Redis) and/or have ports enabled for different protocols.
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:"-"` }
The cluster name and locality is provided to Envoy for the endpoints that it health checks to support statistics reporting, logging and debugging by the Envoy instance (outside of HDS). For maximum usefulness, it should match the same cluster structure as that provided by EDS.
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) 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 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) 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) 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 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) 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) Descriptor() ([]byte, []int)
func (*HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) GetEndpointHealthResponse() *EndpointHealthResponse
func (*HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) GetHealthCheckRequest() *HealthCheckRequest
func (*HealthCheckRequestOrEndpointHealthResponse) GetRequestType ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) GetRequestType() isHealthCheckRequestOrEndpointHealthResponse_RequestType
func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage ¶
func (*HealthCheckRequestOrEndpointHealthResponse) ProtoMessage()
func (*HealthCheckRequestOrEndpointHealthResponse) Reset ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) Reset()
func (*HealthCheckRequestOrEndpointHealthResponse) String ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) String() string
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 (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Merge(src proto.Message)
func (*HealthCheckRequestOrEndpointHealthResponse) XXX_OneofWrappers ¶
func (*HealthCheckRequestOrEndpointHealthResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Size ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Size() int
func (*HealthCheckRequestOrEndpointHealthResponse) XXX_Unmarshal ¶
func (m *HealthCheckRequestOrEndpointHealthResponse) XXX_Unmarshal(b []byte) error
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 HealthCheckSpecifier ¶
type HealthCheckSpecifier struct { ClusterHealthChecks []*ClusterHealthCheck `protobuf:"bytes,1,rep,name=cluster_health_checks,json=clusterHealthChecks,proto3" json:"cluster_health_checks,omitempty"` // The default is 1 second. Interval *types.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() *types.Duration
func (*HealthCheckSpecifier) ProtoMessage ¶
func (*HealthCheckSpecifier) ProtoMessage()
func (*HealthCheckSpecifier) Reset ¶
func (m *HealthCheckSpecifier) Reset()
func (*HealthCheckSpecifier) String ¶
func (m *HealthCheckSpecifier) String() string
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 HealthDiscoveryServiceClient ¶
type HealthDiscoveryServiceClient interface { // 1. Envoy starts up and if its can_healthcheck option in the static // bootstrap config is enabled, sends HealthCheckRequest to the management // server. It supplies its capabilities (which protocol it can health check // with, what zone it resides in, etc.). // 2. In response to (1), the management server designates this Envoy as a // healthchecker to health check a subset of all upstream hosts for a given // cluster (for example upstream Host 1 and Host 2). It streams // HealthCheckSpecifier messages with cluster related configuration for all // clusters this Envoy is designated to health check. Subsequent // HealthCheckSpecifier message will be sent on changes to: // a. Endpoints to health checks // b. Per cluster configuration change // 3. Envoy creates a health probe based on the HealthCheck config and sends // it to endpoint(ip:port) of Host 1 and 2. Based on the HealthCheck // configuration Envoy waits upon the arrival of the probe response and // looks at the content of the response to decide whether the endpoint is // healthy or not. If a response hasn't been received within the timeout // interval, the endpoint health status is considered TIMEOUT. // 4. Envoy reports results back in an EndpointHealthResponse message. // Envoy streams responses as often as the interval configured by the // management server in HealthCheckSpecifier. // 5. The management Server collects health statuses for all endpoints in the // cluster (for all clusters) and uses this information to construct // EndpointDiscoveryResponse messages. // 6. Once Envoy has a list of upstream endpoints to send traffic to, it load // balances traffic to them without additional health checking. It may // use inline healthcheck (i.e. consider endpoint UNHEALTHY if connection // failed to a particular endpoint to account for health status propagation // delay between HDS and EDS). // By default, can_healthcheck is true. If can_healthcheck is false, Cluster // configuration may not contain HealthCheck message. // TODO(htuch): How is can_healthcheck communicated to CDS to ensure the above // invariant? // TODO(htuch): Add @amb67's diagram. StreamHealthCheck(ctx context.Context, opts ...grpc.CallOption) (HealthDiscoveryService_StreamHealthCheckClient, error) // TODO(htuch): Unlike the gRPC version, there is no stream-based binding of // request/response. Should we add an identifier to the HealthCheckSpecifier // to bind with the response? 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 { // 1. Envoy starts up and if its can_healthcheck option in the static // bootstrap config is enabled, sends HealthCheckRequest to the management // server. It supplies its capabilities (which protocol it can health check // with, what zone it resides in, etc.). // 2. In response to (1), the management server designates this Envoy as a // healthchecker to health check a subset of all upstream hosts for a given // cluster (for example upstream Host 1 and Host 2). It streams // HealthCheckSpecifier messages with cluster related configuration for all // clusters this Envoy is designated to health check. Subsequent // HealthCheckSpecifier message will be sent on changes to: // a. Endpoints to health checks // b. Per cluster configuration change // 3. Envoy creates a health probe based on the HealthCheck config and sends // it to endpoint(ip:port) of Host 1 and 2. Based on the HealthCheck // configuration Envoy waits upon the arrival of the probe response and // looks at the content of the response to decide whether the endpoint is // healthy or not. If a response hasn't been received within the timeout // interval, the endpoint health status is considered TIMEOUT. // 4. Envoy reports results back in an EndpointHealthResponse message. // Envoy streams responses as often as the interval configured by the // management server in HealthCheckSpecifier. // 5. The management Server collects health statuses for all endpoints in the // cluster (for all clusters) and uses this information to construct // EndpointDiscoveryResponse messages. // 6. Once Envoy has a list of upstream endpoints to send traffic to, it load // balances traffic to them without additional health checking. It may // use inline healthcheck (i.e. consider endpoint UNHEALTHY if connection // failed to a particular endpoint to account for health status propagation // delay between HDS and EDS). // By default, can_healthcheck is true. If can_healthcheck is false, Cluster // configuration may not contain HealthCheck message. // TODO(htuch): How is can_healthcheck communicated to CDS to ensure the above // invariant? // TODO(htuch): Add @amb67's diagram. StreamHealthCheck(HealthDiscoveryService_StreamHealthCheckServer) error // TODO(htuch): Unlike the gRPC version, there is no stream-based binding of // request/response. Should we add an identifier to the HealthCheckSpecifier // to bind with the response? 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) 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 RtdsDummy ¶
type RtdsDummy struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing services: https://github.com/google/protobuf/issues/4221
func (*RtdsDummy) Descriptor ¶
func (*RtdsDummy) ProtoMessage ¶
func (*RtdsDummy) ProtoMessage()
func (*RtdsDummy) XXX_DiscardUnknown ¶
func (m *RtdsDummy) XXX_DiscardUnknown()
func (*RtdsDummy) XXX_Marshal ¶
func (*RtdsDummy) XXX_Unmarshal ¶
type Runtime ¶
type Runtime struct { // Runtime resource name. This makes the Runtime a self-describing xDS // resource. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Layer *types.Struct `protobuf:"bytes,2,opt,name=layer,proto3" json:"layer,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RTDS resource type. This describes a layer in the runtime virtual filesystem.
func (*Runtime) Descriptor ¶
func (*Runtime) ProtoMessage ¶
func (*Runtime) ProtoMessage()
func (*Runtime) XXX_DiscardUnknown ¶
func (m *Runtime) XXX_DiscardUnknown()
func (*Runtime) XXX_Marshal ¶
func (*Runtime) XXX_Unmarshal ¶
type RuntimeDiscoveryServiceClient ¶
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 ¶
func NewRuntimeDiscoveryServiceClient(cc *grpc.ClientConn) RuntimeDiscoveryServiceClient
type RuntimeDiscoveryServiceServer ¶
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 ¶
type RuntimeDiscoveryService_DeltaRuntimeClient interface { Send(*v2.DeltaDiscoveryRequest) error Recv() (*v2.DeltaDiscoveryResponse, error) grpc.ClientStream }
type RuntimeDiscoveryService_DeltaRuntimeServer ¶
type RuntimeDiscoveryService_DeltaRuntimeServer interface { Send(*v2.DeltaDiscoveryResponse) error Recv() (*v2.DeltaDiscoveryRequest, error) grpc.ServerStream }
type RuntimeDiscoveryService_StreamRuntimeClient ¶
type RuntimeDiscoveryService_StreamRuntimeClient interface { Send(*v2.DiscoveryRequest) error Recv() (*v2.DiscoveryResponse, error) grpc.ClientStream }
type RuntimeDiscoveryService_StreamRuntimeServer ¶
type RuntimeDiscoveryService_StreamRuntimeServer interface { Send(*v2.DiscoveryResponse) error Recv() (*v2.DiscoveryRequest, error) grpc.ServerStream }
type SdsDummy ¶
type SdsDummy struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing services: https://github.com/google/protobuf/issues/4221
func (*SdsDummy) Descriptor ¶
func (*SdsDummy) ProtoMessage ¶
func (*SdsDummy) ProtoMessage()
func (*SdsDummy) XXX_DiscardUnknown ¶
func (m *SdsDummy) XXX_DiscardUnknown()
func (*SdsDummy) XXX_Marshal ¶
func (*SdsDummy) XXX_Unmarshal ¶
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 ¶
type SecretDiscoveryService_DeltaSecretsClient interface { Send(*v2.DeltaDiscoveryRequest) error Recv() (*v2.DeltaDiscoveryResponse, error) grpc.ClientStream }
type SecretDiscoveryService_DeltaSecretsServer ¶
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 }