segment

package
v1.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 11, 2023 License: AGPL-3.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const ProfileIDLabelName = "profile_id"

Variables

This section is empty.

Functions

func AppSegmentKey 

func AppSegmentKey(appName string) string

func FromTreeToDictKey 

func FromTreeToDictKey(k string) string

FromTreeToDictKey returns app name from tree key k: given tree key "foo{}:0:1234567890", 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 ParseTreeKey 

func ParseTreeKey(k string) (time.Time, int, error)

ParseTreeKey retrieves tree time and depth level from the given key.

func TreeKey 

func TreeKey(k string, depth int, unixTime int64) string

func ValidateKey 

func ValidateKey(k *Key) error

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) Clone 

func (k *Key) Clone() *Key

func (*Key) DictKey 

func (k *Key) DictKey() string

func (*Key) HasProfileID 

func (k *Key) HasProfileID() bool

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) ProfileID 

func (k *Key) ProfileID() (string, bool)

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 RetentionPolicy 

type RetentionPolicy struct {
	AbsoluteTime time.Time
	Levels       map[int]time.Time

	ExemplarsRetentionTime time.Time
	// contains filtered or unexported fields
}

func NewRetentionPolicy 

func NewRetentionPolicy() *RetentionPolicy

func (RetentionPolicy) LowerTimeBoundary 

func (r RetentionPolicy) LowerTimeBoundary() time.Time

func (*RetentionPolicy) SetAbsolutePeriod 

func (r *RetentionPolicy) SetAbsolutePeriod(period time.Duration) *RetentionPolicy

func (*RetentionPolicy) SetExemplarsRetentionPeriod 

func (r *RetentionPolicy) SetExemplarsRetentionPeriod(period time.Duration) *RetentionPolicy

func (*RetentionPolicy) SetLevelPeriod 

func (r *RetentionPolicy) SetLevelPeriod(level int, period time.Duration) *RetentionPolicy

func (*RetentionPolicy) SetLevels 

func (r *RetentionPolicy) SetLevels(levels ...time.Duration) *RetentionPolicy

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) Bytes 

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

func (*Segment) DeleteNodesBefore 

func (s *Segment) DeleteNodesBefore(t *RetentionPolicy) (bool, error)

func (*Segment) Get 

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

func (*Segment) GetContext 

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

func (*Segment) GetMetadata 

func (s *Segment) GetMetadata() metadata.Metadata

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) Serialize 

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

func (*Segment) SetMetadata 

func (s *Segment) SetMetadata(md metadata.Metadata)

func (*Segment) StartTime 

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

func (*Segment) Visualize 

func (s *Segment) Visualize()

This is here for debugging

func (*Segment) WalkNodesToDelete 

func (s *Segment) WalkNodesToDelete(t *RetentionPolicy, cb func(depth int, t time.Time) error) (bool, error)

type Timeline 

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

	DurationDeltaNormalized int64 `json:"durationDelta"`

	// Watermarks map contains down-sampling watermarks (Unix timestamps)
	// describing resolution levels of the timeline.
	//
	// Resolution in seconds is calculated as 10^k, where k is the map key.
	// Meaning that any range within these 10^k seconds contains not more
	// than one sample. Any sub-range less than 10^k shows down-sampled data.
	//
	// Given the map:
	//  1: 1635508310
	//  2: 1635507500
	//  3: 1635506200
	//
	// This should be read as follows:
	//  1. Data after 1635508310 is as precise as possible (10s resolution),
	//     down-sampling was not applied.
	//  2. Data before 1635508310 has resolution 100s
	//  3. Data before 1635507500 has resolution 1000s
	//  4. Data before 1635506200 has resolution 10000s
	Watermarks map[int]int64 `json:"watermarks"`
	// 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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.