coredbpb

package
v0.7.212 Latest Latest
Warning

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

Go to latest
Published: Dec 25, 2019 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var CONNECTTYPE_name = map[int32]string{
	0: "UNKNOWN_CONN",
	1: "DIRECT_CONN",
	2: "FORWARD_ONCE",
	3: "FORWARD_MULTIPLE",
}
View Source
var CONNECTTYPE_value = map[string]int32{
	"UNKNOWN_CONN":     0,
	"DIRECT_CONN":      1,
	"FORWARD_ONCE":     2,
	"FORWARD_MULTIPLE": 3,
}

Functions

This section is empty.

Types

type CONNECTTYPE added in v0.7.130

type CONNECTTYPE int32

CONNECTTYPE - connect type

const (
	// unknown connection
	CONNECTTYPE_UNKNOWN_CONN CONNECTTYPE = 0
	// direct connection
	CONNECTTYPE_DIRECT_CONN CONNECTTYPE = 1
	// forward once
	CONNECTTYPE_FORWARD_ONCE CONNECTTYPE = 2
	// forward multiple times
	CONNECTTYPE_FORWARD_MULTIPLE CONNECTTYPE = 3
)

func (CONNECTTYPE) EnumDescriptor added in v0.7.130

func (CONNECTTYPE) EnumDescriptor() ([]byte, []int)

func (CONNECTTYPE) String added in v0.7.130

func (x CONNECTTYPE) String() string

type FileSystem added in v0.7.130

type FileSystem struct {
	CurFileID            int64    `protobuf:"varint,1,opt,name=curFileID,proto3" json:"curFileID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FileSystem

func (*FileSystem) Descriptor added in v0.7.130

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

func (*FileSystem) GetCurFileID added in v0.7.130

func (m *FileSystem) GetCurFileID() int64

func (*FileSystem) ProtoMessage added in v0.7.130

func (*FileSystem) ProtoMessage()

func (*FileSystem) Reset added in v0.7.130

func (m *FileSystem) Reset()

func (*FileSystem) String added in v0.7.130

func (m *FileSystem) String() string

func (*FileSystem) XXX_DiscardUnknown added in v0.7.130

func (m *FileSystem) XXX_DiscardUnknown()

func (*FileSystem) XXX_Marshal added in v0.7.130

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

func (*FileSystem) XXX_Merge added in v0.7.130

func (dst *FileSystem) XXX_Merge(src proto.Message)

func (*FileSystem) XXX_Size added in v0.7.130

func (m *FileSystem) XXX_Size() int

func (*FileSystem) XXX_Unmarshal added in v0.7.130

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

type NodeInfo

type NodeInfo struct {
	// This is the connection address of the node
	ServAddr string `protobuf:"bytes,1,opt,name=servAddr,proto3" json:"servAddr,omitempty"`
	// This is the address of the node
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// This is the node name
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// This is the number of times I connected this node.
	ConnectNums int32 `protobuf:"varint,4,opt,name=connectNums,proto3" json:"connectNums,omitempty"`
	// This is the number of times I successfully connected this node.
	ConnectedNums int32 `protobuf:"varint,5,opt,name=connectedNums,proto3" json:"connectedNums,omitempty"`
	// ctrlID
	CtrlID int64 `protobuf:"varint,6,opt,name=ctrlID,proto3" json:"ctrlID,omitempty"` // Deprecated: Do not use.
	// This is the list of addresses connected to this node
	LstClientAddr []string `protobuf:"bytes,7,rep,name=lstClientAddr,proto3" json:"lstClientAddr,omitempty"`
	// This is the timestamp added for the first time.
	AddTime int64 `protobuf:"varint,8,opt,name=addTime,proto3" json:"addTime,omitempty"`
	// Is this node connected to me?
	ConnectMe bool `protobuf:"varint,9,opt,name=connectMe,proto3" json:"connectMe,omitempty"`
	// Am I connected to this node?
	ConnectNode bool `protobuf:"varint,10,opt,name=connectNode,proto3" json:"connectNode,omitempty"` // Deprecated: Do not use.
	// nodetype version
	NodeTypeVersion string `protobuf:"bytes,11,opt,name=nodeTypeVersion,proto3" json:"nodeTypeVersion,omitempty"`
	// node type
	NodeType string `protobuf:"bytes,12,opt,name=nodeType,proto3" json:"nodeType,omitempty"`
	// jarviscore version
	CoreVersion string `protobuf:"bytes,13,opt,name=coreVersion,proto3" json:"coreVersion,omitempty"`
	// current message id
	// I send message for this node, the msgid is lastSendMsgID + 1
	LastSendMsgID int64 `protobuf:"varint,14,opt,name=lastSendMsgID,proto3" json:"lastSendMsgID,omitempty"`
	// last connect time
	LastConnectTime int64 `protobuf:"varint,15,opt,name=lastConnectTime,proto3" json:"lastConnectTime,omitempty"`
	// last connected time
	LastConnectedTime int64 `protobuf:"varint,16,opt,name=lastConnectedTime,proto3" json:"lastConnectedTime,omitempty"`
	// last connect me time
	LastConnectMeTime int64 `protobuf:"varint,17,opt,name=lastConnectMeTime,proto3" json:"lastConnectMeTime,omitempty"`
	// groups
	LstGroups []string `protobuf:"bytes,18,rep,name=lstGroups,proto3" json:"lstGroups,omitempty"`
	// deprecated
	Deprecated bool `protobuf:"varint,19,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
	// last receive message id
	LastRecvMsgID int64 `protobuf:"varint,20,opt,name=lastRecvMsgID,proto3" json:"lastRecvMsgID,omitempty"`
	// connection type
	ConnType CONNECTTYPE `protobuf:"varint,21,opt,name=connType,proto3,enum=coredbpb.CONNECTTYPE" json:"connType,omitempty"`
	// When I can't connect directly to this node, this is the list of nodes I know
	// that can be directly connected to this node.
	ValidConnNodes []string `protobuf:"bytes,22,rep,name=validConnNodes,proto3" json:"validConnNodes,omitempty"`
	// This node was ignored before this time,
	// this property is only used for deprecated to be false
	TimestampDeprecated int64 `protobuf:"varint,23,opt,name=timestampDeprecated,proto3" json:"timestampDeprecated,omitempty"`
	// This property is the number of failures to connect to the node.
	// If there is a successful connection, this property will be reset to 0.
	NumsConnectFail int32 `protobuf:"varint,24,opt,name=numsConnectFail,proto3" json:"numsConnectFail,omitempty"`
	// Only if this value is 0, I will execute requestnodes
	LastMsgID4RequestNodes int64 `protobuf:"varint,25,opt,name=lastMsgID4RequestNodes,proto3" json:"lastMsgID4RequestNodes,omitempty"`
	// This is the version number of the node node data, which is usually a hash value.
	// This value will be set to lastNodesVersion after requestnodes.
	NodesVersion string `protobuf:"bytes,26,opt,name=nodesVersion,proto3" json:"nodesVersion,omitempty"`
	// This is the version number of the node node data, which is usually a hash value.
	LastNodesVersion     string   `protobuf:"bytes,27,opt,name=lastNodesVersion,proto3" json:"lastNodesVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

node info

func (*NodeInfo) Descriptor

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

func (*NodeInfo) GetAddTime

func (m *NodeInfo) GetAddTime() int64

func (*NodeInfo) GetAddr

func (m *NodeInfo) GetAddr() string

func (*NodeInfo) GetConnType added in v0.7.130

func (m *NodeInfo) GetConnType() CONNECTTYPE

func (*NodeInfo) GetConnectMe

func (m *NodeInfo) GetConnectMe() bool

func (*NodeInfo) GetConnectNode deprecated

func (m *NodeInfo) GetConnectNode() bool

Deprecated: Do not use.

func (*NodeInfo) GetConnectNums

func (m *NodeInfo) GetConnectNums() int32

func (*NodeInfo) GetConnectedNums

func (m *NodeInfo) GetConnectedNums() int32

func (*NodeInfo) GetCoreVersion added in v0.6.12

func (m *NodeInfo) GetCoreVersion() string

func (*NodeInfo) GetCtrlID deprecated

func (m *NodeInfo) GetCtrlID() int64

Deprecated: Do not use.

func (*NodeInfo) GetDeprecated added in v0.7.130

func (m *NodeInfo) GetDeprecated() bool

func (*NodeInfo) GetLastConnectMeTime added in v0.6.21

func (m *NodeInfo) GetLastConnectMeTime() int64

func (*NodeInfo) GetLastConnectTime added in v0.6.21

func (m *NodeInfo) GetLastConnectTime() int64

func (*NodeInfo) GetLastConnectedTime added in v0.6.21

func (m *NodeInfo) GetLastConnectedTime() int64

func (*NodeInfo) GetLastMsgID4RequestNodes added in v0.7.201

func (m *NodeInfo) GetLastMsgID4RequestNodes() int64

func (*NodeInfo) GetLastNodesVersion added in v0.7.208

func (m *NodeInfo) GetLastNodesVersion() string

func (*NodeInfo) GetLastRecvMsgID added in v0.7.130

func (m *NodeInfo) GetLastRecvMsgID() int64

func (*NodeInfo) GetLastSendMsgID added in v0.7.130

func (m *NodeInfo) GetLastSendMsgID() int64

func (*NodeInfo) GetLstClientAddr

func (m *NodeInfo) GetLstClientAddr() []string

func (*NodeInfo) GetLstGroups added in v0.6.21

func (m *NodeInfo) GetLstGroups() []string

func (*NodeInfo) GetName

func (m *NodeInfo) GetName() string

func (*NodeInfo) GetNodeType added in v0.6.12

func (m *NodeInfo) GetNodeType() string

func (*NodeInfo) GetNodeTypeVersion added in v0.6.12

func (m *NodeInfo) GetNodeTypeVersion() string

func (*NodeInfo) GetNodesVersion added in v0.7.208

func (m *NodeInfo) GetNodesVersion() string

func (*NodeInfo) GetNumsConnectFail added in v0.7.130

func (m *NodeInfo) GetNumsConnectFail() int32

func (*NodeInfo) GetServAddr

func (m *NodeInfo) GetServAddr() string

func (*NodeInfo) GetTimestampDeprecated added in v0.7.130

func (m *NodeInfo) GetTimestampDeprecated() int64

func (*NodeInfo) GetValidConnNodes added in v0.7.130

func (m *NodeInfo) GetValidConnNodes() []string

func (*NodeInfo) ProtoMessage

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset

func (m *NodeInfo) Reset()

func (*NodeInfo) String

func (m *NodeInfo) String() string

func (*NodeInfo) XXX_DiscardUnknown

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal

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

func (*NodeInfo) XXX_Merge

func (dst *NodeInfo) XXX_Merge(src proto.Message)

func (*NodeInfo) XXX_Size

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal

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

type NodeInfoList

type NodeInfoList struct {
	SnapshotID           int64       `protobuf:"varint,1,opt,name=snapshotID,proto3" json:"snapshotID,omitempty"`
	EndIndex             int32       `protobuf:"varint,2,opt,name=endIndex,proto3" json:"endIndex,omitempty"`
	MaxIndex             int32       `protobuf:"varint,3,opt,name=maxIndex,proto3" json:"maxIndex,omitempty"`
	Nodes                []*NodeInfo `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

node info list

func (*NodeInfoList) Descriptor

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

func (*NodeInfoList) GetEndIndex

func (m *NodeInfoList) GetEndIndex() int32

func (*NodeInfoList) GetMaxIndex

func (m *NodeInfoList) GetMaxIndex() int32

func (*NodeInfoList) GetNodes

func (m *NodeInfoList) GetNodes() []*NodeInfo

func (*NodeInfoList) GetSnapshotID

func (m *NodeInfoList) GetSnapshotID() int64

func (*NodeInfoList) ProtoMessage

func (*NodeInfoList) ProtoMessage()

func (*NodeInfoList) Reset

func (m *NodeInfoList) Reset()

func (*NodeInfoList) String

func (m *NodeInfoList) String() string

func (*NodeInfoList) XXX_DiscardUnknown

func (m *NodeInfoList) XXX_DiscardUnknown()

func (*NodeInfoList) XXX_Marshal

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

func (*NodeInfoList) XXX_Merge

func (dst *NodeInfoList) XXX_Merge(src proto.Message)

func (*NodeInfoList) XXX_Size

func (m *NodeInfoList) XXX_Size() int

func (*NodeInfoList) XXX_Unmarshal

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

type NodeInfoList2 added in v0.7.208

type NodeInfoList2 struct {
	Nodes                []*NodeInfo `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

node info list v2

func (*NodeInfoList2) Descriptor added in v0.7.208

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

func (*NodeInfoList2) GetNodes added in v0.7.208

func (m *NodeInfoList2) GetNodes() []*NodeInfo

func (*NodeInfoList2) ProtoMessage added in v0.7.208

func (*NodeInfoList2) ProtoMessage()

func (*NodeInfoList2) Reset added in v0.7.208

func (m *NodeInfoList2) Reset()

func (*NodeInfoList2) String added in v0.7.208

func (m *NodeInfoList2) String() string

func (*NodeInfoList2) XXX_DiscardUnknown added in v0.7.208

func (m *NodeInfoList2) XXX_DiscardUnknown()

func (*NodeInfoList2) XXX_Marshal added in v0.7.208

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

func (*NodeInfoList2) XXX_Merge added in v0.7.208

func (dst *NodeInfoList2) XXX_Merge(src proto.Message)

func (*NodeInfoList2) XXX_Size added in v0.7.208

func (m *NodeInfoList2) XXX_Size() int

func (*NodeInfoList2) XXX_Unmarshal added in v0.7.208

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

type PrivateData

type PrivateData struct {
	PriKey               []byte   `protobuf:"bytes,1,opt,name=priKey,proto3" json:"priKey,omitempty"`
	PubKey               []byte   `protobuf:"bytes,2,opt,name=pubKey,proto3" json:"pubKey,omitempty"`
	CreateTime           int64    `protobuf:"varint,3,opt,name=createTime,proto3" json:"createTime,omitempty"`
	OnlineTime           int64    `protobuf:"varint,4,opt,name=onlineTime,proto3" json:"onlineTime,omitempty"`
	Addr                 string   `protobuf:"bytes,5,opt,name=addr,proto3" json:"addr,omitempty"`
	StrPriKey            string   `protobuf:"bytes,6,opt,name=strPriKey,proto3" json:"strPriKey,omitempty"`
	StrPubKey            string   `protobuf:"bytes,7,opt,name=strPubKey,proto3" json:"strPubKey,omitempty"`
	LstTrustNode         []string `protobuf:"bytes,8,rep,name=lstTrustNode,proto3" json:"lstTrustNode,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

private data

func (*PrivateData) Descriptor

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

func (*PrivateData) GetAddr

func (m *PrivateData) GetAddr() string

func (*PrivateData) GetCreateTime

func (m *PrivateData) GetCreateTime() int64

func (*PrivateData) GetLstTrustNode

func (m *PrivateData) GetLstTrustNode() []string

func (*PrivateData) GetOnlineTime

func (m *PrivateData) GetOnlineTime() int64

func (*PrivateData) GetPriKey

func (m *PrivateData) GetPriKey() []byte

func (*PrivateData) GetPubKey

func (m *PrivateData) GetPubKey() []byte

func (*PrivateData) GetStrPriKey

func (m *PrivateData) GetStrPriKey() string

func (*PrivateData) GetStrPubKey

func (m *PrivateData) GetStrPubKey() string

func (*PrivateData) ProtoMessage

func (*PrivateData) ProtoMessage()

func (*PrivateData) Reset

func (m *PrivateData) Reset()

func (*PrivateData) String

func (m *PrivateData) String() string

func (*PrivateData) XXX_DiscardUnknown

func (m *PrivateData) XXX_DiscardUnknown()

func (*PrivateData) XXX_Marshal

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

func (*PrivateData) XXX_Merge

func (dst *PrivateData) XXX_Merge(src proto.Message)

func (*PrivateData) XXX_Size

func (m *PrivateData) XXX_Size() int

func (*PrivateData) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL