Versions in this module Expand all Collapse all v0 v0.14.0 Apr 20, 2026 Changes in this version + func New(logger log.Logger) plugins.Syncer + type Config struct + AccessKeyID string + BucketURL string + Endpoint string + ObjectPrefix string + Region string + SecretAccessKey string + type Sink struct + func (s *Sink) Close() error + func (s *Sink) Init(ctx context.Context, config plugins.Config) (err error) + func (s *Sink) Sink(ctx context.Context, batch []models.Record) (err error)
Go to main page