The highest tagged major version is v2.

channel

package

v1.0.3 Latest Latest Go to latest Published: Nov 21, 2024 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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)

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

func (v *Vec) Remove()

func (v *Vec) Reset()

func (v *Vec) ResetDone()