Documentation ¶
Index ¶
- Constants
- Variables
- func NewDestination() sdk.Destination
- func NewSource() sdk.Source
- func Specification() sdk.Specification
- type Destination
- func (d *Destination) Configure(ctx context.Context, m map[string]string) error
- func (d *Destination) Open(ctx context.Context) error
- func (d *Destination) Parameters() map[string]sdk.Parameter
- func (d *Destination) Teardown(ctx context.Context) error
- func (d *Destination) Write(ctx context.Context, recs []sdk.Record) (int, error)
- type Source
- func (s *Source) Ack(ctx context.Context, position sdk.Position) error
- func (s *Source) Configure(ctx context.Context, m map[string]string) error
- func (s *Source) Open(ctx context.Context, position sdk.Position) error
- func (s *Source) Parameters() map[string]sdk.Parameter
- func (s *Source) Read(ctx context.Context) (sdk.Record, error)
- func (s *Source) Teardown(ctx context.Context) error
Constants ¶
View Source
const (
// ConfigPath is the config name for the path to the file.
ConfigPath = "path"
)
View Source
const MetadataFilePath = "file.path"
Variables ¶
View Source
var Connector = sdk.Connector{ NewSpecification: Specification, NewSource: NewSource, NewDestination: NewDestination, }
Functions ¶
func NewDestination ¶
func NewDestination() sdk.Destination
func Specification ¶
func Specification() sdk.Specification
Specification returns the connector's specification.
Types ¶
type Destination ¶
type Destination struct { sdk.UnimplementedDestination // contains filtered or unexported fields }
Destination connector
func (*Destination) Parameters ¶ added in v0.3.0
func (d *Destination) Parameters() map[string]sdk.Parameter
Click to show internal directories.
Click to hide internal directories.