source

package

v0.3.0 Latest Latest Go to latest Published: Sep 27, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func NewSource() sdk.Source

NewSource returns an instance of sdk.Source

type Iterator interface {
	HasNext() bool
	Next(ctx context.Context) (sdk.Record, error)
	Stop() error
}

type Source struct {
	sdk.UnimplementedSource
	// contains filtered or unexported fields
}

func (s *Source) Ack(ctx context.Context, position sdk.Position) error

Ack is called by the conduit server after the record has been successfully processed by all destination connectors

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

Configure validates the passed config and prepares the source connector

func (s *Source) Open(ctx context.Context, position sdk.Position) error

Open prepare the plugin to start reading records from the given position

func (s *Source) Parameters() map[string]sdk.Parameter

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

func (s *Source) Read(ctx context.Context) (sdk.Record, error)

Read gets the next object

func (s *Source) Teardown(_ context.Context) error

Teardown is called by the conduit server to stop the source connector all the cleanup should be done in this function

Path	Synopsis
iterator
mocks