shared

Jul 11, 2025

Changes in this version

type Task

+ GetDescription func() (string, error)

type TaskClient

+ func (c *TaskClient) GetDescription() (string, error)

Jul 8, 2025

Changes in this version

+ func NewJobClient() (protobuf.JobClient, error)

+ func NewPluginClient(jobServerAddress, taskPluginPath, taskPluginName string, logger *log.Logger) *plugin.Client

+ func PluginServe(taskName string, taskServer protobuf.TaskServer)

Jul 7, 2025

Changes in this version

+ func GetHandshakeConfig(token string) plugin.HandshakeConfig

+ type Job interface

+ InvokeService func(request *protobuf.JobInvokeServiceRequest) (*protobuf.JobInvokeServiceResponse, error)

+ type Task interface

+ Execute func(ctx context.Context, request *protobuf.TaskExecuteRequest) (*protobuf.TaskExecuteResponse, error)

+ type TaskClient struct

+ func (c *TaskClient) Execute(params map[string]string) (string, error)

+ type TaskPlugin struct

+ Impl protobuf.TaskServer

+ Job protobuf.JobClient

+ func (t TaskPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, conn *grpc.ClientConn) (interface{}, error)

+ func (t TaskPlugin) GRPCServer(broker *plugin.GRPCBroker, server *grpc.Server) error