destination

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 17, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDestination 

func NewDestination() sdk.Destination

NewDestination initialises a new Destination.

Types

type Destination 

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

Destination is a Clickhouse destination plugin.

func (*Destination) Configure 

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

Configure parses and stores configurations, returns an error in case of invalid configuration.

func (*Destination) Open 

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

Open initializes a publisher client.

func (*Destination) Parameters 

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

Parameters returns a map of named Parameters that describe how to configure the SourceConfig.

func (*Destination) Teardown 

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

Teardown gracefully closes connections.

func (*Destination) Write 

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

Write writes records into a Destination.

type Writer 

type Writer interface {
	Insert(context.Context, sdk.Record) error
	Update(context.Context, sdk.Record) error
	Delete(context.Context, sdk.Record) error
}

Writer defines a writer interface needed for the Destination.

Source Files

View all Source files

Directories

Path Synopsis
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.