tembo

package
v0.56.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 19, 2024 License: BSD-2-Clause, BSD-3-Clause, PostgreSQL Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetSystemState

func GetSystemState(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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL