Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Handshake = plugin.HandshakeConfig{ ProtocolVersion: sn.ProtoVersion, MagicCookieKey: magicKey, MagicCookieValue: magicValue, }
View Source
var PluginMap = func(timeout time.Duration) map[string]plugin.Plugin { return map[string]plugin.Plugin{ "grpc": &PluginGRPCImpl{ SkynetTimeout: timeout, }, } }
Functions ¶
This section is empty.
Types ¶
type GRPCClient ¶
type GRPCClient struct {
// contains filtered or unexported fields
}
func (*GRPCClient) Disable ¶
func (m *GRPCClient) Disable(h PluginHelper) (*PluginError, error)
func (*GRPCClient) Enable ¶
func (m *GRPCClient) Enable(h PluginHelper) (*PluginError, error)
type GRPCPluginHelperClient ¶
type GRPCPluginHelperClient struct {
// contains filtered or unexported fields
}
type GRPCPluginHelperServer ¶
type GRPCPluginHelperServer struct { proto.UnimplementedPluginHelperServer // contains filtered or unexported fields }
func (*GRPCPluginHelperServer) Eval ¶
func (m *GRPCPluginHelperServer) Eval(ctx context.Context, req *proto.EvalRequest) (rsp *proto.EvalResponse, err error)
type GRPCServer ¶
type GRPCServer struct { proto.UnimplementedPluginServer // contains filtered or unexported fields }
type PluginAPI ¶
type PluginAPI interface { Enable(h PluginHelper) (*PluginError, error) Disable(h PluginHelper) (*PluginError, error) }
type PluginError ¶
type PluginGRPCImpl ¶
type PluginGRPCImpl struct { plugin.NetRPCUnsupportedPlugin Impl PluginAPI SkynetTimeout time.Duration PluginTimeout time.Duration }
func (*PluginGRPCImpl) GRPCClient ¶
func (p *PluginGRPCImpl) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)
func (*PluginGRPCImpl) GRPCServer ¶
func (p *PluginGRPCImpl) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error
type PluginHelper ¶
Click to show internal directories.
Click to hide internal directories.