observability

package

v0.3.2 Latest Latest Go to latest Published: Sep 2, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Details

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