types

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2022 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	FriendAppend = 1
	FriendDelete = 2

	BlackAppend = 1
	BlackDelete = 2

	UserAppend = 1
	UserDelete = 2

	GroupAppend = 1
	GroupDelete = 2
	GroupEdit   = 3
)
View Source 
const (
	Private = 1
	Protect = 2
	Public  = 3

	Whitelist = 2

	QueryTimeOut = time.Second * 120
)
View Source 
const (
	LvlPublic  = "public"
	LvlProtect = "protect"
	LvlPrivate = "private"
)
View Source 
const (
	//ListDESC 表示记录降序排列
	ListDESC = int32(0)

	//ListASC 表示记录升序排列
	ListASC = int32(1)

	FuncNameGetFriends     = "GetFriends"
	FuncNameGetBlackList   = "GetBlackList"
	FuncNameGetUser        = "GetUser"
	FuncNameGetServerGroup = "GetServerGroup"
)
View Source 
const (
	TyUpdateFriendsAction = iota + 100
	TyUpdateBlackListAction
	TyUpdateUserAction
	TyUpdateServerGroupAction

	NameUpdateFriendsAction     = "Update"
	NameUpdateBlackListAction   = "Black"
	NameUpdateUserAction        = "UpdateUser"
	NameUpdateServerGroupAction = "UpdateServerGroup"
)

action类型id和name，这些常量可以自定义修改

View Source 
const (
	TyUnknownLog = iota + 100
	TyLogUpdateFriends
	TyLogUpdateBlackList
	TyLogUpdateUser
	TyLogUpdateServerGroup
)

log类型id值

View Source 
const (
	TableChatPreFix                    = "LODB-chat"
	TableFriendName                    = "friend"
	TableFriendPrimary                 = "mainAddr_friAddr"
	TableFriendIndexMainAddr           = "mainAddr"
	TableFriendIndexMainAddrFriendAddr = "mainAddr_friAddr"

	TableBlackName                    = "black"
	TableBlackPrimary                 = "mainAddr_tagAddr"
	TableBlackIndexMainAddr           = "mainAddr"
	TableBlackIndexMainAddrTargetAddr = "mainAddr_tagAddr"

	TableUserName                   = "user"
	TableUserPrimary                = "mainAddr_fieldName"
	TableUserIndexMainAddr          = "mainAddr"
	TableUserIndexMainAddrFieldName = "mainAddr_fieldName"

	TableServerGroupsName                  = "server"
	TableServerGroupsPrimary               = "mainAddr_serverId"
	TableServerGroupsIndexMainAddr         = "mainAddr"
	TableServerGroupsIndexMainAddrServerId = "mainAddr_serverId"
)
View Source 
const DefaultServerGroupId = "1"
View Source 
const DefaultServerGroupName = "default"
View Source 
const MaxGroupsLength = 20
View Source 
const MaxServerGroupsNumb = 20

Variables

View Source 
var (
	ErrTypeNotExist      = errors.New("类型不存在")
	ErrFieldType         = errors.New("字段类型不合法")
	ErrLevelTypeUnDefine = errors.New("安全级别未定义")
	ErrParams            = errors.New("请求参数错误")
	ErrSignErr           = errors.New("签名不正确")
	ErrLackPermissions   = errors.New("访问权限不足")
	ErrQueryTimeOut      = errors.New("查询请求过期")
	ErrGroupIdFailed     = errors.New("分组id生成失败")
	ErrGroupsArrayOut    = errors.New("分组数量超出限制")
)

Errors for lottery

View Source 
var (
	//ChatX 执行器名称定义
	ChatX = "chat"
)

Functions

func InitExecutor 

func InitExecutor(cfg *types.Chain33Config)

InitExecutor defines register executor

func InitFork 

func InitFork(cfg *types.Chain33Config)

InitFork defines register fork

func NewBlackTable 

func NewBlackTable(kvdb db.KV) *table.Table

黑名单 NewFriendTable 新建表

func NewFriendTable 

func NewFriendTable(kvdb db.KV) *table.Table

NewFriendTable 新建表

func NewServerGroupsTable 

func NewServerGroupsTable(kvdb db.KV) *table.Table

server groups NewServerGroupsTable 新建表

func NewType 

func NewType(cfg *types.Chain33Config) *chatType

func NewUserTable 

func NewUserTable(kvdb db.KV) *table.Table

NewUserTable 新建表

func RegisterChatServer 

func RegisterChatServer(s *grpc.Server, srv ChatServer)

func TableList 

func TableList(dbm db.KVDB, tableName, indexName string, data interface{}, count, direction int32) ([]*table.Row, error)

Types

type Black 

type Black struct {
	MainAddress          string   `protobuf:"bytes,1,opt,name=mainAddress,proto3" json:"mainAddress,omitempty"`
	TargetAddress        string   `protobuf:"bytes,2,opt,name=targetAddress,proto3" json:"targetAddress,omitempty"`
	CreateTime           int64    `protobuf:"varint,3,opt,name=createTime,proto3" json:"createTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Black) Descriptor 

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

func (*Black) GetCreateTime 

func (m *Black) GetCreateTime() int64

func (*Black) GetMainAddress 

func (m *Black) GetMainAddress() string

func (*Black) GetTargetAddress 

func (m *Black) GetTargetAddress() string

func (*Black) ProtoMessage 

func (*Black) ProtoMessage()

func (*Black) Reset 

func (m *Black) Reset()

func (*Black) String 

func (m *Black) String() string

func (*Black) XXX_DiscardUnknown 

func (m *Black) XXX_DiscardUnknown()

func (*Black) XXX_Marshal 

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

func (*Black) XXX_Merge 

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

func (*Black) XXX_Size 

func (m *Black) XXX_Size() int

func (*Black) XXX_Unmarshal 

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

type BlackRow 

type BlackRow struct {
	*Black
}

FriendRow table meta 结构

func NewBlackRow 

func NewBlackRow() *BlackRow

NewFriendRow 新建一个meta 结构

func (*BlackRow) CreateRow 

func (tx *BlackRow) CreateRow() *table.Row

CreateRow 新建数据行(注意index 数据一定也要保存到数据中,不能就保存eventid)

func (*BlackRow) Get 

func (tx *BlackRow) Get(key string) ([]byte, error)

Get 按照indexName 查询 indexValue

func (*BlackRow) SetPayload 

func (tx *BlackRow) SetPayload(data types.Message) error

SetPayload 设置数据

type ChatAction 

type ChatAction struct {
	// Types that are valid to be assigned to Value:
	//	*ChatAction_Update
	//	*ChatAction_Black
	//	*ChatAction_UpdateUser
	//	*ChatAction_UpdateServerGroup
	Value                isChatAction_Value `protobuf_oneof:"value"`
	Ty                   int32              `protobuf:"varint,10,opt,name=ty,proto3" json:"ty,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ChatAction) Descriptor 

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

func (*ChatAction) GetBlack 

func (m *ChatAction) GetBlack() *UpdateBlackList

func (*ChatAction) GetTy 

func (m *ChatAction) GetTy() int32

func (*ChatAction) GetUpdate 

func (m *ChatAction) GetUpdate() *UpdateFriends

func (*ChatAction) GetUpdateServerGroup 

func (m *ChatAction) GetUpdateServerGroup() *UpdateServerGroups

func (*ChatAction) GetUpdateUser 

func (m *ChatAction) GetUpdateUser() *UpdateFields

func (*ChatAction) GetValue 

func (m *ChatAction) GetValue() isChatAction_Value

func (*ChatAction) ProtoMessage 

func (*ChatAction) ProtoMessage()

func (*ChatAction) Reset 

func (m *ChatAction) Reset()

func (*ChatAction) String 

func (m *ChatAction) String() string

func (*ChatAction) XXX_DiscardUnknown 

func (m *ChatAction) XXX_DiscardUnknown()

func (*ChatAction) XXX_Marshal 

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

func (*ChatAction) XXX_Merge 

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

func (*ChatAction) XXX_OneofWrappers 

func (*ChatAction) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ChatAction) XXX_Size 

func (m *ChatAction) XXX_Size() int

func (*ChatAction) XXX_Unmarshal 

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

type ChatAction_Black 

type ChatAction_Black struct {
	Black *UpdateBlackList `protobuf:"bytes,2,opt,name=black,proto3,oneof"`
}

type ChatAction_Update 

type ChatAction_Update struct {
	Update *UpdateFriends `protobuf:"bytes,1,opt,name=update,proto3,oneof"`
}

type ChatAction_UpdateServerGroup 

type ChatAction_UpdateServerGroup struct {
	UpdateServerGroup *UpdateServerGroups `protobuf:"bytes,4,opt,name=updateServerGroup,proto3,oneof"`
}

type ChatAction_UpdateUser 

type ChatAction_UpdateUser struct {
	UpdateUser *UpdateFields `protobuf:"bytes,3,opt,name=updateUser,proto3,oneof"`
}

type ChatClient 

type ChatClient interface {
	Update(ctx context.Context, in *UpdateFriends, opts ...grpc.CallOption) (*types.UnsignTx, error)
	Black(ctx context.Context, in *UpdateBlackList, opts ...grpc.CallOption) (*types.UnsignTx, error)
	UpdateUser(ctx context.Context, in *UpdateFields, opts ...grpc.CallOption) (*types.UnsignTx, error)
	UpdateServerGroup(ctx context.Context, in *UpdateServerGroups, opts ...grpc.CallOption) (*types.UnsignTx, error)
	GetFriends(ctx context.Context, in *ReqGetFriends, opts ...grpc.CallOption) (*ReplyGetFriends, error)
	GetBlackList(ctx context.Context, in *ReqGetBlackList, opts ...grpc.CallOption) (*ReplyGetBlackList, error)
	GetUser(ctx context.Context, in *ReqGetUser, opts ...grpc.CallOption) (*ReplyGetUser, error)
	GetServerGroup(ctx context.Context, in *ReqGetServerGroup, opts ...grpc.CallOption) (*ReplyGetServerGroups, error)
}

ChatClient is the client API for Chat service.

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

func NewChatClient 

func NewChatClient(cc *grpc.ClientConn) ChatClient

type ChatServer 

type ChatServer interface {
	Update(context.Context, *UpdateFriends) (*types.UnsignTx, error)
	Black(context.Context, *UpdateBlackList) (*types.UnsignTx, error)
	UpdateUser(context.Context, *UpdateFields) (*types.UnsignTx, error)
	UpdateServerGroup(context.Context, *UpdateServerGroups) (*types.UnsignTx, error)
	GetFriends(context.Context, *ReqGetFriends) (*ReplyGetFriends, error)
	GetBlackList(context.Context, *ReqGetBlackList) (*ReplyGetBlackList, error)
	GetUser(context.Context, *ReqGetUser) (*ReplyGetUser, error)
	GetServerGroup(context.Context, *ReqGetServerGroup) (*ReplyGetServerGroups, error)
}

ChatServer is the server API for Chat service.

type Field 

type Field struct {
	MainAddress          string   `protobuf:"bytes,1,opt,name=mainAddress,proto3" json:"mainAddress,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Level                string   `protobuf:"bytes,4,opt,name=level,proto3" json:"level,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

------------------------user info----------------//

func (*Field) Descriptor 

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

func (*Field) GetLevel 

func (m *Field) GetLevel() string

func (*Field) GetMainAddress 

func (m *Field) GetMainAddress() string

func (*Field) GetName 

func (m *Field) GetName() string

func (*Field) GetValue 

func (m *Field) GetValue() string

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) Reset 

func (m *Field) Reset()

func (*Field) String 

func (m *Field) String() string

func (*Field) XXX_DiscardUnknown 

func (m *Field) XXX_DiscardUnknown()

func (*Field) XXX_Marshal 

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

func (*Field) XXX_Merge 

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

func (*Field) XXX_Size 

func (m *Field) XXX_Size() int

func (*Field) XXX_Unmarshal 

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

type Friend 

type Friend struct {
	MainAddress          string   `protobuf:"bytes,1,opt,name=mainAddress,proto3" json:"mainAddress,omitempty"`
	FriendAddress        string   `protobuf:"bytes,2,opt,name=friendAddress,proto3" json:"friendAddress,omitempty"`
	CreateTime           int64    `protobuf:"varint,3,opt,name=createTime,proto3" json:"createTime,omitempty"`
	Groups               []string `protobuf:"bytes,4,rep,name=groups,proto3" json:"groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Friend) Descriptor 

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

func (*Friend) GetCreateTime 

func (m *Friend) GetCreateTime() int64

func (*Friend) GetFriendAddress 

func (m *Friend) GetFriendAddress() string

func (*Friend) GetGroups 

func (m *Friend) GetGroups() []string

func (*Friend) GetMainAddress 

func (m *Friend) GetMainAddress() string

func (*Friend) ProtoMessage 

func (*Friend) ProtoMessage()

func (*Friend) Reset 

func (m *Friend) Reset()

func (*Friend) String 

func (m *Friend) String() string

func (*Friend) XXX_DiscardUnknown 

func (m *Friend) XXX_DiscardUnknown()

func (*Friend) XXX_Marshal 

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

func (*Friend) XXX_Merge 

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

func (*Friend) XXX_Size 

func (m *Friend) XXX_Size() int

func (*Friend) XXX_Unmarshal 

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

type FriendRow 

type FriendRow struct {
	*Friend
}

FriendRow table meta 结构

func NewFriendRow 

func NewFriendRow() *FriendRow

NewFriendRow 新建一个meta 结构

func (*FriendRow) CreateRow 

func (tx *FriendRow) CreateRow() *table.Row

CreateRow 新建数据行(注意index 数据一定也要保存到数据中,不能就保存eventid)

func (*FriendRow) Get 

func (tx *FriendRow) Get(key string) ([]byte, error)

Get 按照indexName 查询 indexValue

func (*FriendRow) SetPayload 

func (tx *FriendRow) SetPayload(data types.Message) error

SetPayload 设置数据

type ReplyGetBlackList 

type ReplyGetBlackList struct {
	List                 []*Black `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplyGetBlackList) Descriptor 

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

func (*ReplyGetBlackList) GetList 

func (m *ReplyGetBlackList) GetList() []*Black

func (*ReplyGetBlackList) ProtoMessage 

func (*ReplyGetBlackList) ProtoMessage()

func (*ReplyGetBlackList) Reset 

func (m *ReplyGetBlackList) Reset()

func (*ReplyGetBlackList) String 

func (m *ReplyGetBlackList) String() string

func (*ReplyGetBlackList) XXX_DiscardUnknown 

func (m *ReplyGetBlackList) XXX_DiscardUnknown()

func (*ReplyGetBlackList) XXX_Marshal 

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

func (*ReplyGetBlackList) XXX_Merge 

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

func (*ReplyGetBlackList) XXX_Size 

func (m *ReplyGetBlackList) XXX_Size() int

func (*ReplyGetBlackList) XXX_Unmarshal 

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

type ReplyGetField 

type ReplyGetField struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Level                string   `protobuf:"bytes,3,opt,name=level,proto3" json:"level,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplyGetField) Descriptor 

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

func (*ReplyGetField) GetLevel 

func (m *ReplyGetField) GetLevel() string

func (*ReplyGetField) GetName 

func (m *ReplyGetField) GetName() string

func (*ReplyGetField) GetValue 

func (m *ReplyGetField) GetValue() string

func (*ReplyGetField) ProtoMessage 

func (*ReplyGetField) ProtoMessage()

func (*ReplyGetField) Reset 

func (m *ReplyGetField) Reset()

func (*ReplyGetField) String 

func (m *ReplyGetField) String() string

func (*ReplyGetField) XXX_DiscardUnknown 

func (m *ReplyGetField) XXX_DiscardUnknown()

func (*ReplyGetField) XXX_Marshal 

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

func (*ReplyGetField) XXX_Merge 

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

func (*ReplyGetField) XXX_Size 

func (m *ReplyGetField) XXX_Size() int

func (*ReplyGetField) XXX_Unmarshal 

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

type ReplyGetFriends 

type ReplyGetFriends struct {
	Friends              []*Friend `protobuf:"bytes,1,rep,name=friends,proto3" json:"friends,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ReplyGetFriends) Descriptor 

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

func (*ReplyGetFriends) GetFriends 

func (m *ReplyGetFriends) GetFriends() []*Friend

func (*ReplyGetFriends) ProtoMessage 

func (*ReplyGetFriends) ProtoMessage()

func (*ReplyGetFriends) Reset 

func (m *ReplyGetFriends) Reset()

func (*ReplyGetFriends) String 

func (m *ReplyGetFriends) String() string

func (*ReplyGetFriends) XXX_DiscardUnknown 

func (m *ReplyGetFriends) XXX_DiscardUnknown()

func (*ReplyGetFriends) XXX_Marshal 

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

func (*ReplyGetFriends) XXX_Merge 

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

func (*ReplyGetFriends) XXX_Size 

func (m *ReplyGetFriends) XXX_Size() int

func (*ReplyGetFriends) XXX_Unmarshal 

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

type ReplyGetServerGroup 

type ReplyGetServerGroup struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

server groups reply

func (*ReplyGetServerGroup) Descriptor 

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

func (*ReplyGetServerGroup) GetId 

func (m *ReplyGetServerGroup) GetId() string

func (*ReplyGetServerGroup) GetName 

func (m *ReplyGetServerGroup) GetName() string

func (*ReplyGetServerGroup) GetValue 

func (m *ReplyGetServerGroup) GetValue() string

func (*ReplyGetServerGroup) ProtoMessage 

func (*ReplyGetServerGroup) ProtoMessage()

func (*ReplyGetServerGroup) Reset 

func (m *ReplyGetServerGroup) Reset()

func (*ReplyGetServerGroup) String 

func (m *ReplyGetServerGroup) String() string

func (*ReplyGetServerGroup) XXX_DiscardUnknown 

func (m *ReplyGetServerGroup) XXX_DiscardUnknown()

func (*ReplyGetServerGroup) XXX_Marshal 

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

func (*ReplyGetServerGroup) XXX_Merge 

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

func (*ReplyGetServerGroup) XXX_Size 

func (m *ReplyGetServerGroup) XXX_Size() int

func (*ReplyGetServerGroup) XXX_Unmarshal 

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

type ReplyGetServerGroups 

type ReplyGetServerGroups struct {
	Groups               []*ReplyGetServerGroup `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ReplyGetServerGroups) Descriptor 

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

func (*ReplyGetServerGroups) GetGroups 

func (m *ReplyGetServerGroups) GetGroups() []*ReplyGetServerGroup

func (*ReplyGetServerGroups) ProtoMessage 

func (*ReplyGetServerGroups) ProtoMessage()

func (*ReplyGetServerGroups) Reset 

func (m *ReplyGetServerGroups) Reset()

func (*ReplyGetServerGroups) String 

func (m *ReplyGetServerGroups) String() string

func (*ReplyGetServerGroups) XXX_DiscardUnknown 

func (m *ReplyGetServerGroups) XXX_DiscardUnknown()

func (*ReplyGetServerGroups) XXX_Marshal 

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

func (*ReplyGetServerGroups) XXX_Merge 

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

func (*ReplyGetServerGroups) XXX_Size 

func (m *ReplyGetServerGroups) XXX_Size() int

func (*ReplyGetServerGroups) XXX_Unmarshal 

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

type ReplyGetUser 

type ReplyGetUser struct {
	ChatServers          []*ReplyServerInfo `protobuf:"bytes,1,rep,name=chatServers,proto3" json:"chatServers,omitempty"`
	Fields               []*ReplyGetField   `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	Groups               []string           `protobuf:"bytes,3,rep,name=groups,proto3" json:"groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ReplyGetUser) Descriptor 

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

func (*ReplyGetUser) GetChatServers 

func (m *ReplyGetUser) GetChatServers() []*ReplyServerInfo

func (*ReplyGetUser) GetFields 

func (m *ReplyGetUser) GetFields() []*ReplyGetField

func (*ReplyGetUser) GetGroups 

func (m *ReplyGetUser) GetGroups() []string

func (*ReplyGetUser) ProtoMessage 

func (*ReplyGetUser) ProtoMessage()

func (*ReplyGetUser) Reset 

func (m *ReplyGetUser) Reset()

func (*ReplyGetUser) String 

func (m *ReplyGetUser) String() string

func (*ReplyGetUser) XXX_DiscardUnknown 

func (m *ReplyGetUser) XXX_DiscardUnknown()

func (*ReplyGetUser) XXX_Marshal 

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

func (*ReplyGetUser) XXX_Merge 

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

func (*ReplyGetUser) XXX_Size 

func (m *ReplyGetUser) XXX_Size() int

func (*ReplyGetUser) XXX_Unmarshal 

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

type ReplyServerInfo 

type ReplyServerInfo struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Address              string   `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplyServerInfo) Descriptor 

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

func (*ReplyServerInfo) GetAddress 

func (m *ReplyServerInfo) GetAddress() string

func (*ReplyServerInfo) GetId 

func (m *ReplyServerInfo) GetId() string

func (*ReplyServerInfo) GetName 

func (m *ReplyServerInfo) GetName() string

func (*ReplyServerInfo) ProtoMessage 

func (*ReplyServerInfo) ProtoMessage()

func (*ReplyServerInfo) Reset 

func (m *ReplyServerInfo) Reset()

func (*ReplyServerInfo) String 

func (m *ReplyServerInfo) String() string

func (*ReplyServerInfo) XXX_DiscardUnknown 

func (m *ReplyServerInfo) XXX_DiscardUnknown()

func (*ReplyServerInfo) XXX_Marshal 

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

func (*ReplyServerInfo) XXX_Merge 

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

func (*ReplyServerInfo) XXX_Size 

func (m *ReplyServerInfo) XXX_Size() int

func (*ReplyServerInfo) XXX_Unmarshal 

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

type ReqGetBlackList 

type ReqGetBlackList struct {
	MainAddress          string   `protobuf:"bytes,1,opt,name=mainAddress,proto3" json:"mainAddress,omitempty"`
	Count                int32    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Index                string   `protobuf:"bytes,3,opt,name=index,proto3" json:"index,omitempty"`
	Time                 int64    `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"`
	Sign                 *Sign    `protobuf:"bytes,5,opt,name=sign,proto3" json:"sign,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

查询黑名单列表

func (*ReqGetBlackList) Descriptor 

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

func (*ReqGetBlackList) GetCount 

func (m *ReqGetBlackList) GetCount() int32

func (*ReqGetBlackList) GetIndex 

func (m *ReqGetBlackList) GetIndex() string

func (*ReqGetBlackList) GetMainAddress 

func (m *ReqGetBlackList) GetMainAddress() string

func (*ReqGetBlackList) GetSign 

func (m *ReqGetBlackList) GetSign() *Sign

func (*ReqGetBlackList) GetTime 

func (m *ReqGetBlackList) GetTime() int64

func (*ReqGetBlackList) ProtoMessage 

func (*ReqGetBlackList) ProtoMessage()

func (*ReqGetBlackList) Reset 

func (m *ReqGetBlackList) Reset()

func (*ReqGetBlackList) String 

func (m *ReqGetBlackList) String() string

func (*ReqGetBlackList) XXX_DiscardUnknown 

func (m *ReqGetBlackList) XXX_DiscardUnknown()

func (*ReqGetBlackList) XXX_Marshal 

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

func (*ReqGetBlackList) XXX_Merge 

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

func (*ReqGetBlackList) XXX_Size 

func (m *ReqGetBlackList) XXX_Size() int

func (*ReqGetBlackList) XXX_Unmarshal 

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

type ReqGetFriends 

type ReqGetFriends struct {
	MainAddress          string   `protobuf:"bytes,1,opt,name=mainAddress,proto3" json:"mainAddress,omitempty"`
	Count                int32    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Index                string   `protobuf:"bytes,3,opt,name=index,proto3" json:"index,omitempty"`
	Time                 int64    `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"`
	Sign                 *Sign    `protobuf:"bytes,5,opt,name=sign,proto3" json:"sign,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

查询好友列表

func (*ReqGetFriends) Descriptor 

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

func (*ReqGetFriends) GetCount 

func (m *ReqGetFriends) GetCount() int32

func (*ReqGetFriends) GetIndex 

func (m *ReqGetFriends) GetIndex() string

func (*ReqGetFriends) GetMainAddress 

func (m *ReqGetFriends) GetMainAddress() string

func (*ReqGetFriends) GetSign 

func (m *ReqGetFriends) GetSign() *Sign

func (*ReqGetFriends) GetTime 

func (m *ReqGetFriends) GetTime() int64

func (*ReqGetFriends) ProtoMessage 

func (*ReqGetFriends) ProtoMessage()

func (*ReqGetFriends) Reset 

func (m *ReqGetFriends) Reset()

func (*ReqGetFriends) String 

func (m *ReqGetFriends) String() string

func (*ReqGetFriends) XXX_DiscardUnknown 

func (m *ReqGetFriends) XXX_DiscardUnknown()

func (*ReqGetFriends) XXX_Marshal 

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

func (*ReqGetFriends) XXX_Merge 

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

func (*ReqGetFriends) XXX_Size 

func (m *ReqGetFriends) XXX_Size() int

func (*ReqGetFriends) XXX_Unmarshal 

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

type ReqGetServerGroup 

type ReqGetServerGroup struct {
	MainAddress          string   `protobuf:"bytes,1,opt,name=mainAddress,proto3" json:"mainAddress,omitempty"`
	Count                int32    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Index                string   `protobuf:"bytes,3,opt,name=index,proto3" json:"index,omitempty"`
	Time                 int64    `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"`
	Sign                 *Sign    `protobuf:"bytes,5,opt,name=sign,proto3" json:"sign,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

server groups request 查询分组信息

func (*ReqGetServerGroup) Descriptor 

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

func (*ReqGetServerGroup) GetCount 

func (m *ReqGetServerGroup) GetCount() int32

func (*ReqGetServerGroup) GetIndex 

func (m *ReqGetServerGroup) GetIndex() string

func (*ReqGetServerGroup) GetMainAddress 

func (m *ReqGetServerGroup) GetMainAddress() string

func (*ReqGetServerGroup) GetSign 

func (m *ReqGetServerGroup) GetSign() *Sign

func (*ReqGetServerGroup) GetTime 

func (m *ReqGetServerGroup) GetTime() int64

func (*ReqGetServerGroup) ProtoMessage 

func (*ReqGetServerGroup) ProtoMessage()

func (*ReqGetServerGroup) Reset 

func (m *ReqGetServerGroup) Reset()

func (*ReqGetServerGroup) String 

func (m *ReqGetServerGroup) String() string

func (*ReqGetServerGroup) XXX_DiscardUnknown 

func (m *ReqGetServerGroup) XXX_DiscardUnknown()

func (*ReqGetServerGroup) XXX_Marshal 

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

func (*ReqGetServerGroup) XXX_Merge 

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

func (*ReqGetServerGroup) XXX_Size 

func (m *ReqGetServerGroup) XXX_Size() int

func (*ReqGetServerGroup) XXX_Unmarshal 

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

type ReqGetUser 

type ReqGetUser struct {
	MainAddress          string   `protobuf:"bytes,1,opt,name=mainAddress,proto3" json:"mainAddress,omitempty"`
	TargetAddress        string   `protobuf:"bytes,2,opt,name=targetAddress,proto3" json:"targetAddress,omitempty"`
	Count                int32    `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	Index                string   `protobuf:"bytes,4,opt,name=index,proto3" json:"index,omitempty"`
	Time                 int64    `protobuf:"varint,5,opt,name=time,proto3" json:"time,omitempty"`
	Sign                 *Sign    `protobuf:"bytes,6,opt,name=sign,proto3" json:"sign,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

查询用户信息

func (*ReqGetUser) Descriptor 

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

func (*ReqGetUser) GetCount 

func (m *ReqGetUser) GetCount() int32

func (*ReqGetUser) GetIndex 

func (m *ReqGetUser) GetIndex() string

func (*ReqGetUser) GetMainAddress 

func (m *ReqGetUser) GetMainAddress() string

func (*ReqGetUser) GetSign 

func (m *ReqGetUser) GetSign() *Sign

func (*ReqGetUser) GetTargetAddress 

func (m *ReqGetUser) GetTargetAddress() string

func (*ReqGetUser) GetTime 

func (m *ReqGetUser) GetTime() int64

func (*ReqGetUser) ProtoMessage 

func (*ReqGetUser) ProtoMessage()

func (*ReqGetUser) Reset 

func (m *ReqGetUser) Reset()

func (*ReqGetUser) String 

func (m *ReqGetUser) String() string

func (*ReqGetUser) XXX_DiscardUnknown 

func (m *ReqGetUser) XXX_DiscardUnknown()

func (*ReqGetUser) XXX_Marshal 

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

func (*ReqGetUser) XXX_Merge 

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

func (*ReqGetUser) XXX_Size 

func (m *ReqGetUser) XXX_Size() int

func (*ReqGetUser) XXX_Unmarshal 

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

type ReqUpdateBlackList 

type ReqUpdateBlackList struct {
	TargetAddress        string   `protobuf:"bytes,1,opt,name=targetAddress,proto3" json:"targetAddress,omitempty"`
	Type                 int32    `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

更新黑名单请求

func (*ReqUpdateBlackList) Descriptor 

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

func (*ReqUpdateBlackList) GetTargetAddress 

func (m *ReqUpdateBlackList) GetTargetAddress() string

func (*ReqUpdateBlackList) GetType 

func (m *ReqUpdateBlackList) GetType() int32

func (*ReqUpdateBlackList) ProtoMessage 

func (*ReqUpdateBlackList) ProtoMessage()

func (*ReqUpdateBlackList) Reset 

func (m *ReqUpdateBlackList) Reset()

func (*ReqUpdateBlackList) String 

func (m *ReqUpdateBlackList) String() string

func (*ReqUpdateBlackList) XXX_DiscardUnknown 

func (m *ReqUpdateBlackList) XXX_DiscardUnknown()

func (*ReqUpdateBlackList) XXX_Marshal 

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

func (*ReqUpdateBlackList) XXX_Merge 

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

func (*ReqUpdateBlackList) XXX_Size 

func (m *ReqUpdateBlackList) XXX_Size() int

func (*ReqUpdateBlackList) XXX_Unmarshal 

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

type ReqUpdateField 

type ReqUpdateField struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Type                 int32    `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"`
	Level                string   `protobuf:"bytes,4,opt,name=level,proto3" json:"level,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

更新好友列表

func (*ReqUpdateField) Descriptor 

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

func (*ReqUpdateField) GetLevel 

func (m *ReqUpdateField) GetLevel() string

func (*ReqUpdateField) GetName 

func (m *ReqUpdateField) GetName() string

func (*ReqUpdateField) GetType 

func (m *ReqUpdateField) GetType() int32

func (*ReqUpdateField) GetValue 

func (m *ReqUpdateField) GetValue() string

func (*ReqUpdateField) ProtoMessage 

func (*ReqUpdateField) ProtoMessage()

func (*ReqUpdateField) Reset 

func (m *ReqUpdateField) Reset()

func (*ReqUpdateField) String 

func (m *ReqUpdateField) String() string

func (*ReqUpdateField) XXX_DiscardUnknown 

func (m *ReqUpdateField) XXX_DiscardUnknown()

func (*ReqUpdateField) XXX_Marshal 

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

func (*ReqUpdateField) XXX_Merge 

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

func (*ReqUpdateField) XXX_Size 

func (m *ReqUpdateField) XXX_Size() int

func (*ReqUpdateField) XXX_Unmarshal 

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

type ReqUpdateFriend 

type ReqUpdateFriend struct {
	FriendAddress        string   `protobuf:"bytes,1,opt,name=friendAddress,proto3" json:"friendAddress,omitempty"`
	Type                 int32    `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	Groups               []string `protobuf:"bytes,3,rep,name=groups,proto3" json:"groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

更新好友列表

func (*ReqUpdateFriend) Descriptor 

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

func (*ReqUpdateFriend) GetFriendAddress 

func (m *ReqUpdateFriend) GetFriendAddress() string

func (*ReqUpdateFriend) GetGroups 

func (m *ReqUpdateFriend) GetGroups() []string

func (*ReqUpdateFriend) GetType 

func (m *ReqUpdateFriend) GetType() int32

func (*ReqUpdateFriend) ProtoMessage 

func (*ReqUpdateFriend) ProtoMessage()

func (*ReqUpdateFriend) Reset 

func (m *ReqUpdateFriend) Reset()

func (*ReqUpdateFriend) String 

func (m *ReqUpdateFriend) String() string

func (*ReqUpdateFriend) XXX_DiscardUnknown 

func (m *ReqUpdateFriend) XXX_DiscardUnknown()

func (*ReqUpdateFriend) XXX_Marshal 

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

func (*ReqUpdateFriend) XXX_Merge 

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

func (*ReqUpdateFriend) XXX_Size 

func (m *ReqUpdateFriend) XXX_Size() int

func (*ReqUpdateFriend) XXX_Unmarshal 

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

type ReqUpdateServerGroup 

type ReqUpdateServerGroup struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Type                 int32    `protobuf:"varint,4,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqUpdateServerGroup) Descriptor 

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

func (*ReqUpdateServerGroup) GetId 

func (m *ReqUpdateServerGroup) GetId() string

func (*ReqUpdateServerGroup) GetName 

func (m *ReqUpdateServerGroup) GetName() string

func (*ReqUpdateServerGroup) GetType 

func (m *ReqUpdateServerGroup) GetType() int32

func (*ReqUpdateServerGroup) GetValue 

func (m *ReqUpdateServerGroup) GetValue() string

func (*ReqUpdateServerGroup) ProtoMessage 

func (*ReqUpdateServerGroup) ProtoMessage()

func (*ReqUpdateServerGroup) Reset 

func (m *ReqUpdateServerGroup) Reset()

func (*ReqUpdateServerGroup) String 

func (m *ReqUpdateServerGroup) String() string

func (*ReqUpdateServerGroup) XXX_DiscardUnknown 

func (m *ReqUpdateServerGroup) XXX_DiscardUnknown()

func (*ReqUpdateServerGroup) XXX_Marshal 

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

func (*ReqUpdateServerGroup) XXX_Merge 

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

func (*ReqUpdateServerGroup) XXX_Size 

func (m *ReqUpdateServerGroup) XXX_Size() int

func (*ReqUpdateServerGroup) XXX_Unmarshal 

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

type ServerGroup 

type ServerGroup struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	MainAddress          string   `protobuf:"bytes,4,opt,name=mainAddress,proto3" json:"mainAddress,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

--------------------------server groups-------------------------//

func (*ServerGroup) Descriptor 

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

func (*ServerGroup) GetId 

func (m *ServerGroup) GetId() string

func (*ServerGroup) GetMainAddress 

func (m *ServerGroup) GetMainAddress() string

func (*ServerGroup) GetName 

func (m *ServerGroup) GetName() string

func (*ServerGroup) GetValue 

func (m *ServerGroup) GetValue() string

func (*ServerGroup) ProtoMessage 

func (*ServerGroup) ProtoMessage()

func (*ServerGroup) Reset 

func (m *ServerGroup) Reset()

func (*ServerGroup) String 

func (m *ServerGroup) String() string

func (*ServerGroup) XXX_DiscardUnknown 

func (m *ServerGroup) XXX_DiscardUnknown()

func (*ServerGroup) XXX_Marshal 

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

func (*ServerGroup) XXX_Merge 

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

func (*ServerGroup) XXX_Size 

func (m *ServerGroup) XXX_Size() int

func (*ServerGroup) XXX_Unmarshal 

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

type ServerGroupsRow 

type ServerGroupsRow struct {
	*ServerGroup
}

FriendRow table meta 结构

func NewServerGroupsRow 

func NewServerGroupsRow() *ServerGroupsRow

NewFriendRow 新建一个meta 结构

func (*ServerGroupsRow) CreateRow 

func (tx *ServerGroupsRow) CreateRow() *table.Row

CreateRow 新建数据行(注意index 数据一定也要保存到数据中,不能就保存eventid)

func (*ServerGroupsRow) Get 

func (tx *ServerGroupsRow) Get(key string) ([]byte, error)

Get 按照indexName 查询 indexValue

func (*ServerGroupsRow) SetPayload 

func (tx *ServerGroupsRow) SetPayload(data types.Message) error

SetPayload 设置数据

type Sign 

type Sign struct {
	PublicKey            string   `protobuf:"bytes,1,opt,name=publicKey,proto3" json:"publicKey,omitempty"`
	Signature            string   `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Sign 签名

func (*Sign) Descriptor 

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

func (*Sign) GetPublicKey 

func (m *Sign) GetPublicKey() string

func (*Sign) GetSignature 

func (m *Sign) GetSignature() string

func (*Sign) ProtoMessage 

func (*Sign) ProtoMessage()

func (*Sign) Reset 

func (m *Sign) Reset()

func (*Sign) String 

func (m *Sign) String() string

func (*Sign) XXX_DiscardUnknown 

func (m *Sign) XXX_DiscardUnknown()

func (*Sign) XXX_Marshal 

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

func (*Sign) XXX_Merge 

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

func (*Sign) XXX_Size 

func (m *Sign) XXX_Size() int

func (*Sign) XXX_Unmarshal 

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

type UnimplementedChatServer 

type UnimplementedChatServer struct {
}

UnimplementedChatServer can be embedded to have forward compatible implementations.

func (*UnimplementedChatServer) Black 

func (*UnimplementedChatServer) Black(ctx context.Context, req *UpdateBlackList) (*types.UnsignTx, error)

func (*UnimplementedChatServer) GetBlackList 

func (*UnimplementedChatServer) GetBlackList(ctx context.Context, req *ReqGetBlackList) (*ReplyGetBlackList, error)

func (*UnimplementedChatServer) GetFriends 

func (*UnimplementedChatServer) GetFriends(ctx context.Context, req *ReqGetFriends) (*ReplyGetFriends, error)

func (*UnimplementedChatServer) GetServerGroup 

func (*UnimplementedChatServer) GetServerGroup(ctx context.Context, req *ReqGetServerGroup) (*ReplyGetServerGroups, error)

func (*UnimplementedChatServer) GetUser 

func (*UnimplementedChatServer) GetUser(ctx context.Context, req *ReqGetUser) (*ReplyGetUser, error)

func (*UnimplementedChatServer) Update 

func (*UnimplementedChatServer) Update(ctx context.Context, req *UpdateFriends) (*types.UnsignTx, error)

func (*UnimplementedChatServer) UpdateServerGroup 

func (*UnimplementedChatServer) UpdateServerGroup(ctx context.Context, req *UpdateServerGroups) (*types.UnsignTx, error)

func (*UnimplementedChatServer) UpdateUser 

func (*UnimplementedChatServer) UpdateUser(ctx context.Context, req *UpdateFields) (*types.UnsignTx, error)

type UpdateBlackList 

type UpdateBlackList struct {
	List                 []*ReqUpdateBlackList `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*UpdateBlackList) Descriptor 

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

func (*UpdateBlackList) GetList 

func (m *UpdateBlackList) GetList() []*ReqUpdateBlackList

func (*UpdateBlackList) ProtoMessage 

func (*UpdateBlackList) ProtoMessage()

func (*UpdateBlackList) Reset 

func (m *UpdateBlackList) Reset()

func (*UpdateBlackList) String 

func (m *UpdateBlackList) String() string

func (*UpdateBlackList) XXX_DiscardUnknown 

func (m *UpdateBlackList) XXX_DiscardUnknown()

func (*UpdateBlackList) XXX_Marshal 

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

func (*UpdateBlackList) XXX_Merge 

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

func (*UpdateBlackList) XXX_Size 

func (m *UpdateBlackList) XXX_Size() int

func (*UpdateBlackList) XXX_Unmarshal 

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

type UpdateFields 

type UpdateFields struct {
	Fields               []*ReqUpdateField `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*UpdateFields) Descriptor 

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

func (*UpdateFields) GetFields 

func (m *UpdateFields) GetFields() []*ReqUpdateField

func (*UpdateFields) ProtoMessage 

func (*UpdateFields) ProtoMessage()

func (*UpdateFields) Reset 

func (m *UpdateFields) Reset()

func (*UpdateFields) String 

func (m *UpdateFields) String() string

func (*UpdateFields) XXX_DiscardUnknown 

func (m *UpdateFields) XXX_DiscardUnknown()

func (*UpdateFields) XXX_Marshal 

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

func (*UpdateFields) XXX_Merge 

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

func (*UpdateFields) XXX_Size 

func (m *UpdateFields) XXX_Size() int

func (*UpdateFields) XXX_Unmarshal 

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

type UpdateFriends 

type UpdateFriends struct {
	Friends              []*ReqUpdateFriend `protobuf:"bytes,1,rep,name=friends,proto3" json:"friends,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*UpdateFriends) Descriptor 

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

func (*UpdateFriends) GetFriends 

func (m *UpdateFriends) GetFriends() []*ReqUpdateFriend

func (*UpdateFriends) ProtoMessage 

func (*UpdateFriends) ProtoMessage()

func (*UpdateFriends) Reset 

func (m *UpdateFriends) Reset()

func (*UpdateFriends) String 

func (m *UpdateFriends) String() string

func (*UpdateFriends) XXX_DiscardUnknown 

func (m *UpdateFriends) XXX_DiscardUnknown()

func (*UpdateFriends) XXX_Marshal 

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

func (*UpdateFriends) XXX_Merge 

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

func (*UpdateFriends) XXX_Size 

func (m *UpdateFriends) XXX_Size() int

func (*UpdateFriends) XXX_Unmarshal 

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

type UpdateServerGroups 

type UpdateServerGroups struct {
	Groups               []*ReqUpdateServerGroup `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*UpdateServerGroups) Descriptor 

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

func (*UpdateServerGroups) GetGroups 

func (m *UpdateServerGroups) GetGroups() []*ReqUpdateServerGroup

func (*UpdateServerGroups) ProtoMessage 

func (*UpdateServerGroups) ProtoMessage()

func (*UpdateServerGroups) Reset 

func (m *UpdateServerGroups) Reset()

func (*UpdateServerGroups) String 

func (m *UpdateServerGroups) String() string

func (*UpdateServerGroups) XXX_DiscardUnknown 

func (m *UpdateServerGroups) XXX_DiscardUnknown()

func (*UpdateServerGroups) XXX_Marshal 

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

func (*UpdateServerGroups) XXX_Merge 

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

func (*UpdateServerGroups) XXX_Size 

func (m *UpdateServerGroups) XXX_Size() int

func (*UpdateServerGroups) XXX_Unmarshal 

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

type UserRow 

type UserRow struct {
	*Field
}

FriendRow table meta 结构

func NewUserRow 

func NewUserRow() *UserRow

NewFriendRow 新建一个meta 结构

func (*UserRow) CreateRow 

func (tx *UserRow) CreateRow() *table.Row

CreateRow 新建数据行(注意index 数据一定也要保存到数据中,不能就保存eventid)

func (*UserRow) Get 

func (tx *UserRow) Get(key string) ([]byte, error)

Get 按照indexName 查询 indexValue

func (*UserRow) SetPayload 

func (tx *UserRow) SetPayload(data types.Message) error

SetPayload 设置数据

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.