part

Documentation

Index

• type FuncMap
• type FuncMapType
• type MsgType
  • func NewType[T any](to ...time.Duration) *MsgType[T]
  • func (m *MsgType[T]) ClearAll()
  • func (m *MsgType[T]) Pull_tag(func_map map[string]func(T) (disable bool)) (cancel func())
  • func (m *MsgType[T]) Pull_tag_async(func_map map[string]func(T) (disable bool)) (cancel func())
  • func (m *MsgType[T]) Pull_tag_async_only(key string, f func(T) (disable bool)) (cancel func())
  • func (m *MsgType[T]) Pull_tag_async_order(func_map map[string]func(T) (disable bool)) (cancel func())
  • func (m *MsgType[T]) Pull_tag_chan(key string, size int, ctx context.Context) (cancel func(), ch <-chan T)
  • func (m *MsgType[T]) Pull_tag_only(key string, f func(T) (disable bool)) (cancel func())
  • func (m *MsgType[T]) PushLock_tag(Tag string, Data T)
  • func (m *MsgType[T]) Push_tag(Tag string, Data T)
• type MsgType_tag_data
• type Msgq
  • func New(to ...time.Duration) *Msgq
  • func (m *Msgq) ClearAll()
  • func (m *Msgq) Pull_tag(func_map map[string]func(any) (disable bool)) (cancel func())
  • func (m *Msgq) Pull_tag_async(func_map map[string]func(any) (disable bool)) (cancel func())
  • func (m *Msgq) Pull_tag_async_only(key string, f func(any) (disable bool)) (cancel func())
  • func (m *Msgq) Pull_tag_async_order(func_map map[string]func(any) (disable bool)) (cancel func())
  • func (m *Msgq) Pull_tag_chan(key string, size int, ctx context.Context) (cancel func(), ch <-chan any)
  • func (m *Msgq) Pull_tag_only(key string, f func(any) (disable bool)) (cancel func())
  • func (m *Msgq) Push(msg any)
  • func (m *Msgq) PushLock(msg any)
  • func (m *Msgq) PushLock_tag(Tag string, Data any)
  • func (m *Msgq) Push_tag(Tag string, Data any)
  • func (m *Msgq) Register(f func(any) (disable bool)) (cancel func())
  • func (m *Msgq) Register_front(f func(any) (disable bool)) (cancel func())
• type Msgq_tag_data

Types

type FuncMap

type FuncMap map[string]func(any) (disable bool)

type FuncMapType

type FuncMapType[T any] map[string]func(T) (disable bool)

type MsgType

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

func NewType

func NewType[T any](to ...time.Duration) *MsgType[T]

to[0]:timeout to wait to[1]:timeout to run

func (*MsgType[T]) ClearAll

func (m *MsgType[T]) ClearAll()

func (*MsgType[T]) Pull_tag

func (m *MsgType[T]) Pull_tag(func_map map[string]func(T) (disable bool)) (cancel func())

func (*MsgType[T]) Pull_tag_async

func (m *MsgType[T]) Pull_tag_async(func_map map[string]func(T) (disable bool)) (cancel func())

func (*MsgType[T]) Pull_tag_async_only

func (m *MsgType[T]) Pull_tag_async_only(key string, f func(T) (disable bool)) (cancel func())

func (*MsgType[T]) Pull_tag_async_order

func (m *MsgType[T]) Pull_tag_async_order(func_map map[string]func(T) (disable bool)) (cancel func())

func (*MsgType[T]) Pull_tag_chan

func (m *MsgType[T]) Pull_tag_chan(key string, size int, ctx context.Context) (cancel func(), ch <-chan T)

func (*MsgType[T]) Pull_tag_only

func (m *MsgType[T]) Pull_tag_only(key string, f func(T) (disable bool)) (cancel func())

func (*MsgType[T]) PushLock_tag

func (m *MsgType[T]) PushLock_tag(Tag string, Data T)

不能放置在由Push_tag、PushLock_tag调用的同步Pull中

func (*MsgType[T]) Push_tag

func (m *MsgType[T]) Push_tag(Tag string, Data T)

不能放置在由PushLock_tag调用的同步Pull中

type MsgType_tag_data

type MsgType_tag_data[T any] struct {
	Tag  string
	Data *T
}

type Msgq

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

func New

func New(to ...time.Duration) *Msgq

to[0]:timeout to wait to[1]:timeout to run

func (*Msgq) ClearAll

func (m *Msgq) ClearAll()

func (*Msgq) Pull_tag

func (m *Msgq) Pull_tag(func_map map[string]func(any) (disable bool)) (cancel func())

func (*Msgq) Pull_tag_async

func (m *Msgq) Pull_tag_async(func_map map[string]func(any) (disable bool)) (cancel func())

func (*Msgq) Pull_tag_async_only

func (m *Msgq) Pull_tag_async_only(key string, f func(any) (disable bool)) (cancel func())

func (*Msgq) Pull_tag_async_order

func (m *Msgq) Pull_tag_async_order(func_map map[string]func(any) (disable bool)) (cancel func())

func (*Msgq) Pull_tag_chan

func (m *Msgq) Pull_tag_chan(key string, size int, ctx context.Context) (cancel func(), ch <-chan any)

func (*Msgq) Pull_tag_only

func (m *Msgq) Pull_tag_only(key string, f func(any) (disable bool)) (cancel func())

func (*Msgq) Push

func (m *Msgq) Push(msg any)

func (*Msgq) PushLock

func (m *Msgq) PushLock(msg any)

func (*Msgq) PushLock_tag

func (m *Msgq) PushLock_tag(Tag string, Data any)

不能放置在由Push_tag、PushLock_tag调用的同步Pull中

func (*Msgq) Push_tag

func (m *Msgq) Push_tag(Tag string, Data any)

不能放置在由PushLock_tag调用的同步Pull中

func (*Msgq) Register

func (m *Msgq) Register(f func(any) (disable bool)) (cancel func())

func (*Msgq) Register_front

func (m *Msgq) Register_front(f func(any) (disable bool)) (cancel func())

type Msgq_tag_data

type Msgq_tag_data struct {
	Tag  string
	Data any
}