subscriber

package

v0.0.0-...-71a2b00 Latest Latest Go to latest Published: Jun 20, 2025 License: MIT Imports: 6 Imported by: 0

Details

View Source

const (
	TopicBattleChanged = "battle"
	BattleChanged      = "battle_changed"
)

View Source

const (
	TopicMatchChanged = "match"
	MatchChanged      = "match_changed"
)

View Source

var DefaultSet = wire.NewSet(
	ProvideDatabaseSubscribers,
)

This section is empty.

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

func NewBattleChangedSubscriber(
	startBattle *usecase.StartBattleCommand,
) *BattleChangedSubscriber

func (s *BattleChangedSubscriber) Handler(msg *message.Message) error

func (s *BattleChangedSubscriber) Name() string

func (s *BattleChangedSubscriber) Topic() string

type DatabaseChange[T any] struct {
	Before *T
	After  *T
}

func (c *DatabaseChange[T]) Created() bool

func (c *DatabaseChange[T]) Deleted() bool

func (c *DatabaseChange[T]) Updated() bool

type DatabaseSubscriber Subscriber

func ProvideDatabaseSubscribers(
	notifyJoinMatch *usecase.CreateBattleCommand,
	startBattle *usecase.StartBattleCommand,
) []DatabaseSubscriber

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

func NewMatchChangedSubscriber(createBattle *usecase.CreateBattleCommand) *MatchChangedSubscriber

func (s *MatchChangedSubscriber) Handler(msg *message.Message) error

func (s *MatchChangedSubscriber) Name() string

func (s *MatchChangedSubscriber) Topic() string

type Subscriber interface {
	Name() string
	Topic() string
	Handler(*message.Message) error
}