common

Documentation

Index

• Constants
• type ProcessStatus
  • func NewProcessStatus() *ProcessStatus
  • func (p *ProcessStatus) StopUpdate()
  • func (p *ProcessStatus) Update()
• type RouterStart
• type VcapComponent
  • func (c *VcapComponent) ListenAndServe() error
  • func (c *VcapComponent) Register(mbusClient *nats.Conn) error
  • func (c *VcapComponent) Start() error
  • func (c *VcapComponent) Stop() error
  • func (c *VcapComponent) UpdateVarz()

Constants

const RefreshInterval time.Duration = time.Second * 1

Types

type ProcessStatus

type ProcessStatus struct {
	sync.RWMutex

	CpuUsage float64
	MemRss   int64
	// contains filtered or unexported fields
}

func NewProcessStatus

func NewProcessStatus() *ProcessStatus

func (*ProcessStatus) StopUpdate

func (p *ProcessStatus) StopUpdate()

func (*ProcessStatus) Update

func (p *ProcessStatus) Update()

type RouterStart

type RouterStart struct {
	Id                               string   `json:"id"`
	Hosts                            []string `json:"hosts"`
	MinimumRegisterIntervalInSeconds int      `json:"minimumRegisterIntervalInSeconds"`
	PruneThresholdInSeconds          int      `json:"pruneThresholdInSeconds"`
}

type VcapComponent

type VcapComponent struct {
	Config     interface{}  `json:"-"`
	Varz       *health.Varz `json:"-"`
	Health     http.Handler
	InfoRoutes map[string]json.Marshaler `json:"-"`
	Logger     *slog.Logger              `json:"-"`
	// contains filtered or unexported fields
}

func (*VcapComponent) ListenAndServe

func (c *VcapComponent) ListenAndServe() error

func (*VcapComponent) Register

func (c *VcapComponent) Register(mbusClient *nats.Conn) error

func (*VcapComponent) Start

func (c *VcapComponent) Start() error

func (*VcapComponent) Stop

func (c *VcapComponent) Stop() error

func (*VcapComponent) UpdateVarz

func (c *VcapComponent) UpdateVarz()