destination

package

v0.1.0 Latest Latest Go to latest Published: Apr 5, 2022 License: Apache-2.0 Imports: 7 Imported by: 1

Documentation ¶

This section is empty.

This section is empty.

func NewDestination() sdk.Destination

type Destination struct {
	sdk.UnimplementedDestination
	// contains filtered or unexported fields
}

func (d *Destination) Configure(ctx context.Context, cfg map[string]string) error

func (d *Destination) Flush(context.Context) error

func (d *Destination) Open(ctx context.Context) error

func (d *Destination) Teardown(ctx context.Context) error

func (d *Destination) Write(ctx context.Context, record sdk.Record) error