activerecord

Feb 29, 2024

Changes in this version

type ShardInstanceConfig

+ Password string

+ User string

Feb 28, 2024

Changes in this version

+ type GroupHash struct

+ func NewGroupHash(hash hash.Hash32) *GroupHash

+ func (o *GroupHash) GetHash() string

+ func (o *GroupHash) UpdateHash(data ...interface{}) error

Jan 26, 2024

Changes in this version

type Cluster

+ func (c *Cluster) Equal(c2 *Cluster) bool

Jan 15, 2024

Changes in this version

type Cluster

+ func AddClusterChecker(ctx context.Context, configPath string, params ClusterConfigParameters) (*Cluster, error)

+ func NewCluster(shardCnt int) *Cluster

+ func (c *Cluster) Append(shard Shard)

+ func (c *Cluster) NextMaster(shardNum int) ShardInstance

+ func (c *Cluster) NextReplica(shardNum int) (ShardInstance, bool)

+ func (c *Cluster) SetShardInstances(shardNum int, instances []ShardInstance)

+ func (c *Cluster) ShardInstances(shardNum int) []ShardInstance

+ func (c *Cluster) Shards() int

+ type ClusterCheckerInterface interface

+ AddClusterChecker func(ctx context.Context, path string, params ClusterConfigParameters) (*Cluster, error)

+ type ClusterConfigParameters struct

+ Globs MapGlobParam

+ OptionChecker func(ctx context.Context, instance ShardInstance) (OptionInterface, error)

+ OptionCreator func(ShardInstanceConfig) (OptionInterface, error)

+ func (c ClusterConfigParameters) Validate() bool

type DefaultConfigCacher

+ func NewConfigCacher() *DefaultConfigCacher

+ type MockConfig struct

+ func NewMockConfig(t mockConstructorTestingTNewMockConfig) *MockConfig

+ func (_m *MockConfig) EXPECT() *MockConfig_Expecter

+ func (_m *MockConfig) GetBool(ctx context.Context, confPath string, dfl ...bool) bool

+ func (_m *MockConfig) GetBoolIfExists(ctx context.Context, confPath string) (bool, bool)

+ func (_m *MockConfig) GetDuration(ctx context.Context, confPath string, dfl ...time.Duration) time.Duration

+ func (_m *MockConfig) GetDurationIfExists(ctx context.Context, confPath string) (time.Duration, bool)

+ func (_m *MockConfig) GetInt(ctx context.Context, confPath string, dfl ...int) int

+ func (_m *MockConfig) GetIntIfExists(ctx context.Context, confPath string) (int, bool)

+ func (_m *MockConfig) GetLastUpdateTime() time.Time

+ func (_m *MockConfig) GetString(ctx context.Context, confPath string, dfl ...string) string

+ func (_m *MockConfig) GetStringIfExists(ctx context.Context, confPath string) (string, bool)

+ func (_m *MockConfig) GetStrings(ctx context.Context, confPath string, dfl []string) []string

+ func (_m *MockConfig) GetStruct(ctx context.Context, confPath string, valuePtr interface{}) (bool, error)

+ type MockConfig_Expecter struct

+ func (_e *MockConfig_Expecter) GetBool(ctx interface{}, confPath interface{}, dfl ...interface{}) *MockConfig_GetBool_Call

+ func (_e *MockConfig_Expecter) GetBoolIfExists(ctx interface{}, confPath interface{}) *MockConfig_GetBoolIfExists_Call

+ func (_e *MockConfig_Expecter) GetDuration(ctx interface{}, confPath interface{}, dfl ...interface{}) *MockConfig_GetDuration_Call

+ func (_e *MockConfig_Expecter) GetDurationIfExists(ctx interface{}, confPath interface{}) *MockConfig_GetDurationIfExists_Call

+ func (_e *MockConfig_Expecter) GetInt(ctx interface{}, confPath interface{}, dfl ...interface{}) *MockConfig_GetInt_Call

+ func (_e *MockConfig_Expecter) GetIntIfExists(ctx interface{}, confPath interface{}) *MockConfig_GetIntIfExists_Call

+ func (_e *MockConfig_Expecter) GetLastUpdateTime() *MockConfig_GetLastUpdateTime_Call

+ func (_e *MockConfig_Expecter) GetString(ctx interface{}, confPath interface{}, dfl ...interface{}) *MockConfig_GetString_Call

+ func (_e *MockConfig_Expecter) GetStringIfExists(ctx interface{}, confPath interface{}) *MockConfig_GetStringIfExists_Call

+ func (_e *MockConfig_Expecter) GetStrings(ctx interface{}, confPath interface{}, dfl interface{}) *MockConfig_GetStrings_Call

+ func (_e *MockConfig_Expecter) GetStruct(ctx interface{}, confPath interface{}, valuePtr interface{}) *MockConfig_GetStruct_Call

+ type MockConfig_GetBoolIfExists_Call struct

+ func (_c *MockConfig_GetBoolIfExists_Call) Return(value bool, ok bool) *MockConfig_GetBoolIfExists_Call

+ func (_c *MockConfig_GetBoolIfExists_Call) Run(run func(ctx context.Context, confPath string)) *MockConfig_GetBoolIfExists_Call

+ func (_c *MockConfig_GetBoolIfExists_Call) RunAndReturn(run func(context.Context, string) (bool, bool)) *MockConfig_GetBoolIfExists_Call

+ type MockConfig_GetBool_Call struct

+ func (_c *MockConfig_GetBool_Call) Return(_a0 bool) *MockConfig_GetBool_Call

+ func (_c *MockConfig_GetBool_Call) Run(run func(ctx context.Context, confPath string, dfl ...bool)) *MockConfig_GetBool_Call

+ func (_c *MockConfig_GetBool_Call) RunAndReturn(run func(context.Context, string, ...bool) bool) *MockConfig_GetBool_Call

+ type MockConfig_GetDurationIfExists_Call struct

+ func (_c *MockConfig_GetDurationIfExists_Call) Return(_a0 time.Duration, _a1 bool) *MockConfig_GetDurationIfExists_Call

+ func (_c *MockConfig_GetDurationIfExists_Call) Run(run func(ctx context.Context, confPath string)) *MockConfig_GetDurationIfExists_Call

+ func (_c *MockConfig_GetDurationIfExists_Call) RunAndReturn(run func(context.Context, string) (time.Duration, bool)) *MockConfig_GetDurationIfExists_Call

+ type MockConfig_GetDuration_Call struct

+ func (_c *MockConfig_GetDuration_Call) Return(_a0 time.Duration) *MockConfig_GetDuration_Call

+ func (_c *MockConfig_GetDuration_Call) Run(run func(ctx context.Context, confPath string, dfl ...time.Duration)) *MockConfig_GetDuration_Call

+ func (_c *MockConfig_GetDuration_Call) RunAndReturn(run func(context.Context, string, ...time.Duration) time.Duration) *MockConfig_GetDuration_Call

+ type MockConfig_GetIntIfExists_Call struct

+ func (_c *MockConfig_GetIntIfExists_Call) Return(_a0 int, _a1 bool) *MockConfig_GetIntIfExists_Call

+ func (_c *MockConfig_GetIntIfExists_Call) Run(run func(ctx context.Context, confPath string)) *MockConfig_GetIntIfExists_Call

+ func (_c *MockConfig_GetIntIfExists_Call) RunAndReturn(run func(context.Context, string) (int, bool)) *MockConfig_GetIntIfExists_Call

+ type MockConfig_GetInt_Call struct

+ func (_c *MockConfig_GetInt_Call) Return(_a0 int) *MockConfig_GetInt_Call

+ func (_c *MockConfig_GetInt_Call) Run(run func(ctx context.Context, confPath string, dfl ...int)) *MockConfig_GetInt_Call

+ func (_c *MockConfig_GetInt_Call) RunAndReturn(run func(context.Context, string, ...int) int) *MockConfig_GetInt_Call

+ type MockConfig_GetLastUpdateTime_Call struct

+ func (_c *MockConfig_GetLastUpdateTime_Call) Return(_a0 time.Time) *MockConfig_GetLastUpdateTime_Call

+ func (_c *MockConfig_GetLastUpdateTime_Call) Run(run func()) *MockConfig_GetLastUpdateTime_Call

+ func (_c *MockConfig_GetLastUpdateTime_Call) RunAndReturn(run func() time.Time) *MockConfig_GetLastUpdateTime_Call

+ type MockConfig_GetStringIfExists_Call struct

+ func (_c *MockConfig_GetStringIfExists_Call) Return(_a0 string, _a1 bool) *MockConfig_GetStringIfExists_Call

+ func (_c *MockConfig_GetStringIfExists_Call) Run(run func(ctx context.Context, confPath string)) *MockConfig_GetStringIfExists_Call

+ func (_c *MockConfig_GetStringIfExists_Call) RunAndReturn(run func(context.Context, string) (string, bool)) *MockConfig_GetStringIfExists_Call

+ type MockConfig_GetString_Call struct

+ func (_c *MockConfig_GetString_Call) Return(_a0 string) *MockConfig_GetString_Call

+ func (_c *MockConfig_GetString_Call) Run(run func(ctx context.Context, confPath string, dfl ...string)) *MockConfig_GetString_Call

+ func (_c *MockConfig_GetString_Call) RunAndReturn(run func(context.Context, string, ...string) string) *MockConfig_GetString_Call

+ type MockConfig_GetStrings_Call struct

+ func (_c *MockConfig_GetStrings_Call) Return(_a0 []string) *MockConfig_GetStrings_Call

+ func (_c *MockConfig_GetStrings_Call) Run(run func(ctx context.Context, confPath string, dfl []string)) *MockConfig_GetStrings_Call

+ func (_c *MockConfig_GetStrings_Call) RunAndReturn(run func(context.Context, string, []string) []string) *MockConfig_GetStrings_Call

+ type MockConfig_GetStruct_Call struct

+ func (_c *MockConfig_GetStruct_Call) Return(_a0 bool, _a1 error) *MockConfig_GetStruct_Call

+ func (_c *MockConfig_GetStruct_Call) Run(run func(ctx context.Context, confPath string, valuePtr interface{})) *MockConfig_GetStruct_Call

+ func (_c *MockConfig_GetStruct_Call) RunAndReturn(run func(context.Context, string, interface{}) (bool, error)) *MockConfig_GetStruct_Call

type Option

+ func WithConfigCacher(configCacher ConfigCacherInterface) Option

+ func WithConnectionPinger(pc ClusterCheckerInterface) Option

type Shard

+ func (c *Shard) Instances() []ShardInstance

type ShardInstance

+ Offline bool

Apr 13, 2023

Changes in this version

+ const ContextLogprefix

+ const DebugLoggerLevel

+ const ErrorLoggerLevel

+ const FatalLoggerLevel

+ const InfoLoggerLevel

+ const PanicLoggerLevel

+ const TraceLoggerLevel

+ const ValueContextErrorField

+ const WarnLoggerLevel

+ var ErrNoData = errors.New("no data")

+ func InitActiveRecord(opts ...Option)

+ func ReinitActiveRecord(opts ...Option)

+ func WithShard(masters []OptionInterface, replicas []OptionInterface) clusterOption

+ type ActiveRecord struct

+ func GetInstance() *ActiveRecord

+ type Cluster []Shard

+ func GetClusterInfoFromCfg(ctx context.Context, path string, globs MapGlobParam, ...) (Cluster, error)

+ func NewClusterInfo(opts ...clusterOption) Cluster

+ type ConfigCacherInterface interface

+ Get func(ctx context.Context, path string, glob MapGlobParam, ...) (Cluster, error)

+ func ConfigCacher() ConfigCacherInterface

+ type ConfigInterface interface

+ GetBool func(ctx context.Context, confPath string, dfl ...bool) bool

+ GetBoolIfExists func(ctx context.Context, confPath string) (value bool, ok bool)

+ GetDuration func(ctx context.Context, confPath string, dfl ...time.Duration) time.Duration

+ GetDurationIfExists func(ctx context.Context, confPath string) (time.Duration, bool)

+ GetInt func(ctx context.Context, confPath string, dfl ...int) int

+ GetIntIfExists func(ctx context.Context, confPath string) (int, bool)

+ GetLastUpdateTime func() time.Time

+ GetString func(ctx context.Context, confPath string, dfl ...string) string

+ GetStringIfExists func(ctx context.Context, confPath string) (string, bool)

+ GetStrings func(ctx context.Context, confPath string, dfl []string) []string

+ GetStruct func(ctx context.Context, confPath string, valuePtr interface{}) (bool, error)

+ func Config() ConfigInterface

+ type ConnectionCacherInterface interface

+ Add func(shard ShardInstance, connector func(interface{}) (ConnectionInterface, error)) (ConnectionInterface, error)

+ CloseConnection func(context.Context)

+ Get func(shard ShardInstance) ConnectionInterface

+ GetOrAdd func(shard ShardInstance, connector func(interface{}) (ConnectionInterface, error)) (ConnectionInterface, error)

+ func ConnectionCacher() ConnectionCacherInterface

+ type ConnectionInterface interface

+ Close func()

+ Done func() <-chan struct{}

+ type DefaultConfig struct

+ func NewDefaultConfig() *DefaultConfig

+ func NewDefaultConfigFromMap(cfg map[string]interface{}) *DefaultConfig

+ func (dc *DefaultConfig) GetBool(ctx context.Context, confPath string, dfl ...bool) bool

+ func (dc *DefaultConfig) GetBoolIfExists(ctx context.Context, confPath string) (value bool, ok bool)

+ func (dc *DefaultConfig) GetDuration(ctx context.Context, confPath string, dfl ...time.Duration) time.Duration

+ func (dc *DefaultConfig) GetDurationIfExists(ctx context.Context, confPath string) (time.Duration, bool)

+ func (dc *DefaultConfig) GetInt(ctx context.Context, confPath string, dfl ...int) int

+ func (dc *DefaultConfig) GetIntIfExists(ctx context.Context, confPath string) (int, bool)

+ func (dc *DefaultConfig) GetLastUpdateTime() time.Time

+ func (dc *DefaultConfig) GetString(ctx context.Context, confPath string, dfl ...string) string

+ func (dc *DefaultConfig) GetStringIfExists(ctx context.Context, confPath string) (string, bool)

+ func (dc *DefaultConfig) GetStrings(ctx context.Context, confPath string, dfl []string) []string

+ func (dc *DefaultConfig) GetStruct(ctx context.Context, confPath string, valuePtr interface{}) (bool, error)

+ type DefaultConfigCacher struct

+ func (cc *DefaultConfigCacher) Get(ctx context.Context, path string, globs MapGlobParam, ...) (Cluster, error)

+ type DefaultLogger struct

+ Fields ValueLogPrefix

+ func NewLogger() *DefaultLogger

+ func (l *DefaultLogger) CollectQueries(ctx context.Context, f func() (MockerLogger, error))

+ func (l *DefaultLogger) Debug(ctx context.Context, args ...interface{})

+ func (l *DefaultLogger) Error(ctx context.Context, args ...interface{})

+ func (l *DefaultLogger) Fatal(ctx context.Context, args ...interface{})

+ func (l *DefaultLogger) Info(ctx context.Context, args ...interface{})

+ func (l *DefaultLogger) Panic(ctx context.Context, args ...interface{})

+ func (l *DefaultLogger) SetLogLevel(level uint32)

+ func (l *DefaultLogger) SetLoggerValueToContext(ctx context.Context, val ValueLogPrefix) context.Context

+ func (l *DefaultLogger) Trace(ctx context.Context, args ...interface{})

+ func (l *DefaultLogger) Warn(ctx context.Context, args ...interface{})

+ type DefaultNoopMetric struct

+ func NewDefaultNoopMetric() *DefaultNoopMetric

+ func (*DefaultNoopMetric) ErrorCount(storage, entity string) MetricStatCountInterface

+ func (*DefaultNoopMetric) StatCount(storage, entity string) MetricStatCountInterface

+ func (*DefaultNoopMetric) Timer(storage, entity string) MetricTimerInterface

+ type DefaultNoopMetricCount struct

+ func (*DefaultNoopMetricCount) Inc(ctx context.Context, name string, val float64)

+ type DefaultNoopMetricTimer struct

+ func (*DefaultNoopMetricTimer) Finish(ctx context.Context, name string)

+ func (*DefaultNoopMetricTimer) Timing(ctx context.Context, name string)

+ type IprotoLogger struct

+ func (IprotoLogger) Debugf(ctx context.Context, fmtStr string, v ...interface{})

+ func (IprotoLogger) Printf(ctx context.Context, fmtStr string, v ...interface{})

+ type Limiter struct

+ func EmptyLimiter() Limiter

+ func NewLimitOffset(limit uint32, offset uint32) Limiter

+ func NewLimiter(limit uint32) Limiter

+ func NewThreshold(limit uint32) Limiter

+ func (l Limiter) FullfillWarn() bool

+ func (l Limiter) Limit() uint32

+ func (l Limiter) Offset() uint32

+ func (l Limiter) String() string

+ type LoggerInterface interface

+ CollectQueries func(ctx context.Context, f func() (MockerLogger, error))

+ Debug func(ctx context.Context, args ...interface{})

+ Error func(ctx context.Context, args ...interface{})

+ Fatal func(ctx context.Context, args ...interface{})

+ Info func(ctx context.Context, args ...interface{})

+ SetLogLevel func(level uint32)

+ SetLoggerValueToContext func(ctx context.Context, addVal ValueLogPrefix) context.Context

+ Trace func(ctx context.Context, args ...interface{})

+ Warn func(ctx context.Context, args ...interface{})

+ func Logger() LoggerInterface

+ type MapGlobParam struct

+ PoolSize int

+ Timeout time.Duration

+ type MetricErrorCountInterface interface

+ Inc func(ctx context.Context, name string, val float64)

+ type MetricInterface interface

+ ErrorCount func(storage, entity string) MetricStatCountInterface

+ StatCount func(storage, entity string) MetricStatCountInterface

+ Timer func(storage, entity string) MetricTimerInterface

+ func Metric() MetricInterface

+ type MetricStatCountInterface interface

+ Inc func(ctx context.Context, name string, val float64)

+ type MetricTimerInterface interface

+ Finish func(ctx context.Context, name string)

+ Timing func(ctx context.Context, name string)

+ type MockerLogger struct

+ FixturesSelector string

+ MockerName string

+ Mockers string

+ ResultName string

+ Results any

+ type Option interface

+ func WithConfig(config ConfigInterface) Option

+ func WithLogger(logger LoggerInterface) Option

+ func WithMetrics(metric MetricInterface) Option

+ type OptionInterface interface

+ GetConnectionID func() string

+ InstanceMode func() any

+ type SelectorLimiter interface

+ FullfillWarn func() bool

+ Limit func() uint32

+ Offset func() uint32

+ type SerializerInterface interface

+ Marshal func(data interface{}) (interface{}, error)

+ Unmarshal func(val interface{}) (interface{}, error)

+ type ServerModeType uint8

+ const ModeMaster

+ const ModeReplica

+ type Shard struct

+ Masters []ShardInstance

+ Replicas []ShardInstance

+ func (s *Shard) NextMaster() ShardInstance

+ func (s *Shard) NextReplica() ShardInstance

+ type ShardInstance struct

+ Config ShardInstanceConfig

+ Options interface{}

+ ParamsID string

+ type ShardInstanceConfig struct

+ Addr string

+ Mode ServerModeType

+ PoolSize int

+ Timeout time.Duration

+ type ShardInstanceType uint8

+ const MasterInstanceType

+ const ReplicaInstanceType

+ const ReplicaOrMasterInstanceType

+ type ValueLogPrefix map[string]interface