autoid

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 15, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAutoid        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAutoid          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAutoid = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterAutoIDAllocServer 

func RegisterAutoIDAllocServer(s *grpc.Server, srv AutoIDAllocServer)

Types

type AutoIDAllocClient 

type AutoIDAllocClient interface {
	AllocAutoID(ctx context.Context, in *AutoIDRequest, opts ...grpc.CallOption) (*AutoIDResponse, error)
	Rebase(ctx context.Context, in *RebaseRequest, opts ...grpc.CallOption) (*RebaseResponse, error)
}

AutoIDAllocClient is the client API for AutoIDAlloc service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAutoIDAllocClient 

func NewAutoIDAllocClient(cc *grpc.ClientConn) AutoIDAllocClient

type AutoIDAllocServer 

type AutoIDAllocServer interface {
	AllocAutoID(context.Context, *AutoIDRequest) (*AutoIDResponse, error)
	Rebase(context.Context, *RebaseRequest) (*RebaseResponse, error)
}

AutoIDAllocServer is the server API for AutoIDAlloc service.

type AutoIDRequest 

type AutoIDRequest struct {
	DbID                 int64    `protobuf:"varint,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
	TblID                int64    `protobuf:"varint,2,opt,name=tblID,proto3" json:"tblID,omitempty"`
	IsUnsigned           bool     `protobuf:"varint,3,opt,name=isUnsigned,proto3" json:"isUnsigned,omitempty"`
	N                    uint64   `protobuf:"varint,4,opt,name=n,proto3" json:"n,omitempty"`
	Increment            int64    `protobuf:"varint,5,opt,name=increment,proto3" json:"increment,omitempty"`
	Offset               int64    `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AutoIDRequest) Descriptor 

func (*AutoIDRequest) Descriptor() ([]byte, []int)

func (*AutoIDRequest) GetDbID 

func (m *AutoIDRequest) GetDbID() int64

func (*AutoIDRequest) GetIncrement 

func (m *AutoIDRequest) GetIncrement() int64

func (*AutoIDRequest) GetIsUnsigned 

func (m *AutoIDRequest) GetIsUnsigned() bool

func (*AutoIDRequest) GetN 

func (m *AutoIDRequest) GetN() uint64

func (*AutoIDRequest) GetOffset 

func (m *AutoIDRequest) GetOffset() int64

func (*AutoIDRequest) GetTblID 

func (m *AutoIDRequest) GetTblID() int64

func (*AutoIDRequest) Marshal 

func (m *AutoIDRequest) Marshal() (dAtA []byte, err error)

func (*AutoIDRequest) MarshalTo 

func (m *AutoIDRequest) MarshalTo(dAtA []byte) (int, error)

func (*AutoIDRequest) MarshalToSizedBuffer 

func (m *AutoIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AutoIDRequest) ProtoMessage 

func (*AutoIDRequest) ProtoMessage()

func (*AutoIDRequest) Reset 

func (m *AutoIDRequest) Reset()

func (*AutoIDRequest) Size 

func (m *AutoIDRequest) Size() (n int)

func (*AutoIDRequest) String 

func (m *AutoIDRequest) String() string

func (*AutoIDRequest) Unmarshal 

func (m *AutoIDRequest) Unmarshal(dAtA []byte) error

func (*AutoIDRequest) XXX_DiscardUnknown 

func (m *AutoIDRequest) XXX_DiscardUnknown()

func (*AutoIDRequest) XXX_Marshal 

func (m *AutoIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AutoIDRequest) XXX_Merge 

func (m *AutoIDRequest) XXX_Merge(src proto.Message)

func (*AutoIDRequest) XXX_Size 

func (m *AutoIDRequest) XXX_Size() int

func (*AutoIDRequest) XXX_Unmarshal 

func (m *AutoIDRequest) XXX_Unmarshal(b []byte) error

type AutoIDResponse 

type AutoIDResponse struct {
	Min                  int64    `protobuf:"varint,1,opt,name=min,proto3" json:"min,omitempty"`
	Max                  int64    `protobuf:"varint,2,opt,name=max,proto3" json:"max,omitempty"`
	Errmsg               []byte   `protobuf:"bytes,3,opt,name=errmsg,proto3" json:"errmsg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AutoIDResponse) Descriptor 

func (*AutoIDResponse) Descriptor() ([]byte, []int)

func (*AutoIDResponse) GetErrmsg 

func (m *AutoIDResponse) GetErrmsg() []byte

func (*AutoIDResponse) GetMax 

func (m *AutoIDResponse) GetMax() int64

func (*AutoIDResponse) GetMin 

func (m *AutoIDResponse) GetMin() int64

func (*AutoIDResponse) Marshal 

func (m *AutoIDResponse) Marshal() (dAtA []byte, err error)

func (*AutoIDResponse) MarshalTo 

func (m *AutoIDResponse) MarshalTo(dAtA []byte) (int, error)

func (*AutoIDResponse) MarshalToSizedBuffer 

func (m *AutoIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AutoIDResponse) ProtoMessage 

func (*AutoIDResponse) ProtoMessage()

func (*AutoIDResponse) Reset 

func (m *AutoIDResponse) Reset()

func (*AutoIDResponse) Size 

func (m *AutoIDResponse) Size() (n int)

func (*AutoIDResponse) String 

func (m *AutoIDResponse) String() string

func (*AutoIDResponse) Unmarshal 

func (m *AutoIDResponse) Unmarshal(dAtA []byte) error

func (*AutoIDResponse) XXX_DiscardUnknown 

func (m *AutoIDResponse) XXX_DiscardUnknown()

func (*AutoIDResponse) XXX_Marshal 

func (m *AutoIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AutoIDResponse) XXX_Merge 

func (m *AutoIDResponse) XXX_Merge(src proto.Message)

func (*AutoIDResponse) XXX_Size 

func (m *AutoIDResponse) XXX_Size() int

func (*AutoIDResponse) XXX_Unmarshal 

func (m *AutoIDResponse) XXX_Unmarshal(b []byte) error

type RebaseRequest 

type RebaseRequest struct {
	DbID                 int64    `protobuf:"varint,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
	TblID                int64    `protobuf:"varint,2,opt,name=tblID,proto3" json:"tblID,omitempty"`
	IsUnsigned           bool     `protobuf:"varint,3,opt,name=isUnsigned,proto3" json:"isUnsigned,omitempty"`
	Base                 int64    `protobuf:"varint,4,opt,name=base,proto3" json:"base,omitempty"`
	Force                bool     `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RebaseRequest) Descriptor 

func (*RebaseRequest) Descriptor() ([]byte, []int)

func (*RebaseRequest) GetBase 

func (m *RebaseRequest) GetBase() int64

func (*RebaseRequest) GetDbID 

func (m *RebaseRequest) GetDbID() int64

func (*RebaseRequest) GetForce 

func (m *RebaseRequest) GetForce() bool

func (*RebaseRequest) GetIsUnsigned 

func (m *RebaseRequest) GetIsUnsigned() bool

func (*RebaseRequest) GetTblID 

func (m *RebaseRequest) GetTblID() int64

func (*RebaseRequest) Marshal 

func (m *RebaseRequest) Marshal() (dAtA []byte, err error)

func (*RebaseRequest) MarshalTo 

func (m *RebaseRequest) MarshalTo(dAtA []byte) (int, error)

func (*RebaseRequest) MarshalToSizedBuffer 

func (m *RebaseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RebaseRequest) ProtoMessage 

func (*RebaseRequest) ProtoMessage()

func (*RebaseRequest) Reset 

func (m *RebaseRequest) Reset()

func (*RebaseRequest) Size 

func (m *RebaseRequest) Size() (n int)

func (*RebaseRequest) String 

func (m *RebaseRequest) String() string

func (*RebaseRequest) Unmarshal 

func (m *RebaseRequest) Unmarshal(dAtA []byte) error

func (*RebaseRequest) XXX_DiscardUnknown 

func (m *RebaseRequest) XXX_DiscardUnknown()

func (*RebaseRequest) XXX_Marshal 

func (m *RebaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RebaseRequest) XXX_Merge 

func (m *RebaseRequest) XXX_Merge(src proto.Message)

func (*RebaseRequest) XXX_Size 

func (m *RebaseRequest) XXX_Size() int

func (*RebaseRequest) XXX_Unmarshal 

func (m *RebaseRequest) XXX_Unmarshal(b []byte) error

type RebaseResponse 

type RebaseResponse struct {
	Errmsg               []byte   `protobuf:"bytes,1,opt,name=errmsg,proto3" json:"errmsg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RebaseResponse) Descriptor 

func (*RebaseResponse) Descriptor() ([]byte, []int)

func (*RebaseResponse) GetErrmsg 

func (m *RebaseResponse) GetErrmsg() []byte

func (*RebaseResponse) Marshal 

func (m *RebaseResponse) Marshal() (dAtA []byte, err error)

func (*RebaseResponse) MarshalTo 

func (m *RebaseResponse) MarshalTo(dAtA []byte) (int, error)

func (*RebaseResponse) MarshalToSizedBuffer 

func (m *RebaseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RebaseResponse) ProtoMessage 

func (*RebaseResponse) ProtoMessage()

func (*RebaseResponse) Reset 

func (m *RebaseResponse) Reset()

func (*RebaseResponse) Size 

func (m *RebaseResponse) Size() (n int)

func (*RebaseResponse) String 

func (m *RebaseResponse) String() string

func (*RebaseResponse) Unmarshal 

func (m *RebaseResponse) Unmarshal(dAtA []byte) error

func (*RebaseResponse) XXX_DiscardUnknown 

func (m *RebaseResponse) XXX_DiscardUnknown()

func (*RebaseResponse) XXX_Marshal 

func (m *RebaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RebaseResponse) XXX_Merge 

func (m *RebaseResponse) XXX_Merge(src proto.Message)

func (*RebaseResponse) XXX_Size 

func (m *RebaseResponse) XXX_Size() int

func (*RebaseResponse) XXX_Unmarshal 

func (m *RebaseResponse) XXX_Unmarshal(b []byte) error

type UnimplementedAutoIDAllocServer 

type UnimplementedAutoIDAllocServer struct {
}

UnimplementedAutoIDAllocServer can be embedded to have forward compatible implementations.

func (*UnimplementedAutoIDAllocServer) AllocAutoID 

func (*UnimplementedAutoIDAllocServer) AllocAutoID(ctx context.Context, req *AutoIDRequest) (*AutoIDResponse, error)

func (*UnimplementedAutoIDAllocServer) Rebase 

func (*UnimplementedAutoIDAllocServer) Rebase(ctx context.Context, req *RebaseRequest) (*RebaseResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.