output

Documentation

Index

• type Config
  • func (c *Config) Validate() error
• type RawMessage
  • func (r *RawMessage) Unmarshal(v interface{}) error
  • func (r *RawMessage) UnmarshalYAML(unmarshal func(interface{}) error) error
• type Sink
  • func NewSink(name string, sinkType SinkType, config *RawMessage, log logrus.FieldLogger, ...) (Sink, error)
• type SinkType

Types

type Config

type Config struct {
	Name     string   `yaml:"name"`
	SinkType SinkType `yaml:"type"`

	Config *RawMessage `yaml:"config"`

	FilterConfig pxatu.EventFilterConfig `yaml:"filter"`

	ShippingMethod *processor.ShippingMethod `yaml:"shippingMethod"`
}

func (*Config) Validate

func (c *Config) Validate() error

type RawMessage

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

func (*RawMessage) Unmarshal

func (r *RawMessage) Unmarshal(v interface{}) error

func (*RawMessage) UnmarshalYAML

func (r *RawMessage) UnmarshalYAML(unmarshal func(interface{}) error) error

type Sink

type Sink interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	Type() string
	Name() string
	HandleNewDecoratedEvent(ctx context.Context, event *xatu.DecoratedEvent) error
	HandleNewDecoratedEvents(ctx context.Context, events []*xatu.DecoratedEvent) error
}

func NewSink

func NewSink(name string, sinkType SinkType, config *RawMessage, log logrus.FieldLogger, filterConfig pxatu.EventFilterConfig, shippingMethod processor.ShippingMethod) (Sink, error)

type SinkType

type SinkType string

const (
	SinkTypeUnknown SinkType = "unknown"
	SinkTypeHTTP    SinkType = http.SinkType
	SinkTypeStdOut  SinkType = stdout.SinkType
	SinkTypeXatu    SinkType = xatuSink.SinkType
	SinkTypeKafka   SinkType = kafka.SinkType
)