Documentation ¶
Index ¶
- Variables
- type Message
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) GetAby3ShareData() []byte
- func (m *Message) GetAby3ShareFile() []byte
- 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) GetRole() uint64
- func (m *Message) GetStopped() bool
- func (m *Message) GetTo() string
- func (m *Message) GetType() MessageType
- func (m *Message) GetVecSize() uint64
- 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 (dst *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) GetAby3ShareData() []byte
- func (m *PredictMessage) GetAby3ShareFile() []byte
- func (m *PredictMessage) GetFrom() string
- func (m *PredictMessage) GetPredictPart() []float64
- func (m *PredictMessage) GetRole() uint64
- func (m *PredictMessage) GetTo() string
- func (m *PredictMessage) GetType() MessageType
- func (m *PredictMessage) GetVecSize() uint64
- 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 (dst *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: "MsgFLENVPrepare",
5: "MsgFLDataPrepare",
6: "MsgFLDataGenerate",
7: "MsgFLDataSend",
8: "MsgFLDataExchange",
9: "MsgFLDataStatus",
10: "MsgTrain",
17: "MsgPredictHup",
18: "MsgPredictResultSend",
19: "MsgPredictResultExchange",
20: "MsgPredictResultStatus",
21: "MsgPredictResultRecovery",
22: "MsgPredictStop",
}
View Source
var MessageType_value = map[string]int32{
"MsgPsiEnc": 0,
"MsgPsiAskReEnc": 1,
"MsgPsiReEnc": 2,
"MsgPsiIntersect": 3,
"MsgFLENVPrepare": 4,
"MsgFLDataPrepare": 5,
"MsgFLDataGenerate": 6,
"MsgFLDataSend": 7,
"MsgFLDataExchange": 8,
"MsgFLDataStatus": 9,
"MsgTrain": 10,
"MsgPredictHup": 17,
"MsgPredictResultSend": 18,
"MsgPredictResultExchange": 19,
"MsgPredictResultStatus": 20,
"MsgPredictResultRecovery": 21,
"MsgPredictStop": 22,
}
Functions ¶
This section is empty.
Types ¶
type Message ¶
type Message struct { Type MessageType `protobuf:"varint,1,opt,name=type,enum=dnn_paddlefl_vl.MessageType" json:"type,omitempty"` To string `protobuf:"bytes,2,opt,name=to" json:"to,omitempty"` From string `protobuf:"bytes,3,opt,name=from" json:"from,omitempty"` LoopRound uint64 `protobuf:"varint,4,opt,name=loopRound" json:"loopRound,omitempty"` VlLPsiReEncIDsReq *mpc.VLPsiReEncIDsRequest `protobuf:"bytes,5,opt,name=vlLPsiReEncIDsReq" json:"vlLPsiReEncIDsReq,omitempty"` VlLPsiReEncIDsResp *mpc.VLPsiReEncIDsResponse `protobuf:"bytes,6,opt,name=vlLPsiReEncIDsResp" 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" json:"stopped,omitempty"` VecSize uint64 `protobuf:"varint,16,opt,name=vecSize" json:"vecSize,omitempty"` Role uint64 `protobuf:"varint,17,opt,name=role" json:"role,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Message) Descriptor ¶
func (*Message) GetAby3ShareData ¶
func (*Message) GetAby3ShareFile ¶
func (*Message) GetCostBytes ¶
func (*Message) GetEncCostFromOther ¶
func (*Message) GetEncGradFromOther ¶
func (*Message) GetGradBytes ¶
func (*Message) GetHomoPubkey ¶
func (*Message) GetLoopRound ¶
func (*Message) GetPartBytes ¶
func (*Message) GetStopped ¶
func (*Message) GetType ¶
func (m *Message) GetType() MessageType
func (*Message) GetVecSize ¶
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_MsgFLENVPrepare MessageType = 4 MessageType_MsgFLDataPrepare MessageType = 5 MessageType_MsgFLDataGenerate MessageType = 6 MessageType_MsgFLDataSend MessageType = 7 MessageType_MsgFLDataExchange MessageType = 8 MessageType_MsgFLDataStatus MessageType = 9 MessageType_MsgTrain MessageType = 10 MessageType_MsgPredictHup MessageType = 17 MessageType_MsgPredictResultSend MessageType = 18 MessageType_MsgPredictResultExchange MessageType = 19 MessageType_MsgPredictResultStatus MessageType = 20 MessageType_MsgPredictResultRecovery MessageType = 21 MessageType_MsgPredictStop MessageType = 22 )
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,enum=dnn_paddlefl_vl.MessageType" json:"type,omitempty"` To string `protobuf:"bytes,2,opt,name=to" json:"to,omitempty"` From string `protobuf:"bytes,3,opt,name=from" json:"from,omitempty"` VlLPsiReEncIDsReq *mpc.VLPsiReEncIDsRequest `protobuf:"bytes,4,opt,name=vlLPsiReEncIDsReq" json:"vlLPsiReEncIDsReq,omitempty"` VlLPsiReEncIDsResp *mpc.VLPsiReEncIDsResponse `protobuf:"bytes,5,opt,name=vlLPsiReEncIDsResp" json:"vlLPsiReEncIDsResp,omitempty"` PredictPart []float64 `protobuf:"fixed64,6,rep,packed,name=predictPart" json:"predictPart,omitempty"` VecSize uint64 `protobuf:"varint,9,opt,name=vecSize" json:"vecSize,omitempty"` Role uint64 `protobuf:"varint,10,opt,name=role" json:"role,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PredictMessage) Descriptor ¶
func (*PredictMessage) Descriptor() ([]byte, []int)
func (*PredictMessage) GetAby3ShareData ¶
func (m *PredictMessage) GetAby3ShareData() []byte
func (*PredictMessage) GetAby3ShareFile ¶
func (m *PredictMessage) GetAby3ShareFile() []byte
func (*PredictMessage) GetFrom ¶
func (m *PredictMessage) GetFrom() string
func (*PredictMessage) GetPredictPart ¶
func (m *PredictMessage) GetPredictPart() []float64
func (*PredictMessage) GetRole ¶
func (m *PredictMessage) GetRole() uint64
func (*PredictMessage) GetTo ¶
func (m *PredictMessage) GetTo() string
func (*PredictMessage) GetType ¶
func (m *PredictMessage) GetType() MessageType
func (*PredictMessage) GetVecSize ¶
func (m *PredictMessage) GetVecSize() uint64
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 (dst *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.