destination

Documentation

Index

• Constants
• func NewDestination() sdk.Destination
• type Config
  • func Parse(cfg map[string]string) (Config, error)
• type Destination
  • func (d *Destination) Configure(_ context.Context, cfg map[string]string) error
  • func (d *Destination) Open(context.Context) error
  • func (d *Destination) Parameters() map[string]sdk.Parameter
  • func (d *Destination) Teardown(context.Context) error
  • func (d *Destination) Write(_ context.Context, records []sdk.Record) (int, error)

Constants

const (
	// ConfigKeyRetryWait is a config name for a retry wait duration.
	ConfigKeyRetryWait = "retryWait"
	// ConfigKeyRetryAttempts is a config name for a retry attempts count.
	ConfigKeyRetryAttempts = "retryAttempts"
)

Functions

func NewDestination

func NewDestination() sdk.Destination

NewDestination creates new instance of the Destination.

Types

type Config

type Config struct {
	config.Config

	RetryWait     time.Duration `key:"retryWait"`
	RetryAttempts int           `key:"retryAttempts"`
}

Config holds destination specific configurable values.

func Parse

func Parse(cfg map[string]string) (Config, error)

Parse maps the incoming map to the Config and validates it.

type Destination

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

Destination NATS Connector persists records to a NATS subject or stream.

func (*Destination) Configure

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

Configure parses and initializes the config.

func (*Destination) Open

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

Open makes sure everything is prepared to receive records.

func (*Destination) Parameters

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

func (*Destination) Teardown

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

Teardown gracefully closes connections.

func (*Destination) Write

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

Write writes a record into a Destination.