nomad

Documentation

Index

• func CloseWebSocket(ws *websocket.Conn) tea.Cmd
• func FetchAllocSpec(client api.Client, allocID string) tea.Cmd
• func FetchAllocations(client api.Client, jobID, jobNamespace string) tea.Cmd
• func FetchEventsStream(client api.Client, topics Topics, namespace string, page Page) tea.Cmd
• func FetchJobSpec(client api.Client, jobID, jobNamespace string) tea.Cmd
• func FetchJobs(client api.Client) tea.Cmd
• func FetchLogs(client api.Client, alloc api.Allocation, taskName string, logType LogType, ...) tea.Cmd
• func GetAllPageConfigs(width, height int, copySavePath bool) map[Page]page.Config
• func GetKeypress(msg tea.KeyMsg) (keypress string)
• func GetPageKeyHelp(currentPage Page, ...) string
• func InitiateWebSocket(host, token, allocID, taskName, command string) tea.Cmd
• func JobIDAndNamespaceFromKey(key string) (string, string)
• func LoadExecPage() tea.Cmd
• func PrettifyLine(l string, p Page) tea.Cmd
• func ReadEventsStreamNextMessage(c EventsStream, code *gojq.Code) tea.Cmd
• func ReadExecWebSocketNextMessage(ws *websocket.Conn) tea.Cmd
• func ResizeTty(ws *websocket.Conn, width, height int) tea.Cmd
• func SendHeartbeat(ws *websocket.Conn) tea.Cmd
• func SendHeartbeatWithDelay() tea.Cmd
• func SendWebSocketMessage(ws *websocket.Conn, keyPress string) tea.Cmd
• func UpdatePageDataWithDelay(id int, p Page, d time.Duration) tea.Cmd
• type AllocationInfo
  • func AllocationInfoFromKey(key string) (AllocationInfo, error)
• type EventsStream
• type EventsStreamMsg
• type ExecWebSocketConnectedMsg
• type ExecWebSocketHeartbeatMsg
• type ExecWebSocketResponseMsg
• type LogType
  • func (p LogType) ShortString() string
  • func (p LogType) String() string
• type Page
  • func (p Page) Backward() Page
  • func (p Page) DoesLoad() bool
  • func (p Page) DoesReload() bool
  • func (p Page) Forward() Page
  • func (p Page) GetFilterPrefix(jobID, taskName, allocID string, eventTopics Topics, eventNamespace string) string
  • func (p Page) LoadingString() string
  • func (p Page) String() string
• type PageLoadedMsg
• type Topics
  • func TopicsForAlloc(topics Topics, allocID string) Topics
  • func TopicsForJob(topics Topics, job string) Topics
• type UpdatePageDataMsg

Functions

func CloseWebSocket

func CloseWebSocket(ws *websocket.Conn) tea.Cmd

func FetchAllocSpec

func FetchAllocSpec(client api.Client, allocID string) tea.Cmd

func FetchAllocations

func FetchAllocations(client api.Client, jobID, jobNamespace string) tea.Cmd

func FetchEventsStream

func FetchEventsStream(client api.Client, topics Topics, namespace string, page Page) tea.Cmd

func FetchJobSpec

func FetchJobSpec(client api.Client, jobID, jobNamespace string) tea.Cmd

func FetchJobs

func FetchJobs(client api.Client) tea.Cmd

func FetchLogs

func FetchLogs(client api.Client, alloc api.Allocation, taskName string, logType LogType, logOffset int) tea.Cmd

func GetAllPageConfigs

func GetAllPageConfigs(width, height int, copySavePath bool) map[Page]page.Config

func GetKeypress

func GetKeypress(msg tea.KeyMsg) (keypress string)

func GetPageKeyHelp

func GetPageKeyHelp(currentPage Page, filterFocused, filterApplied, saving, enteringInput, inPty, webSocketConnected bool, logType LogType) string

func InitiateWebSocket

func InitiateWebSocket(host, token, allocID, taskName, command string) tea.Cmd

func JobIDAndNamespaceFromKey

func JobIDAndNamespaceFromKey(key string) (string, string)

func LoadExecPage

func LoadExecPage() tea.Cmd

func PrettifyLine

func PrettifyLine(l string, p Page) tea.Cmd

func ReadEventsStreamNextMessage

func ReadEventsStreamNextMessage(c EventsStream, code *gojq.Code) tea.Cmd

func ReadExecWebSocketNextMessage

func ReadExecWebSocketNextMessage(ws *websocket.Conn) tea.Cmd

func ResizeTty

func ResizeTty(ws *websocket.Conn, width, height int) tea.Cmd

func SendHeartbeat

func SendHeartbeat(ws *websocket.Conn) tea.Cmd

func SendHeartbeatWithDelay

func SendHeartbeatWithDelay() tea.Cmd

func SendWebSocketMessage

func SendWebSocketMessage(ws *websocket.Conn, keyPress string) tea.Cmd

func UpdatePageDataWithDelay

func UpdatePageDataWithDelay(id int, p Page, d time.Duration) tea.Cmd

Types

type AllocationInfo

type AllocationInfo struct {
	Alloc    api.Allocation
	TaskName string
	Running  bool
}

func AllocationInfoFromKey

func AllocationInfoFromKey(key string) (AllocationInfo, error)

type EventsStream

type EventsStream struct {
	Chan      <-chan *api.Events
	Topics    Topics
	Namespace string
}

type EventsStreamMsg

type EventsStreamMsg struct {
	CompleteValue string
	JQValue       string
	Topics        Topics
}

type ExecWebSocketConnectedMsg

type ExecWebSocketConnectedMsg struct {
	WebSocketConnection *websocket.Conn
}

type ExecWebSocketHeartbeatMsg

type ExecWebSocketHeartbeatMsg struct{}

type ExecWebSocketResponseMsg

type ExecWebSocketResponseMsg struct {
	StdOut, StdErr string
	Close          bool
}

type LogType

type LogType int8

const (
	StdOut LogType = iota
	StdErr
)

func (LogType) ShortString

func (p LogType) ShortString() string

func (LogType) String

func (p LogType) String() string

type Page

type Page int8

const (
	Unset Page = iota
	JobsPage
	JobSpecPage
	JobEventsPage
	JobEventPage
	AllocEventsPage
	AllocEventPage
	AllEventsPage
	AllEventPage
	AllocationsPage
	ExecPage
	AllocSpecPage
	LogsPage
	LoglinePage
)

func (Page) Backward

func (p Page) Backward() Page

func (Page) DoesLoad

func (p Page) DoesLoad() bool

func (Page) DoesReload

func (p Page) DoesReload() bool

func (Page) Forward

func (p Page) Forward() Page

func (Page) GetFilterPrefix

func (p Page) GetFilterPrefix(jobID, taskName, allocID string, eventTopics Topics, eventNamespace string) string

func (Page) LoadingString

func (p Page) LoadingString() string

func (Page) String

func (p Page) String() string

type PageLoadedMsg

type PageLoadedMsg struct {
	Page        Page
	TableHeader []string
	AllPageRows []page.Row
	Connection  EventsStream
}

type Topics

type Topics map[api.Topic][]string

func TopicsForAlloc

func TopicsForAlloc(topics Topics, allocID string) Topics

func TopicsForJob

func TopicsForJob(topics Topics, job string) Topics

type UpdatePageDataMsg

type UpdatePageDataMsg struct {
	ID   int
	Page Page
}