utils

package module

v0.0.0-...-47fe569 Latest Latest Go to latest Published: Aug 28, 2022 License: MIT Imports: 13 Imported by: 3

Details

This section is empty.

This section is empty.

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

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

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

func NewAggregateError() *AggregateError

func (ae *AggregateError) Add(err error)

func (ae *AggregateError) GetError() error

type AmqCastType string

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

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

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

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[T any] struct {
	// contains filtered or unexported fields
}

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[T any] struct {
	// contains filtered or unexported fields
}

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[T any] interface {
	Sender[T]
	Processor[T]
}

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

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