Documentation ¶
Index ¶
- Constants
- func NewDestination() sdk.Destination
- type Config
- type Destination
- func (d *Destination) Configure(_ context.Context, cfg map[string]string) error
- func (d *Destination) Open(ctx context.Context) error
- func (d *Destination) Parameters() map[string]sdk.Parameter
- func (d *Destination) Teardown(_ context.Context) error
- func (d *Destination) Write(ctx context.Context, records []sdk.Record) (int, error)
Constants ¶
View Source
const (
// ConfigKeyFormat is the config name for destination format.
ConfigKeyFormat = "format"
)
Variables ¶
This section is empty.
Functions ¶
func NewDestination ¶
func NewDestination() sdk.Destination
Types ¶
type Config ¶
type Config struct { config.Config // the destination format, either "json" or "parquet". Format format.Format `validate:"required,inclusion=parquet|json"` }
Config represents S3 configuration with Destination specific configurations
type Destination ¶
type Destination struct { sdk.UnimplementedDestination Config Config Writer writer.Writer }
Destination S3 Connector persists records to an S3 storage. The records are usually buffered and written in batches for performance reasons. The buffer size is determined by config.
func (*Destination) Open ¶
func (d *Destination) Open(ctx context.Context) error
Open makes sure everything is prepared to receive records.
func (*Destination) Parameters ¶ added in v0.3.0
func (d *Destination) Parameters() map[string]sdk.Parameter
Click to show internal directories.
Click to hide internal directories.