Documentation
¶
Index ¶
- Constants
- type Config
- type ItemExporter
- type StdOut
- 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 ¶
View Source
const SinkType = "stdout"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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
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 (*StdOut) HandleNewDecoratedEvents ¶
Source Files
Click to show internal directories.
Click to hide internal directories.