Documentation
¶
Index ¶
Constants ¶
View Source
const ( SeqShardCount = 12 * 4 // 分片数,降低锁竞争 SeqWindowSize = 4096 // 最大允许的序列号窗口 )
View Source
const (
GOOS = runtime.GOOS
)
Variables ¶
Functions ¶
func LoadBalancePut ¶
Types ¶
type Dispatcher ¶
type Dispatcher struct {
// contains filtered or unexported fields
}
func (*Dispatcher) UpdateWeights ¶
func (d *Dispatcher) UpdateWeights(newWeights map[int]float64)
权重平滑迁移
type Metrics ¶
type Sched ¶
type Sched struct {
// contains filtered or unexported fields
}
func (*Sched) SetStrategy ¶
type SequenceManager ¶
type SequenceManager struct {
// contains filtered or unexported fields
}
func NewSequenceManager ¶
func NewSequenceManager() *SequenceManager
func (*SequenceManager) Close ¶
func (sm *SequenceManager) Close()
func (*SequenceManager) Submit ¶
func (sm *SequenceManager) Submit(seq uint64, data []byte)
按序列号分片提交
Source Files
¶
Click to show internal directories.
Click to hide internal directories.