base.go

package executor

import (
	"context"
	"io"

	"github.com/dstackai/dstack/runner/internal/schemas"
	"github.com/dstackai/dstack/runner/internal/types"
)

type Executor interface {
	GetHistory(timestamp int64) *schemas.PullResponse
	GetJobWsLogsHistory() []schemas.LogEvent
	GetRunnerState() string
	GetJobInfo(ctx context.Context) (username string, workingDir string, err error)
	Run(ctx context.Context) error
	SetJob(job schemas.SubmitBody)
	SetJobState(ctx context.Context, state types.JobState)
	SetJobStateWithTerminationReason(
		ctx context.Context,
		state types.JobState,
		terminationReason types.TerminationReason,
		terminationMessage string,
	)
	SetRunnerState(state string)
	WriteFileArchive(id string, src io.Reader) error
	WriteRepoBlob(src io.Reader) error
	Lock()
	RLock()
	RUnlock()
	Unlock()
}