rpcv1connect

package
v0.0.0-...-2da672c Latest Latest
Warning

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

 Go to latest Published: Sep 23, 2024 License: MIT Imports: 7 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	// WasiExecutorServiceName is the fully-qualified name of the WasiExecutorService service.
	WasiExecutorServiceName = "buildr.rpc.v1.WasiExecutorService"
	// ExecutorHostServiceName is the fully-qualified name of the ExecutorHostService service.
	ExecutorHostServiceName = "buildr.rpc.v1.ExecutorHostService"
)
View Source 
const (
	// WasiExecutorServicePluginInventoryProcedure is the fully-qualified name of the
	// WasiExecutorService's PluginInventory RPC.
	WasiExecutorServicePluginInventoryProcedure = "/buildr.rpc.v1.WasiExecutorService/PluginInventory"
	// WasiExecutorServiceStartTaskProcedure is the fully-qualified name of the WasiExecutorService's
	// StartTask RPC.
	WasiExecutorServiceStartTaskProcedure = "/buildr.rpc.v1.WasiExecutorService/StartTask"
	// WasiExecutorServiceHelpProcedure is the fully-qualified name of the WasiExecutorService's Help
	// RPC.
	WasiExecutorServiceHelpProcedure = "/buildr.rpc.v1.WasiExecutorService/Help"
	// WasiExecutorServiceBinaryNameProcedure is the fully-qualified name of the WasiExecutorService's
	// BinaryName RPC.
	WasiExecutorServiceBinaryNameProcedure = "/buildr.rpc.v1.WasiExecutorService/BinaryName"
	// ExecutorHostServiceProcessStartProcedure is the fully-qualified name of the ExecutorHostService's
	// ProcessStart RPC.
	ExecutorHostServiceProcessStartProcedure = "/buildr.rpc.v1.ExecutorHostService/ProcessStart"
	// ExecutorHostServiceLookupPathProcedure is the fully-qualified name of the ExecutorHostService's
	// LookupPath RPC.
	ExecutorHostServiceLookupPathProcedure = "/buildr.rpc.v1.ExecutorHostService/LookupPath"
)

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 NewExecutorHostServiceHandler 

func NewExecutorHostServiceHandler(svc ExecutorHostServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewExecutorHostServiceHandler 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 NewWasiExecutorServiceHandler 

func NewWasiExecutorServiceHandler(svc WasiExecutorServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewWasiExecutorServiceHandler 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 ExecutorHostServiceClient 

type ExecutorHostServiceClient interface {
	ProcessStart(context.Context, *connect.Request[v1.ProcessStartRequest]) (*connect.Response[v1.ProcessStartResponse], error)
	LookupPath(context.Context, *connect.Request[v1.LookupPathRequest]) (*connect.Response[v1.LookupPathResponse], error)
}

ExecutorHostServiceClient is a client for the buildr.rpc.v1.ExecutorHostService service.

func NewExecutorHostServiceClient 

func NewExecutorHostServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ExecutorHostServiceClient

NewExecutorHostServiceClient constructs a client for the buildr.rpc.v1.ExecutorHostService 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 ExecutorHostServiceHandler 

type ExecutorHostServiceHandler interface {
	ProcessStart(context.Context, *connect.Request[v1.ProcessStartRequest]) (*connect.Response[v1.ProcessStartResponse], error)
	LookupPath(context.Context, *connect.Request[v1.LookupPathRequest]) (*connect.Response[v1.LookupPathResponse], error)
}

ExecutorHostServiceHandler is an implementation of the buildr.rpc.v1.ExecutorHostService service.

type UnimplementedExecutorHostServiceHandler 

type UnimplementedExecutorHostServiceHandler struct{}

UnimplementedExecutorHostServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedExecutorHostServiceHandler) LookupPath 

func (UnimplementedExecutorHostServiceHandler) LookupPath(context.Context, *connect.Request[v1.LookupPathRequest]) (*connect.Response[v1.LookupPathResponse], error)

func (UnimplementedExecutorHostServiceHandler) ProcessStart 

func (UnimplementedExecutorHostServiceHandler) ProcessStart(context.Context, *connect.Request[v1.ProcessStartRequest]) (*connect.Response[v1.ProcessStartResponse], error)

type UnimplementedWasiExecutorServiceHandler 

type UnimplementedWasiExecutorServiceHandler struct{}

UnimplementedWasiExecutorServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedWasiExecutorServiceHandler) BinaryName 

func (UnimplementedWasiExecutorServiceHandler) BinaryName(context.Context, *connect.Request[v1.BinaryNameRequest]) (*connect.Response[v1.BinaryNameResponse], error)

func (UnimplementedWasiExecutorServiceHandler) Help 

func (UnimplementedWasiExecutorServiceHandler) Help(context.Context, *connect.Request[v1.HelpRequest]) (*connect.Response[v1.HelpResponse], error)

func (UnimplementedWasiExecutorServiceHandler) PluginInventory 

func (UnimplementedWasiExecutorServiceHandler) PluginInventory(context.Context, *connect.Request[v1.PluginInventoryRequest]) (*connect.Response[v1.PluginInventoryResponse], error)

func (UnimplementedWasiExecutorServiceHandler) StartTask 

func (UnimplementedWasiExecutorServiceHandler) StartTask(context.Context, *connect.Request[v11.StartTaskRequest]) (*connect.Response[v1.StartTaskResponse], error)

type WasiExecutorServiceClient 

type WasiExecutorServiceClient interface {
	PluginInventory(context.Context, *connect.Request[v1.PluginInventoryRequest]) (*connect.Response[v1.PluginInventoryResponse], error)
	StartTask(context.Context, *connect.Request[v11.StartTaskRequest]) (*connect.Response[v1.StartTaskResponse], error)
	Help(context.Context, *connect.Request[v1.HelpRequest]) (*connect.Response[v1.HelpResponse], error)
	BinaryName(context.Context, *connect.Request[v1.BinaryNameRequest]) (*connect.Response[v1.BinaryNameResponse], error)
}

WasiExecutorServiceClient is a client for the buildr.rpc.v1.WasiExecutorService service.

func NewWasiExecutorServiceClient 

func NewWasiExecutorServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) WasiExecutorServiceClient

NewWasiExecutorServiceClient constructs a client for the buildr.rpc.v1.WasiExecutorService 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 WasiExecutorServiceHandler 

type WasiExecutorServiceHandler interface {
	PluginInventory(context.Context, *connect.Request[v1.PluginInventoryRequest]) (*connect.Response[v1.PluginInventoryResponse], error)
	StartTask(context.Context, *connect.Request[v11.StartTaskRequest]) (*connect.Response[v1.StartTaskResponse], error)
	Help(context.Context, *connect.Request[v1.HelpRequest]) (*connect.Response[v1.HelpResponse], error)
	BinaryName(context.Context, *connect.Request[v1.BinaryNameRequest]) (*connect.Response[v1.BinaryNameResponse], error)
}

WasiExecutorServiceHandler is an implementation of the buildr.rpc.v1.WasiExecutorService 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.