logic_reg_vl

package
v0.0.0-...-ebe581b Latest Latest
Warning

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

 Go to latest Published: Mar 22, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

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) Descriptor() ([]byte, []int)

func (*Message) GetCostBytes 

func (m *Message) GetCostBytes() []byte

func (*Message) GetEncCostFromOther 

func (m *Message) GetEncCostFromOther() []byte

func (*Message) GetEncGradFromOther 

func (m *Message) GetEncGradFromOther() []byte

func (*Message) GetFrom 

func (m *Message) GetFrom() string

func (*Message) GetGradBytes 

func (m *Message) GetGradBytes() []byte

func (*Message) GetHomoPubkey 

func (m *Message) GetHomoPubkey() []byte

func (*Message) GetLoopRound 

func (m *Message) GetLoopRound() uint64

func (*Message) GetPartBytes 

func (m *Message) GetPartBytes() []byte

func (*Message) GetPauseRound 

func (m *Message) GetPauseRound() uint64

func (*Message) GetStopped 

func (m *Message) GetStopped() bool

func (*Message) GetTo 

func (m *Message) GetTo() string

func (*Message) GetTrainSet 

func (m *Message) GetTrainSet() []*common.TrainTaskResult_FileRow

func (*Message) GetTriggerRound 

func (m *Message) GetTriggerRound() uint64

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) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

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

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.