rpcv1connect

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
  • func NewExecutorServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ExecutorServiceClient
• type ExecutorServiceHandler
• type PluginManagerServiceClient
  • func NewPluginManagerServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) PluginManagerServiceClient
• type PluginManagerServiceHandler
• type UnimplementedExecutorServiceHandler
  • func (UnimplementedExecutorServiceHandler) ExecuteStream(context.Context, ...) error
• type UnimplementedPluginManagerServiceHandler
  • func (UnimplementedPluginManagerServiceHandler) RegisterPluginModule(context.Context, *connect.Request[v1.RegisterPluginModuleRequest]) (*connect.Response[v1.RegisterPluginModuleResponse], error)

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.

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)