sardine

package
v0.0.0-...-8588863 Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Alloc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Sardine.alloc",
	HandlerType: (*AllocServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GenUserSeq",
			Handler:    _Alloc_GenUserSeq_Handler,
		},
		{
			MethodName: "GetUserSeq",
			Handler:    _Alloc_GetUserSeq_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/sardine.proto",
}

Alloc_ServiceDesc is the grpc.ServiceDesc for Alloc service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Assign_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Sardine.assign",
	HandlerType: (*AssignServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegSection",
			Handler:    _Assign_RegSection_Handler,
		},
		{
			MethodName: "UnRegSection",
			Handler:    _Assign_UnRegSection_Handler,
		},
		{
			MethodName: "ReBalance",
			Handler:    _Assign_ReBalance_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/sardine.proto",
}

Assign_ServiceDesc is the grpc.ServiceDesc for Assign service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_proto_sardine_proto protoreflect.FileDescriptor
View Source 
var Proxy_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Sardine.proxy",
	HandlerType: (*ProxyServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GenUserSeq",
			Handler:    _Proxy_GenUserSeq_Handler,
		},
		{
			MethodName: "GetUserSeq",
			Handler:    _Proxy_GetUserSeq_Handler,
		},
		{
			MethodName: "GenUserMultiSeq",
			Handler:    _Proxy_GenUserMultiSeq_Handler,
		},
		{
			MethodName: "GetUserMultiSeq",
			Handler:    _Proxy_GetUserMultiSeq_Handler,
		},
		{
			MethodName: "BatchGenUserSeq",
			Handler:    _Proxy_BatchGenUserSeq_Handler,
		},
		{
			MethodName: "BatchGetUserSeq",
			Handler:    _Proxy_BatchGetUserSeq_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/sardine.proto",
}

Proxy_ServiceDesc is the grpc.ServiceDesc for Proxy service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAllocServer 

func RegisterAllocServer(s grpc.ServiceRegistrar, srv AllocServer)

func RegisterAssignServer 

func RegisterAssignServer(s grpc.ServiceRegistrar, srv AssignServer)

func RegisterProxyServer 

func RegisterProxyServer(s grpc.ServiceRegistrar, srv ProxyServer)

Types

type AllocClient 

type AllocClient interface {
	// 生成单个id指定tag的Seq
	GenUserSeq(ctx context.Context, in *GenUserSeqReq, opts ...grpc.CallOption) (*GenUserSeqResp, error)
	// 获取单个id指定tag的Seq
	GetUserSeq(ctx context.Context, in *GetUserSeqReq, opts ...grpc.CallOption) (*GetUserSeqResp, error)
}

AllocClient is the client API for Alloc service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAllocClient 

func NewAllocClient(cc grpc.ClientConnInterface) AllocClient

type AllocServer 

type AllocServer interface {
	// 生成单个id指定tag的Seq
	GenUserSeq(context.Context, *GenUserSeqReq) (*GenUserSeqResp, error)
	// 获取单个id指定tag的Seq
	GetUserSeq(context.Context, *GetUserSeqReq) (*GetUserSeqResp, error)
	// contains filtered or unexported methods
}

AllocServer is the server API for Alloc service. All implementations must embed UnimplementedAllocServer for forward compatibility

type AssignClient 

type AssignClient interface {
	// 注册业务tag
	RegSection(ctx context.Context, in *RegSectionReq, opts ...grpc.CallOption) (*RegSectionResp, error)
	// 注销业务tag
	UnRegSection(ctx context.Context, in *UnRegSectionReq, opts ...grpc.CallOption) (*UnRegSectionResp, error)
	// 手动reBalance
	ReBalance(ctx context.Context, in *ReBalanceReq, opts ...grpc.CallOption) (*ReBalanceResp, error)
}

AssignClient is the client API for Assign service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAssignClient 

func NewAssignClient(cc grpc.ClientConnInterface) AssignClient

type AssignServer 

type AssignServer interface {
	// 注册业务tag
	RegSection(context.Context, *RegSectionReq) (*RegSectionResp, error)
	// 注销业务tag
	UnRegSection(context.Context, *UnRegSectionReq) (*UnRegSectionResp, error)
	// 手动reBalance
	ReBalance(context.Context, *ReBalanceReq) (*ReBalanceResp, error)
	// contains filtered or unexported methods
}

AssignServer is the server API for Assign service. All implementations must embed UnimplementedAssignServer for forward compatibility

type BatchGenUserSeqReq 

type BatchGenUserSeqReq struct {
	IdList []uint32 `protobuf:"varint,1,rep,packed,name=idList,proto3" json:"idList,omitempty"`
	Tag    string   `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	Async  bool     `protobuf:"varint,3,opt,name=async,proto3" json:"async,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchGenUserSeqReq) Descriptor deprecated 

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

Deprecated: Use BatchGenUserSeqReq.ProtoReflect.Descriptor instead.

func (*BatchGenUserSeqReq) GetAsync 

func (x *BatchGenUserSeqReq) GetAsync() bool

func (*BatchGenUserSeqReq) GetIdList 

func (x *BatchGenUserSeqReq) GetIdList() []uint32

func (*BatchGenUserSeqReq) GetTag 

func (x *BatchGenUserSeqReq) GetTag() string

func (*BatchGenUserSeqReq) ProtoMessage 

func (*BatchGenUserSeqReq) ProtoMessage()

func (*BatchGenUserSeqReq) ProtoReflect 

func (x *BatchGenUserSeqReq) ProtoReflect() protoreflect.Message

func (*BatchGenUserSeqReq) Reset 

func (x *BatchGenUserSeqReq) Reset()

func (*BatchGenUserSeqReq) String 

func (x *BatchGenUserSeqReq) String() string

type BatchGenUserSeqResp 

type BatchGenUserSeqResp struct {
	SeqList map[uint32]int64 `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BatchGenUserSeqResp) Descriptor deprecated 

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

Deprecated: Use BatchGenUserSeqResp.ProtoReflect.Descriptor instead.

func (*BatchGenUserSeqResp) GetSeqList 

func (x *BatchGenUserSeqResp) GetSeqList() map[uint32]int64

func (*BatchGenUserSeqResp) ProtoMessage 

func (*BatchGenUserSeqResp) ProtoMessage()

func (*BatchGenUserSeqResp) ProtoReflect 

func (x *BatchGenUserSeqResp) ProtoReflect() protoreflect.Message

func (*BatchGenUserSeqResp) Reset 

func (x *BatchGenUserSeqResp) Reset()

func (*BatchGenUserSeqResp) String 

func (x *BatchGenUserSeqResp) String() string

type BatchGetUserSeqReq 

type BatchGetUserSeqReq struct {
	IdList []uint32 `protobuf:"varint,1,rep,packed,name=idList,proto3" json:"idList,omitempty"`
	Tag    string   `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchGetUserSeqReq) Descriptor deprecated 

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

Deprecated: Use BatchGetUserSeqReq.ProtoReflect.Descriptor instead.

func (*BatchGetUserSeqReq) GetIdList 

func (x *BatchGetUserSeqReq) GetIdList() []uint32

func (*BatchGetUserSeqReq) GetTag 

func (x *BatchGetUserSeqReq) GetTag() string

func (*BatchGetUserSeqReq) ProtoMessage 

func (*BatchGetUserSeqReq) ProtoMessage()

func (*BatchGetUserSeqReq) ProtoReflect 

func (x *BatchGetUserSeqReq) ProtoReflect() protoreflect.Message

func (*BatchGetUserSeqReq) Reset 

func (x *BatchGetUserSeqReq) Reset()

func (*BatchGetUserSeqReq) String 

func (x *BatchGetUserSeqReq) String() string

type BatchGetUserSeqResp 

type BatchGetUserSeqResp struct {
	SeqList map[uint32]int64 `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BatchGetUserSeqResp) Descriptor deprecated 

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

Deprecated: Use BatchGetUserSeqResp.ProtoReflect.Descriptor instead.

func (*BatchGetUserSeqResp) GetSeqList 

func (x *BatchGetUserSeqResp) GetSeqList() map[uint32]int64

func (*BatchGetUserSeqResp) ProtoMessage 

func (*BatchGetUserSeqResp) ProtoMessage()

func (*BatchGetUserSeqResp) ProtoReflect 

func (x *BatchGetUserSeqResp) ProtoReflect() protoreflect.Message

func (*BatchGetUserSeqResp) Reset 

func (x *BatchGetUserSeqResp) Reset()

func (*BatchGetUserSeqResp) String 

func (x *BatchGetUserSeqResp) String() string

type GenUserMultiSeqReq 

type GenUserMultiSeqReq struct {
	Id      uint32   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	TagList []string `protobuf:"bytes,2,rep,name=tagList,proto3" json:"tagList,omitempty"`
	Async   bool     `protobuf:"varint,3,opt,name=async,proto3" json:"async,omitempty"`
	// contains filtered or unexported fields
}

func (*GenUserMultiSeqReq) Descriptor deprecated 

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

Deprecated: Use GenUserMultiSeqReq.ProtoReflect.Descriptor instead.

func (*GenUserMultiSeqReq) GetAsync 

func (x *GenUserMultiSeqReq) GetAsync() bool

func (*GenUserMultiSeqReq) GetId 

func (x *GenUserMultiSeqReq) GetId() uint32

func (*GenUserMultiSeqReq) GetTagList 

func (x *GenUserMultiSeqReq) GetTagList() []string

func (*GenUserMultiSeqReq) ProtoMessage 

func (*GenUserMultiSeqReq) ProtoMessage()

func (*GenUserMultiSeqReq) ProtoReflect 

func (x *GenUserMultiSeqReq) ProtoReflect() protoreflect.Message

func (*GenUserMultiSeqReq) Reset 

func (x *GenUserMultiSeqReq) Reset()

func (*GenUserMultiSeqReq) String 

func (x *GenUserMultiSeqReq) String() string

type GenUserMultiSeqResp 

type GenUserMultiSeqResp struct {
	SeqList map[string]int64 `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GenUserMultiSeqResp) Descriptor deprecated 

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

Deprecated: Use GenUserMultiSeqResp.ProtoReflect.Descriptor instead.

func (*GenUserMultiSeqResp) GetSeqList 

func (x *GenUserMultiSeqResp) GetSeqList() map[string]int64

func (*GenUserMultiSeqResp) ProtoMessage 

func (*GenUserMultiSeqResp) ProtoMessage()

func (*GenUserMultiSeqResp) ProtoReflect 

func (x *GenUserMultiSeqResp) ProtoReflect() protoreflect.Message

func (*GenUserMultiSeqResp) Reset 

func (x *GenUserMultiSeqResp) Reset()

func (*GenUserMultiSeqResp) String 

func (x *GenUserMultiSeqResp) String() string

type GenUserSeqReq 

type GenUserSeqReq struct {
	Id  uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Tag string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*GenUserSeqReq) Descriptor deprecated 

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

Deprecated: Use GenUserSeqReq.ProtoReflect.Descriptor instead.

func (*GenUserSeqReq) GetId 

func (x *GenUserSeqReq) GetId() uint32

func (*GenUserSeqReq) GetTag 

func (x *GenUserSeqReq) GetTag() string

func (*GenUserSeqReq) ProtoMessage 

func (*GenUserSeqReq) ProtoMessage()

func (*GenUserSeqReq) ProtoReflect 

func (x *GenUserSeqReq) ProtoReflect() protoreflect.Message

func (*GenUserSeqReq) Reset 

func (x *GenUserSeqReq) Reset()

func (*GenUserSeqReq) String 

func (x *GenUserSeqReq) String() string

type GenUserSeqResp 

type GenUserSeqResp struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GenUserSeqResp) Descriptor deprecated 

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

Deprecated: Use GenUserSeqResp.ProtoReflect.Descriptor instead.

func (*GenUserSeqResp) GetId 

func (x *GenUserSeqResp) GetId() int64

func (*GenUserSeqResp) ProtoMessage 

func (*GenUserSeqResp) ProtoMessage()

func (*GenUserSeqResp) ProtoReflect 

func (x *GenUserSeqResp) ProtoReflect() protoreflect.Message

func (*GenUserSeqResp) Reset 

func (x *GenUserSeqResp) Reset()

func (*GenUserSeqResp) String 

func (x *GenUserSeqResp) String() string

type GetUserMultiSeqReq 

type GetUserMultiSeqReq struct {
	Id      uint32   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	TagList []string `protobuf:"bytes,2,rep,name=tagList,proto3" json:"tagList,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUserMultiSeqReq) Descriptor deprecated 

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

Deprecated: Use GetUserMultiSeqReq.ProtoReflect.Descriptor instead.

func (*GetUserMultiSeqReq) GetId 

func (x *GetUserMultiSeqReq) GetId() uint32

func (*GetUserMultiSeqReq) GetTagList 

func (x *GetUserMultiSeqReq) GetTagList() []string

func (*GetUserMultiSeqReq) ProtoMessage 

func (*GetUserMultiSeqReq) ProtoMessage()

func (*GetUserMultiSeqReq) ProtoReflect 

func (x *GetUserMultiSeqReq) ProtoReflect() protoreflect.Message

func (*GetUserMultiSeqReq) Reset 

func (x *GetUserMultiSeqReq) Reset()

func (*GetUserMultiSeqReq) String 

func (x *GetUserMultiSeqReq) String() string

type GetUserMultiSeqResp 

type GetUserMultiSeqResp struct {
	SeqList map[string]int64 `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetUserMultiSeqResp) Descriptor deprecated 

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

Deprecated: Use GetUserMultiSeqResp.ProtoReflect.Descriptor instead.

func (*GetUserMultiSeqResp) GetSeqList 

func (x *GetUserMultiSeqResp) GetSeqList() map[string]int64

func (*GetUserMultiSeqResp) ProtoMessage 

func (*GetUserMultiSeqResp) ProtoMessage()

func (*GetUserMultiSeqResp) ProtoReflect 

func (x *GetUserMultiSeqResp) ProtoReflect() protoreflect.Message

func (*GetUserMultiSeqResp) Reset 

func (x *GetUserMultiSeqResp) Reset()

func (*GetUserMultiSeqResp) String 

func (x *GetUserMultiSeqResp) String() string

type GetUserSeqReq 

type GetUserSeqReq struct {
	Id  uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Tag string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUserSeqReq) Descriptor deprecated 

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

Deprecated: Use GetUserSeqReq.ProtoReflect.Descriptor instead.

func (*GetUserSeqReq) GetId 

func (x *GetUserSeqReq) GetId() uint32

func (*GetUserSeqReq) GetTag 

func (x *GetUserSeqReq) GetTag() string

func (*GetUserSeqReq) ProtoMessage 

func (*GetUserSeqReq) ProtoMessage()

func (*GetUserSeqReq) ProtoReflect 

func (x *GetUserSeqReq) ProtoReflect() protoreflect.Message

func (*GetUserSeqReq) Reset 

func (x *GetUserSeqReq) Reset()

func (*GetUserSeqReq) String 

func (x *GetUserSeqReq) String() string

type GetUserSeqResp 

type GetUserSeqResp struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUserSeqResp) Descriptor deprecated 

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

Deprecated: Use GetUserSeqResp.ProtoReflect.Descriptor instead.

func (*GetUserSeqResp) GetId 

func (x *GetUserSeqResp) GetId() int64

func (*GetUserSeqResp) ProtoMessage 

func (*GetUserSeqResp) ProtoMessage()

func (*GetUserSeqResp) ProtoReflect 

func (x *GetUserSeqResp) ProtoReflect() protoreflect.Message

func (*GetUserSeqResp) Reset 

func (x *GetUserSeqResp) Reset()

func (*GetUserSeqResp) String 

func (x *GetUserSeqResp) String() string

type ProxyClient 

type ProxyClient interface {
	// 生成单个id指定tag的Seq
	GenUserSeq(ctx context.Context, in *GenUserSeqReq, opts ...grpc.CallOption) (*GenUserSeqResp, error)
	// 获取单个id指定tag的Seq
	// note: 小概率获取到比实际Seq大的Seq，也是下次调用Gen接口生成的Seq
	GetUserSeq(ctx context.Context, in *GetUserSeqReq, opts ...grpc.CallOption) (*GetUserSeqResp, error)
	// 生成单个id多个tag的Seq 部分失败时不返回错误
	GenUserMultiSeq(ctx context.Context, in *GenUserMultiSeqReq, opts ...grpc.CallOption) (*GenUserMultiSeqResp, error)
	// 获取单个id多个tag的Seq 部分失败时不返回错误
	// note: 小概率获取到比实际Seq大的Seq，也是下次调用Gen接口生成的Seq
	GetUserMultiSeq(ctx context.Context, in *GetUserMultiSeqReq, opts ...grpc.CallOption) (*GetUserMultiSeqResp, error)
	// 生成多个id指定tag的Seq 部分失败时不返回错误
	BatchGenUserSeq(ctx context.Context, in *BatchGenUserSeqReq, opts ...grpc.CallOption) (*BatchGenUserSeqResp, error)
	// 获取多个id指定tag的Seq 部分失败时不返回错误
	// note: 小概率获取到比实际Seq大的Seq，也是下次调用Gen接口生成的Seq
	BatchGetUserSeq(ctx context.Context, in *BatchGetUserSeqReq, opts ...grpc.CallOption) (*BatchGetUserSeqResp, error)
}

ProxyClient is the client API for Proxy service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewProxyClient 

func NewProxyClient(cc grpc.ClientConnInterface) ProxyClient

type ProxyServer 

type ProxyServer interface {
	// 生成单个id指定tag的Seq
	GenUserSeq(context.Context, *GenUserSeqReq) (*GenUserSeqResp, error)
	// 获取单个id指定tag的Seq
	// note: 小概率获取到比实际Seq大的Seq，也是下次调用Gen接口生成的Seq
	GetUserSeq(context.Context, *GetUserSeqReq) (*GetUserSeqResp, error)
	// 生成单个id多个tag的Seq 部分失败时不返回错误
	GenUserMultiSeq(context.Context, *GenUserMultiSeqReq) (*GenUserMultiSeqResp, error)
	// 获取单个id多个tag的Seq 部分失败时不返回错误
	// note: 小概率获取到比实际Seq大的Seq，也是下次调用Gen接口生成的Seq
	GetUserMultiSeq(context.Context, *GetUserMultiSeqReq) (*GetUserMultiSeqResp, error)
	// 生成多个id指定tag的Seq 部分失败时不返回错误
	BatchGenUserSeq(context.Context, *BatchGenUserSeqReq) (*BatchGenUserSeqResp, error)
	// 获取多个id指定tag的Seq 部分失败时不返回错误
	// note: 小概率获取到比实际Seq大的Seq，也是下次调用Gen接口生成的Seq
	BatchGetUserSeq(context.Context, *BatchGetUserSeqReq) (*BatchGetUserSeqResp, error)
	// contains filtered or unexported methods
}

ProxyServer is the server API for Proxy service. All implementations must embed UnimplementedProxyServer for forward compatibility

type ReBalanceReq 

type ReBalanceReq struct {
	// contains filtered or unexported fields
}

func (*ReBalanceReq) Descriptor deprecated 

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

Deprecated: Use ReBalanceReq.ProtoReflect.Descriptor instead.

func (*ReBalanceReq) ProtoMessage 

func (*ReBalanceReq) ProtoMessage()

func (*ReBalanceReq) ProtoReflect 

func (x *ReBalanceReq) ProtoReflect() protoreflect.Message

func (*ReBalanceReq) Reset 

func (x *ReBalanceReq) Reset()

func (*ReBalanceReq) String 

func (x *ReBalanceReq) String() string

type ReBalanceResp 

type ReBalanceResp struct {
	// contains filtered or unexported fields
}

func (*ReBalanceResp) Descriptor deprecated 

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

Deprecated: Use ReBalanceResp.ProtoReflect.Descriptor instead.

func (*ReBalanceResp) ProtoMessage 

func (*ReBalanceResp) ProtoMessage()

func (*ReBalanceResp) ProtoReflect 

func (x *ReBalanceResp) ProtoReflect() protoreflect.Message

func (*ReBalanceResp) Reset 

func (x *ReBalanceResp) Reset()

func (*ReBalanceResp) String 

func (x *ReBalanceResp) String() string

type RegSectionReq 

type RegSectionReq struct {
	Tag   string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"` // 默认支持 int32(0) - int32(math.MaxInt32) 范围
	Async bool   `protobuf:"varint,2,opt,name=async,proto3" json:"async,omitempty"`
	// contains filtered or unexported fields
}

func (*RegSectionReq) Descriptor deprecated 

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

Deprecated: Use RegSectionReq.ProtoReflect.Descriptor instead.

func (*RegSectionReq) GetAsync 

func (x *RegSectionReq) GetAsync() bool

func (*RegSectionReq) GetTag 

func (x *RegSectionReq) GetTag() string

func (*RegSectionReq) ProtoMessage 

func (*RegSectionReq) ProtoMessage()

func (*RegSectionReq) ProtoReflect 

func (x *RegSectionReq) ProtoReflect() protoreflect.Message

func (*RegSectionReq) Reset 

func (x *RegSectionReq) Reset()

func (*RegSectionReq) String 

func (x *RegSectionReq) String() string

type RegSectionResp 

type RegSectionResp struct {
	// contains filtered or unexported fields
}

func (*RegSectionResp) Descriptor deprecated 

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

Deprecated: Use RegSectionResp.ProtoReflect.Descriptor instead.

func (*RegSectionResp) ProtoMessage 

func (*RegSectionResp) ProtoMessage()

func (*RegSectionResp) ProtoReflect 

func (x *RegSectionResp) ProtoReflect() protoreflect.Message

func (*RegSectionResp) Reset 

func (x *RegSectionResp) Reset()

func (*RegSectionResp) String 

func (x *RegSectionResp) String() string

type UnRegSectionReq 

type UnRegSectionReq struct {
	Tag   string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"` // 默认支持 int32(0) - int32(math.MaxInt32) 范围
	Async bool   `protobuf:"varint,2,opt,name=async,proto3" json:"async,omitempty"`
	// contains filtered or unexported fields
}

func (*UnRegSectionReq) Descriptor deprecated 

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

Deprecated: Use UnRegSectionReq.ProtoReflect.Descriptor instead.

func (*UnRegSectionReq) GetAsync 

func (x *UnRegSectionReq) GetAsync() bool

func (*UnRegSectionReq) GetTag 

func (x *UnRegSectionReq) GetTag() string

func (*UnRegSectionReq) ProtoMessage 

func (*UnRegSectionReq) ProtoMessage()

func (*UnRegSectionReq) ProtoReflect 

func (x *UnRegSectionReq) ProtoReflect() protoreflect.Message

func (*UnRegSectionReq) Reset 

func (x *UnRegSectionReq) Reset()

func (*UnRegSectionReq) String 

func (x *UnRegSectionReq) String() string

type UnRegSectionResp 

type UnRegSectionResp struct {
	// contains filtered or unexported fields
}

func (*UnRegSectionResp) Descriptor deprecated 

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

Deprecated: Use UnRegSectionResp.ProtoReflect.Descriptor instead.

func (*UnRegSectionResp) ProtoMessage 

func (*UnRegSectionResp) ProtoMessage()

func (*UnRegSectionResp) ProtoReflect 

func (x *UnRegSectionResp) ProtoReflect() protoreflect.Message

func (*UnRegSectionResp) Reset 

func (x *UnRegSectionResp) Reset()

func (*UnRegSectionResp) String 

func (x *UnRegSectionResp) String() string

type UnimplementedAllocServer 

type UnimplementedAllocServer struct {
}

UnimplementedAllocServer must be embedded to have forward compatible implementations.

func (UnimplementedAllocServer) GenUserSeq 

func (UnimplementedAllocServer) GenUserSeq(context.Context, *GenUserSeqReq) (*GenUserSeqResp, error)

func (UnimplementedAllocServer) GetUserSeq 

func (UnimplementedAllocServer) GetUserSeq(context.Context, *GetUserSeqReq) (*GetUserSeqResp, error)

type UnimplementedAssignServer 

type UnimplementedAssignServer struct {
}

UnimplementedAssignServer must be embedded to have forward compatible implementations.

func (UnimplementedAssignServer) ReBalance 

func (UnimplementedAssignServer) ReBalance(context.Context, *ReBalanceReq) (*ReBalanceResp, error)

func (UnimplementedAssignServer) RegSection 

func (UnimplementedAssignServer) RegSection(context.Context, *RegSectionReq) (*RegSectionResp, error)

func (UnimplementedAssignServer) UnRegSection 

func (UnimplementedAssignServer) UnRegSection(context.Context, *UnRegSectionReq) (*UnRegSectionResp, error)

type UnimplementedProxyServer 

type UnimplementedProxyServer struct {
}

UnimplementedProxyServer must be embedded to have forward compatible implementations.

func (UnimplementedProxyServer) BatchGenUserSeq 

func (UnimplementedProxyServer) BatchGenUserSeq(context.Context, *BatchGenUserSeqReq) (*BatchGenUserSeqResp, error)

func (UnimplementedProxyServer) BatchGetUserSeq 

func (UnimplementedProxyServer) BatchGetUserSeq(context.Context, *BatchGetUserSeqReq) (*BatchGetUserSeqResp, error)

func (UnimplementedProxyServer) GenUserMultiSeq 

func (UnimplementedProxyServer) GenUserMultiSeq(context.Context, *GenUserMultiSeqReq) (*GenUserMultiSeqResp, error)

func (UnimplementedProxyServer) GenUserSeq 

func (UnimplementedProxyServer) GenUserSeq(context.Context, *GenUserSeqReq) (*GenUserSeqResp, error)

func (UnimplementedProxyServer) GetUserMultiSeq 

func (UnimplementedProxyServer) GetUserMultiSeq(context.Context, *GetUserMultiSeqReq) (*GetUserMultiSeqResp, error)

func (UnimplementedProxyServer) GetUserSeq 

func (UnimplementedProxyServer) GetUserSeq(context.Context, *GetUserSeqReq) (*GetUserSeqResp, error)

type UnsafeAllocServer 

type UnsafeAllocServer interface {
	// contains filtered or unexported methods
}

UnsafeAllocServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AllocServer will result in compilation errors.

type UnsafeAssignServer 

type UnsafeAssignServer interface {
	// contains filtered or unexported methods
}

UnsafeAssignServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AssignServer will result in compilation errors.

type UnsafeProxyServer 

type UnsafeProxyServer interface {
	// contains filtered or unexported methods
}

UnsafeProxyServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProxyServer will result in compilation errors.

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.