Documentation
¶
Index ¶
- func GetFileExtension(logFormat types.LogFormat) string
- func GetFormatDescription(logFormat types.LogFormat) string
- type BackgroundStreamer
- func (bs *BackgroundStreamer) GetProcessByID(id string) (*types.BackgroundProcess, bool)
- func (bs *BackgroundStreamer) GetProcesses() []types.BackgroundProcess
- func (bs *BackgroundStreamer) RemoveStoppedProcess(id string) error
- func (bs *BackgroundStreamer) StartProcess(id, name string, logFormat types.LogFormat, interval types.StreamInterval, ...) error
- func (bs *BackgroundStreamer) StopAllProcesses()
- func (bs *BackgroundStreamer) StopProcess(id string) error
- type Logger
- type XMLMetric
- type YAMLMetric
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetFileExtension ¶
func GetFormatDescription ¶
Types ¶
type BackgroundStreamer ¶
type BackgroundStreamer struct {
// contains filtered or unexported fields
}
BackgroundStreamer manages background streaming processes
func NewBackgroundStreamer ¶
func NewBackgroundStreamer(hostInfo *host.InfoStat) *BackgroundStreamer
NewBackgroundStreamer creates a new background streamer
func (*BackgroundStreamer) GetProcessByID ¶
func (bs *BackgroundStreamer) GetProcessByID(id string) (*types.BackgroundProcess, bool)
GetProcessByID returns a process by its ID
func (*BackgroundStreamer) GetProcesses ¶
func (bs *BackgroundStreamer) GetProcesses() []types.BackgroundProcess
GetProcesses returns a copy of all processes
func (*BackgroundStreamer) RemoveStoppedProcess ¶
func (bs *BackgroundStreamer) RemoveStoppedProcess(id string) error
RemoveStoppedProcess removes a stopped process from the manager
func (*BackgroundStreamer) StartProcess ¶
func (bs *BackgroundStreamer) StartProcess(id, name string, logFormat types.LogFormat, interval types.StreamInterval, logPath string) error
StartProcess starts a new background streaming process
func (*BackgroundStreamer) StopAllProcesses ¶
func (bs *BackgroundStreamer) StopAllProcesses()
StopAllProcesses stops all background streaming processes
func (*BackgroundStreamer) StopProcess ¶
func (bs *BackgroundStreamer) StopProcess(id string) error
StopProcess stops a background streaming process
type Logger ¶
type Logger struct {
// contains filtered or unexported fields
}
func (*Logger) StopStreaming ¶
func (*Logger) WriteMetricsToLogs ¶
func (l *Logger) WriteMetricsToLogs(metrics types.MetricsMsg, logFormat types.LogFormat)
Click to show internal directories.
Click to hide internal directories.