port

Documentation

Index

• func NewAPIHTTPHandler(versionSvc *app.VersionService, serverSvc *app.ServerService, ...) http.Handler
• func NewMetaHTTPHandler(h *health.Health) http.Handler
• type APIHTTPHandlerOption
  • func WithOpenAPIConfig(oapiCfg OpenAPIConfig) APIHTTPHandlerOption
• type EnnoblementWatermillConsumer
  • func NewEnnoblementWatermillConsumer(svc *app.EnnoblementService, subscriber message.Subscriber, ...) *EnnoblementWatermillConsumer
  • func (c *EnnoblementWatermillConsumer) Register(router *message.Router)
• type OpenAPIConfig
• type OpenAPIConfigServer
• type PlayerWatermillConsumer
  • func NewPlayerWatermillConsumer(svc *app.PlayerService, snapshotSvc *app.PlayerSnapshotService, ...) *PlayerWatermillConsumer
  • func (c *PlayerWatermillConsumer) Register(router *message.Router)
• type ServerWatermillConsumer
  • func NewServerWatermillConsumer(svc *app.ServerService, snapshotSvc *app.ServerSnapshotService, ...) *ServerWatermillConsumer
  • func (c *ServerWatermillConsumer) Register(router *message.Router)
• type TribeWatermillConsumer
  • func NewTribeWatermillConsumer(svc *app.TribeService, snapshotSvc *app.TribeSnapshotService, ...) *TribeWatermillConsumer
  • func (c *TribeWatermillConsumer) Register(router *message.Router)
• type VillageWatermillConsumer
  • func NewVillageWatermillConsumer(svc *app.VillageService, subscriber message.Subscriber, ...) *VillageWatermillConsumer
  • func (c *VillageWatermillConsumer) Register(router *message.Router)

Functions

func NewAPIHTTPHandler

func NewAPIHTTPHandler(
	versionSvc *app.VersionService,
	serverSvc *app.ServerService,
	tribeSvc *app.TribeService,
	playerSvc *app.PlayerService,
	villageSvc *app.VillageService,
	ennoblementSvc *app.EnnoblementService,
	tribeChangeSvc *app.TribeChangeService,
	tribeSnapshotSvc *app.TribeSnapshotService,
	playerSnapshotSvc *app.PlayerSnapshotService,
	opts ...APIHTTPHandlerOption,
) http.Handler

func NewMetaHTTPHandler

func NewMetaHTTPHandler(h *health.Health) http.Handler

Types

type APIHTTPHandlerOption

type APIHTTPHandlerOption func(cfg *apiHTTPHandlerConfig)

func WithOpenAPIConfig

func WithOpenAPIConfig(oapiCfg OpenAPIConfig) APIHTTPHandlerOption

type EnnoblementWatermillConsumer

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

func NewEnnoblementWatermillConsumer

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

func (*EnnoblementWatermillConsumer) Register

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

type OpenAPIConfig

type OpenAPIConfig struct {
	Enabled        bool
	SwaggerEnabled bool
	BasePath       string
	Servers        []OpenAPIConfigServer
}

type OpenAPIConfigServer

type OpenAPIConfigServer struct {
	URL *url.URL
}

type PlayerWatermillConsumer

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

func NewPlayerWatermillConsumer

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

func (*PlayerWatermillConsumer) Register

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

type ServerWatermillConsumer

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

func NewServerWatermillConsumer

func NewServerWatermillConsumer(
	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,
) *ServerWatermillConsumer

func (*ServerWatermillConsumer) Register

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

type TribeWatermillConsumer

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

func NewTribeWatermillConsumer

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

func (*TribeWatermillConsumer) Register

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

type VillageWatermillConsumer

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

func NewVillageWatermillConsumer

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

func (*VillageWatermillConsumer) Register

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