go.opencensus.io – go.opencensus.io/exporter/jaeger/internal/gen-go/zipkincore Index | Files | Directories

package zipkincore

import "go.opencensus.io/exporter/jaeger/internal/gen-go/zipkincore"

Index

Constants 

const CLIENT_ADDR = "ca"
const CLIENT_RECV = "cr"
const CLIENT_RECV_FRAGMENT = "crf"
const CLIENT_SEND = "cs"
const CLIENT_SEND_FRAGMENT = "csf"
const LOCAL_COMPONENT = "lc"
const SERVER_ADDR = "sa"
const SERVER_RECV = "sr"
const SERVER_RECV_FRAGMENT = "srf"
const SERVER_SEND = "ss"
const SERVER_SEND_FRAGMENT = "ssf"
const WIRE_RECV = "wr"
const WIRE_SEND = "ws"

Variables 

var GoUnusedProtection__ int
var Span_Debug_DEFAULT bool = false
var Span_Duration_DEFAULT int64
var Span_ParentID_DEFAULT int64
var Span_Timestamp_DEFAULT int64
var ZipkinCollectorSubmitZipkinBatchResult_Success_DEFAULT []*Response

Types

type Annotation 

type Annotation struct {
	Timestamp int64     `thrift:"timestamp,1" db:"timestamp" json:"timestamp"`
	Value     string    `thrift:"value,2" db:"value" json:"value"`
	Host      *Endpoint `thrift:"host,3" db:"host" json:"host,omitempty"`
}

An annotation is similar to a log statement. It includes a host field which allows these events to be attributed properly, and also aggregatable.

Attributes:

This value should use the most precise value possible. For example, gettimeofday or syncing nanoTime against a tick of currentTimeMillis.

rollup of all events (such as client requests to a service) by IP address.

func NewAnnotation 

func NewAnnotation() *Annotation

func (*Annotation) GetHost 

func (p *Annotation) GetHost() *Endpoint

func (*Annotation) GetTimestamp 

func (p *Annotation) GetTimestamp() int64

func (*Annotation) GetValue 

func (p *Annotation) GetValue() string

func (*Annotation) IsSetHost 

func (p *Annotation) IsSetHost() bool

func (*Annotation) Read 

func (p *Annotation) Read(iprot thrift.TProtocol) error

func (*Annotation) ReadField1 

func (p *Annotation) ReadField1(iprot thrift.TProtocol) error

func (*Annotation) ReadField2 

func (p *Annotation) ReadField2(iprot thrift.TProtocol) error

func (*Annotation) ReadField3 

func (p *Annotation) ReadField3(iprot thrift.TProtocol) error

func (*Annotation) String 

func (p *Annotation) String() string

func (*Annotation) Write 

func (p *Annotation) Write(oprot thrift.TProtocol) error

type AnnotationType 

type AnnotationType int64
const (
	AnnotationType_BOOL   AnnotationType = 0
	AnnotationType_BYTES  AnnotationType = 1
	AnnotationType_I16    AnnotationType = 2
	AnnotationType_I32    AnnotationType = 3
	AnnotationType_I64    AnnotationType = 4
	AnnotationType_DOUBLE AnnotationType = 5
	AnnotationType_STRING AnnotationType = 6
)

func AnnotationTypeFromString 

func AnnotationTypeFromString(s string) (AnnotationType, error)

func AnnotationTypePtr 

func AnnotationTypePtr(v AnnotationType) *AnnotationType

func (AnnotationType) MarshalText 

func (p AnnotationType) MarshalText() ([]byte, error)

func (*AnnotationType) Scan 

func (p *AnnotationType) Scan(value interface{}) error

func (AnnotationType) String 

func (p AnnotationType) String() string

func (*AnnotationType) UnmarshalText 

func (p *AnnotationType) UnmarshalText(text []byte) error

func (*AnnotationType) Value 

func (p *AnnotationType) Value() (driver.Value, error)

type BinaryAnnotation 

type BinaryAnnotation struct {
	Key            string         `thrift:"key,1" db:"key" json:"key"`
	Value          []byte         `thrift:"value,2" db:"value" json:"value"`
	AnnotationType AnnotationType `thrift:"annotation_type,3" db:"annotation_type" json:"annotation_type"`
	Host           *Endpoint      `thrift:"host,4" db:"host" json:"host,omitempty"`
}

Binary annotations are tags applied to a Span to give it context. For example, a binary annotation of "http.uri" could the path to a resource in a RPC call.

Binary annotations of type STRING are always queryable, though more a historical implementation detail than a structural concern.

Binary annotations can repeat, and vary on the host. Similar to Annotation, the host indicates who logged the event. This allows you to tell the difference between the client and server side of the same key. For example, the key "http.uri" might be different on the client and server side due to rewriting, like "/api/v1/myresource" vs "/myresource. Via the host field, you can see the different points of view, which often help in debugging.

Attributes:

multiple tags with the same key. There are two exceptions to this.

When the key is CLIENT_ADDR or SERVER_ADDR, host indicates the source or destination of an RPC. This exception allows zipkin to display network context of uninstrumented services, or clients such as web browsers.

func NewBinaryAnnotation 

func NewBinaryAnnotation() *BinaryAnnotation

func (*BinaryAnnotation) GetAnnotationType 

func (p *BinaryAnnotation) GetAnnotationType() AnnotationType

func (*BinaryAnnotation) GetHost 

func (p *BinaryAnnotation) GetHost() *Endpoint

func (*BinaryAnnotation) GetKey 

func (p *BinaryAnnotation) GetKey() string

func (*BinaryAnnotation) GetValue 

func (p *BinaryAnnotation) GetValue() []byte

func (*BinaryAnnotation) IsSetHost 

func (p *BinaryAnnotation) IsSetHost() bool

func (*BinaryAnnotation) Read 

func (p *BinaryAnnotation) Read(iprot thrift.TProtocol) error

func (*BinaryAnnotation) ReadField1 

func (p *BinaryAnnotation) ReadField1(iprot thrift.TProtocol) error

func (*BinaryAnnotation) ReadField2 

func (p *BinaryAnnotation) ReadField2(iprot thrift.TProtocol) error

func (*BinaryAnnotation) ReadField3 

func (p *BinaryAnnotation) ReadField3(iprot thrift.TProtocol) error

func (*BinaryAnnotation) ReadField4 

func (p *BinaryAnnotation) ReadField4(iprot thrift.TProtocol) error

func (*BinaryAnnotation) String 

func (p *BinaryAnnotation) String() string

func (*BinaryAnnotation) Write 

func (p *BinaryAnnotation) Write(oprot thrift.TProtocol) error

type Endpoint 

type Endpoint struct {
	Ipv4        int32  `thrift:"ipv4,1" db:"ipv4" json:"ipv4"`
	Port        int16  `thrift:"port,2" db:"port" json:"port"`
	ServiceName string `thrift:"service_name,3" db:"service_name" json:"service_name"`
}

Indicates the network context of a service recording an annotation with two exceptions.

When a BinaryAnnotation, and key is CLIENT_ADDR or SERVER_ADDR, the endpoint indicates the source or destination of an RPC. This exception allows zipkin to display network context of uninstrumented services, or clients such as web browsers.

Attributes:

Ex for the ip 1.2.3.4, it would be (1 << 24) | (2 << 16) | (3 << 8) | 4

Note: this is to be treated as an unsigned integer, so watch for negatives.

Conventionally, when the port isn't known, port = 0.

Conventionally, when the service name isn't known, service_name = "unknown". 

var Annotation_Host_DEFAULT *Endpoint
var BinaryAnnotation_Host_DEFAULT *Endpoint

func NewEndpoint 

func NewEndpoint() *Endpoint

func (*Endpoint) GetIpv4 

func (p *Endpoint) GetIpv4() int32

func (*Endpoint) GetPort 

func (p *Endpoint) GetPort() int16

func (*Endpoint) GetServiceName 

func (p *Endpoint) GetServiceName() string

func (*Endpoint) Read 

func (p *Endpoint) Read(iprot thrift.TProtocol) error

func (*Endpoint) ReadField1 

func (p *Endpoint) ReadField1(iprot thrift.TProtocol) error

func (*Endpoint) ReadField2 

func (p *Endpoint) ReadField2(iprot thrift.TProtocol) error

func (*Endpoint) ReadField3 

func (p *Endpoint) ReadField3(iprot thrift.TProtocol) error

func (*Endpoint) String 

func (p *Endpoint) String() string

func (*Endpoint) Write 

func (p *Endpoint) Write(oprot thrift.TProtocol) error

type Response 

type Response struct {
	Ok bool `thrift:"ok,1,required" db:"ok" json:"ok"`
}

Attributes:

func NewResponse 

func NewResponse() *Response

func (*Response) GetOk 

func (p *Response) GetOk() bool

func (*Response) Read 

func (p *Response) Read(iprot thrift.TProtocol) error

func (*Response) ReadField1 

func (p *Response) ReadField1(iprot thrift.TProtocol) error

func (*Response) String 

func (p *Response) String() string

func (*Response) Write 

func (p *Response) Write(oprot thrift.TProtocol) error

type Span 

type Span struct {
	TraceID int64 `thrift:"trace_id,1" db:"trace_id" json:"trace_id"`
	// unused field # 2
	Name        string        `thrift:"name,3" db:"name" json:"name"`
	ID          int64         `thrift:"id,4" db:"id" json:"id"`
	ParentID    *int64        `thrift:"parent_id,5" db:"parent_id" json:"parent_id,omitempty"`
	Annotations []*Annotation `thrift:"annotations,6" db:"annotations" json:"annotations"`
	// unused field # 7
	BinaryAnnotations []*BinaryAnnotation `thrift:"binary_annotations,8" db:"binary_annotations" json:"binary_annotations"`
	Debug             bool                `thrift:"debug,9" db:"debug" json:"debug,omitempty"`
	Timestamp         *int64              `thrift:"timestamp,10" db:"timestamp" json:"timestamp,omitempty"`
	Duration          *int64              `thrift:"duration,11" db:"duration" json:"duration,omitempty"`
}

A trace is a series of spans (often RPC calls) which form a latency tree.

The root span is where trace_id = id and parent_id = Nil. The root span is usually the longest interval in the trace, starting with a SERVER_RECV annotation and ending with a SERVER_SEND.

Attributes:

Conventionally, when the span name isn't known, name = "unknown".

This value should be set directly by instrumentation, using the most precise value possible. For example, gettimeofday or syncing nanoTime against a tick of currentTimeMillis.

For compatibilty with instrumentation that precede this field, collectors or span stores can derive this via Annotation.timestamp. For example, SERVER_RECV.timestamp or CLIENT_SEND.timestamp.

This field is optional for compatibility with old data: first-party span stores are expected to support this at time of introduction.

This value should be set directly, where possible. Doing so encourages precise measurement decoupled from problems of clocks, such as skew or NTP updates causing time to move backwards.

For compatibilty with instrumentation that precede this field, collectors or span stores can derive this by subtracting Annotation.timestamp. For example, SERVER_SEND.timestamp - SERVER_RECV.timestamp.

If this field is persisted as unset, zipkin will continue to work, except duration query support will be implementation-specific. Similarly, setting this field non-atomically is implementation-specific.

This field is i64 vs i32 to support spans longer than 35 minutes.

func NewSpan 

func NewSpan() *Span

func (*Span) GetAnnotations 

func (p *Span) GetAnnotations() []*Annotation

func (*Span) GetBinaryAnnotations 

func (p *Span) GetBinaryAnnotations() []*BinaryAnnotation

func (*Span) GetDebug 

func (p *Span) GetDebug() bool

func (*Span) GetDuration 

func (p *Span) GetDuration() int64

func (*Span) GetID 

func (p *Span) GetID() int64

func (*Span) GetName 

func (p *Span) GetName() string

func (*Span) GetParentID 

func (p *Span) GetParentID() int64

func (*Span) GetTimestamp 

func (p *Span) GetTimestamp() int64

func (*Span) GetTraceID 

func (p *Span) GetTraceID() int64

func (*Span) IsSetDebug 

func (p *Span) IsSetDebug() bool

func (*Span) IsSetDuration 

func (p *Span) IsSetDuration() bool

func (*Span) IsSetParentID 

func (p *Span) IsSetParentID() bool

func (*Span) IsSetTimestamp 

func (p *Span) IsSetTimestamp() bool

func (*Span) Read 

func (p *Span) Read(iprot thrift.TProtocol) error

func (*Span) ReadField1 

func (p *Span) ReadField1(iprot thrift.TProtocol) error

func (*Span) ReadField10 

func (p *Span) ReadField10(iprot thrift.TProtocol) error

func (*Span) ReadField11 

func (p *Span) ReadField11(iprot thrift.TProtocol) error

func (*Span) ReadField3 

func (p *Span) ReadField3(iprot thrift.TProtocol) error

func (*Span) ReadField4 

func (p *Span) ReadField4(iprot thrift.TProtocol) error

func (*Span) ReadField5 

func (p *Span) ReadField5(iprot thrift.TProtocol) error

func (*Span) ReadField6 

func (p *Span) ReadField6(iprot thrift.TProtocol) error

func (*Span) ReadField8 

func (p *Span) ReadField8(iprot thrift.TProtocol) error

func (*Span) ReadField9 

func (p *Span) ReadField9(iprot thrift.TProtocol) error

func (*Span) String 

func (p *Span) String() string

func (*Span) Write 

func (p *Span) Write(oprot thrift.TProtocol) error

type ZipkinCollector 

type ZipkinCollector interface {
	// Parameters:
	//  - Spans
	SubmitZipkinBatch(ctx context.Context, spans []*Span) (r []*Response, err error)
}

type ZipkinCollectorClient 

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

func NewZipkinCollectorClient 

func NewZipkinCollectorClient(c thrift.TClient) *ZipkinCollectorClient

func NewZipkinCollectorClientFactory 

func NewZipkinCollectorClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ZipkinCollectorClient

Deprecated: Use NewZipkinCollector instead

func NewZipkinCollectorClientProtocol 

func NewZipkinCollectorClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ZipkinCollectorClient

Deprecated: Use NewZipkinCollector instead

func (*ZipkinCollectorClient) SubmitZipkinBatch 

func (p *ZipkinCollectorClient) SubmitZipkinBatch(ctx context.Context, spans []*Span) (r []*Response, err error)

Parameters:

type ZipkinCollectorProcessor 

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

func NewZipkinCollectorProcessor 

func NewZipkinCollectorProcessor(handler ZipkinCollector) *ZipkinCollectorProcessor

func (*ZipkinCollectorProcessor) AddToProcessorMap 

func (p *ZipkinCollectorProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*ZipkinCollectorProcessor) GetProcessorFunction 

func (p *ZipkinCollectorProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*ZipkinCollectorProcessor) Process 

func (p *ZipkinCollectorProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*ZipkinCollectorProcessor) ProcessorMap 

func (p *ZipkinCollectorProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type ZipkinCollectorSubmitZipkinBatchArgs 

type ZipkinCollectorSubmitZipkinBatchArgs struct {
	Spans []*Span `thrift:"spans,1" db:"spans" json:"spans"`
}

Attributes:

func NewZipkinCollectorSubmitZipkinBatchArgs 

func NewZipkinCollectorSubmitZipkinBatchArgs() *ZipkinCollectorSubmitZipkinBatchArgs

func (*ZipkinCollectorSubmitZipkinBatchArgs) GetSpans 

func (p *ZipkinCollectorSubmitZipkinBatchArgs) GetSpans() []*Span

func (*ZipkinCollectorSubmitZipkinBatchArgs) Read 

func (p *ZipkinCollectorSubmitZipkinBatchArgs) Read(iprot thrift.TProtocol) error

func (*ZipkinCollectorSubmitZipkinBatchArgs) ReadField1 

func (p *ZipkinCollectorSubmitZipkinBatchArgs) ReadField1(iprot thrift.TProtocol) error

func (*ZipkinCollectorSubmitZipkinBatchArgs) String 

func (p *ZipkinCollectorSubmitZipkinBatchArgs) String() string

func (*ZipkinCollectorSubmitZipkinBatchArgs) Write 

func (p *ZipkinCollectorSubmitZipkinBatchArgs) Write(oprot thrift.TProtocol) error

type ZipkinCollectorSubmitZipkinBatchResult 

type ZipkinCollectorSubmitZipkinBatchResult struct {
	Success []*Response `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

func NewZipkinCollectorSubmitZipkinBatchResult 

func NewZipkinCollectorSubmitZipkinBatchResult() *ZipkinCollectorSubmitZipkinBatchResult

func (*ZipkinCollectorSubmitZipkinBatchResult) GetSuccess 

func (p *ZipkinCollectorSubmitZipkinBatchResult) GetSuccess() []*Response

func (*ZipkinCollectorSubmitZipkinBatchResult) IsSetSuccess 

func (p *ZipkinCollectorSubmitZipkinBatchResult) IsSetSuccess() bool

func (*ZipkinCollectorSubmitZipkinBatchResult) Read 

func (p *ZipkinCollectorSubmitZipkinBatchResult) Read(iprot thrift.TProtocol) error

func (*ZipkinCollectorSubmitZipkinBatchResult) ReadField0 

func (p *ZipkinCollectorSubmitZipkinBatchResult) ReadField0(iprot thrift.TProtocol) error

func (*ZipkinCollectorSubmitZipkinBatchResult) String 

func (p *ZipkinCollectorSubmitZipkinBatchResult) String() string

func (*ZipkinCollectorSubmitZipkinBatchResult) Write 

func (p *ZipkinCollectorSubmitZipkinBatchResult) Write(oprot thrift.TProtocol) error

Source Files

GoUnusedProtection__.go zipkincore-consts.go zipkincore.go

Directories

PathSynopsis
exporter/jaeger/internal/gen-go/zipkincore/zipkin_collector-remote
Version
v0.2.0
Published
Jan 30, 2018
Platform
js/wasm
Imports
7 packages
Last checked
2 minutes ago –

Tools for package owners.