stdout

Documentation

Index

• Constants
• type Config
  • func (c *Config) Validate() error
• type ItemExporter
  • func NewItemExporter(name string, config *Config, log logrus.FieldLogger) (ItemExporter, error)
  • func (e ItemExporter) ExportItems(ctx context.Context, items []*xatu.DecoratedEvent) error
  • func (e ItemExporter) Shutdown(ctx context.Context) error
• type StdOut
  • func New(name string, config *Config, log logrus.FieldLogger, ...) (*StdOut, error)
  • func (h *StdOut) HandleNewDecoratedEvent(ctx context.Context, event *xatu.DecoratedEvent) error
  • func (h *StdOut) HandleNewDecoratedEvents(ctx context.Context, events []*xatu.DecoratedEvent) error
  • func (h *StdOut) Name() string
  • func (h *StdOut) Start(ctx context.Context) error
  • func (h *StdOut) Stop(ctx context.Context) error
  • func (h *StdOut) Type() string

Constants

const SinkType = "stdout"

Types

type Config

type Config struct {
	LoggingLevel string `yaml:"logging" default:"info"`
}

func (*Config) Validate

func (c *Config) Validate() error

type ItemExporter

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

func NewItemExporter

func NewItemExporter(name string, config *Config, log logrus.FieldLogger) (ItemExporter, error)

func (ItemExporter) ExportItems

func (e ItemExporter) ExportItems(ctx context.Context, items []*xatu.DecoratedEvent) error

func (ItemExporter) Shutdown

func (e ItemExporter) Shutdown(ctx context.Context) error

type StdOut

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

func New

func New(name string, config *Config, log logrus.FieldLogger, filterConfig *xatu.EventFilterConfig, shippingMethod processor.ShippingMethod) (*StdOut, error)

func (*StdOut) HandleNewDecoratedEvent

func (h *StdOut) HandleNewDecoratedEvent(ctx context.Context, event *xatu.DecoratedEvent) error

func (*StdOut) HandleNewDecoratedEvents

func (h *StdOut) HandleNewDecoratedEvents(ctx context.Context, events []*xatu.DecoratedEvent) error

func (*StdOut) Name

func (h *StdOut) Name() string

func (*StdOut) Start

func (h *StdOut) Start(ctx context.Context) error

func (*StdOut) Stop

func (h *StdOut) Stop(ctx context.Context) error

func (*StdOut) Type

func (h *StdOut) Type() string