traceprotobufb

package
v0.0.0-...-c8bf5b5 Latest Latest
Warning

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

Go to latest
Published: Nov 9, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Capabilities_name = map[int32]string{
	0: "SKIP",
	1: "ZLIB_COMPRESSION",
	2: "LZ4_COMPRESSION",
}
View Source
var Capabilities_value = map[string]int32{
	"SKIP":             0,
	"ZLIB_COMPRESSION": 1,
	"LZ4_COMPRESSION":  2,
}
View Source
var CompressionMethod_name = map[int32]string{
	0: "NONE",
	1: "LZ4",
	2: "ZLIB",
}
View Source
var CompressionMethod_value = map[string]int32{
	"NONE": 0,
	"LZ4":  1,
	"ZLIB": 2,
}
View Source
var ExportResponse_ResultCode_name = map[int32]string{
	0: "Success",
	1: "FailedNoneRetryable",
	2: "FailedRetryable",
}
View Source
var ExportResponse_ResultCode_value = map[string]int32{
	"Success":             0,
	"FailedNoneRetryable": 1,
	"FailedRetryable":     2,
}
View Source
var LibraryInfo_Language_name = map[int32]string{
	0:  "LANGUAGE_UNSPECIFIED",
	1:  "CPP",
	2:  "C_SHARP",
	3:  "ERLANG",
	4:  "GO_LANG",
	5:  "JAVA",
	6:  "NODE_JS",
	7:  "PHP",
	8:  "PYTHON",
	9:  "RUBY",
	10: "WEB_JS",
}
View Source
var LibraryInfo_Language_value = map[string]int32{
	"LANGUAGE_UNSPECIFIED": 0,
	"CPP":                  1,
	"C_SHARP":              2,
	"ERLANG":               3,
	"GO_LANG":              4,
	"JAVA":                 5,
	"NODE_JS":              6,
	"PHP":                  7,
	"PYTHON":               8,
	"RUBY":                 9,
	"WEB_JS":               10,
}
View Source
var Span_Link_Type_name = map[int32]string{
	0: "TYPE_UNSPECIFIED",
	1: "CHILD_LINKED_SPAN",
	2: "PARENT_LINKED_SPAN",
}
View Source
var Span_Link_Type_value = map[string]int32{
	"TYPE_UNSPECIFIED":   0,
	"CHILD_LINKED_SPAN":  1,
	"PARENT_LINKED_SPAN": 2,
}
View Source
var Span_SpanKind_name = map[int32]string{
	0: "SPAN_KIND_UNSPECIFIED",
	1: "SERVER",
	2: "CLIENT",
}
View Source
var Span_SpanKind_value = map[string]int32{
	"SPAN_KIND_UNSPECIFIED": 0,
	"SERVER":                1,
	"CLIENT":                2,
}
View Source
var Span_TimeEvent_MessageEvent_Type_name = map[int32]string{
	0: "TYPE_UNSPECIFIED",
	1: "SENT",
	2: "RECEIVED",
}
View Source
var Span_TimeEvent_MessageEvent_Type_value = map[string]int32{
	"TYPE_UNSPECIFIED": 0,
	"SENT":             1,
	"RECEIVED":         2,
}

Functions

func RegisterStreamExporterServer

func RegisterStreamExporterServer(s *grpc.Server, srv StreamExporterServer)

func RegisterUnaryExporterServer

func RegisterUnaryExporterServer(s *grpc.Server, srv UnaryExporterServer)

Types

type AttributeValue

type AttributeValue struct {
	// The type of the value.
	//
	// Types that are valid to be assigned to Value:
	//	*AttributeValue_StringValue
	//	*AttributeValue_IntValue
	//	*AttributeValue_BoolValue
	//	*AttributeValue_DoubleValue
	Value                isAttributeValue_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

The value of an Attribute.

func (*AttributeValue) Descriptor

func (*AttributeValue) Descriptor() ([]byte, []int)

func (*AttributeValue) GetBoolValue

func (m *AttributeValue) GetBoolValue() bool

func (*AttributeValue) GetDoubleValue

func (m *AttributeValue) GetDoubleValue() float64

func (*AttributeValue) GetIntValue

func (m *AttributeValue) GetIntValue() int64

func (*AttributeValue) GetStringValue

func (m *AttributeValue) GetStringValue() string

func (*AttributeValue) GetValue

func (m *AttributeValue) GetValue() isAttributeValue_Value

func (*AttributeValue) ProtoMessage

func (*AttributeValue) ProtoMessage()

func (*AttributeValue) Reset

func (m *AttributeValue) Reset()

func (*AttributeValue) String

func (m *AttributeValue) String() string

func (*AttributeValue) XXX_DiscardUnknown

func (m *AttributeValue) XXX_DiscardUnknown()

func (*AttributeValue) XXX_Marshal

func (m *AttributeValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AttributeValue) XXX_Merge

func (m *AttributeValue) XXX_Merge(src proto.Message)

func (*AttributeValue) XXX_OneofWrappers

func (*AttributeValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AttributeValue) XXX_Size

func (m *AttributeValue) XXX_Size() int

func (*AttributeValue) XXX_Unmarshal

func (m *AttributeValue) XXX_Unmarshal(b []byte) error

type AttributeValue_BoolValue

type AttributeValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,3,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type AttributeValue_DoubleValue

type AttributeValue_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type AttributeValue_IntValue

type AttributeValue_IntValue struct {
	IntValue int64 `protobuf:"varint,2,opt,name=int_value,json=intValue,proto3,oneof"`
}

type AttributeValue_StringValue

type AttributeValue_StringValue struct {
	StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type Capabilities

type Capabilities int32
const (
	Capabilities_SKIP             Capabilities = 0
	Capabilities_ZLIB_COMPRESSION Capabilities = 1
	Capabilities_LZ4_COMPRESSION  Capabilities = 2
)

func (Capabilities) EnumDescriptor

func (Capabilities) EnumDescriptor() ([]byte, []int)

func (Capabilities) String

func (x Capabilities) String() string

type CompressionMethod

type CompressionMethod int32
const (
	CompressionMethod_NONE CompressionMethod = 0
	CompressionMethod_LZ4  CompressionMethod = 1
	CompressionMethod_ZLIB CompressionMethod = 2
)

func (CompressionMethod) EnumDescriptor

func (CompressionMethod) EnumDescriptor() ([]byte, []int)

func (CompressionMethod) String

func (x CompressionMethod) String() string

type ExportRequest

type ExportRequest struct {
	// Unique sequential ID generated by the client.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Telemetry data.
	SpanBatch            []*SpanBatch   `protobuf:"bytes,2,rep,name=spanBatch,proto3" json:"spanBatch,omitempty"`
	MetricBatch          []*MetricBatch `protobuf:"bytes,3,rep,name=metricBatch,proto3" json:"metricBatch,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

A request from client to server containing telemetry data to export.

func (*ExportRequest) Descriptor

func (*ExportRequest) Descriptor() ([]byte, []int)

func (*ExportRequest) GetId

func (m *ExportRequest) GetId() uint64

func (*ExportRequest) GetMetricBatch

func (m *ExportRequest) GetMetricBatch() []*MetricBatch

func (*ExportRequest) GetSpanBatch

func (m *ExportRequest) GetSpanBatch() []*SpanBatch

func (*ExportRequest) ProtoMessage

func (*ExportRequest) ProtoMessage()

func (*ExportRequest) Reset

func (m *ExportRequest) Reset()

func (*ExportRequest) String

func (m *ExportRequest) String() string

func (*ExportRequest) XXX_DiscardUnknown

func (m *ExportRequest) XXX_DiscardUnknown()

func (*ExportRequest) XXX_Marshal

func (m *ExportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExportRequest) XXX_Merge

func (m *ExportRequest) XXX_Merge(src proto.Message)

func (*ExportRequest) XXX_Size

func (m *ExportRequest) XXX_Size() int

func (*ExportRequest) XXX_Unmarshal

func (m *ExportRequest) XXX_Unmarshal(b []byte) error

type ExportResponse

type ExportResponse struct {
	// ID of a response that the server acknowledges.
	Id                   uint64                    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ResultCode           ExportResponse_ResultCode `` /* 138-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

A response to ExportRequest.

func (*ExportResponse) Descriptor

func (*ExportResponse) Descriptor() ([]byte, []int)

func (*ExportResponse) GetId

func (m *ExportResponse) GetId() uint64

func (*ExportResponse) GetResultCode

func (m *ExportResponse) GetResultCode() ExportResponse_ResultCode

func (*ExportResponse) ProtoMessage

func (*ExportResponse) ProtoMessage()

func (*ExportResponse) Reset

func (m *ExportResponse) Reset()

func (*ExportResponse) String

func (m *ExportResponse) String() string

func (*ExportResponse) XXX_DiscardUnknown

func (m *ExportResponse) XXX_DiscardUnknown()

func (*ExportResponse) XXX_Marshal

func (m *ExportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExportResponse) XXX_Merge

func (m *ExportResponse) XXX_Merge(src proto.Message)

func (*ExportResponse) XXX_Size

func (m *ExportResponse) XXX_Size() int

func (*ExportResponse) XXX_Unmarshal

func (m *ExportResponse) XXX_Unmarshal(b []byte) error

type ExportResponse_ResultCode

type ExportResponse_ResultCode int32
const (
	// Telemetry data is successfully processed by the server.
	ExportResponse_Success ExportResponse_ResultCode = 0
	// processing of telemetry data failed. The client MUST NOT retry
	// sending the same telemetry data. The telemetry data MUST be dropped.
	// This for example can happen when the request contains bad data and
	// cannot be deserialized or otherwise processed by the server.
	ExportResponse_FailedNoneRetryable ExportResponse_ResultCode = 1
	// Processing of telemetry data failed. The client SHOULD record the
	// error and MAY retry exporting the same data after some time. This
	// for example can happen when the server is overloaded.
	ExportResponse_FailedRetryable ExportResponse_ResultCode = 2
)

func (ExportResponse_ResultCode) EnumDescriptor

func (ExportResponse_ResultCode) EnumDescriptor() ([]byte, []int)

func (ExportResponse_ResultCode) String

func (x ExportResponse_ResultCode) String() string

type Generator

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

Generator allows to generate a ExportRequest.

func NewGenerator

func NewGenerator() *Generator

func (*Generator) GenerateBatch

func (g *Generator) GenerateBatch(spansPerBatch int, attrsPerSpan int) core.ExportRequest

type HelloRequest

type HelloRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Hello is the first request from client to server.

func (*HelloRequest) Descriptor

func (*HelloRequest) Descriptor() ([]byte, []int)

func (*HelloRequest) ProtoMessage

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) Reset

func (m *HelloRequest) Reset()

func (*HelloRequest) String

func (m *HelloRequest) String() string

func (*HelloRequest) XXX_DiscardUnknown

func (m *HelloRequest) XXX_DiscardUnknown()

func (*HelloRequest) XXX_Marshal

func (m *HelloRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HelloRequest) XXX_Merge

func (m *HelloRequest) XXX_Merge(src proto.Message)

func (*HelloRequest) XXX_Size

func (m *HelloRequest) XXX_Size() int

func (*HelloRequest) XXX_Unmarshal

func (m *HelloRequest) XXX_Unmarshal(b []byte) error

type HelloResponse

type HelloResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response to Hello request.

func (*HelloResponse) Descriptor

func (*HelloResponse) Descriptor() ([]byte, []int)

func (*HelloResponse) ProtoMessage

func (*HelloResponse) ProtoMessage()

func (*HelloResponse) Reset

func (m *HelloResponse) Reset()

func (*HelloResponse) String

func (m *HelloResponse) String() string

func (*HelloResponse) XXX_DiscardUnknown

func (m *HelloResponse) XXX_DiscardUnknown()

func (*HelloResponse) XXX_Marshal

func (m *HelloResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HelloResponse) XXX_Merge

func (m *HelloResponse) XXX_Merge(src proto.Message)

func (*HelloResponse) XXX_Size

func (m *HelloResponse) XXX_Size() int

func (*HelloResponse) XXX_Unmarshal

func (m *HelloResponse) XXX_Unmarshal(b []byte) error

type LibraryInfo

type LibraryInfo struct {
	// Language of OpenCensus Library.
	Language LibraryInfo_Language `protobuf:"varint,1,opt,name=language,proto3,enum=traceprotobufb.LibraryInfo_Language" json:"language,omitempty"`
	// Version of Agent exporter of Library.
	ExporterVersion string `protobuf:"bytes,2,opt,name=exporter_version,json=exporterVersion,proto3" json:"exporter_version,omitempty"`
	// Version of OpenCensus Library.
	CoreLibraryVersion   string   `protobuf:"bytes,3,opt,name=core_library_version,json=coreLibraryVersion,proto3" json:"core_library_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Information on OpenCensus Library.

func (*LibraryInfo) Descriptor

func (*LibraryInfo) Descriptor() ([]byte, []int)

func (*LibraryInfo) GetCoreLibraryVersion

func (m *LibraryInfo) GetCoreLibraryVersion() string

func (*LibraryInfo) GetExporterVersion

func (m *LibraryInfo) GetExporterVersion() string

func (*LibraryInfo) GetLanguage

func (m *LibraryInfo) GetLanguage() LibraryInfo_Language

func (*LibraryInfo) ProtoMessage

func (*LibraryInfo) ProtoMessage()

func (*LibraryInfo) Reset

func (m *LibraryInfo) Reset()

func (*LibraryInfo) String

func (m *LibraryInfo) String() string

func (*LibraryInfo) XXX_DiscardUnknown

func (m *LibraryInfo) XXX_DiscardUnknown()

func (*LibraryInfo) XXX_Marshal

func (m *LibraryInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LibraryInfo) XXX_Merge

func (m *LibraryInfo) XXX_Merge(src proto.Message)

func (*LibraryInfo) XXX_Size

func (m *LibraryInfo) XXX_Size() int

func (*LibraryInfo) XXX_Unmarshal

func (m *LibraryInfo) XXX_Unmarshal(b []byte) error

type LibraryInfo_Language

type LibraryInfo_Language int32
const (
	LibraryInfo_LANGUAGE_UNSPECIFIED LibraryInfo_Language = 0
	LibraryInfo_CPP                  LibraryInfo_Language = 1
	LibraryInfo_C_SHARP              LibraryInfo_Language = 2
	LibraryInfo_ERLANG               LibraryInfo_Language = 3
	LibraryInfo_GO_LANG              LibraryInfo_Language = 4
	LibraryInfo_JAVA                 LibraryInfo_Language = 5
	LibraryInfo_NODE_JS              LibraryInfo_Language = 6
	LibraryInfo_PHP                  LibraryInfo_Language = 7
	LibraryInfo_PYTHON               LibraryInfo_Language = 8
	LibraryInfo_RUBY                 LibraryInfo_Language = 9
	LibraryInfo_WEB_JS               LibraryInfo_Language = 10
)

func (LibraryInfo_Language) EnumDescriptor

func (LibraryInfo_Language) EnumDescriptor() ([]byte, []int)

func (LibraryInfo_Language) String

func (x LibraryInfo_Language) String() string

type Metric

type Metric struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Metric) Descriptor

func (*Metric) Descriptor() ([]byte, []int)

func (*Metric) ProtoMessage

func (*Metric) ProtoMessage()

func (*Metric) Reset

func (m *Metric) Reset()

func (*Metric) String

func (m *Metric) String() string

func (*Metric) XXX_DiscardUnknown

func (m *Metric) XXX_DiscardUnknown()

func (*Metric) XXX_Marshal

func (m *Metric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metric) XXX_Merge

func (m *Metric) XXX_Merge(src proto.Message)

func (*Metric) XXX_Size

func (m *Metric) XXX_Size() int

func (*Metric) XXX_Unmarshal

func (m *Metric) XXX_Unmarshal(b []byte) error

type MetricBatch

type MetricBatch struct {
	Resource             *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Metrics              []*Metric `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

A list of metrics from a Node.

func (*MetricBatch) Descriptor

func (*MetricBatch) Descriptor() ([]byte, []int)

func (*MetricBatch) GetMetrics

func (m *MetricBatch) GetMetrics() []*Metric

func (*MetricBatch) GetResource

func (m *MetricBatch) GetResource() *Resource

func (*MetricBatch) ProtoMessage

func (*MetricBatch) ProtoMessage()

func (*MetricBatch) Reset

func (m *MetricBatch) Reset()

func (*MetricBatch) String

func (m *MetricBatch) String() string

func (*MetricBatch) XXX_DiscardUnknown

func (m *MetricBatch) XXX_DiscardUnknown()

func (*MetricBatch) XXX_Marshal

func (m *MetricBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricBatch) XXX_Merge

func (m *MetricBatch) XXX_Merge(src proto.Message)

func (*MetricBatch) XXX_Size

func (m *MetricBatch) XXX_Size() int

func (*MetricBatch) XXX_Unmarshal

func (m *MetricBatch) XXX_Unmarshal(b []byte) error

type Module

type Module struct {
	// TODO: document the meaning of this field.
	// For example: main binary, kernel modules, and dynamic libraries
	// such as libc.so, sharedlib.so.
	Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// A unique identifier for the module, usually a hash of its
	// contents.
	BuildId              string   `protobuf:"bytes,2,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A description of a binary module.

func (*Module) Descriptor

func (*Module) Descriptor() ([]byte, []int)

func (*Module) GetBuildId

func (m *Module) GetBuildId() string

func (*Module) GetModule

func (m *Module) GetModule() string

func (*Module) ProtoMessage

func (*Module) ProtoMessage()

func (*Module) Reset

func (m *Module) Reset()

func (*Module) String

func (m *Module) String() string

func (*Module) XXX_DiscardUnknown

func (m *Module) XXX_DiscardUnknown()

func (*Module) XXX_Marshal

func (m *Module) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Module) XXX_Merge

func (m *Module) XXX_Merge(src proto.Message)

func (*Module) XXX_Size

func (m *Module) XXX_Size() int

func (*Module) XXX_Unmarshal

func (m *Module) XXX_Unmarshal(b []byte) error

type Node

type Node struct {
	// Identifier that uniquely identifies a process within a VM/container.
	Identifier *ProcessIdentifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// Information on the OpenCensus Library that initiates the stream.
	LibraryInfo *LibraryInfo `protobuf:"bytes,2,opt,name=library_info,json=libraryInfo,proto3" json:"library_info,omitempty"`
	// Additional information on service.
	ServiceInfo *ServiceInfo `protobuf:"bytes,3,opt,name=service_info,json=serviceInfo,proto3" json:"service_info,omitempty"`
	// Additional attributes.
	Attributes           map[string]*AttributeValue `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

Identifier metadata of the Node that produces the span or tracing data. Note, this is not the metadata about the Node or service that is described by associated spans. In the future we plan to extend the identifier proto definition to support additional information (e.g cloud id, etc.)

func (*Node) Descriptor

func (*Node) Descriptor() ([]byte, []int)

func (*Node) GetAttributes

func (m *Node) GetAttributes() map[string]*AttributeValue

func (*Node) GetIdentifier

func (m *Node) GetIdentifier() *ProcessIdentifier

func (*Node) GetLibraryInfo

func (m *Node) GetLibraryInfo() *LibraryInfo

func (*Node) GetServiceInfo

func (m *Node) GetServiceInfo() *ServiceInfo

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) Reset

func (m *Node) Reset()

func (*Node) String

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal

func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node) XXX_Merge

func (m *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_Size

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal

func (m *Node) XXX_Unmarshal(b []byte) error

type ProcessIdentifier

type ProcessIdentifier struct {
	// The host name. Usually refers to the machine/container name.
	// For example: os.Hostname() in Go, socket.gethostname() in Python.
	HostName string `protobuf:"bytes,1,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// Process id.
	Pid uint32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// Start time of this ProcessIdentifier. Represented in epoch time.
	StartTimeUnixnano    int64    `protobuf:"varint,3,opt,name=start_time_unixnano,json=startTimeUnixnano,proto3" json:"start_time_unixnano,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Identifier that uniquely identifies a process within a VM/container.

func (*ProcessIdentifier) Descriptor

func (*ProcessIdentifier) Descriptor() ([]byte, []int)

func (*ProcessIdentifier) GetHostName

func (m *ProcessIdentifier) GetHostName() string

func (*ProcessIdentifier) GetPid

func (m *ProcessIdentifier) GetPid() uint32

func (*ProcessIdentifier) GetStartTimeUnixnano

func (m *ProcessIdentifier) GetStartTimeUnixnano() int64

func (*ProcessIdentifier) ProtoMessage

func (*ProcessIdentifier) ProtoMessage()

func (*ProcessIdentifier) Reset

func (m *ProcessIdentifier) Reset()

func (*ProcessIdentifier) String

func (m *ProcessIdentifier) String() string

func (*ProcessIdentifier) XXX_DiscardUnknown

func (m *ProcessIdentifier) XXX_DiscardUnknown()

func (*ProcessIdentifier) XXX_Marshal

func (m *ProcessIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessIdentifier) XXX_Merge

func (m *ProcessIdentifier) XXX_Merge(src proto.Message)

func (*ProcessIdentifier) XXX_Size

func (m *ProcessIdentifier) XXX_Size() int

func (*ProcessIdentifier) XXX_Unmarshal

func (m *ProcessIdentifier) XXX_Unmarshal(b []byte) error

type RequestBody

type RequestBody struct {
	// Types that are valid to be assigned to Body:
	//	*RequestBody_Hello
	//	*RequestBody_Export
	Body                 isRequestBody_Body `protobuf_oneof:"body"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

RequestBody is used by transports that unlike gRPC don't have built-in message type multiplexing such as WebSocket.

func (*RequestBody) Descriptor

func (*RequestBody) Descriptor() ([]byte, []int)

func (*RequestBody) GetBody

func (m *RequestBody) GetBody() isRequestBody_Body

func (*RequestBody) GetExport

func (m *RequestBody) GetExport() *ExportRequest

func (*RequestBody) GetHello

func (m *RequestBody) GetHello() *HelloRequest

func (*RequestBody) ProtoMessage

func (*RequestBody) ProtoMessage()

func (*RequestBody) Reset

func (m *RequestBody) Reset()

func (*RequestBody) String

func (m *RequestBody) String() string

func (*RequestBody) XXX_DiscardUnknown

func (m *RequestBody) XXX_DiscardUnknown()

func (*RequestBody) XXX_Marshal

func (m *RequestBody) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestBody) XXX_Merge

func (m *RequestBody) XXX_Merge(src proto.Message)

func (*RequestBody) XXX_OneofWrappers

func (*RequestBody) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*RequestBody) XXX_Size

func (m *RequestBody) XXX_Size() int

func (*RequestBody) XXX_Unmarshal

func (m *RequestBody) XXX_Unmarshal(b []byte) error

type RequestBody_Export

type RequestBody_Export struct {
	Export *ExportRequest `protobuf:"bytes,2,opt,name=export,proto3,oneof"`
}

type RequestBody_Hello

type RequestBody_Hello struct {
	Hello *HelloRequest `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}

type RequestHeader

type RequestHeader struct {
	// Compression method used for body.
	Compression CompressionMethod `protobuf:"varint,1,opt,name=compression,proto3,enum=traceprotobufb.CompressionMethod" json:"compression,omitempty"`
	// Compression level as defined by the compression method.
	CompressionLevel     int32    `protobuf:"varint,2,opt,name=compression_level,json=compressionLevel,proto3" json:"compression_level,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RequestHeader is used by transports that unlike gRPC don't have built-in request compression such as WebSocket. Request body typically follows the header.

func (*RequestHeader) Descriptor

func (*RequestHeader) Descriptor() ([]byte, []int)

func (*RequestHeader) GetCompression

func (m *RequestHeader) GetCompression() CompressionMethod

func (*RequestHeader) GetCompressionLevel

func (m *RequestHeader) GetCompressionLevel() int32

func (*RequestHeader) ProtoMessage

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset

func (m *RequestHeader) Reset()

func (*RequestHeader) String

func (m *RequestHeader) String() string

func (*RequestHeader) XXX_DiscardUnknown

func (m *RequestHeader) XXX_DiscardUnknown()

func (*RequestHeader) XXX_Marshal

func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestHeader) XXX_Merge

func (m *RequestHeader) XXX_Merge(src proto.Message)

func (*RequestHeader) XXX_Size

func (m *RequestHeader) XXX_Size() int

func (*RequestHeader) XXX_Unmarshal

func (m *RequestHeader) XXX_Unmarshal(b []byte) error

type Resource

type Resource struct {
	// Identifier that uniquely identifies a process within a VM/container.
	Identifier *ProcessIdentifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// Additional information on service.
	ServiceInfo *ServiceInfo `protobuf:"bytes,3,opt,name=service_info,json=serviceInfo,proto3" json:"service_info,omitempty"`
	// Set of labels that describe the resource.
	Attributes           map[string]*AttributeValue `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

Resource information.

func (*Resource) Descriptor

func (*Resource) Descriptor() ([]byte, []int)

func (*Resource) GetAttributes

func (m *Resource) GetAttributes() map[string]*AttributeValue

func (*Resource) GetIdentifier

func (m *Resource) GetIdentifier() *ProcessIdentifier

func (*Resource) GetServiceInfo

func (m *Resource) GetServiceInfo() *ServiceInfo

func (*Resource) ProtoMessage

func (*Resource) ProtoMessage()

func (*Resource) Reset

func (m *Resource) Reset()

func (*Resource) String

func (m *Resource) String() string

func (*Resource) XXX_DiscardUnknown

func (m *Resource) XXX_DiscardUnknown()

func (*Resource) XXX_Marshal

func (m *Resource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Resource) XXX_Merge

func (m *Resource) XXX_Merge(src proto.Message)

func (*Resource) XXX_Size

func (m *Resource) XXX_Size() int

func (*Resource) XXX_Unmarshal

func (m *Resource) XXX_Unmarshal(b []byte) error

type Response

type Response struct {
	// Types that are valid to be assigned to Body:
	//	*Response_Hello
	//	*Response_Export
	Body                 isResponse_Body `protobuf_oneof:"body"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Response is used by transports that unlike gRPC don't have built-in message type multiplexing such as WebSocket.

func (*Response) Descriptor

func (*Response) Descriptor() ([]byte, []int)

func (*Response) GetBody

func (m *Response) GetBody() isResponse_Body

func (*Response) GetExport

func (m *Response) GetExport() *ExportResponse

func (*Response) GetHello

func (m *Response) GetHello() *HelloResponse

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) String

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_OneofWrappers

func (*Response) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Response) XXX_Size

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal

func (m *Response) XXX_Unmarshal(b []byte) error

type Response_Export

type Response_Export struct {
	Export *ExportResponse `protobuf:"bytes,2,opt,name=export,proto3,oneof"`
}

type Response_Hello

type Response_Hello struct {
	Hello *HelloResponse `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}

type ServiceInfo

type ServiceInfo struct {
	// Name of the service.
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Additional service information.

func (*ServiceInfo) Descriptor

func (*ServiceInfo) Descriptor() ([]byte, []int)

func (*ServiceInfo) GetName

func (m *ServiceInfo) GetName() string

func (*ServiceInfo) ProtoMessage

func (*ServiceInfo) ProtoMessage()

func (*ServiceInfo) Reset

func (m *ServiceInfo) Reset()

func (*ServiceInfo) String

func (m *ServiceInfo) String() string

func (*ServiceInfo) XXX_DiscardUnknown

func (m *ServiceInfo) XXX_DiscardUnknown()

func (*ServiceInfo) XXX_Marshal

func (m *ServiceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceInfo) XXX_Merge

func (m *ServiceInfo) XXX_Merge(src proto.Message)

func (*ServiceInfo) XXX_Size

func (m *ServiceInfo) XXX_Size() int

func (*ServiceInfo) XXX_Unmarshal

func (m *ServiceInfo) XXX_Unmarshal(b []byte) error

type Span

type Span struct {
	// A unique identifier for a trace. All spans from the same trace share
	// the same `trace_id`. The ID is a 16-byte array. An ID with all zeroes
	// is considered invalid.
	//
	// This field is semantically required. Receiver should generate new
	// random trace_id if empty or invalid trace_id was received.
	//
	// This field is required.
	TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// A unique identifier for a span within a trace, assigned when the span
	// is created. The ID is an 8-byte array. An ID with all zeroes is considered
	// invalid.
	//
	// This field is semantically required. Receiver should generate new
	// random span_id if empty or invalid span_id was received.
	//
	// This field is required.
	SpanId []byte `protobuf:"bytes,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	// The Tracestate on the span.
	Tracestate *Span_Tracestate `protobuf:"bytes,15,opt,name=tracestate,proto3" json:"tracestate,omitempty"`
	// The `span_id` of this span's parent span. If this is a root span, then this
	// field must be empty. The ID is an 8-byte array.
	ParentSpanId []byte `protobuf:"bytes,3,opt,name=parent_span_id,json=parentSpanId,proto3" json:"parent_span_id,omitempty"`
	// A description of the span's operation.
	//
	// For example, the name can be a qualified method name or a file name
	// and a line number where the operation is called. A best practice is to use
	// the same display name at the same call point in an application.
	// This makes it easier to correlate spans in different traces.
	//
	// This field is semantically required to be set to non-empty string.
	// When null or empty string received - receiver may use string "name"
	// as a replacement. There might be smarted algorithms implemented by
	// receiver to fix the empty span name.
	//
	// This field is required.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Distinguishes between spans generated in a particular context. For example,
	// two spans with the same name may be distinguished using `CLIENT` (caller)
	// and `SERVER` (callee) to identify queueing latency associated with the span.
	Kind Span_SpanKind `protobuf:"varint,14,opt,name=kind,proto3,enum=traceprotobufb.Span_SpanKind" json:"kind,omitempty"`
	// The start time of the span. On the client side, this is the time kept by
	// the local machine where the span execution starts. On the server side, this
	// is the time when the server's application handler starts running.
	//
	// This field is semantically required. When not set on receive -
	// receiver should set it to the value of end_time field if it was
	// set. Or to the current time if neither was set. It is important to
	// keep end_time > start_time for consistency.
	//
	// This field is required.
	StartTimeUnixnano int64 `protobuf:"varint,5,opt,name=start_time_unixnano,json=startTimeUnixnano,proto3" json:"start_time_unixnano,omitempty"`
	// The end time of the span. On the client side, this is the time kept by
	// the local machine where the span execution ends. On the server side, this
	// is the time when the server application handler stops running.
	//
	// This field is semantically required. When not set on receive -
	// receiver should set it to start_time value. It is important to
	// keep end_time > start_time for consistency.
	//
	// This field is required.
	EndTimeUnixnano int64 `protobuf:"varint,6,opt,name=end_time_unixnano,json=endTimeUnixnano,proto3" json:"end_time_unixnano,omitempty"`
	// The set of attributes. The value can be a string, an integer, a double
	// or the Boolean values `true` or `false`. Note, global attributes like
	// server name can be set as tags using resource API. Examples of attributes:
	//
	//     "/http/user_agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_2) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/71.0.3578.98 Safari/537.36"
	//     "/http/server_latency": 300
	//     "abc.com/myattribute": true
	//     "abc.com/score": 10.239
	Attributes map[string]*AttributeValue `` /* 161-byte string literal not displayed */
	// A stack trace captured at the start of the span.
	StackTrace *StackTrace `protobuf:"bytes,8,opt,name=stack_trace,json=stackTrace,proto3" json:"stack_trace,omitempty"`
	// The included time events.
	TimeEvents *Span_TimeEvents `protobuf:"bytes,9,opt,name=time_events,json=timeEvents,proto3" json:"time_events,omitempty"`
	// The included links.
	Links *Span_Links `protobuf:"bytes,10,opt,name=links,proto3" json:"links,omitempty"`
	// An optional final status for this span. Semantically when Status
	// wasn't set it is means span ended without errors and assume
	// Status.Ok (code = 0).
	Status *Status `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"`
	// An optional resource that is associated with this span. If not set, this span
	// should be part of a batch that does include the resource information, unless resource
	// information is unknown.
	Resource *Resource `protobuf:"bytes,16,opt,name=resource,proto3" json:"resource,omitempty"`
	// A highly recommended but not required flag that identifies when a
	// trace crosses a process boundary. True when the parent_span belongs
	// to the same process as the current span. This flag is most commonly
	// used to indicate the need to adjust time as clocks in different
	// processes may not be synchronized.
	SameProcessAsParentSpan *wrappers.BoolValue `` /* 137-byte string literal not displayed */
	// An optional number of child spans that were generated while this span
	// was active. If set, allows an implementation to detect missing child spans.
	ChildSpanCount       *wrappers.UInt32Value `protobuf:"bytes,13,opt,name=child_span_count,json=childSpanCount,proto3" json:"child_span_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

A span represents a single operation within a trace. Spans can be nested to form a trace tree. Spans may also be linked to other spans from the same or different trace. And form graphs. Often, a trace contains a root span that describes the end-to-end latency, and one or more subspans for its sub-operations. A trace can also contain multiple root spans, or none at all. Spans do not need to be contiguous - there may be gaps or overlaps between spans in a trace.

The next id is 17. TODO(bdrutu): Add an example.

func (*Span) Descriptor

func (*Span) Descriptor() ([]byte, []int)

func (*Span) GetAttributes

func (m *Span) GetAttributes() map[string]*AttributeValue

func (*Span) GetChildSpanCount

func (m *Span) GetChildSpanCount() *wrappers.UInt32Value

func (*Span) GetEndTimeUnixnano

func (m *Span) GetEndTimeUnixnano() int64

func (*Span) GetKind

func (m *Span) GetKind() Span_SpanKind
func (m *Span) GetLinks() *Span_Links

func (*Span) GetName

func (m *Span) GetName() string

func (*Span) GetParentSpanId

func (m *Span) GetParentSpanId() []byte

func (*Span) GetResource

func (m *Span) GetResource() *Resource

func (*Span) GetSameProcessAsParentSpan

func (m *Span) GetSameProcessAsParentSpan() *wrappers.BoolValue

func (*Span) GetSpanId

func (m *Span) GetSpanId() []byte

func (*Span) GetStackTrace

func (m *Span) GetStackTrace() *StackTrace

func (*Span) GetStartTimeUnixnano

func (m *Span) GetStartTimeUnixnano() int64

func (*Span) GetStatus

func (m *Span) GetStatus() *Status

func (*Span) GetTimeEvents

func (m *Span) GetTimeEvents() *Span_TimeEvents

func (*Span) GetTraceId

func (m *Span) GetTraceId() []byte

func (*Span) GetTracestate

func (m *Span) GetTracestate() *Span_Tracestate

func (*Span) ProtoMessage

func (*Span) ProtoMessage()

func (*Span) Reset

func (m *Span) Reset()

func (*Span) String

func (m *Span) String() string

func (*Span) XXX_DiscardUnknown

func (m *Span) XXX_DiscardUnknown()

func (*Span) XXX_Marshal

func (m *Span) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Span) XXX_Merge

func (m *Span) XXX_Merge(src proto.Message)

func (*Span) XXX_Size

func (m *Span) XXX_Size() int

func (*Span) XXX_Unmarshal

func (m *Span) XXX_Unmarshal(b []byte) error

type SpanBatch

type SpanBatch struct {
	Resource             *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Spans                []*Span   `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

A list of spans from a Node.

func (*SpanBatch) Descriptor

func (*SpanBatch) Descriptor() ([]byte, []int)

func (*SpanBatch) GetResource

func (m *SpanBatch) GetResource() *Resource

func (*SpanBatch) GetSpans

func (m *SpanBatch) GetSpans() []*Span

func (*SpanBatch) ProtoMessage

func (*SpanBatch) ProtoMessage()

func (*SpanBatch) Reset

func (m *SpanBatch) Reset()

func (*SpanBatch) String

func (m *SpanBatch) String() string

func (*SpanBatch) XXX_DiscardUnknown

func (m *SpanBatch) XXX_DiscardUnknown()

func (*SpanBatch) XXX_Marshal

func (m *SpanBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpanBatch) XXX_Merge

func (m *SpanBatch) XXX_Merge(src proto.Message)

func (*SpanBatch) XXX_Size

func (m *SpanBatch) XXX_Size() int

func (*SpanBatch) XXX_Unmarshal

func (m *SpanBatch) XXX_Unmarshal(b []byte) error
type Span_Link struct {
	// A unique identifier of a trace that this linked span is part of. The ID is a
	// 16-byte array.
	TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// A unique identifier for the linked span. The ID is an 8-byte array.
	SpanId []byte `protobuf:"bytes,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	// The relationship of the current span relative to the linked span.
	Type Span_Link_Type `protobuf:"varint,3,opt,name=type,proto3,enum=traceprotobufb.Span_Link_Type" json:"type,omitempty"`
	// A set of attributes on the link.
	Attributes map[string]*AttributeValue `` /* 161-byte string literal not displayed */
	// The Tracestate associated with the link.
	Tracestate           *Span_Tracestate `protobuf:"bytes,5,opt,name=tracestate,proto3" json:"tracestate,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

A pointer from the current span to another span in the same trace or in a different trace. For example, this can be used in batching operations, where a single batch handler processes multiple requests from different traces or when the handler receives a request from a different project.

func (*Span_Link) Descriptor

func (*Span_Link) Descriptor() ([]byte, []int)

func (*Span_Link) GetAttributes

func (m *Span_Link) GetAttributes() map[string]*AttributeValue

func (*Span_Link) GetSpanId

func (m *Span_Link) GetSpanId() []byte

func (*Span_Link) GetTraceId

func (m *Span_Link) GetTraceId() []byte

func (*Span_Link) GetTracestate

func (m *Span_Link) GetTracestate() *Span_Tracestate

func (*Span_Link) GetType

func (m *Span_Link) GetType() Span_Link_Type

func (*Span_Link) ProtoMessage

func (*Span_Link) ProtoMessage()

func (*Span_Link) Reset

func (m *Span_Link) Reset()

func (*Span_Link) String

func (m *Span_Link) String() string

func (*Span_Link) XXX_DiscardUnknown

func (m *Span_Link) XXX_DiscardUnknown()

func (*Span_Link) XXX_Marshal

func (m *Span_Link) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Span_Link) XXX_Merge

func (m *Span_Link) XXX_Merge(src proto.Message)

func (*Span_Link) XXX_Size

func (m *Span_Link) XXX_Size() int

func (*Span_Link) XXX_Unmarshal

func (m *Span_Link) XXX_Unmarshal(b []byte) error
type Span_Link_Type int32

The relationship of the current span relative to the linked span: child, parent, or unspecified.

const (
	// The relationship of the two spans is unknown, or known but other
	// than parent-child.
	Span_Link_TYPE_UNSPECIFIED Span_Link_Type = 0
	// The linked span is a child of the current span.
	Span_Link_CHILD_LINKED_SPAN Span_Link_Type = 1
	// The linked span is a parent of the current span.
	Span_Link_PARENT_LINKED_SPAN Span_Link_Type = 2
)
func (Span_Link_Type) EnumDescriptor() ([]byte, []int)
func (x Span_Link_Type) String() string
type Span_Links struct {
	// A collection of links.
	Link []*Span_Link `protobuf:"bytes,1,rep,name=link,proto3" json:"link,omitempty"`
	// The number of dropped links after the maximum size was enforced. If
	// this value is 0, then no links were dropped.
	DroppedLinksCount    int32    `protobuf:"varint,2,opt,name=dropped_links_count,json=droppedLinksCount,proto3" json:"dropped_links_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A collection of links, which are references from this span to a span in the same or different trace.

func (*Span_Links) Descriptor

func (*Span_Links) Descriptor() ([]byte, []int)

func (*Span_Links) GetDroppedLinksCount

func (m *Span_Links) GetDroppedLinksCount() int32
func (m *Span_Links) GetLink() []*Span_Link

func (*Span_Links) ProtoMessage

func (*Span_Links) ProtoMessage()

func (*Span_Links) Reset

func (m *Span_Links) Reset()

func (*Span_Links) String

func (m *Span_Links) String() string

func (*Span_Links) XXX_DiscardUnknown

func (m *Span_Links) XXX_DiscardUnknown()

func (*Span_Links) XXX_Marshal

func (m *Span_Links) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Span_Links) XXX_Merge

func (m *Span_Links) XXX_Merge(src proto.Message)

func (*Span_Links) XXX_Size

func (m *Span_Links) XXX_Size() int

func (*Span_Links) XXX_Unmarshal

func (m *Span_Links) XXX_Unmarshal(b []byte) error

type Span_SpanKind

type Span_SpanKind int32

Type of span. Can be used to specify additional relationships between spans in addition to a parent/child relationship.

const (
	// Unspecified.
	Span_SPAN_KIND_UNSPECIFIED Span_SpanKind = 0
	// Indicates that the span covers server-side handling of an RPC or other
	// remote network request.
	Span_SERVER Span_SpanKind = 1
	// Indicates that the span covers the client-side wrapper around an RPC or
	// other remote request.
	Span_CLIENT Span_SpanKind = 2
)

func (Span_SpanKind) EnumDescriptor

func (Span_SpanKind) EnumDescriptor() ([]byte, []int)

func (Span_SpanKind) String

func (x Span_SpanKind) String() string

type Span_TimeEvent

type Span_TimeEvent struct {
	// The time the event occurred.
	TimeUnixnano int64 `protobuf:"varint,1,opt,name=time_unixnano,json=timeUnixnano,proto3" json:"time_unixnano,omitempty"`
	// A `TimeEvent` can contain either an `Annotation` object or a
	// `MessageEvent` object, but not both.
	//
	// Types that are valid to be assigned to Value:
	//	*Span_TimeEvent_Annotation_
	//	*Span_TimeEvent_MessageEvent_
	Value                isSpan_TimeEvent_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

A time-stamped annotation or message event in the Span.

func (*Span_TimeEvent) Descriptor

func (*Span_TimeEvent) Descriptor() ([]byte, []int)

func (*Span_TimeEvent) GetAnnotation

func (m *Span_TimeEvent) GetAnnotation() *Span_TimeEvent_Annotation

func (*Span_TimeEvent) GetMessageEvent

func (m *Span_TimeEvent) GetMessageEvent() *Span_TimeEvent_MessageEvent

func (*Span_TimeEvent) GetTimeUnixnano

func (m *Span_TimeEvent) GetTimeUnixnano() int64

func (*Span_TimeEvent) GetValue

func (m *Span_TimeEvent) GetValue() isSpan_TimeEvent_Value

func (*Span_TimeEvent) ProtoMessage

func (*Span_TimeEvent) ProtoMessage()

func (*Span_TimeEvent) Reset

func (m *Span_TimeEvent) Reset()

func (*Span_TimeEvent) String

func (m *Span_TimeEvent) String() string

func (*Span_TimeEvent) XXX_DiscardUnknown

func (m *Span_TimeEvent) XXX_DiscardUnknown()

func (*Span_TimeEvent) XXX_Marshal

func (m *Span_TimeEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Span_TimeEvent) XXX_Merge

func (m *Span_TimeEvent) XXX_Merge(src proto.Message)

func (*Span_TimeEvent) XXX_OneofWrappers

func (*Span_TimeEvent) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Span_TimeEvent) XXX_Size

func (m *Span_TimeEvent) XXX_Size() int

func (*Span_TimeEvent) XXX_Unmarshal

func (m *Span_TimeEvent) XXX_Unmarshal(b []byte) error

type Span_TimeEvent_Annotation

type Span_TimeEvent_Annotation struct {
	// A user-supplied message describing the event.
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// A set of attributes on the annotation.
	Attributes           map[string]*AttributeValue `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

A text annotation with a set of attributes.

func (*Span_TimeEvent_Annotation) Descriptor

func (*Span_TimeEvent_Annotation) Descriptor() ([]byte, []int)

func (*Span_TimeEvent_Annotation) GetAttributes

func (m *Span_TimeEvent_Annotation) GetAttributes() map[string]*AttributeValue

func (*Span_TimeEvent_Annotation) GetDescription

func (m *Span_TimeEvent_Annotation) GetDescription() string

func (*Span_TimeEvent_Annotation) ProtoMessage

func (*Span_TimeEvent_Annotation) ProtoMessage()

func (*Span_TimeEvent_Annotation) Reset

func (m *Span_TimeEvent_Annotation) Reset()

func (*Span_TimeEvent_Annotation) String

func (m *Span_TimeEvent_Annotation) String() string

func (*Span_TimeEvent_Annotation) XXX_DiscardUnknown

func (m *Span_TimeEvent_Annotation) XXX_DiscardUnknown()

func (*Span_TimeEvent_Annotation) XXX_Marshal

func (m *Span_TimeEvent_Annotation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Span_TimeEvent_Annotation) XXX_Merge

func (m *Span_TimeEvent_Annotation) XXX_Merge(src proto.Message)

func (*Span_TimeEvent_Annotation) XXX_Size

func (m *Span_TimeEvent_Annotation) XXX_Size() int

func (*Span_TimeEvent_Annotation) XXX_Unmarshal

func (m *Span_TimeEvent_Annotation) XXX_Unmarshal(b []byte) error

type Span_TimeEvent_Annotation_

type Span_TimeEvent_Annotation_ struct {
	Annotation *Span_TimeEvent_Annotation `protobuf:"bytes,2,opt,name=annotation,proto3,oneof"`
}

type Span_TimeEvent_MessageEvent

type Span_TimeEvent_MessageEvent struct {
	// The type of MessageEvent. Indicates whether the message was sent or
	// received.
	Type Span_TimeEvent_MessageEvent_Type `protobuf:"varint,1,opt,name=type,proto3,enum=traceprotobufb.Span_TimeEvent_MessageEvent_Type" json:"type,omitempty"`
	// An identifier for the MessageEvent's message that can be used to match
	// SENT and RECEIVED MessageEvents. For example, this field could
	// represent a sequence ID for a streaming RPC. It is recommended to be
	// unique within a Span.
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// The number of uncompressed bytes sent or received.
	UncompressedSize uint64 `protobuf:"varint,3,opt,name=uncompressed_size,json=uncompressedSize,proto3" json:"uncompressed_size,omitempty"`
	// The number of compressed bytes sent or received. If zero, assumed to
	// be the same size as uncompressed.
	CompressedSize       uint64   `protobuf:"varint,4,opt,name=compressed_size,json=compressedSize,proto3" json:"compressed_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

An event describing a message sent/received between Spans.

func (*Span_TimeEvent_MessageEvent) Descriptor

func (*Span_TimeEvent_MessageEvent) Descriptor() ([]byte, []int)

func (*Span_TimeEvent_MessageEvent) GetCompressedSize

func (m *Span_TimeEvent_MessageEvent) GetCompressedSize() uint64

func (*Span_TimeEvent_MessageEvent) GetId

func (*Span_TimeEvent_MessageEvent) GetType

func (*Span_TimeEvent_MessageEvent) GetUncompressedSize

func (m *Span_TimeEvent_MessageEvent) GetUncompressedSize() uint64

func (*Span_TimeEvent_MessageEvent) ProtoMessage

func (*Span_TimeEvent_MessageEvent) ProtoMessage()

func (*Span_TimeEvent_MessageEvent) Reset

func (m *Span_TimeEvent_MessageEvent) Reset()

func (*Span_TimeEvent_MessageEvent) String

func (m *Span_TimeEvent_MessageEvent) String() string

func (*Span_TimeEvent_MessageEvent) XXX_DiscardUnknown

func (m *Span_TimeEvent_MessageEvent) XXX_DiscardUnknown()

func (*Span_TimeEvent_MessageEvent) XXX_Marshal

func (m *Span_TimeEvent_MessageEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Span_TimeEvent_MessageEvent) XXX_Merge

func (m *Span_TimeEvent_MessageEvent) XXX_Merge(src proto.Message)

func (*Span_TimeEvent_MessageEvent) XXX_Size

func (m *Span_TimeEvent_MessageEvent) XXX_Size() int

func (*Span_TimeEvent_MessageEvent) XXX_Unmarshal

func (m *Span_TimeEvent_MessageEvent) XXX_Unmarshal(b []byte) error

type Span_TimeEvent_MessageEvent_

type Span_TimeEvent_MessageEvent_ struct {
	MessageEvent *Span_TimeEvent_MessageEvent `protobuf:"bytes,3,opt,name=message_event,json=messageEvent,proto3,oneof"`
}

type Span_TimeEvent_MessageEvent_Type

type Span_TimeEvent_MessageEvent_Type int32

Indicates whether the message was sent or received.

const (
	// Unknown event type.
	Span_TimeEvent_MessageEvent_TYPE_UNSPECIFIED Span_TimeEvent_MessageEvent_Type = 0
	// Indicates a sent message.
	Span_TimeEvent_MessageEvent_SENT Span_TimeEvent_MessageEvent_Type = 1
	// Indicates a received message.
	Span_TimeEvent_MessageEvent_RECEIVED Span_TimeEvent_MessageEvent_Type = 2
)

func (Span_TimeEvent_MessageEvent_Type) EnumDescriptor

func (Span_TimeEvent_MessageEvent_Type) EnumDescriptor() ([]byte, []int)

func (Span_TimeEvent_MessageEvent_Type) String

type Span_TimeEvents

type Span_TimeEvents struct {
	// A collection of `TimeEvent`s.
	TimeEvent []*Span_TimeEvent `protobuf:"bytes,1,rep,name=time_event,json=timeEvent,proto3" json:"time_event,omitempty"`
	// The number of dropped annotations in all the included time events.
	// If the value is 0, then no annotations were dropped.
	DroppedAnnotationsCount int32 `` /* 133-byte string literal not displayed */
	// The number of dropped message events in all the included time events.
	// If the value is 0, then no message events were dropped.
	DroppedMessageEventsCount int32    `` /* 141-byte string literal not displayed */
	XXX_NoUnkeyedLiteral      struct{} `json:"-"`
	XXX_unrecognized          []byte   `json:"-"`
	XXX_sizecache             int32    `json:"-"`
}

A collection of `TimeEvent`s. A `TimeEvent` is a time-stamped annotation on the span, consisting of either user-supplied key-value pairs, or details of a message sent/received between Spans.

func (*Span_TimeEvents) Descriptor

func (*Span_TimeEvents) Descriptor() ([]byte, []int)

func (*Span_TimeEvents) GetDroppedAnnotationsCount

func (m *Span_TimeEvents) GetDroppedAnnotationsCount() int32

func (*Span_TimeEvents) GetDroppedMessageEventsCount

func (m *Span_TimeEvents) GetDroppedMessageEventsCount() int32

func (*Span_TimeEvents) GetTimeEvent

func (m *Span_TimeEvents) GetTimeEvent() []*Span_TimeEvent

func (*Span_TimeEvents) ProtoMessage

func (*Span_TimeEvents) ProtoMessage()

func (*Span_TimeEvents) Reset

func (m *Span_TimeEvents) Reset()

func (*Span_TimeEvents) String

func (m *Span_TimeEvents) String() string

func (*Span_TimeEvents) XXX_DiscardUnknown

func (m *Span_TimeEvents) XXX_DiscardUnknown()

func (*Span_TimeEvents) XXX_Marshal

func (m *Span_TimeEvents) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Span_TimeEvents) XXX_Merge

func (m *Span_TimeEvents) XXX_Merge(src proto.Message)

func (*Span_TimeEvents) XXX_Size

func (m *Span_TimeEvents) XXX_Size() int

func (*Span_TimeEvents) XXX_Unmarshal

func (m *Span_TimeEvents) XXX_Unmarshal(b []byte) error

type Span_Tracestate

type Span_Tracestate struct {
	// A list of entries that represent the Tracestate.
	Entries              []*Span_Tracestate_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

This field conveys information about request position in multiple distributed tracing graphs. It is a list of Tracestate.Entry with a maximum of 32 members in the list.

See the https://github.com/w3c/distributed-tracing for more details about this field.

func (*Span_Tracestate) Descriptor

func (*Span_Tracestate) Descriptor() ([]byte, []int)

func (*Span_Tracestate) GetEntries

func (m *Span_Tracestate) GetEntries() []*Span_Tracestate_Entry

func (*Span_Tracestate) ProtoMessage

func (*Span_Tracestate) ProtoMessage()

func (*Span_Tracestate) Reset

func (m *Span_Tracestate) Reset()

func (*Span_Tracestate) String

func (m *Span_Tracestate) String() string

func (*Span_Tracestate) XXX_DiscardUnknown

func (m *Span_Tracestate) XXX_DiscardUnknown()

func (*Span_Tracestate) XXX_Marshal

func (m *Span_Tracestate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Span_Tracestate) XXX_Merge

func (m *Span_Tracestate) XXX_Merge(src proto.Message)

func (*Span_Tracestate) XXX_Size

func (m *Span_Tracestate) XXX_Size() int

func (*Span_Tracestate) XXX_Unmarshal

func (m *Span_Tracestate) XXX_Unmarshal(b []byte) error

type Span_Tracestate_Entry

type Span_Tracestate_Entry struct {
	// The key must begin with a lowercase letter, and can only contain
	// lowercase letters 'a'-'z', digits '0'-'9', underscores '_', dashes
	// '-', asterisks '*', and forward slashes '/'.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The value is opaque string up to 256 characters printable ASCII
	// RFC0020 characters (i.e., the range 0x20 to 0x7E) except ',' and '='.
	// Note that this also excludes tabs, newlines, carriage returns, etc.
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Span_Tracestate_Entry) Descriptor

func (*Span_Tracestate_Entry) Descriptor() ([]byte, []int)

func (*Span_Tracestate_Entry) GetKey

func (m *Span_Tracestate_Entry) GetKey() string

func (*Span_Tracestate_Entry) GetValue

func (m *Span_Tracestate_Entry) GetValue() string

func (*Span_Tracestate_Entry) ProtoMessage

func (*Span_Tracestate_Entry) ProtoMessage()

func (*Span_Tracestate_Entry) Reset

func (m *Span_Tracestate_Entry) Reset()

func (*Span_Tracestate_Entry) String

func (m *Span_Tracestate_Entry) String() string

func (*Span_Tracestate_Entry) XXX_DiscardUnknown

func (m *Span_Tracestate_Entry) XXX_DiscardUnknown()

func (*Span_Tracestate_Entry) XXX_Marshal

func (m *Span_Tracestate_Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Span_Tracestate_Entry) XXX_Merge

func (m *Span_Tracestate_Entry) XXX_Merge(src proto.Message)

func (*Span_Tracestate_Entry) XXX_Size

func (m *Span_Tracestate_Entry) XXX_Size() int

func (*Span_Tracestate_Entry) XXX_Unmarshal

func (m *Span_Tracestate_Entry) XXX_Unmarshal(b []byte) error

type StackTrace

type StackTrace struct {
	// Stack frames in this stack trace.
	StackFrames *StackTrace_StackFrames `protobuf:"bytes,1,opt,name=stack_frames,json=stackFrames,proto3" json:"stack_frames,omitempty"`
	// The hash ID is used to conserve network bandwidth for duplicate
	// stack traces within a single trace.
	//
	// Often multiple spans will have identical stack traces.
	// The first occurrence of a stack trace should contain both
	// `stack_frames` and a value in `stack_trace_hash_id`.
	//
	// Subsequent spans within the same request can refer
	// to that stack trace by setting only `stack_trace_hash_id`.
	//
	// TODO: describe how to deal with the case where stack_trace_hash_id is
	// zero because it was not set.
	StackTraceHashId     uint64   `protobuf:"varint,2,opt,name=stack_trace_hash_id,json=stackTraceHashId,proto3" json:"stack_trace_hash_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The call stack which originated this span.

func (*StackTrace) Descriptor

func (*StackTrace) Descriptor() ([]byte, []int)

func (*StackTrace) GetStackFrames

func (m *StackTrace) GetStackFrames() *StackTrace_StackFrames

func (*StackTrace) GetStackTraceHashId

func (m *StackTrace) GetStackTraceHashId() uint64

func (*StackTrace) ProtoMessage

func (*StackTrace) ProtoMessage()

func (*StackTrace) Reset

func (m *StackTrace) Reset()

func (*StackTrace) String

func (m *StackTrace) String() string

func (*StackTrace) XXX_DiscardUnknown

func (m *StackTrace) XXX_DiscardUnknown()

func (*StackTrace) XXX_Marshal

func (m *StackTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StackTrace) XXX_Merge

func (m *StackTrace) XXX_Merge(src proto.Message)

func (*StackTrace) XXX_Size

func (m *StackTrace) XXX_Size() int

func (*StackTrace) XXX_Unmarshal

func (m *StackTrace) XXX_Unmarshal(b []byte) error

type StackTrace_StackFrame

type StackTrace_StackFrame struct {
	// The fully-qualified name that uniquely identifies the function or
	// method that is active in this frame.
	FunctionName string `protobuf:"bytes,1,opt,name=function_name,json=functionName,proto3" json:"function_name,omitempty"`
	// An un-mangled function name, if `function_name` is
	// [mangled](http://www.avabodh.com/cxxin/namemangling.html). The name can
	// be fully qualified.
	OriginalFunctionName string `protobuf:"bytes,2,opt,name=original_function_name,json=originalFunctionName,proto3" json:"original_function_name,omitempty"`
	// The name of the source file where the function call appears.
	FileName string `protobuf:"bytes,3,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// The line number in `file_name` where the function call appears.
	LineNumber int64 `protobuf:"varint,4,opt,name=line_number,json=lineNumber,proto3" json:"line_number,omitempty"`
	// The column number where the function call appears, if available.
	// This is important in JavaScript because of its anonymous functions.
	ColumnNumber int64 `protobuf:"varint,5,opt,name=column_number,json=columnNumber,proto3" json:"column_number,omitempty"`
	// The binary module from where the code was loaded.
	LoadModule *Module `protobuf:"bytes,6,opt,name=load_module,json=loadModule,proto3" json:"load_module,omitempty"`
	// The version of the deployed source code.
	SourceVersion        string   `protobuf:"bytes,7,opt,name=source_version,json=sourceVersion,proto3" json:"source_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A single stack frame in a stack trace.

func (*StackTrace_StackFrame) Descriptor

func (*StackTrace_StackFrame) Descriptor() ([]byte, []int)

func (*StackTrace_StackFrame) GetColumnNumber

func (m *StackTrace_StackFrame) GetColumnNumber() int64

func (*StackTrace_StackFrame) GetFileName

func (m *StackTrace_StackFrame) GetFileName() string

func (*StackTrace_StackFrame) GetFunctionName

func (m *StackTrace_StackFrame) GetFunctionName() string

func (*StackTrace_StackFrame) GetLineNumber

func (m *StackTrace_StackFrame) GetLineNumber() int64

func (*StackTrace_StackFrame) GetLoadModule

func (m *StackTrace_StackFrame) GetLoadModule() *Module

func (*StackTrace_StackFrame) GetOriginalFunctionName

func (m *StackTrace_StackFrame) GetOriginalFunctionName() string

func (*StackTrace_StackFrame) GetSourceVersion

func (m *StackTrace_StackFrame) GetSourceVersion() string

func (*StackTrace_StackFrame) ProtoMessage

func (*StackTrace_StackFrame) ProtoMessage()

func (*StackTrace_StackFrame) Reset

func (m *StackTrace_StackFrame) Reset()

func (*StackTrace_StackFrame) String

func (m *StackTrace_StackFrame) String() string

func (*StackTrace_StackFrame) XXX_DiscardUnknown

func (m *StackTrace_StackFrame) XXX_DiscardUnknown()

func (*StackTrace_StackFrame) XXX_Marshal

func (m *StackTrace_StackFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StackTrace_StackFrame) XXX_Merge

func (m *StackTrace_StackFrame) XXX_Merge(src proto.Message)

func (*StackTrace_StackFrame) XXX_Size

func (m *StackTrace_StackFrame) XXX_Size() int

func (*StackTrace_StackFrame) XXX_Unmarshal

func (m *StackTrace_StackFrame) XXX_Unmarshal(b []byte) error

type StackTrace_StackFrames

type StackTrace_StackFrames struct {
	// Stack frames in this call stack.
	Frame []*StackTrace_StackFrame `protobuf:"bytes,1,rep,name=frame,proto3" json:"frame,omitempty"`
	// The number of stack frames that were dropped because there
	// were too many stack frames.
	// If this value is 0, then no stack frames were dropped.
	DroppedFramesCount   int32    `protobuf:"varint,2,opt,name=dropped_frames_count,json=droppedFramesCount,proto3" json:"dropped_frames_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A collection of stack frames, which can be truncated.

func (*StackTrace_StackFrames) Descriptor

func (*StackTrace_StackFrames) Descriptor() ([]byte, []int)

func (*StackTrace_StackFrames) GetDroppedFramesCount

func (m *StackTrace_StackFrames) GetDroppedFramesCount() int32

func (*StackTrace_StackFrames) GetFrame

func (*StackTrace_StackFrames) ProtoMessage

func (*StackTrace_StackFrames) ProtoMessage()

func (*StackTrace_StackFrames) Reset

func (m *StackTrace_StackFrames) Reset()

func (*StackTrace_StackFrames) String

func (m *StackTrace_StackFrames) String() string

func (*StackTrace_StackFrames) XXX_DiscardUnknown

func (m *StackTrace_StackFrames) XXX_DiscardUnknown()

func (*StackTrace_StackFrames) XXX_Marshal

func (m *StackTrace_StackFrames) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StackTrace_StackFrames) XXX_Merge

func (m *StackTrace_StackFrames) XXX_Merge(src proto.Message)

func (*StackTrace_StackFrames) XXX_Size

func (m *StackTrace_StackFrames) XXX_Size() int

func (*StackTrace_StackFrames) XXX_Unmarshal

func (m *StackTrace_StackFrames) XXX_Unmarshal(b []byte) error

type Status

type Status struct {
	// The status code. This is optional field. It is safe to assume 0 (OK)
	// when not set.
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// A developer-facing error message, which should be in English.
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. This proto's fields are a subset of those of [google.rpc.Status](https://github.com/googleapis/googleapis/blob/master/google/rpc/status.proto), which is used by [gRPC](https://github.com/grpc).

func (*Status) Descriptor

func (*Status) Descriptor() ([]byte, []int)

func (*Status) GetCode

func (m *Status) GetCode() int32

func (*Status) GetMessage

func (m *Status) GetMessage() string

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) Reset

func (m *Status) Reset()

func (*Status) String

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal

func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status) XXX_Merge

func (m *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal

func (m *Status) XXX_Unmarshal(b []byte) error

type StreamExporterClient

type StreamExporterClient interface {
	// Sends a batch of telemetry data.
	Export(ctx context.Context, opts ...grpc.CallOption) (StreamExporter_ExportClient, error)
}

StreamExporterClient is the client API for StreamExporter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStreamExporterClient

func NewStreamExporterClient(cc *grpc.ClientConn) StreamExporterClient

type StreamExporterServer

type StreamExporterServer interface {
	// Sends a batch of telemetry data.
	Export(StreamExporter_ExportServer) error
}

StreamExporterServer is the server API for StreamExporter service.

type StreamExporter_ExportClient

type StreamExporter_ExportClient interface {
	Send(*ExportRequest) error
	Recv() (*ExportResponse, error)
	grpc.ClientStream
}

type StreamExporter_ExportServer

type StreamExporter_ExportServer interface {
	Send(*ExportResponse) error
	Recv() (*ExportRequest, error)
	grpc.ServerStream
}

type UnaryExporterClient

type UnaryExporterClient interface {
	// Sends a batch of telemetry data.
	Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (*ExportResponse, error)
}

UnaryExporterClient is the client API for UnaryExporter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUnaryExporterClient

func NewUnaryExporterClient(cc *grpc.ClientConn) UnaryExporterClient

type UnaryExporterServer

type UnaryExporterServer interface {
	// Sends a batch of telemetry data.
	Export(context.Context, *ExportRequest) (*ExportResponse, error)
}

UnaryExporterServer is the server API for UnaryExporter service.

type UnimplementedStreamExporterServer

type UnimplementedStreamExporterServer struct {
}

UnimplementedStreamExporterServer can be embedded to have forward compatible implementations.

func (*UnimplementedStreamExporterServer) Export

type UnimplementedUnaryExporterServer

type UnimplementedUnaryExporterServer struct {
}

UnimplementedUnaryExporterServer can be embedded to have forward compatible implementations.

func (*UnimplementedUnaryExporterServer) Export

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL