bus

type Bus interface {
	Publisher
	Subscriber
}

type Error struct {
	ID        string    `json:"id,omitempty"`
	Name      string    `json:"name,omitempty"`
	Group     string    `json:"group,omitempty"`
	Consumer  string    `json:"consumer,omitempty"`
	Err       error     `json:"error,omitempty"`
	EventID   uuid.UUID `json:"event_id,omitempty"`
	EventDate time.Time `json:"event_date,omitempty"`
}

type ErrorHandler func(ctx context.Context, err error)

type Event interface {
	ID() uuid.UUID
	Date() time.Time
	Name() string
	Data() []byte
}

type Handler interface {
	Handle(ctx context.Context, event Event, additional map[string]any) error
}

type HandlerFunc func(ctx context.Context, event Event, additional map[string]any) error

type MetricsBus struct {
	Bus
	// contains filtered or unexported fields
}

type Middleware func(ctx context.Context, event Event, additional map[string]any, next Handler) error

type Option func(b *RedisBus)

type PublishOption func(a *addArgs)

type Publisher interface {
	Publish(ctx context.Context, event Event) error
}

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

type Subscriber interface {
	Middleware(middlewares ...Middleware)
	Subscribe(ctx context.Context, name string, handler Handler) error
	Stop(ctx context.Context) error
	Errors() <-chan error
}

type TracingBus struct {
	Bus
	// contains filtered or unexported fields
}