sharding

Nov 28, 2019

Changes in this version

type Cluster

+ func (cl *Cluster) IDGen() *IDGen

Oct 4, 2019

Changes in this version

+ var DefaultIDGen = NewIDGen(41, 11, 12, _epoch)

Sep 27, 2019

Changes in this version

type IDGen

+ func (g *IDGen) MinID(tm time.Time) int64

type ShardIDGen

+ func (g *ShardIDGen) MinID(tm time.Time) int64

Sep 18, 2019

Changes in this version

+ func MaxID(tm time.Time) int64

+ func MinID(tm time.Time) int64

+ func SetIDGen(gen *IDGen)

+ func SplitID(id int64) (tm time.Time, shardID int64, seqID int64)

+ type IDGen struct

+ func NewIDGen(timeBits, shardBits, seqBits uint, epoch time.Time) *IDGen

+ func (g *IDGen) MakeID(tm time.Time, shard, seq int64) int64

+ func (g *IDGen) MaxID(tm time.Time, shard int64) int64

+ func (g *IDGen) NumShards() int

+ func (g *IDGen) SplitID(id int64) (tm time.Time, shardID int64, seqID int64)

+ type ShardIDGen struct

+ func NewShardIDGen(shard int64, gen *IDGen) *ShardIDGen

+ func (g *ShardIDGen) MaxID(tm time.Time) int64

+ func (g *ShardIDGen) NextID(tm time.Time) int64

+ func (g *ShardIDGen) SplitID(id int64) (tm time.Time, shardID int64, seqID int64)

type UUID

+ func (u *UUID) ShardID() int64

Jul 2, 2019

Changes in this version

+ var DefaultIdGen = NewIdGen(41, 11, 12, epoch)

+ func MaxId(tm time.Time) int64

+ func MinId(tm time.Time) int64

+ func SplitId(id int64) (tm time.Time, shardId int64, seqId int64)

+ type Cluster struct

+ func NewCluster(dbs []*pg.DB, nshards int) *Cluster

+ func NewClusterWithGen(dbs []*pg.DB, nshards int, gen *IdGen) *Cluster

+ func (cl *Cluster) Close() error

+ func (cl *Cluster) DB(number int64) (int, *pg.DB)

+ func (cl *Cluster) DBs() []*pg.DB

+ func (cl *Cluster) ForEachDB(fn func(db *pg.DB) error) error

+ func (cl *Cluster) ForEachNShards(n int, fn func(shard *pg.DB) error) error

+ func (cl *Cluster) ForEachShard(fn func(shard *pg.DB) error) error

+ func (cl *Cluster) Shard(number int64) *pg.DB

+ func (cl *Cluster) Shards(db *pg.DB) []*pg.DB

+ func (cl *Cluster) SplitShard(id int64) *pg.DB

+ func (cl *Cluster) SubCluster(number int64, size int) *SubCluster

+ type IdGen struct

+ func NewIdGen(timeBits, shardBits, seqBits uint, epoch time.Time) *IdGen

+ func (g *IdGen) MaxId(tm time.Time, shard int64) int64

+ func (g *IdGen) NextId(tm time.Time, shard, seq int64) int64

+ func (g *IdGen) NumShards() int

+ func (g *IdGen) SplitId(id int64) (tm time.Time, shardId int64, seqId int64)

+ type ShardIdGen struct

+ func NewShardIdGen(shard int64, gen *IdGen) *ShardIdGen

+ func (g *ShardIdGen) MaxId(tm time.Time) int64

+ func (g *ShardIdGen) NextId(tm time.Time) int64

+ func (g *ShardIdGen) SplitId(id int64) (tm time.Time, shardId int64, seqId int64)

+ type SubCluster struct

+ func (cl *SubCluster) ForEachNShards(n int, fn func(shard *pg.DB) error) error

+ func (cl *SubCluster) ForEachShard(fn func(shard *pg.DB) error) error

+ func (cl *SubCluster) Shard(number int64) *pg.DB

+ func (cl *SubCluster) SplitShard(id int64) *pg.DB

+ type UUID [uuidLen]byte

+ func NewUUID(shardId int64, tm time.Time) UUID

+ func ParseUUID(b []byte) (UUID, error)

+ func (u *UUID) IsZero() bool

+ func (u *UUID) MarshalBinary() ([]byte, error)

+ func (u *UUID) MarshalJSON() ([]byte, error)

+ func (u *UUID) MarshalText() ([]byte, error)

+ func (u *UUID) Scan(b interface{}) error

+ func (u *UUID) ShardId() int64

+ func (u *UUID) Split() (shardId int64, tm time.Time)

+ func (u *UUID) Time() time.Time

+ func (u *UUID) UnmarshalBinary(b []byte) error

+ func (u *UUID) UnmarshalJSON(b []byte) error

+ func (u *UUID) UnmarshalText(b []byte) error

+ func (u UUID) AppendValue(b []byte, quote int) ([]byte, error)

+ func (u UUID) String() string

+ func (u UUID) Value() (driver.Value, error)