event_plugin

Documentation

Index

• type Actionresponse
• type ApplyArgs
• type ApplyResponse
• type EventProcessorPlugin
  • func (p *EventProcessorPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
  • func (p *EventProcessorPlugin) Server(*plugin.MuxBroker) (interface{}, error)
• type EventProcessorRPC
  • func (g *EventProcessorRPC) Apply(event ...*formatters.EventMsg) []*formatters.EventMsg
  • func (g *EventProcessorRPC) Init(cfg interface{}, opts ...formatters.Option) error
  • func (g *EventProcessorRPC) WithActions(act map[string]map[string]interface{})
  • func (g *EventProcessorRPC) WithLogger(l *log.Logger)
  • func (g *EventProcessorRPC) WithProcessors(procs map[string]map[string]any)
  • func (g *EventProcessorRPC) WithTargets(tcs map[string]*types.TargetConfig)
• type InitArgs
• type InitResponse
• type Proccessorresponse
• type Targetresponse

Types

type Actionresponse

type Actionresponse struct{}

type ApplyArgs

type ApplyArgs struct {
	Events []*formatters.EventMsg
}

type ApplyResponse

type ApplyResponse struct {
	Events []*formatters.EventMsg
}

type EventProcessorPlugin

type EventProcessorPlugin struct {
	Impl formatters.EventProcessor
}

func (*EventProcessorPlugin) Client

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

func (*EventProcessorPlugin) Server

func (p *EventProcessorPlugin) Server(*plugin.MuxBroker) (interface{}, error)

type EventProcessorRPC

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

func (*EventProcessorRPC) Apply

func (g *EventProcessorRPC) Apply(event ...*formatters.EventMsg) []*formatters.EventMsg

func (*EventProcessorRPC) Init

func (g *EventProcessorRPC) Init(cfg interface{}, opts ...formatters.Option) error

func (*EventProcessorRPC) WithActions

func (g *EventProcessorRPC) WithActions(act map[string]map[string]interface{})

func (*EventProcessorRPC) WithLogger

func (g *EventProcessorRPC) WithLogger(l *log.Logger)

func (*EventProcessorRPC) WithProcessors

func (g *EventProcessorRPC) WithProcessors(procs map[string]map[string]any)

func (*EventProcessorRPC) WithTargets

func (g *EventProcessorRPC) WithTargets(tcs map[string]*types.TargetConfig)

type InitArgs

type InitArgs struct {
	Cfg interface{}
}

type InitResponse

type InitResponse struct{}

type Proccessorresponse

type Proccessorresponse struct{}

type Targetresponse

type Targetresponse struct{}