endpointv3connect

Documentation

Index

• Constants
• func NewEndpointDiscoveryServiceHandler(svc EndpointDiscoveryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
• func NewLocalityEndpointDiscoveryServiceHandler(svc LocalityEndpointDiscoveryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
• type EndpointDiscoveryServiceClient
  • func NewEndpointDiscoveryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) EndpointDiscoveryServiceClient
• type EndpointDiscoveryServiceHandler
• type LocalityEndpointDiscoveryServiceClient
  • func NewLocalityEndpointDiscoveryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) LocalityEndpointDiscoveryServiceClient
• type LocalityEndpointDiscoveryServiceHandler
• type UnimplementedEndpointDiscoveryServiceHandler
  • func (UnimplementedEndpointDiscoveryServiceHandler) DeltaEndpoints(context.Context, ...) error
  • func (UnimplementedEndpointDiscoveryServiceHandler) FetchEndpoints(context.Context, *connect.Request[v31.DiscoveryRequest]) (*connect.Response[v31.DiscoveryResponse], error)
  • func (UnimplementedEndpointDiscoveryServiceHandler) StreamEndpoints(context.Context, ...) error
• type UnimplementedLocalityEndpointDiscoveryServiceHandler
  • func (UnimplementedLocalityEndpointDiscoveryServiceHandler) DeltaLocalityEndpoints(context.Context, ...) error

Constants

const (
	// EndpointDiscoveryServiceStreamEndpointsProcedure is the fully-qualified name of the
	// EndpointDiscoveryService's StreamEndpoints RPC.
	EndpointDiscoveryServiceStreamEndpointsProcedure = "/envoy.service.endpoint.v3.EndpointDiscoveryService/StreamEndpoints"
	// EndpointDiscoveryServiceDeltaEndpointsProcedure is the fully-qualified name of the
	// EndpointDiscoveryService's DeltaEndpoints RPC.
	EndpointDiscoveryServiceDeltaEndpointsProcedure = "/envoy.service.endpoint.v3.EndpointDiscoveryService/DeltaEndpoints"
	// EndpointDiscoveryServiceFetchEndpointsProcedure is the fully-qualified name of the
	// EndpointDiscoveryService's FetchEndpoints RPC.
	EndpointDiscoveryServiceFetchEndpointsProcedure = "/envoy.service.endpoint.v3.EndpointDiscoveryService/FetchEndpoints"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

const (
	// EndpointDiscoveryServiceName is the fully-qualified name of the EndpointDiscoveryService service.
	EndpointDiscoveryServiceName = "envoy.service.endpoint.v3.EndpointDiscoveryService"
)

const (
	// LocalityEndpointDiscoveryServiceDeltaLocalityEndpointsProcedure is the fully-qualified name of
	// the LocalityEndpointDiscoveryService's DeltaLocalityEndpoints RPC.
	LocalityEndpointDiscoveryServiceDeltaLocalityEndpointsProcedure = "/envoy.service.endpoint.v3.LocalityEndpointDiscoveryService/DeltaLocalityEndpoints"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

const (
	// LocalityEndpointDiscoveryServiceName is the fully-qualified name of the
	// LocalityEndpointDiscoveryService service.
	LocalityEndpointDiscoveryServiceName = "envoy.service.endpoint.v3.LocalityEndpointDiscoveryService"
)

Functions

func NewEndpointDiscoveryServiceHandler

func NewEndpointDiscoveryServiceHandler(svc EndpointDiscoveryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewEndpointDiscoveryServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewLocalityEndpointDiscoveryServiceHandler

func NewLocalityEndpointDiscoveryServiceHandler(svc LocalityEndpointDiscoveryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewLocalityEndpointDiscoveryServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type EndpointDiscoveryServiceClient

type EndpointDiscoveryServiceClient interface {
	// The resource_names field in DiscoveryRequest specifies a list of clusters
	// to subscribe to updates for.
	StreamEndpoints(context.Context) *connect.BidiStreamForClient[v31.DiscoveryRequest, v31.DiscoveryResponse]
	DeltaEndpoints(context.Context) *connect.BidiStreamForClient[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]
	FetchEndpoints(context.Context, *connect.Request[v31.DiscoveryRequest]) (*connect.Response[v31.DiscoveryResponse], error)
}

EndpointDiscoveryServiceClient is a client for the envoy.service.endpoint.v3.EndpointDiscoveryService service.

func NewEndpointDiscoveryServiceClient

func NewEndpointDiscoveryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) EndpointDiscoveryServiceClient

NewEndpointDiscoveryServiceClient constructs a client for the envoy.service.endpoint.v3.EndpointDiscoveryService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type EndpointDiscoveryServiceHandler

type EndpointDiscoveryServiceHandler interface {
	// The resource_names field in DiscoveryRequest specifies a list of clusters
	// to subscribe to updates for.
	StreamEndpoints(context.Context, *connect.BidiStream[v31.DiscoveryRequest, v31.DiscoveryResponse]) error
	DeltaEndpoints(context.Context, *connect.BidiStream[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]) error
	FetchEndpoints(context.Context, *connect.Request[v31.DiscoveryRequest]) (*connect.Response[v31.DiscoveryResponse], error)
}

EndpointDiscoveryServiceHandler is an implementation of the envoy.service.endpoint.v3.EndpointDiscoveryService service.

type LocalityEndpointDiscoveryServiceClient

type LocalityEndpointDiscoveryServiceClient interface {
	// The resource_names_subscribe resource_names_unsubscribe fields in DeltaDiscoveryRequest
	// specify a list of glob collections to subscribe to updates for.
	DeltaLocalityEndpoints(context.Context) *connect.BidiStreamForClient[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]
}

LocalityEndpointDiscoveryServiceClient is a client for the envoy.service.endpoint.v3.LocalityEndpointDiscoveryService service.

func NewLocalityEndpointDiscoveryServiceClient

func NewLocalityEndpointDiscoveryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) LocalityEndpointDiscoveryServiceClient

NewLocalityEndpointDiscoveryServiceClient constructs a client for the envoy.service.endpoint.v3.LocalityEndpointDiscoveryService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type LocalityEndpointDiscoveryServiceHandler

type LocalityEndpointDiscoveryServiceHandler interface {
	// The resource_names_subscribe resource_names_unsubscribe fields in DeltaDiscoveryRequest
	// specify a list of glob collections to subscribe to updates for.
	DeltaLocalityEndpoints(context.Context, *connect.BidiStream[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]) error
}

LocalityEndpointDiscoveryServiceHandler is an implementation of the envoy.service.endpoint.v3.LocalityEndpointDiscoveryService service.

type UnimplementedEndpointDiscoveryServiceHandler

type UnimplementedEndpointDiscoveryServiceHandler struct{}

UnimplementedEndpointDiscoveryServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedEndpointDiscoveryServiceHandler) DeltaEndpoints

func (UnimplementedEndpointDiscoveryServiceHandler) DeltaEndpoints(context.Context, *connect.BidiStream[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]) error

func (UnimplementedEndpointDiscoveryServiceHandler) FetchEndpoints

func (UnimplementedEndpointDiscoveryServiceHandler) FetchEndpoints(context.Context, *connect.Request[v31.DiscoveryRequest]) (*connect.Response[v31.DiscoveryResponse], error)

func (UnimplementedEndpointDiscoveryServiceHandler) StreamEndpoints

func (UnimplementedEndpointDiscoveryServiceHandler) StreamEndpoints(context.Context, *connect.BidiStream[v31.DiscoveryRequest, v31.DiscoveryResponse]) error

type UnimplementedLocalityEndpointDiscoveryServiceHandler

type UnimplementedLocalityEndpointDiscoveryServiceHandler struct{}

UnimplementedLocalityEndpointDiscoveryServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedLocalityEndpointDiscoveryServiceHandler) DeltaLocalityEndpoints

func (UnimplementedLocalityEndpointDiscoveryServiceHandler) DeltaLocalityEndpoints(context.Context, *connect.BidiStream[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]) error