observability

package

v0.3.1 Latest Latest Go to latest Published: Sep 12, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Here we put the stuff that makes it possible to gain some insight into what is happening on the bridge.

The idea is to have a channel that we listen to and update counters and health based on what comes through that channel.

This section is empty.

This section is empty.

This section is empty.

type Channel chan StatusMessage

func GetChannel(size int) Channel

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

func Initialize(params Params) *Observability

func (obs *Observability) Cleanup()

func (obs *Observability) HealthzHandler(w http.ResponseWriter, _ *http.Request)

func (obs *Observability) Ready()

func (obs Observability) Run(ctx context.Context)

type Params struct {
	Channel    Channel
	HealthPort int
	LogLevel   log.LogLevel
}

type StatusMessage int

const (
	MqttReceived StatusMessage = iota
	MqttError
	KafkaSent
	KafkaError
)

func (d StatusMessage) String() string