elastic

Documentation

Index

• func New(c *config.Config) (pipeline.Processor, error)
• func NewActivityProcessor(c *config.Config) (pipeline.Processor, error)
• type ActivityProcessor
  • func (processor *ActivityProcessor) HandleActivity(activityByte []byte) error
  • func (processor *ActivityProcessor) Name() string
  • func (processor *ActivityProcessor) Process(ctx *pipeline.Context) error
• type Config
• type MetadataProcessor
  • func (processor *MetadataProcessor) HandleIndexHealthChange(ev *event.Event) error
  • func (processor *MetadataProcessor) HandleIndexStateChange(indexState []byte) error
  • func (processor *MetadataProcessor) HandleUnknownNodeStatus(ev []byte) error
  • func (processor *MetadataProcessor) Name() string
  • func (processor *MetadataProcessor) Process(ctx *pipeline.Context) error

Functions

func New

func New(c *config.Config) (pipeline.Processor, error)

func NewActivityProcessor

func NewActivityProcessor(c *config.Config) (pipeline.Processor, error)

Types

type ActivityProcessor

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

func (*ActivityProcessor) HandleActivity

func (processor *ActivityProcessor) HandleActivity(activityByte []byte) error

func (*ActivityProcessor) Name

func (processor *ActivityProcessor) Name() string

func (*ActivityProcessor) Process

func (processor *ActivityProcessor) Process(ctx *pipeline.Context) error

type Config

type Config struct {
	MessageField  param.ParaKey `config:"message_field"`
	Elasticsearch string        `config:"elasticsearch,omitempty"`
}

type MetadataProcessor

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

func (*MetadataProcessor) HandleIndexHealthChange

func (processor *MetadataProcessor) HandleIndexHealthChange(ev *event.Event) error

func (*MetadataProcessor) HandleIndexStateChange

func (processor *MetadataProcessor) HandleIndexStateChange(indexState []byte) error

func (*MetadataProcessor) HandleUnknownNodeStatus

func (processor *MetadataProcessor) HandleUnknownNodeStatus(ev []byte) error

func (*MetadataProcessor) Name

func (processor *MetadataProcessor) Name() string

func (*MetadataProcessor) Process

func (processor *MetadataProcessor) Process(ctx *pipeline.Context) error