Documentation ¶
Index ¶
- Variables
- type Message
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) GetCostBytes() []byte
- func (m *Message) GetEncCostFromOther() []byte
- func (m *Message) GetEncGradFromOther() []byte
- func (m *Message) GetFrom() string
- func (m *Message) GetGradBytes() []byte
- func (m *Message) GetHomoPubkey() []byte
- func (m *Message) GetLoopRound() uint64
- func (m *Message) GetPartBytes() []byte
- func (m *Message) GetPauseRound() uint64
- func (m *Message) GetStopped() bool
- func (m *Message) GetTo() string
- func (m *Message) GetTrainSet() []*common.TrainTaskResult_FileRow
- func (m *Message) GetTriggerRound() uint64
- func (m *Message) GetType() MessageType
- func (m *Message) GetVlLPsiReEncIDsReq() *mpc.VLPsiReEncIDsRequest
- func (m *Message) GetVlLPsiReEncIDsResp() *mpc.VLPsiReEncIDsResponse
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) String() string
- func (m *Message) XXX_DiscardUnknown()
- func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Message) XXX_Merge(src proto.Message)
- func (m *Message) XXX_Size() int
- func (m *Message) XXX_Unmarshal(b []byte) error
- type MessageType
- type PredictMessage
- func (*PredictMessage) Descriptor() ([]byte, []int)
- func (m *PredictMessage) GetFrom() string
- func (m *PredictMessage) GetPredictPart() []float64
- func (m *PredictMessage) GetTo() string
- func (m *PredictMessage) GetType() MessageType
- func (m *PredictMessage) GetVlLPsiReEncIDsReq() *mpc.VLPsiReEncIDsRequest
- func (m *PredictMessage) GetVlLPsiReEncIDsResp() *mpc.VLPsiReEncIDsResponse
- func (*PredictMessage) ProtoMessage()
- func (m *PredictMessage) Reset()
- func (m *PredictMessage) String() string
- func (m *PredictMessage) XXX_DiscardUnknown()
- func (m *PredictMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PredictMessage) XXX_Merge(src proto.Message)
- func (m *PredictMessage) XXX_Size() int
- func (m *PredictMessage) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var MessageType_name = map[int32]string{
0: "MsgPsiEnc",
1: "MsgPsiAskReEnc",
2: "MsgPsiReEnc",
3: "MsgPsiIntersect",
4: "MsgTrainHup",
5: "MsgHomoPubkey",
6: "MsgTrainLoop",
7: "MsgTrainCalLocalGradCost",
8: "MsgTrainPartBytes",
9: "MsgTrainCalEncGradCost",
10: "MsgTrainEncGradCost",
11: "MsgTrainDecLocalGradCost",
12: "MsgTrainGradAndCost",
13: "MsgTrainUpdCostGrad",
14: "MsgTrainStatus",
15: "MsgTrainCheckStatus",
16: "MsgTrainModels",
17: "MsgCheckPauseRound",
18: "MsgTrainSet",
19: "MsgContinueLoop",
51: "MsgPredictHup",
52: "MsgPredictPart",
53: "MsgPredictFinal",
}
View Source
var MessageType_value = map[string]int32{
"MsgPsiEnc": 0,
"MsgPsiAskReEnc": 1,
"MsgPsiReEnc": 2,
"MsgPsiIntersect": 3,
"MsgTrainHup": 4,
"MsgHomoPubkey": 5,
"MsgTrainLoop": 6,
"MsgTrainCalLocalGradCost": 7,
"MsgTrainPartBytes": 8,
"MsgTrainCalEncGradCost": 9,
"MsgTrainEncGradCost": 10,
"MsgTrainDecLocalGradCost": 11,
"MsgTrainGradAndCost": 12,
"MsgTrainUpdCostGrad": 13,
"MsgTrainStatus": 14,
"MsgTrainCheckStatus": 15,
"MsgTrainModels": 16,
"MsgCheckPauseRound": 17,
"MsgTrainSet": 18,
"MsgContinueLoop": 19,
"MsgPredictHup": 51,
"MsgPredictPart": 52,
"MsgPredictFinal": 53,
}
Functions ¶
This section is empty.
Types ¶
type Message ¶
type Message struct { Type MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=logic_reg_vl.MessageType" json:"type,omitempty"` To string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"` From string `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"` LoopRound uint64 `protobuf:"varint,4,opt,name=loopRound,proto3" json:"loopRound,omitempty"` VlLPsiReEncIDsReq *mpc.VLPsiReEncIDsRequest `protobuf:"bytes,5,opt,name=vlLPsiReEncIDsReq,proto3" json:"vlLPsiReEncIDsReq,omitempty"` VlLPsiReEncIDsResp *mpc.VLPsiReEncIDsResponse `protobuf:"bytes,6,opt,name=vlLPsiReEncIDsResp,proto3" json:"vlLPsiReEncIDsResp,omitempty"` HomoPubkey []byte `protobuf:"bytes,7,opt,name=homoPubkey,proto3" json:"homoPubkey,omitempty"` PartBytes []byte `protobuf:"bytes,8,opt,name=PartBytes,proto3" json:"PartBytes,omitempty"` EncGradFromOther []byte `protobuf:"bytes,9,opt,name=encGradFromOther,proto3" json:"encGradFromOther,omitempty"` EncCostFromOther []byte `protobuf:"bytes,10,opt,name=encCostFromOther,proto3" json:"encCostFromOther,omitempty"` GradBytes []byte `protobuf:"bytes,11,opt,name=gradBytes,proto3" json:"gradBytes,omitempty"` CostBytes []byte `protobuf:"bytes,12,opt,name=costBytes,proto3" json:"costBytes,omitempty"` Stopped bool `protobuf:"varint,13,opt,name=stopped,proto3" json:"stopped,omitempty"` TrainSet []*common.TrainTaskResult_FileRow `protobuf:"bytes,14,rep,name=trainSet,proto3" json:"trainSet,omitempty"` PauseRound uint64 `protobuf:"varint,15,opt,name=pauseRound,proto3" json:"pauseRound,omitempty"` TriggerRound uint64 `protobuf:"varint,16,opt,name=triggerRound,proto3" json:"triggerRound,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Message) Descriptor ¶
func (*Message) GetCostBytes ¶
func (*Message) GetEncCostFromOther ¶
func (*Message) GetEncGradFromOther ¶
func (*Message) GetGradBytes ¶
func (*Message) GetHomoPubkey ¶
func (*Message) GetLoopRound ¶
func (*Message) GetPartBytes ¶
func (*Message) GetPauseRound ¶
func (*Message) GetStopped ¶
func (*Message) GetTrainSet ¶
func (m *Message) GetTrainSet() []*common.TrainTaskResult_FileRow
func (*Message) GetTriggerRound ¶
func (*Message) GetType ¶
func (m *Message) GetType() MessageType
func (*Message) GetVlLPsiReEncIDsReq ¶
func (m *Message) GetVlLPsiReEncIDsReq() *mpc.VLPsiReEncIDsRequest
func (*Message) GetVlLPsiReEncIDsResp ¶
func (m *Message) GetVlLPsiReEncIDsResp() *mpc.VLPsiReEncIDsResponse
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) XXX_DiscardUnknown ¶
func (m *Message) XXX_DiscardUnknown()
func (*Message) XXX_Marshal ¶
func (*Message) XXX_Unmarshal ¶
type MessageType ¶
type MessageType int32
MessageType defines the type of message with which communicate with nodes in cluster, and in some way it indicates the phase of learning Some types are for local message which is not passed between nodes
const ( MessageType_MsgPsiEnc MessageType = 0 MessageType_MsgPsiAskReEnc MessageType = 1 MessageType_MsgPsiReEnc MessageType = 2 MessageType_MsgPsiIntersect MessageType = 3 MessageType_MsgTrainHup MessageType = 4 MessageType_MsgHomoPubkey MessageType = 5 MessageType_MsgTrainLoop MessageType = 6 MessageType_MsgTrainCalLocalGradCost MessageType = 7 MessageType_MsgTrainPartBytes MessageType = 8 MessageType_MsgTrainCalEncGradCost MessageType = 9 MessageType_MsgTrainEncGradCost MessageType = 10 MessageType_MsgTrainDecLocalGradCost MessageType = 11 MessageType_MsgTrainGradAndCost MessageType = 12 MessageType_MsgTrainUpdCostGrad MessageType = 13 MessageType_MsgTrainStatus MessageType = 14 MessageType_MsgTrainCheckStatus MessageType = 15 MessageType_MsgTrainModels MessageType = 16 MessageType_MsgCheckPauseRound MessageType = 17 MessageType_MsgTrainSet MessageType = 18 MessageType_MsgContinueLoop MessageType = 19 MessageType_MsgPredictHup MessageType = 51 MessageType_MsgPredictPart MessageType = 52 MessageType_MsgPredictFinal MessageType = 53 )
func (MessageType) EnumDescriptor ¶
func (MessageType) EnumDescriptor() ([]byte, []int)
func (MessageType) String ¶
func (x MessageType) String() string
type PredictMessage ¶
type PredictMessage struct { Type MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=logic_reg_vl.MessageType" json:"type,omitempty"` To string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"` From string `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"` VlLPsiReEncIDsReq *mpc.VLPsiReEncIDsRequest `protobuf:"bytes,4,opt,name=vlLPsiReEncIDsReq,proto3" json:"vlLPsiReEncIDsReq,omitempty"` VlLPsiReEncIDsResp *mpc.VLPsiReEncIDsResponse `protobuf:"bytes,5,opt,name=vlLPsiReEncIDsResp,proto3" json:"vlLPsiReEncIDsResp,omitempty"` PredictPart []float64 `protobuf:"fixed64,6,rep,packed,name=predictPart,proto3" json:"predictPart,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PredictMessage) Descriptor ¶
func (*PredictMessage) Descriptor() ([]byte, []int)
func (*PredictMessage) GetFrom ¶
func (m *PredictMessage) GetFrom() string
func (*PredictMessage) GetPredictPart ¶
func (m *PredictMessage) GetPredictPart() []float64
func (*PredictMessage) GetTo ¶
func (m *PredictMessage) GetTo() string
func (*PredictMessage) GetType ¶
func (m *PredictMessage) GetType() MessageType
func (*PredictMessage) GetVlLPsiReEncIDsReq ¶
func (m *PredictMessage) GetVlLPsiReEncIDsReq() *mpc.VLPsiReEncIDsRequest
func (*PredictMessage) GetVlLPsiReEncIDsResp ¶
func (m *PredictMessage) GetVlLPsiReEncIDsResp() *mpc.VLPsiReEncIDsResponse
func (*PredictMessage) ProtoMessage ¶
func (*PredictMessage) ProtoMessage()
func (*PredictMessage) Reset ¶
func (m *PredictMessage) Reset()
func (*PredictMessage) String ¶
func (m *PredictMessage) String() string
func (*PredictMessage) XXX_DiscardUnknown ¶
func (m *PredictMessage) XXX_DiscardUnknown()
func (*PredictMessage) XXX_Marshal ¶
func (m *PredictMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PredictMessage) XXX_Merge ¶
func (m *PredictMessage) XXX_Merge(src proto.Message)
func (*PredictMessage) XXX_Size ¶
func (m *PredictMessage) XXX_Size() int
func (*PredictMessage) XXX_Unmarshal ¶
func (m *PredictMessage) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.