plugin

Oct 27, 2024

Changes in this version

+ const ExecutorPluginName

+ const ProcessorPluginName

+ var Handshake = plugin.HandshakeConfig

+ var PluginMap = map[string]plugin.Plugin

+ func Serve(opts *ServeOpts)

+ type Broker interface

+ AcceptAndServe func(id uint32, s func([]grpc.ServerOption) *grpc.Server)

+ NextId func() uint32

+ type Config map[string]string

+ type Executor interface

+ Execute func(args *types.ExecuteRequest, cb StatusHelper) (*types.ExecuteResponse, error)

+ type ExecutorClient struct

+ func (m *ExecutorClient) Execute(args *types.ExecuteRequest, cb StatusHelper) (*types.ExecuteResponse, error)

+ type ExecutorPlugin struct

+ Executor Executor

+ func (p *ExecutorPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

+ func (p *ExecutorPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

+ type ExecutorPluginConfig map[string]string

+ type ExecutorServer struct

+ Impl Executor

+ func (m ExecutorServer) Execute(ctx context.Context, req *types.ExecuteRequest) (*types.ExecuteResponse, error)

+ type GRPCStatusHelperClient struct

+ func (m *GRPCStatusHelperClient) Update(b []byte, c bool) (int64, error)

+ type GRPCStatusHelperServer struct

+ Impl StatusHelper

+ func (m *GRPCStatusHelperServer) Update(ctx context.Context, req *types.StatusUpdateRequest) (resp *types.StatusUpdateResponse, err error)

+ type Processor interface

+ Process func(args *ProcessorArgs) types.Execution

+ type ProcessorArgs struct

+ Config Config

+ Execution types.Execution

+ type ProcessorClient struct

+ Broker *plugin.MuxBroker

+ Client *rpc.Client

+ func (e *ProcessorClient) Process(args *ProcessorArgs) types.Execution

+ type ProcessorPlugin struct

+ Processor Processor

+ func (p *ProcessorPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

+ func (p *ProcessorPlugin) Server(b *plugin.MuxBroker) (interface{}, error)

+ type ProcessorServer struct

+ Broker *plugin.MuxBroker

+ Processor Processor

+ func (e *ProcessorServer) Process(args *ProcessorArgs, resp *types.Execution) error

+ type ServeOpts struct

+ Executor Executor

+ Processor Processor

+ type StatusHelper interface

+ Update func([]byte, bool) (int64, error)