job

type Aggregator int32

type CmdResult struct {
	Status CmdResult_Status `protobuf:"varint,1,opt,name=status,enum=job.CmdResult_Status" json:"status,omitempty"`
	Msg    string           `protobuf:"bytes,2,opt,name=msg" json:"msg,omitempty"`
	Result *SMCResult       `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"`
	// Partly filled on receiver side (e.g. peer ID)
	Metadata map[string]string `` /* 136-byte string literal not displayed */
}

type CmdResult_Status int32

type DataOrigin int32

type DebugPhase struct {
	Ping       int32 `protobuf:"varint,1,opt,name=ping" json:"ping,omitempty"`
	MorePhases bool  `protobuf:"varint,3,opt,name=morePhases" json:"morePhases,omitempty"`
	// options configures the peers' environment. Otherwise, it is empty.
	Options map[string]*Option `` /* 134-byte string literal not displayed */
}

type LinkingPhase struct {
}

type MetadataKey int32

type Option struct {
	// Types that are valid to be assigned to OptValue:
	//	*Option_Str
	//	*Option_Dec
	OptValue isOption_OptValue `protobuf_oneof:"optValue"`
}

type Option_Dec struct {
	Dec int32 `protobuf:"varint,2,opt,name=dec,oneof"`
}

type Option_Str struct {
	Str string `protobuf:"bytes,1,opt,name=str,oneof"`
}

type PreparePhase struct {
	Participants []*PreparePhase_Participant `protobuf:"bytes,1,rep,name=participants" json:"participants,omitempty"`
	SmcTask      *SMCTask                    `protobuf:"bytes,3,opt,name=smcTask" json:"smcTask,omitempty"`
}

type PreparePhase_Participant struct {
	// Fixed authentication (certificate) based identity
	AuthID string `protobuf:"bytes,1,opt,name=authID" json:"authID,omitempty"`
	// Temporarily assigned peer identity for the current SMC task
	SmcPeerID int32 `protobuf:"varint,2,opt,name=smcPeerID" json:"smcPeerID,omitempty"`
	// Address and port of the service (address:port)
	Endpoint string `protobuf:"bytes,3,opt,name=endpoint" json:"endpoint,omitempty"`
}

type SMCCmd struct {
	SessionID string       `protobuf:"bytes,1,opt,name=sessionID" json:"sessionID,omitempty"`
	SmcPeerID int32        `protobuf:"varint,5,opt,name=smcPeerID" json:"smcPeerID,omitempty"`
	State     SMCCmd_Phase `protobuf:"varint,2,opt,name=state,enum=job.SMCCmd_Phase" json:"state,omitempty"`
	// Payload packet
	//
	// Types that are valid to be assigned to Payload:
	//	*SMCCmd_Prepare
	//	*SMCCmd_Link
	//	*SMCCmd_Session
	//	*SMCCmd_Debug
	Payload isSMCCmd_Payload `protobuf_oneof:"payload"`
}

type SMCCmd_Debug struct {
	Debug *DebugPhase `protobuf:"bytes,9,opt,name=debug,oneof"`
}

type SMCCmd_Link struct {
	Link *LinkingPhase `protobuf:"bytes,6,opt,name=link,oneof"`
}

type SMCCmd_Phase int32

type SMCCmd_Prepare struct {
	Prepare *PreparePhase `protobuf:"bytes,3,opt,name=prepare,oneof"`
}

type SMCCmd_Session struct {
	Session *SessionPhase `protobuf:"bytes,4,opt,name=session,oneof"`
}

type SMCResult struct {
	Res float64 `protobuf:"fixed64,1,opt,name=res" json:"res,omitempty"`
}

type SMCTask struct {
	Set    string     `protobuf:"bytes,1,opt,name=set" json:"set,omitempty"`
	Source DataOrigin `protobuf:"varint,2,opt,name=source,enum=job.DataOrigin" json:"source,omitempty"`
	// Limit maximum number of data items to process from a (bigger) series. Default is 1.
	MaxDataItems int32 `protobuf:"varint,10,opt,name=maxDataItems" json:"maxDataItems,omitempty"`
	// (Pre)Selectors
	Aggregator      Aggregator                 `protobuf:"varint,4,opt,name=aggregator,enum=job.Aggregator" json:"aggregator,omitempty"`
	Options         map[string]*Option         `` /* 134-byte string literal not displayed */
	TicketSignature string                     `protobuf:"bytes,7,opt,name=ticketSignature" json:"ticketSignature,omitempty"`
	Issued          *google_protobuf.Timestamp `protobuf:"bytes,8,opt,name=issued" json:"issued,omitempty"`
	QuerySignature  string                     `protobuf:"bytes,9,opt,name=querySignature" json:"querySignature,omitempty"`
}

type SessionPhase struct {
	// Number of parallel operations if at least same number of data entities
	// are available on each peer. Must be smaller or equal to numDataItems.
	// Default is 1.
	ParallelBatchOps int32 `protobuf:"varint,2,opt,name=parallelBatchOps" json:"parallelBatchOps,omitempty"`
}