utils

Documentation

Index

• func MakeConfig[T any](filePath string) (T, error)
• func ShouldProcessMessage[T any](consumer schema.ConsumerType, msg schema.Message[T]) bool
• type AggregateError
  • func NewAggregateError() *AggregateError
  • func (ae *AggregateError) Add(err error)
  • func (ae *AggregateError) GetError() error
• type AmqCastType
• type AmqConfig
• type AmqMessenger
  • func NewAmqMessenger[T any](cfg AmqConfig, address string, castType AmqCastType) *AmqMessenger[T]
  • func (m *AmqMessenger[T]) Disconnect() error
  • func (m *AmqMessenger[T]) Process(processor func(schema.Message[T], error) error) error
  • func (m *AmqMessenger[T]) Send(msg schema.Message[T]) error
• type InMemoryMessenger
  • func MakeInMemoryMessenger[T any]() InMemoryMessenger[T]
  • func (m InMemoryMessenger[T]) Process(processor func(msg schema.Message[T]) error) error
  • func (m InMemoryMessenger[T]) Send(msg schema.Message[T]) error
• type MessageFactory
  • func MakeMessageFactory[T any](version string) MessageFactory[T]
  • func (p MessageFactory[T]) Make(payload T) schema.Message[T]
  • func (p MessageFactory[T]) MakeWithConsumer(consumers []schema.ConsumerType, payload T) schema.Message[T]
• type Messenger
• type Processor
• type Sender

Functions

func MakeConfig

func MakeConfig[T any](filePath string) (T, error)

func ShouldProcessMessage

func ShouldProcessMessage[T any](consumer schema.ConsumerType, msg schema.Message[T]) bool

Types

type AggregateError

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

func NewAggregateError

func NewAggregateError() *AggregateError

func (*AggregateError) Add

func (ae *AggregateError) Add(err error)

func (*AggregateError) GetError

func (ae *AggregateError) GetError() error

type AmqCastType

type AmqCastType string

const (
	Anycast   AmqCastType = "ANYCAST"
	Multicast AmqCastType = "MULTICAST"
)

type AmqConfig

type AmqConfig struct {
	Endpoint, User, Pass string
	Consumer             schema.ConsumerType
}

type AmqMessenger

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

func NewAmqMessenger

func NewAmqMessenger[T any](cfg AmqConfig, address string, castType AmqCastType) *AmqMessenger[T]

func (*AmqMessenger[T]) Disconnect

func (m *AmqMessenger[T]) Disconnect() error

func (*AmqMessenger[T]) Process

func (m *AmqMessenger[T]) Process(processor func(schema.Message[T], error) error) error

func (*AmqMessenger[T]) Send

func (m *AmqMessenger[T]) Send(msg schema.Message[T]) error

type InMemoryMessenger

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

func MakeInMemoryMessenger

func MakeInMemoryMessenger[T any]() InMemoryMessenger[T]

func (InMemoryMessenger[T]) Process

func (m InMemoryMessenger[T]) Process(processor func(msg schema.Message[T]) error) error

func (InMemoryMessenger[T]) Send

func (m InMemoryMessenger[T]) Send(msg schema.Message[T]) error

type MessageFactory

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

func MakeMessageFactory

func MakeMessageFactory[T any](version string) MessageFactory[T]

func (MessageFactory[T]) Make

func (p MessageFactory[T]) Make(payload T) schema.Message[T]

func (MessageFactory[T]) MakeWithConsumer

func (p MessageFactory[T]) MakeWithConsumer(consumers []schema.ConsumerType, payload T) schema.Message[T]

type Messenger

type Messenger[T any] interface {
	Sender[T]
	Processor[T]
}

type Processor

type Processor[T any] interface {
	Process(func(schema.Message[T], error) error) error
}

type Sender

type Sender[T any] interface {
	Send(msg schema.Message[T]) error
}