tembo

Documentation

Index

• func GetSystemState(ctx context.Context, server *state.Server, logger *util.Logger) (system state.SystemState)
• func SetupWebsocketHandlerLogs(ctx context.Context, wg *sync.WaitGroup, logger *util.Logger, ...)
• type Data
• type JSONLogEvent
• type Metric
• type MetricResult
• type Response
• type StreamMetadata
• type StreamResult
• type StreamSet

Functions

func GetSystemState

func GetSystemState(ctx context.Context, server *state.Server, logger *util.Logger) (system state.SystemState)

GetSystemState - Gets system information for a Tembo Cloud instance

func SetupWebsocketHandlerLogs

func SetupWebsocketHandlerLogs(ctx context.Context, wg *sync.WaitGroup, logger *util.Logger, servers []*state.Server, globalCollectionOpts state.CollectionOpts, parsedLogStream chan state.ParsedLogStreamItem)

SetupWebsocketHandlerLogs - Sets up a websocket handler for Tembo logs

Types

type Data

type Data struct {
	ResultType string         `json:"resultType"`
	Result     []MetricResult `json:"result"`
}

type JSONLogEvent

type JSONLogEvent struct {
	Record map[string]string `json:"record"`
}

type Metric

type Metric struct {
	Name                  string `json:"__name__"`
	Endpoint              string `json:"endpoint"`
	Instance              string `json:"instance"`
	Job                   string `json:"job"`
	MetricsPath           string `json:"metrics_path"`
	Namespace             string `json:"namespace"`
	Node                  string `json:"node"`
	PersistentVolumeClaim string `json:"persistentvolumeclaim"`
	Service               string `json:"service"`
}

type MetricResult

type MetricResult struct {
	Metric Metric        `json:"metric"`
	Value  []interface{} `json:"value"`
}

type Response

type Response struct {
	Status string `json:"status"`
	Data   Data   `json:"data"`
}

type StreamMetadata

type StreamMetadata struct {
	App                 string `json:"app"`
	Container           string `json:"container"`
	Pod                 string `json:"pod"`
	Stream              string `json:"stream"`
	TemboInstanceID     string `json:"tembo_instance_id"`
	TemboOrganizationID string `json:"tembo_organization_id"`
}

type StreamResult

type StreamResult struct {
	Streams []StreamSet `json:"streams"`
}

type StreamSet

type StreamSet struct {
	Stream StreamMetadata `json:"stream"`
	Values [][]string     `json:"values"`
}