services

Documentation

Index

• type APIClient
  • func NewAPICaller(ctx context.Context, cfg *config.Config, client *resty.Client) (*APIClient, error)
  • func (c *APIClient) Request(ctx context.Context, request domain.APIRequest) (contracts.APIResponse, error)
• type LocalCache
  • func NewLocalCache(_ *config.Config) (*LocalCache, error)
  • func (cache *LocalCache) Delete(_ context.Context, key string)
  • func (cache *LocalCache) Get(_ context.Context, key string)
  • func (cache *LocalCache) Set(_ context.Context, key string, val interface{}, ttl time.Duration)
• type LocalStore
  • func NewLocalStore(_ *config.Config) (*LocalStore, error)
  • func (store *LocalStore) Delete(_ context.Context, key string)
  • func (store *LocalStore) Get(_ context.Context, key string)
  • func (store *LocalStore) Set(_ context.Context, key string, val interface{})
• type NoopAPICaller
  • func (n *NoopAPICaller) Request(_ context.Context, _ domain.APIRequest) (contracts.APIResponse, error)
• type Runner
  • func NewProcessRunner(cfg *config.Config, executor contracts.Executor, ...) (*Runner, error)
  • func (r *Runner) EnableGRPCMode()
  • func (r *Runner) Init(ctx context.Context, cfg *config.Config) error
  • func (r *Runner) RunGDaemonServer(ctx context.Context, cfg *config.Config) func() error
  • func (r *Runner) RunGDaemonTaskScheduler(ctx context.Context, _ *config.Config) func() error
  • func (r *Runner) RunGRPCClient(ctx context.Context, cfg *config.Config) func() error
  • func (r *Runner) RunServerScheduler(ctx context.Context, cfg *config.Config) func() error
  • func (r *Runner) RunServersLoop(ctx context.Context, cfg *config.Config) func() error
  • func (r *Runner) RunServersLoopWithReporter(ctx context.Context, cfg *config.Config) func() error
  • func (r *Runner) SetGRPCComponents(connectionManager *grpcclient.ConnectionManager, ...)

Types

type APIClient

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

func NewAPICaller

func NewAPICaller(ctx context.Context, cfg *config.Config, client *resty.Client) (*APIClient, error)

func (*APIClient) Request

func (c *APIClient) Request(ctx context.Context, request domain.APIRequest) (contracts.APIResponse, error)

type LocalCache

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

func NewLocalCache

func NewLocalCache(_ *config.Config) (*LocalCache, error)

func (*LocalCache) Delete

func (cache *LocalCache) Delete(_ context.Context, key string)

func (*LocalCache) Get

func (cache *LocalCache) Get(_ context.Context, key string)

func (*LocalCache) Set

func (cache *LocalCache) Set(_ context.Context, key string, val interface{}, ttl time.Duration)

type LocalStore

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

func NewLocalStore

func NewLocalStore(_ *config.Config) (*LocalStore, error)

func (*LocalStore) Delete

func (store *LocalStore) Delete(_ context.Context, key string)

func (*LocalStore) Get

func (store *LocalStore) Get(_ context.Context, key string)

func (*LocalStore) Set

func (store *LocalStore) Set(_ context.Context, key string, val interface{})

type NoopAPICaller

type NoopAPICaller struct{}

NoopAPICaller is a stub APIRequestMaker used in gRPC mode where the HTTP API is not needed.

func (*NoopAPICaller) Request

func (n *NoopAPICaller) Request(_ context.Context, _ domain.APIRequest) (contracts.APIResponse, error)

type Runner

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

func NewProcessRunner

func NewProcessRunner(
	cfg *config.Config,
	executor contracts.Executor,
	commandFactory *gameservercommands.ServerCommandFactory,
	apiClient contracts.APIRequestMaker,
	gdTaskManager *gdaemonscheduler.TaskManager,
	serverRepository domain.ServerRepository,
	serverTaskRepository domain.ServerTaskRepository,
) (*Runner, error)

func (*Runner) EnableGRPCMode

func (r *Runner) EnableGRPCMode()

func (*Runner) Init

func (r *Runner) Init(ctx context.Context, cfg *config.Config) error

func (*Runner) RunGDaemonServer

func (r *Runner) RunGDaemonServer(ctx context.Context, cfg *config.Config) func() error

func (*Runner) RunGDaemonTaskScheduler

func (r *Runner) RunGDaemonTaskScheduler(ctx context.Context, _ *config.Config) func() error

func (*Runner) RunGRPCClient

func (r *Runner) RunGRPCClient(ctx context.Context, cfg *config.Config) func() error

func (*Runner) RunServerScheduler

func (r *Runner) RunServerScheduler(ctx context.Context, cfg *config.Config) func() error

func (*Runner) RunServersLoop

func (r *Runner) RunServersLoop(ctx context.Context, cfg *config.Config) func() error

func (*Runner) RunServersLoopWithReporter

func (r *Runner) RunServersLoopWithReporter(ctx context.Context, cfg *config.Config) func() error

func (*Runner) SetGRPCComponents

func (r *Runner) SetGRPCComponents(
	connectionManager *grpcclient.ConnectionManager,
	statusReporter *grpcclient.ServerStatusReporter,
)