store

Documentation

Index

• type Config
• type Store
  • func New(schema *typedef.Schema, testCluster, oracleCluster *gocql.ClusterConfig, ...) (Store, error)

Types

type Config

type Config struct {
	MaxRetriesMutate        int
	MaxRetriesMutateSleep   time.Duration
	UseServerSideTimestamps bool
}

type Store

type Store interface {
	Create(context.Context, qb.Builder, qb.Builder) error
	Mutate(context.Context, qb.Builder, ...interface{}) error
	Check(context.Context, *typedef.Table, qb.Builder, ...interface{}) error
	Close() error
}

func New

func New(schema *typedef.Schema, testCluster, oracleCluster *gocql.ClusterConfig, cfg Config, traceOut *os.File, logger *zap.Logger) (Store, error)