@ -6,17 +6,18 @@ package logproto
import (
context "context"
fmt "fmt"
_ "github.com/gogo/protobuf/gogoproto"
proto "github.com/gogo/protobuf/proto"
_ "github.com/gogo/protobuf/types"
github_com_gogo_protobuf_types "github.com/gogo/protobuf/types"
grpc "google.golang.org/grpc"
io "io"
math "math"
reflect "reflect"
strconv "strconv"
strings "strings"
time "time"
_ "github.com/gogo/protobuf/gogoproto"
proto "github.com/gogo/protobuf/proto"
_ "github.com/gogo/protobuf/types"
github_com_gogo_protobuf_types "github.com/gogo/protobuf/types"
grpc "google.golang.org/grpc"
)
// Reference imports to suppress errors if they are not otherwise used.
@ -257,8 +258,10 @@ func (m *QueryResponse) GetStreams() []*Stream {
}
type LabelRequest struct {
Name string ` protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" `
Values bool ` protobuf:"varint,2,opt,name=values,proto3" json:"values,omitempty" `
Name string ` protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" `
Values bool ` protobuf:"varint,2,opt,name=values,proto3" json:"values,omitempty" `
Start * time . Time ` protobuf:"bytes,3,opt,name=start,proto3,stdtime" json:"start,omitempty" `
End * time . Time ` protobuf:"bytes,4,opt,name=end,proto3,stdtime" json:"end,omitempty" `
}
func ( m * LabelRequest ) Reset ( ) { * m = LabelRequest { } }
@ -307,6 +310,20 @@ func (m *LabelRequest) GetValues() bool {
return false
}
func ( m * LabelRequest ) GetStart ( ) * time . Time {
if m != nil {
return m . Start
}
return nil
}
func ( m * LabelRequest ) GetEnd ( ) * time . Time {
if m != nil {
return m . End
}
return nil
}
type LabelResponse struct {
Values [ ] string ` protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty" `
}
@ -838,6 +855,20 @@ func (this *LabelRequest) Equal(that interface{}) bool {
if this . Values != that1 . Values {
return false
}
if that1 . Start == nil {
if this . Start != nil {
return false
}
} else if ! this . Start . Equal ( * that1 . Start ) {
return false
}
if that1 . End == nil {
if this . End != nil {
return false
}
} else if ! this . End . Equal ( * that1 . End ) {
return false
}
return true
}
func ( this * LabelResponse ) Equal ( that interface { } ) bool {
@ -1072,10 +1103,12 @@ func (this *LabelRequest) GoString() string {
if this == nil {
return "nil"
}
s := make ( [ ] string , 0 , 6 )
s := make ( [ ] string , 0 , 8 )
s = append ( s , "&logproto.LabelRequest{" )
s = append ( s , "Name: " + fmt . Sprintf ( "%#v" , this . Name ) + ",\n" )
s = append ( s , "Values: " + fmt . Sprintf ( "%#v" , this . Values ) + ",\n" )
s = append ( s , "Start: " + fmt . Sprintf ( "%#v" , this . Start ) + ",\n" )
s = append ( s , "End: " + fmt . Sprintf ( "%#v" , this . End ) + ",\n" )
s = append ( s , "}" )
return strings . Join ( s , "" )
}
@ -1587,6 +1620,26 @@ func (m *LabelRequest) MarshalTo(dAtA []byte) (int, error) {
}
i ++
}
if m . Start != nil {
dAtA [ i ] = 0x1a
i ++
i = encodeVarintLogproto ( dAtA , i , uint64 ( github_com_gogo_protobuf_types . SizeOfStdTime ( * m . Start ) ) )
n3 , err3 := github_com_gogo_protobuf_types . StdTimeMarshalTo ( * m . Start , dAtA [ i : ] )
if err3 != nil {
return 0 , err3
}
i += n3
}
if m . End != nil {
dAtA [ i ] = 0x22
i ++
i = encodeVarintLogproto ( dAtA , i , uint64 ( github_com_gogo_protobuf_types . SizeOfStdTime ( * m . End ) ) )
n4 , err4 := github_com_gogo_protobuf_types . StdTimeMarshalTo ( * m . End , dAtA [ i : ] )
if err4 != nil {
return 0 , err4
}
i += n4
}
return i , nil
}
@ -1677,11 +1730,11 @@ func (m *Entry) MarshalTo(dAtA []byte) (int, error) {
dAtA [ i ] = 0xa
i ++
i = encodeVarintLogproto ( dAtA , i , uint64 ( github_com_gogo_protobuf_types . SizeOfStdTime ( m . Timestamp ) ) )
n3 , err3 := github_com_gogo_protobuf_types . StdTimeMarshalTo ( m . Timestamp , dAtA [ i : ] )
if err3 != nil {
return 0 , err3
n5 , err5 := github_com_gogo_protobuf_types . StdTimeMarshalTo ( m . Timestamp , dAtA [ i : ] )
if err5 != nil {
return 0 , err5
}
i += n3
i += n5
if len ( m . Line ) > 0 {
dAtA [ i ] = 0x12
i ++
@ -1894,6 +1947,14 @@ func (m *LabelRequest) Size() (n int) {
if m . Values {
n += 2
}
if m . Start != nil {
l = github_com_gogo_protobuf_types . SizeOfStdTime ( * m . Start )
n += 1 + l + sovLogproto ( uint64 ( l ) )
}
if m . End != nil {
l = github_com_gogo_protobuf_types . SizeOfStdTime ( * m . End )
n += 1 + l + sovLogproto ( uint64 ( l ) )
}
return n
}
@ -2076,6 +2137,8 @@ func (this *LabelRequest) String() string {
s := strings . Join ( [ ] string { ` &LabelRequest { ` ,
` Name: ` + fmt . Sprintf ( "%v" , this . Name ) + ` , ` ,
` Values: ` + fmt . Sprintf ( "%v" , this . Values ) + ` , ` ,
` Start: ` + strings . Replace ( fmt . Sprintf ( "%v" , this . Start ) , "Timestamp" , "types.Timestamp" , 1 ) + ` , ` ,
` End: ` + strings . Replace ( fmt . Sprintf ( "%v" , this . End ) , "Timestamp" , "types.Timestamp" , 1 ) + ` , ` ,
` } ` ,
} , "" )
return s
@ -2694,6 +2757,78 @@ func (m *LabelRequest) Unmarshal(dAtA []byte) error {
}
}
m . Values = bool ( v != 0 )
case 3 :
if wireType != 2 {
return fmt . Errorf ( "proto: wrong wireType = %d for field Start" , 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
}
if m . Start == nil {
m . Start = new ( time . Time )
}
if err := github_com_gogo_protobuf_types . StdTimeUnmarshal ( m . Start , dAtA [ iNdEx : postIndex ] ) ; err != nil {
return err
}
iNdEx = postIndex
case 4 :
if wireType != 2 {
return fmt . Errorf ( "proto: wrong wireType = %d for field End" , 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
}
if m . End == nil {
m . End = new ( time . Time )
}
if err := github_com_gogo_protobuf_types . StdTimeUnmarshal ( m . End , dAtA [ iNdEx : postIndex ] ) ; err != nil {
return err
}
iNdEx = postIndex
default :
iNdEx = preIndex
skippy , err := skipLogproto ( dAtA [ iNdEx : ] )
Cyril Tovena
6 years ago
committed by