validator

Documentation

Index

• func Canonizator(t *testing.T, ...) func() abstract.Sinker
• func InitDone(t *testing.T) func() abstract.Sinker
• func New(isStrictSource bool, factories ...func() abstract.Sinker) func() abstract.Sinker
• func Referencer(t *testing.T, ...) func() abstract.Sinker
• func RemoveVariableFieldsRowMiddleware(items []abstract.ChangeItem) []abstract.ChangeItem
• func Sequencer(t *testing.T, ...) (middleware func() abstract.Sinker, dumpCallback func())
• func TypesystemChecker(provider abstract.ProviderType, ...) func() abstract.Sinker
• func ValuesTypeChecker() abstract.Sinker
• type Aggregator
  • func (c *Aggregator) Close() error
  • func (c *Aggregator) Commit() error
  • func (c *Aggregator) Push(items []abstract.ChangeItem) error
• type CanonizatorSink
  • func (c *CanonizatorSink) Close() error
  • func (c *CanonizatorSink) Commit() error
  • func (c *CanonizatorSink) Push(items []abstract.ChangeItem) error
• type Container
• type Counter
  • func NewCounter() (*Counter, func() abstract.Sinker)
  • func (c *Counter) Close()
  • func (c *Counter) EstimateTableRowsCount(table abstract.TableID) (uint64, error)
  • func (c *Counter) ExactTableRowsCount(table abstract.TableID) (uint64, error)
  • func (c *Counter) GetSum() uint64
  • func (c *Counter) LoadTable(ctx context.Context, table abstract.TableDescription, pusher abstract.Pusher) error
  • func (c *Counter) Ping() error
  • func (c *Counter) TableExists(table abstract.TableID) (bool, error)
  • func (c *Counter) TableList(filter abstract.IncludeTableList) (abstract.TableMap, error)
  • func (c *Counter) TableSchema(ctx context.Context, table abstract.TableID) (*abstract.TableSchema, error)
  • func (c *Counter) Truncate(tableID abstract.TableID)
• type CounterSink
  • func (c *CounterSink) Close() error
  • func (c *CounterSink) Push(items []abstract.ChangeItem) error
• type ReferenceRow
• type ReferenceTable
• type ReferencerSink
  • func (c *ReferencerSink) AsReferenceRow(row abstract.ChangeItem) ReferenceRow
  • func (c *ReferencerSink) Close() error
  • func (c *ReferencerSink) Push(items []abstract.ChangeItem) error
• type TypesystemCheckerSink
  • func (t TypesystemCheckerSink) Close() error
  • func (t TypesystemCheckerSink) Push(items []abstract.ChangeItem) error
• type ValuesTypeCheckerSink
  • func (t ValuesTypeCheckerSink) Close() error
  • func (t ValuesTypeCheckerSink) Push(items []abstract.ChangeItem) error

Functions

func Canonizator

func Canonizator(
	t *testing.T,
	changeItemMiddlewares ...func(item []abstract.ChangeItem) []abstract.ChangeItem,
) func() abstract.Sinker

func InitDone

func InitDone(t *testing.T) func() abstract.Sinker

func New

func New(isStrictSource bool, factories ...func() abstract.Sinker) func() abstract.Sinker

func Referencer

func Referencer(
	t *testing.T,
	changeItemMiddlewares ...func(item []abstract.ChangeItem) []abstract.ChangeItem,
) func() abstract.Sinker

func RemoveVariableFieldsRowMiddleware

func RemoveVariableFieldsRowMiddleware(items []abstract.ChangeItem) []abstract.ChangeItem

func Sequencer

func Sequencer(t *testing.T, rowMiddlewares ...func([]abstract.ChangeItem) []abstract.ChangeItem) (middleware func() abstract.Sinker, dumpCallback func())

func TypesystemChecker

func TypesystemChecker(provider abstract.ProviderType, originalTypeParser func(colSchema abstract.ColSchema) string) func() abstract.Sinker

func ValuesTypeChecker

func ValuesTypeChecker() abstract.Sinker

Types

type Aggregator

type Aggregator struct {
	// contains filtered or unexported fields
}

func (*Aggregator) Close

func (c *Aggregator) Close() error

func (*Aggregator) Commit

func (c *Aggregator) Commit() error

func (*Aggregator) Push

func (c *Aggregator) Push(items []abstract.ChangeItem) error

type CanonizatorSink

type CanonizatorSink struct {
	// contains filtered or unexported fields
}

func (*CanonizatorSink) Close

func (c *CanonizatorSink) Close() error

func (*CanonizatorSink) Commit

func (c *CanonizatorSink) Commit() error

func (*CanonizatorSink) Push

func (c *CanonizatorSink) Push(items []abstract.ChangeItem) error

type Container

type Container struct {
	GoType string
	Val    interface{}
}

type Counter

type Counter struct {
	// contains filtered or unexported fields
}

func NewCounter

func NewCounter() (*Counter, func() abstract.Sinker)

func (*Counter) Close

func (c *Counter) Close()

func (*Counter) EstimateTableRowsCount

func (c *Counter) EstimateTableRowsCount(table abstract.TableID) (uint64, error)

func (*Counter) ExactTableRowsCount

func (c *Counter) ExactTableRowsCount(table abstract.TableID) (uint64, error)

func (*Counter) GetSum

func (c *Counter) GetSum() uint64

func (*Counter) LoadTable

func (c *Counter) LoadTable(ctx context.Context, table abstract.TableDescription, pusher abstract.Pusher) error

func (*Counter) Ping

func (c *Counter) Ping() error

func (*Counter) TableExists

func (c *Counter) TableExists(table abstract.TableID) (bool, error)

func (*Counter) TableList

func (c *Counter) TableList(filter abstract.IncludeTableList) (abstract.TableMap, error)

func (*Counter) TableSchema

func (c *Counter) TableSchema(ctx context.Context, table abstract.TableID) (*abstract.TableSchema, error)

func (*Counter) Truncate

func (c *Counter) Truncate(tableID abstract.TableID)

type CounterSink

type CounterSink struct {
	// contains filtered or unexported fields
}

func (*CounterSink) Close

func (c *CounterSink) Close() error

func (*CounterSink) Push

func (c *CounterSink) Push(items []abstract.ChangeItem) error

type ReferenceRow

type ReferenceRow struct {
	Data map[string]Container
}

type ReferenceTable

type ReferenceTable struct {
	TableID     abstract.TableID
	Rows        []ReferenceRow
	TableSchema abstract.TableColumns
}

type ReferencerSink

type ReferencerSink struct {
	// contains filtered or unexported fields
}

func (*ReferencerSink) AsReferenceRow

func (c *ReferencerSink) AsReferenceRow(row abstract.ChangeItem) ReferenceRow

func (*ReferencerSink) Close

func (c *ReferencerSink) Close() error

func (*ReferencerSink) Push

func (c *ReferencerSink) Push(items []abstract.ChangeItem) error

type TypesystemCheckerSink

type TypesystemCheckerSink struct {
	// contains filtered or unexported fields
}

func (TypesystemCheckerSink) Close

func (t TypesystemCheckerSink) Close() error

func (TypesystemCheckerSink) Push

func (t TypesystemCheckerSink) Push(items []abstract.ChangeItem) error

type ValuesTypeCheckerSink

type ValuesTypeCheckerSink struct {
	// contains filtered or unexported fields
}

func (ValuesTypeCheckerSink) Close

func (t ValuesTypeCheckerSink) Close() error

func (ValuesTypeCheckerSink) Push

func (t ValuesTypeCheckerSink) Push(items []abstract.ChangeItem) error