Documentation
¶
Index ¶
- Constants
- func NewExecutorServiceHandler(svc ExecutorServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- func NewPluginManagerServiceHandler(svc PluginManagerServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
- type ExecutorServiceClient
- type ExecutorServiceHandler
- type PluginManagerServiceClient
- type PluginManagerServiceHandler
- type UnimplementedExecutorServiceHandler
- type UnimplementedPluginManagerServiceHandler
Constants ¶
const ( // ExecutorServiceName is the fully-qualified name of the ExecutorService service. ExecutorServiceName = "buildr.rpc.v1.ExecutorService" // PluginManagerServiceName is the fully-qualified name of the PluginManagerService service. PluginManagerServiceName = "buildr.rpc.v1.PluginManagerService" )
const ( // ExecutorServiceExecuteStreamProcedure is the fully-qualified name of the ExecutorService's // ExecuteStream RPC. ExecutorServiceExecuteStreamProcedure = "/buildr.rpc.v1.ExecutorService/ExecuteStream" // PluginManagerServiceRegisterPluginModuleProcedure is the fully-qualified name of the // PluginManagerService's RegisterPluginModule RPC. PluginManagerServiceRegisterPluginModuleProcedure = "/buildr.rpc.v1.PluginManagerService/RegisterPluginModule" )
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.
Variables ¶
This section is empty.
Functions ¶
func NewExecutorServiceHandler ¶
func NewExecutorServiceHandler(svc ExecutorServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewExecutorServiceHandler 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 NewPluginManagerServiceHandler ¶
func NewPluginManagerServiceHandler(svc PluginManagerServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewPluginManagerServiceHandler 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 ExecutorServiceClient ¶
type ExecutorServiceClient interface {
ExecuteStream(context.Context) *connect.BidiStreamForClient[v1.ExecutionClientMessage, v1.ExecutionServerMessage]
}
ExecutorServiceClient is a client for the buildr.rpc.v1.ExecutorService service.
func NewExecutorServiceClient ¶
func NewExecutorServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ExecutorServiceClient
NewExecutorServiceClient constructs a client for the buildr.rpc.v1.ExecutorService 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 ExecutorServiceHandler ¶
type ExecutorServiceHandler interface {
ExecuteStream(context.Context, *connect.BidiStream[v1.ExecutionClientMessage, v1.ExecutionServerMessage]) error
}
ExecutorServiceHandler is an implementation of the buildr.rpc.v1.ExecutorService service.
type PluginManagerServiceClient ¶
type PluginManagerServiceClient interface {
RegisterPluginModule(context.Context, *connect.Request[v1.RegisterPluginModuleRequest]) (*connect.Response[v1.RegisterPluginModuleResponse], error)
}
PluginManagerServiceClient is a client for the buildr.rpc.v1.PluginManagerService service.
func NewPluginManagerServiceClient ¶
func NewPluginManagerServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) PluginManagerServiceClient
NewPluginManagerServiceClient constructs a client for the buildr.rpc.v1.PluginManagerService 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 PluginManagerServiceHandler ¶
type PluginManagerServiceHandler interface {
RegisterPluginModule(context.Context, *connect.Request[v1.RegisterPluginModuleRequest]) (*connect.Response[v1.RegisterPluginModuleResponse], error)
}
PluginManagerServiceHandler is an implementation of the buildr.rpc.v1.PluginManagerService service.
type UnimplementedExecutorServiceHandler ¶
type UnimplementedExecutorServiceHandler struct{}
UnimplementedExecutorServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedExecutorServiceHandler) ExecuteStream ¶
func (UnimplementedExecutorServiceHandler) ExecuteStream(context.Context, *connect.BidiStream[v1.ExecutionClientMessage, v1.ExecutionServerMessage]) error
type UnimplementedPluginManagerServiceHandler ¶
type UnimplementedPluginManagerServiceHandler struct{}
UnimplementedPluginManagerServiceHandler returns CodeUnimplemented from all methods.
func (UnimplementedPluginManagerServiceHandler) RegisterPluginModule ¶
func (UnimplementedPluginManagerServiceHandler) RegisterPluginModule(context.Context, *connect.Request[v1.RegisterPluginModuleRequest]) (*connect.Response[v1.RegisterPluginModuleResponse], error)
Source Files