consumer

Documentation

Index

• type Consumer
  • func NewNatsEventsConsumer(nc *nats.Conn, guildHandlersFabric GuildHandlersFabric, ...) Consumer
• type GroupHandlersFabric
• type GuildHandlersFabric
• type ServerRegistryHandlerFabric

Types

type Consumer

type Consumer interface {
	Start() error
	Stop() error
}

func NewNatsEventsConsumer

func NewNatsEventsConsumer(
	nc *nats.Conn,
	guildHandlersFabric GuildHandlersFabric,
	groupHandlersFabric GroupHandlersFabric,
	serverRegistryHandlersFabric ServerRegistryHandlerFabric,
	queue queue.HandlersQueue,
	realmID uint32,
) Consumer

type GroupHandlersFabric

type GroupHandlersFabric interface {
	GroupCreated(payload *events.GroupEventGroupCreatedPayload) queue.Handler
	GroupMemberAdded(payload *events.GroupEventGroupMemberAddedPayload) queue.Handler
	GroupMemberRemoved(payload *events.GroupEventGroupMemberLeftPayload) queue.Handler
	GroupDisbanded(payload *events.GroupEventGroupDisbandPayload) queue.Handler
	GroupLootTypeChanged(payload *events.GroupEventGroupLootTypeChangedPayload) queue.Handler
	GroupDifficultyChanged(payload *events.GroupEventGroupDifficultyChangedPayload) queue.Handler
	GroupConvertedToRaid(payload *events.GroupEventGroupConvertedToRaidPayload) queue.Handler
}

type GuildHandlersFabric

type GuildHandlersFabric interface {
	GuildMemberAddedHandler(guildID, characterGUID uint64) queue.Handler
	GuildMemberRemovedHandler(guildID, characterGUID uint64) queue.Handler
	GuildMemberLeftHandler(guildID, characterGUID uint64) queue.Handler
}

type ServerRegistryHandlerFabric

type ServerRegistryHandlerFabric interface {
	GameServerMapsReassigned(payload *events.ServerRegistryEventGSMapsReassignedPayload) queue.Handler
}