map_chan

Documentation

Index

• Constants
• type ChanElement
• type MapChan
  • func NewMapChan[T any](name string, chanNum, chanSize int, sendChanTimeout time.Duration, ...) *MapChan[T]
  • func (c *MapChan[T]) ChangeChanList(chanNum, chanSize int)
  • func (c *MapChan[T]) Close()
  • func (c *MapChan[T]) Send(v T, key string) error

Constants

const (
	DefaultChanNum         = 16
	DefaultChanSize        = 1000
	DefaultSendChanTimeout = 1 * time.Second
)

Types

type ChanElement

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

type MapChan

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

func NewMapChan

func NewMapChan[T any](name string, chanNum, chanSize int, sendChanTimeout time.Duration, fn func(ctx context.Context, t T), cleanFn func(context.Context)) *MapChan[T]

func (*MapChan[T]) ChangeChanList

func (c *MapChan[T]) ChangeChanList(chanNum, chanSize int)

func (*MapChan[T]) Close

func (c *MapChan[T]) Close()

func (*MapChan[T]) Send

func (c *MapChan[T]) Send(v T, key string) error