destination

Documentation

Index

• Constants
• func NewDestination() sdk.Destination
• type Config
  • func (Config) Parameters() map[string]sdk.Parameter
• type Destination
  • func (d *Destination) Configure(ctx 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

const (
	ConfigKeyAWSSQSDelayTime = "aws.delayTime"
)

Functions

func NewDestination

func NewDestination() sdk.Destination

Types

type Config

type Config struct {
	common.Config
	// amazon sqs message delay time
	AWSSQSMessageDelay int32 `json:"aws.delayTime" default:"0"`
}

func (Config) Parameters

func (Config) Parameters() map[string]sdk.Parameter

type Destination

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

func (*Destination) Configure

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

func (*Destination) Open

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

func (*Destination) Parameters

func (d *Destination) Parameters() map[string]sdk.Parameter

func (*Destination) Teardown

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

func (*Destination) Write

func (d *Destination) Write(ctx context.Context, records []sdk.Record) (int, error)