package tablev1alpha1
import (
fmt "fmt"
protohelpers "github.com/planetscale/vtprotobuf/protohelpers"
v1alpha1 "github.com/polarsignals/frostdb/gen/proto/go/frostdb/schema/v1alpha1"
v1alpha2 "github.com/polarsignals/frostdb/gen/proto/go/frostdb/schema/v1alpha2"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
io "io"
)
const (
_ = protoimpl .EnforceVersion (20 - protoimpl .MinVersion )
_ = protoimpl .EnforceVersion (protoimpl .MaxVersion - 20 )
)
func (m *TableConfig ) MarshalVT () (dAtA []byte , err error ) {
if m == nil {
return nil , nil
}
size := m .SizeVT ()
dAtA = make ([]byte , size )
n , err := m .MarshalToSizedBufferVT (dAtA [:size ])
if err != nil {
return nil , err
}
return dAtA [:n ], nil
}
func (m *TableConfig ) MarshalToVT (dAtA []byte ) (int , error ) {
size := m .SizeVT ()
return m .MarshalToSizedBufferVT (dAtA [:size ])
}
func (m *TableConfig ) MarshalToSizedBufferVT (dAtA []byte ) (int , error ) {
if m == nil {
return 0 , nil
}
i := len (dAtA )
_ = i
var l int
_ = l
if m .unknownFields != nil {
i -= len (m .unknownFields )
copy (dAtA [i :], m .unknownFields )
}
if vtmsg , ok := m .Schema .(interface {
MarshalToSizedBufferVT ([]byte ) (int , error )
}); ok {
size , err := vtmsg .MarshalToSizedBufferVT (dAtA [:i ])
if err != nil {
return 0 , err
}
i -= size
}
if m .DisableWal {
i --
if m .DisableWal {
dAtA [i ] = 1
} else {
dAtA [i ] = 0
}
i --
dAtA [i ] = 0x28
}
if m .BlockReaderLimit != 0 {
i = protohelpers .EncodeVarint (dAtA , i , uint64 (m .BlockReaderLimit ))
i --
dAtA [i ] = 0x20
}
if m .RowGroupSize != 0 {
i = protohelpers .EncodeVarint (dAtA , i , uint64 (m .RowGroupSize ))
i --
dAtA [i ] = 0x18
}
return len (dAtA ) - i , nil
}
func (m *TableConfig_DeprecatedSchema ) MarshalToVT (dAtA []byte ) (int , error ) {
size := m .SizeVT ()
return m .MarshalToSizedBufferVT (dAtA [:size ])
}
func (m *TableConfig_DeprecatedSchema ) MarshalToSizedBufferVT (dAtA []byte ) (int , error ) {
i := len (dAtA )
if m .DeprecatedSchema != nil {
size , err := m .DeprecatedSchema .MarshalToSizedBufferVT (dAtA [:i ])
if err != nil {
return 0 , err
}
i -= size
i = protohelpers .EncodeVarint (dAtA , i , uint64 (size ))
i --
dAtA [i ] = 0xa
}
return len (dAtA ) - i , nil
}
func (m *TableConfig_SchemaV2 ) MarshalToVT (dAtA []byte ) (int , error ) {
size := m .SizeVT ()
return m .MarshalToSizedBufferVT (dAtA [:size ])
}
func (m *TableConfig_SchemaV2 ) MarshalToSizedBufferVT (dAtA []byte ) (int , error ) {
i := len (dAtA )
if m .SchemaV2 != nil {
size , err := m .SchemaV2 .MarshalToSizedBufferVT (dAtA [:i ])
if err != nil {
return 0 , err
}
i -= size
i = protohelpers .EncodeVarint (dAtA , i , uint64 (size ))
i --
dAtA [i ] = 0x12
}
return len (dAtA ) - i , nil
}
func (m *TableConfig ) SizeVT () (n int ) {
if m == nil {
return 0
}
var l int
_ = l
if vtmsg , ok := m .Schema .(interface { SizeVT () int }); ok {
n += vtmsg .SizeVT ()
}
if m .RowGroupSize != 0 {
n += 1 + protohelpers .SizeOfVarint (uint64 (m .RowGroupSize ))
}
if m .BlockReaderLimit != 0 {
n += 1 + protohelpers .SizeOfVarint (uint64 (m .BlockReaderLimit ))
}
if m .DisableWal {
n += 2
}
n += len (m .unknownFields )
return n
}
func (m *TableConfig_DeprecatedSchema ) SizeVT () (n int ) {
if m == nil {
return 0
}
var l int
_ = l
if m .DeprecatedSchema != nil {
l = m .DeprecatedSchema .SizeVT ()
n += 1 + l + protohelpers .SizeOfVarint (uint64 (l ))
}
return n
}
func (m *TableConfig_SchemaV2 ) SizeVT () (n int ) {
if m == nil {
return 0
}
var l int
_ = l
if m .SchemaV2 != nil {
l = m .SchemaV2 .SizeVT ()
n += 1 + l + protohelpers .SizeOfVarint (uint64 (l ))
}
return n
}
func (m *TableConfig ) UnmarshalVT (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 protohelpers .ErrIntOverflow
}
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: TableConfig: wiretype end group for non-group" )
}
if fieldNum <= 0 {
return fmt .Errorf ("proto: TableConfig: illegal tag %d (wire type %d)" , fieldNum , wire )
}
switch fieldNum {
case 1 :
if wireType != 2 {
return fmt .Errorf ("proto: wrong wireType = %d for field DeprecatedSchema" , wireType )
}
var msglen int
for shift := uint (0 ); ; shift += 7 {
if shift >= 64 {
return protohelpers .ErrIntOverflow
}
if iNdEx >= l {
return io .ErrUnexpectedEOF
}
b := dAtA [iNdEx ]
iNdEx ++
msglen |= int (b &0x7F ) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return protohelpers .ErrInvalidLength
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return protohelpers .ErrInvalidLength
}
if postIndex > l {
return io .ErrUnexpectedEOF
}
if oneof , ok := m .Schema .(*TableConfig_DeprecatedSchema ); ok {
if err := oneof .DeprecatedSchema .UnmarshalVT (dAtA [iNdEx :postIndex ]); err != nil {
return err
}
} else {
v := &v1alpha1 .Schema {}
if err := v .UnmarshalVT (dAtA [iNdEx :postIndex ]); err != nil {
return err
}
m .Schema = &TableConfig_DeprecatedSchema {DeprecatedSchema : v }
}
iNdEx = postIndex
case 2 :
if wireType != 2 {
return fmt .Errorf ("proto: wrong wireType = %d for field SchemaV2" , wireType )
}
var msglen int
for shift := uint (0 ); ; shift += 7 {
if shift >= 64 {
return protohelpers .ErrIntOverflow
}
if iNdEx >= l {
return io .ErrUnexpectedEOF
}
b := dAtA [iNdEx ]
iNdEx ++
msglen |= int (b &0x7F ) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return protohelpers .ErrInvalidLength
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return protohelpers .ErrInvalidLength
}
if postIndex > l {
return io .ErrUnexpectedEOF
}
if oneof , ok := m .Schema .(*TableConfig_SchemaV2 ); ok {
if err := oneof .SchemaV2 .UnmarshalVT (dAtA [iNdEx :postIndex ]); err != nil {
return err
}
} else {
v := &v1alpha2 .Schema {}
if err := v .UnmarshalVT (dAtA [iNdEx :postIndex ]); err != nil {
return err
}
m .Schema = &TableConfig_SchemaV2 {SchemaV2 : v }
}
iNdEx = postIndex
case 3 :
if wireType != 0 {
return fmt .Errorf ("proto: wrong wireType = %d for field RowGroupSize" , wireType )
}
m .RowGroupSize = 0
for shift := uint (0 ); ; shift += 7 {
if shift >= 64 {
return protohelpers .ErrIntOverflow
}
if iNdEx >= l {
return io .ErrUnexpectedEOF
}
b := dAtA [iNdEx ]
iNdEx ++
m .RowGroupSize |= uint64 (b &0x7F ) << shift
if b < 0x80 {
break
}
}
case 4 :
if wireType != 0 {
return fmt .Errorf ("proto: wrong wireType = %d for field BlockReaderLimit" , wireType )
}
m .BlockReaderLimit = 0
for shift := uint (0 ); ; shift += 7 {
if shift >= 64 {
return protohelpers .ErrIntOverflow
}
if iNdEx >= l {
return io .ErrUnexpectedEOF
}
b := dAtA [iNdEx ]
iNdEx ++
m .BlockReaderLimit |= uint64 (b &0x7F ) << shift
if b < 0x80 {
break
}
}
case 5 :
if wireType != 0 {
return fmt .Errorf ("proto: wrong wireType = %d for field DisableWal" , wireType )
}
var v int
for shift := uint (0 ); ; shift += 7 {
if shift >= 64 {
return protohelpers .ErrIntOverflow
}
if iNdEx >= l {
return io .ErrUnexpectedEOF
}
b := dAtA [iNdEx ]
iNdEx ++
v |= int (b &0x7F ) << shift
if b < 0x80 {
break
}
}
m .DisableWal = bool (v != 0 )
default :
iNdEx = preIndex
skippy , err := protohelpers .Skip (dAtA [iNdEx :])
if err != nil {
return err
}
if (skippy < 0 ) || (iNdEx +skippy ) < 0 {
return protohelpers .ErrInvalidLength
}
if (iNdEx + skippy ) > l {
return io .ErrUnexpectedEOF
}
m .unknownFields = append (m .unknownFields , dAtA [iNdEx :iNdEx +skippy ]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io .ErrUnexpectedEOF
}
return nil
}
The pages are generated with Golds v0.8.4 . (GOOS=linux GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu .
PR and bug reports are welcome and can be submitted to the issue list .
Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds .