portwatermill

Documentation

Index

• type EnnoblementConsumer
  • func NewEnnoblementConsumer(svc *app.EnnoblementService, subscriber message.Subscriber, ...) *EnnoblementConsumer
  • func (c *EnnoblementConsumer) Register(router *message.Router)
• type PlayerConsumer
  • func NewPlayerConsumer(svc *app.PlayerService, snapshotSvc *app.PlayerSnapshotService, ...) *PlayerConsumer
  • func (c *PlayerConsumer) Register(router *message.Router)
• type ServerConsumer
  • func NewServerConsumer(svc *app.ServerService, snapshotSvc *app.ServerSnapshotService, ...) *ServerConsumer
  • func (c *ServerConsumer) Register(router *message.Router)
• type TribeConsumer
  • func NewTribeConsumer(svc *app.TribeService, snapshotSvc *app.TribeSnapshotService, ...) *TribeConsumer
  • func (c *TribeConsumer) Register(router *message.Router)
• type VillageConsumer
  • func NewVillageConsumer(svc *app.VillageService, subscriber message.Subscriber, ...) *VillageConsumer
  • func (c *VillageConsumer) Register(router *message.Router)

Types

type EnnoblementConsumer

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

func NewEnnoblementConsumer

func NewEnnoblementConsumer(
	svc *app.EnnoblementService,
	subscriber message.Subscriber,
	logger watermill.LoggerAdapter,
	marshaler watermillmsg.Marshaler,
	cmdSyncTopic string,
	cmdCleanUpTopic string,
) *EnnoblementConsumer

func (*EnnoblementConsumer) Register

func (c *EnnoblementConsumer) Register(router *message.Router)

type PlayerConsumer

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

func NewPlayerConsumer

func NewPlayerConsumer(
	svc *app.PlayerService,
	snapshotSvc *app.PlayerSnapshotService,
	subscriber message.Subscriber,
	logger watermill.LoggerAdapter,
	marshaler watermillmsg.Marshaler,
	eventServerSyncedTopic string,
	cmdCreateSnapshotsTopic string,
	cmdCleanUpTopic string,
) *PlayerConsumer

func (*PlayerConsumer) Register

func (c *PlayerConsumer) Register(router *message.Router)

type ServerConsumer

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

func NewServerConsumer

func NewServerConsumer(
	svc *app.ServerService,
	snapshotSvc *app.ServerSnapshotService,
	subscriber message.Subscriber,
	logger watermill.LoggerAdapter,
	marshaler watermillmsg.Marshaler,
	cmdSyncTopic string,
	cmdCreateSnapshotsTopic string,
	eventServerSyncedTopic string,
	eventTribesSyncedTopic string,
	eventPlayersSyncedTopic string,
	eventVillagesSyncedTopic string,
	eventEnnoblementsSyncedTopic string,
	eventTribeSnapshotsCreatedTopic string,
	eventPlayerSnapshotsCreatedTopic string,
) *ServerConsumer

func (*ServerConsumer) Register

func (c *ServerConsumer) Register(router *message.Router)

type TribeConsumer

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

func NewTribeConsumer

func NewTribeConsumer(
	svc *app.TribeService,
	snapshotSvc *app.TribeSnapshotService,
	subscriber message.Subscriber,
	logger watermill.LoggerAdapter,
	marshaler watermillmsg.Marshaler,
	eventServerSyncedTopic string,
	eventVillagesSyncedTopic string,
	cmdCreateSnapshotsTopic string,
	cmdCleanUpTopic string,
) *TribeConsumer

func (*TribeConsumer) Register

func (c *TribeConsumer) Register(router *message.Router)

type VillageConsumer

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

func NewVillageConsumer

func NewVillageConsumer(
	svc *app.VillageService,
	subscriber message.Subscriber,
	logger watermill.LoggerAdapter,
	marshaler watermillmsg.Marshaler,
	eventServerSyncedTopic string,
) *VillageConsumer

func (*VillageConsumer) Register

func (c *VillageConsumer) Register(router *message.Router)