package types
import (
context "context"
fmt "fmt"
grpc1 "github.com/cosmos/gogoproto/grpc"
proto "github.com/cosmos/gogoproto/proto"
_ "google.golang.org/genproto/googleapis/api/annotations"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
io "io"
math "math"
math_bits "math/bits"
)
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
const _ = proto.GoGoProtoPackageIsVersion3
type QueryGraphStatsRequest struct {
}
func (m *QueryGraphStatsRequest) Reset() { *m = QueryGraphStatsRequest{} }
func (m *QueryGraphStatsRequest) String() string { return proto.CompactTextString(m) }
func (*QueryGraphStatsRequest) ProtoMessage() {}
func (*QueryGraphStatsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_1588f994db3ad35c, []int{0}
}
func (m *QueryGraphStatsRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryGraphStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryGraphStatsRequest.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 *QueryGraphStatsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryGraphStatsRequest.Merge(m, src)
}
func (m *QueryGraphStatsRequest) XXX_Size() int {
return m.Size()
}
func (m *QueryGraphStatsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryGraphStatsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryGraphStatsRequest proto.InternalMessageInfo
type QueryGraphStatsResponse struct {
Cyberlinks uint64 `protobuf:"varint,1,opt,name=cyberlinks,proto3" json:"cyberlinks,omitempty"`
Particles uint64 `protobuf:"varint,2,opt,name=particles,proto3" json:"particles,omitempty"`
}
func (m *QueryGraphStatsResponse) Reset() { *m = QueryGraphStatsResponse{} }
func (m *QueryGraphStatsResponse) String() string { return proto.CompactTextString(m) }
func (*QueryGraphStatsResponse) ProtoMessage() {}
func (*QueryGraphStatsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_1588f994db3ad35c, []int{1}
}
func (m *QueryGraphStatsResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryGraphStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryGraphStatsResponse.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 *QueryGraphStatsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryGraphStatsResponse.Merge(m, src)
}
func (m *QueryGraphStatsResponse) XXX_Size() int {
return m.Size()
}
func (m *QueryGraphStatsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_QueryGraphStatsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_QueryGraphStatsResponse proto.InternalMessageInfo
func (m *QueryGraphStatsResponse) GetCyberlinks() uint64 {
if m != nil {
return m.Cyberlinks
}
return 0
}
func (m *QueryGraphStatsResponse) GetParticles() uint64 {
if m != nil {
return m.Particles
}
return 0
}
type QueryBurnStatsRequest struct {
}
func (m *QueryBurnStatsRequest) Reset() { *m = QueryBurnStatsRequest{} }
func (m *QueryBurnStatsRequest) String() string { return proto.CompactTextString(m) }
func (*QueryBurnStatsRequest) ProtoMessage() {}
func (*QueryBurnStatsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_1588f994db3ad35c, []int{2}
}
func (m *QueryBurnStatsRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryBurnStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryBurnStatsRequest.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 *QueryBurnStatsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryBurnStatsRequest.Merge(m, src)
}
func (m *QueryBurnStatsRequest) XXX_Size() int {
return m.Size()
}
func (m *QueryBurnStatsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryBurnStatsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryBurnStatsRequest proto.InternalMessageInfo
type QueryBurnStatsResponse struct {
Millivolt uint64 `protobuf:"varint,1,opt,name=millivolt,proto3" json:"millivolt,omitempty"`
Milliampere uint64 `protobuf:"varint,2,opt,name=milliampere,proto3" json:"milliampere,omitempty"`
}
func (m *QueryBurnStatsResponse) Reset() { *m = QueryBurnStatsResponse{} }
func (m *QueryBurnStatsResponse) String() string { return proto.CompactTextString(m) }
func (*QueryBurnStatsResponse) ProtoMessage() {}
func (*QueryBurnStatsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_1588f994db3ad35c, []int{3}
}
func (m *QueryBurnStatsResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryBurnStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryBurnStatsResponse.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 *QueryBurnStatsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryBurnStatsResponse.Merge(m, src)
}
func (m *QueryBurnStatsResponse) XXX_Size() int {
return m.Size()
}
func (m *QueryBurnStatsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_QueryBurnStatsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_QueryBurnStatsResponse proto.InternalMessageInfo
func (m *QueryBurnStatsResponse) GetMillivolt() uint64 {
if m != nil {
return m.Millivolt
}
return 0
}
func (m *QueryBurnStatsResponse) GetMilliampere() uint64 {
if m != nil {
return m.Milliampere
}
return 0
}
func init() {
proto.RegisterType((*QueryGraphStatsRequest)(nil), "cyber.graph.v1beta1.QueryGraphStatsRequest")
proto.RegisterType((*QueryGraphStatsResponse)(nil), "cyber.graph.v1beta1.QueryGraphStatsResponse")
proto.RegisterType((*QueryBurnStatsRequest)(nil), "cyber.graph.v1beta1.QueryBurnStatsRequest")
proto.RegisterType((*QueryBurnStatsResponse)(nil), "cyber.graph.v1beta1.QueryBurnStatsResponse")
}
func init() { proto.RegisterFile("cyber/graph/v1beta1/query.proto", fileDescriptor_1588f994db3ad35c) }
var fileDescriptor_1588f994db3ad35c = []byte{
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x52, 0xc1, 0x4e, 0x2a, 0x31,
0x14, 0xa5, 0xe4, 0x3d, 0x13, 0xea, 0xae, 0x46, 0x21, 0x84, 0x14, 0x9c, 0x8d, 0x44, 0x74, 0x1a,
0xf4, 0x0f, 0xd8, 0x18, 0x97, 0xe2, 0x42, 0xe3, 0xc6, 0x74, 0x26, 0xcd, 0xd0, 0x38, 0xb4, 0xa5,
0xed, 0x10, 0xd9, 0xba, 0x37, 0xd1, 0xf8, 0x19, 0xfe, 0x88, 0x4b, 0x12, 0x37, 0x2e, 0x0d, 0xf8,
0x21, 0x86, 0x4e, 0x23, 0xa8, 0x63, 0xc2, 0xf2, 0x9e, 0x7b, 0xee, 0x39, 0xe7, 0xde, 0x16, 0x36,
0xe3, 0x49, 0xc4, 0x34, 0x49, 0x34, 0x55, 0x03, 0x32, 0xee, 0x46, 0xcc, 0xd2, 0x2e, 0x19, 0x65,
0x4c, 0x4f, 0x42, 0xa5, 0xa5, 0x95, 0x68, 0xcb, 0x11, 0x42, 0x47, 0x08, 0x3d, 0xa1, 0xde, 0x48,
0xa4, 0x4c, 0x52, 0x46, 0xa8, 0xe2, 0x84, 0x0a, 0x21, 0x2d, 0xb5, 0x5c, 0x0a, 0x93, 0x8f, 0x04,
0x35, 0xb8, 0x73, 0xb6, 0x50, 0x38, 0x59, 0xcc, 0x9c, 0x5b, 0x6a, 0x4d, 0x9f, 0x8d, 0x32, 0x66,
0x6c, 0x70, 0x01, 0xab, 0xbf, 0x3a, 0x46, 0x49, 0x61, 0x18, 0xc2, 0x10, 0x3a, 0xa7, 0x94, 0x8b,
0x1b, 0x53, 0x03, 0x2d, 0xd0, 0xfe, 0xd7, 0x5f, 0x41, 0x50, 0x03, 0x56, 0x14, 0xd5, 0x96, 0xc7,
0x29, 0x33, 0xb5, 0xb2, 0x6b, 0x2f, 0x81, 0xa0, 0x0a, 0xb7, 0x9d, 0x70, 0x2f, 0xd3, 0xe2, 0x9b,
0xe3, 0xa5, 0xcf, 0xb2, 0xd2, 0xf0, 0x86, 0x0d, 0x58, 0x19, 0xf2, 0x34, 0xe5, 0x63, 0x99, 0x5a,
0xef, 0xb7, 0x04, 0x50, 0x0b, 0x6e, 0xba, 0x82, 0x0e, 0x15, 0xd3, 0xcc, 0x1b, 0xae, 0x42, 0x47,
0xcf, 0x65, 0xf8, 0xdf, 0x49, 0xa3, 0x47, 0x00, 0xe1, 0x72, 0x23, 0xd4, 0x09, 0x0b, 0x4e, 0x16,
0x16, 0x5f, 0xa4, 0x7e, 0xb0, 0x1e, 0x39, 0xcf, 0x1c, 0xb4, 0xef, 0x5e, 0x3f, 0x9e, 0xca, 0x01,
0x6a, 0x91, 0xa2, 0x67, 0x73, 0xd5, 0xb5, 0x71, 0x21, 0xee, 0x01, 0xac, 0x7c, 0xed, 0x8c, 0xf6,
0xff, 0x76, 0xf9, 0x79, 0xb1, 0x7a, 0x67, 0x2d, 0xae, 0x0f, 0xb4, 0xe7, 0x02, 0xed, 0xa2, 0x66,
0x61, 0xa0, 0x28, 0xd3, 0x22, 0xcf, 0xd3, 0x3b, 0x7d, 0x99, 0x61, 0x30, 0x9d, 0x61, 0xf0, 0x3e,
0xc3, 0xe0, 0x61, 0x8e, 0x4b, 0xd3, 0x39, 0x2e, 0xbd, 0xcd, 0x71, 0xe9, 0x8a, 0x24, 0xdc, 0x0e,
0xb2, 0x28, 0x8c, 0xe5, 0x30, 0x17, 0x89, 0xa5, 0x48, 0x34, 0x33, 0x86, 0x24, 0xf2, 0x30, 0x57,
0xbd, 0xf5, 0xba, 0x76, 0xa2, 0x98, 0x89, 0x36, 0xdc, 0x2f, 0x3b, 0xfe, 0x0c, 0x00, 0x00, 0xff,
0xff, 0x55, 0x5d, 0xaf, 0x89, 0xbb, 0x02, 0x00, 0x00,
}
var _ context.Context
var _ grpc.ClientConn
const _ = grpc.SupportPackageIsVersion4
type QueryClient interface {
GraphStats(ctx context.Context, in *QueryGraphStatsRequest, opts ...grpc.CallOption) (*QueryGraphStatsResponse, error)
BurnStats(ctx context.Context, in *QueryBurnStatsRequest, opts ...grpc.CallOption) (*QueryBurnStatsResponse, error)
}
type queryClient struct {
cc grpc1.ClientConn
}
func NewQueryClient(cc grpc1.ClientConn) QueryClient {
return &queryClient{cc}
}
func (c *queryClient) GraphStats(ctx context.Context, in *QueryGraphStatsRequest, opts ...grpc.CallOption) (*QueryGraphStatsResponse, error) {
out := new(QueryGraphStatsResponse)
err := c.cc.Invoke(ctx, "/cyber.graph.v1beta1.Query/GraphStats", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *queryClient) BurnStats(ctx context.Context, in *QueryBurnStatsRequest, opts ...grpc.CallOption) (*QueryBurnStatsResponse, error) {
out := new(QueryBurnStatsResponse)
err := c.cc.Invoke(ctx, "/cyber.graph.v1beta1.Query/BurnStats", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
type QueryServer interface {
GraphStats(context.Context, *QueryGraphStatsRequest) (*QueryGraphStatsResponse, error)
BurnStats(context.Context, *QueryBurnStatsRequest) (*QueryBurnStatsResponse, error)
}
type UnimplementedQueryServer struct {
}
func (*UnimplementedQueryServer) GraphStats(ctx context.Context, req *QueryGraphStatsRequest) (*QueryGraphStatsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GraphStats not implemented")
}
func (*UnimplementedQueryServer) BurnStats(ctx context.Context, req *QueryBurnStatsRequest) (*QueryBurnStatsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method BurnStats not implemented")
}
func RegisterQueryServer(s grpc1.Server, srv QueryServer) {
s.RegisterService(&_Query_serviceDesc, srv)
}
func _Query_GraphStats_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryGraphStatsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(QueryServer).GraphStats(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/cyber.graph.v1beta1.Query/GraphStats",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(QueryServer).GraphStats(ctx, req.(*QueryGraphStatsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Query_BurnStats_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryBurnStatsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(QueryServer).BurnStats(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/cyber.graph.v1beta1.Query/BurnStats",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(QueryServer).BurnStats(ctx, req.(*QueryBurnStatsRequest))
}
return interceptor(ctx, in, info, handler)
}
var _Query_serviceDesc = grpc.ServiceDesc{
ServiceName: "cyber.graph.v1beta1.Query",
HandlerType: (*QueryServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "GraphStats",
Handler: _Query_GraphStats_Handler,
},
{
MethodName: "BurnStats",
Handler: _Query_BurnStats_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "cyber/graph/v1beta1/query.proto",
}
func (m *QueryGraphStatsRequest) 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 *QueryGraphStatsRequest) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryGraphStatsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
return len(dAtA) - i, nil
}
func (m *QueryGraphStatsResponse) 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 *QueryGraphStatsResponse) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryGraphStatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.Particles != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.Particles))
i--
dAtA[i] = 0x10
}
if m.Cyberlinks != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.Cyberlinks))
i--
dAtA[i] = 0x8
}
return len(dAtA) - i, nil
}
func (m *QueryBurnStatsRequest) 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 *QueryBurnStatsRequest) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryBurnStatsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
return len(dAtA) - i, nil
}
func (m *QueryBurnStatsResponse) 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 *QueryBurnStatsResponse) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryBurnStatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.Milliampere != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.Milliampere))
i--
dAtA[i] = 0x10
}
if m.Millivolt != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.Millivolt))
i--
dAtA[i] = 0x8
}
return len(dAtA) - i, nil
}
func encodeVarintQuery(dAtA []byte, offset int, v uint64) int {
offset -= sovQuery(v)
base := offset
for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7
offset++
}
dAtA[offset] = uint8(v)
return base
}
func (m *QueryGraphStatsRequest) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
return n
}
func (m *QueryGraphStatsResponse) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Cyberlinks != 0 {
n += 1 + sovQuery(uint64(m.Cyberlinks))
}
if m.Particles != 0 {
n += 1 + sovQuery(uint64(m.Particles))
}
return n
}
func (m *QueryBurnStatsRequest) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
return n
}
func (m *QueryBurnStatsResponse) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Millivolt != 0 {
n += 1 + sovQuery(uint64(m.Millivolt))
}
if m.Milliampere != 0 {
n += 1 + sovQuery(uint64(m.Milliampere))
}
return n
}
func sovQuery(x uint64) (n int) {
return (math_bits.Len64(x|1) + 6) / 7
}
func sozQuery(x uint64) (n int) {
return sovQuery(uint64((x << 1) ^ uint64((int64(x) >> 63))))
}
func (m *QueryGraphStatsRequest) 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 ErrIntOverflowQuery
}
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: QueryGraphStatsRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryGraphStatsRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryGraphStatsResponse) 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 ErrIntOverflowQuery
}
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: QueryGraphStatsResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryGraphStatsResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Cyberlinks", wireType)
}
m.Cyberlinks = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Cyberlinks |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Particles", wireType)
}
m.Particles = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Particles |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryBurnStatsRequest) 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 ErrIntOverflowQuery
}
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: QueryBurnStatsRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryBurnStatsRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryBurnStatsResponse) 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 ErrIntOverflowQuery
}
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: QueryBurnStatsResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryBurnStatsResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Millivolt", wireType)
}
m.Millivolt = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Millivolt |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Milliampere", wireType)
}
m.Milliampere = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Milliampere |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func skipQuery(dAtA []byte) (n int, err error) {
l := len(dAtA)
iNdEx := 0
depth := 0
for iNdEx < l {
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowQuery
}
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, ErrIntOverflowQuery
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
iNdEx++
if dAtA[iNdEx-1] < 0x80 {
break
}
}
case 1:
iNdEx += 8
case 2:
var length int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowQuery
}
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, ErrInvalidLengthQuery
}
iNdEx += length
case 3:
depth++
case 4:
if depth == 0 {
return 0, ErrUnexpectedEndOfGroupQuery
}
depth--
case 5:
iNdEx += 4
default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
}
if iNdEx < 0 {
return 0, ErrInvalidLengthQuery
}
if depth == 0 {
return iNdEx, nil
}
}
return 0, io.ErrUnexpectedEOF
}
var (
ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow")
ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)