splunk_trace_firehose

Documentation

Overview

Package splunk_trace_firehose is a generated protocol buffer package.

It is generated from these files:

kafka.proto

It has these top-level messages:

Kafka

Index

• Variables
• type Kafka
  • func (*Kafka) Descriptor() ([]byte, []int)
  • func (m *Kafka) GetIngestTime() int64
  • func (m *Kafka) GetOrgID() int64
  • func (m *Kafka) GetSpan() *jaeger_api_v2.Span
  • func (m *Kafka) GetTokenID() int64
  • func (m *Kafka) Marshal() (dAtA []byte, err error)
  • func (m *Kafka) MarshalTo(dAtA []byte) (int, error)
  • func (*Kafka) ProtoMessage()
  • func (m *Kafka) Reset()
  • func (m *Kafka) Size() (n int)
  • func (m *Kafka) String() string
  • func (m *Kafka) Unmarshal(dAtA []byte) error

Variables

var (
	ErrInvalidLengthKafka = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowKafka   = fmt.Errorf("proto: integer overflow")
)

Types

type Kafka

type Kafka struct {
	Span       *jaeger_api_v2.Span `protobuf:"bytes,1,opt,name=span" json:"span,omitempty"`
	OrgID      int64               `protobuf:"varint,2,opt,name=orgID,proto3" json:"orgID,omitempty"`
	TokenID    int64               `protobuf:"varint,3,opt,name=tokenID,proto3" json:"tokenID,omitempty"`
	IngestTime int64               `protobuf:"varint,4,opt,name=ingestTime,proto3" json:"ingestTime,omitempty"`
}

func (*Kafka) Descriptor

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

func (*Kafka) GetIngestTime

func (m *Kafka) GetIngestTime() int64

func (*Kafka) GetOrgID

func (m *Kafka) GetOrgID() int64

func (*Kafka) GetSpan

func (m *Kafka) GetSpan() *jaeger_api_v2.Span

func (*Kafka) GetTokenID

func (m *Kafka) GetTokenID() int64

func (*Kafka) Marshal

func (m *Kafka) Marshal() (dAtA []byte, err error)

func (*Kafka) MarshalTo

func (m *Kafka) MarshalTo(dAtA []byte) (int, error)

func (*Kafka) ProtoMessage

func (*Kafka) ProtoMessage()

func (*Kafka) Reset

func (m *Kafka) Reset()

func (*Kafka) Size

func (m *Kafka) Size() (n int)

func (*Kafka) String

func (m *Kafka) String() string

func (*Kafka) Unmarshal

func (m *Kafka) Unmarshal(dAtA []byte) error