mq

Documentation

Index

• type AllConsumer
• type BasicConsumer
• type MQ
  • func NewInMemoryMQ[T any]() MQ[T]
• type Message

Types

type AllConsumer

type AllConsumer[T any] func([]Message[T])

type BasicConsumer

type BasicConsumer[T any] func(Message[T])

type MQ

type MQ[T any] interface {
	Publish(Message[T])
	Consume(BasicConsumer[T])
	ConsumeAll(AllConsumer[T])
	Clear()
	Len() int
}

func NewInMemoryMQ

func NewInMemoryMQ[T any]() MQ[T]

type Message

type Message[T any] struct {
	Content T
}