consoleprint

Documentation

Overview

package consoleprint contains the logic to update the console UI

Index

• Constants
• func EnableStatusOutput()
• func ErrorPrint(msg string)
• func PrintState()
• func UpdateCollectionArgs(collectionArgs string)
• func UpdateCollectionMode(collectionMode string)
• func UpdateK8sFiles(fileName string)
• func UpdateNodeAutodetectDisabled(node string, enabled bool)
• func UpdateNodeState(nodeState NodeState)
• func UpdateResult(result string)
• func UpdateRuntime(ddcVersion, logFile, ddcYaml, collectionType string, enabled []string, ...)
• func UpdateTarballDir(tarballDir string)
• func WarningPrint(msg string)
• type CollectionStats
• type ErrorOut
• type NodeCaptureStats
• type NodeState
• type StatusUpdate
• type WarnOut

Constants

const (
	ResultPending = "PENDING"
	ResultFailure = "FAILURE"
)

const (
	Starting                   = "STARTING"
	CreatingRemoteDir          = "CREATING_REMOTE_DIR"
	CopyDDCToHost              = "COPY_DDC_TO_HOST"
	SettingDDCPermissions      = "SETTING_DDC_PERMISSIONS"
	CopyDDCYaml                = "COPY_DDC_YAML"
	Collecting                 = "COLLECTING"
	CollectingAwaitingTransfer = "COLLECTING_AWAITING_TRANSFER"
	TarballTransfer            = "TARBALL_TRANSFER"
	Completed                  = "COMPLETED"
	DiskUsage                  = "DISK_USAGE"
	DremioConfig               = "DREMIO_CONFIG"
	GcLog                      = "GC_LOG"
	Jfr                        = "JFR"
	Jstack                     = "JSTACK"
	JVMFlags                   = "JVM_FLAGS"
	MetadataLog                = "METADATA_LOG"
	OSConfig                   = "OS_CONFIG"
	Queries                    = "QUERIES"
	ReflectionLog              = "REFLECTION_LOG"
	ServerLog                  = "SERVER_LOG"
	Ttop                       = "TTOP"
	AccelerationLog            = "ACCELERATION_LOG"
	AccessLog                  = "ACCESS_LOG"
	AuditLog                   = "AUDIT_LOG"
	JobProfiles                = "JOB_PROFILES"
	KVStore                    = "KV_STORE"
	SystemTable                = "SYSTEM_TABLE"
	Wlm                        = "WLM"
	HeapDump                   = "HEAP_DUMP"
)

Functions

func EnableStatusOutput

func EnableStatusOutput()

func ErrorPrint

func ErrorPrint(msg string)

func PrintState

func PrintState()

func UpdateCollectionArgs

func UpdateCollectionArgs(collectionArgs string)

func UpdateCollectionMode

func UpdateCollectionMode(collectionMode string)

func UpdateK8sFiles

func UpdateK8sFiles(fileName string)

func UpdateNodeAutodetectDisabled

func UpdateNodeAutodetectDisabled(node string, enabled bool)

Update updates the CollectionStats fields in a thread-safe manner.

func UpdateNodeState

func UpdateNodeState(nodeState NodeState)

Update updates the CollectionStats fields in a thread-safe manner.

func UpdateResult

func UpdateResult(result string)

func UpdateRuntime

func UpdateRuntime(ddcVersion, logFile, ddcYaml, collectionType string, enabled []string, disabled []string, patSet bool, transfersComplete, totalTransfers int)

Update updates the CollectionStats fields in a thread-safe manner.

func UpdateTarballDir

func UpdateTarballDir(tarballDir string)

func WarningPrint

func WarningPrint(msg string)

Types

type CollectionStats

type CollectionStats struct {
	TransfersComplete int
	// contains filtered or unexported fields
}

CollectionStats represents stats for a collection.

type ErrorOut

type ErrorOut struct {
	Error string `json:"error"`
}

type NodeCaptureStats

type NodeCaptureStats struct {
	// contains filtered or unexported fields
}

NodeCaptureStats represents stats for a node capture.

type NodeState

type NodeState struct {
	Status     string `json:"status"`
	StatusUX   string `json:"status_ux"`
	Node       string `json:"node"`
	Message    string `json:"message"`
	Result     string `json:"result"`
	EndProcess bool   `json:"end_process"`
}

type StatusUpdate

type StatusUpdate struct {
	Result string `json:"result"`
}

type WarnOut

type WarnOut struct {
	Warning string `json:"warning"`
}