Versions in this module Expand all Collapse all v0 v0.2.0 Oct 3, 2026 v0.1.0 Oct 1, 2026 Changes in this version + const KVMinColWidth + const ShutdownTimeout + var DimStyle = lipgloss.NewStyle().Foreground(Gray) + var Gray = lipgloss.Color("245") + var Green = lipgloss.Color("#67ea94") + var LightGray = lipgloss.Color("241") + var Purple = lipgloss.Color("99") + var Red = lipgloss.Color("#ef4444") + var Teal = lipgloss.Color("#06ffa5") + var White = lipgloss.Color("15") + var Yellow = lipgloss.Color("222") + func BoolToSafeString(b *bool) string + func BuildAuditStreamConfig(namespace string, auditCfg config.NATSAudit) jetstream.StreamConfig + func BuildEnrollmentKVConfig(namespace string, enrollmentCfg config.NATSEnrollment) jetstream.KeyValueConfig + func BuildFactsKVConfig(namespace string, factsCfg config.NATSFacts) jetstream.KeyValueConfig + func BuildFileStateKVConfig(namespace string, fileStateCfg config.NATSFileState) jetstream.KeyValueConfig + func BuildJobKVConfig(namespace string, kvCfg config.NATSKV) jetstream.KeyValueConfig + func BuildNATSAuthOptions(auth config.NATSAuth) natsclient.AuthOptions + func BuildObjectStoreConfig(namespace string, objectsCfg config.NATSObjects) jetstream.ObjectStoreConfig + func BuildRegistryKVConfig(namespace string, registryCfg config.NATSRegistry) jetstream.KeyValueConfig + func BuildResponseKVConfig(namespace string, kvCfg config.NATSKV) jetstream.KeyValueConfig + func BuildStateKVConfig(namespace string, stateCfg config.NATSState) jetstream.KeyValueConfig + func CalculateColumnWidths(headers []string, rows [][]string, minPadding int) []int + func CloseNATSClient(nc natsCloser) + func DisplayJobDetail(resp *client.JobDetail) + func Float64ToSafeString(f *float64) string + func FormatAge(d time.Duration) string + func FormatBytes(b int) string + func FormatLabels(labels map[string]string) string + func FormatList(list []string) string + func GetMaxLineWidth(text string) int + func HandleError(err error, logger *slog.Logger) + func IntToSafeString(i *int) string + func IsOSFamilySupported(distro string, version string) (string, bool) + func LogFatal(logger *slog.Logger, message string, err error, kvPairs ...any) + func MaxExitCode(results []RawResult) int + func ParseJetstreamStorageType(s string) jetstream.StorageType + func PrintCompactTable(sections []Section) + func PrintErrors(errors []ErrorEntry) + func PrintKV(pairs ...string) + func PrintRawOutput(stdout io.Writer, stderr io.Writer, results []RawResult, showStdout bool, ...) + func PrintRawOutputPlain(stdout io.Writer, stderr io.Writer, results []RawResult, showStdout bool, ...) + func RunServer(ctx context.Context, server Lifecycle, cleanupFns ...func(context.Context)) + func SafeString(s *string) string + func SafeUUID(u *uuid.UUID) string + func ValidateDistribution(logger *slog.Logger) + type ErrorEntry struct + Hostname string + Message string + Status string + type Lifecycle interface + Start func() + Stop func(ctx context.Context) + type OSFamily struct + Distributions map[string][]string + Name string + type RawResult struct + ExitCode int + Hostname string + Stderr string + Stdout string + type ResultRow struct + Changed *bool + Error *string + Fields []string + Hostname string + Status string + type Section struct + Duration string + Errors []ErrorEntry + Headers []string + Rows [][]string + Title string + type TableResult struct + Errors []ErrorEntry + Headers []string + Rows [][]string + func BuildBroadcastTable(results []ResultRow, fieldHeaders []string) TableResult + func BuildMutationTable(results []ResultRow, fieldHeaders []string) TableResult
Go to main page