source

Documentation

Index

• Constants
• func NewSource() sdk.Source
• type Config
  • func (Config) Parameters() map[string]config.Parameter
  • func (c Config) Validate(ctx context.Context) (Config, error)
• type Source
  • func (s *Source) Ack(ctx context.Context, pos opencdc.Position) error
  • func (s *Source) Configure(ctx context.Context, cfg config.Config) error
  • func (s *Source) Open(ctx context.Context, sdkPos opencdc.Position) error
  • func (s *Source) Parameters() config.Parameters
  • func (s *Source) Read(ctx context.Context) (rec opencdc.Record, err error)
  • func (s *Source) Teardown(ctx context.Context) error

Constants

const (
	ConfigClientID           = "clientID"
	ConfigClientSecret       = "clientSecret"
	ConfigInsecureSkipVerify = "insecureSkipVerify"
	ConfigOauthEndpoint      = "oauthEndpoint"
	ConfigPollingPeriod      = "pollingPeriod"
	ConfigPubsubAddress      = "pubsubAddress"
	ConfigReplayPreset       = "replayPreset"
	ConfigRetryCount         = "retryCount"
	ConfigTopicName          = "topicName"
	ConfigTopicNames         = "topicNames"
)

Functions

func NewSource

func NewSource() sdk.Source

Types

type Config

type Config struct {
	config.Config

	// Deprecated: use `topicNames` instead.
	TopicName string `json:"topicName"`

	// TopicNames are the TopicNames the source connector will subscribe to
	TopicNames []string `json:"topicNames"`

	// PollingPeriod is the client event polling interval
	PollingPeriod time.Duration `json:"pollingPeriod" default:"100ms"`

	// Replay preset for the position the connector is fetching events from, can be latest or default to earliest.
	ReplayPreset string `json:"replayPreset" default:"earliest" validate:"inclusion=latest|earliest"`
}

func (Config) Parameters

func (Config) Parameters() map[string]config.Parameter

func (Config) Validate

func (c Config) Validate(ctx context.Context) (Config, error)

type Source

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

func (*Source) Ack

func (s *Source) Ack(ctx context.Context, pos opencdc.Position) error

func (*Source) Configure

func (s *Source) Configure(ctx context.Context, cfg config.Config) error

func (*Source) Open

func (s *Source) Open(ctx context.Context, sdkPos opencdc.Position) error

func (*Source) Parameters

func (s *Source) Parameters() config.Parameters

func (*Source) Read

func (s *Source) Read(ctx context.Context) (rec opencdc.Record, err error)

func (*Source) Teardown

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