service

Documentation

Index

• Variables
• type CharactersUpdatesBarrier
  • func NewCharactersUpdatesBarrier(logger *zerolog.Logger, producer events.LoadBalancerProducer, ...) *CharactersUpdatesBarrier
  • func (b *CharactersUpdatesBarrier) Run(ctx context.Context)
  • func (b *CharactersUpdatesBarrier) UpdateLevel(charGUID uint64, lvl uint8)
  • func (b *CharactersUpdatesBarrier) UpdateMap(charGUID uint64, mapID uint32)
  • func (b *CharactersUpdatesBarrier) UpdateZone(charGUID uint64, area, zone uint32)
• type GameServerGRPCConnMgr
  • func NewGameServerGRPCConnMgr() GameServerGRPCConnMgr
• type Listener
  • func NewChatNatsListener(nc *nats.Conn, lbID string, broadcaster eBroadcaster.Broadcaster) Listener
  • func NewGroupNatsListener(nc *nats.Conn, broadcaster eBroadcaster.Broadcaster) Listener
  • func NewGuildNatsListener(nc *nats.Conn, broadcaster eBroadcaster.Broadcaster) Listener
  • func NewMailNatsListener(nc *nats.Conn, broadcaster eBroadcaster.Broadcaster) Listener

Variables

var DefaultGameServerGRPCConnMgr = NewGameServerGRPCConnMgr()

Types

type CharactersUpdatesBarrier

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

func NewCharactersUpdatesBarrier

func NewCharactersUpdatesBarrier(logger *zerolog.Logger, producer events.LoadBalancerProducer, barrierOpenTime time.Duration) *CharactersUpdatesBarrier

func (*CharactersUpdatesBarrier) Run

func (b *CharactersUpdatesBarrier) Run(ctx context.Context)

func (*CharactersUpdatesBarrier) UpdateLevel

func (b *CharactersUpdatesBarrier) UpdateLevel(charGUID uint64, lvl uint8)

func (*CharactersUpdatesBarrier) UpdateMap

func (b *CharactersUpdatesBarrier) UpdateMap(charGUID uint64, mapID uint32)

func (*CharactersUpdatesBarrier) UpdateZone

func (b *CharactersUpdatesBarrier) UpdateZone(charGUID uint64, area, zone uint32)

type GameServerGRPCConnMgr

type GameServerGRPCConnMgr interface {
	AddAddressMapping(gameServerAddress, grpcServerAddress string)
	GRPCConnByGameServerAddress(address string) (conn pb.WorldServerServiceClient, err error)
}

func NewGameServerGRPCConnMgr

func NewGameServerGRPCConnMgr() GameServerGRPCConnMgr

type Listener

type Listener interface {
	Listen() error
	Stop() error
}

func NewChatNatsListener

func NewChatNatsListener(nc *nats.Conn, lbID string, broadcaster eBroadcaster.Broadcaster) Listener

func NewGroupNatsListener

func NewGroupNatsListener(nc *nats.Conn, broadcaster eBroadcaster.Broadcaster) Listener

func NewGuildNatsListener

func NewGuildNatsListener(nc *nats.Conn, broadcaster eBroadcaster.Broadcaster) Listener

func NewMailNatsListener

func NewMailNatsListener(nc *nats.Conn, broadcaster eBroadcaster.Broadcaster) Listener