apiv2connect

package
v1.16.0-20231220200614... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ClusterDiscoveryServiceStreamClustersProcedure is the fully-qualified name of the
	// ClusterDiscoveryService's StreamClusters RPC.
	ClusterDiscoveryServiceStreamClustersProcedure = "/envoy.api.v2.ClusterDiscoveryService/StreamClusters"
	// ClusterDiscoveryServiceDeltaClustersProcedure is the fully-qualified name of the
	// ClusterDiscoveryService's DeltaClusters RPC.
	ClusterDiscoveryServiceDeltaClustersProcedure = "/envoy.api.v2.ClusterDiscoveryService/DeltaClusters"
	// ClusterDiscoveryServiceFetchClustersProcedure is the fully-qualified name of the
	// ClusterDiscoveryService's FetchClusters RPC.
	ClusterDiscoveryServiceFetchClustersProcedure = "/envoy.api.v2.ClusterDiscoveryService/FetchClusters"
)

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.

View Source 
const (
	// EndpointDiscoveryServiceStreamEndpointsProcedure is the fully-qualified name of the
	// EndpointDiscoveryService's StreamEndpoints RPC.
	EndpointDiscoveryServiceStreamEndpointsProcedure = "/envoy.api.v2.EndpointDiscoveryService/StreamEndpoints"
	// EndpointDiscoveryServiceDeltaEndpointsProcedure is the fully-qualified name of the
	// EndpointDiscoveryService's DeltaEndpoints RPC.
	EndpointDiscoveryServiceDeltaEndpointsProcedure = "/envoy.api.v2.EndpointDiscoveryService/DeltaEndpoints"
	// EndpointDiscoveryServiceFetchEndpointsProcedure is the fully-qualified name of the
	// EndpointDiscoveryService's FetchEndpoints RPC.
	EndpointDiscoveryServiceFetchEndpointsProcedure = "/envoy.api.v2.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.

View Source 
const (
	// ListenerDiscoveryServiceDeltaListenersProcedure is the fully-qualified name of the
	// ListenerDiscoveryService's DeltaListeners RPC.
	ListenerDiscoveryServiceDeltaListenersProcedure = "/envoy.api.v2.ListenerDiscoveryService/DeltaListeners"
	// ListenerDiscoveryServiceStreamListenersProcedure is the fully-qualified name of the
	// ListenerDiscoveryService's StreamListeners RPC.
	ListenerDiscoveryServiceStreamListenersProcedure = "/envoy.api.v2.ListenerDiscoveryService/StreamListeners"
	// ListenerDiscoveryServiceFetchListenersProcedure is the fully-qualified name of the
	// ListenerDiscoveryService's FetchListeners RPC.
	ListenerDiscoveryServiceFetchListenersProcedure = "/envoy.api.v2.ListenerDiscoveryService/FetchListeners"
)

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.

View Source 
const (
	// RouteDiscoveryServiceName is the fully-qualified name of the RouteDiscoveryService service.
	RouteDiscoveryServiceName = "envoy.api.v2.RouteDiscoveryService"
	// VirtualHostDiscoveryServiceName is the fully-qualified name of the VirtualHostDiscoveryService
	// service.
	VirtualHostDiscoveryServiceName = "envoy.api.v2.VirtualHostDiscoveryService"
)
View Source 
const (
	// RouteDiscoveryServiceStreamRoutesProcedure is the fully-qualified name of the
	// RouteDiscoveryService's StreamRoutes RPC.
	RouteDiscoveryServiceStreamRoutesProcedure = "/envoy.api.v2.RouteDiscoveryService/StreamRoutes"
	// RouteDiscoveryServiceDeltaRoutesProcedure is the fully-qualified name of the
	// RouteDiscoveryService's DeltaRoutes RPC.
	RouteDiscoveryServiceDeltaRoutesProcedure = "/envoy.api.v2.RouteDiscoveryService/DeltaRoutes"
	// RouteDiscoveryServiceFetchRoutesProcedure is the fully-qualified name of the
	// RouteDiscoveryService's FetchRoutes RPC.
	RouteDiscoveryServiceFetchRoutesProcedure = "/envoy.api.v2.RouteDiscoveryService/FetchRoutes"
	// VirtualHostDiscoveryServiceDeltaVirtualHostsProcedure is the fully-qualified name of the
	// VirtualHostDiscoveryService's DeltaVirtualHosts RPC.
	VirtualHostDiscoveryServiceDeltaVirtualHostsProcedure = "/envoy.api.v2.VirtualHostDiscoveryService/DeltaVirtualHosts"
)

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.

View Source 
const (
	// ScopedRoutesDiscoveryServiceStreamScopedRoutesProcedure is the fully-qualified name of the
	// ScopedRoutesDiscoveryService's StreamScopedRoutes RPC.
	ScopedRoutesDiscoveryServiceStreamScopedRoutesProcedure = "/envoy.api.v2.ScopedRoutesDiscoveryService/StreamScopedRoutes"
	// ScopedRoutesDiscoveryServiceDeltaScopedRoutesProcedure is the fully-qualified name of the
	// ScopedRoutesDiscoveryService's DeltaScopedRoutes RPC.
	ScopedRoutesDiscoveryServiceDeltaScopedRoutesProcedure = "/envoy.api.v2.ScopedRoutesDiscoveryService/DeltaScopedRoutes"
	// ScopedRoutesDiscoveryServiceFetchScopedRoutesProcedure is the fully-qualified name of the
	// ScopedRoutesDiscoveryService's FetchScopedRoutes RPC.
	ScopedRoutesDiscoveryServiceFetchScopedRoutesProcedure = "/envoy.api.v2.ScopedRoutesDiscoveryService/FetchScopedRoutes"
)

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.

View Source 
const (
	// ClusterDiscoveryServiceName is the fully-qualified name of the ClusterDiscoveryService service.
	ClusterDiscoveryServiceName = "envoy.api.v2.ClusterDiscoveryService"
)
View Source 
const (
	// EndpointDiscoveryServiceName is the fully-qualified name of the EndpointDiscoveryService service.
	EndpointDiscoveryServiceName = "envoy.api.v2.EndpointDiscoveryService"
)
View Source 
const (
	// ListenerDiscoveryServiceName is the fully-qualified name of the ListenerDiscoveryService service.
	ListenerDiscoveryServiceName = "envoy.api.v2.ListenerDiscoveryService"
)
View Source 
const (
	// ScopedRoutesDiscoveryServiceName is the fully-qualified name of the ScopedRoutesDiscoveryService
	// service.
	ScopedRoutesDiscoveryServiceName = "envoy.api.v2.ScopedRoutesDiscoveryService"
)

Variables

This section is empty.

Functions

func NewClusterDiscoveryServiceHandler 

func NewClusterDiscoveryServiceHandler(svc ClusterDiscoveryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewClusterDiscoveryServiceHandler 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 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 NewListenerDiscoveryServiceHandler 

func NewListenerDiscoveryServiceHandler(svc ListenerDiscoveryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewListenerDiscoveryServiceHandler 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 NewRouteDiscoveryServiceHandler 

func NewRouteDiscoveryServiceHandler(svc RouteDiscoveryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewRouteDiscoveryServiceHandler 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 NewScopedRoutesDiscoveryServiceHandler 

func NewScopedRoutesDiscoveryServiceHandler(svc ScopedRoutesDiscoveryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewScopedRoutesDiscoveryServiceHandler 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 NewVirtualHostDiscoveryServiceHandler 

func NewVirtualHostDiscoveryServiceHandler(svc VirtualHostDiscoveryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewVirtualHostDiscoveryServiceHandler 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 ClusterDiscoveryServiceClient 

type ClusterDiscoveryServiceClient interface {
	StreamClusters(context.Context) *connect.BidiStreamForClient[v2.DiscoveryRequest, v2.DiscoveryResponse]
	DeltaClusters(context.Context) *connect.BidiStreamForClient[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]
	FetchClusters(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)
}

ClusterDiscoveryServiceClient is a client for the envoy.api.v2.ClusterDiscoveryService service.

func NewClusterDiscoveryServiceClient 

func NewClusterDiscoveryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ClusterDiscoveryServiceClient

NewClusterDiscoveryServiceClient constructs a client for the envoy.api.v2.ClusterDiscoveryService 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 ClusterDiscoveryServiceHandler 

type ClusterDiscoveryServiceHandler interface {
	StreamClusters(context.Context, *connect.BidiStream[v2.DiscoveryRequest, v2.DiscoveryResponse]) error
	DeltaClusters(context.Context, *connect.BidiStream[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]) error
	FetchClusters(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)
}

ClusterDiscoveryServiceHandler is an implementation of the envoy.api.v2.ClusterDiscoveryService service.

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[v2.DiscoveryRequest, v2.DiscoveryResponse]
	DeltaEndpoints(context.Context) *connect.BidiStreamForClient[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]
	FetchEndpoints(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)
}

EndpointDiscoveryServiceClient is a client for the envoy.api.v2.EndpointDiscoveryService service.

func NewEndpointDiscoveryServiceClient 

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

NewEndpointDiscoveryServiceClient constructs a client for the envoy.api.v2.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[v2.DiscoveryRequest, v2.DiscoveryResponse]) error
	DeltaEndpoints(context.Context, *connect.BidiStream[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]) error
	FetchEndpoints(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)
}

EndpointDiscoveryServiceHandler is an implementation of the envoy.api.v2.EndpointDiscoveryService service.

type ListenerDiscoveryServiceClient 

type ListenerDiscoveryServiceClient interface {
	DeltaListeners(context.Context) *connect.BidiStreamForClient[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]
	StreamListeners(context.Context) *connect.BidiStreamForClient[v2.DiscoveryRequest, v2.DiscoveryResponse]
	FetchListeners(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)
}

ListenerDiscoveryServiceClient is a client for the envoy.api.v2.ListenerDiscoveryService service.

func NewListenerDiscoveryServiceClient 

func NewListenerDiscoveryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ListenerDiscoveryServiceClient

NewListenerDiscoveryServiceClient constructs a client for the envoy.api.v2.ListenerDiscoveryService 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 ListenerDiscoveryServiceHandler 

type ListenerDiscoveryServiceHandler interface {
	DeltaListeners(context.Context, *connect.BidiStream[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]) error
	StreamListeners(context.Context, *connect.BidiStream[v2.DiscoveryRequest, v2.DiscoveryResponse]) error
	FetchListeners(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)
}

ListenerDiscoveryServiceHandler is an implementation of the envoy.api.v2.ListenerDiscoveryService service.

type RouteDiscoveryServiceClient 

type RouteDiscoveryServiceClient interface {
	StreamRoutes(context.Context) *connect.BidiStreamForClient[v2.DiscoveryRequest, v2.DiscoveryResponse]
	DeltaRoutes(context.Context) *connect.BidiStreamForClient[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]
	FetchRoutes(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)
}

RouteDiscoveryServiceClient is a client for the envoy.api.v2.RouteDiscoveryService service.

func NewRouteDiscoveryServiceClient 

func NewRouteDiscoveryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) RouteDiscoveryServiceClient

NewRouteDiscoveryServiceClient constructs a client for the envoy.api.v2.RouteDiscoveryService 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 RouteDiscoveryServiceHandler 

type RouteDiscoveryServiceHandler interface {
	StreamRoutes(context.Context, *connect.BidiStream[v2.DiscoveryRequest, v2.DiscoveryResponse]) error
	DeltaRoutes(context.Context, *connect.BidiStream[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]) error
	FetchRoutes(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)
}

RouteDiscoveryServiceHandler is an implementation of the envoy.api.v2.RouteDiscoveryService service.

type ScopedRoutesDiscoveryServiceClient 

type ScopedRoutesDiscoveryServiceClient interface {
	StreamScopedRoutes(context.Context) *connect.BidiStreamForClient[v2.DiscoveryRequest, v2.DiscoveryResponse]
	DeltaScopedRoutes(context.Context) *connect.BidiStreamForClient[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]
	FetchScopedRoutes(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)
}

ScopedRoutesDiscoveryServiceClient is a client for the envoy.api.v2.ScopedRoutesDiscoveryService service.

func NewScopedRoutesDiscoveryServiceClient 

func NewScopedRoutesDiscoveryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ScopedRoutesDiscoveryServiceClient

NewScopedRoutesDiscoveryServiceClient constructs a client for the envoy.api.v2.ScopedRoutesDiscoveryService 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 ScopedRoutesDiscoveryServiceHandler 

type ScopedRoutesDiscoveryServiceHandler interface {
	StreamScopedRoutes(context.Context, *connect.BidiStream[v2.DiscoveryRequest, v2.DiscoveryResponse]) error
	DeltaScopedRoutes(context.Context, *connect.BidiStream[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]) error
	FetchScopedRoutes(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)
}

ScopedRoutesDiscoveryServiceHandler is an implementation of the envoy.api.v2.ScopedRoutesDiscoveryService service.

type UnimplementedClusterDiscoveryServiceHandler 

type UnimplementedClusterDiscoveryServiceHandler struct{}

UnimplementedClusterDiscoveryServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedClusterDiscoveryServiceHandler) DeltaClusters 

func (UnimplementedClusterDiscoveryServiceHandler) DeltaClusters(context.Context, *connect.BidiStream[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]) error

func (UnimplementedClusterDiscoveryServiceHandler) FetchClusters 

func (UnimplementedClusterDiscoveryServiceHandler) FetchClusters(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)

func (UnimplementedClusterDiscoveryServiceHandler) StreamClusters 

func (UnimplementedClusterDiscoveryServiceHandler) StreamClusters(context.Context, *connect.BidiStream[v2.DiscoveryRequest, v2.DiscoveryResponse]) error

type UnimplementedEndpointDiscoveryServiceHandler 

type UnimplementedEndpointDiscoveryServiceHandler struct{}

UnimplementedEndpointDiscoveryServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedEndpointDiscoveryServiceHandler) DeltaEndpoints 

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

func (UnimplementedEndpointDiscoveryServiceHandler) FetchEndpoints 

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

func (UnimplementedEndpointDiscoveryServiceHandler) StreamEndpoints 

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

type UnimplementedListenerDiscoveryServiceHandler 

type UnimplementedListenerDiscoveryServiceHandler struct{}

UnimplementedListenerDiscoveryServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedListenerDiscoveryServiceHandler) DeltaListeners 

func (UnimplementedListenerDiscoveryServiceHandler) DeltaListeners(context.Context, *connect.BidiStream[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]) error

func (UnimplementedListenerDiscoveryServiceHandler) FetchListeners 

func (UnimplementedListenerDiscoveryServiceHandler) FetchListeners(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)

func (UnimplementedListenerDiscoveryServiceHandler) StreamListeners 

func (UnimplementedListenerDiscoveryServiceHandler) StreamListeners(context.Context, *connect.BidiStream[v2.DiscoveryRequest, v2.DiscoveryResponse]) error

type UnimplementedRouteDiscoveryServiceHandler 

type UnimplementedRouteDiscoveryServiceHandler struct{}

UnimplementedRouteDiscoveryServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedRouteDiscoveryServiceHandler) DeltaRoutes 

func (UnimplementedRouteDiscoveryServiceHandler) DeltaRoutes(context.Context, *connect.BidiStream[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]) error

func (UnimplementedRouteDiscoveryServiceHandler) FetchRoutes 

func (UnimplementedRouteDiscoveryServiceHandler) FetchRoutes(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)

func (UnimplementedRouteDiscoveryServiceHandler) StreamRoutes 

func (UnimplementedRouteDiscoveryServiceHandler) StreamRoutes(context.Context, *connect.BidiStream[v2.DiscoveryRequest, v2.DiscoveryResponse]) error

type UnimplementedScopedRoutesDiscoveryServiceHandler 

type UnimplementedScopedRoutesDiscoveryServiceHandler struct{}

UnimplementedScopedRoutesDiscoveryServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedScopedRoutesDiscoveryServiceHandler) DeltaScopedRoutes 

func (UnimplementedScopedRoutesDiscoveryServiceHandler) DeltaScopedRoutes(context.Context, *connect.BidiStream[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]) error

func (UnimplementedScopedRoutesDiscoveryServiceHandler) FetchScopedRoutes 

func (UnimplementedScopedRoutesDiscoveryServiceHandler) FetchScopedRoutes(context.Context, *connect.Request[v2.DiscoveryRequest]) (*connect.Response[v2.DiscoveryResponse], error)

func (UnimplementedScopedRoutesDiscoveryServiceHandler) StreamScopedRoutes 

func (UnimplementedScopedRoutesDiscoveryServiceHandler) StreamScopedRoutes(context.Context, *connect.BidiStream[v2.DiscoveryRequest, v2.DiscoveryResponse]) error

type UnimplementedVirtualHostDiscoveryServiceHandler 

type UnimplementedVirtualHostDiscoveryServiceHandler struct{}

UnimplementedVirtualHostDiscoveryServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedVirtualHostDiscoveryServiceHandler) DeltaVirtualHosts 

func (UnimplementedVirtualHostDiscoveryServiceHandler) DeltaVirtualHosts(context.Context, *connect.BidiStream[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]) error

type VirtualHostDiscoveryServiceClient 

type VirtualHostDiscoveryServiceClient interface {
	DeltaVirtualHosts(context.Context) *connect.BidiStreamForClient[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]
}

VirtualHostDiscoveryServiceClient is a client for the envoy.api.v2.VirtualHostDiscoveryService service.

func NewVirtualHostDiscoveryServiceClient 

func NewVirtualHostDiscoveryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) VirtualHostDiscoveryServiceClient

NewVirtualHostDiscoveryServiceClient constructs a client for the envoy.api.v2.VirtualHostDiscoveryService 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 VirtualHostDiscoveryServiceHandler 

type VirtualHostDiscoveryServiceHandler interface {
	DeltaVirtualHosts(context.Context, *connect.BidiStream[v2.DeltaDiscoveryRequest, v2.DeltaDiscoveryResponse]) error
}

VirtualHostDiscoveryServiceHandler is an implementation of the envoy.api.v2.VirtualHostDiscoveryService service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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