config

Documentation

Index

• type CommitStrategy
  • func ParseStrategyString(strategy string) (CommitStrategy, error)
  • func (s CommitStrategy) String() string
• type IngestorConfig

Types

type CommitStrategy

type CommitStrategy int

CommitStrategy describes how the ingestor should handle the ingested data Single Transaction or Commit on Each Batch

const (
	CommitOnEnd CommitStrategy = iota + 1
	CommitOnEachBatch
)

Available values for the CommitStrategy enum

func ParseStrategyString

func ParseStrategyString(strategy string) (CommitStrategy, error)

ParseStrategyString returns the enum value matching the string, or an error

func (CommitStrategy) String

func (s CommitStrategy) String() string

type IngestorConfig

type IngestorConfig struct {
	IngestorID              string
	BatchSize               uint16
	RollbackOnExternalError bool
	CommitStrategy          CommitStrategy
	SchemaStrategy          schemaconfig.SchemaStrategy
	Schema                  string
	ChunkTimeInterval       string
}

IngestorConfig holds all the properties required to create and run an ingestor