destination

package

v0.3.0 Latest Latest Go to latest Published: Sep 27, 2022 License: Apache-2.0 Imports: 7 Imported by: 1

Documentation ¶

Index ¶

Constants
func NewDestination() sdk.Destination
type Destination

Constants ¶

const (
	ConfigURL   = "url"
	ConfigTable = "table"
	ConfigKey   = "key"

	// TODO same constant is defined in packages longpoll, logrepl and destination
	//  use same constant everywhere
	MetadataPostgresTable = "postgres.table"
)

Variables ¶

This section is empty.

Functions ¶

func NewDestination ¶

func NewDestination() sdk.Destination

Types ¶

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 ¶ added in v0.3.0

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

func (*Destination) Teardown ¶

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

func (*Destination) Write ¶

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

Write routes incoming records to their appropriate handler based on the operation.

Source Files ¶

View all Source files

destination.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL