tools

Documentation

Index

• type Interval
• type IntervalTree
  • func NewIntervalTree(ctx context.Context) *IntervalTree
  • func (t *IntervalTree) BatchDelete(ctx context.Context, intervalList []*Interval) error
  • func (t *IntervalTree) BatchInsert(ctx context.Context, kvmap map[*Interval]interface{}) error
  • func (t *IntervalTree) Empty() bool
  • func (t *IntervalTree) ListNode() (ch chan *KV)
  • func (t *IntervalTree) Search(ctx context.Context, i *Interval) (*Interval, interface{}, error)
  • func (t *IntervalTree) UpdateNode(ctx context.Context, i *Interval, value interface{}) error
• type KV
• type LeaderMgr
  • func NewLeaderMgr(instanceId string, endpoints []string) (lm *LeaderMgr, err error)
  • func (lm *LeaderMgr) Elect(key string) (err error)
  • func (lm *LeaderMgr) Get(ctx context.Context, key string) (val string, err error)
  • func (lm *LeaderMgr) Set(ctx context.Context, key string, val string) (err error)
  • func (lm *LeaderMgr) Stop()
• type RBcolor

Types

type Interval

type Interval struct {
	Low  uint64
	High uint64
}

type IntervalTree

type IntervalTree struct {
	// contains filtered or unexported fields
}

func NewIntervalTree

func NewIntervalTree(ctx context.Context) *IntervalTree

func (*IntervalTree) BatchDelete

func (t *IntervalTree) BatchDelete(ctx context.Context, intervalList []*Interval) error

func (*IntervalTree) BatchInsert

func (t *IntervalTree) BatchInsert(ctx context.Context, kvmap map[*Interval]interface{}) error

func (*IntervalTree) Empty

func (t *IntervalTree) Empty() bool

func (*IntervalTree) ListNode

func (t *IntervalTree) ListNode() (ch chan *KV)

func (*IntervalTree) Search

func (t *IntervalTree) Search(ctx context.Context, i *Interval) (*Interval, interface{}, error)

func (*IntervalTree) UpdateNode

func (t *IntervalTree) UpdateNode(ctx context.Context, i *Interval, value interface{}) error

type KV

type KV struct {
	Interval *Interval
	Value    interface{}
}

type LeaderMgr

type LeaderMgr struct {
	// contains filtered or unexported fields
}

func NewLeaderMgr

func NewLeaderMgr(instanceId string, endpoints []string) (lm *LeaderMgr, err error)

func (*LeaderMgr) Elect

func (lm *LeaderMgr) Elect(key string) (err error)

func (*LeaderMgr) Get

func (lm *LeaderMgr) Get(ctx context.Context, key string) (val string, err error)

func (*LeaderMgr) Set

func (lm *LeaderMgr) Set(ctx context.Context, key string, val string) (err error)

func (*LeaderMgr) Stop

func (lm *LeaderMgr) Stop()

type RBcolor

type RBcolor int