runnerinterface

Documentation

Index

• type RunnerContainer
• type RunnerExposedPort
• type RunnerInterface
  • func (ri *RunnerInterface) ForwardHttp(workspace *models.Workspace, container *models.WorkspaceContainer, ...) error
  • func (ri *RunnerInterface) ForwardSsh(workspace *models.Workspace, container *models.WorkspaceContainer, ...) error
  • func (ri *RunnerInterface) ForwardTcpPort(workspace *models.Workspace, container *models.WorkspaceContainer, ...) error
  • func (ri *RunnerInterface) GetDetails(workspace *models.Workspace) (response RunnerWorkspaceStatusResponse, err error)
  • func (ri *RunnerInterface) GetLogs(workspace *models.Workspace) (logs string, err error)
  • func (ri *RunnerInterface) GetRunnerVersion() (version string, err error)
  • func (ri *RunnerInterface) PingAgent(container *models.WorkspaceContainer) bool
  • func (ri *RunnerInterface) RemoveWorkspace(workspace *models.Workspace) error
  • func (ri *RunnerInterface) StartWorkspace(workspace *models.Workspace) (err error)
  • func (ri *RunnerInterface) StopWorkpace(workspace *models.Workspace) error
• type RunnerWorkspaceStatusResponse

Types

type RunnerContainer

type RunnerContainer struct {
	ID                string              `json:"id"`
	Name              string              `json:"name"`
	State             string              `json:"state"`
	Image             string              `json:"image"`
	ContainerUserID   string              `json:"container_user"`
	ContainerUserName string              `json:"container_user_name"`
	ExposedPorts      []RunnerExposedPort `json:"exposed_ports"`
	WorkspacePath     string              `json:"workspace_path"`
}

type RunnerExposedPort

type RunnerExposedPort struct {
	PortNumber  int    `json:"port_number"`
	ServiceName string `json:"service_name"`
	Public      bool   `json:"public"`
}

type RunnerInterface

type RunnerInterface struct {
	Runner *models.Runner
}

func (*RunnerInterface) ForwardHttp

func (ri *RunnerInterface) ForwardHttp(
	workspace *models.Workspace,
	container *models.WorkspaceContainer,
	port *models.WorkspaceContainerPort,
	path string,
	rw http.ResponseWriter,
	req *http.Request,
) error

func (*RunnerInterface) ForwardSsh

func (ri *RunnerInterface) ForwardSsh(
	workspace *models.Workspace,
	container *models.WorkspaceContainer,
	rw http.ResponseWriter,
	req *http.Request,
) error

func (*RunnerInterface) ForwardTcpPort

func (ri *RunnerInterface) ForwardTcpPort(
	workspace *models.Workspace,
	container *models.WorkspaceContainer,
	rw http.ResponseWriter,
	req *http.Request,
	port uint,
) error

func (*RunnerInterface) GetDetails

func (ri *RunnerInterface) GetDetails(workspace *models.Workspace) (response RunnerWorkspaceStatusResponse, err error)

func (*RunnerInterface) GetLogs

func (ri *RunnerInterface) GetLogs(workspace *models.Workspace) (logs string, err error)

func (*RunnerInterface) GetRunnerVersion

func (ri *RunnerInterface) GetRunnerVersion() (version string, err error)

func (*RunnerInterface) PingAgent

func (ri *RunnerInterface) PingAgent(container *models.WorkspaceContainer) bool

func (*RunnerInterface) RemoveWorkspace

func (ri *RunnerInterface) RemoveWorkspace(workspace *models.Workspace) error

func (*RunnerInterface) StartWorkspace

func (ri *RunnerInterface) StartWorkspace(workspace *models.Workspace) (err error)

func (*RunnerInterface) StopWorkpace

func (ri *RunnerInterface) StopWorkpace(workspace *models.Workspace) error

type RunnerWorkspaceStatusResponse

type RunnerWorkspaceStatusResponse struct {
	Status     string            `json:"status"`
	Containers []RunnerContainer `json:"containers"`
}