core

package

v1.0.0-rc.27 Latest Latest Go to latest Published: Dec 25, 2023 License: MIT Imports: 18 Imported by: 0

Details

This section is empty.

View Source

var ErrRequestedTooManyBots = errors.New("requested too many bots")

This section is empty.

type BotEngine interface {
	Run(ctx context.Context) <-chan types.Direction
}

type BotOperator interface {
	Run(ctx context.Context)
	Stop()
}

func NewBotOperator(params *BotOperatorParams) BotOperator

type BotOperatorFactory interface {
	New(gameId int) BotOperator
}

type BotOperatorParams struct {
	GameId    int
	Connector Connector
	BotEngine BotEngine
	Parser    Parser
	Rand      Rand
	Clock     utils.Clock
}

type Connector interface {
	Connect(ctx context.Context, gameId int) (connect.Connection, error)
}

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

func NewCore(params *CoreParams) *Core

func (c *Core) GetState(ctx context.Context) map[int]int

func (c *Core) Run(ctx context.Context)

func (c *Core) SetOne(ctx context.Context, gameId, bots int) (map[int]int, error)

func (c *Core) SetState(ctx context.Context, state map[int]int) (map[int]int, error)

type CoreParams struct {
	BotsLimit int
	BotOperatorFactory
	utils.Clock
	Storage
}

type DijkstrasBotOperatorFactory struct {
	Logger    *logrus.Entry
	Rand      Rand
	Connector Connector
	Clock     utils.Clock
}

func (f *DijkstrasBotOperatorFactory) New(gameId int) BotOperator

type Parser interface {
	Parse(message []byte) error
}

type Rand interface {
	Intn(n int) int
}

type Storage interface {
	Load(ctx context.Context) (map[int]int, error)
	Save(ctx context.Context, state map[int]int) error
	Type() string
}

func NewStorage(fs afero.Fs, cfg config.Storage) Storage

Path	Synopsis
corefakes Code generated by counterfeiter.	Code generated by counterfeiter.