ligo_microservices

May 17, 2026

Changes in this version

+ var ErrConnectionLost = errors.New("microservices: connection lost during request")

May 17, 2026

Changes in this version

type RabbitMQConfig

+ Queue string

May 17, 2026

Changes in this version

+ var ErrNotConnected = errors.New("microservices: broker not connected")

+ func BuilderActionEvent[T any](hb *handlerBuilder, handler func(ctx context.Context, input T) error)

+ func BuilderAction[T, R any](hb *handlerBuilder, handler func(ctx context.Context, input T) (R, error))

+ func Emit(ctx context.Context, b *Broker, pattern string, payload any) error

+ func HandleBuilder[T, R any](b *Broker, pattern string) *handlerBuilder

+ func Handle[T, R any](b *Broker, pattern string, ...)

+ func OnBuilder[T any](b *Broker, pattern string) *handlerBuilder

+ func On[T any](b *Broker, pattern string, handler func(ctx context.Context, input T) error)

+ func Provider() ligo.Provider

+ func RabbitMQModule(cfg RabbitMQConfig) ligo.Module

+ func Send[T any](ctx context.Context, b *Broker, pattern string, payload any) (T, error)

+ type Broker struct

+ func NewBroker(cfg RabbitMQConfig) *Broker

+ func (b *Broker) Register(r *ligo.HookRegistry)

+ type BrokerError struct

+ Message string

+ Type string

+ func Internal(msg string) *BrokerError

+ func NotFound(msg string) *BrokerError

+ func Timeout(msg string) *BrokerError

+ func Validation(msg string) *BrokerError

+ func (e *BrokerError) Error() string

+ type Codec interface

+ Decode func(data []byte, target any) error

+ Encode func(any) ([]byte, error)

+ var JSONCodec Codec = jsonCodec{}

+ var ProtobufCodec Codec = protobufCodec{}

+ type HandlerBuilder interface

+ Filter func(filters ...MessageExceptionFilter) *handlerBuilder

+ Guard func(guards ...MessageGuard) *handlerBuilder

+ Intercept func(interceptors ...MessageInterceptor) *handlerBuilder

+ Pipe func(pipes ...MessagePipe) *handlerBuilder

+ type Message struct

+ Data []byte

+ Headers map[string]any

+ ID string

+ Pattern string

+ type MessageExceptionFilter func(err error, ctx context.Context, msg Message) error

+ type MessageGuard func(ctx context.Context, msg Message) (bool, error)

+ type MessageInterceptor func(ctx context.Context, msg Message, next func() error) error

+ type MessagePipe func(ctx context.Context, msg Message) error

+ type RabbitMQConfig struct

+ Codec Codec

+ Exchange string

+ Retry RetryConfig

+ Timeout time.Duration

+ URL string

+ type RetryConfig struct

+ Delay time.Duration

+ MaxAttempts int

+ MaxDelay time.Duration

+ OnReconnect func()

+ OnRetry func(attempt int, err error)