// Code generated by protoc-gen-gogo. DO NOT EDIT. // source: stats.proto package pb import ( fmt "fmt" _ "github.com/gogo/protobuf/gogoproto" proto "github.com/gogo/protobuf/proto" io "io" math "math" ) // Reference imports to suppress errors if they are not otherwise used. var _ = proto.Marshal var _ = fmt.Errorf var _ = math.Inf // This is a compile-time assertion to ensure that this generated file // is compatible with the proto package it is being compiled against. // A compilation error at this line likely means your copy of the // proto package needs to be updated. const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package // StatsPayload is the payload used to send stats from the agent to the backend. type StatsPayload struct { AgentHostname string `protobuf:"bytes,1,opt,name=agentHostname,proto3" json:"agentHostname,omitempty"` AgentEnv string `protobuf:"bytes,2,opt,name=agentEnv,proto3" json:"agentEnv,omitempty"` Stats []ClientStatsPayload `protobuf:"bytes,3,rep,name=stats,proto3" json:"stats"` AgentVersion string `protobuf:"bytes,4,opt,name=agentVersion,proto3" json:"agentVersion,omitempty"` ClientComputed bool `protobuf:"varint,5,opt,name=clientComputed,proto3" json:"clientComputed,omitempty"` } func (m *StatsPayload) Reset() { *m = StatsPayload{} } func (m *StatsPayload) String() string { return proto.CompactTextString(m) } func (*StatsPayload) ProtoMessage() {} func (*StatsPayload) Descriptor() ([]byte, []int) { return fileDescriptor_b4756a0aec8b9d44, []int{0} } func (m *StatsPayload) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *StatsPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_StatsPayload.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *StatsPayload) XXX_Merge(src proto.Message) { xxx_messageInfo_StatsPayload.Merge(m, src) } func (m *StatsPayload) XXX_Size() int { return m.Size() } func (m *StatsPayload) XXX_DiscardUnknown() { xxx_messageInfo_StatsPayload.DiscardUnknown(m) } var xxx_messageInfo_StatsPayload proto.InternalMessageInfo func (m *StatsPayload) GetAgentHostname() string { if m != nil { return m.AgentHostname } return "" } func (m *StatsPayload) GetAgentEnv() string { if m != nil { return m.AgentEnv } return "" } func (m *StatsPayload) GetStats() []ClientStatsPayload { if m != nil { return m.Stats } return nil } func (m *StatsPayload) GetAgentVersion() string { if m != nil { return m.AgentVersion } return "" } func (m *StatsPayload) GetClientComputed() bool { if m != nil { return m.ClientComputed } return false } // ClientStatsPayload is the first layer of span stats aggregation. It is also // the payload sent by tracers to the agent when stats in tracer are enabled. type ClientStatsPayload struct { // Hostname is the tracer hostname. It's extracted from spans with "_dd.hostname" meta // or set by tracer stats payload when hostname reporting is enabled. Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` Env string `protobuf:"bytes,2,opt,name=env,proto3" json:"env,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` Stats []ClientStatsBucket `protobuf:"bytes,4,rep,name=stats,proto3" json:"stats"` Lang string `protobuf:"bytes,5,opt,name=lang,proto3" json:"lang,omitempty"` TracerVersion string `protobuf:"bytes,6,opt,name=tracerVersion,proto3" json:"tracerVersion,omitempty"` RuntimeID string `protobuf:"bytes,7,opt,name=runtimeID,proto3" json:"runtimeID,omitempty"` Sequence uint64 `protobuf:"varint,8,opt,name=sequence,proto3" json:"sequence,omitempty"` // AgentAggregation is set by the agent on tracer payloads modified by the agent aggregation layer // characterizes counts only and distributions only payloads AgentAggregation string `protobuf:"bytes,9,opt,name=agentAggregation,proto3" json:"agentAggregation,omitempty"` // Service is the main service of the tracer. // It is part of unified tagging: https://docs.datadoghq.com/getting_started/tagging/unified_service_tagging Service string `protobuf:"bytes,10,opt,name=service,proto3" json:"service,omitempty"` // ContainerID specifies the origin container ID. It is meant to be populated by the client and may // be enhanced by the agent to ensure it is unique. ContainerID string `protobuf:"bytes,11,opt,name=containerID,proto3" json:"containerID,omitempty"` // Tags specifies a set of tags obtained from the orchestrator (where applicable) using the specified containerID. // This field should be left empty by the client. It only applies to some specific environment. Tags []string `protobuf:"bytes,12,rep,name=tags,proto3" json:"tags,omitempty"` } func (m *ClientStatsPayload) Reset() { *m = ClientStatsPayload{} } func (m *ClientStatsPayload) String() string { return proto.CompactTextString(m) } func (*ClientStatsPayload) ProtoMessage() {} func (*ClientStatsPayload) Descriptor() ([]byte, []int) { return fileDescriptor_b4756a0aec8b9d44, []int{1} } func (m *ClientStatsPayload) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *ClientStatsPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_ClientStatsPayload.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *ClientStatsPayload) XXX_Merge(src proto.Message) { xxx_messageInfo_ClientStatsPayload.Merge(m, src) } func (m *ClientStatsPayload) XXX_Size() int { return m.Size() } func (m *ClientStatsPayload) XXX_DiscardUnknown() { xxx_messageInfo_ClientStatsPayload.DiscardUnknown(m) } var xxx_messageInfo_ClientStatsPayload proto.InternalMessageInfo func (m *ClientStatsPayload) GetHostname() string { if m != nil { return m.Hostname } return "" } func (m *ClientStatsPayload) GetEnv() string { if m != nil { return m.Env } return "" } func (m *ClientStatsPayload) GetVersion() string { if m != nil { return m.Version } return "" } func (m *ClientStatsPayload) GetStats() []ClientStatsBucket { if m != nil { return m.Stats } return nil } func (m *ClientStatsPayload) GetLang() string { if m != nil { return m.Lang } return "" } func (m *ClientStatsPayload) GetTracerVersion() string { if m != nil { return m.TracerVersion } return "" } func (m *ClientStatsPayload) GetRuntimeID() string { if m != nil { return m.RuntimeID } return "" } func (m *ClientStatsPayload) GetSequence() uint64 { if m != nil { return m.Sequence } return 0 } func (m *ClientStatsPayload) GetAgentAggregation() string { if m != nil { return m.AgentAggregation } return "" } func (m *ClientStatsPayload) GetService() string { if m != nil { return m.Service } return "" } func (m *ClientStatsPayload) GetContainerID() string { if m != nil { return m.ContainerID } return "" } func (m *ClientStatsPayload) GetTags() []string { if m != nil { return m.Tags } return nil } // ClientStatsBucket is a time bucket containing aggregated stats. type ClientStatsBucket struct { Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` Duration uint64 `protobuf:"varint,2,opt,name=duration,proto3" json:"duration,omitempty"` Stats []ClientGroupedStats `protobuf:"bytes,3,rep,name=stats,proto3" json:"stats"` // AgentTimeShift is the shift applied by the agent stats aggregator on bucket start // when the received bucket start is outside of the agent aggregation window AgentTimeShift int64 `protobuf:"varint,4,opt,name=agentTimeShift,proto3" json:"agentTimeShift,omitempty"` } func (m *ClientStatsBucket) Reset() { *m = ClientStatsBucket{} } func (m *ClientStatsBucket) String() string { return proto.CompactTextString(m) } func (*ClientStatsBucket) ProtoMessage() {} func (*ClientStatsBucket) Descriptor() ([]byte, []int) { return fileDescriptor_b4756a0aec8b9d44, []int{2} } func (m *ClientStatsBucket) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *ClientStatsBucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_ClientStatsBucket.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *ClientStatsBucket) XXX_Merge(src proto.Message) { xxx_messageInfo_ClientStatsBucket.Merge(m, src) } func (m *ClientStatsBucket) XXX_Size() int { return m.Size() } func (m *ClientStatsBucket) XXX_DiscardUnknown() { xxx_messageInfo_ClientStatsBucket.DiscardUnknown(m) } var xxx_messageInfo_ClientStatsBucket proto.InternalMessageInfo func (m *ClientStatsBucket) GetStart() uint64 { if m != nil { return m.Start } return 0 } func (m *ClientStatsBucket) GetDuration() uint64 { if m != nil { return m.Duration } return 0 } func (m *ClientStatsBucket) GetStats() []ClientGroupedStats { if m != nil { return m.Stats } return nil } func (m *ClientStatsBucket) GetAgentTimeShift() int64 { if m != nil { return m.AgentTimeShift } return 0 } // ClientGroupedStats aggregate stats on spans grouped by service, name, resource, status_code, type type ClientGroupedStats struct { Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` HTTPStatusCode uint32 `protobuf:"varint,4,opt,name=HTTP_status_code,json=HTTPStatusCode,proto3" json:"HTTP_status_code,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` DBType string `protobuf:"bytes,6,opt,name=DB_type,json=DBType,proto3" json:"DB_type,omitempty"` Hits uint64 `protobuf:"varint,7,opt,name=hits,proto3" json:"hits,omitempty"` Errors uint64 `protobuf:"varint,8,opt,name=errors,proto3" json:"errors,omitempty"` Duration uint64 `protobuf:"varint,9,opt,name=duration,proto3" json:"duration,omitempty"` OkSummary []byte `protobuf:"bytes,10,opt,name=okSummary,proto3" json:"okSummary,omitempty"` ErrorSummary []byte `protobuf:"bytes,11,opt,name=errorSummary,proto3" json:"errorSummary,omitempty"` Synthetics bool `protobuf:"varint,12,opt,name=synthetics,proto3" json:"synthetics,omitempty"` TopLevelHits uint64 `protobuf:"varint,13,opt,name=topLevelHits,proto3" json:"topLevelHits,omitempty"` PeerService string `protobuf:"bytes,14,opt,name=peer_service,json=peerService,proto3" json:"peer_service,omitempty"` SpanKind string `protobuf:"bytes,15,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"` } func (m *ClientGroupedStats) Reset() { *m = ClientGroupedStats{} } func (m *ClientGroupedStats) String() string { return proto.CompactTextString(m) } func (*ClientGroupedStats) ProtoMessage() {} func (*ClientGroupedStats) Descriptor() ([]byte, []int) { return fileDescriptor_b4756a0aec8b9d44, []int{3} } func (m *ClientGroupedStats) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *ClientGroupedStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_ClientGroupedStats.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *ClientGroupedStats) XXX_Merge(src proto.Message) { xxx_messageInfo_ClientGroupedStats.Merge(m, src) } func (m *ClientGroupedStats) XXX_Size() int { return m.Size() } func (m *ClientGroupedStats) XXX_DiscardUnknown() { xxx_messageInfo_ClientGroupedStats.DiscardUnknown(m) } var xxx_messageInfo_ClientGroupedStats proto.InternalMessageInfo func (m *ClientGroupedStats) GetService() string { if m != nil { return m.Service } return "" } func (m *ClientGroupedStats) GetName() string { if m != nil { return m.Name } return "" } func (m *ClientGroupedStats) GetResource() string { if m != nil { return m.Resource } return "" } func (m *ClientGroupedStats) GetHTTPStatusCode() uint32 { if m != nil { return m.HTTPStatusCode } return 0 } func (m *ClientGroupedStats) GetType() string { if m != nil { return m.Type } return "" } func (m *ClientGroupedStats) GetDBType() string { if m != nil { return m.DBType } return "" } func (m *ClientGroupedStats) GetHits() uint64 { if m != nil { return m.Hits } return 0 } func (m *ClientGroupedStats) GetErrors() uint64 { if m != nil { return m.Errors } return 0 } func (m *ClientGroupedStats) GetDuration() uint64 { if m != nil { return m.Duration } return 0 } func (m *ClientGroupedStats) GetOkSummary() []byte { if m != nil { return m.OkSummary } return nil } func (m *ClientGroupedStats) GetErrorSummary() []byte { if m != nil { return m.ErrorSummary } return nil } func (m *ClientGroupedStats) GetSynthetics() bool { if m != nil { return m.Synthetics } return false } func (m *ClientGroupedStats) GetTopLevelHits() uint64 { if m != nil { return m.TopLevelHits } return 0 } func (m *ClientGroupedStats) GetPeerService() string { if m != nil { return m.PeerService } return "" } func (m *ClientGroupedStats) GetSpanKind() string { if m != nil { return m.SpanKind } return "" } func init() { proto.RegisterType((*StatsPayload)(nil), "pb.StatsPayload") proto.RegisterType((*ClientStatsPayload)(nil), "pb.ClientStatsPayload") proto.RegisterType((*ClientStatsBucket)(nil), "pb.ClientStatsBucket") proto.RegisterType((*ClientGroupedStats)(nil), "pb.ClientGroupedStats") } func init() { proto.RegisterFile("stats.proto", fileDescriptor_b4756a0aec8b9d44) } var fileDescriptor_b4756a0aec8b9d44 = []byte{ // 666 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x54, 0xc1, 0x6e, 0xda, 0x4a, 0x14, 0xc5, 0xd8, 0x21, 0xf1, 0x85, 0xf0, 0xf2, 0x46, 0xef, 0xe5, 0x59, 0x79, 0x91, 0x4b, 0x51, 0x15, 0xa1, 0x4a, 0x25, 0x6a, 0xfa, 0x05, 0x25, 0x54, 0x4d, 0xd4, 0x2e, 0x22, 0x83, 0xba, 0x45, 0xc6, 0xbe, 0x31, 0x56, 0xf0, 0x8c, 0x3b, 0x1e, 0x23, 0xf1, 0x17, 0xfd, 0x85, 0x7e, 0x4b, 0x37, 0x59, 0x66, 0xd9, 0x55, 0x55, 0x25, 0x1f, 0xd2, 0x6a, 0xae, 0x31, 0xc1, 0x44, 0xea, 0xee, 0x9e, 0x33, 0x97, 0x3b, 0xf7, 0x1c, 0x9f, 0x01, 0x9a, 0x99, 0xf2, 0x55, 0xd6, 0x4f, 0xa5, 0x50, 0x82, 0xd5, 0xd3, 0xe9, 0xd1, 0xab, 0x28, 0x56, 0xb3, 0x7c, 0xda, 0x0f, 0x44, 0x72, 0x1a, 0x89, 0x48, 0x9c, 0xd2, 0xd1, 0x34, 0xbf, 0x26, 0x44, 0x80, 0xaa, 0xe2, 0x27, 0xdd, 0x3b, 0x03, 0x5a, 0x23, 0x3d, 0xe2, 0xca, 0x5f, 0xce, 0x85, 0x1f, 0xb2, 0x17, 0xb0, 0xef, 0x47, 0xc8, 0xd5, 0x85, 0xc8, 0x14, 0xf7, 0x13, 0x74, 0x8c, 0x8e, 0xd1, 0xb3, 0xbd, 0x2a, 0xc9, 0x8e, 0x60, 0x8f, 0x88, 0x77, 0x7c, 0xe1, 0xd4, 0xa9, 0x61, 0x8d, 0xd9, 0x19, 0xec, 0xd0, 0x52, 0x8e, 0xd9, 0x31, 0x7b, 0xcd, 0xb3, 0xc3, 0x7e, 0x3a, 0xed, 0x9f, 0xcf, 0x63, 0xe4, 0x6a, 0xf3, 0xa2, 0x81, 0x75, 0xfb, 0xe3, 0x59, 0xcd, 0x2b, 0x5a, 0x59, 0x17, 0x5a, 0xf4, 0xfb, 0x4f, 0x28, 0xb3, 0x58, 0x70, 0xc7, 0xa2, 0x99, 0x15, 0x8e, 0x9d, 0x40, 0x3b, 0xa0, 0x31, 0xe7, 0x22, 0x49, 0x73, 0x85, 0xa1, 0xb3, 0xd3, 0x31, 0x7a, 0x7b, 0xde, 0x16, 0xdb, 0xfd, 0x55, 0x07, 0xf6, 0xf4, 0x3e, 0xbd, 0xf2, 0xac, 0xaa, 0x69, 0x8d, 0xd9, 0x01, 0x98, 0xb8, 0x56, 0xa2, 0x4b, 0xe6, 0xc0, 0xee, 0x62, 0xb5, 0x8b, 0x49, 0x6c, 0x09, 0xd9, 0xeb, 0x52, 0x9e, 0x45, 0xf2, 0xfe, 0xdd, 0x92, 0x37, 0xc8, 0x83, 0x1b, 0x54, 0x55, 0x75, 0x0c, 0xac, 0xb9, 0xcf, 0x23, 0xda, 0xd7, 0xf6, 0xa8, 0xd6, 0x3e, 0x2b, 0xe9, 0x07, 0x28, 0x4b, 0xc9, 0x8d, 0xc2, 0xe7, 0x0a, 0xc9, 0x8e, 0xc1, 0x96, 0x39, 0x57, 0x71, 0x82, 0x97, 0x43, 0x67, 0x97, 0x3a, 0x1e, 0x09, 0x2d, 0x29, 0xc3, 0xcf, 0x39, 0xf2, 0x00, 0x9d, 0xbd, 0x8e, 0xd1, 0xb3, 0xbc, 0x35, 0x66, 0x2f, 0xe1, 0x80, 0xdc, 0x7b, 0x1b, 0x45, 0x12, 0x23, 0x5f, 0xe9, 0x2b, 0x6c, 0x1a, 0xf0, 0x84, 0xd7, 0x62, 0x33, 0x94, 0x8b, 0x38, 0x40, 0x07, 0x0a, 0xb1, 0x2b, 0xc8, 0x3a, 0xd0, 0x0c, 0x04, 0x57, 0x7e, 0xcc, 0x51, 0x5e, 0x0e, 0x9d, 0x26, 0x9d, 0x6e, 0x52, 0x5a, 0x9b, 0xf2, 0xa3, 0xcc, 0x69, 0x75, 0x4c, 0xad, 0x4d, 0xd7, 0xdd, 0xaf, 0x06, 0xfc, 0xfd, 0xc4, 0x12, 0xf6, 0x0f, 0x19, 0x27, 0x15, 0xb9, 0x6f, 0x79, 0x05, 0xd0, 0x1a, 0xc2, 0x5c, 0x16, 0xfb, 0xd5, 0x0b, 0x0d, 0x25, 0xfe, 0x43, 0x92, 0xde, 0x4b, 0x91, 0xa7, 0x18, 0x16, 0xe3, 0x2b, 0x5e, 0x9f, 0x40, 0x9b, 0xf4, 0x8d, 0xe3, 0x04, 0x47, 0xb3, 0xf8, 0x5a, 0x51, 0x96, 0x4c, 0x6f, 0x8b, 0xed, 0x7e, 0x33, 0xcb, 0x94, 0x6c, 0xce, 0xda, 0xb4, 0xc2, 0xa8, 0x5a, 0xc1, 0xc0, 0xa2, 0xec, 0x14, 0x21, 0xb1, 0xca, 0x67, 0x20, 0x31, 0x13, 0xb9, 0x0c, 0x70, 0x15, 0x93, 0x35, 0x66, 0x3d, 0x38, 0xb8, 0x18, 0x8f, 0xaf, 0x26, 0x7a, 0xad, 0x3c, 0x9b, 0x04, 0x22, 0x44, 0x5a, 0x65, 0xdf, 0x6b, 0x6b, 0x7e, 0x44, 0xf4, 0xb9, 0x08, 0x69, 0xb2, 0x5a, 0xa6, 0x58, 0xc6, 0x43, 0xd7, 0xec, 0x3f, 0xd8, 0x1d, 0x0e, 0x26, 0x44, 0x17, 0xc1, 0x68, 0x0c, 0x07, 0x63, 0x7d, 0xc0, 0xc0, 0x9a, 0xc5, 0x2a, 0xa3, 0x30, 0x58, 0x1e, 0xd5, 0xec, 0x10, 0x1a, 0x28, 0xa5, 0x90, 0xd9, 0x2a, 0x05, 0x2b, 0x54, 0xf1, 0xd6, 0xde, 0xf2, 0xf6, 0x18, 0x6c, 0x71, 0x33, 0xca, 0x93, 0xc4, 0x97, 0x4b, 0xfa, 0xea, 0x2d, 0xef, 0x91, 0xd0, 0xef, 0x91, 0x66, 0x94, 0x0d, 0x4d, 0x6a, 0xa8, 0x70, 0xcc, 0x05, 0xc8, 0x96, 0x5c, 0xcd, 0x50, 0xc5, 0x81, 0xfe, 0xfe, 0xfa, 0x2d, 0x6e, 0x30, 0x7a, 0x86, 0x12, 0xe9, 0x47, 0x5c, 0xe0, 0xfc, 0x42, 0x6f, 0xbc, 0x4f, 0x1b, 0x54, 0x38, 0xf6, 0x1c, 0x5a, 0x29, 0xa2, 0x9c, 0x94, 0x9e, 0xb7, 0x8b, 0x80, 0x69, 0x6e, 0xb4, 0xf2, 0xfd, 0x7f, 0xb0, 0xb3, 0xd4, 0xe7, 0x93, 0x9b, 0x98, 0x87, 0xce, 0x5f, 0x85, 0xc9, 0x9a, 0xf8, 0x10, 0xf3, 0x70, 0xe0, 0xdc, 0xde, 0xbb, 0xc6, 0xdd, 0xbd, 0x6b, 0xfc, 0xbc, 0x77, 0x8d, 0x2f, 0x0f, 0x6e, 0xed, 0xee, 0xc1, 0xad, 0x7d, 0x7f, 0x70, 0x6b, 0xd3, 0x06, 0xfd, 0xbf, 0xbd, 0xf9, 0x1d, 0x00, 0x00, 0xff, 0xff, 0xc7, 0x5d, 0xe8, 0x01, 0x21, 0x05, 0x00, 0x00, } func (m *StatsPayload) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *StatsPayload) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.AgentHostname) > 0 { dAtA[i] = 0xa i++ i = encodeVarintStats(dAtA, i, uint64(len(m.AgentHostname))) i += copy(dAtA[i:], m.AgentHostname) } if len(m.AgentEnv) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintStats(dAtA, i, uint64(len(m.AgentEnv))) i += copy(dAtA[i:], m.AgentEnv) } if len(m.Stats) > 0 { for _, msg := range m.Stats { dAtA[i] = 0x1a i++ i = encodeVarintStats(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } if len(m.AgentVersion) > 0 { dAtA[i] = 0x22 i++ i = encodeVarintStats(dAtA, i, uint64(len(m.AgentVersion))) i += copy(dAtA[i:], m.AgentVersion) } if m.ClientComputed { dAtA[i] = 0x28 i++ if m.ClientComputed { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } return i, nil } func (m *ClientStatsPayload) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *ClientStatsPayload) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Hostname) > 0 { dAtA[i] = 0xa i++ i = encodeVarintStats(dAtA, i, uint64(len(m.Hostname))) i += copy(dAtA[i:], m.Hostname) } if len(m.Env) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintStats(dAtA, i, uint64(len(m.Env))) i += copy(dAtA[i:], m.Env) } if len(m.Version) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintStats(dAtA, i, uint64(len(m.Version))) i += copy(dAtA[i:], m.Version) } if len(m.Stats) > 0 { for _, msg := range m.Stats { dAtA[i] = 0x22 i++ i = encodeVarintStats(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } if len(m.Lang) > 0 { dAtA[i] = 0x2a i++ i = encodeVarintStats(dAtA, i, uint64(len(m.Lang))) i += copy(dAtA[i:], m.Lang) } if len(m.TracerVersion) > 0 { dAtA[i] = 0x32 i++ i = encodeVarintStats(dAtA, i, uint64(len(m.TracerVersion))) i += copy(dAtA[i:], m.TracerVersion) } if len(m.RuntimeID) > 0 { dAtA[i] = 0x3a i++ i = encodeVarintStats(dAtA, i, uint64(len(m.RuntimeID))) i += copy(dAtA[i:], m.RuntimeID) } if m.Sequence != 0 { dAtA[i] = 0x40 i++ i = encodeVarintStats(dAtA, i, uint64(m.Sequence)) } if len(m.AgentAggregation) > 0 { dAtA[i] = 0x4a i++ i = encodeVarintStats(dAtA, i, uint64(len(m.AgentAggregation))) i += copy(dAtA[i:], m.AgentAggregation) } if len(m.Service) > 0 { dAtA[i] = 0x52 i++ i = encodeVarintStats(dAtA, i, uint64(len(m.Service))) i += copy(dAtA[i:], m.Service) } if len(m.ContainerID) > 0 { dAtA[i] = 0x5a i++ i = encodeVarintStats(dAtA, i, uint64(len(m.ContainerID))) i += copy(dAtA[i:], m.ContainerID) } if len(m.Tags) > 0 { for _, s := range m.Tags { dAtA[i] = 0x62 i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } return i, nil } func (m *ClientStatsBucket) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *ClientStatsBucket) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Start != 0 { dAtA[i] = 0x8 i++ i = encodeVarintStats(dAtA, i, uint64(m.Start)) } if m.Duration != 0 { dAtA[i] = 0x10 i++ i = encodeVarintStats(dAtA, i, uint64(m.Duration)) } if len(m.Stats) > 0 { for _, msg := range m.Stats { dAtA[i] = 0x1a i++ i = encodeVarintStats(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } if m.AgentTimeShift != 0 { dAtA[i] = 0x20 i++ i = encodeVarintStats(dAtA, i, uint64(m.AgentTimeShift)) } return i, nil } func (m *ClientGroupedStats) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *ClientGroupedStats) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Service) > 0 { dAtA[i] = 0xa i++ i = encodeVarintStats(dAtA, i, uint64(len(m.Service))) i += copy(dAtA[i:], m.Service) } if len(m.Name) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintStats(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) } if len(m.Resource) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintStats(dAtA, i, uint64(len(m.Resource))) i += copy(dAtA[i:], m.Resource) } if m.HTTPStatusCode != 0 { dAtA[i] = 0x20 i++ i = encodeVarintStats(dAtA, i, uint64(m.HTTPStatusCode)) } if len(m.Type) > 0 { dAtA[i] = 0x2a i++ i = encodeVarintStats(dAtA, i, uint64(len(m.Type))) i += copy(dAtA[i:], m.Type) } if len(m.DBType) > 0 { dAtA[i] = 0x32 i++ i = encodeVarintStats(dAtA, i, uint64(len(m.DBType))) i += copy(dAtA[i:], m.DBType) } if m.Hits != 0 { dAtA[i] = 0x38 i++ i = encodeVarintStats(dAtA, i, uint64(m.Hits)) } if m.Errors != 0 { dAtA[i] = 0x40 i++ i = encodeVarintStats(dAtA, i, uint64(m.Errors)) } if m.Duration != 0 { dAtA[i] = 0x48 i++ i = encodeVarintStats(dAtA, i, uint64(m.Duration)) } if len(m.OkSummary) > 0 { dAtA[i] = 0x52 i++ i = encodeVarintStats(dAtA, i, uint64(len(m.OkSummary))) i += copy(dAtA[i:], m.OkSummary) } if len(m.ErrorSummary) > 0 { dAtA[i] = 0x5a i++ i = encodeVarintStats(dAtA, i, uint64(len(m.ErrorSummary))) i += copy(dAtA[i:], m.ErrorSummary) } if m.Synthetics { dAtA[i] = 0x60 i++ if m.Synthetics { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if m.TopLevelHits != 0 { dAtA[i] = 0x68 i++ i = encodeVarintStats(dAtA, i, uint64(m.TopLevelHits)) } if len(m.PeerService) > 0 { dAtA[i] = 0x72 i++ i = encodeVarintStats(dAtA, i, uint64(len(m.PeerService))) i += copy(dAtA[i:], m.PeerService) } if len(m.SpanKind) > 0 { dAtA[i] = 0x7a i++ i = encodeVarintStats(dAtA, i, uint64(len(m.SpanKind))) i += copy(dAtA[i:], m.SpanKind) } return i, nil } func encodeVarintStats(dAtA []byte, offset int, v uint64) int { for v >= 1<<7 { dAtA[offset] = uint8(v&0x7f | 0x80) v >>= 7 offset++ } dAtA[offset] = uint8(v) return offset + 1 } func (m *StatsPayload) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.AgentHostname) if l > 0 { n += 1 + l + sovStats(uint64(l)) } l = len(m.AgentEnv) if l > 0 { n += 1 + l + sovStats(uint64(l)) } if len(m.Stats) > 0 { for _, e := range m.Stats { l = e.Size() n += 1 + l + sovStats(uint64(l)) } } l = len(m.AgentVersion) if l > 0 { n += 1 + l + sovStats(uint64(l)) } if m.ClientComputed { n += 2 } return n } func (m *ClientStatsPayload) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Hostname) if l > 0 { n += 1 + l + sovStats(uint64(l)) } l = len(m.Env) if l > 0 { n += 1 + l + sovStats(uint64(l)) } l = len(m.Version) if l > 0 { n += 1 + l + sovStats(uint64(l)) } if len(m.Stats) > 0 { for _, e := range m.Stats { l = e.Size() n += 1 + l + sovStats(uint64(l)) } } l = len(m.Lang) if l > 0 { n += 1 + l + sovStats(uint64(l)) } l = len(m.TracerVersion) if l > 0 { n += 1 + l + sovStats(uint64(l)) } l = len(m.RuntimeID) if l > 0 { n += 1 + l + sovStats(uint64(l)) } if m.Sequence != 0 { n += 1 + sovStats(uint64(m.Sequence)) } l = len(m.AgentAggregation) if l > 0 { n += 1 + l + sovStats(uint64(l)) } l = len(m.Service) if l > 0 { n += 1 + l + sovStats(uint64(l)) } l = len(m.ContainerID) if l > 0 { n += 1 + l + sovStats(uint64(l)) } if len(m.Tags) > 0 { for _, s := range m.Tags { l = len(s) n += 1 + l + sovStats(uint64(l)) } } return n } func (m *ClientStatsBucket) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Start != 0 { n += 1 + sovStats(uint64(m.Start)) } if m.Duration != 0 { n += 1 + sovStats(uint64(m.Duration)) } if len(m.Stats) > 0 { for _, e := range m.Stats { l = e.Size() n += 1 + l + sovStats(uint64(l)) } } if m.AgentTimeShift != 0 { n += 1 + sovStats(uint64(m.AgentTimeShift)) } return n } func (m *ClientGroupedStats) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Service) if l > 0 { n += 1 + l + sovStats(uint64(l)) } l = len(m.Name) if l > 0 { n += 1 + l + sovStats(uint64(l)) } l = len(m.Resource) if l > 0 { n += 1 + l + sovStats(uint64(l)) } if m.HTTPStatusCode != 0 { n += 1 + sovStats(uint64(m.HTTPStatusCode)) } l = len(m.Type) if l > 0 { n += 1 + l + sovStats(uint64(l)) } l = len(m.DBType) if l > 0 { n += 1 + l + sovStats(uint64(l)) } if m.Hits != 0 { n += 1 + sovStats(uint64(m.Hits)) } if m.Errors != 0 { n += 1 + sovStats(uint64(m.Errors)) } if m.Duration != 0 { n += 1 + sovStats(uint64(m.Duration)) } l = len(m.OkSummary) if l > 0 { n += 1 + l + sovStats(uint64(l)) } l = len(m.ErrorSummary) if l > 0 { n += 1 + l + sovStats(uint64(l)) } if m.Synthetics { n += 2 } if m.TopLevelHits != 0 { n += 1 + sovStats(uint64(m.TopLevelHits)) } l = len(m.PeerService) if l > 0 { n += 1 + l + sovStats(uint64(l)) } l = len(m.SpanKind) if l > 0 { n += 1 + l + sovStats(uint64(l)) } return n } func sovStats(x uint64) (n int) { for { n++ x >>= 7 if x == 0 { break } } return n } func sozStats(x uint64) (n int) { return sovStats(uint64((x << 1) ^ uint64((int64(x) >> 63)))) } func (m *StatsPayload) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: StatsPayload: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: StatsPayload: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field AgentHostname", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.AgentHostname = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field AgentEnv", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.AgentEnv = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Stats", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Stats = append(m.Stats, ClientStatsPayload{}) if err := m.Stats[len(m.Stats)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field AgentVersion", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.AgentVersion = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 5: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field ClientComputed", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.ClientComputed = bool(v != 0) default: iNdEx = preIndex skippy, err := skipStats(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthStats } if (iNdEx + skippy) < 0 { return ErrInvalidLengthStats } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *ClientStatsPayload) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: ClientStatsPayload: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: ClientStatsPayload: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Hostname", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Hostname = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Env", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Env = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Version", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Version = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Stats", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Stats = append(m.Stats, ClientStatsBucket{}) if err := m.Stats[len(m.Stats)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Lang", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Lang = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TracerVersion", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.TracerVersion = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 7: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field RuntimeID", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.RuntimeID = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 8: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Sequence", wireType) } m.Sequence = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Sequence |= uint64(b&0x7F) << shift if b < 0x80 { break } } case 9: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field AgentAggregation", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.AgentAggregation = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 10: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Service", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Service = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 11: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ContainerID", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.ContainerID = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 12: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Tags", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Tags = append(m.Tags, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipStats(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthStats } if (iNdEx + skippy) < 0 { return ErrInvalidLengthStats } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *ClientStatsBucket) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: ClientStatsBucket: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: ClientStatsBucket: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Start", wireType) } m.Start = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Start |= uint64(b&0x7F) << shift if b < 0x80 { break } } case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Duration", wireType) } m.Duration = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Duration |= uint64(b&0x7F) << shift if b < 0x80 { break } } case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Stats", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Stats = append(m.Stats, ClientGroupedStats{}) if err := m.Stats[len(m.Stats)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 4: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field AgentTimeShift", wireType) } m.AgentTimeShift = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.AgentTimeShift |= int64(b&0x7F) << shift if b < 0x80 { break } } default: iNdEx = preIndex skippy, err := skipStats(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthStats } if (iNdEx + skippy) < 0 { return ErrInvalidLengthStats } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *ClientGroupedStats) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: ClientGroupedStats: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: ClientGroupedStats: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Service", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Service = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Name = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Resource", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Resource = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field HTTPStatusCode", wireType) } m.HTTPStatusCode = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.HTTPStatusCode |= uint32(b&0x7F) << shift if b < 0x80 { break } } case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.Type = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field DBType", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.DBType = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 7: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Hits", wireType) } m.Hits = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Hits |= uint64(b&0x7F) << shift if b < 0x80 { break } } case 8: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Errors", wireType) } m.Errors = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Errors |= uint64(b&0x7F) << shift if b < 0x80 { break } } case 9: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Duration", wireType) } m.Duration = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Duration |= uint64(b&0x7F) << shift if b < 0x80 { break } } case 10: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field OkSummary", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.OkSummary = append(m.OkSummary[:0], dAtA[iNdEx:postIndex]...) if m.OkSummary == nil { m.OkSummary = []byte{} } iNdEx = postIndex case 11: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ErrorSummary", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.ErrorSummary = append(m.ErrorSummary[:0], dAtA[iNdEx:postIndex]...) if m.ErrorSummary == nil { m.ErrorSummary = []byte{} } iNdEx = postIndex case 12: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Synthetics", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.Synthetics = bool(v != 0) case 13: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field TopLevelHits", wireType) } m.TopLevelHits = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.TopLevelHits |= uint64(b&0x7F) << shift if b < 0x80 { break } } case 14: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field PeerService", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.PeerService = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 15: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SpanKind", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowStats } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthStats } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthStats } if postIndex > l { return io.ErrUnexpectedEOF } m.SpanKind = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipStats(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthStats } if (iNdEx + skippy) < 0 { return ErrInvalidLengthStats } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func skipStats(dAtA []byte) (n int, err error) { l := len(dAtA) iNdEx := 0 for iNdEx < l { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowStats } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } wireType := int(wire & 0x7) switch wireType { case 0: for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowStats } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } iNdEx++ if dAtA[iNdEx-1] < 0x80 { break } } return iNdEx, nil case 1: iNdEx += 8 return iNdEx, nil case 2: var length int for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowStats } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ length |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if length < 0 { return 0, ErrInvalidLengthStats } iNdEx += length if iNdEx < 0 { return 0, ErrInvalidLengthStats } return iNdEx, nil case 3: for { var innerWire uint64 var start int = iNdEx for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowStats } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ innerWire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } innerWireType := int(innerWire & 0x7) if innerWireType == 4 { break } next, err := skipStats(dAtA[start:]) if err != nil { return 0, err } iNdEx = start + next if iNdEx < 0 { return 0, ErrInvalidLengthStats } } return iNdEx, nil case 4: return iNdEx, nil case 5: iNdEx += 4 return iNdEx, nil default: return 0, fmt.Errorf("proto: illegal wireType %d", wireType) } } panic("unreachable") } var ( ErrInvalidLengthStats = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowStats = fmt.Errorf("proto: integer overflow") )