apitech
/
grafana
mirror of https://github.com/grafana/grafana
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Regenerate stubs

Browse Source
pull/101196/head
Mostafa Moradian 5 months ago
parent b17e559716
commit c0f1760c7b
No known key found for this signature in database
GPG Key ID: F77FCEA0D3854DA3
1 changed files with 389 additions and 32 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 421
      pkg/components/loki/logproto/logproto.pb.go

421
pkg/components/loki/logproto/logproto.pb.go
Unescape View File

@ -165,15 +165,67 @@ func (m *StreamAdapter) GetHash() uint64 {
return 0
}
type LabelPairAdapter struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}
func (m *LabelPairAdapter) Reset() { *m = LabelPairAdapter{} }
func (*LabelPairAdapter) ProtoMessage() {}
func (*LabelPairAdapter) Descriptor() ([]byte, []int) {
return fileDescriptor_7a8976f235a02f79, []int{3}
}
func (m *LabelPairAdapter) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *LabelPairAdapter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_LabelPairAdapter.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *LabelPairAdapter) XXX_Merge(src proto.Message) {
xxx_messageInfo_LabelPairAdapter.Merge(m, src)
}
func (m *LabelPairAdapter) XXX_Size() int {
return m.Size()
}
func (m *LabelPairAdapter) XXX_DiscardUnknown() {
xxx_messageInfo_LabelPairAdapter.DiscardUnknown(m)
}
var xxx_messageInfo_LabelPairAdapter proto.InternalMessageInfo
func (m *LabelPairAdapter) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *LabelPairAdapter) GetValue() string {
if m != nil {
return m.Value
}
return ""
}
type EntryAdapter struct {
Timestamp time.Time `protobuf:"bytes,1,opt,name=timestamp,proto3,stdtime" json:"ts"`
Line string `protobuf:"bytes,2,opt,name=line,proto3" json:"line"`
Timestamp time.Time `protobuf:"bytes,1,opt,name=timestamp,proto3,stdtime" json:"ts"`
Line string `protobuf:"bytes,2,opt,name=line,proto3" json:"line"`
StructuredMetadata []LabelPairAdapter `protobuf:"bytes,3,rep,name=structuredMetadata,proto3" json:"structuredMetadata,omitempty"`
}
func (m *EntryAdapter) Reset() { *m = EntryAdapter{} }
func (*EntryAdapter) ProtoMessage() {}
func (*EntryAdapter) Descriptor() ([]byte, []int) {
return fileDescriptor_7a8976f235a02f79, []int{3}
return fileDescriptor_7a8976f235a02f79, []int{4}
}
func (m *EntryAdapter) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -216,43 +268,56 @@ func (m *EntryAdapter) GetLine() string {
return ""
}
func (m *EntryAdapter) GetStructuredMetadata() []LabelPairAdapter {
if m != nil {
return m.StructuredMetadata
}
return nil
}
func init() {
proto.RegisterType((*PushRequest)(nil), "logproto.PushRequest")
proto.RegisterType((*PushResponse)(nil), "logproto.PushResponse")
proto.RegisterType((*StreamAdapter)(nil), "logproto.StreamAdapter")
proto.RegisterType((*LabelPairAdapter)(nil), "logproto.LabelPairAdapter")
proto.RegisterType((*EntryAdapter)(nil), "logproto.EntryAdapter")
}
func init() { proto.RegisterFile("logproto.proto", fileDescriptor_7a8976f235a02f79) }
var fileDescriptor_7a8976f235a02f79 = []byte{
// 406 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x5c, 0x52, 0x41, 0x8f, 0x93, 0x40,
0x18, 0x9d, 0xe9, 0x22, 0xbb, 0x3b, 0x5d, 0x6b, 0x32, 0xc9, 0xae, 0x48, 0xcc, 0xcc, 0x86, 0x53,
0x2f, 0xa5, 0x49, 0x3d, 0x78, 0x33, 0x29, 0x89, 0x49, 0x8f, 0x06, 0x4d, 0x4c, 0xbc, 0x81, 0x8e,
0x40, 0x02, 0x0c, 0x32, 0x83, 0x89, 0x37, 0x7f, 0x42, 0xfd, 0x17, 0xfe, 0x94, 0x1e, 0x7b, 0x6c,
0x3c, 0xa0, 0xa5, 0x17, 0xc3, 0xa9, 0x3f, 0xc1, 0x30, 0x40, 0xa9, 0x7b, 0x99, 0xf9, 0xde, 0xe3,
0x7d, 0xdf, 0xbc, 0x79, 0x0c, 0x9a, 0xc4, 0x3c, 0xc8, 0x72, 0x2e, 0xb9, 0xad, 0x56, 0x7c, 0xd5,
0x63, 0x73, 0x16, 0x44, 0x32, 0x2c, 0x7c, 0xfb, 0x23, 0x4f, 0xe6, 0x01, 0x0f, 0xf8, 0x5c, 0xd1,
0x7e, 0xf1, 0x59, 0x21, 0x05, 0x54, 0xd5, 0x36, 0x9a, 0x34, 0xe0, 0x3c, 0x88, 0xd9, 0xa0, 0x92,
0x51, 0xc2, 0x84, 0xf4, 0x92, 0xac, 0x15, 0x58, 0xef, 0xd1, 0xf8, 0x4d, 0x21, 0x42, 0x97, 0x7d,
0x29, 0x98, 0x90, 0x78, 0x85, 0x2e, 0x85, 0xcc, 0x99, 0x97, 0x08, 0x03, 0xde, 0x5f, 0x4c, 0xc7,
0x8b, 0xa7, 0xf6, 0xc9, 0xca, 0x5b, 0xf5, 0x61, 0xf9, 0xc9, 0xcb, 0x24, 0xcb, 0x9d, 0xdb, 0x5f,
0x25, 0xd5, 0x5b, 0xaa, 0x2e, 0x69, 0xdf, 0xe5, 0xf6, 0x85, 0x35, 0x41, 0x37, 0xed, 0x60, 0x91,
0xf1, 0x54, 0x30, 0xeb, 0x07, 0x44, 0x8f, 0xff, 0x9b, 0x80, 0x2d, 0xa4, 0xc7, 0x9e, 0xcf, 0xe2,
0xe6, 0x28, 0x38, 0xbd, 0x76, 0x50, 0x5d, 0xd2, 0x8e, 0x71, 0xbb, 0x1d, 0x2f, 0xd1, 0x25, 0x4b,
0x65, 0x1e, 0x31, 0x61, 0x8c, 0x94, 0x9f, 0xbb, 0xc1, 0xcf, 0xeb, 0x54, 0xe6, 0xdf, 0x7a, 0x3b,
0x4f, 0x36, 0x25, 0x05, 0x8d, 0x91, 0x4e, 0xee, 0xf6, 0x05, 0x7e, 0x86, 0xb4, 0xd0, 0x13, 0xa1,
0x71, 0x71, 0x0f, 0xa7, 0x9a, 0xf3, 0xa8, 0x2e, 0x29, 0x9c, 0xb9, 0x8a, 0xb2, 0xbe, 0xa2, 0x9b,
0xf3, 0x21, 0x78, 0x85, 0xae, 0x4f, 0xf9, 0x28, 0x53, 0xe3, 0x85, 0x69, 0xb7, 0x09, 0xda, 0x7d,
0x82, 0xf6, 0xbb, 0x5e, 0xe1, 0x4c, 0xba, 0x33, 0x47, 0x52, 0xac, 0x7f, 0x53, 0xe8, 0x0e, 0xcd,
0xf8, 0x39, 0xd2, 0xe2, 0x28, 0x65, 0xc6, 0x48, 0xdd, 0xec, 0xaa, 0x2e, 0xa9, 0xc2, 0xae, 0x5a,
0x17, 0x4b, 0xa4, 0x37, 0xd9, 0xb0, 0x1c, 0xbf, 0x44, 0x5a, 0x53, 0xe1, 0xdb, 0xe1, 0x5a, 0x67,
0xbf, 0xc3, 0xbc, 0x7b, 0x48, 0x77, 0x61, 0x02, 0xe7, 0xd5, 0x76, 0x4f, 0xc0, 0x6e, 0x4f, 0xc0,
0x71, 0x4f, 0xe0, 0xf7, 0x8a, 0xc0, 0x9f, 0x15, 0x81, 0x9b, 0x8a, 0xc0, 0x6d, 0x45, 0xe0, 0x9f,
0x8a, 0xc0, 0xbf, 0x15, 0x01, 0xc7, 0x8a, 0xc0, 0xf5, 0x81, 0x80, 0xed, 0x81, 0x80, 0xdd, 0x81,
0x80, 0x0f, 0xa7, 0x77, 0xe4, 0xeb, 0x6a, 0x7b, 0xf1, 0x2f, 0x00, 0x00, 0xff, 0xff, 0x81, 0x6a,
0x10, 0x6d, 0x6a, 0x02, 0x00, 0x00,
// 486 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x6c, 0x52, 0xc1, 0x6e, 0xd3, 0x40,
0x10, 0xf5, 0x26, 0x69, 0xda, 0x4e, 0x4a, 0x40, 0x2b, 0x5a, 0x8c, 0x55, 0xad, 0x2b, 0x8b, 0x43,
0x0e, 0xd4, 0x95, 0xc2, 0x81, 0x0b, 0x42, 0x8a, 0x25, 0xa4, 0x1e, 0x40, 0xaa, 0x0c, 0x12, 0x12,
0xb7, 0x4d, 0xb3, 0x38, 0x96, 0x6c, 0xaf, 0xd9, 0x5d, 0x23, 0xf5, 0xc6, 0x27, 0x94, 0xbf, 0xe0,
0x53, 0x7a, 0xcc, 0xb1, 0xe2, 0x60, 0x88, 0x73, 0xa9, 0x72, 0xea, 0x27, 0x20, 0xaf, 0xed, 0xb8,
0x14, 0x2e, 0xbb, 0x33, 0xcf, 0xf3, 0xe6, 0x3d, 0xcf, 0x2c, 0x0c, 0x23, 0x1e, 0xa4, 0x82, 0x2b,
0xee, 0xea, 0x13, 0xef, 0x34, 0xb9, 0x75, 0x1c, 0x84, 0x6a, 0x9e, 0x4d, 0xdd, 0x73, 0x1e, 0x9f,
0x04, 0x3c, 0xe0, 0x27, 0x1a, 0x9e, 0x66, 0x9f, 0x75, 0xa6, 0x13, 0x1d, 0x55, 0x44, 0xcb, 0x0e,
0x38, 0x0f, 0x22, 0xd6, 0x56, 0xa9, 0x30, 0x66, 0x52, 0xd1, 0x38, 0xad, 0x0a, 0x9c, 0x8f, 0x30,
0x38, 0xcb, 0xe4, 0xdc, 0x67, 0x5f, 0x32, 0x26, 0x15, 0x3e, 0x85, 0x6d, 0xa9, 0x04, 0xa3, 0xb1,
0x34, 0xd1, 0x51, 0x77, 0x34, 0x18, 0x3f, 0x71, 0x37, 0x56, 0xde, 0xeb, 0x0f, 0x93, 0x19, 0x4d,
0x15, 0x13, 0xde, 0xfe, 0xcf, 0xdc, 0xee, 0x57, 0xd0, 0x3a, 0xb7, 0x1b, 0x96, 0xdf, 0x04, 0xce,
0x10, 0xf6, 0xaa, 0xc6, 0x32, 0xe5, 0x89, 0x64, 0xce, 0x77, 0x04, 0x0f, 0xfe, 0xea, 0x80, 0x1d,
0xe8, 0x47, 0x74, 0xca, 0xa2, 0x52, 0x0a, 0x8d, 0x76, 0x3d, 0x58, 0xe7, 0x76, 0x8d, 0xf8, 0xf5,
0x8d, 0x27, 0xb0, 0xcd, 0x12, 0x25, 0x42, 0x26, 0xcd, 0x8e, 0xf6, 0x73, 0xd0, 0xfa, 0x79, 0x93,
0x28, 0x71, 0xd1, 0xd8, 0x79, 0x78, 0x95, 0xdb, 0x46, 0x69, 0xa4, 0x2e, 0xf7, 0x9b, 0x00, 0x3f,
0x85, 0xde, 0x9c, 0xca, 0xb9, 0xd9, 0x3d, 0x42, 0xa3, 0x9e, 0xb7, 0xb5, 0xce, 0x6d, 0x74, 0xec,
0x6b, 0xc8, 0x79, 0x05, 0x8f, 0xde, 0x96, 0x3a, 0x67, 0x34, 0x14, 0x8d, 0x2b, 0x0c, 0xbd, 0x84,
0xc6, 0xac, 0xf2, 0xe4, 0xeb, 0x18, 0x3f, 0x86, 0xad, 0xaf, 0x34, 0xca, 0x98, 0xd9, 0xd1, 0x60,
0x95, 0x38, 0x37, 0x08, 0xf6, 0xee, 0x7a, 0xc0, 0xa7, 0xb0, 0xbb, 0x19, 0xaf, 0xe6, 0x0f, 0xc6,
0x96, 0x5b, 0x2d, 0xc0, 0x6d, 0x16, 0xe0, 0x7e, 0x68, 0x2a, 0xbc, 0x61, 0x6d, 0xb9, 0xa3, 0xe4,
0xe5, 0x2f, 0x1b, 0xf9, 0x2d, 0x19, 0x1f, 0x42, 0x2f, 0x0a, 0x93, 0x5a, 0xcf, 0xdb, 0x59, 0xe7,
0xb6, 0xce, 0x7d, 0x7d, 0xe2, 0x14, 0xb0, 0x54, 0x22, 0x3b, 0x57, 0x99, 0x60, 0xb3, 0x77, 0x4c,
0xd1, 0x19, 0x55, 0xd4, 0xec, 0xea, 0xf9, 0x58, 0xed, 0x7c, 0xee, 0xff, 0x9a, 0xf7, 0xac, 0x16,
0x3c, 0xfc, 0x97, 0xfd, 0x9c, 0xc7, 0xa1, 0x62, 0x71, 0xaa, 0x2e, 0xfc, 0xff, 0xf4, 0x1e, 0x4f,
0xa0, 0x5f, 0x2e, 0x93, 0x09, 0xfc, 0x12, 0x7a, 0x65, 0x84, 0xf7, 0x5b, 0x9d, 0x3b, 0xef, 0xc7,
0x3a, 0xb8, 0x0f, 0xd7, 0xdb, 0x37, 0xbc, 0xd7, 0x8b, 0x25, 0x31, 0xae, 0x97, 0xc4, 0xb8, 0x5d,
0x12, 0xf4, 0xad, 0x20, 0xe8, 0x47, 0x41, 0xd0, 0x55, 0x41, 0xd0, 0xa2, 0x20, 0xe8, 0x77, 0x41,
0xd0, 0x4d, 0x41, 0x8c, 0xdb, 0x82, 0xa0, 0xcb, 0x15, 0x31, 0x16, 0x2b, 0x62, 0x5c, 0xaf, 0x88,
0xf1, 0x69, 0xf3, 0xf0, 0xa7, 0x7d, 0x7d, 0xbd, 0xf8, 0x13, 0x00, 0x00, 0xff, 0xff, 0x9f, 0xeb,
0xfd, 0xd0, 0x1b, 0x03, 0x00, 0x00,
}
func (this *PushRequest) Equal(that any) bool {
@ -340,6 +405,33 @@ func (this *StreamAdapter) Equal(that any) bool {
}
return true
}
func (this *LabelPairAdapter) Equal(that any) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*LabelPairAdapter)
if !ok {
that2, ok := that.(LabelPairAdapter)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Name != that1.Name {
return false
}
if this.Value != that1.Value {
return false
}
return true
}
func (this *EntryAdapter) Equal(that any) bool {
if that == nil {
return this == nil
@ -365,6 +457,14 @@ func (this *EntryAdapter) Equal(that any) bool {
if this.Line != that1.Line {
return false
}
if len(this.StructuredMetadata) != len(that1.StructuredMetadata) {
return false
}
for i := range this.StructuredMetadata {
if !this.StructuredMetadata[i].Equal(&that1.StructuredMetadata[i]) {
return false
}
}
return true
}
func (this *PushRequest) GoString() string {
@ -404,14 +504,32 @@ func (this *StreamAdapter) GoString() string {
s = append(s, "}")
return strings.Join(s, "")
}
func (this *EntryAdapter) GoString() string {
func (this *LabelPairAdapter) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 6)
s = append(s, "&logproto.LabelPairAdapter{")
s = append(s, "Name: "+fmt.Sprintf("%#v", this.Name)+",\n")
s = append(s, "Value: "+fmt.Sprintf("%#v", this.Value)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *EntryAdapter) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 7)
s = append(s, "&logproto.EntryAdapter{")
s = append(s, "Timestamp: "+fmt.Sprintf("%#v", this.Timestamp)+",\n")
s = append(s, "Line: "+fmt.Sprintf("%#v", this.Line)+",\n")
if this.StructuredMetadata != nil {
vs := make([]LabelPairAdapter, len(this.StructuredMetadata))
for i := range vs {
vs[i] = this.StructuredMetadata[i]
}
s = append(s, "StructuredMetadata: "+fmt.Sprintf("%#v", vs)+",\n")
}
s = append(s, "}")
return strings.Join(s, "")
}
@ -613,6 +731,43 @@ func (m *StreamAdapter) MarshalToSizedBuffer(dAtA []byte) (int, error) {
return len(dAtA) - i, nil
}
func (m *LabelPairAdapter) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *LabelPairAdapter) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *LabelPairAdapter) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if len(m.Value) > 0 {
i -= len(m.Value)
copy(dAtA[i:], m.Value)
i = encodeVarintLogproto(dAtA, i, uint64(len(m.Value)))
i--
dAtA[i] = 0x12
}
if len(m.Name) > 0 {
i -= len(m.Name)
copy(dAtA[i:], m.Name)
i = encodeVarintLogproto(dAtA, i, uint64(len(m.Name)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *EntryAdapter) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
@ -633,6 +788,20 @@ func (m *EntryAdapter) MarshalToSizedBuffer(dAtA []byte) (int, error) {
_ = i
var l int
_ = l
if len(m.StructuredMetadata) > 0 {
for iNdEx := len(m.StructuredMetadata) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.StructuredMetadata[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintLogproto(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x1a
}
}
if len(m.Line) > 0 {
i -= len(m.Line)
copy(dAtA[i:], m.Line)
@ -708,6 +877,23 @@ func (m *StreamAdapter) Size() (n int) {
return n
}
func (m *LabelPairAdapter) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Name)
if l > 0 {
n += 1 + l + sovLogproto(uint64(l))
}
l = len(m.Value)
if l > 0 {
n += 1 + l + sovLogproto(uint64(l))
}
return n
}
func (m *EntryAdapter) Size() (n int) {
if m == nil {
return 0
@ -720,6 +906,12 @@ func (m *EntryAdapter) Size() (n int) {
if l > 0 {
n += 1 + l + sovLogproto(uint64(l))
}
if len(m.StructuredMetadata) > 0 {
for _, e := range m.StructuredMetadata {
l = e.Size()
n += 1 + l + sovLogproto(uint64(l))
}
}
return n
}
@ -765,13 +957,30 @@ func (this *StreamAdapter) String() string {
}, "")
return s
}
func (this *LabelPairAdapter) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&LabelPairAdapter{`,
`Name:` + fmt.Sprintf("%v", this.Name) + `,`,
`Value:` + fmt.Sprintf("%v", this.Value) + `,`,
`}`,
}, "")
return s
}
func (this *EntryAdapter) String() string {
if this == nil {
return "nil"
}
repeatedStringForStructuredMetadata := "[]LabelPairAdapter{"
for _, f := range this.StructuredMetadata {
repeatedStringForStructuredMetadata += strings.Replace(strings.Replace(f.String(), "LabelPairAdapter", "LabelPairAdapter", 1), `&`, ``, 1) + ","
}
repeatedStringForStructuredMetadata += "}"
s := strings.Join([]string{`&EntryAdapter{`,
`Timestamp:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.Timestamp), "Timestamp", "timestamp.Timestamp", 1), `&`, ``, 1) + `,`,
`Timestamp:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.Timestamp), "Timestamp", "timestamppb.Timestamp", 1), `&`, ``, 1) + `,`,
`Line:` + fmt.Sprintf("%v", this.Line) + `,`,
`StructuredMetadata:` + repeatedStringForStructuredMetadata + `,`,
`}`,
}, "")
return s
@ -1053,6 +1262,120 @@ func (m *StreamAdapter) Unmarshal(dAtA []byte) error {
}
return nil
}
func (m *LabelPairAdapter) 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 ErrIntOverflowLogproto
}
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: LabelPairAdapter: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: LabelPairAdapter: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
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 ErrIntOverflowLogproto
}
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 ErrInvalidLengthLogproto
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthLogproto
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Name = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Value", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowLogproto
}
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 ErrInvalidLengthLogproto
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthLogproto
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Value = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipLogproto(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthLogproto
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *EntryAdapter) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
@ -1147,6 +1470,40 @@ func (m *EntryAdapter) Unmarshal(dAtA []byte) error {
}
m.Line = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field StructuredMetadata", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowLogproto
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthLogproto
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthLogproto
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.StructuredMetadata = append(m.StructuredMetadata, LabelPairAdapter{})
if err := m.StructuredMetadata[len(m.StructuredMetadata)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipLogproto(dAtA[iNdEx:])

Write Preview
Loading…
Cancel
Save