otel: go.opentelemetry.io/otel/exporters/trace/jaeger/internal/gen-go/jaeger Index | Files | Directories

package jaeger

import "go.opentelemetry.io/otel/exporters/trace/jaeger/internal/gen-go/jaeger"

Index

Package Files

GoUnusedProtection__.go agent.go jaeger-consts.go jaeger.go

Variables

❖
var CollectorSubmitBatchesResult_Success_DEFAULT []*BatchSubmitResponse
❖
var GoUnusedProtection__ int
❖
var Process_Tags_DEFAULT []*Tag
❖
var Span_Logs_DEFAULT []*Log
❖
var Span_References_DEFAULT []*SpanRef
❖
var Span_Tags_DEFAULT []*Tag
❖
var Tag_VBinary_DEFAULT []byte
❖
var Tag_VBool_DEFAULT bool
❖
var Tag_VDouble_DEFAULT float64
❖
var Tag_VLong_DEFAULT int64
❖
var Tag_VStr_DEFAULT string

type Agent Uses

❖
type Agent interface {
    // Parameters:
    //  - Batch
    EmitBatch(batch *Batch) (err error)
}

type AgentClient Uses

❖
type AgentClient struct {
    Transport       thrift.TTransport
    ProtocolFactory thrift.TProtocolFactory
    InputProtocol   thrift.TProtocol
    OutputProtocol  thrift.TProtocol
    SeqId           int32
}

func NewAgentClientFactory Uses

❖
func NewAgentClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *AgentClient

func NewAgentClientProtocol Uses

❖
func NewAgentClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *AgentClient

func (*AgentClient) EmitBatch Uses

❖
func (p *AgentClient) EmitBatch(batch *Batch) (err error)

Parameters: 

- Batch

type AgentEmitBatchArgs Uses

❖
type AgentEmitBatchArgs struct {
    Batch *Batch `thrift:"batch,1" json:"batch"`
}

Attributes: 

- Batch

func NewAgentEmitBatchArgs Uses

❖
func NewAgentEmitBatchArgs() *AgentEmitBatchArgs

func (*AgentEmitBatchArgs) GetBatch Uses

❖
func (p *AgentEmitBatchArgs) GetBatch() *Batch

func (*AgentEmitBatchArgs) IsSetBatch Uses

❖
func (p *AgentEmitBatchArgs) IsSetBatch() bool

func (*AgentEmitBatchArgs) Read Uses

❖
func (p *AgentEmitBatchArgs) Read(iprot thrift.TProtocol) error

func (*AgentEmitBatchArgs) String Uses

❖
func (p *AgentEmitBatchArgs) String() string

func (*AgentEmitBatchArgs) Write Uses

❖
func (p *AgentEmitBatchArgs) Write(oprot thrift.TProtocol) error

type AgentProcessor Uses

❖
type AgentProcessor struct {
    // contains filtered or unexported fields
}

func NewAgentProcessor Uses

❖
func NewAgentProcessor(handler Agent) *AgentProcessor

func (*AgentProcessor) AddToProcessorMap Uses

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

func (*AgentProcessor) GetProcessorFunction Uses

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

func (*AgentProcessor) Process Uses

❖
func (p *AgentProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*AgentProcessor) ProcessorMap Uses

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

type Batch Uses

❖
type Batch struct {
    Process *Process `thrift:"process,1,required" db:"process" json:"process"`
    Spans   []*Span  `thrift:"spans,2,required" db:"spans" json:"spans"`
}

Attributes: 

- Process
- Spans
❖
var AgentEmitBatchArgs_Batch_DEFAULT *Batch

func NewBatch Uses

❖
func NewBatch() *Batch

func (*Batch) GetProcess Uses

❖
func (p *Batch) GetProcess() *Process

func (*Batch) GetSpans Uses

❖
func (p *Batch) GetSpans() []*Span

func (*Batch) IsSetProcess Uses

❖
func (p *Batch) IsSetProcess() bool

func (*Batch) Read Uses

❖
func (p *Batch) Read(iprot thrift.TProtocol) error

func (*Batch) ReadField1 Uses

❖
func (p *Batch) ReadField1(iprot thrift.TProtocol) error

func (*Batch) ReadField2 Uses

❖
func (p *Batch) ReadField2(iprot thrift.TProtocol) error

func (*Batch) String Uses

❖
func (p *Batch) String() string

func (*Batch) Write Uses

❖
func (p *Batch) Write(oprot thrift.TProtocol) error

type BatchSubmitResponse Uses

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

Attributes: 

- Ok

func NewBatchSubmitResponse Uses

❖
func NewBatchSubmitResponse() *BatchSubmitResponse

func (*BatchSubmitResponse) GetOk Uses

❖
func (p *BatchSubmitResponse) GetOk() bool

func (*BatchSubmitResponse) Read Uses

❖
func (p *BatchSubmitResponse) Read(iprot thrift.TProtocol) error

func (*BatchSubmitResponse) ReadField1 Uses

❖
func (p *BatchSubmitResponse) ReadField1(iprot thrift.TProtocol) error

func (*BatchSubmitResponse) String Uses

❖
func (p *BatchSubmitResponse) String() string

func (*BatchSubmitResponse) Write Uses

❖
func (p *BatchSubmitResponse) Write(oprot thrift.TProtocol) error

type Collector Uses

❖
type Collector interface {
    // Parameters:
    //  - Batches
    SubmitBatches(ctx context.Context, batches []*Batch) (r []*BatchSubmitResponse, err error)
}

type CollectorClient Uses

❖
type CollectorClient struct {
    // contains filtered or unexported fields
}

func NewCollectorClient Uses

❖
func NewCollectorClient(c thrift.TClient) *CollectorClient

func NewCollectorClientFactory Uses

❖
func NewCollectorClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *CollectorClient

Deprecated: Use NewCollector instead

func NewCollectorClientProtocol Uses

❖
func NewCollectorClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *CollectorClient

Deprecated: Use NewCollector instead

func (*CollectorClient) SubmitBatches Uses

❖
func (p *CollectorClient) SubmitBatches(ctx context.Context, batches []*Batch) (r []*BatchSubmitResponse, err error)

Parameters: 

- Batches

type CollectorProcessor Uses

❖
type CollectorProcessor struct {
    // contains filtered or unexported fields
}

func NewCollectorProcessor Uses

❖
func NewCollectorProcessor(handler Collector) *CollectorProcessor

func (*CollectorProcessor) AddToProcessorMap Uses

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

func (*CollectorProcessor) GetProcessorFunction Uses

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

func (*CollectorProcessor) Process Uses

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

func (*CollectorProcessor) ProcessorMap Uses

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

type CollectorSubmitBatchesArgs Uses

❖
type CollectorSubmitBatchesArgs struct {
    Batches []*Batch `thrift:"batches,1" db:"batches" json:"batches"`
}

Attributes: 

- Batches

func NewCollectorSubmitBatchesArgs Uses

❖
func NewCollectorSubmitBatchesArgs() *CollectorSubmitBatchesArgs

func (*CollectorSubmitBatchesArgs) GetBatches Uses

❖
func (p *CollectorSubmitBatchesArgs) GetBatches() []*Batch

func (*CollectorSubmitBatchesArgs) Read Uses

❖
func (p *CollectorSubmitBatchesArgs) Read(iprot thrift.TProtocol) error

func (*CollectorSubmitBatchesArgs) ReadField1 Uses

❖
func (p *CollectorSubmitBatchesArgs) ReadField1(iprot thrift.TProtocol) error

func (*CollectorSubmitBatchesArgs) String Uses

❖
func (p *CollectorSubmitBatchesArgs) String() string

func (*CollectorSubmitBatchesArgs) Write Uses

❖
func (p *CollectorSubmitBatchesArgs) Write(oprot thrift.TProtocol) error

type CollectorSubmitBatchesResult Uses

❖
type CollectorSubmitBatchesResult struct {
    Success []*BatchSubmitResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes: 

- Success

func NewCollectorSubmitBatchesResult Uses

❖
func NewCollectorSubmitBatchesResult() *CollectorSubmitBatchesResult

func (*CollectorSubmitBatchesResult) GetSuccess Uses

❖
func (p *CollectorSubmitBatchesResult) GetSuccess() []*BatchSubmitResponse

func (*CollectorSubmitBatchesResult) IsSetSuccess Uses

❖
func (p *CollectorSubmitBatchesResult) IsSetSuccess() bool

func (*CollectorSubmitBatchesResult) Read Uses

❖
func (p *CollectorSubmitBatchesResult) Read(iprot thrift.TProtocol) error

func (*CollectorSubmitBatchesResult) ReadField0 Uses

❖
func (p *CollectorSubmitBatchesResult) ReadField0(iprot thrift.TProtocol) error

func (*CollectorSubmitBatchesResult) String Uses

❖
func (p *CollectorSubmitBatchesResult) String() string

func (*CollectorSubmitBatchesResult) Write Uses

❖
func (p *CollectorSubmitBatchesResult) Write(oprot thrift.TProtocol) error

type Log Uses

❖
type Log struct {
    Timestamp int64  `thrift:"timestamp,1,required" db:"timestamp" json:"timestamp"`
    Fields    []*Tag `thrift:"fields,2,required" db:"fields" json:"fields"`
}

Attributes: 

- Timestamp
- Fields

func NewLog Uses

❖
func NewLog() *Log

func (*Log) GetFields Uses

❖
func (p *Log) GetFields() []*Tag

func (*Log) GetTimestamp Uses

❖
func (p *Log) GetTimestamp() int64

func (*Log) Read Uses

❖
func (p *Log) Read(iprot thrift.TProtocol) error

func (*Log) ReadField1 Uses

❖
func (p *Log) ReadField1(iprot thrift.TProtocol) error

func (*Log) ReadField2 Uses

❖
func (p *Log) ReadField2(iprot thrift.TProtocol) error

func (*Log) String Uses

❖
func (p *Log) String() string

func (*Log) Write Uses

❖
func (p *Log) Write(oprot thrift.TProtocol) error

type Process Uses

❖
type Process struct {
    ServiceName string `thrift:"serviceName,1,required" db:"serviceName" json:"serviceName"`
    Tags        []*Tag `thrift:"tags,2" db:"tags" json:"tags,omitempty"`
}

Attributes: 

- ServiceName
- Tags
❖
var Batch_Process_DEFAULT *Process

func NewProcess Uses

❖
func NewProcess() *Process

func (*Process) GetServiceName Uses

❖
func (p *Process) GetServiceName() string

func (*Process) GetTags Uses

❖
func (p *Process) GetTags() []*Tag

func (*Process) IsSetTags Uses

❖
func (p *Process) IsSetTags() bool

func (*Process) Read Uses

❖
func (p *Process) Read(iprot thrift.TProtocol) error

func (*Process) ReadField1 Uses

❖
func (p *Process) ReadField1(iprot thrift.TProtocol) error

func (*Process) ReadField2 Uses

❖
func (p *Process) ReadField2(iprot thrift.TProtocol) error

func (*Process) String Uses

❖
func (p *Process) String() string

func (*Process) Write Uses

❖
func (p *Process) Write(oprot thrift.TProtocol) error

type Span Uses

❖
type Span struct {
    TraceIdLow    int64      `thrift:"traceIdLow,1,required" db:"traceIdLow" json:"traceIdLow"`
    TraceIdHigh   int64      `thrift:"traceIdHigh,2,required" db:"traceIdHigh" json:"traceIdHigh"`
    SpanId        int64      `thrift:"spanId,3,required" db:"spanId" json:"spanId"`
    ParentSpanId  int64      `thrift:"parentSpanId,4,required" db:"parentSpanId" json:"parentSpanId"`
    OperationName string     `thrift:"operationName,5,required" db:"operationName" json:"operationName"`
    References    []*SpanRef `thrift:"references,6" db:"references" json:"references,omitempty"`
    Flags         int32      `thrift:"flags,7,required" db:"flags" json:"flags"`
    StartTime     int64      `thrift:"startTime,8,required" db:"startTime" json:"startTime"`
    Duration      int64      `thrift:"duration,9,required" db:"duration" json:"duration"`
    Tags          []*Tag     `thrift:"tags,10" db:"tags" json:"tags,omitempty"`
    Logs          []*Log     `thrift:"logs,11" db:"logs" json:"logs,omitempty"`
}

Attributes: 

- TraceIdLow
- TraceIdHigh
- SpanId
- ParentSpanId
- OperationName
- References
- Flags
- StartTime
- Duration
- Tags
- Logs

func NewSpan Uses

❖
func NewSpan() *Span

func (*Span) GetDuration Uses

❖
func (p *Span) GetDuration() int64

func (*Span) GetFlags Uses

❖
func (p *Span) GetFlags() int32

func (*Span) GetLogs Uses

❖
func (p *Span) GetLogs() []*Log

func (*Span) GetOperationName Uses

❖
func (p *Span) GetOperationName() string

func (*Span) GetParentSpanId Uses

❖
func (p *Span) GetParentSpanId() int64

func (*Span) GetReferences Uses

❖
func (p *Span) GetReferences() []*SpanRef

func (*Span) GetSpanId Uses

❖
func (p *Span) GetSpanId() int64

func (*Span) GetStartTime Uses

❖
func (p *Span) GetStartTime() int64

func (*Span) GetTags Uses

❖
func (p *Span) GetTags() []*Tag

func (*Span) GetTraceIdHigh Uses

❖
func (p *Span) GetTraceIdHigh() int64

func (*Span) GetTraceIdLow Uses

❖
func (p *Span) GetTraceIdLow() int64

func (*Span) IsSetLogs Uses

❖
func (p *Span) IsSetLogs() bool

func (*Span) IsSetReferences Uses

❖
func (p *Span) IsSetReferences() bool

func (*Span) IsSetTags Uses

❖
func (p *Span) IsSetTags() bool

func (*Span) Read Uses

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

func (*Span) ReadField1 Uses

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

func (*Span) ReadField10 Uses

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

func (*Span) ReadField11 Uses

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

func (*Span) ReadField2 Uses

❖
func (p *Span) ReadField2(iprot thrift.TProtocol) error

func (*Span) ReadField3 Uses

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

func (*Span) ReadField4 Uses

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

func (*Span) ReadField5 Uses

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

func (*Span) ReadField6 Uses

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

func (*Span) ReadField7 Uses

❖
func (p *Span) ReadField7(iprot thrift.TProtocol) error

func (*Span) ReadField8 Uses

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

func (*Span) ReadField9 Uses

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

func (*Span) String Uses

❖
func (p *Span) String() string

func (*Span) Write Uses

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

type SpanRef Uses

❖
type SpanRef struct {
    RefType     SpanRefType `thrift:"refType,1,required" db:"refType" json:"refType"`
    TraceIdLow  int64       `thrift:"traceIdLow,2,required" db:"traceIdLow" json:"traceIdLow"`
    TraceIdHigh int64       `thrift:"traceIdHigh,3,required" db:"traceIdHigh" json:"traceIdHigh"`
    SpanId      int64       `thrift:"spanId,4,required" db:"spanId" json:"spanId"`
}

Attributes: 

- RefType
- TraceIdLow
- TraceIdHigh
- SpanId

func NewSpanRef Uses

❖
func NewSpanRef() *SpanRef

func (*SpanRef) GetRefType Uses

❖
func (p *SpanRef) GetRefType() SpanRefType

func (*SpanRef) GetSpanId Uses

❖
func (p *SpanRef) GetSpanId() int64

func (*SpanRef) GetTraceIdHigh Uses

❖
func (p *SpanRef) GetTraceIdHigh() int64

func (*SpanRef) GetTraceIdLow Uses

❖
func (p *SpanRef) GetTraceIdLow() int64

func (*SpanRef) Read Uses

❖
func (p *SpanRef) Read(iprot thrift.TProtocol) error

func (*SpanRef) ReadField1 Uses

❖
func (p *SpanRef) ReadField1(iprot thrift.TProtocol) error

func (*SpanRef) ReadField2 Uses

❖
func (p *SpanRef) ReadField2(iprot thrift.TProtocol) error

func (*SpanRef) ReadField3 Uses

❖
func (p *SpanRef) ReadField3(iprot thrift.TProtocol) error

func (*SpanRef) ReadField4 Uses

❖
func (p *SpanRef) ReadField4(iprot thrift.TProtocol) error

func (*SpanRef) String Uses

❖
func (p *SpanRef) String() string

func (*SpanRef) Write Uses

❖
func (p *SpanRef) Write(oprot thrift.TProtocol) error

type SpanRefType Uses

❖
type SpanRefType int64
❖
const (
    SpanRefType_CHILD_OF     SpanRefType = 0
    SpanRefType_FOLLOWS_FROM SpanRefType = 1
)

func SpanRefTypeFromString Uses

❖
func SpanRefTypeFromString(s string) (SpanRefType, error)

func SpanRefTypePtr Uses

❖
func SpanRefTypePtr(v SpanRefType) *SpanRefType

func (SpanRefType) MarshalText Uses

❖
func (p SpanRefType) MarshalText() ([]byte, error)

func (*SpanRefType) Scan Uses

❖
func (p *SpanRefType) Scan(value interface{}) error

func (SpanRefType) String Uses

❖
func (p SpanRefType) String() string

func (*SpanRefType) UnmarshalText Uses

❖
func (p *SpanRefType) UnmarshalText(text []byte) error

func (*SpanRefType) Value Uses

❖
func (p *SpanRefType) Value() (driver.Value, error)

type Tag Uses

❖
type Tag struct {
    Key     string   `thrift:"key,1,required" db:"key" json:"key"`
    VType   TagType  `thrift:"vType,2,required" db:"vType" json:"vType"`
    VStr    *string  `thrift:"vStr,3" db:"vStr" json:"vStr,omitempty"`
    VDouble *float64 `thrift:"vDouble,4" db:"vDouble" json:"vDouble,omitempty"`
    VBool   *bool    `thrift:"vBool,5" db:"vBool" json:"vBool,omitempty"`
    VLong   *int64   `thrift:"vLong,6" db:"vLong" json:"vLong,omitempty"`
    VBinary []byte   `thrift:"vBinary,7" db:"vBinary" json:"vBinary,omitempty"`
}

Attributes: 

- Key
- VType
- VStr
- VDouble
- VBool
- VLong
- VBinary

func NewTag Uses

❖
func NewTag() *Tag

func (*Tag) GetKey Uses

❖
func (p *Tag) GetKey() string

func (*Tag) GetVBinary Uses

❖
func (p *Tag) GetVBinary() []byte

func (*Tag) GetVBool Uses

❖
func (p *Tag) GetVBool() bool

func (*Tag) GetVDouble Uses

❖
func (p *Tag) GetVDouble() float64

func (*Tag) GetVLong Uses

❖
func (p *Tag) GetVLong() int64

func (*Tag) GetVStr Uses

❖
func (p *Tag) GetVStr() string

func (*Tag) GetVType Uses

❖
func (p *Tag) GetVType() TagType

func (*Tag) IsSetVBinary Uses

❖
func (p *Tag) IsSetVBinary() bool

func (*Tag) IsSetVBool Uses

❖
func (p *Tag) IsSetVBool() bool

func (*Tag) IsSetVDouble Uses

❖
func (p *Tag) IsSetVDouble() bool

func (*Tag) IsSetVLong Uses

❖
func (p *Tag) IsSetVLong() bool

func (*Tag) IsSetVStr Uses

❖
func (p *Tag) IsSetVStr() bool

func (*Tag) Read Uses

❖
func (p *Tag) Read(iprot thrift.TProtocol) error

func (*Tag) ReadField1 Uses

❖
func (p *Tag) ReadField1(iprot thrift.TProtocol) error

func (*Tag) ReadField2 Uses

❖
func (p *Tag) ReadField2(iprot thrift.TProtocol) error

func (*Tag) ReadField3 Uses

❖
func (p *Tag) ReadField3(iprot thrift.TProtocol) error

func (*Tag) ReadField4 Uses

❖
func (p *Tag) ReadField4(iprot thrift.TProtocol) error

func (*Tag) ReadField5 Uses

❖
func (p *Tag) ReadField5(iprot thrift.TProtocol) error

func (*Tag) ReadField6 Uses

❖
func (p *Tag) ReadField6(iprot thrift.TProtocol) error

func (*Tag) ReadField7 Uses

❖
func (p *Tag) ReadField7(iprot thrift.TProtocol) error

func (*Tag) String Uses

❖
func (p *Tag) String() string

func (*Tag) Write Uses

❖
func (p *Tag) Write(oprot thrift.TProtocol) error

type TagType Uses

❖
type TagType int64
❖
const (
    TagType_STRING TagType = 0
    TagType_DOUBLE TagType = 1
    TagType_BOOL   TagType = 2
    TagType_LONG   TagType = 3
    TagType_BINARY TagType = 4
)

func TagTypeFromString Uses

❖
func TagTypeFromString(s string) (TagType, error)

func TagTypePtr Uses

❖
func TagTypePtr(v TagType) *TagType

func (TagType) MarshalText Uses

❖
func (p TagType) MarshalText() ([]byte, error)

func (*TagType) Scan Uses

❖
func (p *TagType) Scan(value interface{}) error

func (TagType) String Uses

❖
func (p TagType) String() string

func (*TagType) UnmarshalText Uses

❖
func (p *TagType) UnmarshalText(text []byte) error

func (*TagType) Value Uses

❖
func (p *TagType) Value() (driver.Value, error)

Directories

PathSynopsis
collector-remote

Package jaeger imports 7 packages (graph) and is imported by 2 packages. Updated 2020-03-04. Refresh now. Tools for package owners.