events

package

v0.16.1 Latest Latest Go to latest Published: Sep 25, 2024 License: Apache-2.0 Imports: 6 Imported by: 1

Details

This section is empty.

This section is empty.

func Dequeue[T any, E swarm.EventKind[T]](q swarm.Broker, category ...string) (<-chan swarm.Msg[*E], chan<- swarm.Msg[*E])

Dequeue event

func Enqueue[T any, E swarm.EventKind[T]](q swarm.Broker, category ...string) (chan<- *E, <-chan *E)

Enqueue creates pair of channels - to send messages - failed messages (dead-letter queue)

func TypeOf[T any]() string

normalized type name

type Enqueuer[T any, E swarm.EventKind[T]] interface {
	Put(*E) error
	Enq(string, *E) error
}

func New[T any, E swarm.EventKind[T]](q swarm.Broker, category ...string) Enqueuer[T, E]