spec

Documentation

Index

• type IMessage
• type Publisher
• type Subscriber
• type SubscriberSync

Types

type IMessage

type IMessage[T common.Type] interface {
	Publisher[T]
	Subscriber[T]
	SubscriberSync[T]
	common.Error
}

Messager is an interfer that implements two other interfaces which are Publisher and Subscriber

type Publisher

type Publisher[T common.Type] interface {
	Publish(ctx context.Context, message *common.Message[T]) IMessage[T]
}

Publisher is to publish a message on a topic/subject

type Subscriber

type Subscriber[T common.Type] interface {
	Subscribe(ctx context.Context, message *common.Message[T], f func(data T)) IMessage[T]
}

Subscriber is used to subscribe a message on a subject/topic

type SubscriberSync

type SubscriberSync[T common.Type] interface {
	SubscribeSync(ctx context.Context, message *common.Message[T], f func(data T)) IMessage[T]
}

Subscriber is used to subscribe a message on a subject/topic