avr_harness

Documentation

Index

• Constants
• type Config
• type Harness
  • func (h *Harness) SetupNATSSubscriber(subj string, addr string) *NatsConn
• type NatsConn
• type Stats

Constants

const (
	NatsSubj = "controller.avrd.metrics"
)

Types

type Config

type Config struct {
	NATSPort  int    `envconfig:"nats_port" default:"4222"`
	AvrSocket string `envconfig:"avr_socket" default:"/tmp/bench.sock"`
	PromPort  int    `envconfig:"prometheus_port" default:"2112"`
}

type Harness

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

func (*Harness) SetupNATSSubscriber

func (h *Harness) SetupNATSSubscriber(subj string, addr string) *NatsConn

type NatsConn

type NatsConn struct {
	Nats  *nats.Conn
	Stats chan *Stats
}

type Stats

type Stats struct {
	Stats   *metrics.StatsEntity
	Subject *string
	Size    *int
}

Stats is a container, so we can pass through the channel