event

Documentation

Index

• Variables
• func Register(ctx context.Context) error
• func RegisterChannelQueue(ctx context.Context) error
• type ChannelQueue
  • func NewChannelQueue() *ChannelQueue
  • func (q ChannelQueue) Pop(events map[EventType]reflect.Type) (Event, error)
  • func (q ChannelQueue) Push(e Event) error
• type ChannelQueueConfig
  • func NewChannelQueueConfig() *ChannelQueueConfig
  • func (c *ChannelQueueConfig) Queue() Queue
• type Config
• type Event
• type EventService
  • func Service(listeners ...*Listener) *EventService
  • func (s *EventService) Name() string
  • func (s *EventService) Run(ctx context.Context) error
• type EventType
• type Handler
• type Listener
  • func NewListener[H Handler[E], E Event]() *Listener
• type Queue
• type QueueConfiger

Variables

var (
	ErrEventTypeNotFound = errors.New("event type not found")
)

Functions

func Register

func Register(ctx context.Context) error

func RegisterChannelQueue

func RegisterChannelQueue(ctx context.Context) error

Types

type ChannelQueue

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

func NewChannelQueue

func NewChannelQueue() *ChannelQueue

func (ChannelQueue) Pop

func (q ChannelQueue) Pop(events map[EventType]reflect.Type) (Event, error)

func (ChannelQueue) Push

func (q ChannelQueue) Push(e Event) error

type ChannelQueueConfig

type ChannelQueueConfig struct{}

func NewChannelQueueConfig

func NewChannelQueueConfig() *ChannelQueueConfig

func (*ChannelQueueConfig) Queue

func (c *ChannelQueueConfig) Queue() Queue

type Config

type Config interface {
	Queue() Queue
}

type Event

type Event interface {
	Type() EventType
}

type EventService

type EventService struct {
	Queue  Queue                  `inject:""`
	Logger *slog.Logger           `inject:""`
	DP     *di.DependencyProvider `inject:""`
	// contains filtered or unexported fields
}

func Service

func Service(listeners ...*Listener) *EventService

func (*EventService) Name

func (s *EventService) Name() string

func (*EventService) Run

func (s *EventService) Run(ctx context.Context) error

type EventType

type EventType string

type Handler

type Handler[E Event] interface {
	Handle(ctx context.Context, event E) error
}

type Listener

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

func NewListener

func NewListener[H Handler[E], E Event]() *Listener

type Queue

type Queue interface {
	Push(e Event) error
	Pop(events map[EventType]reflect.Type) (Event, error)
}

type QueueConfiger

type QueueConfiger interface {
	QueueConfig() Config
}