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.