Documentation
¶
Index ¶
- func NewDestination() sdk.Destination
- 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, rec []sdk.Record) (int, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDestination ¶
func NewDestination() sdk.Destination
NewDestination returns an instance of sdk.Destination
Types ¶
type Destination ¶
type Destination struct {
sdk.UnimplementedDestination
// contains filtered or unexported fields
}
func (*Destination) Configure ¶
Configure sets up the destination by validating and parsing the config
func (*Destination) Open ¶
func (d *Destination) Open(ctx context.Context) error
Open creates a connection to redis and validates the type to key using Type <key> command
func (*Destination) Parameters ¶
func (d *Destination) Parameters() map[string]sdk.Parameter
Parameters returns a map of named Parameters that describe how to configure the Source.
func (*Destination) Teardown ¶
func (d *Destination) Teardown(_ context.Context) error
Teardown is called by conduit server to stop the destination connector the graceful shutdown is performed in this function
Source Files
Click to show internal directories.
Click to hide internal directories.