channel

Documentation

Index

• type Vec
  • func NewVector(len uint64) *Vec
  • func (v *Vec) Destroy()
  • func (v *Vec) Drain()
  • func (v *Vec) Len() int
  • func (v *Vec) Pop(ctx context.Context) (worker.BaseProcess, error)
  • func (v *Vec) Push(w worker.BaseProcess)
  • func (v *Vec) Remove(_ int64)
  • func (v *Vec) Reset()
  • func (v *Vec) ResetDone()

Types

type Vec

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

func NewVector

func NewVector(len uint64) *Vec

func (*Vec) Destroy

func (v *Vec) Destroy()

func (*Vec) Drain

func (v *Vec) Drain()

func (*Vec) Len

func (v *Vec) Len() int

func (*Vec) Pop

func (v *Vec) Pop(ctx context.Context) (worker.BaseProcess, error)

func (*Vec) Push

func (v *Vec) Push(w worker.BaseProcess)

Push is O(1) operation In case of TTL and full channel O(n) worst case, where n is len of the channel

func (*Vec) Remove

func (v *Vec) Remove(_ int64)

func (*Vec) Reset

func (v *Vec) Reset()

func (*Vec) ResetDone

func (v *Vec) ResetDone()