opencensus

Documentation

Index

• Constants
• type OpenCensusBase
  • func (census *OpenCensusBase) Initialize(projectId string, reportPeriod int)
  • func (census *OpenCensusBase) Record(arguments *protocol.MeasureArgument) *protocol.Response
  • func (census *OpenCensusBase) ViewRegistration(myView *(view.View)) error
• type Slave
  • func (slave *Slave) Collect(period time.Duration)
  • func (slave *Slave) Initialize(config *goserial.Config, parser parser.Parser) error
  • func (slave *Slave) Subscribe(listener OpenCensusBase)

Constants

const (
	// TODO: We could make it configurable in the future
	SETUPDURATION = 2
)

Types

type OpenCensusBase

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

func (*OpenCensusBase) Initialize

func (census *OpenCensusBase) Initialize(projectId string, reportPeriod int)

func (*OpenCensusBase) Record

func (census *OpenCensusBase) Record(arguments *protocol.MeasureArgument) *protocol.Response

func (*OpenCensusBase) ViewRegistration

func (census *OpenCensusBase) ViewRegistration(myView *(view.View)) error

Given the censusArgument, initialize the OpenCensus framework

type Slave

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

func (*Slave) Collect

func (slave *Slave) Collect(period time.Duration)

func (*Slave) Initialize

func (slave *Slave) Initialize(config *goserial.Config, parser parser.Parser) error

func (*Slave) Subscribe

func (slave *Slave) Subscribe(listener OpenCensusBase)