jarviscorepb

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: 6 Imported by: 9

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var FileType_name = map[int32]string{
	0: "FT_BINARY",
	1: "FT_UTF8",
}
View Source 
var FileType_value = map[string]int32{
	"FT_BINARY": 0,
	"FT_UTF8":   1,
}
View Source 
var MSGTYPE_name = map[int32]string{
	0:  "NULL_TYPE",
	1:  "CONNECT_NODE",
	2:  "REQUEST_NODES",
	3:  "FORWARD_MSG",
	4:  "REQUEST_CTRL",
	5:  "REPLY_CTRL_RESULT",
	6:  "TRUST_NODE",
	7:  "RM_TRUST_NODE",
	8:  "REPLY",
	9:  "NODE_INFO",
	10: "REPLY_CONNECT",
	11: "LOCAL_CONNECT_OTHER",
	12: "LOCAL_SENDMSG",
	13: "LOCAL_REQUEST_NODES",
	14: "TRANSFER_FILE",
	15: "REQUEST_FILE",
	16: "REPLY_REQUEST_FILE",
	17: "MULTI_MSG",
	18: "REPLY_CONNECT2",
	19: "REPLY_TRANSFER_FILE",
	20: "REPLY2",
	21: "UPDATENODE",
	22: "NODESTATUS",
	23: "REQUEST_NODESTATUS",
	24: "FILE_HASH_DATA",
	25: "REPLY_CONNECT3",
	26: "TRANSFER_FILE2",
	27: "REQUEST_MSG_STATE",
	28: "REPLY_MSG_STATE",
	29: "CLEAR_LOGS",
	30: "REQUEST_LOGLIST",
	31: "REQUEST_LOG",
	32: "REPLY_LOGLIST",
	33: "REPLY_LOG",
	35: "REQUEST_NODES2",
	36: "REPLY_MYNODESVERSION",
}
View Source 
var MSGTYPE_value = map[string]int32{
	"NULL_TYPE":            0,
	"CONNECT_NODE":         1,
	"REQUEST_NODES":        2,
	"FORWARD_MSG":          3,
	"REQUEST_CTRL":         4,
	"REPLY_CTRL_RESULT":    5,
	"TRUST_NODE":           6,
	"RM_TRUST_NODE":        7,
	"REPLY":                8,
	"NODE_INFO":            9,
	"REPLY_CONNECT":        10,
	"LOCAL_CONNECT_OTHER":  11,
	"LOCAL_SENDMSG":        12,
	"LOCAL_REQUEST_NODES":  13,
	"TRANSFER_FILE":        14,
	"REQUEST_FILE":         15,
	"REPLY_REQUEST_FILE":   16,
	"MULTI_MSG":            17,
	"REPLY_CONNECT2":       18,
	"REPLY_TRANSFER_FILE":  19,
	"REPLY2":               20,
	"UPDATENODE":           21,
	"NODESTATUS":           22,
	"REQUEST_NODESTATUS":   23,
	"FILE_HASH_DATA":       24,
	"REPLY_CONNECT3":       25,
	"TRANSFER_FILE2":       26,
	"REQUEST_MSG_STATE":    27,
	"REPLY_MSG_STATE":      28,
	"CLEAR_LOGS":           29,
	"REQUEST_LOGLIST":      30,
	"REQUEST_LOG":          31,
	"REPLY_LOGLIST":        32,
	"REPLY_LOG":            33,
	"REQUEST_NODES2":       35,
	"REPLY_MYNODESVERSION": 36,
}
View Source 
var REPLYTYPE_name = map[int32]string{
	0: "OK",
	1: "FORWARD",
	2: "TIMEOUT",
	3: "ISME",
	4: "ERROR",
	5: "ERRMSGID",
	6: "IGOTIT",
	7: "END",
	8: "WAITPUSH",
}
View Source 
var REPLYTYPE_value = map[string]int32{
	"OK":       0,
	"FORWARD":  1,
	"TIMEOUT":  2,
	"ISME":     3,
	"ERROR":    4,
	"ERRMSGID": 5,
	"IGOTIT":   6,
	"END":      7,
	"WAITPUSH": 8,
}
View Source 
var TASKTYPE_name = map[int32]string{
	0: "NORMAL",
	1: "SERVICE",
}
View Source 
var TASKTYPE_value = map[string]int32{
	"NORMAL":  0,
	"SERVICE": 1,
}

Functions

func RegisterJarvisCoreServServer 

func RegisterJarvisCoreServServer(s *grpc.Server, srv JarvisCoreServServer)

func RegisterJarvisTaskServServer added in v0.7.166 

func RegisterJarvisTaskServServer(s *grpc.Server, srv JarvisTaskServServer)

Types

type ConnectInfo 

type ConnectInfo struct {
	ServAddr             string        `protobuf:"bytes,1,opt,name=servAddr,proto3" json:"servAddr,omitempty"`
	MyInfo               *NodeBaseInfo `protobuf:"bytes,2,opt,name=myInfo,proto3" json:"myInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

ConnectInfo - used in CONNECT_NODE

func (*ConnectInfo) Descriptor 

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

func (*ConnectInfo) GetMyInfo 

func (m *ConnectInfo) GetMyInfo() *NodeBaseInfo

func (*ConnectInfo) GetServAddr 

func (m *ConnectInfo) GetServAddr() string

func (*ConnectInfo) ProtoMessage 

func (*ConnectInfo) ProtoMessage()

func (*ConnectInfo) Reset 

func (m *ConnectInfo) Reset()

func (*ConnectInfo) String 

func (m *ConnectInfo) String() string

func (*ConnectInfo) XXX_DiscardUnknown 

func (m *ConnectInfo) XXX_DiscardUnknown()

func (*ConnectInfo) XXX_Marshal 

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

func (*ConnectInfo) XXX_Merge 

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

func (*ConnectInfo) XXX_Size 

func (m *ConnectInfo) XXX_Size() int

func (*ConnectInfo) XXX_Unmarshal 

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

type CtrlInfo 

type CtrlInfo struct {
	CtrlID               int64    `protobuf:"varint,1,opt,name=ctrlID,proto3" json:"ctrlID,omitempty"` // Deprecated: Do not use.
	CtrlType             string   `protobuf:"bytes,2,opt,name=ctrlType,proto3" json:"ctrlType,omitempty"`
	Command              string   `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"`         // Deprecated: Do not use.
	Params               []string `protobuf:"bytes,4,rep,name=params,proto3" json:"params,omitempty"`           // Deprecated: Do not use.
	Description          string   `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` // Deprecated: Do not use.
	Dat                  *any.Any `protobuf:"bytes,1000,opt,name=dat,proto3" json:"dat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CtrlInfo -

func (*CtrlInfo) Descriptor 

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

func (*CtrlInfo) GetCommand deprecated 

func (m *CtrlInfo) GetCommand() string

Deprecated: Do not use.

func (*CtrlInfo) GetCtrlID deprecated 

func (m *CtrlInfo) GetCtrlID() int64

Deprecated: Do not use.

func (*CtrlInfo) GetCtrlType 

func (m *CtrlInfo) GetCtrlType() string

func (*CtrlInfo) GetDat 

func (m *CtrlInfo) GetDat() *any.Any

func (*CtrlInfo) GetDescription deprecated 

func (m *CtrlInfo) GetDescription() string

Deprecated: Do not use.

func (*CtrlInfo) GetParams deprecated 

func (m *CtrlInfo) GetParams() []string

Deprecated: Do not use.

func (*CtrlInfo) ProtoMessage 

func (*CtrlInfo) ProtoMessage()

func (*CtrlInfo) Reset 

func (m *CtrlInfo) Reset()

func (*CtrlInfo) String 

func (m *CtrlInfo) String() string

func (*CtrlInfo) XXX_DiscardUnknown 

func (m *CtrlInfo) XXX_DiscardUnknown()

func (*CtrlInfo) XXX_Marshal 

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

func (*CtrlInfo) XXX_Merge 

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

func (*CtrlInfo) XXX_Size 

func (m *CtrlInfo) XXX_Size() int

func (*CtrlInfo) XXX_Unmarshal 

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

type CtrlResult 

type CtrlResult struct {
	CtrlID               int64    `protobuf:"varint,1,opt,name=ctrlID,proto3" json:"ctrlID,omitempty"` // Deprecated: Do not use.
	CtrlResult           string   `protobuf:"bytes,2,opt,name=ctrlResult,proto3" json:"ctrlResult,omitempty"`
	ErrInfo              string   `protobuf:"bytes,3,opt,name=errInfo,proto3" json:"errInfo,omitempty"`
	Dat                  *any.Any `protobuf:"bytes,1000,opt,name=dat,proto3" json:"dat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CtrlResult -

func (*CtrlResult) Descriptor 

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

func (*CtrlResult) GetCtrlID deprecated 

func (m *CtrlResult) GetCtrlID() int64

Deprecated: Do not use.

func (*CtrlResult) GetCtrlResult 

func (m *CtrlResult) GetCtrlResult() string

func (*CtrlResult) GetDat added in v0.7.136 

func (m *CtrlResult) GetDat() *any.Any

func (*CtrlResult) GetErrInfo added in v0.7.178 

func (m *CtrlResult) GetErrInfo() string

func (*CtrlResult) ProtoMessage 

func (*CtrlResult) ProtoMessage()

func (*CtrlResult) Reset 

func (m *CtrlResult) Reset()

func (*CtrlResult) String 

func (m *CtrlResult) String() string

func (*CtrlResult) XXX_DiscardUnknown 

func (m *CtrlResult) XXX_DiscardUnknown()

func (*CtrlResult) XXX_Marshal 

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

func (*CtrlResult) XXX_Merge 

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

func (*CtrlResult) XXX_Size 

func (m *CtrlResult) XXX_Size() int

func (*CtrlResult) XXX_Unmarshal 

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

type CtrlScript2Data added in v0.6.21 

type CtrlScript2Data struct {
	ScriptFile           *FileData   `protobuf:"bytes,1,opt,name=scriptFile,proto3" json:"scriptFile,omitempty"`
	SrcFiles             []*FileData `protobuf:"bytes,2,rep,name=srcFiles,proto3" json:"srcFiles,omitempty"`
	ScriptName           string      `protobuf:"bytes,3,opt,name=scriptName,proto3" json:"scriptName,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

CtrlScript2Data - used in CtrlInfo.dat

  • scriptfile2

func (*CtrlScript2Data) Descriptor added in v0.6.21 

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

func (*CtrlScript2Data) GetScriptFile added in v0.6.21 

func (m *CtrlScript2Data) GetScriptFile() *FileData

func (*CtrlScript2Data) GetScriptName added in v0.7.172 

func (m *CtrlScript2Data) GetScriptName() string

func (*CtrlScript2Data) GetSrcFiles added in v0.6.21 

func (m *CtrlScript2Data) GetSrcFiles() []*FileData

func (*CtrlScript2Data) ProtoMessage added in v0.6.21 

func (*CtrlScript2Data) ProtoMessage()

func (*CtrlScript2Data) Reset added in v0.6.21 

func (m *CtrlScript2Data) Reset()

func (*CtrlScript2Data) String added in v0.6.21 

func (m *CtrlScript2Data) String() string

func (*CtrlScript2Data) XXX_DiscardUnknown added in v0.6.21 

func (m *CtrlScript2Data) XXX_DiscardUnknown()

func (*CtrlScript2Data) XXX_Marshal added in v0.6.21 

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

func (*CtrlScript2Data) XXX_Merge added in v0.6.21 

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

func (*CtrlScript2Data) XXX_Size added in v0.6.21 

func (m *CtrlScript2Data) XXX_Size() int

func (*CtrlScript2Data) XXX_Unmarshal added in v0.6.21 

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

type CtrlScript3Data added in v0.7.130 

type CtrlScript3Data struct {
	ScriptFile           *FileData `protobuf:"bytes,1,opt,name=scriptFile,proto3" json:"scriptFile,omitempty"`
	EndFiles             []string  `protobuf:"bytes,2,rep,name=endFiles,proto3" json:"endFiles,omitempty"`
	ScriptName           string    `protobuf:"bytes,3,opt,name=scriptName,proto3" json:"scriptName,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

CtrlScript3Data - used in CtrlInfo.dat

  • scriptfile3

func (*CtrlScript3Data) Descriptor added in v0.7.130 

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

func (*CtrlScript3Data) GetEndFiles added in v0.7.130 

func (m *CtrlScript3Data) GetEndFiles() []string

func (*CtrlScript3Data) GetScriptFile added in v0.7.130 

func (m *CtrlScript3Data) GetScriptFile() *FileData

func (*CtrlScript3Data) GetScriptName added in v0.7.172 

func (m *CtrlScript3Data) GetScriptName() string

func (*CtrlScript3Data) ProtoMessage added in v0.7.130 

func (*CtrlScript3Data) ProtoMessage()

func (*CtrlScript3Data) Reset added in v0.7.130 

func (m *CtrlScript3Data) Reset()

func (*CtrlScript3Data) String added in v0.7.130 

func (m *CtrlScript3Data) String() string

func (*CtrlScript3Data) XXX_DiscardUnknown added in v0.7.130 

func (m *CtrlScript3Data) XXX_DiscardUnknown()

func (*CtrlScript3Data) XXX_Marshal added in v0.7.130 

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

func (*CtrlScript3Data) XXX_Merge added in v0.7.130 

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

func (*CtrlScript3Data) XXX_Size added in v0.7.130 

func (m *CtrlScript3Data) XXX_Size() int

func (*CtrlScript3Data) XXX_Unmarshal added in v0.7.130 

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

type CtrlScriptData 

type CtrlScriptData struct {
	File                 []byte   `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	DestPath             string   `protobuf:"bytes,2,opt,name=destPath,proto3" json:"destPath,omitempty"`
	Filename             string   `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	ScriptName           string   `protobuf:"bytes,4,opt,name=scriptName,proto3" json:"scriptName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CtrlScriptData - used in CtrlInfo.dat

  • scriptfile

func (*CtrlScriptData) Descriptor 

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

func (*CtrlScriptData) GetDestPath 

func (m *CtrlScriptData) GetDestPath() string

func (*CtrlScriptData) GetFile 

func (m *CtrlScriptData) GetFile() []byte

func (*CtrlScriptData) GetFilename 

func (m *CtrlScriptData) GetFilename() string

func (*CtrlScriptData) GetScriptName added in v0.7.172 

func (m *CtrlScriptData) GetScriptName() string

func (*CtrlScriptData) ProtoMessage 

func (*CtrlScriptData) ProtoMessage()

func (*CtrlScriptData) Reset 

func (m *CtrlScriptData) Reset()

func (*CtrlScriptData) String 

func (m *CtrlScriptData) String() string

func (*CtrlScriptData) XXX_DiscardUnknown 

func (m *CtrlScriptData) XXX_DiscardUnknown()

func (*CtrlScriptData) XXX_Marshal 

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

func (*CtrlScriptData) XXX_Merge 

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

func (*CtrlScriptData) XXX_Size 

func (m *CtrlScriptData) XXX_Size() int

func (*CtrlScriptData) XXX_Unmarshal 

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

type FileData added in v0.6.10 

type FileData struct {
	File                 []byte   `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	Filename             string   `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`
	DestPath             string   `protobuf:"bytes,3,opt,name=destPath,proto3" json:"destPath,omitempty"`
	Md5String            string   `protobuf:"bytes,4,opt,name=md5String,proto3" json:"md5String,omitempty"`
	Ft                   FileType `protobuf:"varint,5,opt,name=ft,proto3,enum=jarviscorepb.FileType" json:"ft,omitempty"`
	Start                int64    `protobuf:"varint,6,opt,name=start,proto3" json:"start,omitempty"`
	Length               int64    `protobuf:"varint,7,opt,name=length,proto3" json:"length,omitempty"`
	TotalLength          int64    `protobuf:"varint,8,opt,name=totalLength,proto3" json:"totalLength,omitempty"`
	FileMD5String        string   `protobuf:"bytes,9,opt,name=fileMD5String,proto3" json:"fileMD5String,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FileData - file data

func (*FileData) Descriptor added in v0.6.10 

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

func (*FileData) GetDestPath added in v0.6.21 

func (m *FileData) GetDestPath() string

func (*FileData) GetFile added in v0.6.10 

func (m *FileData) GetFile() []byte

func (*FileData) GetFileMD5String added in v0.7.130 

func (m *FileData) GetFileMD5String() string

func (*FileData) GetFilename added in v0.6.10 

func (m *FileData) GetFilename() string

func (*FileData) GetFt added in v0.7.130 

func (m *FileData) GetFt() FileType

func (*FileData) GetLength added in v0.7.130 

func (m *FileData) GetLength() int64

func (*FileData) GetMd5String added in v0.7.130 

func (m *FileData) GetMd5String() string

func (*FileData) GetStart added in v0.7.130 

func (m *FileData) GetStart() int64

func (*FileData) GetTotalLength added in v0.7.130 

func (m *FileData) GetTotalLength() int64

func (*FileData) ProtoMessage added in v0.6.10 

func (*FileData) ProtoMessage()

func (*FileData) Reset added in v0.6.10 

func (m *FileData) Reset()

func (*FileData) String added in v0.6.10 

func (m *FileData) String() string

func (*FileData) XXX_DiscardUnknown added in v0.6.10 

func (m *FileData) XXX_DiscardUnknown()

func (*FileData) XXX_Marshal added in v0.6.10 

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

func (*FileData) XXX_Merge added in v0.6.10 

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

func (*FileData) XXX_Size added in v0.6.10 

func (m *FileData) XXX_Size() int

func (*FileData) XXX_Unmarshal added in v0.6.10 

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

type FileHashData added in v0.7.130 

type FileHashData struct {
	Filename             string   `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	FileMD5String        string   `protobuf:"bytes,2,opt,name=fileMD5String,proto3" json:"fileMD5String,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FileHashData - file hash data

func (*FileHashData) Descriptor added in v0.7.130 

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

func (*FileHashData) GetFileMD5String added in v0.7.130 

func (m *FileHashData) GetFileMD5String() string

func (*FileHashData) GetFilename added in v0.7.130 

func (m *FileHashData) GetFilename() string

func (*FileHashData) ProtoMessage added in v0.7.130 

func (*FileHashData) ProtoMessage()

func (*FileHashData) Reset added in v0.7.130 

func (m *FileHashData) Reset()

func (*FileHashData) String added in v0.7.130 

func (m *FileHashData) String() string

func (*FileHashData) XXX_DiscardUnknown added in v0.7.130 

func (m *FileHashData) XXX_DiscardUnknown()

func (*FileHashData) XXX_Marshal added in v0.7.130 

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

func (*FileHashData) XXX_Merge added in v0.7.130 

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

func (*FileHashData) XXX_Size added in v0.7.130 

func (m *FileHashData) XXX_Size() int

func (*FileHashData) XXX_Unmarshal added in v0.7.130 

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

type FileType added in v0.7.130 

type FileType int32

FileType - file type 

const (
	FileType_FT_BINARY FileType = 0
	FileType_FT_UTF8   FileType = 1
)

func (FileType) EnumDescriptor added in v0.7.130 

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

func (FileType) String added in v0.7.130 

func (x FileType) String() string

type JarvisCoreServClient 

type JarvisCoreServClient interface {
	ProcMsg(ctx context.Context, in *JarvisMsg, opts ...grpc.CallOption) (JarvisCoreServ_ProcMsgClient, error)
	ProcMsgStream(ctx context.Context, opts ...grpc.CallOption) (JarvisCoreServ_ProcMsgStreamClient, error)
}

JarvisCoreServClient is the client API for JarvisCoreServ service.

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

func NewJarvisCoreServClient 

func NewJarvisCoreServClient(cc *grpc.ClientConn) JarvisCoreServClient

type JarvisCoreServServer 

type JarvisCoreServServer interface {
	ProcMsg(*JarvisMsg, JarvisCoreServ_ProcMsgServer) error
	ProcMsgStream(JarvisCoreServ_ProcMsgStreamServer) error
}

JarvisCoreServServer is the server API for JarvisCoreServ service.

type JarvisCoreServ_ProcMsgClient 

type JarvisCoreServ_ProcMsgClient interface {
	Recv() (*JarvisMsg, error)
	grpc.ClientStream
}

type JarvisCoreServ_ProcMsgServer 

type JarvisCoreServ_ProcMsgServer interface {
	Send(*JarvisMsg) error
	grpc.ServerStream
}

type JarvisCoreServ_ProcMsgStreamClient added in v0.7.130 

type JarvisCoreServ_ProcMsgStreamClient interface {
	Send(*JarvisMsg) error
	Recv() (*JarvisMsg, error)
	grpc.ClientStream
}

type JarvisCoreServ_ProcMsgStreamServer added in v0.7.130 

type JarvisCoreServ_ProcMsgStreamServer interface {
	Send(*JarvisMsg) error
	Recv() (*JarvisMsg, error)
	grpc.ServerStream
}

type JarvisMsg 

type JarvisMsg struct {
	MsgID          int64     `protobuf:"varint,1,opt,name=msgID,proto3" json:"msgID,omitempty"`
	CurTime        int64     `protobuf:"varint,2,opt,name=curTime,proto3" json:"curTime,omitempty"`
	SignR          []byte    `protobuf:"bytes,3,opt,name=signR,proto3" json:"signR,omitempty"`
	SignS          []byte    `protobuf:"bytes,4,opt,name=signS,proto3" json:"signS,omitempty"`
	PubKey         []byte    `protobuf:"bytes,5,opt,name=pubKey,proto3" json:"pubKey,omitempty"`
	SrcAddr        string    `protobuf:"bytes,6,opt,name=srcAddr,proto3" json:"srcAddr,omitempty"`
	MyAddr         string    `protobuf:"bytes,7,opt,name=myAddr,proto3" json:"myAddr,omitempty"`
	DestAddr       string    `protobuf:"bytes,8,opt,name=destAddr,proto3" json:"destAddr,omitempty"`
	MsgType        MSGTYPE   `protobuf:"varint,9,opt,name=msgType,proto3,enum=jarviscorepb.MSGTYPE" json:"msgType,omitempty"`
	ReplyType      REPLYTYPE `protobuf:"varint,10,opt,name=replyType,proto3,enum=jarviscorepb.REPLYTYPE" json:"replyType,omitempty"`
	Err            string    `protobuf:"bytes,11,opt,name=err,proto3" json:"err,omitempty"`
	LastMsgID      int64     `protobuf:"varint,12,opt,name=lastMsgID,proto3" json:"lastMsgID,omitempty"`
	ReplyMsgID     int64     `protobuf:"varint,13,opt,name=replyMsgID,proto3" json:"replyMsgID,omitempty"`
	StreamMsgID    int64     `protobuf:"varint,14,opt,name=streamMsgID,proto3" json:"streamMsgID,omitempty"` // Deprecated: Do not use.
	StreamMsgIndex int32     `protobuf:"varint,15,opt,name=streamMsgIndex,proto3" json:"streamMsgIndex,omitempty"`
	// Types that are valid to be assigned to Data:
	//	*JarvisMsg_NodeInfo
	//	*JarvisMsg_CtrlInfo
	//	*JarvisMsg_CtrlResult
	//	*JarvisMsg_ConnInfo
	//	*JarvisMsg_Msg
	//	*JarvisMsg_File
	//	*JarvisMsg_RequestFile
	//	*JarvisMsg_MultiMsgData
	//	*JarvisMsg_ReplyConn2
	//	*JarvisMsg_ReplyTransferFile
	//	*JarvisMsg_UpdateNode
	//	*JarvisMsg_NodeStatus
	//	*JarvisMsg_FileHashData
	//	*JarvisMsg_RequestMsgState
	//	*JarvisMsg_ReplyMsgState
	//	*JarvisMsg_Logs
	//	*JarvisMsg_RequestLog
	//	*JarvisMsg_LogInfo
	//	*JarvisMsg_RequestNodes2
	//	*JarvisMsg_ReplyMyNodesVersion
	Data                 isJarvisMsg_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

JarvisMsg - jarvis base msg 

sign(msgID + msgType + destAddr + curTime + srcAddr + data)

func (*JarvisMsg) Descriptor 

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

func (*JarvisMsg) GetConnInfo 

func (m *JarvisMsg) GetConnInfo() *ConnectInfo

func (*JarvisMsg) GetCtrlInfo 

func (m *JarvisMsg) GetCtrlInfo() *CtrlInfo

func (*JarvisMsg) GetCtrlResult 

func (m *JarvisMsg) GetCtrlResult() *CtrlResult

func (*JarvisMsg) GetCurTime 

func (m *JarvisMsg) GetCurTime() int64

func (*JarvisMsg) GetData 

func (m *JarvisMsg) GetData() isJarvisMsg_Data

func (*JarvisMsg) GetDestAddr 

func (m *JarvisMsg) GetDestAddr() string

func (*JarvisMsg) GetErr added in v0.6.10 

func (m *JarvisMsg) GetErr() string

func (*JarvisMsg) GetFile added in v0.6.10 

func (m *JarvisMsg) GetFile() *FileData

func (*JarvisMsg) GetFileHashData added in v0.7.130 

func (m *JarvisMsg) GetFileHashData() *FileHashData

func (*JarvisMsg) GetLastMsgID added in v0.7.130 

func (m *JarvisMsg) GetLastMsgID() int64

func (*JarvisMsg) GetLogInfo added in v0.7.192 

func (m *JarvisMsg) GetLogInfo() *ReplyLog

func (*JarvisMsg) GetLogs added in v0.7.192 

func (m *JarvisMsg) GetLogs() *ReplyLogList

func (*JarvisMsg) GetMsg 

func (m *JarvisMsg) GetMsg() *JarvisMsg

func (*JarvisMsg) GetMsgID 

func (m *JarvisMsg) GetMsgID() int64

func (*JarvisMsg) GetMsgType 

func (m *JarvisMsg) GetMsgType() MSGTYPE

func (*JarvisMsg) GetMultiMsgData added in v0.6.21 

func (m *JarvisMsg) GetMultiMsgData() *MultiMsgData

func (*JarvisMsg) GetMyAddr 

func (m *JarvisMsg) GetMyAddr() string

func (*JarvisMsg) GetNodeInfo 

func (m *JarvisMsg) GetNodeInfo() *NodeBaseInfo

func (*JarvisMsg) GetNodeStatus added in v0.7.130 

func (m *JarvisMsg) GetNodeStatus() *JarvisNodeStatus

func (*JarvisMsg) GetPubKey 

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

func (*JarvisMsg) GetReplyConn2 deprecated added in v0.7.130 

func (m *JarvisMsg) GetReplyConn2() *ReplyConnect2

Deprecated: Do not use.

func (*JarvisMsg) GetReplyMsgID added in v0.7.130 

func (m *JarvisMsg) GetReplyMsgID() int64

func (*JarvisMsg) GetReplyMsgState added in v0.7.157 

func (m *JarvisMsg) GetReplyMsgState() *ReplyMsgState

func (*JarvisMsg) GetReplyMyNodesVersion added in v0.7.208 

func (m *JarvisMsg) GetReplyMyNodesVersion() *ReplyMyNodesVersion

func (*JarvisMsg) GetReplyTransferFile added in v0.7.130 

func (m *JarvisMsg) GetReplyTransferFile() *ReplyTransferFile

func (*JarvisMsg) GetReplyType 

func (m *JarvisMsg) GetReplyType() REPLYTYPE

func (*JarvisMsg) GetRequestFile added in v0.6.12 

func (m *JarvisMsg) GetRequestFile() *RequestFile

func (*JarvisMsg) GetRequestLog added in v0.7.192 

func (m *JarvisMsg) GetRequestLog() *RequestLog

func (*JarvisMsg) GetRequestMsgState added in v0.7.157 

func (m *JarvisMsg) GetRequestMsgState() *RequestMsgState

func (*JarvisMsg) GetRequestNodes2 added in v0.7.201 

func (m *JarvisMsg) GetRequestNodes2() *RequestNodes2

func (*JarvisMsg) GetSignR 

func (m *JarvisMsg) GetSignR() []byte

func (*JarvisMsg) GetSignS 

func (m *JarvisMsg) GetSignS() []byte

func (*JarvisMsg) GetSrcAddr 

func (m *JarvisMsg) GetSrcAddr() string

func (*JarvisMsg) GetStreamMsgID deprecated added in v0.7.130 

func (m *JarvisMsg) GetStreamMsgID() int64

Deprecated: Do not use.

func (*JarvisMsg) GetStreamMsgIndex added in v0.7.157 

func (m *JarvisMsg) GetStreamMsgIndex() int32

func (*JarvisMsg) GetUpdateNode added in v0.7.130 

func (m *JarvisMsg) GetUpdateNode() *UpdateNode

func (*JarvisMsg) ProtoMessage 

func (*JarvisMsg) ProtoMessage()

func (*JarvisMsg) Reset 

func (m *JarvisMsg) Reset()

func (*JarvisMsg) String 

func (m *JarvisMsg) String() string

func (*JarvisMsg) XXX_DiscardUnknown 

func (m *JarvisMsg) XXX_DiscardUnknown()

func (*JarvisMsg) XXX_Marshal 

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

func (*JarvisMsg) XXX_Merge 

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

func (*JarvisMsg) XXX_OneofFuncs 

func (*JarvisMsg) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*JarvisMsg) XXX_Size 

func (m *JarvisMsg) XXX_Size() int

func (*JarvisMsg) XXX_Unmarshal 

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

type JarvisMsg_ConnInfo 

type JarvisMsg_ConnInfo struct {
	ConnInfo *ConnectInfo `protobuf:"bytes,103,opt,name=connInfo,proto3,oneof"`
}

type JarvisMsg_CtrlInfo 

type JarvisMsg_CtrlInfo struct {
	CtrlInfo *CtrlInfo `protobuf:"bytes,101,opt,name=ctrlInfo,proto3,oneof"`
}

type JarvisMsg_CtrlResult 

type JarvisMsg_CtrlResult struct {
	CtrlResult *CtrlResult `protobuf:"bytes,102,opt,name=ctrlResult,proto3,oneof"`
}

type JarvisMsg_File added in v0.6.10 

type JarvisMsg_File struct {
	File *FileData `protobuf:"bytes,105,opt,name=file,proto3,oneof"`
}

type JarvisMsg_FileHashData added in v0.7.130 

type JarvisMsg_FileHashData struct {
	FileHashData *FileHashData `protobuf:"bytes,112,opt,name=fileHashData,proto3,oneof"`
}

type JarvisMsg_LogInfo added in v0.7.192 

type JarvisMsg_LogInfo struct {
	LogInfo *ReplyLog `protobuf:"bytes,118,opt,name=logInfo,proto3,oneof"`
}

type JarvisMsg_Logs added in v0.7.192 

type JarvisMsg_Logs struct {
	Logs *ReplyLogList `protobuf:"bytes,116,opt,name=logs,proto3,oneof"`
}

type JarvisMsg_Msg 

type JarvisMsg_Msg struct {
	Msg *JarvisMsg `protobuf:"bytes,104,opt,name=msg,proto3,oneof"`
}

type JarvisMsg_MultiMsgData added in v0.6.21 

type JarvisMsg_MultiMsgData struct {
	MultiMsgData *MultiMsgData `protobuf:"bytes,107,opt,name=multiMsgData,proto3,oneof"`
}

type JarvisMsg_NodeInfo 

type JarvisMsg_NodeInfo struct {
	NodeInfo *NodeBaseInfo `protobuf:"bytes,100,opt,name=nodeInfo,proto3,oneof"`
}

type JarvisMsg_NodeStatus added in v0.7.130 

type JarvisMsg_NodeStatus struct {
	NodeStatus *JarvisNodeStatus `protobuf:"bytes,111,opt,name=nodeStatus,proto3,oneof"`
}

type JarvisMsg_ReplyConn2 added in v0.7.130 

type JarvisMsg_ReplyConn2 struct {
	ReplyConn2 *ReplyConnect2 `protobuf:"bytes,108,opt,name=replyConn2,proto3,oneof"`
}

type JarvisMsg_ReplyMsgState added in v0.7.157 

type JarvisMsg_ReplyMsgState struct {
	ReplyMsgState *ReplyMsgState `protobuf:"bytes,115,opt,name=replyMsgState,proto3,oneof"`
}

type JarvisMsg_ReplyMyNodesVersion added in v0.7.208 

type JarvisMsg_ReplyMyNodesVersion struct {
	ReplyMyNodesVersion *ReplyMyNodesVersion `protobuf:"bytes,120,opt,name=replyMyNodesVersion,proto3,oneof"`
}

type JarvisMsg_ReplyTransferFile added in v0.7.130 

type JarvisMsg_ReplyTransferFile struct {
	ReplyTransferFile *ReplyTransferFile `protobuf:"bytes,109,opt,name=replyTransferFile,proto3,oneof"`
}

type JarvisMsg_RequestFile added in v0.6.12 

type JarvisMsg_RequestFile struct {
	RequestFile *RequestFile `protobuf:"bytes,106,opt,name=requestFile,proto3,oneof"`
}

type JarvisMsg_RequestLog added in v0.7.192 

type JarvisMsg_RequestLog struct {
	RequestLog *RequestLog `protobuf:"bytes,117,opt,name=requestLog,proto3,oneof"`
}

type JarvisMsg_RequestMsgState added in v0.7.157 

type JarvisMsg_RequestMsgState struct {
	RequestMsgState *RequestMsgState `protobuf:"bytes,113,opt,name=requestMsgState,proto3,oneof"`
}

type JarvisMsg_RequestNodes2 added in v0.7.201 

type JarvisMsg_RequestNodes2 struct {
	RequestNodes2 *RequestNodes2 `protobuf:"bytes,119,opt,name=requestNodes2,proto3,oneof"`
}

type JarvisMsg_UpdateNode added in v0.7.130 

type JarvisMsg_UpdateNode struct {
	UpdateNode *UpdateNode `protobuf:"bytes,110,opt,name=updateNode,proto3,oneof"`
}

type JarvisNodeStatus added in v0.7.130 

type JarvisNodeStatus struct {
	MyBaseInfo           *NodeBaseInfo   `protobuf:"bytes,1,opt,name=myBaseInfo,proto3" json:"myBaseInfo,omitempty"`
	LstConnected         []*NodeBaseInfo `protobuf:"bytes,2,rep,name=lstConnected,proto3" json:"lstConnected,omitempty"`
	MsgPool              *L2PoolInfo     `protobuf:"bytes,3,opt,name=msgPool,proto3" json:"msgPool,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

JarvisNodeStatus - for NODESTATUS

func (*JarvisNodeStatus) Descriptor added in v0.7.130 

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

func (*JarvisNodeStatus) GetLstConnected added in v0.7.130 

func (m *JarvisNodeStatus) GetLstConnected() []*NodeBaseInfo

func (*JarvisNodeStatus) GetMsgPool added in v0.7.130 

func (m *JarvisNodeStatus) GetMsgPool() *L2PoolInfo

func (*JarvisNodeStatus) GetMyBaseInfo added in v0.7.130 

func (m *JarvisNodeStatus) GetMyBaseInfo() *NodeBaseInfo

func (*JarvisNodeStatus) ProtoMessage added in v0.7.130 

func (*JarvisNodeStatus) ProtoMessage()

func (*JarvisNodeStatus) Reset added in v0.7.130 

func (m *JarvisNodeStatus) Reset()

func (*JarvisNodeStatus) String added in v0.7.130 

func (m *JarvisNodeStatus) String() string

func (*JarvisNodeStatus) XXX_DiscardUnknown added in v0.7.130 

func (m *JarvisNodeStatus) XXX_DiscardUnknown()

func (*JarvisNodeStatus) XXX_Marshal added in v0.7.130 

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

func (*JarvisNodeStatus) XXX_Merge added in v0.7.130 

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

func (*JarvisNodeStatus) XXX_Size added in v0.7.130 

func (m *JarvisNodeStatus) XXX_Size() int

func (*JarvisNodeStatus) XXX_Unmarshal added in v0.7.130 

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

type JarvisTask added in v0.7.166 

type JarvisTask struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CfgFiles             map[string]string `` /* 157-byte string literal not displayed */
	LogFiles             map[string]string `` /* 157-byte string literal not displayed */
	TaskType             TASKTYPE          `protobuf:"varint,4,opt,name=taskType,proto3,enum=jarviscorepb.TASKTYPE" json:"taskType,omitempty"`
	CurTime              int64             `protobuf:"varint,5,opt,name=curTime,proto3" json:"curTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

JarvisTask

func (*JarvisTask) Descriptor added in v0.7.166 

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

func (*JarvisTask) GetCfgFiles added in v0.7.166 

func (m *JarvisTask) GetCfgFiles() map[string]string

func (*JarvisTask) GetCurTime added in v0.7.178 

func (m *JarvisTask) GetCurTime() int64

func (*JarvisTask) GetLogFiles added in v0.7.166 

func (m *JarvisTask) GetLogFiles() map[string]string

func (*JarvisTask) GetName added in v0.7.166 

func (m *JarvisTask) GetName() string

func (*JarvisTask) GetTaskType added in v0.7.178 

func (m *JarvisTask) GetTaskType() TASKTYPE

func (*JarvisTask) ProtoMessage added in v0.7.166 

func (*JarvisTask) ProtoMessage()

func (*JarvisTask) Reset added in v0.7.166 

func (m *JarvisTask) Reset()

func (*JarvisTask) String added in v0.7.166 

func (m *JarvisTask) String() string

func (*JarvisTask) XXX_DiscardUnknown added in v0.7.166 

func (m *JarvisTask) XXX_DiscardUnknown()

func (*JarvisTask) XXX_Marshal added in v0.7.166 

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

func (*JarvisTask) XXX_Merge added in v0.7.166 

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

func (*JarvisTask) XXX_Size added in v0.7.166 

func (m *JarvisTask) XXX_Size() int

func (*JarvisTask) XXX_Unmarshal added in v0.7.166 

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

type JarvisTaskServClient added in v0.7.166 

type JarvisTaskServClient interface {
	UpdTask(ctx context.Context, in *JarvisTask, opts ...grpc.CallOption) (*ReplyUpdTask, error)
}

JarvisTaskServClient is the client API for JarvisTaskServ service.

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

func NewJarvisTaskServClient added in v0.7.166 

func NewJarvisTaskServClient(cc *grpc.ClientConn) JarvisTaskServClient

type JarvisTaskServServer added in v0.7.166 

type JarvisTaskServServer interface {
	UpdTask(context.Context, *JarvisTask) (*ReplyUpdTask, error)
}

JarvisTaskServServer is the server API for JarvisTaskServ service.

type L2PoolInfo added in v0.7.130 

type L2PoolInfo struct {
	NumsMapRoutine       int32    `protobuf:"varint,1,opt,name=numsMapRoutine,proto3" json:"numsMapRoutine,omitempty"`
	NumsChanRemove       int32    `protobuf:"varint,2,opt,name=numsChanRemove,proto3" json:"numsChanRemove,omitempty"`
	NumsChanWaiting      int32    `protobuf:"varint,3,opt,name=numsChanWaiting,proto3" json:"numsChanWaiting,omitempty"`
	NumsChanTask         int32    `protobuf:"varint,4,opt,name=numsChanTask,proto3" json:"numsChanTask,omitempty"`
	NumsTasks            int32    `protobuf:"varint,5,opt,name=numsTasks,proto3" json:"numsTasks,omitempty"`
	MaxNums              int32    `protobuf:"varint,6,opt,name=maxNums,proto3" json:"maxNums,omitempty"`
	NumsWaiting          int32    `protobuf:"varint,7,opt,name=numsWaiting,proto3" json:"numsWaiting,omitempty"`
	NumsTotal            int32    `protobuf:"varint,8,opt,name=numsTotal,proto3" json:"numsTotal,omitempty"`
	CurTaskID            int32    `protobuf:"varint,9,opt,name=curTaskID,proto3" json:"curTaskID,omitempty"`
	ZeroTaskID           int32    `protobuf:"varint,10,opt,name=zeroTaskID,proto3" json:"zeroTaskID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

L2PoolInfo -

func (*L2PoolInfo) Descriptor added in v0.7.130 

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

func (*L2PoolInfo) GetCurTaskID added in v0.7.130 

func (m *L2PoolInfo) GetCurTaskID() int32

func (*L2PoolInfo) GetMaxNums added in v0.7.130 

func (m *L2PoolInfo) GetMaxNums() int32

func (*L2PoolInfo) GetNumsChanRemove added in v0.7.130 

func (m *L2PoolInfo) GetNumsChanRemove() int32

func (*L2PoolInfo) GetNumsChanTask added in v0.7.130 

func (m *L2PoolInfo) GetNumsChanTask() int32

func (*L2PoolInfo) GetNumsChanWaiting added in v0.7.130 

func (m *L2PoolInfo) GetNumsChanWaiting() int32

func (*L2PoolInfo) GetNumsMapRoutine added in v0.7.130 

func (m *L2PoolInfo) GetNumsMapRoutine() int32

func (*L2PoolInfo) GetNumsTasks added in v0.7.130 

func (m *L2PoolInfo) GetNumsTasks() int32

func (*L2PoolInfo) GetNumsTotal added in v0.7.130 

func (m *L2PoolInfo) GetNumsTotal() int32

func (*L2PoolInfo) GetNumsWaiting added in v0.7.130 

func (m *L2PoolInfo) GetNumsWaiting() int32

func (*L2PoolInfo) GetZeroTaskID added in v0.7.130 

func (m *L2PoolInfo) GetZeroTaskID() int32

func (*L2PoolInfo) ProtoMessage added in v0.7.130 

func (*L2PoolInfo) ProtoMessage()

func (*L2PoolInfo) Reset added in v0.7.130 

func (m *L2PoolInfo) Reset()

func (*L2PoolInfo) String added in v0.7.130 

func (m *L2PoolInfo) String() string

func (*L2PoolInfo) XXX_DiscardUnknown added in v0.7.130 

func (m *L2PoolInfo) XXX_DiscardUnknown()

func (*L2PoolInfo) XXX_Marshal added in v0.7.130 

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

func (*L2PoolInfo) XXX_Merge added in v0.7.130 

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

func (*L2PoolInfo) XXX_Size added in v0.7.130 

func (m *L2PoolInfo) XXX_Size() int

func (*L2PoolInfo) XXX_Unmarshal added in v0.7.130 

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

type LogInfo added in v0.7.192 

type LogInfo struct {
	// appName
	AppName string `protobuf:"bytes,1,opt,name=appName,proto3" json:"appName,omitempty"`
	// subName
	SubName string `protobuf:"bytes,2,opt,name=subName,proto3" json:"subName,omitempty"`
	// fileLen
	FileLen int64 `protobuf:"varint,3,opt,name=fileLen,proto3" json:"fileLen,omitempty"`
	// startPos
	StartPos int64 `protobuf:"varint,4,opt,name=startPos,proto3" json:"startPos,omitempty"`
	// bufLen
	BufLen int64 `protobuf:"varint,5,opt,name=bufLen,proto3" json:"bufLen,omitempty"`
	// buf
	Buf []byte `protobuf:"bytes,6,opt,name=buf,proto3" json:"buf,omitempty"`
	// curTime
	CurTime int64 `protobuf:"varint,7,opt,name=curTime,proto3" json:"curTime,omitempty"`
	// logPath
	LogPath string `protobuf:"bytes,8,opt,name=logPath,proto3" json:"logPath,omitempty"`
	// dockerLogName
	DockerLogName string `protobuf:"bytes,9,opt,name=dockerLogName,proto3" json:"dockerLogName,omitempty"`
	// dockerLogPath
	DockerLogPath        string   `protobuf:"bytes,10,opt,name=dockerLogPath,proto3" json:"dockerLogPath,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogInfo) Descriptor added in v0.7.192 

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

func (*LogInfo) GetAppName added in v0.7.192 

func (m *LogInfo) GetAppName() string

func (*LogInfo) GetBuf added in v0.7.192 

func (m *LogInfo) GetBuf() []byte

func (*LogInfo) GetBufLen added in v0.7.192 

func (m *LogInfo) GetBufLen() int64

func (*LogInfo) GetCurTime added in v0.7.211 

func (m *LogInfo) GetCurTime() int64

func (*LogInfo) GetDockerLogName added in v0.7.211 

func (m *LogInfo) GetDockerLogName() string

func (*LogInfo) GetDockerLogPath added in v0.7.211 

func (m *LogInfo) GetDockerLogPath() string

func (*LogInfo) GetFileLen added in v0.7.192 

func (m *LogInfo) GetFileLen() int64

func (*LogInfo) GetLogPath added in v0.7.211 

func (m *LogInfo) GetLogPath() string

func (*LogInfo) GetStartPos added in v0.7.192 

func (m *LogInfo) GetStartPos() int64

func (*LogInfo) GetSubName added in v0.7.192 

func (m *LogInfo) GetSubName() string

func (*LogInfo) ProtoMessage added in v0.7.192 

func (*LogInfo) ProtoMessage()

func (*LogInfo) Reset added in v0.7.192 

func (m *LogInfo) Reset()

func (*LogInfo) String added in v0.7.192 

func (m *LogInfo) String() string

func (*LogInfo) XXX_DiscardUnknown added in v0.7.192 

func (m *LogInfo) XXX_DiscardUnknown()

func (*LogInfo) XXX_Marshal added in v0.7.192 

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

func (*LogInfo) XXX_Merge added in v0.7.192 

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

func (*LogInfo) XXX_Size added in v0.7.192 

func (m *LogInfo) XXX_Size() int

func (*LogInfo) XXX_Unmarshal added in v0.7.192 

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

type MSGTYPE 

type MSGTYPE int32

jarvis msg type 

const (
	// null type
	MSGTYPE_NULL_TYPE MSGTYPE = 0
	// connect jarvis node
	MSGTYPE_CONNECT_NODE MSGTYPE = 1
	// request a node's child nodes
	MSGTYPE_REQUEST_NODES MSGTYPE = 2
	// forward message
	MSGTYPE_FORWARD_MSG MSGTYPE = 3
	// request a ctrl msg
	MSGTYPE_REQUEST_CTRL MSGTYPE = 4
	// reply a ctrl result
	MSGTYPE_REPLY_CTRL_RESULT MSGTYPE = 5
	// trusted node request you trust a other node
	MSGTYPE_TRUST_NODE MSGTYPE = 6
	// trusted node request you remove a trusted node
	MSGTYPE_RM_TRUST_NODE MSGTYPE = 7
	// reply msg
	MSGTYPE_REPLY MSGTYPE = 8 // Deprecated: Do not use.
	// node info
	MSGTYPE_NODE_INFO MSGTYPE = 9
	// reply connect
	MSGTYPE_REPLY_CONNECT MSGTYPE = 10
	// local connect other
	MSGTYPE_LOCAL_CONNECT_OTHER MSGTYPE = 11 // Deprecated: Do not use.
	// local sendmsg
	MSGTYPE_LOCAL_SENDMSG MSGTYPE = 12 // Deprecated: Do not use.
	// local request nodes child
	MSGTYPE_LOCAL_REQUEST_NODES MSGTYPE = 13 // Deprecated: Do not use.
	// transfer file
	MSGTYPE_TRANSFER_FILE MSGTYPE = 14
	// request file
	MSGTYPE_REQUEST_FILE MSGTYPE = 15
	// reply request file
	MSGTYPE_REPLY_REQUEST_FILE MSGTYPE = 16
	// multi message
	MSGTYPE_MULTI_MSG MSGTYPE = 17
	// reply connect2
	MSGTYPE_REPLY_CONNECT2 MSGTYPE = 18 // Deprecated: Do not use.
	// reply transfer file
	MSGTYPE_REPLY_TRANSFER_FILE MSGTYPE = 19
	// reply2 msg
	MSGTYPE_REPLY2 MSGTYPE = 20
	// update node
	MSGTYPE_UPDATENODE MSGTYPE = 21
	// node status
	MSGTYPE_NODESTATUS MSGTYPE = 22
	// request node status
	MSGTYPE_REQUEST_NODESTATUS MSGTYPE = 23
	// file hash data
	MSGTYPE_FILE_HASH_DATA MSGTYPE = 24
	// reply connect3
	MSGTYPE_REPLY_CONNECT3 MSGTYPE = 25
	// transfer file2
	MSGTYPE_TRANSFER_FILE2 MSGTYPE = 26
	// request message state
	MSGTYPE_REQUEST_MSG_STATE MSGTYPE = 27
	// reply message state
	MSGTYPE_REPLY_MSG_STATE MSGTYPE = 28
	// clear logs
	MSGTYPE_CLEAR_LOGS MSGTYPE = 29
	// request log list
	MSGTYPE_REQUEST_LOGLIST MSGTYPE = 30
	// request log
	MSGTYPE_REQUEST_LOG MSGTYPE = 31
	// reply log list
	MSGTYPE_REPLY_LOGLIST MSGTYPE = 32
	// reply log
	MSGTYPE_REPLY_LOG MSGTYPE = 33
	// request a node's child nodes version 2
	MSGTYPE_REQUEST_NODES2 MSGTYPE = 35
	// reply my nodes version
	MSGTYPE_REPLY_MYNODESVERSION MSGTYPE = 36
)

func (MSGTYPE) EnumDescriptor 

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

func (MSGTYPE) String 

func (x MSGTYPE) String() string

type MultiMsgData added in v0.6.21 

type MultiMsgData struct {
	TotalMsgLength       int64    `protobuf:"varint,1,opt,name=totalMsgLength,proto3" json:"totalMsgLength,omitempty"`
	CurMsgIndex          int32    `protobuf:"varint,2,opt,name=curMsgIndex,proto3" json:"curMsgIndex,omitempty"`
	Buf                  []byte   `protobuf:"bytes,3,opt,name=buf,proto3" json:"buf,omitempty"`
	CurMD5               string   `protobuf:"bytes,4,opt,name=curMD5,proto3" json:"curMD5,omitempty"`
	TotalMD5             string   `protobuf:"bytes,5,opt,name=totalMD5,proto3" json:"totalMD5,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MultiMsgData - for MULTI_MSG

func (*MultiMsgData) Descriptor added in v0.6.21 

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

func (*MultiMsgData) GetBuf added in v0.6.21 

func (m *MultiMsgData) GetBuf() []byte

func (*MultiMsgData) GetCurMD5 added in v0.7.157 

func (m *MultiMsgData) GetCurMD5() string

func (*MultiMsgData) GetCurMsgIndex added in v0.6.21 

func (m *MultiMsgData) GetCurMsgIndex() int32

func (*MultiMsgData) GetTotalMD5 added in v0.7.157 

func (m *MultiMsgData) GetTotalMD5() string

func (*MultiMsgData) GetTotalMsgLength added in v0.6.21 

func (m *MultiMsgData) GetTotalMsgLength() int64

func (*MultiMsgData) ProtoMessage added in v0.6.21 

func (*MultiMsgData) ProtoMessage()

func (*MultiMsgData) Reset added in v0.6.21 

func (m *MultiMsgData) Reset()

func (*MultiMsgData) String added in v0.6.21 

func (m *MultiMsgData) String() string

func (*MultiMsgData) XXX_DiscardUnknown added in v0.6.21 

func (m *MultiMsgData) XXX_DiscardUnknown()

func (*MultiMsgData) XXX_Marshal added in v0.6.21 

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

func (*MultiMsgData) XXX_Merge added in v0.6.21 

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

func (*MultiMsgData) XXX_Size added in v0.6.21 

func (m *MultiMsgData) XXX_Size() int

func (*MultiMsgData) XXX_Unmarshal added in v0.6.21 

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

type NodeBaseInfo 

type NodeBaseInfo struct {
	// node server address
	ServAddr string `protobuf:"bytes,1,opt,name=servAddr,proto3" json:"servAddr,omitempty"`
	// node address
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// node name
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// nodetype version
	NodeTypeVersion string `protobuf:"bytes,4,opt,name=nodeTypeVersion,proto3" json:"nodeTypeVersion,omitempty"`
	// node type
	NodeType string `protobuf:"bytes,5,opt,name=nodeType,proto3" json:"nodeType,omitempty"`
	// jarviscore version
	CoreVersion          string   `protobuf:"bytes,6,opt,name=coreVersion,proto3" json:"coreVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeBaseInfo) Descriptor 

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

func (*NodeBaseInfo) GetAddr 

func (m *NodeBaseInfo) GetAddr() string

func (*NodeBaseInfo) GetCoreVersion added in v0.6.12 

func (m *NodeBaseInfo) GetCoreVersion() string

func (*NodeBaseInfo) GetName 

func (m *NodeBaseInfo) GetName() string

func (*NodeBaseInfo) GetNodeType added in v0.6.12 

func (m *NodeBaseInfo) GetNodeType() string

func (*NodeBaseInfo) GetNodeTypeVersion added in v0.6.12 

func (m *NodeBaseInfo) GetNodeTypeVersion() string

func (*NodeBaseInfo) GetServAddr 

func (m *NodeBaseInfo) GetServAddr() string

func (*NodeBaseInfo) ProtoMessage 

func (*NodeBaseInfo) ProtoMessage()

func (*NodeBaseInfo) Reset 

func (m *NodeBaseInfo) Reset()

func (*NodeBaseInfo) String 

func (m *NodeBaseInfo) String() string

func (*NodeBaseInfo) XXX_DiscardUnknown 

func (m *NodeBaseInfo) XXX_DiscardUnknown()

func (*NodeBaseInfo) XXX_Marshal 

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

func (*NodeBaseInfo) XXX_Merge 

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

func (*NodeBaseInfo) XXX_Size 

func (m *NodeBaseInfo) XXX_Size() int

func (*NodeBaseInfo) XXX_Unmarshal 

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

type REPLYTYPE 

type REPLYTYPE int32

REPLYTYPE - reply type 

const (
	// reply ok
	REPLYTYPE_OK REPLYTYPE = 0
	// forward
	REPLYTYPE_FORWARD REPLYTYPE = 1
	// timeout
	REPLYTYPE_TIMEOUT REPLYTYPE = 2
	// is me
	REPLYTYPE_ISME REPLYTYPE = 3
	// error
	REPLYTYPE_ERROR REPLYTYPE = 4
	// messageid error
	REPLYTYPE_ERRMSGID REPLYTYPE = 5
	// I got it
	REPLYTYPE_IGOTIT REPLYTYPE = 6
	// end
	REPLYTYPE_END REPLYTYPE = 7
	// wait for me to push the message
	REPLYTYPE_WAITPUSH REPLYTYPE = 8 // Deprecated: Do not use.
)

func (REPLYTYPE) EnumDescriptor 

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

func (REPLYTYPE) String 

func (x REPLYTYPE) String() string

type ReplyConnect2 added in v0.7.130 

type ReplyConnect2 struct {
	YourLastMsgID        int64         `protobuf:"varint,1,opt,name=yourLastMsgID,proto3" json:"yourLastMsgID,omitempty"`
	Nbi                  *NodeBaseInfo `protobuf:"bytes,2,opt,name=nbi,proto3" json:"nbi,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

ReplyConnect2 - used in REPLY_CONNECT2

func (*ReplyConnect2) Descriptor added in v0.7.130 

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

func (*ReplyConnect2) GetNbi added in v0.7.130 

func (m *ReplyConnect2) GetNbi() *NodeBaseInfo

func (*ReplyConnect2) GetYourLastMsgID added in v0.7.130 

func (m *ReplyConnect2) GetYourLastMsgID() int64

func (*ReplyConnect2) ProtoMessage added in v0.7.130 

func (*ReplyConnect2) ProtoMessage()

func (*ReplyConnect2) Reset added in v0.7.130 

func (m *ReplyConnect2) Reset()

func (*ReplyConnect2) String added in v0.7.130 

func (m *ReplyConnect2) String() string

func (*ReplyConnect2) XXX_DiscardUnknown added in v0.7.130 

func (m *ReplyConnect2) XXX_DiscardUnknown()

func (*ReplyConnect2) XXX_Marshal added in v0.7.130 

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

func (*ReplyConnect2) XXX_Merge added in v0.7.130 

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

func (*ReplyConnect2) XXX_Size added in v0.7.130 

func (m *ReplyConnect2) XXX_Size() int

func (*ReplyConnect2) XXX_Unmarshal added in v0.7.130 

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

type ReplyJoin 

type ReplyJoin struct {
	Addr                 string   `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplyJoin) Descriptor 

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

func (*ReplyJoin) GetAddr 

func (m *ReplyJoin) GetAddr() string

func (*ReplyJoin) GetName 

func (m *ReplyJoin) GetName() string

func (*ReplyJoin) ProtoMessage 

func (*ReplyJoin) ProtoMessage()

func (*ReplyJoin) Reset 

func (m *ReplyJoin) Reset()

func (*ReplyJoin) String 

func (m *ReplyJoin) String() string

func (*ReplyJoin) XXX_DiscardUnknown 

func (m *ReplyJoin) XXX_DiscardUnknown()

func (*ReplyJoin) XXX_Marshal 

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

func (*ReplyJoin) XXX_Merge 

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

func (*ReplyJoin) XXX_Size 

func (m *ReplyJoin) XXX_Size() int

func (*ReplyJoin) XXX_Unmarshal 

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

type ReplyLog added in v0.7.192 

type ReplyLog struct {
	Logs                 *LogInfo `protobuf:"bytes,1,opt,name=logs,proto3" json:"logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ReplyLog - for REPLY_LOG

func (*ReplyLog) Descriptor added in v0.7.192 

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

func (*ReplyLog) GetLogs added in v0.7.192 

func (m *ReplyLog) GetLogs() *LogInfo

func (*ReplyLog) ProtoMessage added in v0.7.192 

func (*ReplyLog) ProtoMessage()

func (*ReplyLog) Reset added in v0.7.192 

func (m *ReplyLog) Reset()

func (*ReplyLog) String added in v0.7.192 

func (m *ReplyLog) String() string

func (*ReplyLog) XXX_DiscardUnknown added in v0.7.192 

func (m *ReplyLog) XXX_DiscardUnknown()

func (*ReplyLog) XXX_Marshal added in v0.7.192 

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

func (*ReplyLog) XXX_Merge added in v0.7.192 

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

func (*ReplyLog) XXX_Size added in v0.7.192 

func (m *ReplyLog) XXX_Size() int

func (*ReplyLog) XXX_Unmarshal added in v0.7.192 

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

type ReplyLogList added in v0.7.192 

type ReplyLogList struct {
	Logs                 []*LogInfo `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

ReplyLogList - for REPLY_LOGLIST

func (*ReplyLogList) Descriptor added in v0.7.192 

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

func (*ReplyLogList) GetLogs added in v0.7.192 

func (m *ReplyLogList) GetLogs() []*LogInfo

func (*ReplyLogList) ProtoMessage added in v0.7.192 

func (*ReplyLogList) ProtoMessage()

func (*ReplyLogList) Reset added in v0.7.192 

func (m *ReplyLogList) Reset()

func (*ReplyLogList) String added in v0.7.192 

func (m *ReplyLogList) String() string

func (*ReplyLogList) XXX_DiscardUnknown added in v0.7.192 

func (m *ReplyLogList) XXX_DiscardUnknown()

func (*ReplyLogList) XXX_Marshal added in v0.7.192 

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

func (*ReplyLogList) XXX_Merge added in v0.7.192 

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

func (*ReplyLogList) XXX_Size added in v0.7.192 

func (m *ReplyLogList) XXX_Size() int

func (*ReplyLogList) XXX_Unmarshal added in v0.7.192 

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

type ReplyMsgState added in v0.7.157 

type ReplyMsgState struct {
	MsgID int64 `protobuf:"varint,1,opt,name=msgID,proto3" json:"msgID,omitempty"`
	// state - if state < 0, then message is lost
	State                int32    `protobuf:"varint,2,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ReplyMsgState - for REPLY_MSG_STATE

func (*ReplyMsgState) Descriptor added in v0.7.157 

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

func (*ReplyMsgState) GetMsgID added in v0.7.157 

func (m *ReplyMsgState) GetMsgID() int64

func (*ReplyMsgState) GetState added in v0.7.157 

func (m *ReplyMsgState) GetState() int32

func (*ReplyMsgState) ProtoMessage added in v0.7.157 

func (*ReplyMsgState) ProtoMessage()

func (*ReplyMsgState) Reset added in v0.7.157 

func (m *ReplyMsgState) Reset()

func (*ReplyMsgState) String added in v0.7.157 

func (m *ReplyMsgState) String() string

func (*ReplyMsgState) XXX_DiscardUnknown added in v0.7.157 

func (m *ReplyMsgState) XXX_DiscardUnknown()

func (*ReplyMsgState) XXX_Marshal added in v0.7.157 

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

func (*ReplyMsgState) XXX_Merge added in v0.7.157 

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

func (*ReplyMsgState) XXX_Size added in v0.7.157 

func (m *ReplyMsgState) XXX_Size() int

func (*ReplyMsgState) XXX_Unmarshal added in v0.7.157 

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

type ReplyMyNodesVersion added in v0.7.208 

type ReplyMyNodesVersion struct {
	// myNodesVersion - my nodes version
	MyNodesVersion       string   `protobuf:"bytes,1,opt,name=myNodesVersion,proto3" json:"myNodesVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ReplyMyNodesVersion - for REPLY_MYNODESVERSION

func (*ReplyMyNodesVersion) Descriptor added in v0.7.208 

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

func (*ReplyMyNodesVersion) GetMyNodesVersion added in v0.7.208 

func (m *ReplyMyNodesVersion) GetMyNodesVersion() string

func (*ReplyMyNodesVersion) ProtoMessage added in v0.7.208 

func (*ReplyMyNodesVersion) ProtoMessage()

func (*ReplyMyNodesVersion) Reset added in v0.7.208 

func (m *ReplyMyNodesVersion) Reset()

func (*ReplyMyNodesVersion) String added in v0.7.208 

func (m *ReplyMyNodesVersion) String() string

func (*ReplyMyNodesVersion) XXX_DiscardUnknown added in v0.7.208 

func (m *ReplyMyNodesVersion) XXX_DiscardUnknown()

func (*ReplyMyNodesVersion) XXX_Marshal added in v0.7.208 

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

func (*ReplyMyNodesVersion) XXX_Merge added in v0.7.208 

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

func (*ReplyMyNodesVersion) XXX_Size added in v0.7.208 

func (m *ReplyMyNodesVersion) XXX_Size() int

func (*ReplyMyNodesVersion) XXX_Unmarshal added in v0.7.208 

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

type ReplyTransferFile added in v0.7.130 

type ReplyTransferFile struct {
	Md5String            string   `protobuf:"bytes,1,opt,name=md5String,proto3" json:"md5String,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ReplyTransferFile - used in REPLY_TRANSFER_FILE

func (*ReplyTransferFile) Descriptor added in v0.7.130 

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

func (*ReplyTransferFile) GetMd5String added in v0.7.130 

func (m *ReplyTransferFile) GetMd5String() string

func (*ReplyTransferFile) ProtoMessage added in v0.7.130 

func (*ReplyTransferFile) ProtoMessage()

func (*ReplyTransferFile) Reset added in v0.7.130 

func (m *ReplyTransferFile) Reset()

func (*ReplyTransferFile) String added in v0.7.130 

func (m *ReplyTransferFile) String() string

func (*ReplyTransferFile) XXX_DiscardUnknown added in v0.7.130 

func (m *ReplyTransferFile) XXX_DiscardUnknown()

func (*ReplyTransferFile) XXX_Marshal added in v0.7.130 

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

func (*ReplyTransferFile) XXX_Merge added in v0.7.130 

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

func (*ReplyTransferFile) XXX_Size added in v0.7.130 

func (m *ReplyTransferFile) XXX_Size() int

func (*ReplyTransferFile) XXX_Unmarshal added in v0.7.130 

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

type ReplyUpdTask added in v0.7.166 

type ReplyUpdTask struct {
	IsOK                 bool     `protobuf:"varint,1,opt,name=isOK,proto3" json:"isOK,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ReplyUpdTask

func (*ReplyUpdTask) Descriptor added in v0.7.166 

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

func (*ReplyUpdTask) GetIsOK added in v0.7.166 

func (m *ReplyUpdTask) GetIsOK() bool

func (*ReplyUpdTask) ProtoMessage added in v0.7.166 

func (*ReplyUpdTask) ProtoMessage()

func (*ReplyUpdTask) Reset added in v0.7.166 

func (m *ReplyUpdTask) Reset()

func (*ReplyUpdTask) String added in v0.7.166 

func (m *ReplyUpdTask) String() string

func (*ReplyUpdTask) XXX_DiscardUnknown added in v0.7.166 

func (m *ReplyUpdTask) XXX_DiscardUnknown()

func (*ReplyUpdTask) XXX_Marshal added in v0.7.166 

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

func (*ReplyUpdTask) XXX_Merge added in v0.7.166 

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

func (*ReplyUpdTask) XXX_Size added in v0.7.166 

func (m *ReplyUpdTask) XXX_Size() int

func (*ReplyUpdTask) XXX_Unmarshal added in v0.7.166 

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

type RequestFile added in v0.6.12 

type RequestFile struct {
	Filename             string   `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Ft                   FileType `protobuf:"varint,2,opt,name=ft,proto3,enum=jarviscorepb.FileType" json:"ft,omitempty"`
	Start                int64    `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	Length               int64    `protobuf:"varint,4,opt,name=length,proto3" json:"length,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RequestFile - request file

func (*RequestFile) Descriptor added in v0.6.12 

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

func (*RequestFile) GetFilename added in v0.6.12 

func (m *RequestFile) GetFilename() string

func (*RequestFile) GetFt added in v0.7.130 

func (m *RequestFile) GetFt() FileType

func (*RequestFile) GetLength added in v0.7.130 

func (m *RequestFile) GetLength() int64

func (*RequestFile) GetStart added in v0.7.130 

func (m *RequestFile) GetStart() int64

func (*RequestFile) ProtoMessage added in v0.6.12 

func (*RequestFile) ProtoMessage()

func (*RequestFile) Reset added in v0.6.12 

func (m *RequestFile) Reset()

func (*RequestFile) String added in v0.6.12 

func (m *RequestFile) String() string

func (*RequestFile) XXX_DiscardUnknown added in v0.6.12 

func (m *RequestFile) XXX_DiscardUnknown()

func (*RequestFile) XXX_Marshal added in v0.6.12 

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

func (*RequestFile) XXX_Merge added in v0.6.12 

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

func (*RequestFile) XXX_Size added in v0.6.12 

func (m *RequestFile) XXX_Size() int

func (*RequestFile) XXX_Unmarshal added in v0.6.12 

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

type RequestLog added in v0.7.192 

type RequestLog struct {
	Log                  *LogInfo `protobuf:"bytes,1,opt,name=log,proto3" json:"log,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RequestLog - for REQUEST_LOG

func (*RequestLog) Descriptor added in v0.7.192 

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

func (*RequestLog) GetLog added in v0.7.192 

func (m *RequestLog) GetLog() *LogInfo

func (*RequestLog) ProtoMessage added in v0.7.192 

func (*RequestLog) ProtoMessage()

func (*RequestLog) Reset added in v0.7.192 

func (m *RequestLog) Reset()

func (*RequestLog) String added in v0.7.192 

func (m *RequestLog) String() string

func (*RequestLog) XXX_DiscardUnknown added in v0.7.192 

func (m *RequestLog) XXX_DiscardUnknown()

func (*RequestLog) XXX_Marshal added in v0.7.192 

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

func (*RequestLog) XXX_Merge added in v0.7.192 

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

func (*RequestLog) XXX_Size added in v0.7.192 

func (m *RequestLog) XXX_Size() int

func (*RequestLog) XXX_Unmarshal added in v0.7.192 

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

type RequestMsgState added in v0.7.157 

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

RequestMsgState - for REQUEST_MSG_STATE

func (*RequestMsgState) Descriptor added in v0.7.157 

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

func (*RequestMsgState) GetMsgID added in v0.7.157 

func (m *RequestMsgState) GetMsgID() int64

func (*RequestMsgState) ProtoMessage added in v0.7.157 

func (*RequestMsgState) ProtoMessage()

func (*RequestMsgState) Reset added in v0.7.157 

func (m *RequestMsgState) Reset()

func (*RequestMsgState) String added in v0.7.157 

func (m *RequestMsgState) String() string

func (*RequestMsgState) XXX_DiscardUnknown added in v0.7.157 

func (m *RequestMsgState) XXX_DiscardUnknown()

func (*RequestMsgState) XXX_Marshal added in v0.7.157 

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

func (*RequestMsgState) XXX_Merge added in v0.7.157 

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

func (*RequestMsgState) XXX_Size added in v0.7.157 

func (m *RequestMsgState) XXX_Size() int

func (*RequestMsgState) XXX_Unmarshal added in v0.7.157 

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

type RequestNodes2 added in v0.7.201 

type RequestNodes2 struct {
	// isNeedLocalHost - is need give me localhost node
	IsNeedLocalHost bool `protobuf:"varint,1,opt,name=isNeedLocalHost,proto3" json:"isNeedLocalHost,omitempty"`
	// myNodesVersion - my nodes version
	MyNodesVersion string `protobuf:"bytes,2,opt,name=myNodesVersion,proto3" json:"myNodesVersion,omitempty"`
	// nodesVersion - your nodes version
	NodesVersion         string   `protobuf:"bytes,3,opt,name=nodesVersion,proto3" json:"nodesVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RequestNodes2 - for REQUEST_NODES2

func (*RequestNodes2) Descriptor added in v0.7.201 

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

func (*RequestNodes2) GetIsNeedLocalHost added in v0.7.201 

func (m *RequestNodes2) GetIsNeedLocalHost() bool

func (*RequestNodes2) GetMyNodesVersion added in v0.7.208 

func (m *RequestNodes2) GetMyNodesVersion() string

func (*RequestNodes2) GetNodesVersion added in v0.7.208 

func (m *RequestNodes2) GetNodesVersion() string

func (*RequestNodes2) ProtoMessage added in v0.7.201 

func (*RequestNodes2) ProtoMessage()

func (*RequestNodes2) Reset added in v0.7.201 

func (m *RequestNodes2) Reset()

func (*RequestNodes2) String added in v0.7.201 

func (m *RequestNodes2) String() string

func (*RequestNodes2) XXX_DiscardUnknown added in v0.7.201 

func (m *RequestNodes2) XXX_DiscardUnknown()

func (*RequestNodes2) XXX_Marshal added in v0.7.201 

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

func (*RequestNodes2) XXX_Merge added in v0.7.201 

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

func (*RequestNodes2) XXX_Size added in v0.7.201 

func (m *RequestNodes2) XXX_Size() int

func (*RequestNodes2) XXX_Unmarshal added in v0.7.201 

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

type TASKTYPE added in v0.7.178 

type TASKTYPE int32

jarvis task type 

const (
	// normal
	TASKTYPE_NORMAL TASKTYPE = 0
	// service
	TASKTYPE_SERVICE TASKTYPE = 1
)

func (TASKTYPE) EnumDescriptor added in v0.7.178 

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

func (TASKTYPE) String added in v0.7.178 

func (x TASKTYPE) String() string

type UpdateNode added in v0.7.130 

type UpdateNode struct {
	// nodetype version
	NodeTypeVersion string `protobuf:"bytes,1,opt,name=nodeTypeVersion,proto3" json:"nodeTypeVersion,omitempty"`
	// node type
	NodeType string `protobuf:"bytes,2,opt,name=nodeType,proto3" json:"nodeType,omitempty"`
	// Just need to restart the node
	IsOnlyRestart        bool     `protobuf:"varint,3,opt,name=isOnlyRestart,proto3" json:"isOnlyRestart,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

UpdateNode - for UPDATENODE

func (*UpdateNode) Descriptor added in v0.7.130 

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

func (*UpdateNode) GetIsOnlyRestart added in v0.7.185 

func (m *UpdateNode) GetIsOnlyRestart() bool

func (*UpdateNode) GetNodeType added in v0.7.130 

func (m *UpdateNode) GetNodeType() string

func (*UpdateNode) GetNodeTypeVersion added in v0.7.130 

func (m *UpdateNode) GetNodeTypeVersion() string

func (*UpdateNode) ProtoMessage added in v0.7.130 

func (*UpdateNode) ProtoMessage()

func (*UpdateNode) Reset added in v0.7.130 

func (m *UpdateNode) Reset()

func (*UpdateNode) String added in v0.7.130 

func (m *UpdateNode) String() string

func (*UpdateNode) XXX_DiscardUnknown added in v0.7.130 

func (m *UpdateNode) XXX_DiscardUnknown()

func (*UpdateNode) XXX_Marshal added in v0.7.130 

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

func (*UpdateNode) XXX_Merge added in v0.7.130 

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

func (*UpdateNode) XXX_Size added in v0.7.130 

func (m *UpdateNode) XXX_Size() int

func (*UpdateNode) XXX_Unmarshal added in v0.7.130 

func (m *UpdateNode) XXX_Unmarshal(b []byte) 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.