channel

Documentation

Index

• type Vec
  • func NewVector() *Vec
  • func (v *Vec) Destroy()
  • func (v *Vec) Len() int
  • func (v *Vec) Pop(ctx context.Context) (*worker.Process, error)
  • func (v *Vec) Push(w *worker.Process)
  • func (v *Vec) Remove()
  • func (v *Vec) Reset()
  • func (v *Vec) ResetDone()

Types

type Vec

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

func NewVector

func NewVector() *Vec

func (*Vec) Destroy

func (v *Vec) Destroy()

func (*Vec) Len

func (v *Vec) Len() int

func (*Vec) Pop

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

func (*Vec) Push

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

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()

func (*Vec) Reset

func (v *Vec) Reset()

func (*Vec) ResetDone

func (v *Vec) ResetDone()