Documentation ¶
Index ¶
- func NewSource() sdk.Source
- type Source
- func (s *Source) Ack(ctx context.Context, rp sdk.Position) error
- func (s *Source) Configure(ctx context.Context, cfgRaw map[string]string) error
- func (s *Source) Open(ctx context.Context, rp sdk.Position) error
- func (s *Source) Read(ctx context.Context) (sdk.Record, error)
- func (s *Source) Teardown(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Source ¶
type Source struct { sdk.UnimplementedSource // contains filtered or unexported fields }
A Source represents the source connector.
func (*Source) Configure ¶
Configure parses and stores configurations, returns an error in case of invalid configuration.
Click to show internal directories.
Click to hide internal directories.