grpcplugin

Documentation

Index

• func NewFromGRPCConn(l L.L, id apiplugin.PluginID, conn *grpc.ClientConn) (plugin.Plugin, error)
• func NewFromHostPort(l L.L, id apiplugin.PluginID, hostPort string) (plugin.Plugin, error)
• type GRPCPlugin
  • func (p *GRPCPlugin) Call(ctx context.Context, v *apivalues.Value, args []*apivalues.Value, ...) (*apivalues.Value, error)
  • func (p *GRPCPlugin) Describe(ctx context.Context) (*apiplugin.PluginDesc, error)
  • func (p *GRPCPlugin) Get(ctx context.Context, name string) (*apivalues.Value, error)
  • func (p *GRPCPlugin) GetAll(ctx context.Context) (map[string]*apivalues.Value, error)

Functions

func NewFromGRPCConn

func NewFromGRPCConn(l L.L, id apiplugin.PluginID, conn *grpc.ClientConn) (plugin.Plugin, error)

func NewFromHostPort

func NewFromHostPort(l L.L, id apiplugin.PluginID, hostPort string) (plugin.Plugin, error)

Types

type GRPCPlugin

type GRPCPlugin struct {
	L      L.Nullable
	ID     apiplugin.PluginID
	Client pb.PluginsProviderClient
}

func (*GRPCPlugin) Call

func (p *GRPCPlugin) Call(ctx context.Context, v *apivalues.Value, args []*apivalues.Value, kwargs map[string]*apivalues.Value) (*apivalues.Value, error)

func (*GRPCPlugin) Describe

func (p *GRPCPlugin) Describe(ctx context.Context) (*apiplugin.PluginDesc, error)

func (*GRPCPlugin) Get

func (p *GRPCPlugin) Get(ctx context.Context, name string) (*apivalues.Value, error)

func (*GRPCPlugin) GetAll

func (p *GRPCPlugin) GetAll(ctx context.Context) (map[string]*apivalues.Value, error)