grpc

package

v0.1.1 Latest Latest Go to latest Published: Apr 3, 2026 License: AGPL-3.0 Imports: 6 Imported by: 0

Details

Package grpc manages live gRPC connections to plugin containers.

This section is empty.

This section is empty.

This section is empty.

type Pool struct {
	// contains filtered or unexported fields
}

Pool manages a set of live gRPC connections to plugin containers. Connections are keyed by plugin ID. The pool is safe for concurrent use.

func NewPool() *Pool

NewPool creates an empty connection pool.

func (p *Pool) Close(id string) error

Close closes and removes the connection for the given plugin ID. Returns nil if the connection does not exist.

func (p *Pool) CloseAll()

CloseAll closes every connection in the pool.

func (p *Pool) Dial(ctx context.Context, id, addr string) error

Dial opens a gRPC connection to the plugin at addr and registers it under id. If a connection already exists for id, it is closed first.

func (p *Pool) HTTPPluginClient(id string) (pluginsv1.PluginHTTPClient, error)

HTTPPluginClient returns a PluginHTTPClient for the given plugin ID.

func (p *Pool) HasConnection(id string) bool

HasConnection reports whether a live connection exists for id.

func (p *Pool) HealthClient(id string) (pluginsv1.PluginHealthClient, error)

HealthClient returns a PluginHealthClient for the given plugin ID.

func (p *Pool) IDPClient(id string) (pluginsv1.IdentityPluginClient, error)

IDPClient returns an IdentityPluginClient for the given plugin ID.

func (p *Pool) MiddlewareClient(id string) (pluginsv1.PluginMiddlewareClient, error)

MiddlewareClient returns a PluginMiddlewareClient for the given plugin ID.

func (p *Pool) UIClient(id string) (pluginsv1.PluginUIClient, error)

UIClient returns a PluginUIClient for the given plugin ID.