segment

Documentation

Index

• func FromTreeToDictKey(k string) string
• func FromTreeToMainKey(k string) string
• type Addon
• type Key
  • func NewKey(labels map[string]string) *Key
  • func ParseKey(name string) (*Key, error)
  • func (k *Key) Add(key, value string)
  • func (k *Key) AppName() string
  • func (k *Key) DictKey() string
  • func (k *Key) Labels() map[string]string
  • func (k *Key) Match(q *flameql.Query) bool
  • func (k *Key) Normalized() string
  • func (k *Key) SegmentKey() string
  • func (k *Key) TreeKey(depth int, t time.Time) string
• type ParserState
• type Segment
  • func Deserialize(r io.Reader) (*Segment, error)
  • func FromBytes(p []byte) (*Segment, error)
  • func New() *Segment
  • func (s *Segment) AggregationType() string
  • func (s *Segment) Bytes() ([]byte, error)
  • func (s *Segment) DeleteDataBefore(retentionThreshold time.Time, cb func(depth int, t time.Time)) bool
  • func (s *Segment) Get(st, et time.Time, ...)
  • func (s *Segment) Put(st, et time.Time, samples uint64, ...) error
  • func (s *Segment) SampleRate() uint32
  • func (s *Segment) Serialize(w io.Writer) error
  • func (s *Segment) SetMetadata(spyName string, sampleRate uint32, units, aggregationType string)
  • func (s *Segment) SpyName() string
  • func (s *Segment) StartTime() time.Time
  • func (s *Segment) Units() string
  • func (s *Segment) Visualize()
• type Timeline
  • func GenerateTimeline(st, et time.Time) *Timeline
  • func (tl *Timeline) PopulateTimeline(s *Segment)
• type TmpltVars

Functions

func FromTreeToDictKey

func FromTreeToDictKey(k string) string

FromTreeToDictKey returns app name from tree key k: given tree key "foo{}:0:-62135596790", the call returns "foo".

Before tags support, segment key form (i.e. app name + tags: foo{key=value}) has been used to reference a dictionary (trie).

func FromTreeToMainKey

func FromTreeToMainKey(k string) string

Types

type Addon

type Addon struct {
	Depth int
	T     time.Time
}

type Key

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

func NewKey

func NewKey(labels map[string]string) *Key

func ParseKey

func ParseKey(name string) (*Key, error)

func (*Key) Add

func (k *Key) Add(key, value string)

func (*Key) AppName

func (k *Key) AppName() string

func (*Key) DictKey

func (k *Key) DictKey() string

func (*Key) Labels

func (k *Key) Labels() map[string]string

func (*Key) Match

func (k *Key) Match(q *flameql.Query) bool

Match reports whether the key matches the query.

func (*Key) Normalized

func (k *Key) Normalized() string

func (*Key) SegmentKey

func (k *Key) SegmentKey() string

func (*Key) TreeKey

func (k *Key) TreeKey(depth int, t time.Time) string

type ParserState

type ParserState int

type Segment

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

func Deserialize

func Deserialize(r io.Reader) (*Segment, error)

func FromBytes

func FromBytes(p []byte) (*Segment, error)

func New

func New() *Segment

func (*Segment) AggregationType

func (s *Segment) AggregationType() string

func (*Segment) Bytes

func (s *Segment) Bytes() ([]byte, error)

func (*Segment) DeleteDataBefore

func (s *Segment) DeleteDataBefore(retentionThreshold time.Time, cb func(depth int, t time.Time)) bool

func (*Segment) Get

func (s *Segment) Get(st, et time.Time, cb func(depth int, samples, writes uint64, t time.Time, r *big.Rat))

TODO: simplify arguments TODO: validate st < et

func (*Segment) Put

func (s *Segment) Put(st, et time.Time, samples uint64, cb func(depth int, t time.Time, r *big.Rat, addons []Addon)) error

TODO: simplify arguments TODO: validate st < et

func (*Segment) SampleRate

func (s *Segment) SampleRate() uint32

func (*Segment) Serialize

func (s *Segment) Serialize(w io.Writer) error

func (*Segment) SetMetadata

func (s *Segment) SetMetadata(spyName string, sampleRate uint32, units, aggregationType string)

TODO: this should be refactored

func (*Segment) SpyName

func (s *Segment) SpyName() string

func (*Segment) StartTime

func (s *Segment) StartTime() time.Time

func (*Segment) Units

func (s *Segment) Units() string

func (*Segment) Visualize

func (s *Segment) Visualize()

This is here for debugging

type Timeline

type Timeline struct {
	StartTime int64    `json:"startTime"`
	Samples   []uint64 `json:"samples"`

	DurationDeltaNormalized int64 `json:"durationDelta"`
	// contains filtered or unexported fields
}

func GenerateTimeline

func GenerateTimeline(st, et time.Time) *Timeline

func (*Timeline) PopulateTimeline

func (tl *Timeline) PopulateTimeline(s *Segment)

type TmpltVars

type TmpltVars struct {
	Data string
}