processor

Documentation

Index

• Constants
• func NewMySQLImplementation(input *config.Input, target *config.Target, verboseMode bool, ...) (*mySQLImplementation, error)
• func NewRedisImplementation(input *config.Input, target *config.Target, verboseMode bool) (*redisImplementation, error)
• type Function
• type Implementation
• type Processor
  • func NewProcessor(cfg *config.Config, id string, procHook hook.ProcessorHook) (processor Processor, err error)
  • func (proc *Processor) Close()
  • func (proc *Processor) DryRun(data [][]string) error
  • func (proc *Processor) Process(data [][]string, index int) error
• type ProcessorType

Constants

const (
	KeyColumn   = "key"
	ValueColumn = "value"
	TTLColumn   = "ttl"
)

const NullExpr = "NULL"

Functions

func NewMySQLImplementation

func NewMySQLImplementation(input *config.Input, target *config.Target, verboseMode bool, procHook hook.ProcessorHook) (*mySQLImplementation, error)

func NewRedisImplementation

func NewRedisImplementation(input *config.Input, target *config.Target, verboseMode bool) (*redisImplementation, error)

Types

type Function

type Function string

const (
	NilValue         Function = "NIL"
	CurrentTimestamp Function = "CURRENT_TIMESTAMP"
)

supported functions

type Implementation

type Implementation interface {
	Process(data [][]string) error
	DryRun(data [][]string) error
	Close()
}

type Processor

type Processor struct {
	ID string
	// contains filtered or unexported fields
}

func NewProcessor

func NewProcessor(cfg *config.Config, id string, procHook hook.ProcessorHook) (processor Processor, err error)

func (*Processor) Close

func (proc *Processor) Close()

func (*Processor) DryRun

func (proc *Processor) DryRun(data [][]string) error

func (*Processor) Process

func (proc *Processor) Process(data [][]string, index int) error

type ProcessorType

type ProcessorType string

const (
	ProcessorTypeMySQL ProcessorType = "mysql"
	ProcessorTypeRedis ProcessorType = "redis"
)

supported types