database

Documentation

Index

• type CompletionHandler
• type DBCommand
• type Writer

Types

type CompletionHandler

type CompletionHandler func(DBCommand)

type DBCommand

type DBCommand interface {
	GetReference() interface{}
	GetPipelineID() uint64
	GetSequence() uint64
	GetTables() []string
}

type Writer

type Writer interface {
	Init() error
	ProcessData(interface{}, *gravity_sdk_types_record.Record, []string) error
	SetCompletionHandler(CompletionHandler)
	Truncate(string) error
}