Documentation ¶
Index ¶
- Constants
- Variables
- func NewDestination() sdk.Destination
- func NewSource() sdk.Source
- func Specification() sdk.Specification
- type Config
- type Destination
- func (d *Destination) Configure(ctx context.Context, cfg config.Config) error
- func (d *Destination) Open(context.Context) error
- func (d *Destination) Parameters() config.Parameters
- func (d *Destination) Teardown(context.Context) error
- func (d *Destination) Write(_ context.Context, recs []opencdc.Record) (int, error)
- type DestinationConfig
- type Source
- func (s *Source) Ack(context.Context, opencdc.Position) error
- func (s *Source) Configure(ctx context.Context, cfg config.Config) error
- func (s *Source) Open(ctx context.Context, position opencdc.Position) error
- func (s *Source) Parameters() config.Parameters
- func (s *Source) Read(ctx context.Context) (opencdc.Record, error)
- func (s *Source) Teardown(context.Context) error
- type SourceConfig
Constants ¶
View Source
const (
DestinationConfigPath = "path"
)
View Source
const MetadataFilePath = "file.path"
View Source
const (
SourceConfigPath = "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 Config ¶ added in v0.7.0
type Config struct { // Path is the file path used by the connector to read/write records. Path string `json:"path" validate:"required"` }
type Destination ¶
type Destination struct { sdk.UnimplementedDestination // contains filtered or unexported fields }
func (*Destination) Parameters ¶ added in v0.3.0
func (d *Destination) Parameters() config.Parameters
type DestinationConfig ¶ added in v0.7.0
type DestinationConfig struct {
Config // embed the global config
}
func (DestinationConfig) Parameters ¶ added in v0.7.0
func (DestinationConfig) Parameters() map[string]config.Parameter
func (DestinationConfig) Validate ¶ added in v0.7.0
func (c DestinationConfig) Validate() error
type Source ¶
type Source struct { sdk.UnimplementedSource // contains filtered or unexported fields }
func (*Source) Parameters ¶ added in v0.3.0
func (s *Source) Parameters() config.Parameters
type SourceConfig ¶ added in v0.7.0
type SourceConfig struct {
Config // embed the global config
}
func (SourceConfig) Parameters ¶ added in v0.7.0
func (SourceConfig) Parameters() map[string]config.Parameter
func (SourceConfig) Validate ¶ added in v0.7.0
func (c SourceConfig) Validate() error
Source Files ¶
Click to show internal directories.
Click to hide internal directories.