schema

Oct 11, 2021

Changes in this version

type CassandraSchema

+ func (cs *CassandraSchema) ValidateOrg(orgName string) bool

type LogSchema

+ ValidateOrg func(orgName string) bool

Aug 13, 2021

Changes in this version

type LogSchema

+ CreateDefault func() error

Jul 31, 2021

Changes in this version

+ const BaseLogAlterTableGCGraceSeconds

+ const BaseLogCreateIndex

+ const BaseLogCreateTable

+ const DefaultBaseLogTable

+ const DefaultKeySpace

+ const LogMetaCreateIndex

+ const LogMetaCreateTable

+ func BaseLogWithOrgName(orgName string) string

+ func KeyspaceWithOrgName(orgName string) string

+ type CassandraSchema struct

+ Logger logs.Logger

+ func NewCassandraSchema(cass cassandra.Interface, l logs.Logger, ops ...Option) (*CassandraSchema, error)

+ func (cs *CassandraSchema) CreateDefault() error

+ func (cs *CassandraSchema) Name() string

+ func (cs *CassandraSchema) RunDaemon(ctx context.Context, interval time.Duration, muInf mutex.Interface)

+ type LogSchema interface

+ Name func() string

+ RunDaemon func(ctx context.Context, interval time.Duration, muInf mutex.Interface)

+ type Option func(cs *CassandraSchema)

+ func WithMutexKey(key string) Option