management

type ClientEvent struct {
	Type ClientEventType `json:"type,omitempty"`
	// contains filtered or unexported fields
}

type ClientEventType string

type EventLog struct {
	ServerEvent
	Logs []*Log `json:"logs"`
}

type EventStartStreaming struct {
	ClientEvent
	Filters *StreamingFilters `json:"filters,omitempty"`
}

type EventStopStreaming struct {
	ClientEvent
}

type Log struct {
	Time    string                 `json:"time,omitempty"`
	Level   LogLevel               `json:"level,omitempty"`
	Message string                 `json:"message,omitempty"`
	Event   LogEventType           `json:"event,omitempty"`
	Fields  map[string]interface{} `json:"fields,omitempty"`
}

type LogEventType int8

type LogLevel int8

type Logger struct {

	// Unique logger that isn't a io.Writer of the list of zerolog writers. This helps prevent management log
	// statements from creating infinite recursion to export messages to a session and allows basic debugging and
	// error statements to be issued in the management code itself.
	Log *zerolog.Logger
	// contains filtered or unexported fields
}

type LoggerListener interface {
	// ActiveSession returns the first active session for the requested actor.
	ActiveSession(actor) *session
	// ActiveSession returns the count of active sessions.
	ActiveSessions() int
	// Listen appends the session to the list of sessions that receive log events.
	Listen(*session)
	// Remove a session from the available sessions that were receiving log events.
	Remove(*session)
}

type ManagementService struct {
	// The management tunnel hostname
	Hostname string
	// contains filtered or unexported fields
}

type ServerEvent struct {
	Type ServerEventType `json:"type,omitempty"`
	// contains filtered or unexported fields
}

type ServerEventType string

type StreamingFilters struct {
	Events   []LogEventType `json:"events,omitempty"`
	Level    *LogLevel      `json:"level,omitempty"`
	Sampling float64        `json:"sampling,omitempty"`
}