run

Documentation

Index

• Variables
• func GetRunLogs(ctx context.Context, jobId string) ([]tlApi.PodLogs, error)
• func GetTopLogs(logs []tlApi.PodLogs, pat *regexp.Regexp, count int) []string
• func PrintLogs(logs []tlApi.PodLogs)
• func WrapLogsInTarFile(logs []tlApi.PodLogs, output string, defaultFileName string) (string, error)
• type LogsPageContent
  • func (l *LogsPageContent) Init() tea.Cmd
  • func (l *LogsPageContent) Update(msg tea.Msg) (tea.Model, tea.Cmd)
  • func (l *LogsPageContent) View() string
• type RunEntity
  • func GetRuns(ctx context.Context, subTypes []tensorleapapi.JobSubType, ...) ([]RunEntity, error)

Variables

var RunEntityDesc = entity.NewEntityDescriptor(
	"run",
	"runs",
	func(r *RunEntity) string {
		createdAt, err := api.ParseAndFormatDateToLocalTime(r.GetCreatedAt())

		if err != nil {
			return fmt.Sprintf("%s \t %s \t %s", r.GetJobType(), r.GetCreatedAt(), r.GetStatus())
		}
		return fmt.Sprintf("%s \t %s \t %s", r.GetJobType(), createdAt, r.GetStatus())
	},
	func(r *RunEntity) string { return r.GetJobId() },
)

Functions

func GetRunLogs

func GetRunLogs(ctx context.Context, jobId string) ([]tlApi.PodLogs, error)

func GetTopLogs

func GetTopLogs(logs []tlApi.PodLogs, pat *regexp.Regexp, count int) []string

func PrintLogs

func PrintLogs(logs []tlApi.PodLogs)

func WrapLogsInTarFile

func WrapLogsInTarFile(logs []tlApi.PodLogs, output string, defaultFileName string) (string, error)

Types

type LogsPageContent

type LogsPageContent struct {
	Logs []string
}

func (*LogsPageContent) Init

func (l *LogsPageContent) Init() tea.Cmd

func (*LogsPageContent) Update

func (l *LogsPageContent) Update(msg tea.Msg) (tea.Model, tea.Cmd)

func (*LogsPageContent) View

func (l *LogsPageContent) View() string

type RunEntity

type RunEntity = tensorleapapi.RunProcess

func GetRuns

func GetRuns(ctx context.Context, subTypes []tensorleapapi.JobSubType, statuses []tensorleapapi.JobStatus, projectId string) ([]RunEntity, error)