events

type Command interface {
	GetBody() ([]byte, error)
	GetExchangeName() string
	GetCommandName() string
	GetHeaders() map[string]any
	SetHeaders(map[string]any)
}

type DBRepository struct {
	*repositories.Repositories
	// contains filtered or unexported fields
}

type DeliveryMode uint8

type Event struct {
	ID         string
	EntityID   string
	EntityName string
	Published  bool
	Payload    any
	Headers    map[string]any
	Exchange   string
	RoutingKey string
	CreatedAt  time.Time
	UpdatedAt  time.Time
}

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

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

type HeaderRouterOption interface {
	// contains filtered or unexported methods
}

type Matcher func(msgRoute string, handlerRoute string) bool

type Model struct {
	ID         string
	EntityID   string
	EntityName string
	Published  bool
	Payload    pgtype.JSONB
	Headers    pgtype.JSONB
	Exchange   string
	RoutingKey string
	CreatedAt  pgtype.Timestamp
	UpdatedAt  sql.NullTime
}

type Publisher interface {
	Publish(publishing Publishing) error
}

type Publishing interface {
	GetBody() ([]byte, error)
	GetHeaders() amqp.Table
	SetHeaders(map[string]any)
	GetDeliveryMode() DeliveryMode
	GetRoutingKey() string
}

type Repository interface {
	Create(ctx context.Context, event *Event) error
	Update(ctx context.Context, event *Event) error
}

type Response interface {
	GetBody() ([]byte, error)
	GetHeaders() map[string]any
	SetHeaders(map[string]any)
}

type Router interface {
	Match(msg amqp.Delivery, route string) bool
}

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

type RouterKeyRouterOption interface {
	// contains filtered or unexported methods
}