Versions in this module Expand all Collapse all v0 v0.0.2 Feb 18, 2020 v0.0.1 Feb 18, 2020 Changes in this version + var ErrIntOverflowKafka = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthKafka = fmt.Errorf("proto: negative length found during unmarshaling") + type Kafka struct + IngestTime int64 + OrgID int64 + Span *jaeger_api_v2.Span + TokenID int64 + func (*Kafka) Descriptor() ([]byte, []int) + func (*Kafka) ProtoMessage() + 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 (m *Kafka) Reset() + func (m *Kafka) Size() (n int) + func (m *Kafka) String() string + func (m *Kafka) Unmarshal(dAtA []byte) error
Go to main page