common

Documentation

Index

• Constants
• func GenerateUUID() (string, error)
• func UnixToTime(unixTime string) (time.Time, error)
• type Duration
  • func (d Duration) MarshalJSON() ([]byte, error)
  • func (d *Duration) UnmarshalJSON(b []byte) error
• type GenericVarz
• type Healthz
  • func (v *Healthz) Value() string
• type LogCounter
  • func NewLogCounter() *LogCounter
  • func (lc *LogCounter) GetCount(key string) int
  • func (lc *LogCounter) Log(logLevel lager.LogLevel, payload []byte)
  • func (lc *LogCounter) MarshalJSON() ([]byte, error)
• type ProcessStatus
  • func NewProcessStatus() *ProcessStatus
  • func (p *ProcessStatus) StopUpdate()
  • func (p *ProcessStatus) Update()
• type RouterStart
• type Time
  • func (t Time) Elapsed() Duration
  • func (t Time) MarshalJSON() ([]byte, error)
  • func (t *Time) UnmarshalJSON(b []byte) error
• type Varz
  • func (v *Varz) MarshalJSON() ([]byte, error)
• type VcapComponent
  • func (c *VcapComponent) ListenAndServe()
  • func (c *VcapComponent) Register(mbusClient yagnats.NATSConn) error
  • func (c *VcapComponent) Start() error
  • func (c *VcapComponent) Stop()
  • func (c *VcapComponent) UpdateVarz()

Constants

const RefreshInterval time.Duration = time.Second * 1

Functions

func GenerateUUID

func GenerateUUID() (string, error)

func UnixToTime

func UnixToTime(unixTime string) (time.Time, error)

Types

type Duration

type Duration time.Duration

func (Duration) MarshalJSON

func (d Duration) MarshalJSON() ([]byte, error)

func (*Duration) UnmarshalJSON

func (d *Duration) UnmarshalJSON(b []byte) error

type GenericVarz

type GenericVarz struct {
	// These fields are from individual components
	Type        string   `json:"type"`
	Index       uint     `json:"index"`
	Host        string   `json:"host"`
	Credentials []string `json:"credentials"`

	// These fields are automatically generated
	UUID      string `json:"uuid"`
	StartTime Time   `json:"start"`

	// Static common metrics
	NumCores int `json:"num_cores"`

	// Dynamic common metrics
	MemStat int64   `json:"mem"`
	Cpu     float64 `json:"cpu"`

	Uptime    Duration    `json:"uptime"`
	LogCounts *LogCounter `json:"log_counts"`
}

type Healthz

type Healthz struct {
}

func (*Healthz) Value

func (v *Healthz) Value() string

type LogCounter

type LogCounter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewLogCounter

func NewLogCounter() *LogCounter

func (*LogCounter) GetCount

func (lc *LogCounter) GetCount(key string) int

func (*LogCounter) Log

func (lc *LogCounter) Log(logLevel lager.LogLevel, payload []byte)

func (*LogCounter) MarshalJSON

func (lc *LogCounter) MarshalJSON() ([]byte, error)

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 Time

type Time time.Time

func (Time) Elapsed

func (t Time) Elapsed() Duration

func (Time) MarshalJSON

func (t Time) MarshalJSON() ([]byte, error)

func (*Time) UnmarshalJSON

func (t *Time) UnmarshalJSON(b []byte) error

type Varz

type Varz struct {
	sync.Mutex
	GenericVarz
	UniqueVarz interface{} // Every component's unique metrics
}

func (*Varz) MarshalJSON

func (v *Varz) MarshalJSON() ([]byte, error)

type VcapComponent

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

func (*VcapComponent) ListenAndServe

func (c *VcapComponent) ListenAndServe()

func (*VcapComponent) Register

func (c *VcapComponent) Register(mbusClient yagnats.NATSConn) error

func (*VcapComponent) Start

func (c *VcapComponent) Start() error

func (*VcapComponent) Stop

func (c *VcapComponent) Stop()

func (*VcapComponent) UpdateVarz

func (c *VcapComponent) UpdateVarz()