plugins

package

v0.0.0-...-fa1d311 Latest Latest Go to latest Published: May 16, 2024 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/sandrolain/event-runner

Links

Open Source Insights

Documentation ¶

Index ¶

func GetFreePort() (port int, err error)
func NewEventPlugins(plugins []*Plugin) itf.EventPlugins
type AppServiceServer
- func (s *AppServiceServer) Input(ctx context.Context, in *proto.InputReq) (res *proto.InputRes, err error)
- func (s *AppServiceServer) Result(ctx context.Context, in *proto.ResultReq) (res *proto.ResultRes, err error)
type EventPlugin
type EventPlugins
- func (p *EventPlugins) GetPlugin(id string) (res itf.EventPlugin, err error)
type Plugin
- func (p *Plugin) Start() (err error)
- func (p *Plugin) Stop()
type PluginCommandResult
type PluginInput
- func (p *PluginInput) GetInput() *proto.InputRes
- func (p *PluginInput) GetTime() time.Time
type PluginManager
- func NewPluginManager() (res *PluginManager, err error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetFreePort ¶

func GetFreePort() (port int, err error)

func NewEventPlugins ¶

func NewEventPlugins(plugins []*Plugin) itf.EventPlugins

Types ¶

type AppServiceServer ¶

type AppServiceServer struct {
	proto.UnimplementedAppServiceServer
}

implement structure for grpc server for AppService

func (*AppServiceServer) Input ¶

func (s *AppServiceServer) Input(ctx context.Context, in *proto.InputReq) (res *proto.InputRes, err error)

Input

func (*AppServiceServer) Result ¶

func (s *AppServiceServer) Result(ctx context.Context, in *proto.ResultReq) (res *proto.ResultRes, err error)

Result

type EventPlugin ¶

type EventPlugin struct {
	// contains filtered or unexported fields
}

func (*EventPlugin) Command ¶

func (p *EventPlugin) Command(name string, data any) (res itf.PluginCommandResult, err error)

func (*EventPlugin) Input ¶

func (p *EventPlugin) Input(buffer int, config map[string]string) (res <-chan itf.PluginInput, err error)

func (*EventPlugin) Output ¶

func (p *EventPlugin) Output(uuid string, topic string, data []byte, metadata map[string][]string) (err error)

type EventPlugins ¶

type EventPlugins struct {
	// contains filtered or unexported fields
}

func (*EventPlugins) GetPlugin ¶

func (p *EventPlugins) GetPlugin(id string) (res itf.EventPlugin, err error)

type Plugin ¶

type Plugin struct {
	AppPort int
	ID      string
	Host    string
	Port    int
	Exec    string
	Name    string
	Args    []string
	Env     []string
	Config  config.Plugin
	Output  bool

	ConnRetry int
	ConnDelay time.Duration
	// contains filtered or unexported fields
}

func (*Plugin) Start ¶

func (p *Plugin) Start() (err error)

func (*Plugin) Stop ¶

func (p *Plugin) Stop()

type PluginCommandResult ¶

type PluginCommandResult struct {
	// contains filtered or unexported fields
}

func (*PluginCommandResult) GetCommand ¶

func (r *PluginCommandResult) GetCommand() string

func (*PluginCommandResult) GetData ¶

func (r *PluginCommandResult) GetData() (any, error)

func (*PluginCommandResult) GetUUID ¶

func (r *PluginCommandResult) GetUUID() string

func (*PluginCommandResult) IsAsync ¶

func (r *PluginCommandResult) IsAsync() bool

type PluginInput ¶

type PluginInput struct {
	// contains filtered or unexported fields
}

func (*PluginInput) GetInput ¶

func (p *PluginInput) GetInput() *proto.InputRes

func (*PluginInput) GetTime ¶

func (p *PluginInput) GetTime() time.Time

type PluginManager ¶

type PluginManager struct {
	// contains filtered or unexported fields
}

func NewPluginManager ¶

func NewPluginManager() (res *PluginManager, err error)

func (*PluginManager) CreatePlugin ¶

func (p *PluginManager) CreatePlugin(cfg config.Plugin) (res *Plugin, err error)

func (*PluginManager) GetPlugin ¶

func (p *PluginManager) GetPlugin(id string) (res *Plugin, err error)

func (*PluginManager) Start ¶

func (p *PluginManager) Start() (err error)

func (*PluginManager) Stop ¶

func (p *PluginManager) Stop() (err error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL