Documentation
¶
Index ¶
- Constants
- type Config
- type ItemExporter
- type KeepAliveConfig
- type RetryConfig
- type Xatu
- func (h *Xatu) HandleNewDecoratedEvent(ctx context.Context, event *xatu.DecoratedEvent) error
- func (h *Xatu) HandleNewDecoratedEvents(ctx context.Context, events []*xatu.DecoratedEvent) error
- func (h *Xatu) Name() string
- func (h *Xatu) SetAuthorization(val string)
- func (h *Xatu) Start(ctx context.Context) error
- func (h *Xatu) Stop(ctx context.Context) error
- func (h *Xatu) Type() string
Constants ¶
View Source
const SinkType = "xatu"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Address string `yaml:"address"`
Headers map[string]string `yaml:"headers"`
TLS bool `yaml:"tls" default:"false"`
MaxQueueSize int `yaml:"maxQueueSize" default:"51200"`
BatchTimeout time.Duration `yaml:"batchTimeout" default:"5s"`
ExportTimeout time.Duration `yaml:"exportTimeout" default:"30s"`
MaxExportBatchSize int `yaml:"maxExportBatchSize" default:"512"`
Workers int `yaml:"workers" default:"1"`
Retry RetryConfig `yaml:"retry"`
KeepAlive KeepAliveConfig `yaml:"keepAlive"`
}
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 []*pb.DecoratedEvent) error
type KeepAliveConfig ¶ added in v0.0.198
type RetryConfig ¶ added in v0.0.158
type Xatu ¶
type Xatu struct {
// contains filtered or unexported fields
}
func New ¶
func New(name string, config *Config, log logrus.FieldLogger, filterConfig *xatu.EventFilterConfig, shippingMethod processor.ShippingMethod) (*Xatu, error)
func (*Xatu) HandleNewDecoratedEvent ¶
func (*Xatu) HandleNewDecoratedEvents ¶
func (*Xatu) SetAuthorization ¶ added in v0.0.200
Click to show internal directories.
Click to hide internal directories.