common

Documentation

Index

• Variables
• func Assert(err error)
• func GetError(ctx context.Context) error
• func Hung()
• func WithError(ctx context.Context, err error) context.Context
• type Adder
  • func NewAdder() *Adder
  • func (this *Adder) Add(key string, addValue uint64)
  • func (this *Adder) Clean()
  • func (this *Adder) Get(key string) uint64
  • func (this *Adder) List() (keys []string)
• type KV
• type SimpleQueue
  • func NewSimpleQueue() *SimpleQueue
  • func (this *SimpleQueue) GetAverage(t time.Time) int64
  • func (this *SimpleQueue) GetMax(t time.Time) int64
  • func (this *SimpleQueue) GetMost(t time.Time) int64
  • func (this *SimpleQueue) Insert(data int64)

Variables

var ErrNoAvailableClients = errors.New("no available clients")

Functions

func Assert

func Assert(err error)

func GetError

func GetError(ctx context.Context) error

func Hung

func Hung()

func WithError

func WithError(ctx context.Context, err error) context.Context

Types

type Adder

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

func NewAdder

func NewAdder() *Adder

func (*Adder) Add

func (this *Adder) Add(key string, addValue uint64)

func (*Adder) Clean

func (this *Adder) Clean()

func (*Adder) Get

func (this *Adder) Get(key string) uint64

func (*Adder) List

func (this *Adder) List() (keys []string)

type KV

type KV struct {
	Key    string
	Weight int
}

type SimpleQueue

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

func NewSimpleQueue

func NewSimpleQueue() *SimpleQueue

func (*SimpleQueue) GetAverage

func (this *SimpleQueue) GetAverage(t time.Time) int64

func (*SimpleQueue) GetMax

func (this *SimpleQueue) GetMax(t time.Time) int64

func (*SimpleQueue) GetMost

func (this *SimpleQueue) GetMost(t time.Time) int64

func (*SimpleQueue) Insert

func (this *SimpleQueue) Insert(data int64)