Versions in this module Expand all Collapse all v1 v1.0.7 Oct 1, 2024 v1.0.6 Sep 30, 2024 Changes in this version + var Handshake = plugin.HandshakeConfig v1.0.5 Sep 27, 2024 Changes in this version + const ApplicationResponseSuccess + type GRPCClient struct + func (g *GRPCClient) Init(m map[string]string) error + func (g *GRPCClient) Name() (string, error) + func (g *GRPCClient) ParseOutput() (string, error) + func (g *GRPCClient) Run() error + func (g *GRPCClient) Version() (string, error) + type GRPCPlugin struct + Impl IPlugin + func (p *GRPCPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error) + func (p *GRPCPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error + type GRPCServer struct + Impl IPlugin + func (g *GRPCServer) Init(_ context.Context, config *plugininterface.Config) (*plugininterface.InitResponse, error) + func (g *GRPCServer) Name(_ context.Context, _ *plugininterface.Empty) (*plugininterface.NameResponse, error) + func (g *GRPCServer) ParseOutput(_ context.Context, _ *plugininterface.Empty) (*plugininterface.ParseOutputResponse, error) + func (g *GRPCServer) Run(_ context.Context, _ *plugininterface.Empty) (*plugininterface.RunResponse, error) + func (g *GRPCServer) Version(_ context.Context, _ *plugininterface.Empty) (*plugininterface.VersionResponse, error) + type IPlugin interface + Init func(map[string]string) error + Name func() (string, error) + ParseOutput func() (string, error) + Run func() error + Version func() (string, error) v1.0.4 Sep 26, 2024 Changes in this version + var PluginMap = map[string]plugin.PluginClient + type KV interface + Get func(key string) ([]byte, error) + Put func(key string, value []byte) error + type KVGRPCPlugin struct + Impl KV + func (p *KVGRPCPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error) + func (p *KVGRPCPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error + type KVPlugin struct + Impl KV + func (*KVPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error) + func (p *KVPlugin) Server(*plugin.MuxBroker) (interface{}, error)
Go to main page