isuqueue

Documentation

Index

• func AllReset()
• func SetEnableMetrics(enable bool)
• type Channel
  • func NewChannel[T any](name string, len int) *Channel[T]
  • func (c *Channel[T]) Pop() <-chan T
  • func (c *Channel[T]) Push() chan<- T
  • func (c *Channel[T]) Reset()

Functions

func AllReset

func AllReset()

func SetEnableMetrics

func SetEnableMetrics(enable bool)

Types

type Channel

type Channel[T any] struct {
	// contains filtered or unexported fields
}

func NewChannel

func NewChannel[T any](name string, len int) *Channel[T]

func (*Channel[T]) Pop

func (c *Channel[T]) Pop() <-chan T

func (*Channel[T]) Push

func (c *Channel[T]) Push() chan<- T

func (*Channel[T]) Reset

func (c *Channel[T]) Reset()