Documentation ¶
Index ¶
- Constants
- func NewRouteDiscoveryServiceHandler(svc RouteDiscoveryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewScopedRoutesDiscoveryServiceHandler(svc ScopedRoutesDiscoveryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewVirtualHostDiscoveryServiceHandler(svc VirtualHostDiscoveryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- type RouteDiscoveryServiceClient
- type RouteDiscoveryServiceHandler
- type ScopedRoutesDiscoveryServiceClient
- type ScopedRoutesDiscoveryServiceHandler
- type UnimplementedRouteDiscoveryServiceHandler
- func (UnimplementedRouteDiscoveryServiceHandler) DeltaRoutes(context.Context, ...) error
- func (UnimplementedRouteDiscoveryServiceHandler) FetchRoutes(context.Context, *connect.Request[v31.DiscoveryRequest]) (*connect.Response[v31.DiscoveryResponse], error)
- func (UnimplementedRouteDiscoveryServiceHandler) StreamRoutes(context.Context, ...) error
- type UnimplementedScopedRoutesDiscoveryServiceHandler
- func (UnimplementedScopedRoutesDiscoveryServiceHandler) DeltaScopedRoutes(context.Context, ...) error
- func (UnimplementedScopedRoutesDiscoveryServiceHandler) FetchScopedRoutes(context.Context, *connect.Request[v31.DiscoveryRequest]) (*connect.Response[v31.DiscoveryResponse], error)
- func (UnimplementedScopedRoutesDiscoveryServiceHandler) StreamScopedRoutes(context.Context, ...) error
- type UnimplementedVirtualHostDiscoveryServiceHandler
- type VirtualHostDiscoveryServiceClient
- type VirtualHostDiscoveryServiceHandler
Constants ¶
const ( // RouteDiscoveryServiceName is the fully-qualified name of the RouteDiscoveryService service. RouteDiscoveryServiceName = "envoy.service.route.v3.RouteDiscoveryService" // VirtualHostDiscoveryServiceName is the fully-qualified name of the VirtualHostDiscoveryService // service. VirtualHostDiscoveryServiceName = "envoy.service.route.v3.VirtualHostDiscoveryService" )
const ( // RouteDiscoveryServiceStreamRoutesProcedure is the fully-qualified name of the // RouteDiscoveryService's StreamRoutes RPC. RouteDiscoveryServiceStreamRoutesProcedure = "/envoy.service.route.v3.RouteDiscoveryService/StreamRoutes" // RouteDiscoveryServiceDeltaRoutesProcedure is the fully-qualified name of the // RouteDiscoveryService's DeltaRoutes RPC. RouteDiscoveryServiceDeltaRoutesProcedure = "/envoy.service.route.v3.RouteDiscoveryService/DeltaRoutes" // RouteDiscoveryServiceFetchRoutesProcedure is the fully-qualified name of the // RouteDiscoveryService's FetchRoutes RPC. RouteDiscoveryServiceFetchRoutesProcedure = "/envoy.service.route.v3.RouteDiscoveryService/FetchRoutes" // VirtualHostDiscoveryServiceDeltaVirtualHostsProcedure is the fully-qualified name of the // VirtualHostDiscoveryService's DeltaVirtualHosts RPC. VirtualHostDiscoveryServiceDeltaVirtualHostsProcedure = "/envoy.service.route.v3.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.
const ( // ScopedRoutesDiscoveryServiceStreamScopedRoutesProcedure is the fully-qualified name of the // ScopedRoutesDiscoveryService's StreamScopedRoutes RPC. ScopedRoutesDiscoveryServiceStreamScopedRoutesProcedure = "/envoy.service.route.v3.ScopedRoutesDiscoveryService/StreamScopedRoutes" // ScopedRoutesDiscoveryServiceDeltaScopedRoutesProcedure is the fully-qualified name of the // ScopedRoutesDiscoveryService's DeltaScopedRoutes RPC. ScopedRoutesDiscoveryServiceDeltaScopedRoutesProcedure = "/envoy.service.route.v3.ScopedRoutesDiscoveryService/DeltaScopedRoutes" // ScopedRoutesDiscoveryServiceFetchScopedRoutesProcedure is the fully-qualified name of the // ScopedRoutesDiscoveryService's FetchScopedRoutes RPC. ScopedRoutesDiscoveryServiceFetchScopedRoutesProcedure = "/envoy.service.route.v3.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.
const ( // ScopedRoutesDiscoveryServiceName is the fully-qualified name of the ScopedRoutesDiscoveryService // service. ScopedRoutesDiscoveryServiceName = "envoy.service.route.v3.ScopedRoutesDiscoveryService" )
Variables ¶
This section is empty.
Functions ¶
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 RouteDiscoveryServiceClient ¶
type RouteDiscoveryServiceClient interface { StreamRoutes(context.Context) *connect.BidiStreamForClient[v31.DiscoveryRequest, v31.DiscoveryResponse] DeltaRoutes(context.Context) *connect.BidiStreamForClient[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse] FetchRoutes(context.Context, *connect.Request[v31.DiscoveryRequest]) (*connect.Response[v31.DiscoveryResponse], error) }
RouteDiscoveryServiceClient is a client for the envoy.service.route.v3.RouteDiscoveryService service.
func NewRouteDiscoveryServiceClient ¶
func NewRouteDiscoveryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) RouteDiscoveryServiceClient
NewRouteDiscoveryServiceClient constructs a client for the envoy.service.route.v3.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[v31.DiscoveryRequest, v31.DiscoveryResponse]) error DeltaRoutes(context.Context, *connect.BidiStream[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]) error FetchRoutes(context.Context, *connect.Request[v31.DiscoveryRequest]) (*connect.Response[v31.DiscoveryResponse], error) }
RouteDiscoveryServiceHandler is an implementation of the envoy.service.route.v3.RouteDiscoveryService service.
type ScopedRoutesDiscoveryServiceClient ¶
type ScopedRoutesDiscoveryServiceClient interface { StreamScopedRoutes(context.Context) *connect.BidiStreamForClient[v31.DiscoveryRequest, v31.DiscoveryResponse] DeltaScopedRoutes(context.Context) *connect.BidiStreamForClient[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse] FetchScopedRoutes(context.Context, *connect.Request[v31.DiscoveryRequest]) (*connect.Response[v31.DiscoveryResponse], error) }
ScopedRoutesDiscoveryServiceClient is a client for the envoy.service.route.v3.ScopedRoutesDiscoveryService service.
func NewScopedRoutesDiscoveryServiceClient ¶
func NewScopedRoutesDiscoveryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ScopedRoutesDiscoveryServiceClient
NewScopedRoutesDiscoveryServiceClient constructs a client for the envoy.service.route.v3.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[v31.DiscoveryRequest, v31.DiscoveryResponse]) error DeltaScopedRoutes(context.Context, *connect.BidiStream[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]) error FetchScopedRoutes(context.Context, *connect.Request[v31.DiscoveryRequest]) (*connect.Response[v31.DiscoveryResponse], error) }
ScopedRoutesDiscoveryServiceHandler is an implementation of the envoy.service.route.v3.ScopedRoutesDiscoveryService service.
type UnimplementedRouteDiscoveryServiceHandler ¶
type UnimplementedRouteDiscoveryServiceHandler struct{}
UnimplementedRouteDiscoveryServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedRouteDiscoveryServiceHandler) DeltaRoutes ¶
func (UnimplementedRouteDiscoveryServiceHandler) DeltaRoutes(context.Context, *connect.BidiStream[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]) error
func (UnimplementedRouteDiscoveryServiceHandler) FetchRoutes ¶
func (UnimplementedRouteDiscoveryServiceHandler) FetchRoutes(context.Context, *connect.Request[v31.DiscoveryRequest]) (*connect.Response[v31.DiscoveryResponse], error)
func (UnimplementedRouteDiscoveryServiceHandler) StreamRoutes ¶
func (UnimplementedRouteDiscoveryServiceHandler) StreamRoutes(context.Context, *connect.BidiStream[v31.DiscoveryRequest, v31.DiscoveryResponse]) error
type UnimplementedScopedRoutesDiscoveryServiceHandler ¶
type UnimplementedScopedRoutesDiscoveryServiceHandler struct{}
UnimplementedScopedRoutesDiscoveryServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedScopedRoutesDiscoveryServiceHandler) DeltaScopedRoutes ¶
func (UnimplementedScopedRoutesDiscoveryServiceHandler) DeltaScopedRoutes(context.Context, *connect.BidiStream[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]) error
func (UnimplementedScopedRoutesDiscoveryServiceHandler) FetchScopedRoutes ¶
func (UnimplementedScopedRoutesDiscoveryServiceHandler) FetchScopedRoutes(context.Context, *connect.Request[v31.DiscoveryRequest]) (*connect.Response[v31.DiscoveryResponse], error)
func (UnimplementedScopedRoutesDiscoveryServiceHandler) StreamScopedRoutes ¶
func (UnimplementedScopedRoutesDiscoveryServiceHandler) StreamScopedRoutes(context.Context, *connect.BidiStream[v31.DiscoveryRequest, v31.DiscoveryResponse]) error
type UnimplementedVirtualHostDiscoveryServiceHandler ¶
type UnimplementedVirtualHostDiscoveryServiceHandler struct{}
UnimplementedVirtualHostDiscoveryServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedVirtualHostDiscoveryServiceHandler) DeltaVirtualHosts ¶
func (UnimplementedVirtualHostDiscoveryServiceHandler) DeltaVirtualHosts(context.Context, *connect.BidiStream[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]) error
type VirtualHostDiscoveryServiceClient ¶
type VirtualHostDiscoveryServiceClient interface {
DeltaVirtualHosts(context.Context) *connect.BidiStreamForClient[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]
}
VirtualHostDiscoveryServiceClient is a client for the envoy.service.route.v3.VirtualHostDiscoveryService service.
func NewVirtualHostDiscoveryServiceClient ¶
func NewVirtualHostDiscoveryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) VirtualHostDiscoveryServiceClient
NewVirtualHostDiscoveryServiceClient constructs a client for the envoy.service.route.v3.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[v31.DeltaDiscoveryRequest, v31.DeltaDiscoveryResponse]) error
}
VirtualHostDiscoveryServiceHandler is an implementation of the envoy.service.route.v3.VirtualHostDiscoveryService service.