nomad

Documentation

Index

• func CloseWebSocket(ws *websocket.Conn) tea.Cmd
• func FetchAllocSpec(url, token, allocID string) tea.Cmd
• func FetchAllocations(url, token, jobID, jobNamespace string) tea.Cmd
• func FetchEventsStream(url, token, topics, namespace string) tea.Cmd
• func FetchJobSpec(url, token, jobID, jobNamespace string) tea.Cmd
• func FetchJobs(url, token string) tea.Cmd
• func FetchLogs(url, token, allocID, taskName string, logType LogType, logOffset int) 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(r *bufio.Reader) 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 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, eventTopics, eventNamespace string) string
  • func (p Page) LoadingString() string
  • func (p Page) String() string
• type PageLoadedMsg
• type PersistentConnection
• type UpdatePageDataMsg

Functions

func CloseWebSocket

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

func FetchAllocSpec

func FetchAllocSpec(url, token, allocID string) tea.Cmd

func FetchAllocations

func FetchAllocations(url, token, jobID, jobNamespace string) tea.Cmd

func FetchEventsStream

func FetchEventsStream(url, token, topics, namespace string) tea.Cmd

func FetchJobSpec

func FetchJobSpec(url, token, jobID, jobNamespace string) tea.Cmd

func FetchJobs

func FetchJobs(url, token string) tea.Cmd

func FetchLogs

func FetchLogs(url, token, allocID, 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) 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(r *bufio.Reader) 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 {
	AllocID, TaskName string
	Running           bool
}

func AllocationInfoFromKey

func AllocationInfoFromKey(key string) (AllocationInfo, error)

type EventsStreamMsg

type EventsStreamMsg struct {
	Value  string
	Closed bool
}

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
	EventsPage
	EventPage
	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, eventTopics, 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  PersistentConnection
}

type PersistentConnection

type PersistentConnection struct {
	Reader *bufio.Reader
	Body   io.ReadCloser
}

type UpdatePageDataMsg

type UpdatePageDataMsg struct {
	ID   int
	Page Page
}