service

Documentation

Index

• func Register() error
• type RunnerClientService
  • func NewRunnerClientService() *RunnerClientService
  • func (r *RunnerClientService) DockerPull(ctx context.Context, runner *model.Runner, image string)
  • func (r *RunnerClientService) DockerRun(ctx context.Context, runner *model.Runner, image string)
  • func (r *RunnerClientService) Exec(ctx context.Context, taskName string, ip string, port int, shell string, ...) (string, error)
  • func (r *RunnerClientService) FetchRunnerConfig(ctx context.Context, runner *model.Runner) (string, error)
• type RunnerService
  • func NewRunnerService() *RunnerService
  • func (r *RunnerService) FindById(ctx context.Context, id int64) (*model.Runner, error)
  • func (r *RunnerService) FindDisableRunners(ctx context.Context) ([]*model.Runner, error)
  • func (r *RunnerService) FindEnableRunners(ctx context.Context) ([]*model.Runner, error)
  • func (r *RunnerService) FindRunnersByEnable(ctx context.Context, enable bool) ([]*model.Runner, error)
  • func (r *RunnerService) PickOneEnableRunner(ctx context.Context) (*model.Runner, error)
• type Service
  • func NewService(runnerService *RunnerService, runnerClientService *RunnerClientService) *Service

Functions

func Register

func Register() error

Types

type RunnerClientService

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

func NewRunnerClientService

func NewRunnerClientService() *RunnerClientService

func (*RunnerClientService) DockerPull

func (r *RunnerClientService) DockerPull(ctx context.Context, runner *model.Runner, image string)

func (*RunnerClientService) DockerRun

func (r *RunnerClientService) DockerRun(ctx context.Context, runner *model.Runner, image string)

func (*RunnerClientService) Exec

func (r *RunnerClientService) Exec(ctx context.Context, taskName string, ip string, port int, shell string, timeoutSecond int) (string, error)

func (*RunnerClientService) FetchRunnerConfig

func (r *RunnerClientService) FetchRunnerConfig(ctx context.Context, runner *model.Runner) (string, error)

type RunnerService

type RunnerService struct {
}

func NewRunnerService

func NewRunnerService() *RunnerService

func (*RunnerService) FindById

func (r *RunnerService) FindById(ctx context.Context, id int64) (*model.Runner, error)

func (*RunnerService) FindDisableRunners

func (r *RunnerService) FindDisableRunners(ctx context.Context) ([]*model.Runner, error)

func (*RunnerService) FindEnableRunners

func (r *RunnerService) FindEnableRunners(ctx context.Context) ([]*model.Runner, error)

func (*RunnerService) FindRunnersByEnable

func (r *RunnerService) FindRunnersByEnable(ctx context.Context, enable bool) ([]*model.Runner, error)

func (*RunnerService) PickOneEnableRunner

func (r *RunnerService) PickOneEnableRunner(ctx context.Context) (*model.Runner, error)

type Service

type Service struct {
	RunnerService       *RunnerService
	RunnerClientService *RunnerClientService
}

var Services *Service

func NewService

func NewService(runnerService *RunnerService, runnerClientService *RunnerClientService) *Service