Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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"`
}
type RawMessage ¶
type RawMessage struct {
// contains filtered or unexported fields
}
func (*RawMessage) Unmarshal ¶
func (r *RawMessage) Unmarshal(v any) error
func (*RawMessage) UnmarshalYAML ¶
func (r *RawMessage) UnmarshalYAML(unmarshal func(any) 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 observability.ContextualLogger, 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 SinkTypeClickhouse SinkType = chSink.SinkType SinkTypeS3BlobStore SinkType = s3blobstore.SinkType )
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package clickhouse implements an output sink that writes DecoratedEvents directly to ClickHouse using the shared writer + router stack from pkg/clickhouse.
|
Package clickhouse implements an output sink that writes DecoratedEvents directly to ClickHouse using the shared writer + router stack from pkg/clickhouse. |
|
internal
|
|
|
s3
Package s3 wraps an S3-compatible object store client (AWS S3, Cloudflare R2, MinIO, etc.) with the minimal surface needed by xatu output sinks: connect, PutObject.
|
Package s3 wraps an S3-compatible object store client (AWS S3, Cloudflare R2, MinIO, etc.) with the minimal surface needed by xatu output sinks: connect, PutObject. |
|
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
|
Package s3blobstore implements an output sink that archives beacon blob sidecars to an S3-compatible object store (Cloudflare R2, AWS S3, MinIO).
|
Package s3blobstore implements an output sink that archives beacon blob sidecars to an S3-compatible object store (Cloudflare R2, AWS S3, MinIO). |
Click to show internal directories.
Click to hide internal directories.