output

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"`
}

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

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
}

type SinkType string