Versions in this module Expand all Collapse all v0 v0.1.2 Jul 4, 2018 v0.1.1 Jun 29, 2018 Changes in this version + type GRPCClient struct + func (m *GRPCClient) ExecuteJob(job *proto.Job) (*proto.JobResult, error) + func (m *GRPCClient) GetJobs() (proto.Plugin_GetJobsClient, error) + type Plugin struct + func NewPlugin(command *exec.Cmd, logPath *string) (p *Plugin, err error) + func (p *Plugin) Close() + func (p *Plugin) Connect() error + func (p *Plugin) Execute(j *gaia.Job) error + func (p *Plugin) GetJobs() ([]gaia.Job, error) + type PluginGRPC interface + ExecuteJob func(job *proto.Job) (*proto.JobResult, error) + GetJobs func() (proto.Plugin_GetJobsClient, error) + type PluginGRPCImpl struct + Impl PluginGRPC + func (p *PluginGRPCImpl) GRPCClient(context context.Context, b *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error) + func (p *PluginGRPCImpl) GRPCServer(b *plugin.GRPCBroker, s *grpc.Server) error
Go to main page