runner

Documentation

Index

• func CreateRunnerGroupServer(ctx context.Context, kubeconfigPath string, runnerImage string, ...) error
• func DeleteRunnerGroupServer(_ context.Context, kubeconfigPath string) error
• func GetRunnerGroupResult(ctx context.Context, kubecfgPath string, wait bool) (*types.RunnerGroupsReport, error)
• func ListRunnerGroups(ctx context.Context, kubeCfgPath string) ([]*types.RunnerGroup, error)
• type RunCmdOpt
  • func WithRunCmdRunnerGroupFlowControl(priorityLevel string, matchingPrecedence int) RunCmdOpt
  • func WithRunCmdServerNodeSelectorsOpt(labels map[string][]string) RunCmdOpt
• type Server
  • func NewServer(dataDir string, addrs []string, groups ...*group.Handler) (*Server, error)
  • func (s *Server) Run() error

Functions

func CreateRunnerGroupServer

func CreateRunnerGroupServer(ctx context.Context,
	kubeconfigPath string,
	runnerImage string,
	rgSpec *types.RunnerGroupSpec,
	opts ...RunCmdOpt,
) error

CreateRunnerGroupServer creates a long running server to deploy runner groups.

TODO: 1. create a new package to define ErrNotFound, ErrAlreadyExists, ... errors. 2. support configurable timeout.

func DeleteRunnerGroupServer

func DeleteRunnerGroupServer(_ context.Context, kubeconfigPath string) error

DeleteRunnerGroupServer delete existing long running server.

func GetRunnerGroupResult

func GetRunnerGroupResult(ctx context.Context, kubecfgPath string, wait bool) (*types.RunnerGroupsReport, error)

GetRunnerGroupResult gets runner group's aggregated report.

func ListRunnerGroups

func ListRunnerGroups(ctx context.Context, kubeCfgPath string) ([]*types.RunnerGroup, error)

ListRunnerGroups lists RunnerGroups from server.

Types

type RunCmdOpt

type RunCmdOpt func(*runCmdConfig)

RunCmdOpt is used to update default run command's setting.

func WithRunCmdRunnerGroupFlowControl

func WithRunCmdRunnerGroupFlowControl(priorityLevel string, matchingPrecedence int) RunCmdOpt

WithRunCmdRunnerGroupFlowControl updates runner groups' flowcontrol.

func WithRunCmdServerNodeSelectorsOpt

func WithRunCmdServerNodeSelectorsOpt(labels map[string][]string) RunCmdOpt

WithRunCmdServerNodeSelectorsOpt updates server's node selectors.

type Server

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

Server is to deploy runner groups and expose endpoints for runner report.

func NewServer

func NewServer(dataDir string, addrs []string, groups ...*group.Handler) (*Server, error)

NewServer returns new instance of server.

func (*Server) Run

func (s *Server) Run() error

Run is to expose endpoints.