events

Documentation

Index

• func DecodeEvent[T any](v *validation.Validator, ctx context.Context, eventJson string) (*T, error)
• func Validations() map[string]validation.ValidationFunc
• type BasicHandler
  • func (b *BasicHandler) MsgReceived(ctx context.Context, event contract.Message, ack func())
  • func (b *BasicHandler) Register(event string, handler domain.EventHandlerFunc)
• type MessagePublishedMetric
• type Publisher
  • func NewPublisher(client *redis.Client) *Publisher
  • func (p Publisher) Publish(ctx context.Context, message domain.PublishableMessage) error
• type Subscriber
  • func NewSubscriber(validator *validation.Validator, serviceName, hostName string, ...) *Subscriber
  • func (s *Subscriber) Ack(msgCtx context.Context, stream string, msg redis.XMessage)
  • func (s *Subscriber) DecodeHeader(msg redis.XMessage) (*contract.Header, error)
  • func (s *Subscriber) Listen(ctx context.Context) error
  • func (s *Subscriber) Subscribe(stream string) *BasicHandler

Functions

func DecodeEvent

func DecodeEvent[T any](v *validation.Validator, ctx context.Context, eventJson string) (*T, error)

func Validations

func Validations() map[string]validation.ValidationFunc

Types

type BasicHandler

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

func (*BasicHandler) MsgReceived

func (b *BasicHandler) MsgReceived(ctx context.Context, event contract.Message, ack func())

func (*BasicHandler) Register

func (b *BasicHandler) Register(event string, handler domain.EventHandlerFunc)

type MessagePublishedMetric

type MessagePublishedMetric struct {
	Channel string `metric:"channel"`
	Event   string `metric:"event"`
	Payload string `metric:"payload"`
}

type Publisher

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

func NewPublisher

func NewPublisher(client *redis.Client) *Publisher

func (Publisher) Publish

func (p Publisher) Publish(ctx context.Context, message domain.PublishableMessage) error

type Subscriber

type Subscriber struct {
	Validator *validation.Validator
	// contains filtered or unexported fields
}

func NewSubscriber

func NewSubscriber(validator *validation.Validator, serviceName, hostName string, rdb *redis.Client) *Subscriber

func (*Subscriber) Ack

func (s *Subscriber) Ack(msgCtx context.Context, stream string, msg redis.XMessage)

func (*Subscriber) DecodeHeader

func (s *Subscriber) DecodeHeader(msg redis.XMessage) (*contract.Header, error)

func (*Subscriber) Listen

func (s *Subscriber) Listen(ctx context.Context) error

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(stream string) *BasicHandler

Subscribe registers a handler for a given stream (channel).