encoding

package module
v0.0.0-...-762ffb6 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2019 License: Apache-2.0 Imports: 9 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BufferEntriesWithSpans 

type BufferEntriesWithSpans []*BufferEntryWithSpans

func (BufferEntriesWithSpans) MarshalEasyJSON 

func (v BufferEntriesWithSpans) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (BufferEntriesWithSpans) MarshalJSON 

func (v BufferEntriesWithSpans) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*BufferEntriesWithSpans) UnmarshalEasyJSON 

func (v *BufferEntriesWithSpans) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*BufferEntriesWithSpans) UnmarshalJSON 

func (v *BufferEntriesWithSpans) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type BufferEntry 

type BufferEntry struct {
	TraceID        ID          `json:",omitempty"` // id of the trace
	Last           int64       `json:",omitempty"` // Last time we saw a span for this trace id
	LatestEndTime  int64       `json:",omitempty"` // Latest end time we've seen for any span
	FirstWallclock int64       `json:",omitempty"` // first wallclock we've seen a point for this (used to query)
	LastWallClock  int64       `json:",omitempty"` // last wallclock we've seen a point for this (used to query)
	SizeSoFar      int64       `json:",omitempty"` // size of the trace so far
	Initiating     *trace.Span `json:",omitempty"` // initiating span
	CountOfSpans   int32       `json:",omitempty"` // CountOfSpans
	ToBeReleased   bool        `json:",omitempty"` // spans that have been selected to be released
}

func (*BufferEntry) GetStartTime 

func (v *BufferEntry) GetStartTime() int64

func (BufferEntry) MarshalEasyJSON 

func (v BufferEntry) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (BufferEntry) MarshalJSON 

func (v BufferEntry) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*BufferEntry) UnmarshalEasyJSON 

func (v *BufferEntry) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*BufferEntry) UnmarshalJSON 

func (v *BufferEntry) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type BufferEntryCommon 

type BufferEntryCommon struct {
	TraceID       string      `json:",omitempty"` // id of the trace
	Last          time.Time   `json:",omitempty"` // Last time we saw a span for this trace id
	LatestEndTime int64       `json:",omitempty"` // Latest end time we've seen for any span
	StartTime     int64       `json:",omitempty"` // Start time of initiating span if found
	Initiating    *trace.Span `json:",omitempty"` // initiating span
}

func (BufferEntryCommon) MarshalEasyJSON 

func (v BufferEntryCommon) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (BufferEntryCommon) MarshalJSON 

func (v BufferEntryCommon) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*BufferEntryCommon) UnmarshalEasyJSON 

func (v *BufferEntryCommon) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*BufferEntryCommon) UnmarshalJSON 

func (v *BufferEntryCommon) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type BufferEntryOld 

type BufferEntryOld struct {
	*BufferEntryCommon
	Spans        []*trace.Span `json:",omitempty"` // buffer of spans by trace id
	SizeSoFar    int64         `json:",omitempty"` // size of the trace so far
	ToBeReleased bool          `json:",omitempty"` // spans that have been selected to be released
}

func (BufferEntryOld) MarshalEasyJSON 

func (v BufferEntryOld) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (BufferEntryOld) MarshalJSON 

func (v BufferEntryOld) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*BufferEntryOld) UnmarshalEasyJSON 

func (v *BufferEntryOld) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*BufferEntryOld) UnmarshalJSON 

func (v *BufferEntryOld) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type BufferEntryWithSpans 

type BufferEntryWithSpans struct {
	BufferEntry
	Spans [][]byte `json:",omitempty"` // spans that are already serialized
}

func (BufferEntryWithSpans) MarshalEasyJSON 

func (v BufferEntryWithSpans) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (BufferEntryWithSpans) MarshalJSON 

func (v BufferEntryWithSpans) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*BufferEntryWithSpans) UnmarshalEasyJSON 

func (v *BufferEntryWithSpans) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*BufferEntryWithSpans) UnmarshalJSON 

func (v *BufferEntryWithSpans) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type BufferInMemory 

type BufferInMemory struct {
	NumSpans       int64                `json:",omitempty"` // num spans buffered in Traces
	Entries        []BufferEntry        `json:",omitempty"` // buffer entries
	ExpiredEntries []ExpiredBufferEntry `json:",omitempty"` // expired buffer entries
	EntryMap       map[ID]int           `json:",omitempty"` // map of trace id to index of new buffer entry
	ExpiredMap     map[ID]int           `json:",omitempty"` // map of trace id to expired buffer entry
}

can't be easyjson'd due to map keys

type BufferOnDisk 

type BufferOnDisk struct {
	NumSpans       int64                `json:",omitempty"` // num spans buffered in Traces
	Entries        []BufferEntry        `json:",omitempty"` // buffer entries
	ExpiredEntries []ExpiredBufferEntry `json:",omitempty"` // expired buffer entries
	EntryMap       map[string]int       `json:",omitempty"` // map of trace id to index of new buffer entry
	ExpiredMap     map[string]int       `json:",omitempty"` // map of trace id to expired buffer entry
}

func (BufferOnDisk) MarshalEasyJSON 

func (v BufferOnDisk) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (BufferOnDisk) MarshalJSON 

func (v BufferOnDisk) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*BufferOnDisk) UnmarshalEasyJSON 

func (v *BufferOnDisk) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*BufferOnDisk) UnmarshalJSON 

func (v *BufferOnDisk) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type EtcdConfig 

type EtcdConfig struct {
	RebalanceAddress string `json:",omitempty"`
	IngestAddress    string `json:",omitempty"`
	ID               string `json:",omitempty"`
	Weight           int32  `json:",omitempty"`
	Version          int32  `json:",omitempty"`
}

func (EtcdConfig) MarshalEasyJSON 

func (v EtcdConfig) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (EtcdConfig) MarshalJSON 

func (v EtcdConfig) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*EtcdConfig) UnmarshalEasyJSON 

func (v *EtcdConfig) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*EtcdConfig) UnmarshalJSON 

func (v *EtcdConfig) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type ExpiredBufferEntries 

type ExpiredBufferEntries []*ExpiredBufferEntry

func (ExpiredBufferEntries) MarshalEasyJSON 

func (v ExpiredBufferEntries) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (ExpiredBufferEntries) MarshalJSON 

func (v ExpiredBufferEntries) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*ExpiredBufferEntries) UnmarshalEasyJSON 

func (v *ExpiredBufferEntries) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*ExpiredBufferEntries) UnmarshalJSON 

func (v *ExpiredBufferEntries) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type ExpiredBufferEntry 

type ExpiredBufferEntry struct {
	TraceID            ID           `json:",omitempty"` // id of the trace
	Last               int64        `json:",omitempty"` // Last time we saw a span for this trace id
	LatestEndTime      int64        `json:",omitempty"` // Latest end time we've seen for any span
	StartTime          int64        `json:",omitempty"` // EarliestStartTime
	InitiatingIdentity SpanIdentity `json:",omitempty"` // initiating span
	NewSpanSeen        bool         `json:",omitempty"` // we've seen a new span
	Released           bool         `json:",omitempty"` // we've released this trace so send along any new spans we see
	TraceTooLarge      bool         `json:",omitempty"` // trace is too large so increment counters to this effect
	DefinitiveTraceID  bool         `json:",omitempty"` // spanID == traceID for buffer entry
}

func (*ExpiredBufferEntry) HasInitiating 

func (v *ExpiredBufferEntry) HasInitiating() bool

func (ExpiredBufferEntry) MarshalEasyJSON 

func (v ExpiredBufferEntry) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (ExpiredBufferEntry) MarshalJSON 

func (v ExpiredBufferEntry) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*ExpiredBufferEntry) UnmarshalEasyJSON 

func (v *ExpiredBufferEntry) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*ExpiredBufferEntry) UnmarshalJSON 

func (v *ExpiredBufferEntry) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type ExpiredBufferEntryOld 

type ExpiredBufferEntryOld struct {
	*BufferEntryCommon
	NewSpanSeen   bool `json:",omitempty"` // we've seen a new span
	Released      bool `json:",omitempty"` // we've released this trace so send along any new spans we see
	TraceTooLarge bool `json:",omitempty"` // trace is too large so increment counters to this effect
}

func (ExpiredBufferEntryOld) MarshalEasyJSON 

func (v ExpiredBufferEntryOld) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (ExpiredBufferEntryOld) MarshalJSON 

func (v ExpiredBufferEntryOld) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*ExpiredBufferEntryOld) UnmarshalEasyJSON 

func (v *ExpiredBufferEntryOld) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*ExpiredBufferEntryOld) UnmarshalJSON 

func (v *ExpiredBufferEntryOld) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type Histo 

type Histo struct {
	Error *HistoOnDisk `json:",omitempty"`
	Span  *HistoOnDisk `json:",omitempty"`
	Trace *HistoOnDisk `json:",omitempty"`
}

func (Histo) MarshalEasyJSON 

func (v Histo) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (Histo) MarshalJSON 

func (v Histo) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*Histo) UnmarshalEasyJSON 

func (v *Histo) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Histo) UnmarshalJSON 

func (v *Histo) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type HistoOnDisk 

type HistoOnDisk struct {
	Entries map[SpanIdentity]HistoOnDiskEntry `json:",omitempty"`
}

func (HistoOnDisk) MarshalEasyJSON 

func (v HistoOnDisk) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (HistoOnDisk) MarshalJSON 

func (v HistoOnDisk) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*HistoOnDisk) UnmarshalEasyJSON 

func (v *HistoOnDisk) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*HistoOnDisk) UnmarshalJSON 

func (v *HistoOnDisk) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type HistoOnDiskEntry 

type HistoOnDiskEntry struct {
	Digest       []byte    `json:",omitempty"`
	Last         time.Time `json:",omitempty"`
	Count        int64     `json:",omitempty"`
	DecayedCount float64   `json:",omitempty"`
}

func (HistoOnDiskEntry) MarshalEasyJSON 

func (v HistoOnDiskEntry) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (HistoOnDiskEntry) MarshalJSON 

func (v HistoOnDiskEntry) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*HistoOnDiskEntry) UnmarshalEasyJSON 

func (v *HistoOnDiskEntry) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*HistoOnDiskEntry) UnmarshalJSON 

func (v *HistoOnDiskEntry) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type ID 

type ID [2]uint64

low, high

func GetID 

func GetID(s string) (ID, error)

func (*ID) String 

func (id *ID) String() string

type Rebalance 

type Rebalance struct {
	Buffers        []*BufferEntryWithSpans `json:",omitempty"` // array of buffer entries with spans
	ExpiredBuffers []*ExpiredBufferEntry   `json:",omitempty"` // array of expired buffer entries
}

func (Rebalance) MarshalEasyJSON 

func (v Rebalance) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (Rebalance) MarshalJSON 

func (v Rebalance) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*Rebalance) UnmarshalEasyJSON 

func (v *Rebalance) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Rebalance) UnmarshalJSON 

func (v *Rebalance) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type RebalanceOld 

type RebalanceOld struct {
	Buffers        map[string]*BufferEntryOld        `json:",omitempty"` // map of trace id to buffer entry
	ExpiredBuffers map[string]*ExpiredBufferEntryOld `json:",omitempty"` // map of trace id to expired buffer entry
}

func (RebalanceOld) MarshalEasyJSON 

func (v RebalanceOld) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (RebalanceOld) MarshalJSON 

func (v RebalanceOld) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*RebalanceOld) UnmarshalEasyJSON 

func (v *RebalanceOld) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*RebalanceOld) UnmarshalJSON 

func (v *RebalanceOld) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type SampleEntry 

type SampleEntry struct {
	ID      *SpanIdentity `json:",omitempty"`
	Samples []int64       `json:",omitempty"`
}

func (SampleEntry) MarshalEasyJSON 

func (v SampleEntry) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (SampleEntry) MarshalJSON 

func (v SampleEntry) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*SampleEntry) UnmarshalEasyJSON 

func (v *SampleEntry) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*SampleEntry) UnmarshalJSON 

func (v *SampleEntry) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type SampleList 

type SampleList []*SampleEntry

func (SampleList) MarshalEasyJSON 

func (v SampleList) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (SampleList) MarshalJSON 

func (v SampleList) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*SampleList) UnmarshalEasyJSON 

func (v *SampleList) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*SampleList) UnmarshalJSON 

func (v *SampleList) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type SpanIdentity 

type SpanIdentity struct {
	Service              string `json:",omitempty"`
	Operation            string `json:",omitempty"`
	HttpMethod           string `json:",omitempty"`
	Kind                 string `json:",omitempty"`
	AdditionalDimensions string `json:",omitempty"`
	Error                bool   `json:",omitempty"`
	ServiceMesh          bool   `json:",omitempty"`
}

SpanIdentity is a tuple of Service and Operation

func NewExtendedSpanIdentity 

func NewExtendedSpanIdentity(baseID *SpanIdentity, additionalDims map[string]string) *SpanIdentity

NewExtendedSpanIdentity returns a SpanIdentity with additional dimensions applied

func (*SpanIdentity) Dims 

func (v *SpanIdentity) Dims() map[string]string

func (SpanIdentity) MarshalEasyJSON 

func (v SpanIdentity) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (SpanIdentity) MarshalJSON 

func (v SpanIdentity) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*SpanIdentity) String 

func (v *SpanIdentity) String() string

func (*SpanIdentity) UnmarshalEasyJSON 

func (v *SpanIdentity) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*SpanIdentity) UnmarshalJSON 

func (v *SpanIdentity) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

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.