config

Documentation

Index

• Constants
• type SourceConfig
  • func ParseSourceConfig(ctx context.Context, cfg map[string]string) (SourceConfig, error)

Constants

const (
	// Marketo CDC polling period
	KeyPollingPeriod = "pollingPeriod"
	// KeySnapshotInitialDate is a date from which the snapshot iterator initially starts getting records.
	KeySnapshotInitialDate = "snapshotInitialDate"
	// Fields to retrieve from Marketo database
	KeyFields = "fields"
	// DefaultPollingPeriod is the value assumed for the pooling period when the
	// config omits the polling period parameter
	DefaultPollingPeriod = time.Minute
)

Types

type SourceConfig

type SourceConfig struct {
	config.Config
	PollingPeriod       time.Duration
	SnapshotInitialDate time.Time
	Fields              []string
}

SourceConfig represents source configuration with GCS configurations

func ParseSourceConfig

func ParseSourceConfig(ctx context.Context, cfg map[string]string) (SourceConfig, error)

ParseSourceConfig attempts to parse the configurations into a SourceConfig struct that Source could utilize