destination

Documentation

Index

• type Destination
  • func (s *Destination) Open(ctx context.Context, cfg plugins.Config) error
  • func (s *Destination) Teardown() error
  • func (s *Destination) Validate(cfg plugins.Config) error
  • func (s *Destination) Write(ctx context.Context, r record.Record) (record.Position, error)

Types

type Destination

type Destination struct {
	Position record.Position
	// contains filtered or unexported fields
}

Destination fulfills the Destination interface

func (*Destination) Open

func (s *Destination) Open(ctx context.Context, cfg plugins.Config) error

Open attempts to open a database connection to Postgres.

func (*Destination) Teardown

func (s *Destination) Teardown() error

Teardown will attempt to gracefully close the database connection.

func (*Destination) Validate

func (s *Destination) Validate(cfg plugins.Config) error

Validate will validate a configuration.

func (*Destination) Write

func (s *Destination) Write(ctx context.Context, r record.Record) (record.Position, error)

Write will write the record to the Destination and then returns the written Position or an error.