pluginsv1connect

package
v0.1.0-do.not.use Latest Latest
Warning

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

 Go to latest Published: Jul 1, 2026 License: Apache-2.0 Imports: 6 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	// RegisterServiceName is the fully-qualified name of the RegisterService service.
	RegisterServiceName = "plugins.v1.RegisterService"
	// PluginServiceName is the fully-qualified name of the PluginService service.
	PluginServiceName = "plugins.v1.PluginService"
	// PluginManagementServiceName is the fully-qualified name of the PluginManagementService service.
	PluginManagementServiceName = "plugins.v1.PluginManagementService"
)
View Source 
const (
	// RegisterServiceRegisterPluginProcedure is the fully-qualified name of the RegisterService's
	// RegisterPlugin RPC.
	RegisterServiceRegisterPluginProcedure = "/plugins.v1.RegisterService/RegisterPlugin"
	// PluginServiceShutdownProcedure is the fully-qualified name of the PluginService's Shutdown RPC.
	PluginServiceShutdownProcedure = "/plugins.v1.PluginService/Shutdown"
	// PluginManagementServiceListPluginsProcedure is the fully-qualified name of the
	// PluginManagementService's ListPlugins RPC.
	PluginManagementServiceListPluginsProcedure = "/plugins.v1.PluginManagementService/ListPlugins"
	// PluginManagementServiceEnablePluginProcedure is the fully-qualified name of the
	// PluginManagementService's EnablePlugin RPC.
	PluginManagementServiceEnablePluginProcedure = "/plugins.v1.PluginManagementService/EnablePlugin"
	// PluginManagementServiceDisablePluginProcedure is the fully-qualified name of the
	// PluginManagementService's DisablePlugin RPC.
	PluginManagementServiceDisablePluginProcedure = "/plugins.v1.PluginManagementService/DisablePlugin"
)

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 NewPluginManagementServiceHandler 

func NewPluginManagementServiceHandler(svc PluginManagementServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewPluginManagementServiceHandler 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 NewPluginServiceHandler 

func NewPluginServiceHandler(svc PluginServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewPluginServiceHandler 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 NewRegisterServiceHandler 

func NewRegisterServiceHandler(svc RegisterServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewRegisterServiceHandler 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 PluginManagementServiceClient 

type PluginManagementServiceClient interface {
	// ListPlugins returns all plugins registered with the engine.
	ListPlugins(context.Context, *connect.Request[v1.ListPluginsRequest]) (*connect.Response[v1.ListPluginsResponse], error)
	// EnablePlugin enables a plugin by name.
	EnablePlugin(context.Context, *connect.Request[v1.EnablePluginRequest]) (*connect.Response[v1.EnablePluginResponse], error)
	// DisablePlugin disables a plugin by name.
	DisablePlugin(context.Context, *connect.Request[v1.DisablePluginRequest]) (*connect.Response[v1.DisablePluginResponse], error)
}

PluginManagementServiceClient is a client for the plugins.v1.PluginManagementService service.

func NewPluginManagementServiceClient 

func NewPluginManagementServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) PluginManagementServiceClient

NewPluginManagementServiceClient constructs a client for the plugins.v1.PluginManagementService 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 PluginManagementServiceHandler 

type PluginManagementServiceHandler interface {
	// ListPlugins returns all plugins registered with the engine.
	ListPlugins(context.Context, *connect.Request[v1.ListPluginsRequest]) (*connect.Response[v1.ListPluginsResponse], error)
	// EnablePlugin enables a plugin by name.
	EnablePlugin(context.Context, *connect.Request[v1.EnablePluginRequest]) (*connect.Response[v1.EnablePluginResponse], error)
	// DisablePlugin disables a plugin by name.
	DisablePlugin(context.Context, *connect.Request[v1.DisablePluginRequest]) (*connect.Response[v1.DisablePluginResponse], error)
}

PluginManagementServiceHandler is an implementation of the plugins.v1.PluginManagementService service.

type PluginServiceClient 

type PluginServiceClient interface {
	// Shutdown a plugin (let it know the runtime is going down).
	Shutdown(context.Context, *connect.Request[v1.ShutdownRequest]) (*connect.Response[v1.ShutdownResponse], error)
}

PluginServiceClient is a client for the plugins.v1.PluginService service.

func NewPluginServiceClient 

func NewPluginServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) PluginServiceClient

NewPluginServiceClient constructs a client for the plugins.v1.PluginService 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 PluginServiceHandler 

type PluginServiceHandler interface {
	// Shutdown a plugin (let it know the runtime is going down).
	Shutdown(context.Context, *connect.Request[v1.ShutdownRequest]) (*connect.Response[v1.ShutdownResponse], error)
}

PluginServiceHandler is an implementation of the plugins.v1.PluginService service.

type RegisterServiceClient 

type RegisterServiceClient interface {
	// RegisterPlugin registers the plugin with the engine.
	RegisterPlugin(context.Context, *connect.Request[v1.RegisterPluginRequest]) (*connect.Response[v1.RegisterPluginResponse], error)
}

RegisterServiceClient is a client for the plugins.v1.RegisterService service.

func NewRegisterServiceClient 

func NewRegisterServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) RegisterServiceClient

NewRegisterServiceClient constructs a client for the plugins.v1.RegisterService 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 RegisterServiceHandler 

type RegisterServiceHandler interface {
	// RegisterPlugin registers the plugin with the engine.
	RegisterPlugin(context.Context, *connect.Request[v1.RegisterPluginRequest]) (*connect.Response[v1.RegisterPluginResponse], error)
}

RegisterServiceHandler is an implementation of the plugins.v1.RegisterService service.

type UnimplementedPluginManagementServiceHandler 

type UnimplementedPluginManagementServiceHandler struct{}

UnimplementedPluginManagementServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedPluginManagementServiceHandler) DisablePlugin 

func (UnimplementedPluginManagementServiceHandler) DisablePlugin(context.Context, *connect.Request[v1.DisablePluginRequest]) (*connect.Response[v1.DisablePluginResponse], error)

func (UnimplementedPluginManagementServiceHandler) EnablePlugin 

func (UnimplementedPluginManagementServiceHandler) EnablePlugin(context.Context, *connect.Request[v1.EnablePluginRequest]) (*connect.Response[v1.EnablePluginResponse], error)

func (UnimplementedPluginManagementServiceHandler) ListPlugins 

func (UnimplementedPluginManagementServiceHandler) ListPlugins(context.Context, *connect.Request[v1.ListPluginsRequest]) (*connect.Response[v1.ListPluginsResponse], error)

type UnimplementedPluginServiceHandler 

type UnimplementedPluginServiceHandler struct{}

UnimplementedPluginServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedPluginServiceHandler) Shutdown 

func (UnimplementedPluginServiceHandler) Shutdown(context.Context, *connect.Request[v1.ShutdownRequest]) (*connect.Response[v1.ShutdownResponse], error)

type UnimplementedRegisterServiceHandler 

type UnimplementedRegisterServiceHandler struct{}

UnimplementedRegisterServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedRegisterServiceHandler) RegisterPlugin 

func (UnimplementedRegisterServiceHandler) RegisterPlugin(context.Context, *connect.Request[v1.RegisterPluginRequest]) (*connect.Response[v1.RegisterPluginResponse], error)

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.