job

package
v0.0.0-...-496ee5d Latest Latest
Warning

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

 Go to latest Published: Sep 6, 2017 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package job is a generated protocol buffer package.

It is generated from these files: 

job/job.proto

It has these top-level messages: 

Option
SMCTask
PreparePhase
LinkingPhase
SessionPhase
DebugPhase
SMCCmd
CmdResult
SMCResult

Index

Constants

This section is empty.

Variables

View Source 
var Aggregator_name = map[int32]string{
	0:    "SUM",
	1:    "AVG",
	2:    "MEDIAN",
	3:    "STD_DEVIATION",
	1000: "DBG_PINGPONG",
	1001: "DBG_PINGPONG_10",
	1002: "DBG_PINGPONG_100",
	1024: "DBG_SET_CONFIG",
}
View Source 
var Aggregator_value = map[string]int32{
	"SUM":              0,
	"AVG":              1,
	"MEDIAN":           2,
	"STD_DEVIATION":    3,
	"DBG_PINGPONG":     1000,
	"DBG_PINGPONG_10":  1001,
	"DBG_PINGPONG_100": 1002,
	"DBG_SET_CONFIG":   1024,
}
View Source 
var CmdResult_Status_name = map[int32]string{
	0:   "SUCCESS",
	1:   "SUCCESS_DONE",
	32:  "ERR_CLASS_NORM",
	33:  "UNKNOWN_CMD",
	34:  "DENIED",
	64:  "ERR_CLASS_FAULT",
	65:  "ABORTED",
	128: "ERR_CLASS_COMM",
	129: "STREAM_ERR",
	192: "SEVERE_ERROR_CLASSES",
	224: "ALL_ERROR_CLASSES",
}
View Source 
var CmdResult_Status_value = map[string]int32{
	"SUCCESS":              0,
	"SUCCESS_DONE":         1,
	"ERR_CLASS_NORM":       32,
	"UNKNOWN_CMD":          33,
	"DENIED":               34,
	"ERR_CLASS_FAULT":      64,
	"ABORTED":              65,
	"ERR_CLASS_COMM":       128,
	"STREAM_ERR":           129,
	"SEVERE_ERROR_CLASSES": 192,
	"ALL_ERROR_CLASSES":    224,
}
View Source 
var DataOrigin_name = map[int32]string{
	0:      "TEMPERATURE",
	1:      "HUMIDITY",
	2:      "AMBIENT",
	3:      "AIR_PRESSURE",
	10:     "PRESENCE",
	999:    "RESERVED_999",
	1000:   "DYNAMIC_ASSIGNMENT_1000",
	99999:  "DYNAMIC_ASSIGNMENT_99999",
	100000: "RESERVED_100000",
}
View Source 
var DataOrigin_value = map[string]int32{
	"TEMPERATURE":              0,
	"HUMIDITY":                 1,
	"AMBIENT":                  2,
	"AIR_PRESSURE":             3,
	"PRESENCE":                 10,
	"RESERVED_999":             999,
	"DYNAMIC_ASSIGNMENT_1000":  1000,
	"DYNAMIC_ASSIGNMENT_99999": 99999,
	"RESERVED_100000":          100000,
}
View Source 
var MetadataKey_name = map[int32]string{
	0: "PEERID",
}
View Source 
var MetadataKey_value = map[string]int32{
	"PEERID": 0,
}
View Source 
var SMCCmd_Phase_name = map[int32]string{
	0:   "PREPARE",
	1:   "LINK",
	2:   "SESSION",
	126: "FINISH",
	127: "ABORT",
}
View Source 
var SMCCmd_Phase_value = map[string]int32{
	"PREPARE": 0,
	"LINK":    1,
	"SESSION": 2,
	"FINISH":  126,
	"ABORT":   127,
}

Functions

This section is empty.

Types

type Aggregator 

type Aggregator int32
const (
	Aggregator_SUM              Aggregator = 0
	Aggregator_AVG              Aggregator = 1
	Aggregator_MEDIAN           Aggregator = 2
	Aggregator_STD_DEVIATION    Aggregator = 3
	Aggregator_DBG_PINGPONG     Aggregator = 1000
	Aggregator_DBG_PINGPONG_10  Aggregator = 1001
	Aggregator_DBG_PINGPONG_100 Aggregator = 1002
	Aggregator_DBG_SET_CONFIG   Aggregator = 1024
)

func (Aggregator) EnumDescriptor 

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

func (Aggregator) String 

func (x Aggregator) String() string

type CmdResult 

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 */
}

func (*CmdResult) Descriptor 

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

func (*CmdResult) GetMetadata 

func (m *CmdResult) GetMetadata() map[string]string

func (*CmdResult) GetResult 

func (m *CmdResult) GetResult() *SMCResult

func (*CmdResult) ProtoMessage 

func (*CmdResult) ProtoMessage()

func (*CmdResult) Reset 

func (m *CmdResult) Reset()

func (*CmdResult) String 

func (m *CmdResult) String() string

type CmdResult_Status 

type CmdResult_Status int32
const (
	// Class: success and info
	CmdResult_SUCCESS      CmdResult_Status = 0
	CmdResult_SUCCESS_DONE CmdResult_Status = 1
	// Class: soft or recoverable errors (32 - 63)
	CmdResult_ERR_CLASS_NORM CmdResult_Status = 32
	CmdResult_UNKNOWN_CMD    CmdResult_Status = 33
	CmdResult_DENIED         CmdResult_Status = 34
	// Class: irreversible errors on peer side (64 - 127)
	CmdResult_ERR_CLASS_FAULT CmdResult_Status = 64
	CmdResult_ABORTED         CmdResult_Status = 65
	// Class: communication errors (128 - 255)
	CmdResult_ERR_CLASS_COMM       CmdResult_Status = 128
	CmdResult_STREAM_ERR           CmdResult_Status = 129
	CmdResult_SEVERE_ERROR_CLASSES CmdResult_Status = 192
	CmdResult_ALL_ERROR_CLASSES    CmdResult_Status = 224
)

func (CmdResult_Status) EnumDescriptor 

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

func (CmdResult_Status) String 

func (x CmdResult_Status) String() string

type DataOrigin 

type DataOrigin int32
const (
	DataOrigin_TEMPERATURE  DataOrigin = 0
	DataOrigin_HUMIDITY     DataOrigin = 1
	DataOrigin_AMBIENT      DataOrigin = 2
	DataOrigin_AIR_PRESSURE DataOrigin = 3
	DataOrigin_PRESENCE     DataOrigin = 10
	// Dynamically assigned sensor types.
	DataOrigin_RESERVED_999            DataOrigin = 999
	DataOrigin_DYNAMIC_ASSIGNMENT_1000 DataOrigin = 1000
	// ...
	DataOrigin_DYNAMIC_ASSIGNMENT_99999 DataOrigin = 99999
	DataOrigin_RESERVED_100000          DataOrigin = 100000
)

func (DataOrigin) EnumDescriptor 

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

func (DataOrigin) String 

func (x DataOrigin) String() string

type DebugPhase 

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 */
}

func (*DebugPhase) Descriptor 

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

func (*DebugPhase) GetOptions 

func (m *DebugPhase) GetOptions() map[string]*Option

func (*DebugPhase) ProtoMessage 

func (*DebugPhase) ProtoMessage()

func (*DebugPhase) Reset 

func (m *DebugPhase) Reset()

func (*DebugPhase) String 

func (m *DebugPhase) String() string

type LinkingPhase 

type LinkingPhase struct {
}

func (*LinkingPhase) Descriptor 

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

func (*LinkingPhase) ProtoMessage 

func (*LinkingPhase) ProtoMessage()

func (*LinkingPhase) Reset 

func (m *LinkingPhase) Reset()

func (*LinkingPhase) String 

func (m *LinkingPhase) String() string

type MetadataKey 

type MetadataKey int32
const (
	MetadataKey_PEERID MetadataKey = 0
)

func (MetadataKey) EnumDescriptor 

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

func (MetadataKey) String 

func (x MetadataKey) String() string

type Option 

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

func (*Option) Descriptor 

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

func (*Option) GetDec 

func (m *Option) GetDec() int32

func (*Option) GetOptValue 

func (m *Option) GetOptValue() isOption_OptValue

func (*Option) GetStr 

func (m *Option) GetStr() string

func (*Option) ProtoMessage 

func (*Option) ProtoMessage()

func (*Option) Reset 

func (m *Option) Reset()

func (*Option) String 

func (m *Option) String() string

func (*Option) XXX_OneofFuncs 

func (*Option) 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.

type Option_Dec 

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

type Option_Str 

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

type PreparePhase 

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"`
}

func (*PreparePhase) Descriptor 

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

func (*PreparePhase) GetParticipants 

func (m *PreparePhase) GetParticipants() []*PreparePhase_Participant

func (*PreparePhase) GetSmcTask 

func (m *PreparePhase) GetSmcTask() *SMCTask

func (*PreparePhase) ProtoMessage 

func (*PreparePhase) ProtoMessage()

func (*PreparePhase) Reset 

func (m *PreparePhase) Reset()

func (*PreparePhase) String 

func (m *PreparePhase) String() string

type PreparePhase_Participant 

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"`
}

func (*PreparePhase_Participant) Descriptor 

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

func (*PreparePhase_Participant) ProtoMessage 

func (*PreparePhase_Participant) ProtoMessage()

func (*PreparePhase_Participant) Reset 

func (m *PreparePhase_Participant) Reset()

func (*PreparePhase_Participant) String 

func (m *PreparePhase_Participant) String() string

type SMCCmd 

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"`
}

func (*SMCCmd) Descriptor 

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

func (*SMCCmd) GetDebug 

func (m *SMCCmd) GetDebug() *DebugPhase
func (m *SMCCmd) GetLink() *LinkingPhase

func (*SMCCmd) GetPayload 

func (m *SMCCmd) GetPayload() isSMCCmd_Payload

func (*SMCCmd) GetPrepare 

func (m *SMCCmd) GetPrepare() *PreparePhase

func (*SMCCmd) GetSession 

func (m *SMCCmd) GetSession() *SessionPhase

func (*SMCCmd) ProtoMessage 

func (*SMCCmd) ProtoMessage()

func (*SMCCmd) Reset 

func (m *SMCCmd) Reset()

func (*SMCCmd) String 

func (m *SMCCmd) String() string

func (*SMCCmd) XXX_OneofFuncs 

func (*SMCCmd) 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.

type SMCCmd_Debug 

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 

type SMCCmd_Phase int32
const (
	SMCCmd_PREPARE SMCCmd_Phase = 0
	SMCCmd_LINK    SMCCmd_Phase = 1
	SMCCmd_SESSION SMCCmd_Phase = 2
	// ...
	SMCCmd_FINISH SMCCmd_Phase = 126
	SMCCmd_ABORT  SMCCmd_Phase = 127
)

func (SMCCmd_Phase) EnumDescriptor 

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

func (SMCCmd_Phase) String 

func (x SMCCmd_Phase) String() string

type SMCCmd_Prepare 

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

type SMCCmd_Session 

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

type SMCResult 

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

func (*SMCResult) Descriptor 

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

func (*SMCResult) ProtoMessage 

func (*SMCResult) ProtoMessage()

func (*SMCResult) Reset 

func (m *SMCResult) Reset()

func (*SMCResult) String 

func (m *SMCResult) String() string

type SMCTask 

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"`
}

func (*SMCTask) Descriptor 

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

func (*SMCTask) GetIssued 

func (m *SMCTask) GetIssued() *google_protobuf.Timestamp

func (*SMCTask) GetOptions 

func (m *SMCTask) GetOptions() map[string]*Option

func (*SMCTask) ProtoMessage 

func (*SMCTask) ProtoMessage()

func (*SMCTask) Reset 

func (m *SMCTask) Reset()

func (*SMCTask) String 

func (m *SMCTask) String() string

type SessionPhase 

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"`
}

func (*SessionPhase) Descriptor 

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

func (*SessionPhase) ProtoMessage 

func (*SessionPhase) ProtoMessage()

func (*SessionPhase) Reset 

func (m *SessionPhase) Reset()

func (*SessionPhase) String 

func (m *SessionPhase) String() string

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.