package envoy_service_endpoint_v3alpha

import "github.com/envoyproxy/go-control-plane/envoy/service/endpoint/v3alpha"

Index ¶

• func RegisterEndpointDiscoveryServiceServer(s *grpc.Server, srv EndpointDiscoveryServiceServer)
• type EdsDummy
• func (*EdsDummy) Descriptor() ([]byte, []int)
• func (*EdsDummy) ProtoMessage()
• func (m *EdsDummy) Reset()
• func (m *EdsDummy) String() string
• func (m *EdsDummy) Validate() error
• func (m *EdsDummy) XXX_DiscardUnknown()
• func (m *EdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
• func (m *EdsDummy) XXX_Merge(src proto.Message)
• func (m *EdsDummy) XXX_Size() int
• func (m *EdsDummy) XXX_Unmarshal(b []byte) error
• type EdsDummyValidationError
• func (e EdsDummyValidationError) Cause() error
• func (e EdsDummyValidationError) Error() string
• func (e EdsDummyValidationError) ErrorName() string
• func (e EdsDummyValidationError) Field() string
• func (e EdsDummyValidationError) Key() bool
• func (e EdsDummyValidationError) Reason() string
• type EndpointDiscoveryServiceClient
• func NewEndpointDiscoveryServiceClient(cc *grpc.ClientConn) EndpointDiscoveryServiceClient
• type EndpointDiscoveryServiceServer
• type EndpointDiscoveryService_DeltaEndpointsClient
• type EndpointDiscoveryService_DeltaEndpointsServer
• type EndpointDiscoveryService_StreamEndpointsClient
• type EndpointDiscoveryService_StreamEndpointsServer
• type UnimplementedEndpointDiscoveryServiceServer
• func (*UnimplementedEndpointDiscoveryServiceServer) DeltaEndpoints(srv EndpointDiscoveryService_DeltaEndpointsServer) error
• func (*UnimplementedEndpointDiscoveryServiceServer) FetchEndpoints(ctx context.Context, req *v3alpha.DiscoveryRequest) (*v3alpha.DiscoveryResponse, error)
• func (*UnimplementedEndpointDiscoveryServiceServer) StreamEndpoints(srv EndpointDiscoveryService_StreamEndpointsServer) error

Functions ¶

func RegisterEndpointDiscoveryServiceServer ¶

func RegisterEndpointDiscoveryServiceServer(s *grpc.Server, srv EndpointDiscoveryServiceServer)

Types ¶

type EdsDummy ¶

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

func (*EdsDummy) Descriptor ¶

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

func (*EdsDummy) ProtoMessage ¶

func (*EdsDummy) ProtoMessage()

func (*EdsDummy) Reset ¶

func (m *EdsDummy) Reset()

func (*EdsDummy) String ¶

func (m *EdsDummy) String() string

func (*EdsDummy) Validate ¶

func (m *EdsDummy) Validate() error

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

func (*EdsDummy) XXX_DiscardUnknown ¶

func (m *EdsDummy) XXX_DiscardUnknown()

func (*EdsDummy) XXX_Marshal ¶

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

func (*EdsDummy) XXX_Merge ¶

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

func (*EdsDummy) XXX_Size ¶

func (m *EdsDummy) XXX_Size() int

func (*EdsDummy) XXX_Unmarshal ¶

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

type EdsDummyValidationError ¶

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

EdsDummyValidationError is the validation error returned by EdsDummy.Validate if the designated constraints aren't met.

func (EdsDummyValidationError) Cause ¶

func (e EdsDummyValidationError) Cause() error

Cause function returns cause value.

func (EdsDummyValidationError) Error ¶

func (e EdsDummyValidationError) Error() string

Error satisfies the builtin error interface

func (EdsDummyValidationError) ErrorName ¶

func (e EdsDummyValidationError) ErrorName() string

ErrorName returns error name.

func (EdsDummyValidationError) Field ¶

func (e EdsDummyValidationError) Field() string

Field function returns field value.

func (EdsDummyValidationError) Key ¶

func (e EdsDummyValidationError) Key() bool

Key function returns key value.

func (EdsDummyValidationError) Reason ¶

func (e EdsDummyValidationError) Reason() string

Reason function returns reason value.

type EndpointDiscoveryServiceClient ¶

type EndpointDiscoveryServiceClient interface {
	StreamEndpoints(ctx context.Context, opts ...grpc.CallOption) (EndpointDiscoveryService_StreamEndpointsClient, error)
	DeltaEndpoints(ctx context.Context, opts ...grpc.CallOption) (EndpointDiscoveryService_DeltaEndpointsClient, error)
	FetchEndpoints(ctx context.Context, in *v3alpha.DiscoveryRequest, opts ...grpc.CallOption) (*v3alpha.DiscoveryResponse, error)
}

EndpointDiscoveryServiceClient is the client API for EndpointDiscoveryService service.

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

func NewEndpointDiscoveryServiceClient ¶

func NewEndpointDiscoveryServiceClient(cc *grpc.ClientConn) EndpointDiscoveryServiceClient

type EndpointDiscoveryServiceServer ¶

type EndpointDiscoveryServiceServer interface {
	StreamEndpoints(EndpointDiscoveryService_StreamEndpointsServer) error
	DeltaEndpoints(EndpointDiscoveryService_DeltaEndpointsServer) error
	FetchEndpoints(context.Context, *v3alpha.DiscoveryRequest) (*v3alpha.DiscoveryResponse, error)
}

EndpointDiscoveryServiceServer is the server API for EndpointDiscoveryService service.

type EndpointDiscoveryService_DeltaEndpointsClient ¶

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

type EndpointDiscoveryService_DeltaEndpointsServer ¶

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

type EndpointDiscoveryService_StreamEndpointsClient ¶

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

type EndpointDiscoveryService_StreamEndpointsServer ¶

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

type UnimplementedEndpointDiscoveryServiceServer ¶

type UnimplementedEndpointDiscoveryServiceServer struct {
}

UnimplementedEndpointDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEndpointDiscoveryServiceServer) DeltaEndpoints ¶

func (*UnimplementedEndpointDiscoveryServiceServer) DeltaEndpoints(srv EndpointDiscoveryService_DeltaEndpointsServer) error

func (*UnimplementedEndpointDiscoveryServiceServer) FetchEndpoints ¶

func (*UnimplementedEndpointDiscoveryServiceServer) FetchEndpoints(ctx context.Context, req *v3alpha.DiscoveryRequest) (*v3alpha.DiscoveryResponse, error)

func (*UnimplementedEndpointDiscoveryServiceServer) StreamEndpoints ¶

func (*UnimplementedEndpointDiscoveryServiceServer) StreamEndpoints(srv EndpointDiscoveryService_StreamEndpointsServer) error

Source Files ¶

eds.pb.go eds.pb.validate.go