monitor

Documentation

Index

• func PluralizeResourceType(resourceType string) string
• func StreamBuildLogs(resp *http.Response, onLog func(string)) error
• type BuildLogWatcher
  • func NewBuildLogWatcher(client *blaxel.Client, workspace, resourceType, resourceName string, ...) *BuildLogWatcher
  • func (w *BuildLogWatcher) Start()
  • func (w *BuildLogWatcher) Stop()
• type LogEntry
• type LogFetcher
  • func NewLogFetcher(client *blaxel.Client, workspace, resourceType, resourceName string, ...) *LogFetcher
  • func (lf *LogFetcher) FetchLogs() ([]LogEntry, error)
• type LogFollower
  • func NewLogFollower(client *blaxel.Client, workspace, resourceType, resourceName string, ...) *LogFollower
  • func (lf *LogFollower) Start()
  • func (lf *LogFollower) Stop()

Functions

func PluralizeResourceType

func PluralizeResourceType(resourceType string) string

PluralizeResourceType converts singular resource types to plural

func StreamBuildLogs

func StreamBuildLogs(resp *http.Response, onLog func(string)) error

StreamBuildLogs streams build logs from an HTTP response

Types

type BuildLogWatcher

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

BuildLogWatcher watches build logs for a resource

func NewBuildLogWatcher

func NewBuildLogWatcher(client *blaxel.Client, workspace, resourceType, resourceName string, onLog func(string)) *BuildLogWatcher

NewBuildLogWatcher creates a new build log watcher

func (*BuildLogWatcher) Start

func (w *BuildLogWatcher) Start()

Start begins watching build logs

func (*BuildLogWatcher) Stop

func (w *BuildLogWatcher) Stop()

Stop stops watching build logs

type LogEntry

type LogEntry struct {
	Timestamp string
	Message   string
}

LogEntry represents a single log entry with timestamp

type LogFetcher

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

LogFetcher fetches logs for a resource with custom time ranges

func NewLogFetcher

func NewLogFetcher(client *blaxel.Client, workspace, resourceType, resourceName string, startTime, endTime time.Time, severity, search, taskID, executionID string) *LogFetcher

NewLogFetcher creates a new log fetcher

func (*LogFetcher) FetchLogs

func (lf *LogFetcher) FetchLogs() ([]LogEntry, error)

FetchLogs fetches logs for the configured time range

type LogFollower

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

LogFollower follows logs in real-time

func NewLogFollower

func NewLogFollower(client *blaxel.Client, workspace, resourceType, resourceName string, startTime time.Time, severity, search, taskID, executionID string, onLog func(LogEntry), onError func(error), onInfo func(string)) *LogFollower

NewLogFollower creates a new log follower

func (*LogFollower) Start

func (lf *LogFollower) Start()

Start begins following logs

func (*LogFollower) Stop

func (lf *LogFollower) Stop()

Stop stops following logs