adapter

package

Go to main page

Versions in this module

v1

v1.0.0

Apr 6, 2024

Changes in this version

+ type DataCleanupPublisher struct

+ func NewDataCleanupPublisher(publisher message.Publisher, marshaler watermillmsg.Marshaler, ...) *DataCleanupPublisher

+ func (pub *DataCleanupPublisher) CmdCleanUp(ctx context.Context, payloads ...domain.CleanUpDataCmdPayload) error

type EnnoblementBunRepository

+ func (repo *EnnoblementBunRepository) ListWithRelations(ctx context.Context, params domain.ListEnnoblementsParams) (domain.ListEnnoblementsWithRelationsResult, error)

type EnnoblementWatermillPublisher

+ func (pub *EnnoblementWatermillPublisher) CmdSync(ctx context.Context, payloads ...domain.SyncEnnoblementsCmdPayload) error

+ func (pub *EnnoblementWatermillPublisher) EventSynced(ctx context.Context, payloads ...domain.EnnoblementsSyncedEventPayload) error

type PlayerBunRepository

+ func (repo *PlayerBunRepository) ListWithRelations(ctx context.Context, params domain.ListPlayersParams) (domain.ListPlayersWithRelationsResult, error)

type PlayerSnapshotBunRepository

+ func (repo *PlayerSnapshotBunRepository) ListWithRelations(ctx context.Context, params domain.ListPlayerSnapshotsParams) (domain.ListPlayerSnapshotsWithRelationsResult, error)

+ type PlayerWatermillPublisher struct

+ func NewPlayerWatermillPublisher(publisher message.Publisher, marshaler watermillmsg.Marshaler, ...) *PlayerWatermillPublisher

+ func (pub *PlayerWatermillPublisher) EventSynced(ctx context.Context, payloads ...domain.PlayersSyncedEventPayload) error

type ServerWatermillPublisher

+ func (pub *ServerWatermillPublisher) CmdSync(ctx context.Context, payloads ...domain.SyncServersCmdPayload) error

+ func (pub *ServerWatermillPublisher) EventSynced(ctx context.Context, payloads ...domain.ServerSyncedEventPayload) error

type SnapshotWatermillPublisher

+ func (pub *SnapshotWatermillPublisher) CmdCreate(ctx context.Context, payloads ...domain.CreateSnapshotsCmdPayload) error

+ func (pub *SnapshotWatermillPublisher) EventCreated(ctx context.Context, payloads ...domain.SnapshotsCreatedEventPayload) error

type TribeChangeBunRepository

+ func (repo *TribeChangeBunRepository) ListWithRelations(ctx context.Context, params domain.ListTribeChangesParams) (domain.ListTribeChangesWithRelationsResult, error)

type TribeSnapshotBunRepository

+ func (repo *TribeSnapshotBunRepository) ListWithRelations(ctx context.Context, params domain.ListTribeSnapshotsParams) (domain.ListTribeSnapshotsWithRelationsResult, error)

+ type TribeWatermillPublisher struct

+ func NewTribeWatermillPublisher(publisher message.Publisher, marshaler watermillmsg.Marshaler, ...) *TribeWatermillPublisher

+ func (pub *TribeWatermillPublisher) EventSynced(ctx context.Context, payloads ...domain.TribesSyncedEventPayload) error

type VillageBunRepository

+ func (repo *VillageBunRepository) Delete(ctx context.Context, serverKey string, ids ...int) error

+ func (repo *VillageBunRepository) ListWithRelations(ctx context.Context, params domain.ListVillagesParams) (domain.ListVillagesWithRelationsResult, error)

+ type VillageWatermillPublisher struct

+ func NewVillageWatermillPublisher(publisher message.Publisher, marshaler watermillmsg.Marshaler, ...) *VillageWatermillPublisher

+ func (pub *VillageWatermillPublisher) EventSynced(ctx context.Context, payloads ...domain.VillagesSyncedEventPayload) error

v0

v0.13.4

Oct 30, 2023

v0.13.3

Sep 9, 2023

v0.13.2

Jul 22, 2023

Changes in this version

+ type BunChecker struct

+ func NewBunChecker(db *bun.DB) *BunChecker

+ func (c *BunChecker) Check(ctx context.Context) error

+ func (c *BunChecker) Name() string

+ type EnnoblementBunRepository struct

+ func NewEnnoblementBunRepository(db *bun.DB) *EnnoblementBunRepository

+ func (e *EnnoblementBunRepository) Create(ctx context.Context, params ...domain.CreateEnnoblementParams) error

+ func (e *EnnoblementBunRepository) Delete(ctx context.Context, serverKey string, createdAtLTE time.Time) error

+ func (e *EnnoblementBunRepository) List(ctx context.Context, params domain.ListEnnoblementsParams) ([]domain.Ennoblement, error)

+ func (e *EnnoblementBunRepository) ListCountWithRelations(ctx context.Context, params domain.ListEnnoblementsParams) ([]domain.EnnoblementWithRelations, int64, error)

+ type EnnoblementWatermillPublisher struct

+ func NewEnnoblementWatermillPublisher(publisher message.Publisher, marshaler WatermillMarshaler) *EnnoblementWatermillPublisher

+ func (e *EnnoblementWatermillPublisher) CmdRefresh(ctx context.Context, payloads ...domain.RefreshEnnoblementsCmdPayload) error

+ type JSONWatermillMarshaler struct

+ NewUUID func() string

+ func (m JSONWatermillMarshaler) Marshal(v any) (*message.Message, error)

+ func (m JSONWatermillMarshaler) Unmarshal(msg *message.Message, v any) error

+ type PlayerBunRepository struct

+ func NewPlayerBunRepository(db *bun.DB) *PlayerBunRepository

+ func (p *PlayerBunRepository) CreateOrUpdate(ctx context.Context, params ...domain.CreatePlayerParams) error

+ func (p *PlayerBunRepository) Delete(ctx context.Context, serverKey string, ids ...int64) error

+ func (p *PlayerBunRepository) List(ctx context.Context, params domain.ListPlayersParams) ([]domain.Player, error)

+ func (p *PlayerBunRepository) ListCountWithRelations(ctx context.Context, params domain.ListPlayersParams) ([]domain.PlayerWithRelations, int64, error)

+ type PlayerSnapshotBunRepository struct

+ func NewPlayerSnapshotBunRepository(db *bun.DB) *PlayerSnapshotBunRepository

+ func (p *PlayerSnapshotBunRepository) Create(ctx context.Context, params ...domain.CreatePlayerSnapshotParams) error

+ func (p *PlayerSnapshotBunRepository) Delete(ctx context.Context, serverKey string, createdAtLTE time.Time) error

+ func (p *PlayerSnapshotBunRepository) List(ctx context.Context, params domain.ListPlayerSnapshotsParams) ([]domain.PlayerSnapshot, error)

+ func (p *PlayerSnapshotBunRepository) ListCountWithRelations(ctx context.Context, params domain.ListPlayerSnapshotsParams) ([]domain.PlayerSnapshotWithRelations, int64, error)

+ type ServerBunRepository struct

+ func NewServerBunRepository(db *bun.DB) *ServerBunRepository

+ func (s *ServerBunRepository) CreateOrUpdate(ctx context.Context, params ...domain.CreateServerParams) ([]domain.Server, error)

+ func (s *ServerBunRepository) List(ctx context.Context, params domain.ListServersParams) ([]domain.Server, error)

+ func (s *ServerBunRepository) ListCount(ctx context.Context, params domain.ListServersParams) ([]domain.Server, int64, error)

+ func (s *ServerBunRepository) Update(ctx context.Context, key string, params domain.UpdateServerParams) (domain.Server, error)

+ type ServerWatermillPublisher struct

+ func NewServerWatermillPublisher(publisher message.Publisher, marshaler WatermillMarshaler) *ServerWatermillPublisher

+ func (s *ServerWatermillPublisher) CmdRefresh(ctx context.Context, payloads ...domain.RefreshServersCmdPayload) error

+ type SnapshotWatermillPublisher struct

+ func NewSnapshotWatermillPublisher(publisher message.Publisher, marshaler WatermillMarshaler) *SnapshotWatermillPublisher

+ func (s *SnapshotWatermillPublisher) CmdCreatePlayers(ctx context.Context, payloads ...domain.CreateSnapshotsCmdPayload) error

+ func (s *SnapshotWatermillPublisher) CmdCreateTribes(ctx context.Context, payloads ...domain.CreateSnapshotsCmdPayload) error

+ type TWHTTPClient struct

+ func NewTWHTTPClient(client *tw.Client) *TWHTTPClient

+ func (t *TWHTTPClient) GetBuildingInfo(ctx context.Context, baseURL string) (domain.BuildingInfo, error)

+ func (t *TWHTTPClient) GetEnnoblements(ctx context.Context, baseURL string, since time.Time) ([]domain.BaseEnnoblement, error)

+ func (t *TWHTTPClient) GetOpenServers(ctx context.Context, baseURL string) ([]domain.OpenServer, error)

+ func (t *TWHTTPClient) GetPlayers(ctx context.Context, baseURL string) ([]domain.BasePlayer, error)

+ func (t *TWHTTPClient) GetServerConfig(ctx context.Context, baseURL string) (domain.ServerConfig, error)

+ func (t *TWHTTPClient) GetTribes(ctx context.Context, baseURL string) ([]domain.BaseTribe, error)

+ func (t *TWHTTPClient) GetUnitInfo(ctx context.Context, baseURL string) (domain.UnitInfo, error)

+ func (t *TWHTTPClient) GetVillages(ctx context.Context, baseURL string) ([]domain.BaseVillage, error)

+ type TribeBunRepository struct

+ func NewTribeBunRepository(db *bun.DB) *TribeBunRepository

+ func (t *TribeBunRepository) CreateOrUpdate(ctx context.Context, params ...domain.CreateTribeParams) error

+ func (t *TribeBunRepository) Delete(ctx context.Context, serverKey string, ids ...int64) error

+ func (t *TribeBunRepository) List(ctx context.Context, params domain.ListTribesParams) ([]domain.Tribe, error)

+ func (t *TribeBunRepository) ListCount(ctx context.Context, params domain.ListTribesParams) ([]domain.Tribe, int64, error)

+ func (t *TribeBunRepository) UpdateDominance(ctx context.Context, serverKey string, numPlayerVillages int64) error

+ type TribeChangeBunRepository struct

+ func NewTribeChangeBunRepository(db *bun.DB) *TribeChangeBunRepository

+ func (t *TribeChangeBunRepository) Create(ctx context.Context, params ...domain.CreateTribeChangeParams) error

+ func (t *TribeChangeBunRepository) List(ctx context.Context, params domain.ListTribeChangesParams) ([]domain.TribeChange, error)

+ func (t *TribeChangeBunRepository) ListCountWithRelations(ctx context.Context, params domain.ListTribeChangesParams) ([]domain.TribeChangeWithRelations, int64, error)

+ type TribeSnapshotBunRepository struct

+ func NewTribeSnapshotBunRepository(db *bun.DB) *TribeSnapshotBunRepository

+ func (t *TribeSnapshotBunRepository) Create(ctx context.Context, params ...domain.CreateTribeSnapshotParams) error

+ func (t *TribeSnapshotBunRepository) Delete(ctx context.Context, serverKey string, createdAtLTE time.Time) error

+ func (t *TribeSnapshotBunRepository) List(ctx context.Context, params domain.ListTribeSnapshotsParams) ([]domain.TribeSnapshot, error)

+ func (t *TribeSnapshotBunRepository) ListCount(ctx context.Context, params domain.ListTribeSnapshotsParams) ([]domain.TribeSnapshot, int64, error)

+ type VersionBunRepository struct

+ func NewVersionBunRepository(db *bun.DB) *VersionBunRepository

+ func (v *VersionBunRepository) GetByCode(ctx context.Context, code string) (domain.Version, error)

+ func (v *VersionBunRepository) List(ctx context.Context) ([]domain.Version, error)

+ func (v *VersionBunRepository) ListCount(ctx context.Context) ([]domain.Version, int64, error)

+ type VillageBunRepository struct

+ func NewVillageBunRepository(db *bun.DB) *VillageBunRepository

+ func (v *VillageBunRepository) CreateOrUpdate(ctx context.Context, params ...domain.CreateVillageParams) error

+ func (v *VillageBunRepository) List(ctx context.Context, params domain.ListVillagesParams) ([]domain.Village, error)

+ func (v *VillageBunRepository) ListCountWithRelations(ctx context.Context, params domain.ListVillagesParams) ([]domain.VillageWithRelations, int64, error)

+ type WatermillMarshaler interface

+ Marshal func(v any) (*message.Message, error)

+ Unmarshal func(msg *message.Message, v any) error

v0.13.1

Jul 20, 2023

Changes in this version

+ type CheckerBun struct

+ func NewCheckerBun(db *bun.DB) *CheckerBun

+ func (c *CheckerBun) Check(ctx context.Context) error

+ func (c *CheckerBun) Name() string

+ type EnnoblementBun struct

+ func NewEnnoblementBun(db *bun.DB) *EnnoblementBun

+ func (e *EnnoblementBun) Create(ctx context.Context, params ...domain.CreateEnnoblementParams) error

+ func (e *EnnoblementBun) Delete(ctx context.Context, serverKey string, createdAtLTE time.Time) error

+ func (e *EnnoblementBun) List(ctx context.Context, params domain.ListEnnoblementsParams) ([]domain.Ennoblement, error)

+ func (e *EnnoblementBun) ListCountWithRelations(ctx context.Context, params domain.ListEnnoblementsParams) ([]domain.EnnoblementWithRelations, int64, error)

+ type PlayerBun struct

+ func NewPlayerBun(db *bun.DB) *PlayerBun

+ func (p *PlayerBun) CreateOrUpdate(ctx context.Context, params ...domain.CreatePlayerParams) error

+ func (p *PlayerBun) Delete(ctx context.Context, serverKey string, ids ...int64) error

+ func (p *PlayerBun) List(ctx context.Context, params domain.ListPlayersParams) ([]domain.Player, error)

+ func (p *PlayerBun) ListCountWithRelations(ctx context.Context, params domain.ListPlayersParams) ([]domain.PlayerWithRelations, int64, error)

+ type PlayerSnapshotBun struct

+ func NewPlayerSnapshotBun(db *bun.DB) *PlayerSnapshotBun

+ func (p *PlayerSnapshotBun) Create(ctx context.Context, params ...domain.CreatePlayerSnapshotParams) error

+ func (p *PlayerSnapshotBun) Delete(ctx context.Context, serverKey string, createdAtLTE time.Time) error

+ func (p *PlayerSnapshotBun) List(ctx context.Context, params domain.ListPlayerSnapshotsParams) ([]domain.PlayerSnapshot, error)

+ func (p *PlayerSnapshotBun) ListCountWithRelations(ctx context.Context, params domain.ListPlayerSnapshotsParams) ([]domain.PlayerSnapshotWithRelations, int64, error)

+ type ServerBun struct

+ func NewServerBun(db *bun.DB) *ServerBun

+ func (s *ServerBun) CreateOrUpdate(ctx context.Context, params ...domain.CreateServerParams) ([]domain.Server, error)

+ func (s *ServerBun) List(ctx context.Context, params domain.ListServersParams) ([]domain.Server, error)

+ func (s *ServerBun) ListCount(ctx context.Context, params domain.ListServersParams) ([]domain.Server, int64, error)

+ func (s *ServerBun) Update(ctx context.Context, key string, params domain.UpdateServerParams) (domain.Server, error)

+ type TWHTTP struct

+ func NewTWHTTP(client *tw.Client) *TWHTTP

+ func (t *TWHTTP) GetBuildingInfo(ctx context.Context, baseURL string) (domain.BuildingInfo, error)

+ func (t *TWHTTP) GetEnnoblements(ctx context.Context, baseURL string, since time.Time) ([]domain.BaseEnnoblement, error)

+ func (t *TWHTTP) GetOpenServers(ctx context.Context, baseURL string) ([]domain.OpenServer, error)

+ func (t *TWHTTP) GetPlayers(ctx context.Context, baseURL string) ([]domain.BasePlayer, error)

+ func (t *TWHTTP) GetServerConfig(ctx context.Context, baseURL string) (domain.ServerConfig, error)

+ func (t *TWHTTP) GetTribes(ctx context.Context, baseURL string) ([]domain.BaseTribe, error)

+ func (t *TWHTTP) GetUnitInfo(ctx context.Context, baseURL string) (domain.UnitInfo, error)

+ func (t *TWHTTP) GetVillages(ctx context.Context, baseURL string) ([]domain.BaseVillage, error)

+ type TribeBun struct

+ func NewTribeBun(db *bun.DB) *TribeBun

+ func (t *TribeBun) CreateOrUpdate(ctx context.Context, params ...domain.CreateTribeParams) error

+ func (t *TribeBun) Delete(ctx context.Context, serverKey string, ids ...int64) error

+ func (t *TribeBun) List(ctx context.Context, params domain.ListTribesParams) ([]domain.Tribe, error)

+ func (t *TribeBun) ListCount(ctx context.Context, params domain.ListTribesParams) ([]domain.Tribe, int64, error)

+ func (t *TribeBun) UpdateDominance(ctx context.Context, serverKey string, numPlayerVillages int64) error

+ type TribeChangeBun struct

+ func NewTribeChangeBun(db *bun.DB) *TribeChangeBun

+ func (t *TribeChangeBun) Create(ctx context.Context, params ...domain.CreateTribeChangeParams) error

+ func (t *TribeChangeBun) List(ctx context.Context, params domain.ListTribeChangesParams) ([]domain.TribeChange, error)

+ func (t *TribeChangeBun) ListCountWithRelations(ctx context.Context, params domain.ListTribeChangesParams) ([]domain.TribeChangeWithRelations, int64, error)

+ type TribeSnapshotBun struct

+ func NewTribeSnapshotBun(db *bun.DB) *TribeSnapshotBun

+ func (t *TribeSnapshotBun) Create(ctx context.Context, params ...domain.CreateTribeSnapshotParams) error

+ func (t *TribeSnapshotBun) Delete(ctx context.Context, serverKey string, createdAtLTE time.Time) error

+ func (t *TribeSnapshotBun) List(ctx context.Context, params domain.ListTribeSnapshotsParams) ([]domain.TribeSnapshot, error)

+ func (t *TribeSnapshotBun) ListCount(ctx context.Context, params domain.ListTribeSnapshotsParams) ([]domain.TribeSnapshot, int64, error)

+ type VersionBun struct

+ func NewVersionBun(db *bun.DB) *VersionBun

+ func (v *VersionBun) GetByCode(ctx context.Context, code string) (domain.Version, error)

+ func (v *VersionBun) List(ctx context.Context) ([]domain.Version, error)

+ func (v *VersionBun) ListCount(ctx context.Context) ([]domain.Version, int64, error)

+ type VillageBun struct

+ func NewVillageBun(db *bun.DB) *VillageBun

+ func (v *VillageBun) CreateOrUpdate(ctx context.Context, params ...domain.CreateVillageParams) error

+ func (v *VillageBun) List(ctx context.Context, params domain.ListVillagesParams) ([]domain.Village, error)

+ func (v *VillageBun) ListCountWithRelations(ctx context.Context, params domain.ListVillagesParams) ([]domain.VillageWithRelations, int64, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL