digest

Documentation

Index

• Constants
• type Digest
• type Digester
  • func NewDigester(settings Settings) *Digester
  • func (d *Digester) Close() error
  • func (d *Digester) ProcessSample(streams []control.SamplerStreamUID, sampleData *data.Data) bool
  • func (d *Digester) SetDigestsConfig(digestCfgs map[control.SamplerDigestUID]control.Digest)
• type Settings
• type St
  • func NewStDigest(maxProcessedFields int, notifyErr func(error)) *St
  • func (s *St) AddSampleData(sampleData *data.Data) error
  • func (s *St) JSON() ([]byte, error)
  • func (s *St) Reset()
  • func (s *St) SampleType() control.SampleType
  • func (s *St) String() string
• type Value
  • func NewValue(maxProcessedFields int) *Value
  • func (v *Value) AddSampleData(sampleData *data.Data) error
  • func (v *Value) JSON() ([]byte, error)
  • func (v *Value) Reset()
  • func (v *Value) SampleType() control.SampleType
  • func (v *Value) String() string
• type ValueType

Constants

const (
	UnknownValueType = ValueType(iota)
	NumberValueType
	StringValueType
	BooleanValueType
	ObjValueType
	ArrayValueType
	NilValueType
)

Types

type Digest

type Digest interface {
	AddSampleData(*data.Data) error
	JSON() ([]byte, error)
	Reset()
	String() string
	SampleType() control.SampleType
}

type Digester

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

func NewDigester

func NewDigester(settings Settings) *Digester

func (*Digester) Close

func (d *Digester) Close() error

func (*Digester) ProcessSample

func (d *Digester) ProcessSample(streams []control.SamplerStreamUID, sampleData *data.Data) bool

func (*Digester) SetDigestsConfig

func (d *Digester) SetDigestsConfig(digestCfgs map[control.SamplerDigestUID]control.Digest)

type Settings

type Settings struct {
	ResourceName   string
	SamplerName    string
	EnabledDigests []control.DigestType

	NotifyErr func(error)
	Exporter  exporter.Exporter
}

type St

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

func NewStDigest

func NewStDigest(maxProcessedFields int, notifyErr func(error)) *St

func (*St) AddSampleData

func (s *St) AddSampleData(sampleData *data.Data) error

AddSample is not thread safe

func (*St) JSON

func (s *St) JSON() ([]byte, error)

func (*St) Reset

func (s *St) Reset()

func (*St) SampleType

func (s *St) SampleType() control.SampleType

func (*St) String

func (s *St) String() string

type Value

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

func NewValue

func NewValue(maxProcessedFields int) *Value

func (*Value) AddSampleData

func (v *Value) AddSampleData(sampleData *data.Data) error

AddSample is not thread safe

func (*Value) JSON

func (v *Value) JSON() ([]byte, error)

func (*Value) Reset

func (v *Value) Reset()

func (*Value) SampleType

func (v *Value) SampleType() control.SampleType

func (*Value) String

func (v *Value) String() string

type ValueType

type ValueType int8