event_plugin

package
v0.36.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 5, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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{}

Jump to

Keyboard shortcuts

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