runtime

Documentation

Index

• type BotRunner
• type QueuedBot
• type RuntimeService
  • func NewRuntimeService(maxBots int) (*RuntimeService, error)
  • func NewRuntimeServiceWithRunner(runner BotRunner, maxBots int) *RuntimeService
  • func (s *RuntimeService) GetRuntimeStats(ctx context.Context, req *pb.Empty) (*pb.RuntimeStats, error)
  • func (s *RuntimeService) StartBot(ctx context.Context, req *pb.StartBotRequest) (*pb.StartBotResponse, error)
  • func (s *RuntimeService) StopBot(ctx context.Context, req *pb.StopBotRequest) (*pb.StopBotResponse, error)
• type Scheduler
  • func NewScheduler(runner BotRunner, maxBots int) *Scheduler
  • func (s *Scheduler) GetActiveCount() int
  • func (s *Scheduler) GetQueueSize() int
  • func (s *Scheduler) NotifyStop(botID string)
  • func (s *Scheduler) StartBot(ctx context.Context, botID, image, matchID string, env []string) (string, bool, int, error)

Types

type BotRunner

type BotRunner interface {
	StartContainer(ctx context.Context, image string, botID string, env []string) (string, error)
	StopContainer(ctx context.Context, containerID string) error
	CountActiveContainers(ctx context.Context) (int, error)
}

type QueuedBot

type QueuedBot struct {
	ID    string
	Image string
	Env   []string
	Match string
}

type RuntimeService

type RuntimeService struct {
	pb.UnimplementedRuntimeServiceServer
	// contains filtered or unexported fields
}

func NewRuntimeService

func NewRuntimeService(maxBots int) (*RuntimeService, error)

func NewRuntimeServiceWithRunner

func NewRuntimeServiceWithRunner(runner BotRunner, maxBots int) *RuntimeService

func (*RuntimeService) GetRuntimeStats

func (s *RuntimeService) GetRuntimeStats(ctx context.Context, req *pb.Empty) (*pb.RuntimeStats, error)

func (*RuntimeService) StartBot

func (s *RuntimeService) StartBot(ctx context.Context, req *pb.StartBotRequest) (*pb.StartBotResponse, error)

func (*RuntimeService) StopBot

func (s *RuntimeService) StopBot(ctx context.Context, req *pb.StopBotRequest) (*pb.StopBotResponse, error)

type Scheduler

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

func NewScheduler

func NewScheduler(runner BotRunner, maxBots int) *Scheduler

func (*Scheduler) GetActiveCount

func (s *Scheduler) GetActiveCount() int

func (*Scheduler) GetQueueSize

func (s *Scheduler) GetQueueSize() int

func (*Scheduler) NotifyStop

func (s *Scheduler) NotifyStop(botID string)

func (*Scheduler) StartBot

func (s *Scheduler) StartBot(ctx context.Context, botID, image, matchID string, env []string) (string, bool, int, error)