grpc

package

Go to main page

Versions in this module

v0

v0.8.1

Apr 4, 2026

Changes in this version

+ func GenerateComposeFragment(pluginName string, sidecars []plugin.SidecarSpec) string

type K8sPodSpec

+ Sidecars []plugin.SidecarSpec

v0.8.0

Mar 28, 2026

Changes in this version

+ func GeneratePodManifest(spec K8sPodSpec) string

+ type IsolationMode string

+ const IsolationK8s

+ const IsolationLocal

+ func GetIsolationMode() IsolationMode

+ type K8sPodSpec struct

+ CPUMillis int

+ Image string

+ MemoryMB int

+ Namespace string

+ PluginName string

+ Port int

v0.7.0

Mar 26, 2026

Changes in this version

+ type GKPluginPluginHost struct

+ Host plugin.HostAPI

+ Impl GKPluginInterface

+ PluginName string

+ func (p *GKPluginPluginHost) Client(b *goplugin.MuxBroker, c *rpc.Client) (interface{}, error)

+ func (p *GKPluginPluginHost) Server(b *goplugin.MuxBroker) (interface{}, error)

+ type GKPluginRPCClientHost struct

+ func (c *GKPluginRPCClientHost) Call(fn string, args json.RawMessage) (json.RawMessage, error)

+ func (c *GKPluginRPCClientHost) GKRegister() (*plugin.GKRegistration, error)

+ func (c *GKPluginRPCClientHost) Init(config map[string]string) error

+ func (c *GKPluginRPCClientHost) Shutdown() error

+ type GKPluginRPCServerHost struct

+ Impl GKPluginInterface

+ func (s *GKPluginRPCServerHost) Call(req CallRequest, resp *CallResponse) error

+ func (s *GKPluginRPCServerHost) GKRegister(args interface{}, resp *[]byte) error

+ func (s *GKPluginRPCServerHost) Init(req InitRequest, resp *interface{}) error

+ func (s *GKPluginRPCServerHost) Shutdown(args interface{}, resp *interface{}) error

type GRPCPlugin

+ func (p *GRPCPlugin) SetCallTimeout(d time.Duration)

type HostAPIRPCServer

+ CallerName string

v0.6.5

Feb 9, 2026

Changes in this version

+ var Handshake = goplugin.HandshakeConfig

+ var PluginMap = map[string]goplugin.Plugin

+ func ServePlugin(impl GKPluginInterface)

+ type CallRequest struct

+ Args json.RawMessage

+ Function string

+ type CallResponse struct

+ Error string

+ Result json.RawMessage

+ type GKPluginInterface interface

+ Call func(fn string, args json.RawMessage) (json.RawMessage, error)

+ GKRegister func() (*plugin.GKRegistration, error)

+ Init func(config map[string]string) error

+ Shutdown func() error

+ type GKPluginPlugin struct

+ Host plugin.HostAPI

+ Impl GKPluginInterface

+ func (p *GKPluginPlugin) Client(b *goplugin.MuxBroker, c *rpc.Client) (interface{}, error)

+ func (p *GKPluginPlugin) Server(b *goplugin.MuxBroker) (interface{}, error)

+ type GKPluginRPCClient struct

+ func (c *GKPluginRPCClient) Call(fn string, args json.RawMessage) (json.RawMessage, error)

+ func (c *GKPluginRPCClient) GKRegister() (*plugin.GKRegistration, error)

+ func (c *GKPluginRPCClient) Init(config map[string]string) error

+ func (c *GKPluginRPCClient) Shutdown() error

+ type GKPluginRPCServer struct

+ Impl GKPluginInterface

+ func (s *GKPluginRPCServer) Call(req CallRequest, resp *CallResponse) error

+ func (s *GKPluginRPCServer) GKRegister(args interface{}, resp *plugin.GKRegistration) error

+ func (s *GKPluginRPCServer) Init(req InitRequest, resp *interface{}) error

+ func (s *GKPluginRPCServer) Shutdown(args interface{}, resp *interface{}) error

+ type GRPCPlugin struct

+ func LoadGRPCPlugin(execPath string, host plugin.HostAPI) (*GRPCPlugin, error)

+ func (p *GRPCPlugin) Call(ctx context.Context, fn string, args json.RawMessage) (json.RawMessage, error)

+ func (p *GRPCPlugin) GKRegister() plugin.GKRegistration

+ func (p *GRPCPlugin) Init(ctx context.Context, host plugin.HostAPI) error

+ func (p *GRPCPlugin) Shutdown(ctx context.Context) error

+ type HostAPIRPCClient struct

+ func NewHostAPIRPCClient(client *rpc.Client) *HostAPIRPCClient

+ func (c *HostAPIRPCClient) Call(method string, args any) (json.RawMessage, error)

+ func (c *HostAPIRPCClient) CallPlugin(pluginName, fn string, args json.RawMessage) (json.RawMessage, error)

+ func (c *HostAPIRPCClient) DBExec(query string, args ...any) (int64, error)

+ func (c *HostAPIRPCClient) DBQuery(query string, args ...any) ([]map[string]any, error)

+ type HostAPIRPCServer struct

+ Host plugin.HostAPI

+ func (s *HostAPIRPCServer) Call(req HostAPIRequest, resp *HostAPIResponse) error

+ type HostAPIRequest struct

+ Args json.RawMessage

+ CallerPlugin string

+ Method string

+ type HostAPIResponse struct

+ Error string

+ Result json.RawMessage

+ type HostError struct

+ Message string

+ func (e *HostError) Error() string

+ type InitRequest struct

+ Config map[string]string

+ HostAPIID uint32

+ type UnknownMethodError struct

+ Method string

+ func (e *UnknownMethodError) Error() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL