channel

Documentation

Index

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

Types

type Vec

type Vec struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewVector

func NewVector(len uint64) *Vec

func (*Vec) Destroy

func (v *Vec) Destroy()

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)