exported

Documentation

Index

• type Average
  • func NewAverage(exporter *VariableExporter, v *variable.Variable) *Average
  • func (ea *Average) Export() chan *oproto.ValueStream
  • func (ea *Average) Update(sum float64, count uint64)
• type Exportable
• type Float
  • func NewFloat(exporter *VariableExporter, v *variable.Variable) *Float
  • func (ef *Float) Add(value float64)
  • func (ef *Float) Export() chan *oproto.ValueStream
  • func (ef *Float) Get() float64
  • func (ef *Float) Set(value float64)
  • func (ef *Float) Sub(value float64)
• type Integer
  • func NewInteger(exporter *VariableExporter, v *variable.Variable) *Integer
  • func (ei *Integer) Add(value uint64)
  • func (ei *Integer) Export() chan *oproto.ValueStream
  • func (ei *Integer) Get() uint64
  • func (ei *Integer) Set(value uint64)
  • func (ei *Integer) Sub(value uint64)
• type Ratio
  • func NewRatio(exporter *VariableExporter, v *variable.Variable) *Ratio
  • func (er *Ratio) Export() chan *oproto.ValueStream
  • func (er *Ratio) Failure()
  • func (er *Ratio) Success()
• type String
  • func NewString(exporter *VariableExporter, v *variable.Variable) *String
  • func (es *String) Export() chan *oproto.ValueStream
  • func (es *String) Get() string
  • func (es *String) Set(value string)
• type Timer
  • func NewTimer(exporter *VariableExporter, v *variable.Variable) *Timer
  • func (et *Timer) Export() chan *oproto.ValueStream
  • func (et *Timer) Start()
  • func (et *Timer) Stop()
• type VariableExporter
  • func NewExporter(ctx context.Context, c client.Client, interval time.Duration) *VariableExporter
  • func (e *VariableExporter) GetStreams() []*oproto.ValueStream
  • func (e *VariableExporter) Shutdown()

Types

type Average

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

////////// Average ///////////////////////////////

func NewAverage

func NewAverage(exporter *VariableExporter, v *variable.Variable) *Average

func (*Average) Export

func (ea *Average) Export() chan *oproto.ValueStream

func (*Average) Update

func (ea *Average) Update(sum float64, count uint64)

type Exportable

type Exportable interface {
	Export() chan *oproto.ValueStream
}

type Float

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

////////// Float ///////////////////////////////

func NewFloat

func NewFloat(exporter *VariableExporter, v *variable.Variable) *Float

func (*Float) Add

func (ef *Float) Add(value float64)

func (*Float) Export

func (ef *Float) Export() chan *oproto.ValueStream

func (*Float) Get

func (ef *Float) Get() float64

func (*Float) Set

func (ef *Float) Set(value float64)

func (*Float) Sub

func (ef *Float) Sub(value float64)

type Integer

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

////////// Integer ///////////////////////////////

func NewInteger

func NewInteger(exporter *VariableExporter, v *variable.Variable) *Integer

func (*Integer) Add

func (ei *Integer) Add(value uint64)

func (*Integer) Export

func (ei *Integer) Export() chan *oproto.ValueStream

func (*Integer) Get

func (ei *Integer) Get() uint64

func (*Integer) Set

func (ei *Integer) Set(value uint64)

func (*Integer) Sub

func (ei *Integer) Sub(value uint64)

type Ratio

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

////////// Ratio ///////////////////////////////

func NewRatio

func NewRatio(exporter *VariableExporter, v *variable.Variable) *Ratio

func (*Ratio) Export

func (er *Ratio) Export() chan *oproto.ValueStream

func (*Ratio) Failure

func (er *Ratio) Failure()

func (*Ratio) Success

func (er *Ratio) Success()

type String

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

////////// String ///////////////////////////////

func NewString

func NewString(exporter *VariableExporter, v *variable.Variable) *String

func (*String) Export

func (es *String) Export() chan *oproto.ValueStream

func (*String) Get

func (es *String) Get() string

func (*String) Set

func (es *String) Set(value string)

type Timer

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

////////// Timer ///////////////////////////////

func NewTimer

func NewTimer(exporter *VariableExporter, v *variable.Variable) *Timer

func (*Timer) Export

func (et *Timer) Export() chan *oproto.ValueStream

func (*Timer) Start

func (et *Timer) Start()

func (*Timer) Stop

func (et *Timer) Stop()

type VariableExporter

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

func NewExporter

func NewExporter(ctx context.Context, c client.Client, interval time.Duration) *VariableExporter

func (*VariableExporter) GetStreams

func (e *VariableExporter) GetStreams() []*oproto.ValueStream

func (*VariableExporter) Shutdown

func (e *VariableExporter) Shutdown()