agent

Documentation

Index

• Constants
• Variables
• func CloneRepositoryForWorkspace(ctx context.Context, source *provider2.WorkspaceSource, ...) error
• func CreateAgentWorkspaceDir(agentFolder, context, workspaceID string) (string, error)
• func CreateWorkspaceBusyFile(folder string)
• func DecodeContainerWorkspaceInfo(workspaceInfoRaw string) (*provider2.ContainerWorkspaceInfo, string, error)
• func DecodeWorkspaceInfo(workspaceInfoRaw string) (*provider2.AgentWorkspaceInfo, string, error)
• func DefaultAgentDownloadURL() string
• func DeleteWorkspaceBusyFile(folder string)
• func FindAgentHomeFolder(agentFolder string) (string, error)
• func GetAgentBinariesDir(agentFolder, context, workspaceID string) (string, error)
• func GetAgentBinariesDirFromWorkspaceDir(workspaceDir string) (string, error)
• func GetAgentDaemonLogFolder(agentFolder string) (string, error)
• func GetAgentWorkspaceContentDir(workspaceDir string) string
• func GetAgentWorkspaceDir(agentFolder, context, workspaceID string) (string, error)
• func HasWorkspaceBusyFile(folder string) bool
• func InjectAgent(ctx context.Context, exec inject.ExecFunc, local bool, ...) error
• func InjectAgentAndExecute(ctx context.Context, exec inject.ExecFunc, local bool, ...) error
• func ParseAgentWorkspaceInfo(workspaceConfigFile string) (*provider2.AgentWorkspaceInfo, error)
• func PrepareAgentHomeFolder(agentFolder string) (string, error)
• func ReadAgentWorkspaceInfo(agentFolder, context, id string, log log.Logger) (bool, *provider2.AgentWorkspaceInfo, error)
• func Tunnel(ctx context.Context, exec Exec, user string, stdin io.Reader, stdout io.Writer, ...) error
• func WorkspaceInfo(workspaceInfoEncoded string, log log.Logger) (bool, *provider2.AgentWorkspaceInfo, error)
• func WriteWorkspaceInfo(workspaceInfoEncoded string, log log.Logger) (bool, *provider2.AgentWorkspaceInfo, error)
• func WriteWorkspaceInfoAndDeleteOld(workspaceInfoEncoded string, ...) (bool, *provider2.AgentWorkspaceInfo, error)
• type Exec

Constants

const ContainerActivityFile = "/tmp/devpod.activity"

const ContainerDevPodHelperLocation = "/usr/local/bin/devpod"

const DefaultInactivityTimeout = time.Minute * 20

const EnvDevPodAgentURL = "DEVPOD_AGENT_URL"

const RemoteDevPodHelperLocation = "/tmp/devpod"

const WorkspaceBusyFile = "workspace.lock"

Variables

var ErrFindAgentHomeFolder = fmt.Errorf("couldn't find devpod home directory")

Functions

func CloneRepositoryForWorkspace

func CloneRepositoryForWorkspace(
	ctx context.Context,
	source *provider2.WorkspaceSource,
	agentConfig *provider2.ProviderAgentConfig,
	workspaceDir, helper string,
	options provider2.CLIOptions,
	overwriteContent bool,
	log log.Logger,
) error

func CreateAgentWorkspaceDir

func CreateAgentWorkspaceDir(agentFolder, context, workspaceID string) (string, error)

func CreateWorkspaceBusyFile

func CreateWorkspaceBusyFile(folder string)

func DecodeContainerWorkspaceInfo

func DecodeContainerWorkspaceInfo(workspaceInfoRaw string) (*provider2.ContainerWorkspaceInfo, string, error)

func DecodeWorkspaceInfo

func DecodeWorkspaceInfo(workspaceInfoRaw string) (*provider2.AgentWorkspaceInfo, string, error)

func DefaultAgentDownloadURL

func DefaultAgentDownloadURL() string

func DeleteWorkspaceBusyFile

func DeleteWorkspaceBusyFile(folder string)

func FindAgentHomeFolder

func FindAgentHomeFolder(agentFolder string) (string, error)

func GetAgentBinariesDir

func GetAgentBinariesDir(agentFolder, context, workspaceID string) (string, error)

func GetAgentBinariesDirFromWorkspaceDir

func GetAgentBinariesDirFromWorkspaceDir(workspaceDir string) (string, error)

func GetAgentDaemonLogFolder

func GetAgentDaemonLogFolder(agentFolder string) (string, error)

func GetAgentWorkspaceContentDir

func GetAgentWorkspaceContentDir(workspaceDir string) string

func GetAgentWorkspaceDir

func GetAgentWorkspaceDir(agentFolder, context, workspaceID string) (string, error)

func HasWorkspaceBusyFile

func HasWorkspaceBusyFile(folder string) bool

func InjectAgent

func InjectAgent(
	ctx context.Context,
	exec inject.ExecFunc,
	local bool,
	remoteAgentPath,
	downloadURL string,
	preferDownload bool,
	log log.Logger,
	timeout time.Duration,
) error

func InjectAgentAndExecute

func InjectAgentAndExecute(
	ctx context.Context,
	exec inject.ExecFunc,
	local bool,
	remoteAgentPath,
	downloadURL string,
	preferDownload bool,
	command string,
	stdin io.Reader,
	stdout io.Writer,
	stderr io.Writer,
	log log.Logger,
	timeout time.Duration,
) error

func ParseAgentWorkspaceInfo

func ParseAgentWorkspaceInfo(workspaceConfigFile string) (*provider2.AgentWorkspaceInfo, error)

func PrepareAgentHomeFolder

func PrepareAgentHomeFolder(agentFolder string) (string, error)

func ReadAgentWorkspaceInfo

func ReadAgentWorkspaceInfo(agentFolder, context, id string, log log.Logger) (bool, *provider2.AgentWorkspaceInfo, error)

func Tunnel

func Tunnel(
	ctx context.Context,
	exec Exec,
	user string,
	stdin io.Reader,
	stdout io.Writer,
	stderr io.Writer,
	log log.Logger,
	timeout time.Duration,
) error

func WorkspaceInfo

func WorkspaceInfo(workspaceInfoEncoded string, log log.Logger) (bool, *provider2.AgentWorkspaceInfo, error)

func WriteWorkspaceInfo

func WriteWorkspaceInfo(workspaceInfoEncoded string, log log.Logger) (bool, *provider2.AgentWorkspaceInfo, error)

func WriteWorkspaceInfoAndDeleteOld

func WriteWorkspaceInfoAndDeleteOld(workspaceInfoEncoded string, deleteWorkspace func(workspaceInfo *provider2.AgentWorkspaceInfo, log log.Logger) error, log log.Logger) (bool, *provider2.AgentWorkspaceInfo, error)

Types

type Exec

type Exec func(ctx context.Context, user string, command string, stdin io.Reader, stdout io.Writer, stderr io.Writer) error