store

type ClusterObserver struct {
	Logger      *stmtlogger.Logger
	AppLogger   *zap.Logger
	ClusterName stmtlogger.Type
}

type Config struct {
	OracleClusterConfig     *ScyllaClusterConfig
	OracleStatementFile     string
	TestStatementFile       string
	TestClusterConfig       ScyllaClusterConfig
	MaxRetriesMutate        int
	MaxRetriesMutateSleep   time.Duration
	Compression             stmtlogger.Compression
	UseServerSideTimestamps bool
}

type ErrorRowDifference struct {
	OracleRow       Row
	TestRow         Row
	Diff            string
	MissingInTest   []string
	MissingInOracle []string
	TestRows        int
	OracleRows      int
}

type Row map[string]any

type Rows []Row

type ScyllaClusterConfig struct {
	Name                    stmtlogger.Type
	HostSelectionPolicy     string
	Consistency             string
	Username                string
	Password                string
	Hosts                   []string
	RequestTimeout          time.Duration
	ConnectTimeout          time.Duration
	UseServerSideTimestamps bool
}

type Store interface {
	io.Closer

	Create(context.Context, *typedef.Stmt, *typedef.Stmt) error
	Mutate(context.Context, *typedef.Stmt) error
	Check(context.Context, *typedef.Table, *typedef.Stmt, bool) error
}