Documentation ¶
Index ¶
- Variables
- type ClusterInfo
- func (*ClusterInfo) Descriptor() ([]byte, []int)
- func (this *ClusterInfo) Equal(that interface{}) bool
- func (info *ClusterInfo) FindWoerkerInfoByPartition(partitionID uint64) *ClusterInfo_WorkerInfo
- func (m *ClusterInfo) GetWorkerInfo() []*ClusterInfo_WorkerInfo
- func (this *ClusterInfo) GoString() string
- func (m *ClusterInfo) Marshal() (dAtA []byte, err error)
- func (m *ClusterInfo) MarshalTo(dAtA []byte) (int, error)
- func (info *ClusterInfo) NumOfPartitions() uint64
- func (*ClusterInfo) ProtoMessage()
- func (m *ClusterInfo) Reset()
- func (m *ClusterInfo) Size() (n int)
- func (this *ClusterInfo) String() string
- func (m *ClusterInfo) Unmarshal(dAtA []byte) error
- func (m *ClusterInfo) XXX_DiscardUnknown()
- func (m *ClusterInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterInfo) XXX_Merge(src proto.Message)
- func (m *ClusterInfo) XXX_Size() int
- func (m *ClusterInfo) XXX_Unmarshal(b []byte) error
- type ClusterInfo_WorkerInfo
- func (*ClusterInfo_WorkerInfo) Descriptor() ([]byte, []int)
- func (this *ClusterInfo_WorkerInfo) Equal(that interface{}) bool
- func (m *ClusterInfo_WorkerInfo) GetPartitions() []uint64
- func (m *ClusterInfo_WorkerInfo) GetWorkerPid() *actor.PID
- func (this *ClusterInfo_WorkerInfo) GoString() string
- func (m *ClusterInfo_WorkerInfo) Marshal() (dAtA []byte, err error)
- func (m *ClusterInfo_WorkerInfo) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterInfo_WorkerInfo) ProtoMessage()
- func (m *ClusterInfo_WorkerInfo) Reset()
- func (m *ClusterInfo_WorkerInfo) Size() (n int)
- func (this *ClusterInfo_WorkerInfo) String() string
- func (m *ClusterInfo_WorkerInfo) Unmarshal(dAtA []byte) error
- func (m *ClusterInfo_WorkerInfo) XXX_DiscardUnknown()
- func (m *ClusterInfo_WorkerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterInfo_WorkerInfo) XXX_Merge(src proto.Message)
- func (m *ClusterInfo_WorkerInfo) XXX_Size() int
- func (m *ClusterInfo_WorkerInfo) XXX_Unmarshal(b []byte) error
- type Compute
- func (*Compute) Descriptor() ([]byte, []int)
- func (this *Compute) Equal(that interface{}) bool
- func (m *Compute) GetAggregatedValues() map[string]*types.Any
- func (m *Compute) GetSuperStep() uint64
- func (this *Compute) GoString() string
- func (m *Compute) Marshal() (dAtA []byte, err error)
- func (m *Compute) MarshalTo(dAtA []byte) (int, error)
- func (*Compute) ProtoMessage()
- func (m *Compute) Reset()
- func (m *Compute) Size() (n int)
- func (this *Compute) String() string
- func (m *Compute) Unmarshal(dAtA []byte) error
- func (m *Compute) XXX_DiscardUnknown()
- func (m *Compute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Compute) XXX_Merge(src proto.Message)
- func (m *Compute) XXX_Size() int
- func (m *Compute) XXX_Unmarshal(b []byte) error
- type ComputeAck
- func (*ComputeAck) Descriptor() ([]byte, []int)
- func (this *ComputeAck) Equal(that interface{}) bool
- func (m *ComputeAck) GetAggregatedValues() map[string]*types.Any
- func (m *ComputeAck) GetHalted() bool
- func (m *ComputeAck) GetVertexId() string
- func (this *ComputeAck) GoString() string
- func (m *ComputeAck) Marshal() (dAtA []byte, err error)
- func (m *ComputeAck) MarshalTo(dAtA []byte) (int, error)
- func (*ComputeAck) ProtoMessage()
- func (m *ComputeAck) Reset()
- func (m *ComputeAck) Size() (n int)
- func (this *ComputeAck) String() string
- func (m *ComputeAck) Unmarshal(dAtA []byte) error
- func (m *ComputeAck) XXX_DiscardUnknown()
- func (m *ComputeAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ComputeAck) XXX_Merge(src proto.Message)
- func (m *ComputeAck) XXX_Size() int
- func (m *ComputeAck) XXX_Unmarshal(b []byte) error
- type ComputePartitionAck
- func (*ComputePartitionAck) Descriptor() ([]byte, []int)
- func (this *ComputePartitionAck) Equal(that interface{}) bool
- func (m *ComputePartitionAck) GetAggregatedValues() map[string]*types.Any
- func (m *ComputePartitionAck) GetPartitionId() uint64
- func (this *ComputePartitionAck) GoString() string
- func (m *ComputePartitionAck) Marshal() (dAtA []byte, err error)
- func (m *ComputePartitionAck) MarshalTo(dAtA []byte) (int, error)
- func (*ComputePartitionAck) ProtoMessage()
- func (m *ComputePartitionAck) Reset()
- func (m *ComputePartitionAck) Size() (n int)
- func (this *ComputePartitionAck) String() string
- func (m *ComputePartitionAck) Unmarshal(dAtA []byte) error
- func (m *ComputePartitionAck) XXX_DiscardUnknown()
- func (m *ComputePartitionAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ComputePartitionAck) XXX_Merge(src proto.Message)
- func (m *ComputePartitionAck) XXX_Size() int
- func (m *ComputePartitionAck) XXX_Unmarshal(b []byte) error
- type ComputeWorkerAck
- func (*ComputeWorkerAck) Descriptor() ([]byte, []int)
- func (this *ComputeWorkerAck) Equal(that interface{}) bool
- func (m *ComputeWorkerAck) GetAggregatedValues() map[string]*types.Any
- func (m *ComputeWorkerAck) GetWorkerPid() *actor.PID
- func (this *ComputeWorkerAck) GoString() string
- func (m *ComputeWorkerAck) Marshal() (dAtA []byte, err error)
- func (m *ComputeWorkerAck) MarshalTo(dAtA []byte) (int, error)
- func (*ComputeWorkerAck) ProtoMessage()
- func (m *ComputeWorkerAck) Reset()
- func (m *ComputeWorkerAck) Size() (n int)
- func (this *ComputeWorkerAck) String() string
- func (m *ComputeWorkerAck) Unmarshal(dAtA []byte) error
- func (m *ComputeWorkerAck) XXX_DiscardUnknown()
- func (m *ComputeWorkerAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ComputeWorkerAck) XXX_Merge(src proto.Message)
- func (m *ComputeWorkerAck) XXX_Size() int
- func (m *ComputeWorkerAck) XXX_Unmarshal(b []byte) error
- type CoordinatorStats
- func (*CoordinatorStats) Descriptor() ([]byte, []int)
- func (this *CoordinatorStats) Equal(that interface{}) bool
- func (this *CoordinatorStats) GoString() string
- func (m *CoordinatorStats) Marshal() (dAtA []byte, err error)
- func (m *CoordinatorStats) MarshalTo(dAtA []byte) (int, error)
- func (*CoordinatorStats) ProtoMessage()
- func (m *CoordinatorStats) Reset()
- func (m *CoordinatorStats) Size() (n int)
- func (this *CoordinatorStats) String() string
- func (m *CoordinatorStats) Unmarshal(dAtA []byte) error
- func (m *CoordinatorStats) XXX_DiscardUnknown()
- func (m *CoordinatorStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CoordinatorStats) XXX_Merge(src proto.Message)
- func (m *CoordinatorStats) XXX_Size() int
- func (m *CoordinatorStats) XXX_Unmarshal(b []byte) error
- type CoordinatorStatsAck
- func (*CoordinatorStatsAck) Descriptor() ([]byte, []int)
- func (this *CoordinatorStatsAck) Equal(that interface{}) bool
- func (m *CoordinatorStatsAck) GetNrOfActiveVertex() uint64
- func (m *CoordinatorStatsAck) GetNrOfSentMessages() uint64
- func (m *CoordinatorStatsAck) GetState() string
- func (m *CoordinatorStatsAck) GetSuperStep() uint64
- func (this *CoordinatorStatsAck) GoString() string
- func (m *CoordinatorStatsAck) Marshal() (dAtA []byte, err error)
- func (m *CoordinatorStatsAck) MarshalTo(dAtA []byte) (int, error)
- func (*CoordinatorStatsAck) ProtoMessage()
- func (m *CoordinatorStatsAck) Reset()
- func (m *CoordinatorStatsAck) Size() (n int)
- func (s *CoordinatorStatsAck) StatsCompleted() bool
- func (this *CoordinatorStatsAck) String() string
- func (m *CoordinatorStatsAck) Unmarshal(dAtA []byte) error
- func (m *CoordinatorStatsAck) XXX_DiscardUnknown()
- func (m *CoordinatorStatsAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CoordinatorStatsAck) XXX_Merge(src proto.Message)
- func (m *CoordinatorStatsAck) XXX_Size() int
- func (m *CoordinatorStatsAck) XXX_Unmarshal(b []byte) error
- type GetVertexValue
- func (*GetVertexValue) Descriptor() ([]byte, []int)
- func (this *GetVertexValue) Equal(that interface{}) bool
- func (m *GetVertexValue) GetVertexId() string
- func (this *GetVertexValue) GoString() string
- func (m *GetVertexValue) Marshal() (dAtA []byte, err error)
- func (m *GetVertexValue) MarshalTo(dAtA []byte) (int, error)
- func (*GetVertexValue) ProtoMessage()
- func (m *GetVertexValue) Reset()
- func (m *GetVertexValue) Size() (n int)
- func (this *GetVertexValue) String() string
- func (m *GetVertexValue) Unmarshal(dAtA []byte) error
- func (m *GetVertexValue) XXX_DiscardUnknown()
- func (m *GetVertexValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetVertexValue) XXX_Merge(src proto.Message)
- func (m *GetVertexValue) XXX_Size() int
- func (m *GetVertexValue) XXX_Unmarshal(b []byte) error
- type GetVertexValueAck
- func (*GetVertexValueAck) Descriptor() ([]byte, []int)
- func (this *GetVertexValueAck) Equal(that interface{}) bool
- func (m *GetVertexValueAck) GetValue() string
- func (m *GetVertexValueAck) GetVertexId() string
- func (this *GetVertexValueAck) GoString() string
- func (m *GetVertexValueAck) Marshal() (dAtA []byte, err error)
- func (m *GetVertexValueAck) MarshalTo(dAtA []byte) (int, error)
- func (*GetVertexValueAck) ProtoMessage()
- func (m *GetVertexValueAck) Reset()
- func (m *GetVertexValueAck) Size() (n int)
- func (this *GetVertexValueAck) String() string
- func (m *GetVertexValueAck) Unmarshal(dAtA []byte) error
- func (m *GetVertexValueAck) XXX_DiscardUnknown()
- func (m *GetVertexValueAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetVertexValueAck) XXX_Merge(src proto.Message)
- func (m *GetVertexValueAck) XXX_Size() int
- func (m *GetVertexValueAck) XXX_Unmarshal(b []byte) error
- type InitPartition
- func (*InitPartition) Descriptor() ([]byte, []int)
- func (this *InitPartition) Equal(that interface{}) bool
- func (m *InitPartition) GetPartitionId() uint64
- func (this *InitPartition) GoString() string
- func (m *InitPartition) Marshal() (dAtA []byte, err error)
- func (m *InitPartition) MarshalTo(dAtA []byte) (int, error)
- func (*InitPartition) ProtoMessage()
- func (m *InitPartition) Reset()
- func (m *InitPartition) Size() (n int)
- func (this *InitPartition) String() string
- func (m *InitPartition) Unmarshal(dAtA []byte) error
- func (m *InitPartition) XXX_DiscardUnknown()
- func (m *InitPartition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InitPartition) XXX_Merge(src proto.Message)
- func (m *InitPartition) XXX_Size() int
- func (m *InitPartition) XXX_Unmarshal(b []byte) error
- type InitPartitionAck
- func (*InitPartitionAck) Descriptor() ([]byte, []int)
- func (this *InitPartitionAck) Equal(that interface{}) bool
- func (m *InitPartitionAck) GetPartitionId() uint64
- func (this *InitPartitionAck) GoString() string
- func (m *InitPartitionAck) Marshal() (dAtA []byte, err error)
- func (m *InitPartitionAck) MarshalTo(dAtA []byte) (int, error)
- func (*InitPartitionAck) ProtoMessage()
- func (m *InitPartitionAck) Reset()
- func (m *InitPartitionAck) Size() (n int)
- func (this *InitPartitionAck) String() string
- func (m *InitPartitionAck) Unmarshal(dAtA []byte) error
- func (m *InitPartitionAck) XXX_DiscardUnknown()
- func (m *InitPartitionAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InitPartitionAck) XXX_Merge(src proto.Message)
- func (m *InitPartitionAck) XXX_Size() int
- func (m *InitPartitionAck) XXX_Unmarshal(b []byte) error
- type InitWorker
- func (*InitWorker) Descriptor() ([]byte, []int)
- func (this *InitWorker) Equal(that interface{}) bool
- func (m *InitWorker) GetCoordinator() *actor.PID
- func (m *InitWorker) GetPartitions() []uint64
- func (this *InitWorker) GoString() string
- func (m *InitWorker) Marshal() (dAtA []byte, err error)
- func (m *InitWorker) MarshalTo(dAtA []byte) (int, error)
- func (*InitWorker) ProtoMessage()
- func (m *InitWorker) Reset()
- func (m *InitWorker) Size() (n int)
- func (this *InitWorker) String() string
- func (m *InitWorker) Unmarshal(dAtA []byte) error
- func (m *InitWorker) XXX_DiscardUnknown()
- func (m *InitWorker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InitWorker) XXX_Merge(src proto.Message)
- func (m *InitWorker) XXX_Size() int
- func (m *InitWorker) XXX_Unmarshal(b []byte) error
- type InitWorkerAck
- func (*InitWorkerAck) Descriptor() ([]byte, []int)
- func (this *InitWorkerAck) Equal(that interface{}) bool
- func (m *InitWorkerAck) GetWorkerPid() *actor.PID
- func (this *InitWorkerAck) GoString() string
- func (m *InitWorkerAck) Marshal() (dAtA []byte, err error)
- func (m *InitWorkerAck) MarshalTo(dAtA []byte) (int, error)
- func (*InitWorkerAck) ProtoMessage()
- func (m *InitWorkerAck) Reset()
- func (m *InitWorkerAck) Size() (n int)
- func (this *InitWorkerAck) String() string
- func (m *InitWorkerAck) Unmarshal(dAtA []byte) error
- func (m *InitWorkerAck) XXX_DiscardUnknown()
- func (m *InitWorkerAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InitWorkerAck) XXX_Merge(src proto.Message)
- func (m *InitWorkerAck) XXX_Size() int
- func (m *InitWorkerAck) XXX_Unmarshal(b []byte) error
- type LoadPartitionVertices
- func (*LoadPartitionVertices) Descriptor() ([]byte, []int)
- func (this *LoadPartitionVertices) Equal(that interface{}) bool
- func (m *LoadPartitionVertices) GetNumOfPartitions() uint64
- func (this *LoadPartitionVertices) GoString() string
- func (m *LoadPartitionVertices) Marshal() (dAtA []byte, err error)
- func (m *LoadPartitionVertices) MarshalTo(dAtA []byte) (int, error)
- func (*LoadPartitionVertices) ProtoMessage()
- func (m *LoadPartitionVertices) Reset()
- func (m *LoadPartitionVertices) Size() (n int)
- func (this *LoadPartitionVertices) String() string
- func (m *LoadPartitionVertices) Unmarshal(dAtA []byte) error
- func (m *LoadPartitionVertices) XXX_DiscardUnknown()
- func (m *LoadPartitionVertices) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadPartitionVertices) XXX_Merge(src proto.Message)
- func (m *LoadPartitionVertices) XXX_Size() int
- func (m *LoadPartitionVertices) XXX_Unmarshal(b []byte) error
- type LoadPartitionVerticesAck
- func (*LoadPartitionVerticesAck) Descriptor() ([]byte, []int)
- func (this *LoadPartitionVerticesAck) Equal(that interface{}) bool
- func (m *LoadPartitionVerticesAck) GetError() string
- func (m *LoadPartitionVerticesAck) GetPartitionId() uint64
- func (this *LoadPartitionVerticesAck) GoString() string
- func (m *LoadPartitionVerticesAck) Marshal() (dAtA []byte, err error)
- func (m *LoadPartitionVerticesAck) MarshalTo(dAtA []byte) (int, error)
- func (*LoadPartitionVerticesAck) ProtoMessage()
- func (m *LoadPartitionVerticesAck) Reset()
- func (m *LoadPartitionVerticesAck) Size() (n int)
- func (this *LoadPartitionVerticesAck) String() string
- func (m *LoadPartitionVerticesAck) Unmarshal(dAtA []byte) error
- func (m *LoadPartitionVerticesAck) XXX_DiscardUnknown()
- func (m *LoadPartitionVerticesAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadPartitionVerticesAck) XXX_Merge(src proto.Message)
- func (m *LoadPartitionVerticesAck) XXX_Size() int
- func (m *LoadPartitionVerticesAck) XXX_Unmarshal(b []byte) error
- type LoadPartitionVerticesWorkerAck
- func (*LoadPartitionVerticesWorkerAck) Descriptor() ([]byte, []int)
- func (this *LoadPartitionVerticesWorkerAck) Equal(that interface{}) bool
- func (m *LoadPartitionVerticesWorkerAck) GetWorkerPid() *actor.PID
- func (this *LoadPartitionVerticesWorkerAck) GoString() string
- func (m *LoadPartitionVerticesWorkerAck) Marshal() (dAtA []byte, err error)
- func (m *LoadPartitionVerticesWorkerAck) MarshalTo(dAtA []byte) (int, error)
- func (*LoadPartitionVerticesWorkerAck) ProtoMessage()
- func (m *LoadPartitionVerticesWorkerAck) Reset()
- func (m *LoadPartitionVerticesWorkerAck) Size() (n int)
- func (this *LoadPartitionVerticesWorkerAck) String() string
- func (m *LoadPartitionVerticesWorkerAck) Unmarshal(dAtA []byte) error
- func (m *LoadPartitionVerticesWorkerAck) XXX_DiscardUnknown()
- func (m *LoadPartitionVerticesWorkerAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadPartitionVerticesWorkerAck) XXX_Merge(src proto.Message)
- func (m *LoadPartitionVerticesWorkerAck) XXX_Size() int
- func (m *LoadPartitionVerticesWorkerAck) XXX_Unmarshal(b []byte) error
- type LoadVertex
- func (*LoadVertex) Descriptor() ([]byte, []int)
- func (this *LoadVertex) Equal(that interface{}) bool
- func (m *LoadVertex) GetVertexId() string
- func (this *LoadVertex) GoString() string
- func (m *LoadVertex) Marshal() (dAtA []byte, err error)
- func (m *LoadVertex) MarshalTo(dAtA []byte) (int, error)
- func (*LoadVertex) ProtoMessage()
- func (m *LoadVertex) Reset()
- func (m *LoadVertex) Size() (n int)
- func (this *LoadVertex) String() string
- func (m *LoadVertex) Unmarshal(dAtA []byte) error
- func (m *LoadVertex) XXX_DiscardUnknown()
- func (m *LoadVertex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadVertex) XXX_Merge(src proto.Message)
- func (m *LoadVertex) XXX_Size() int
- func (m *LoadVertex) XXX_Unmarshal(b []byte) error
- type LoadVertexAck
- func (*LoadVertexAck) Descriptor() ([]byte, []int)
- func (this *LoadVertexAck) Equal(that interface{}) bool
- func (m *LoadVertexAck) GetError() string
- func (m *LoadVertexAck) GetVertexId() string
- func (this *LoadVertexAck) GoString() string
- func (m *LoadVertexAck) Marshal() (dAtA []byte, err error)
- func (m *LoadVertexAck) MarshalTo(dAtA []byte) (int, error)
- func (*LoadVertexAck) ProtoMessage()
- func (m *LoadVertexAck) Reset()
- func (m *LoadVertexAck) Size() (n int)
- func (this *LoadVertexAck) String() string
- func (m *LoadVertexAck) Unmarshal(dAtA []byte) error
- func (m *LoadVertexAck) XXX_DiscardUnknown()
- func (m *LoadVertexAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadVertexAck) XXX_Merge(src proto.Message)
- func (m *LoadVertexAck) XXX_Size() int
- func (m *LoadVertexAck) XXX_Unmarshal(b []byte) error
- type NewCluster
- func (*NewCluster) Descriptor() ([]byte, []int)
- func (this *NewCluster) Equal(that interface{}) bool
- func (m *NewCluster) GetNrOfPartitions() uint64
- func (m *NewCluster) GetWorkers() []*NewCluster_WorkerReq
- func (this *NewCluster) GoString() string
- func (m *NewCluster) Marshal() (dAtA []byte, err error)
- func (m *NewCluster) MarshalTo(dAtA []byte) (int, error)
- func (*NewCluster) ProtoMessage()
- func (m *NewCluster) Reset()
- func (m *NewCluster) Size() (n int)
- func (this *NewCluster) String() string
- func (m *NewCluster) Unmarshal(dAtA []byte) error
- func (m *NewCluster) XXX_DiscardUnknown()
- func (m *NewCluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NewCluster) XXX_Merge(src proto.Message)
- func (m *NewCluster) XXX_Size() int
- func (m *NewCluster) XXX_Unmarshal(b []byte) error
- type NewClusterAck
- func (*NewClusterAck) Descriptor() ([]byte, []int)
- func (this *NewClusterAck) Equal(that interface{}) bool
- func (this *NewClusterAck) GoString() string
- func (m *NewClusterAck) Marshal() (dAtA []byte, err error)
- func (m *NewClusterAck) MarshalTo(dAtA []byte) (int, error)
- func (*NewClusterAck) ProtoMessage()
- func (m *NewClusterAck) Reset()
- func (m *NewClusterAck) Size() (n int)
- func (this *NewClusterAck) String() string
- func (m *NewClusterAck) Unmarshal(dAtA []byte) error
- func (m *NewClusterAck) XXX_DiscardUnknown()
- func (m *NewClusterAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NewClusterAck) XXX_Merge(src proto.Message)
- func (m *NewClusterAck) XXX_Size() int
- func (m *NewClusterAck) XXX_Unmarshal(b []byte) error
- type NewCluster_WorkerReq
- func (*NewCluster_WorkerReq) Descriptor() ([]byte, []int)
- func (this *NewCluster_WorkerReq) Equal(that interface{}) bool
- func (m *NewCluster_WorkerReq) GetHostAndPort() string
- func (m *NewCluster_WorkerReq) GetRemote() bool
- func (this *NewCluster_WorkerReq) GoString() string
- func (m *NewCluster_WorkerReq) Marshal() (dAtA []byte, err error)
- func (m *NewCluster_WorkerReq) MarshalTo(dAtA []byte) (int, error)
- func (*NewCluster_WorkerReq) ProtoMessage()
- func (m *NewCluster_WorkerReq) Reset()
- func (m *NewCluster_WorkerReq) Size() (n int)
- func (this *NewCluster_WorkerReq) String() string
- func (m *NewCluster_WorkerReq) Unmarshal(dAtA []byte) error
- func (m *NewCluster_WorkerReq) XXX_DiscardUnknown()
- func (m *NewCluster_WorkerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NewCluster_WorkerReq) XXX_Merge(src proto.Message)
- func (m *NewCluster_WorkerReq) XXX_Size() int
- func (m *NewCluster_WorkerReq) XXX_Unmarshal(b []byte) error
- type ShowAggregatedValue
- func (*ShowAggregatedValue) Descriptor() ([]byte, []int)
- func (this *ShowAggregatedValue) Equal(that interface{}) bool
- func (this *ShowAggregatedValue) GoString() string
- func (m *ShowAggregatedValue) Marshal() (dAtA []byte, err error)
- func (m *ShowAggregatedValue) MarshalTo(dAtA []byte) (int, error)
- func (*ShowAggregatedValue) ProtoMessage()
- func (m *ShowAggregatedValue) Reset()
- func (m *ShowAggregatedValue) Size() (n int)
- func (this *ShowAggregatedValue) String() string
- func (m *ShowAggregatedValue) Unmarshal(dAtA []byte) error
- func (m *ShowAggregatedValue) XXX_DiscardUnknown()
- func (m *ShowAggregatedValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShowAggregatedValue) XXX_Merge(src proto.Message)
- func (m *ShowAggregatedValue) XXX_Size() int
- func (m *ShowAggregatedValue) XXX_Unmarshal(b []byte) error
- type ShowAggregatedValueAck
- func (*ShowAggregatedValueAck) Descriptor() ([]byte, []int)
- func (this *ShowAggregatedValueAck) Equal(that interface{}) bool
- func (m *ShowAggregatedValueAck) GetAggregatedValues() map[string]string
- func (this *ShowAggregatedValueAck) GoString() string
- func (m *ShowAggregatedValueAck) Marshal() (dAtA []byte, err error)
- func (m *ShowAggregatedValueAck) MarshalTo(dAtA []byte) (int, error)
- func (*ShowAggregatedValueAck) ProtoMessage()
- func (m *ShowAggregatedValueAck) Reset()
- func (m *ShowAggregatedValueAck) Size() (n int)
- func (this *ShowAggregatedValueAck) String() string
- func (m *ShowAggregatedValueAck) Unmarshal(dAtA []byte) error
- func (m *ShowAggregatedValueAck) XXX_DiscardUnknown()
- func (m *ShowAggregatedValueAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShowAggregatedValueAck) XXX_Merge(src proto.Message)
- func (m *ShowAggregatedValueAck) XXX_Size() int
- func (m *ShowAggregatedValueAck) XXX_Unmarshal(b []byte) error
- type Shutdown
- func (*Shutdown) Descriptor() ([]byte, []int)
- func (this *Shutdown) Equal(that interface{}) bool
- func (this *Shutdown) GoString() string
- func (m *Shutdown) Marshal() (dAtA []byte, err error)
- func (m *Shutdown) MarshalTo(dAtA []byte) (int, error)
- func (*Shutdown) ProtoMessage()
- func (m *Shutdown) Reset()
- func (m *Shutdown) Size() (n int)
- func (this *Shutdown) String() string
- func (m *Shutdown) Unmarshal(dAtA []byte) error
- func (m *Shutdown) XXX_DiscardUnknown()
- func (m *Shutdown) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Shutdown) XXX_Merge(src proto.Message)
- func (m *Shutdown) XXX_Size() int
- func (m *Shutdown) XXX_Unmarshal(b []byte) error
- type ShutdownAck
- func (*ShutdownAck) Descriptor() ([]byte, []int)
- func (this *ShutdownAck) Equal(that interface{}) bool
- func (this *ShutdownAck) GoString() string
- func (m *ShutdownAck) Marshal() (dAtA []byte, err error)
- func (m *ShutdownAck) MarshalTo(dAtA []byte) (int, error)
- func (*ShutdownAck) ProtoMessage()
- func (m *ShutdownAck) Reset()
- func (m *ShutdownAck) Size() (n int)
- func (this *ShutdownAck) String() string
- func (m *ShutdownAck) Unmarshal(dAtA []byte) error
- func (m *ShutdownAck) XXX_DiscardUnknown()
- func (m *ShutdownAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShutdownAck) XXX_Merge(src proto.Message)
- func (m *ShutdownAck) XXX_Size() int
- func (m *ShutdownAck) XXX_Unmarshal(b []byte) error
- type StartSuperStep
- func (*StartSuperStep) Descriptor() ([]byte, []int)
- func (this *StartSuperStep) Equal(that interface{}) bool
- func (this *StartSuperStep) GoString() string
- func (m *StartSuperStep) Marshal() (dAtA []byte, err error)
- func (m *StartSuperStep) MarshalTo(dAtA []byte) (int, error)
- func (*StartSuperStep) ProtoMessage()
- func (m *StartSuperStep) Reset()
- func (m *StartSuperStep) Size() (n int)
- func (this *StartSuperStep) String() string
- func (m *StartSuperStep) Unmarshal(dAtA []byte) error
- func (m *StartSuperStep) XXX_DiscardUnknown()
- func (m *StartSuperStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartSuperStep) XXX_Merge(src proto.Message)
- func (m *StartSuperStep) XXX_Size() int
- func (m *StartSuperStep) XXX_Unmarshal(b []byte) error
- type SuperStepBarrier
- func (*SuperStepBarrier) Descriptor() ([]byte, []int)
- func (this *SuperStepBarrier) Equal(that interface{}) bool
- func (this *SuperStepBarrier) GoString() string
- func (m *SuperStepBarrier) Marshal() (dAtA []byte, err error)
- func (m *SuperStepBarrier) MarshalTo(dAtA []byte) (int, error)
- func (*SuperStepBarrier) ProtoMessage()
- func (m *SuperStepBarrier) Reset()
- func (m *SuperStepBarrier) Size() (n int)
- func (this *SuperStepBarrier) String() string
- func (m *SuperStepBarrier) Unmarshal(dAtA []byte) error
- func (m *SuperStepBarrier) XXX_DiscardUnknown()
- func (m *SuperStepBarrier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SuperStepBarrier) XXX_Merge(src proto.Message)
- func (m *SuperStepBarrier) XXX_Size() int
- func (m *SuperStepBarrier) XXX_Unmarshal(b []byte) error
- type SuperStepBarrierAck
- func (*SuperStepBarrierAck) Descriptor() ([]byte, []int)
- func (this *SuperStepBarrierAck) Equal(that interface{}) bool
- func (m *SuperStepBarrierAck) GetVertexId() string
- func (this *SuperStepBarrierAck) GoString() string
- func (m *SuperStepBarrierAck) Marshal() (dAtA []byte, err error)
- func (m *SuperStepBarrierAck) MarshalTo(dAtA []byte) (int, error)
- func (*SuperStepBarrierAck) ProtoMessage()
- func (m *SuperStepBarrierAck) Reset()
- func (m *SuperStepBarrierAck) Size() (n int)
- func (this *SuperStepBarrierAck) String() string
- func (m *SuperStepBarrierAck) Unmarshal(dAtA []byte) error
- func (m *SuperStepBarrierAck) XXX_DiscardUnknown()
- func (m *SuperStepBarrierAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SuperStepBarrierAck) XXX_Merge(src proto.Message)
- func (m *SuperStepBarrierAck) XXX_Size() int
- func (m *SuperStepBarrierAck) XXX_Unmarshal(b []byte) error
- type SuperStepBarrierPartitionAck
- func (*SuperStepBarrierPartitionAck) Descriptor() ([]byte, []int)
- func (this *SuperStepBarrierPartitionAck) Equal(that interface{}) bool
- func (m *SuperStepBarrierPartitionAck) GetPartitionId() uint64
- func (this *SuperStepBarrierPartitionAck) GoString() string
- func (m *SuperStepBarrierPartitionAck) Marshal() (dAtA []byte, err error)
- func (m *SuperStepBarrierPartitionAck) MarshalTo(dAtA []byte) (int, error)
- func (*SuperStepBarrierPartitionAck) ProtoMessage()
- func (m *SuperStepBarrierPartitionAck) Reset()
- func (m *SuperStepBarrierPartitionAck) Size() (n int)
- func (this *SuperStepBarrierPartitionAck) String() string
- func (m *SuperStepBarrierPartitionAck) Unmarshal(dAtA []byte) error
- func (m *SuperStepBarrierPartitionAck) XXX_DiscardUnknown()
- func (m *SuperStepBarrierPartitionAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SuperStepBarrierPartitionAck) XXX_Merge(src proto.Message)
- func (m *SuperStepBarrierPartitionAck) XXX_Size() int
- func (m *SuperStepBarrierPartitionAck) XXX_Unmarshal(b []byte) error
- type SuperStepBarrierWorkerAck
- func (*SuperStepBarrierWorkerAck) Descriptor() ([]byte, []int)
- func (this *SuperStepBarrierWorkerAck) Equal(that interface{}) bool
- func (m *SuperStepBarrierWorkerAck) GetWorkerPid() *actor.PID
- func (this *SuperStepBarrierWorkerAck) GoString() string
- func (m *SuperStepBarrierWorkerAck) Marshal() (dAtA []byte, err error)
- func (m *SuperStepBarrierWorkerAck) MarshalTo(dAtA []byte) (int, error)
- func (*SuperStepBarrierWorkerAck) ProtoMessage()
- func (m *SuperStepBarrierWorkerAck) Reset()
- func (m *SuperStepBarrierWorkerAck) Size() (n int)
- func (this *SuperStepBarrierWorkerAck) String() string
- func (m *SuperStepBarrierWorkerAck) Unmarshal(dAtA []byte) error
- func (m *SuperStepBarrierWorkerAck) XXX_DiscardUnknown()
- func (m *SuperStepBarrierWorkerAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SuperStepBarrierWorkerAck) XXX_Merge(src proto.Message)
- func (m *SuperStepBarrierWorkerAck) XXX_Size() int
- func (m *SuperStepBarrierWorkerAck) XXX_Unmarshal(b []byte) error
- type SuperStepMessage
- func (*SuperStepMessage) Descriptor() ([]byte, []int)
- func (this *SuperStepMessage) Equal(that interface{}) bool
- func (m *SuperStepMessage) GetDestVertexId() string
- func (m *SuperStepMessage) GetMessage() *types.Any
- func (m *SuperStepMessage) GetSrcVertexId() string
- func (m *SuperStepMessage) GetSuperStep() uint64
- func (m *SuperStepMessage) GetUuid() string
- func (this *SuperStepMessage) GoString() string
- func (m *SuperStepMessage) Marshal() (dAtA []byte, err error)
- func (m *SuperStepMessage) MarshalTo(dAtA []byte) (int, error)
- func (*SuperStepMessage) ProtoMessage()
- func (m *SuperStepMessage) Reset()
- func (m *SuperStepMessage) Size() (n int)
- func (this *SuperStepMessage) String() string
- func (m *SuperStepMessage) Unmarshal(dAtA []byte) error
- func (m *SuperStepMessage) XXX_DiscardUnknown()
- func (m *SuperStepMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SuperStepMessage) XXX_Merge(src proto.Message)
- func (m *SuperStepMessage) XXX_Size() int
- func (m *SuperStepMessage) XXX_Unmarshal(b []byte) error
- type SuperStepMessageAck
- func (*SuperStepMessageAck) Descriptor() ([]byte, []int)
- func (this *SuperStepMessageAck) Equal(that interface{}) bool
- func (m *SuperStepMessageAck) GetUuid() string
- func (this *SuperStepMessageAck) GoString() string
- func (m *SuperStepMessageAck) Marshal() (dAtA []byte, err error)
- func (m *SuperStepMessageAck) MarshalTo(dAtA []byte) (int, error)
- func (*SuperStepMessageAck) ProtoMessage()
- func (m *SuperStepMessageAck) Reset()
- func (m *SuperStepMessageAck) Size() (n int)
- func (this *SuperStepMessageAck) String() string
- func (m *SuperStepMessageAck) Unmarshal(dAtA []byte) error
- func (m *SuperStepMessageAck) XXX_DiscardUnknown()
- func (m *SuperStepMessageAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SuperStepMessageAck) XXX_Merge(src proto.Message)
- func (m *SuperStepMessageAck) XXX_Size() int
- func (m *SuperStepMessageAck) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthCommand = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCommand = fmt.Errorf("proto: integer overflow") )
Functions ¶
This section is empty.
Types ¶
type ClusterInfo ¶
type ClusterInfo struct {
WorkerInfo []*ClusterInfo_WorkerInfo `protobuf:"bytes,1,rep,name=worker_info,json=workerInfo,proto3" json:"worker_info,omitempty"`
}
func (*ClusterInfo) Descriptor ¶
func (*ClusterInfo) Descriptor() ([]byte, []int)
func (*ClusterInfo) Equal ¶
func (this *ClusterInfo) Equal(that interface{}) bool
func (*ClusterInfo) FindWoerkerInfoByPartition ¶
func (info *ClusterInfo) FindWoerkerInfoByPartition(partitionID uint64) *ClusterInfo_WorkerInfo
FindWoerkerInfoByPartition returns worker info that owns partition
func (*ClusterInfo) GetWorkerInfo ¶
func (m *ClusterInfo) GetWorkerInfo() []*ClusterInfo_WorkerInfo
func (*ClusterInfo) GoString ¶
func (this *ClusterInfo) GoString() string
func (*ClusterInfo) Marshal ¶
func (m *ClusterInfo) Marshal() (dAtA []byte, err error)
func (*ClusterInfo) NumOfPartitions ¶
func (info *ClusterInfo) NumOfPartitions() uint64
NumOfPartitions returns number of partitions
func (*ClusterInfo) ProtoMessage ¶
func (*ClusterInfo) ProtoMessage()
func (*ClusterInfo) Reset ¶
func (m *ClusterInfo) Reset()
func (*ClusterInfo) Size ¶
func (m *ClusterInfo) Size() (n int)
func (*ClusterInfo) String ¶
func (this *ClusterInfo) String() string
func (*ClusterInfo) Unmarshal ¶
func (m *ClusterInfo) Unmarshal(dAtA []byte) error
func (*ClusterInfo) XXX_DiscardUnknown ¶
func (m *ClusterInfo) XXX_DiscardUnknown()
func (*ClusterInfo) XXX_Marshal ¶
func (m *ClusterInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterInfo) XXX_Merge ¶
func (m *ClusterInfo) XXX_Merge(src proto.Message)
func (*ClusterInfo) XXX_Size ¶
func (m *ClusterInfo) XXX_Size() int
func (*ClusterInfo) XXX_Unmarshal ¶
func (m *ClusterInfo) XXX_Unmarshal(b []byte) error
type ClusterInfo_WorkerInfo ¶
type ClusterInfo_WorkerInfo struct { WorkerPid *actor.PID `protobuf:"bytes,1,opt,name=worker_pid,json=workerPid,proto3" json:"worker_pid,omitempty"` Partitions []uint64 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` }
func (*ClusterInfo_WorkerInfo) Descriptor ¶
func (*ClusterInfo_WorkerInfo) Descriptor() ([]byte, []int)
func (*ClusterInfo_WorkerInfo) Equal ¶
func (this *ClusterInfo_WorkerInfo) Equal(that interface{}) bool
func (*ClusterInfo_WorkerInfo) GetPartitions ¶
func (m *ClusterInfo_WorkerInfo) GetPartitions() []uint64
func (*ClusterInfo_WorkerInfo) GetWorkerPid ¶
func (m *ClusterInfo_WorkerInfo) GetWorkerPid() *actor.PID
func (*ClusterInfo_WorkerInfo) GoString ¶
func (this *ClusterInfo_WorkerInfo) GoString() string
func (*ClusterInfo_WorkerInfo) Marshal ¶
func (m *ClusterInfo_WorkerInfo) Marshal() (dAtA []byte, err error)
func (*ClusterInfo_WorkerInfo) MarshalTo ¶
func (m *ClusterInfo_WorkerInfo) MarshalTo(dAtA []byte) (int, error)
func (*ClusterInfo_WorkerInfo) ProtoMessage ¶
func (*ClusterInfo_WorkerInfo) ProtoMessage()
func (*ClusterInfo_WorkerInfo) Reset ¶
func (m *ClusterInfo_WorkerInfo) Reset()
func (*ClusterInfo_WorkerInfo) Size ¶
func (m *ClusterInfo_WorkerInfo) Size() (n int)
func (*ClusterInfo_WorkerInfo) String ¶
func (this *ClusterInfo_WorkerInfo) String() string
func (*ClusterInfo_WorkerInfo) Unmarshal ¶
func (m *ClusterInfo_WorkerInfo) Unmarshal(dAtA []byte) error
func (*ClusterInfo_WorkerInfo) XXX_DiscardUnknown ¶
func (m *ClusterInfo_WorkerInfo) XXX_DiscardUnknown()
func (*ClusterInfo_WorkerInfo) XXX_Marshal ¶
func (m *ClusterInfo_WorkerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterInfo_WorkerInfo) XXX_Merge ¶
func (m *ClusterInfo_WorkerInfo) XXX_Merge(src proto.Message)
func (*ClusterInfo_WorkerInfo) XXX_Size ¶
func (m *ClusterInfo_WorkerInfo) XXX_Size() int
func (*ClusterInfo_WorkerInfo) XXX_Unmarshal ¶
func (m *ClusterInfo_WorkerInfo) XXX_Unmarshal(b []byte) error
type Compute ¶
type Compute struct { SuperStep uint64 `protobuf:"varint,1,opt,name=super_step,json=superStep,proto3" json:"super_step,omitempty"` AggregatedValues map[string]*types.Any `` /* 197-byte string literal not displayed */ }
func (*Compute) Descriptor ¶
func (*Compute) GetSuperStep ¶
func (*Compute) ProtoMessage ¶
func (*Compute) ProtoMessage()
func (*Compute) XXX_DiscardUnknown ¶
func (m *Compute) XXX_DiscardUnknown()
func (*Compute) XXX_Marshal ¶
func (*Compute) XXX_Unmarshal ¶
type ComputeAck ¶
type ComputeAck struct { VertexId string `protobuf:"bytes,1,opt,name=vertex_id,json=vertexId,proto3" json:"vertex_id,omitempty"` Halted bool `protobuf:"varint,2,opt,name=halted,proto3" json:"halted,omitempty"` AggregatedValues map[string]*types.Any `` /* 197-byte string literal not displayed */ }
func (*ComputeAck) Descriptor ¶
func (*ComputeAck) Descriptor() ([]byte, []int)
func (*ComputeAck) Equal ¶
func (this *ComputeAck) Equal(that interface{}) bool
func (*ComputeAck) GetAggregatedValues ¶
func (m *ComputeAck) GetAggregatedValues() map[string]*types.Any
func (*ComputeAck) GetHalted ¶
func (m *ComputeAck) GetHalted() bool
func (*ComputeAck) GetVertexId ¶
func (m *ComputeAck) GetVertexId() string
func (*ComputeAck) GoString ¶
func (this *ComputeAck) GoString() string
func (*ComputeAck) Marshal ¶
func (m *ComputeAck) Marshal() (dAtA []byte, err error)
func (*ComputeAck) ProtoMessage ¶
func (*ComputeAck) ProtoMessage()
func (*ComputeAck) Reset ¶
func (m *ComputeAck) Reset()
func (*ComputeAck) Size ¶
func (m *ComputeAck) Size() (n int)
func (*ComputeAck) String ¶
func (this *ComputeAck) String() string
func (*ComputeAck) Unmarshal ¶
func (m *ComputeAck) Unmarshal(dAtA []byte) error
func (*ComputeAck) XXX_DiscardUnknown ¶
func (m *ComputeAck) XXX_DiscardUnknown()
func (*ComputeAck) XXX_Marshal ¶
func (m *ComputeAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ComputeAck) XXX_Merge ¶
func (m *ComputeAck) XXX_Merge(src proto.Message)
func (*ComputeAck) XXX_Size ¶
func (m *ComputeAck) XXX_Size() int
func (*ComputeAck) XXX_Unmarshal ¶
func (m *ComputeAck) XXX_Unmarshal(b []byte) error
type ComputePartitionAck ¶
type ComputePartitionAck struct { PartitionId uint64 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"` AggregatedValues map[string]*types.Any `` /* 197-byte string literal not displayed */ }
func (*ComputePartitionAck) Descriptor ¶
func (*ComputePartitionAck) Descriptor() ([]byte, []int)
func (*ComputePartitionAck) Equal ¶
func (this *ComputePartitionAck) Equal(that interface{}) bool
func (*ComputePartitionAck) GetAggregatedValues ¶
func (m *ComputePartitionAck) GetAggregatedValues() map[string]*types.Any
func (*ComputePartitionAck) GetPartitionId ¶
func (m *ComputePartitionAck) GetPartitionId() uint64
func (*ComputePartitionAck) GoString ¶
func (this *ComputePartitionAck) GoString() string
func (*ComputePartitionAck) Marshal ¶
func (m *ComputePartitionAck) Marshal() (dAtA []byte, err error)
func (*ComputePartitionAck) MarshalTo ¶
func (m *ComputePartitionAck) MarshalTo(dAtA []byte) (int, error)
func (*ComputePartitionAck) ProtoMessage ¶
func (*ComputePartitionAck) ProtoMessage()
func (*ComputePartitionAck) Reset ¶
func (m *ComputePartitionAck) Reset()
func (*ComputePartitionAck) Size ¶
func (m *ComputePartitionAck) Size() (n int)
func (*ComputePartitionAck) String ¶
func (this *ComputePartitionAck) String() string
func (*ComputePartitionAck) Unmarshal ¶
func (m *ComputePartitionAck) Unmarshal(dAtA []byte) error
func (*ComputePartitionAck) XXX_DiscardUnknown ¶
func (m *ComputePartitionAck) XXX_DiscardUnknown()
func (*ComputePartitionAck) XXX_Marshal ¶
func (m *ComputePartitionAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ComputePartitionAck) XXX_Merge ¶
func (m *ComputePartitionAck) XXX_Merge(src proto.Message)
func (*ComputePartitionAck) XXX_Size ¶
func (m *ComputePartitionAck) XXX_Size() int
func (*ComputePartitionAck) XXX_Unmarshal ¶
func (m *ComputePartitionAck) XXX_Unmarshal(b []byte) error
type ComputeWorkerAck ¶
type ComputeWorkerAck struct { WorkerPid *actor.PID `protobuf:"bytes,1,opt,name=worker_pid,json=workerPid,proto3" json:"worker_pid,omitempty"` AggregatedValues map[string]*types.Any `` /* 197-byte string literal not displayed */ }
func (*ComputeWorkerAck) Descriptor ¶
func (*ComputeWorkerAck) Descriptor() ([]byte, []int)
func (*ComputeWorkerAck) Equal ¶
func (this *ComputeWorkerAck) Equal(that interface{}) bool
func (*ComputeWorkerAck) GetAggregatedValues ¶
func (m *ComputeWorkerAck) GetAggregatedValues() map[string]*types.Any
func (*ComputeWorkerAck) GetWorkerPid ¶
func (m *ComputeWorkerAck) GetWorkerPid() *actor.PID
func (*ComputeWorkerAck) GoString ¶
func (this *ComputeWorkerAck) GoString() string
func (*ComputeWorkerAck) Marshal ¶
func (m *ComputeWorkerAck) Marshal() (dAtA []byte, err error)
func (*ComputeWorkerAck) ProtoMessage ¶
func (*ComputeWorkerAck) ProtoMessage()
func (*ComputeWorkerAck) Reset ¶
func (m *ComputeWorkerAck) Reset()
func (*ComputeWorkerAck) Size ¶
func (m *ComputeWorkerAck) Size() (n int)
func (*ComputeWorkerAck) String ¶
func (this *ComputeWorkerAck) String() string
func (*ComputeWorkerAck) Unmarshal ¶
func (m *ComputeWorkerAck) Unmarshal(dAtA []byte) error
func (*ComputeWorkerAck) XXX_DiscardUnknown ¶
func (m *ComputeWorkerAck) XXX_DiscardUnknown()
func (*ComputeWorkerAck) XXX_Marshal ¶
func (m *ComputeWorkerAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ComputeWorkerAck) XXX_Merge ¶
func (m *ComputeWorkerAck) XXX_Merge(src proto.Message)
func (*ComputeWorkerAck) XXX_Size ¶
func (m *ComputeWorkerAck) XXX_Size() int
func (*ComputeWorkerAck) XXX_Unmarshal ¶
func (m *ComputeWorkerAck) XXX_Unmarshal(b []byte) error
type CoordinatorStats ¶
type CoordinatorStats struct { }
func (*CoordinatorStats) Descriptor ¶
func (*CoordinatorStats) Descriptor() ([]byte, []int)
func (*CoordinatorStats) Equal ¶
func (this *CoordinatorStats) Equal(that interface{}) bool
func (*CoordinatorStats) GoString ¶
func (this *CoordinatorStats) GoString() string
func (*CoordinatorStats) Marshal ¶
func (m *CoordinatorStats) Marshal() (dAtA []byte, err error)
func (*CoordinatorStats) ProtoMessage ¶
func (*CoordinatorStats) ProtoMessage()
func (*CoordinatorStats) Reset ¶
func (m *CoordinatorStats) Reset()
func (*CoordinatorStats) Size ¶
func (m *CoordinatorStats) Size() (n int)
func (*CoordinatorStats) String ¶
func (this *CoordinatorStats) String() string
func (*CoordinatorStats) Unmarshal ¶
func (m *CoordinatorStats) Unmarshal(dAtA []byte) error
func (*CoordinatorStats) XXX_DiscardUnknown ¶
func (m *CoordinatorStats) XXX_DiscardUnknown()
func (*CoordinatorStats) XXX_Marshal ¶
func (m *CoordinatorStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CoordinatorStats) XXX_Merge ¶
func (m *CoordinatorStats) XXX_Merge(src proto.Message)
func (*CoordinatorStats) XXX_Size ¶
func (m *CoordinatorStats) XXX_Size() int
func (*CoordinatorStats) XXX_Unmarshal ¶
func (m *CoordinatorStats) XXX_Unmarshal(b []byte) error
type CoordinatorStatsAck ¶
type CoordinatorStatsAck struct { SuperStep uint64 `protobuf:"varint,1,opt,name=super_step,json=superStep,proto3" json:"super_step,omitempty"` NrOfActiveVertex uint64 `protobuf:"varint,2,opt,name=nr_of_active_vertex,json=nrOfActiveVertex,proto3" json:"nr_of_active_vertex,omitempty"` NrOfSentMessages uint64 `protobuf:"varint,3,opt,name=nr_of_sent_messages,json=nrOfSentMessages,proto3" json:"nr_of_sent_messages,omitempty"` State string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"` }
func (*CoordinatorStatsAck) Descriptor ¶
func (*CoordinatorStatsAck) Descriptor() ([]byte, []int)
func (*CoordinatorStatsAck) Equal ¶
func (this *CoordinatorStatsAck) Equal(that interface{}) bool
func (*CoordinatorStatsAck) GetNrOfActiveVertex ¶
func (m *CoordinatorStatsAck) GetNrOfActiveVertex() uint64
func (*CoordinatorStatsAck) GetNrOfSentMessages ¶
func (m *CoordinatorStatsAck) GetNrOfSentMessages() uint64
func (*CoordinatorStatsAck) GetState ¶
func (m *CoordinatorStatsAck) GetState() string
func (*CoordinatorStatsAck) GetSuperStep ¶
func (m *CoordinatorStatsAck) GetSuperStep() uint64
func (*CoordinatorStatsAck) GoString ¶
func (this *CoordinatorStatsAck) GoString() string
func (*CoordinatorStatsAck) Marshal ¶
func (m *CoordinatorStatsAck) Marshal() (dAtA []byte, err error)
func (*CoordinatorStatsAck) MarshalTo ¶
func (m *CoordinatorStatsAck) MarshalTo(dAtA []byte) (int, error)
func (*CoordinatorStatsAck) ProtoMessage ¶
func (*CoordinatorStatsAck) ProtoMessage()
func (*CoordinatorStatsAck) Reset ¶
func (m *CoordinatorStatsAck) Reset()
func (*CoordinatorStatsAck) Size ¶
func (m *CoordinatorStatsAck) Size() (n int)
func (*CoordinatorStatsAck) StatsCompleted ¶
func (s *CoordinatorStatsAck) StatsCompleted() bool
StatsCompleted returns if CoordinatorStatsAck shows processing has finished or not
func (*CoordinatorStatsAck) String ¶
func (this *CoordinatorStatsAck) String() string
func (*CoordinatorStatsAck) Unmarshal ¶
func (m *CoordinatorStatsAck) Unmarshal(dAtA []byte) error
func (*CoordinatorStatsAck) XXX_DiscardUnknown ¶
func (m *CoordinatorStatsAck) XXX_DiscardUnknown()
func (*CoordinatorStatsAck) XXX_Marshal ¶
func (m *CoordinatorStatsAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CoordinatorStatsAck) XXX_Merge ¶
func (m *CoordinatorStatsAck) XXX_Merge(src proto.Message)
func (*CoordinatorStatsAck) XXX_Size ¶
func (m *CoordinatorStatsAck) XXX_Size() int
func (*CoordinatorStatsAck) XXX_Unmarshal ¶
func (m *CoordinatorStatsAck) XXX_Unmarshal(b []byte) error
type GetVertexValue ¶
type GetVertexValue struct {
VertexId string `protobuf:"bytes,1,opt,name=vertex_id,json=vertexId,proto3" json:"vertex_id,omitempty"`
}
func (*GetVertexValue) Descriptor ¶
func (*GetVertexValue) Descriptor() ([]byte, []int)
func (*GetVertexValue) Equal ¶
func (this *GetVertexValue) Equal(that interface{}) bool
func (*GetVertexValue) GetVertexId ¶
func (m *GetVertexValue) GetVertexId() string
func (*GetVertexValue) GoString ¶
func (this *GetVertexValue) GoString() string
func (*GetVertexValue) Marshal ¶
func (m *GetVertexValue) Marshal() (dAtA []byte, err error)
func (*GetVertexValue) ProtoMessage ¶
func (*GetVertexValue) ProtoMessage()
func (*GetVertexValue) Reset ¶
func (m *GetVertexValue) Reset()
func (*GetVertexValue) Size ¶
func (m *GetVertexValue) Size() (n int)
func (*GetVertexValue) String ¶
func (this *GetVertexValue) String() string
func (*GetVertexValue) Unmarshal ¶
func (m *GetVertexValue) Unmarshal(dAtA []byte) error
func (*GetVertexValue) XXX_DiscardUnknown ¶
func (m *GetVertexValue) XXX_DiscardUnknown()
func (*GetVertexValue) XXX_Marshal ¶
func (m *GetVertexValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetVertexValue) XXX_Merge ¶
func (m *GetVertexValue) XXX_Merge(src proto.Message)
func (*GetVertexValue) XXX_Size ¶
func (m *GetVertexValue) XXX_Size() int
func (*GetVertexValue) XXX_Unmarshal ¶
func (m *GetVertexValue) XXX_Unmarshal(b []byte) error
type GetVertexValueAck ¶
type GetVertexValueAck struct { VertexId string `protobuf:"bytes,1,opt,name=vertex_id,json=vertexId,proto3" json:"vertex_id,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` }
func (*GetVertexValueAck) Descriptor ¶
func (*GetVertexValueAck) Descriptor() ([]byte, []int)
func (*GetVertexValueAck) Equal ¶
func (this *GetVertexValueAck) Equal(that interface{}) bool
func (*GetVertexValueAck) GetValue ¶
func (m *GetVertexValueAck) GetValue() string
func (*GetVertexValueAck) GetVertexId ¶
func (m *GetVertexValueAck) GetVertexId() string
func (*GetVertexValueAck) GoString ¶
func (this *GetVertexValueAck) GoString() string
func (*GetVertexValueAck) Marshal ¶
func (m *GetVertexValueAck) Marshal() (dAtA []byte, err error)
func (*GetVertexValueAck) MarshalTo ¶
func (m *GetVertexValueAck) MarshalTo(dAtA []byte) (int, error)
func (*GetVertexValueAck) ProtoMessage ¶
func (*GetVertexValueAck) ProtoMessage()
func (*GetVertexValueAck) Reset ¶
func (m *GetVertexValueAck) Reset()
func (*GetVertexValueAck) Size ¶
func (m *GetVertexValueAck) Size() (n int)
func (*GetVertexValueAck) String ¶
func (this *GetVertexValueAck) String() string
func (*GetVertexValueAck) Unmarshal ¶
func (m *GetVertexValueAck) Unmarshal(dAtA []byte) error
func (*GetVertexValueAck) XXX_DiscardUnknown ¶
func (m *GetVertexValueAck) XXX_DiscardUnknown()
func (*GetVertexValueAck) XXX_Marshal ¶
func (m *GetVertexValueAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetVertexValueAck) XXX_Merge ¶
func (m *GetVertexValueAck) XXX_Merge(src proto.Message)
func (*GetVertexValueAck) XXX_Size ¶
func (m *GetVertexValueAck) XXX_Size() int
func (*GetVertexValueAck) XXX_Unmarshal ¶
func (m *GetVertexValueAck) XXX_Unmarshal(b []byte) error
type InitPartition ¶
type InitPartition struct {
PartitionId uint64 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
}
func (*InitPartition) Descriptor ¶
func (*InitPartition) Descriptor() ([]byte, []int)
func (*InitPartition) Equal ¶
func (this *InitPartition) Equal(that interface{}) bool
func (*InitPartition) GetPartitionId ¶
func (m *InitPartition) GetPartitionId() uint64
func (*InitPartition) GoString ¶
func (this *InitPartition) GoString() string
func (*InitPartition) Marshal ¶
func (m *InitPartition) Marshal() (dAtA []byte, err error)
func (*InitPartition) ProtoMessage ¶
func (*InitPartition) ProtoMessage()
func (*InitPartition) Reset ¶
func (m *InitPartition) Reset()
func (*InitPartition) Size ¶
func (m *InitPartition) Size() (n int)
func (*InitPartition) String ¶
func (this *InitPartition) String() string
func (*InitPartition) Unmarshal ¶
func (m *InitPartition) Unmarshal(dAtA []byte) error
func (*InitPartition) XXX_DiscardUnknown ¶
func (m *InitPartition) XXX_DiscardUnknown()
func (*InitPartition) XXX_Marshal ¶
func (m *InitPartition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitPartition) XXX_Merge ¶
func (m *InitPartition) XXX_Merge(src proto.Message)
func (*InitPartition) XXX_Size ¶
func (m *InitPartition) XXX_Size() int
func (*InitPartition) XXX_Unmarshal ¶
func (m *InitPartition) XXX_Unmarshal(b []byte) error
type InitPartitionAck ¶
type InitPartitionAck struct {
PartitionId uint64 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
}
func (*InitPartitionAck) Descriptor ¶
func (*InitPartitionAck) Descriptor() ([]byte, []int)
func (*InitPartitionAck) Equal ¶
func (this *InitPartitionAck) Equal(that interface{}) bool
func (*InitPartitionAck) GetPartitionId ¶
func (m *InitPartitionAck) GetPartitionId() uint64
func (*InitPartitionAck) GoString ¶
func (this *InitPartitionAck) GoString() string
func (*InitPartitionAck) Marshal ¶
func (m *InitPartitionAck) Marshal() (dAtA []byte, err error)
func (*InitPartitionAck) ProtoMessage ¶
func (*InitPartitionAck) ProtoMessage()
func (*InitPartitionAck) Reset ¶
func (m *InitPartitionAck) Reset()
func (*InitPartitionAck) Size ¶
func (m *InitPartitionAck) Size() (n int)
func (*InitPartitionAck) String ¶
func (this *InitPartitionAck) String() string
func (*InitPartitionAck) Unmarshal ¶
func (m *InitPartitionAck) Unmarshal(dAtA []byte) error
func (*InitPartitionAck) XXX_DiscardUnknown ¶
func (m *InitPartitionAck) XXX_DiscardUnknown()
func (*InitPartitionAck) XXX_Marshal ¶
func (m *InitPartitionAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitPartitionAck) XXX_Merge ¶
func (m *InitPartitionAck) XXX_Merge(src proto.Message)
func (*InitPartitionAck) XXX_Size ¶
func (m *InitPartitionAck) XXX_Size() int
func (*InitPartitionAck) XXX_Unmarshal ¶
func (m *InitPartitionAck) XXX_Unmarshal(b []byte) error
type InitWorker ¶
type InitWorker struct { Coordinator *actor.PID `protobuf:"bytes,1,opt,name=coordinator,proto3" json:"coordinator,omitempty"` Partitions []uint64 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` }
func (*InitWorker) Descriptor ¶
func (*InitWorker) Descriptor() ([]byte, []int)
func (*InitWorker) Equal ¶
func (this *InitWorker) Equal(that interface{}) bool
func (*InitWorker) GetCoordinator ¶
func (m *InitWorker) GetCoordinator() *actor.PID
func (*InitWorker) GetPartitions ¶
func (m *InitWorker) GetPartitions() []uint64
func (*InitWorker) GoString ¶
func (this *InitWorker) GoString() string
func (*InitWorker) Marshal ¶
func (m *InitWorker) Marshal() (dAtA []byte, err error)
func (*InitWorker) ProtoMessage ¶
func (*InitWorker) ProtoMessage()
func (*InitWorker) Reset ¶
func (m *InitWorker) Reset()
func (*InitWorker) Size ¶
func (m *InitWorker) Size() (n int)
func (*InitWorker) String ¶
func (this *InitWorker) String() string
func (*InitWorker) Unmarshal ¶
func (m *InitWorker) Unmarshal(dAtA []byte) error
func (*InitWorker) XXX_DiscardUnknown ¶
func (m *InitWorker) XXX_DiscardUnknown()
func (*InitWorker) XXX_Marshal ¶
func (m *InitWorker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitWorker) XXX_Merge ¶
func (m *InitWorker) XXX_Merge(src proto.Message)
func (*InitWorker) XXX_Size ¶
func (m *InitWorker) XXX_Size() int
func (*InitWorker) XXX_Unmarshal ¶
func (m *InitWorker) XXX_Unmarshal(b []byte) error
type InitWorkerAck ¶
type InitWorkerAck struct {
WorkerPid *actor.PID `protobuf:"bytes,1,opt,name=worker_pid,json=workerPid,proto3" json:"worker_pid,omitempty"`
}
func (*InitWorkerAck) Descriptor ¶
func (*InitWorkerAck) Descriptor() ([]byte, []int)
func (*InitWorkerAck) Equal ¶
func (this *InitWorkerAck) Equal(that interface{}) bool
func (*InitWorkerAck) GetWorkerPid ¶
func (m *InitWorkerAck) GetWorkerPid() *actor.PID
func (*InitWorkerAck) GoString ¶
func (this *InitWorkerAck) GoString() string
func (*InitWorkerAck) Marshal ¶
func (m *InitWorkerAck) Marshal() (dAtA []byte, err error)
func (*InitWorkerAck) ProtoMessage ¶
func (*InitWorkerAck) ProtoMessage()
func (*InitWorkerAck) Reset ¶
func (m *InitWorkerAck) Reset()
func (*InitWorkerAck) Size ¶
func (m *InitWorkerAck) Size() (n int)
func (*InitWorkerAck) String ¶
func (this *InitWorkerAck) String() string
func (*InitWorkerAck) Unmarshal ¶
func (m *InitWorkerAck) Unmarshal(dAtA []byte) error
func (*InitWorkerAck) XXX_DiscardUnknown ¶
func (m *InitWorkerAck) XXX_DiscardUnknown()
func (*InitWorkerAck) XXX_Marshal ¶
func (m *InitWorkerAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitWorkerAck) XXX_Merge ¶
func (m *InitWorkerAck) XXX_Merge(src proto.Message)
func (*InitWorkerAck) XXX_Size ¶
func (m *InitWorkerAck) XXX_Size() int
func (*InitWorkerAck) XXX_Unmarshal ¶
func (m *InitWorkerAck) XXX_Unmarshal(b []byte) error
type LoadPartitionVertices ¶
type LoadPartitionVertices struct {
NumOfPartitions uint64 `protobuf:"varint,1,opt,name=num_of_partitions,json=numOfPartitions,proto3" json:"num_of_partitions,omitempty"`
}
func (*LoadPartitionVertices) Descriptor ¶
func (*LoadPartitionVertices) Descriptor() ([]byte, []int)
func (*LoadPartitionVertices) Equal ¶
func (this *LoadPartitionVertices) Equal(that interface{}) bool
func (*LoadPartitionVertices) GetNumOfPartitions ¶
func (m *LoadPartitionVertices) GetNumOfPartitions() uint64
func (*LoadPartitionVertices) GoString ¶
func (this *LoadPartitionVertices) GoString() string
func (*LoadPartitionVertices) Marshal ¶
func (m *LoadPartitionVertices) Marshal() (dAtA []byte, err error)
func (*LoadPartitionVertices) MarshalTo ¶
func (m *LoadPartitionVertices) MarshalTo(dAtA []byte) (int, error)
func (*LoadPartitionVertices) ProtoMessage ¶
func (*LoadPartitionVertices) ProtoMessage()
func (*LoadPartitionVertices) Reset ¶
func (m *LoadPartitionVertices) Reset()
func (*LoadPartitionVertices) Size ¶
func (m *LoadPartitionVertices) Size() (n int)
func (*LoadPartitionVertices) String ¶
func (this *LoadPartitionVertices) String() string
func (*LoadPartitionVertices) Unmarshal ¶
func (m *LoadPartitionVertices) Unmarshal(dAtA []byte) error
func (*LoadPartitionVertices) XXX_DiscardUnknown ¶
func (m *LoadPartitionVertices) XXX_DiscardUnknown()
func (*LoadPartitionVertices) XXX_Marshal ¶
func (m *LoadPartitionVertices) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadPartitionVertices) XXX_Merge ¶
func (m *LoadPartitionVertices) XXX_Merge(src proto.Message)
func (*LoadPartitionVertices) XXX_Size ¶
func (m *LoadPartitionVertices) XXX_Size() int
func (*LoadPartitionVertices) XXX_Unmarshal ¶
func (m *LoadPartitionVertices) XXX_Unmarshal(b []byte) error
type LoadPartitionVerticesAck ¶
type LoadPartitionVerticesAck struct { PartitionId uint64 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` }
func (*LoadPartitionVerticesAck) Descriptor ¶
func (*LoadPartitionVerticesAck) Descriptor() ([]byte, []int)
func (*LoadPartitionVerticesAck) Equal ¶
func (this *LoadPartitionVerticesAck) Equal(that interface{}) bool
func (*LoadPartitionVerticesAck) GetError ¶
func (m *LoadPartitionVerticesAck) GetError() string
func (*LoadPartitionVerticesAck) GetPartitionId ¶
func (m *LoadPartitionVerticesAck) GetPartitionId() uint64
func (*LoadPartitionVerticesAck) GoString ¶
func (this *LoadPartitionVerticesAck) GoString() string
func (*LoadPartitionVerticesAck) Marshal ¶
func (m *LoadPartitionVerticesAck) Marshal() (dAtA []byte, err error)
func (*LoadPartitionVerticesAck) MarshalTo ¶
func (m *LoadPartitionVerticesAck) MarshalTo(dAtA []byte) (int, error)
func (*LoadPartitionVerticesAck) ProtoMessage ¶
func (*LoadPartitionVerticesAck) ProtoMessage()
func (*LoadPartitionVerticesAck) Reset ¶
func (m *LoadPartitionVerticesAck) Reset()
func (*LoadPartitionVerticesAck) Size ¶
func (m *LoadPartitionVerticesAck) Size() (n int)
func (*LoadPartitionVerticesAck) String ¶
func (this *LoadPartitionVerticesAck) String() string
func (*LoadPartitionVerticesAck) Unmarshal ¶
func (m *LoadPartitionVerticesAck) Unmarshal(dAtA []byte) error
func (*LoadPartitionVerticesAck) XXX_DiscardUnknown ¶
func (m *LoadPartitionVerticesAck) XXX_DiscardUnknown()
func (*LoadPartitionVerticesAck) XXX_Marshal ¶
func (m *LoadPartitionVerticesAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadPartitionVerticesAck) XXX_Merge ¶
func (m *LoadPartitionVerticesAck) XXX_Merge(src proto.Message)
func (*LoadPartitionVerticesAck) XXX_Size ¶
func (m *LoadPartitionVerticesAck) XXX_Size() int
func (*LoadPartitionVerticesAck) XXX_Unmarshal ¶
func (m *LoadPartitionVerticesAck) XXX_Unmarshal(b []byte) error
type LoadPartitionVerticesWorkerAck ¶
type LoadPartitionVerticesWorkerAck struct {
WorkerPid *actor.PID `protobuf:"bytes,1,opt,name=worker_pid,json=workerPid,proto3" json:"worker_pid,omitempty"`
}
func (*LoadPartitionVerticesWorkerAck) Descriptor ¶
func (*LoadPartitionVerticesWorkerAck) Descriptor() ([]byte, []int)
func (*LoadPartitionVerticesWorkerAck) Equal ¶
func (this *LoadPartitionVerticesWorkerAck) Equal(that interface{}) bool
func (*LoadPartitionVerticesWorkerAck) GetWorkerPid ¶
func (m *LoadPartitionVerticesWorkerAck) GetWorkerPid() *actor.PID
func (*LoadPartitionVerticesWorkerAck) GoString ¶
func (this *LoadPartitionVerticesWorkerAck) GoString() string
func (*LoadPartitionVerticesWorkerAck) Marshal ¶
func (m *LoadPartitionVerticesWorkerAck) Marshal() (dAtA []byte, err error)
func (*LoadPartitionVerticesWorkerAck) MarshalTo ¶
func (m *LoadPartitionVerticesWorkerAck) MarshalTo(dAtA []byte) (int, error)
func (*LoadPartitionVerticesWorkerAck) ProtoMessage ¶
func (*LoadPartitionVerticesWorkerAck) ProtoMessage()
func (*LoadPartitionVerticesWorkerAck) Reset ¶
func (m *LoadPartitionVerticesWorkerAck) Reset()
func (*LoadPartitionVerticesWorkerAck) Size ¶
func (m *LoadPartitionVerticesWorkerAck) Size() (n int)
func (*LoadPartitionVerticesWorkerAck) String ¶
func (this *LoadPartitionVerticesWorkerAck) String() string
func (*LoadPartitionVerticesWorkerAck) Unmarshal ¶
func (m *LoadPartitionVerticesWorkerAck) Unmarshal(dAtA []byte) error
func (*LoadPartitionVerticesWorkerAck) XXX_DiscardUnknown ¶
func (m *LoadPartitionVerticesWorkerAck) XXX_DiscardUnknown()
func (*LoadPartitionVerticesWorkerAck) XXX_Marshal ¶
func (m *LoadPartitionVerticesWorkerAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadPartitionVerticesWorkerAck) XXX_Merge ¶
func (m *LoadPartitionVerticesWorkerAck) XXX_Merge(src proto.Message)
func (*LoadPartitionVerticesWorkerAck) XXX_Size ¶
func (m *LoadPartitionVerticesWorkerAck) XXX_Size() int
func (*LoadPartitionVerticesWorkerAck) XXX_Unmarshal ¶
func (m *LoadPartitionVerticesWorkerAck) XXX_Unmarshal(b []byte) error
type LoadVertex ¶
type LoadVertex struct {
VertexId string `protobuf:"bytes,1,opt,name=vertex_id,json=vertexId,proto3" json:"vertex_id,omitempty"`
}
func (*LoadVertex) Descriptor ¶
func (*LoadVertex) Descriptor() ([]byte, []int)
func (*LoadVertex) Equal ¶
func (this *LoadVertex) Equal(that interface{}) bool
func (*LoadVertex) GetVertexId ¶
func (m *LoadVertex) GetVertexId() string
func (*LoadVertex) GoString ¶
func (this *LoadVertex) GoString() string
func (*LoadVertex) Marshal ¶
func (m *LoadVertex) Marshal() (dAtA []byte, err error)
func (*LoadVertex) ProtoMessage ¶
func (*LoadVertex) ProtoMessage()
func (*LoadVertex) Reset ¶
func (m *LoadVertex) Reset()
func (*LoadVertex) Size ¶
func (m *LoadVertex) Size() (n int)
func (*LoadVertex) String ¶
func (this *LoadVertex) String() string
func (*LoadVertex) Unmarshal ¶
func (m *LoadVertex) Unmarshal(dAtA []byte) error
func (*LoadVertex) XXX_DiscardUnknown ¶
func (m *LoadVertex) XXX_DiscardUnknown()
func (*LoadVertex) XXX_Marshal ¶
func (m *LoadVertex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadVertex) XXX_Merge ¶
func (m *LoadVertex) XXX_Merge(src proto.Message)
func (*LoadVertex) XXX_Size ¶
func (m *LoadVertex) XXX_Size() int
func (*LoadVertex) XXX_Unmarshal ¶
func (m *LoadVertex) XXX_Unmarshal(b []byte) error
type LoadVertexAck ¶
type LoadVertexAck struct { VertexId string `protobuf:"bytes,1,opt,name=vertex_id,json=vertexId,proto3" json:"vertex_id,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` }
func (*LoadVertexAck) Descriptor ¶
func (*LoadVertexAck) Descriptor() ([]byte, []int)
func (*LoadVertexAck) Equal ¶
func (this *LoadVertexAck) Equal(that interface{}) bool
func (*LoadVertexAck) GetError ¶
func (m *LoadVertexAck) GetError() string
func (*LoadVertexAck) GetVertexId ¶
func (m *LoadVertexAck) GetVertexId() string
func (*LoadVertexAck) GoString ¶
func (this *LoadVertexAck) GoString() string
func (*LoadVertexAck) Marshal ¶
func (m *LoadVertexAck) Marshal() (dAtA []byte, err error)
func (*LoadVertexAck) ProtoMessage ¶
func (*LoadVertexAck) ProtoMessage()
func (*LoadVertexAck) Reset ¶
func (m *LoadVertexAck) Reset()
func (*LoadVertexAck) Size ¶
func (m *LoadVertexAck) Size() (n int)
func (*LoadVertexAck) String ¶
func (this *LoadVertexAck) String() string
func (*LoadVertexAck) Unmarshal ¶
func (m *LoadVertexAck) Unmarshal(dAtA []byte) error
func (*LoadVertexAck) XXX_DiscardUnknown ¶
func (m *LoadVertexAck) XXX_DiscardUnknown()
func (*LoadVertexAck) XXX_Marshal ¶
func (m *LoadVertexAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadVertexAck) XXX_Merge ¶
func (m *LoadVertexAck) XXX_Merge(src proto.Message)
func (*LoadVertexAck) XXX_Size ¶
func (m *LoadVertexAck) XXX_Size() int
func (*LoadVertexAck) XXX_Unmarshal ¶
func (m *LoadVertexAck) XXX_Unmarshal(b []byte) error
type NewCluster ¶
type NewCluster struct { Workers []*NewCluster_WorkerReq `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"` NrOfPartitions uint64 `protobuf:"varint,2,opt,name=nr_of_partitions,json=nrOfPartitions,proto3" json:"nr_of_partitions,omitempty"` }
func (*NewCluster) Descriptor ¶
func (*NewCluster) Descriptor() ([]byte, []int)
func (*NewCluster) Equal ¶
func (this *NewCluster) Equal(that interface{}) bool
func (*NewCluster) GetNrOfPartitions ¶
func (m *NewCluster) GetNrOfPartitions() uint64
func (*NewCluster) GetWorkers ¶
func (m *NewCluster) GetWorkers() []*NewCluster_WorkerReq
func (*NewCluster) GoString ¶
func (this *NewCluster) GoString() string
func (*NewCluster) Marshal ¶
func (m *NewCluster) Marshal() (dAtA []byte, err error)
func (*NewCluster) ProtoMessage ¶
func (*NewCluster) ProtoMessage()
func (*NewCluster) Reset ¶
func (m *NewCluster) Reset()
func (*NewCluster) Size ¶
func (m *NewCluster) Size() (n int)
func (*NewCluster) String ¶
func (this *NewCluster) String() string
func (*NewCluster) Unmarshal ¶
func (m *NewCluster) Unmarshal(dAtA []byte) error
func (*NewCluster) XXX_DiscardUnknown ¶
func (m *NewCluster) XXX_DiscardUnknown()
func (*NewCluster) XXX_Marshal ¶
func (m *NewCluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NewCluster) XXX_Merge ¶
func (m *NewCluster) XXX_Merge(src proto.Message)
func (*NewCluster) XXX_Size ¶
func (m *NewCluster) XXX_Size() int
func (*NewCluster) XXX_Unmarshal ¶
func (m *NewCluster) XXX_Unmarshal(b []byte) error
type NewClusterAck ¶
type NewClusterAck struct { }
func (*NewClusterAck) Descriptor ¶
func (*NewClusterAck) Descriptor() ([]byte, []int)
func (*NewClusterAck) Equal ¶
func (this *NewClusterAck) Equal(that interface{}) bool
func (*NewClusterAck) GoString ¶
func (this *NewClusterAck) GoString() string
func (*NewClusterAck) Marshal ¶
func (m *NewClusterAck) Marshal() (dAtA []byte, err error)
func (*NewClusterAck) ProtoMessage ¶
func (*NewClusterAck) ProtoMessage()
func (*NewClusterAck) Reset ¶
func (m *NewClusterAck) Reset()
func (*NewClusterAck) Size ¶
func (m *NewClusterAck) Size() (n int)
func (*NewClusterAck) String ¶
func (this *NewClusterAck) String() string
func (*NewClusterAck) Unmarshal ¶
func (m *NewClusterAck) Unmarshal(dAtA []byte) error
func (*NewClusterAck) XXX_DiscardUnknown ¶
func (m *NewClusterAck) XXX_DiscardUnknown()
func (*NewClusterAck) XXX_Marshal ¶
func (m *NewClusterAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NewClusterAck) XXX_Merge ¶
func (m *NewClusterAck) XXX_Merge(src proto.Message)
func (*NewClusterAck) XXX_Size ¶
func (m *NewClusterAck) XXX_Size() int
func (*NewClusterAck) XXX_Unmarshal ¶
func (m *NewClusterAck) XXX_Unmarshal(b []byte) error
type NewCluster_WorkerReq ¶
type NewCluster_WorkerReq struct { Remote bool `protobuf:"varint,1,opt,name=remote,proto3" json:"remote,omitempty"` HostAndPort string `protobuf:"bytes,2,opt,name=host_and_port,json=hostAndPort,proto3" json:"host_and_port,omitempty"` }
func (*NewCluster_WorkerReq) Descriptor ¶
func (*NewCluster_WorkerReq) Descriptor() ([]byte, []int)
func (*NewCluster_WorkerReq) Equal ¶
func (this *NewCluster_WorkerReq) Equal(that interface{}) bool
func (*NewCluster_WorkerReq) GetHostAndPort ¶
func (m *NewCluster_WorkerReq) GetHostAndPort() string
func (*NewCluster_WorkerReq) GetRemote ¶
func (m *NewCluster_WorkerReq) GetRemote() bool
func (*NewCluster_WorkerReq) GoString ¶
func (this *NewCluster_WorkerReq) GoString() string
func (*NewCluster_WorkerReq) Marshal ¶
func (m *NewCluster_WorkerReq) Marshal() (dAtA []byte, err error)
func (*NewCluster_WorkerReq) MarshalTo ¶
func (m *NewCluster_WorkerReq) MarshalTo(dAtA []byte) (int, error)
func (*NewCluster_WorkerReq) ProtoMessage ¶
func (*NewCluster_WorkerReq) ProtoMessage()
func (*NewCluster_WorkerReq) Reset ¶
func (m *NewCluster_WorkerReq) Reset()
func (*NewCluster_WorkerReq) Size ¶
func (m *NewCluster_WorkerReq) Size() (n int)
func (*NewCluster_WorkerReq) String ¶
func (this *NewCluster_WorkerReq) String() string
func (*NewCluster_WorkerReq) Unmarshal ¶
func (m *NewCluster_WorkerReq) Unmarshal(dAtA []byte) error
func (*NewCluster_WorkerReq) XXX_DiscardUnknown ¶
func (m *NewCluster_WorkerReq) XXX_DiscardUnknown()
func (*NewCluster_WorkerReq) XXX_Marshal ¶
func (m *NewCluster_WorkerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NewCluster_WorkerReq) XXX_Merge ¶
func (m *NewCluster_WorkerReq) XXX_Merge(src proto.Message)
func (*NewCluster_WorkerReq) XXX_Size ¶
func (m *NewCluster_WorkerReq) XXX_Size() int
func (*NewCluster_WorkerReq) XXX_Unmarshal ¶
func (m *NewCluster_WorkerReq) XXX_Unmarshal(b []byte) error
type ShowAggregatedValue ¶
type ShowAggregatedValue struct { }
func (*ShowAggregatedValue) Descriptor ¶
func (*ShowAggregatedValue) Descriptor() ([]byte, []int)
func (*ShowAggregatedValue) Equal ¶
func (this *ShowAggregatedValue) Equal(that interface{}) bool
func (*ShowAggregatedValue) GoString ¶
func (this *ShowAggregatedValue) GoString() string
func (*ShowAggregatedValue) Marshal ¶
func (m *ShowAggregatedValue) Marshal() (dAtA []byte, err error)
func (*ShowAggregatedValue) MarshalTo ¶
func (m *ShowAggregatedValue) MarshalTo(dAtA []byte) (int, error)
func (*ShowAggregatedValue) ProtoMessage ¶
func (*ShowAggregatedValue) ProtoMessage()
func (*ShowAggregatedValue) Reset ¶
func (m *ShowAggregatedValue) Reset()
func (*ShowAggregatedValue) Size ¶
func (m *ShowAggregatedValue) Size() (n int)
func (*ShowAggregatedValue) String ¶
func (this *ShowAggregatedValue) String() string
func (*ShowAggregatedValue) Unmarshal ¶
func (m *ShowAggregatedValue) Unmarshal(dAtA []byte) error
func (*ShowAggregatedValue) XXX_DiscardUnknown ¶
func (m *ShowAggregatedValue) XXX_DiscardUnknown()
func (*ShowAggregatedValue) XXX_Marshal ¶
func (m *ShowAggregatedValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShowAggregatedValue) XXX_Merge ¶
func (m *ShowAggregatedValue) XXX_Merge(src proto.Message)
func (*ShowAggregatedValue) XXX_Size ¶
func (m *ShowAggregatedValue) XXX_Size() int
func (*ShowAggregatedValue) XXX_Unmarshal ¶
func (m *ShowAggregatedValue) XXX_Unmarshal(b []byte) error
type ShowAggregatedValueAck ¶
type ShowAggregatedValueAck struct {
AggregatedValues map[string]string `` /* 197-byte string literal not displayed */
}
func (*ShowAggregatedValueAck) Descriptor ¶
func (*ShowAggregatedValueAck) Descriptor() ([]byte, []int)
func (*ShowAggregatedValueAck) Equal ¶
func (this *ShowAggregatedValueAck) Equal(that interface{}) bool
func (*ShowAggregatedValueAck) GetAggregatedValues ¶
func (m *ShowAggregatedValueAck) GetAggregatedValues() map[string]string
func (*ShowAggregatedValueAck) GoString ¶
func (this *ShowAggregatedValueAck) GoString() string
func (*ShowAggregatedValueAck) Marshal ¶
func (m *ShowAggregatedValueAck) Marshal() (dAtA []byte, err error)
func (*ShowAggregatedValueAck) MarshalTo ¶
func (m *ShowAggregatedValueAck) MarshalTo(dAtA []byte) (int, error)
func (*ShowAggregatedValueAck) ProtoMessage ¶
func (*ShowAggregatedValueAck) ProtoMessage()
func (*ShowAggregatedValueAck) Reset ¶
func (m *ShowAggregatedValueAck) Reset()
func (*ShowAggregatedValueAck) Size ¶
func (m *ShowAggregatedValueAck) Size() (n int)
func (*ShowAggregatedValueAck) String ¶
func (this *ShowAggregatedValueAck) String() string
func (*ShowAggregatedValueAck) Unmarshal ¶
func (m *ShowAggregatedValueAck) Unmarshal(dAtA []byte) error
func (*ShowAggregatedValueAck) XXX_DiscardUnknown ¶
func (m *ShowAggregatedValueAck) XXX_DiscardUnknown()
func (*ShowAggregatedValueAck) XXX_Marshal ¶
func (m *ShowAggregatedValueAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShowAggregatedValueAck) XXX_Merge ¶
func (m *ShowAggregatedValueAck) XXX_Merge(src proto.Message)
func (*ShowAggregatedValueAck) XXX_Size ¶
func (m *ShowAggregatedValueAck) XXX_Size() int
func (*ShowAggregatedValueAck) XXX_Unmarshal ¶
func (m *ShowAggregatedValueAck) XXX_Unmarshal(b []byte) error
type Shutdown ¶
type Shutdown struct { }
func (*Shutdown) Descriptor ¶
func (*Shutdown) ProtoMessage ¶
func (*Shutdown) ProtoMessage()
func (*Shutdown) XXX_DiscardUnknown ¶
func (m *Shutdown) XXX_DiscardUnknown()
func (*Shutdown) XXX_Marshal ¶
func (*Shutdown) XXX_Unmarshal ¶
type ShutdownAck ¶
type ShutdownAck struct { }
func (*ShutdownAck) Descriptor ¶
func (*ShutdownAck) Descriptor() ([]byte, []int)
func (*ShutdownAck) Equal ¶
func (this *ShutdownAck) Equal(that interface{}) bool
func (*ShutdownAck) GoString ¶
func (this *ShutdownAck) GoString() string
func (*ShutdownAck) Marshal ¶
func (m *ShutdownAck) Marshal() (dAtA []byte, err error)
func (*ShutdownAck) ProtoMessage ¶
func (*ShutdownAck) ProtoMessage()
func (*ShutdownAck) Reset ¶
func (m *ShutdownAck) Reset()
func (*ShutdownAck) Size ¶
func (m *ShutdownAck) Size() (n int)
func (*ShutdownAck) String ¶
func (this *ShutdownAck) String() string
func (*ShutdownAck) Unmarshal ¶
func (m *ShutdownAck) Unmarshal(dAtA []byte) error
func (*ShutdownAck) XXX_DiscardUnknown ¶
func (m *ShutdownAck) XXX_DiscardUnknown()
func (*ShutdownAck) XXX_Marshal ¶
func (m *ShutdownAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShutdownAck) XXX_Merge ¶
func (m *ShutdownAck) XXX_Merge(src proto.Message)
func (*ShutdownAck) XXX_Size ¶
func (m *ShutdownAck) XXX_Size() int
func (*ShutdownAck) XXX_Unmarshal ¶
func (m *ShutdownAck) XXX_Unmarshal(b []byte) error
type StartSuperStep ¶
type StartSuperStep struct { }
func (*StartSuperStep) Descriptor ¶
func (*StartSuperStep) Descriptor() ([]byte, []int)
func (*StartSuperStep) Equal ¶
func (this *StartSuperStep) Equal(that interface{}) bool
func (*StartSuperStep) GoString ¶
func (this *StartSuperStep) GoString() string
func (*StartSuperStep) Marshal ¶
func (m *StartSuperStep) Marshal() (dAtA []byte, err error)
func (*StartSuperStep) ProtoMessage ¶
func (*StartSuperStep) ProtoMessage()
func (*StartSuperStep) Reset ¶
func (m *StartSuperStep) Reset()
func (*StartSuperStep) Size ¶
func (m *StartSuperStep) Size() (n int)
func (*StartSuperStep) String ¶
func (this *StartSuperStep) String() string
func (*StartSuperStep) Unmarshal ¶
func (m *StartSuperStep) Unmarshal(dAtA []byte) error
func (*StartSuperStep) XXX_DiscardUnknown ¶
func (m *StartSuperStep) XXX_DiscardUnknown()
func (*StartSuperStep) XXX_Marshal ¶
func (m *StartSuperStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartSuperStep) XXX_Merge ¶
func (m *StartSuperStep) XXX_Merge(src proto.Message)
func (*StartSuperStep) XXX_Size ¶
func (m *StartSuperStep) XXX_Size() int
func (*StartSuperStep) XXX_Unmarshal ¶
func (m *StartSuperStep) XXX_Unmarshal(b []byte) error
type SuperStepBarrier ¶
type SuperStepBarrier struct { }
func (*SuperStepBarrier) Descriptor ¶
func (*SuperStepBarrier) Descriptor() ([]byte, []int)
func (*SuperStepBarrier) Equal ¶
func (this *SuperStepBarrier) Equal(that interface{}) bool
func (*SuperStepBarrier) GoString ¶
func (this *SuperStepBarrier) GoString() string
func (*SuperStepBarrier) Marshal ¶
func (m *SuperStepBarrier) Marshal() (dAtA []byte, err error)
func (*SuperStepBarrier) ProtoMessage ¶
func (*SuperStepBarrier) ProtoMessage()
func (*SuperStepBarrier) Reset ¶
func (m *SuperStepBarrier) Reset()
func (*SuperStepBarrier) Size ¶
func (m *SuperStepBarrier) Size() (n int)
func (*SuperStepBarrier) String ¶
func (this *SuperStepBarrier) String() string
func (*SuperStepBarrier) Unmarshal ¶
func (m *SuperStepBarrier) Unmarshal(dAtA []byte) error
func (*SuperStepBarrier) XXX_DiscardUnknown ¶
func (m *SuperStepBarrier) XXX_DiscardUnknown()
func (*SuperStepBarrier) XXX_Marshal ¶
func (m *SuperStepBarrier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SuperStepBarrier) XXX_Merge ¶
func (m *SuperStepBarrier) XXX_Merge(src proto.Message)
func (*SuperStepBarrier) XXX_Size ¶
func (m *SuperStepBarrier) XXX_Size() int
func (*SuperStepBarrier) XXX_Unmarshal ¶
func (m *SuperStepBarrier) XXX_Unmarshal(b []byte) error
type SuperStepBarrierAck ¶
type SuperStepBarrierAck struct {
VertexId string `protobuf:"bytes,1,opt,name=vertex_id,json=vertexId,proto3" json:"vertex_id,omitempty"`
}
func (*SuperStepBarrierAck) Descriptor ¶
func (*SuperStepBarrierAck) Descriptor() ([]byte, []int)
func (*SuperStepBarrierAck) Equal ¶
func (this *SuperStepBarrierAck) Equal(that interface{}) bool
func (*SuperStepBarrierAck) GetVertexId ¶
func (m *SuperStepBarrierAck) GetVertexId() string
func (*SuperStepBarrierAck) GoString ¶
func (this *SuperStepBarrierAck) GoString() string
func (*SuperStepBarrierAck) Marshal ¶
func (m *SuperStepBarrierAck) Marshal() (dAtA []byte, err error)
func (*SuperStepBarrierAck) MarshalTo ¶
func (m *SuperStepBarrierAck) MarshalTo(dAtA []byte) (int, error)
func (*SuperStepBarrierAck) ProtoMessage ¶
func (*SuperStepBarrierAck) ProtoMessage()
func (*SuperStepBarrierAck) Reset ¶
func (m *SuperStepBarrierAck) Reset()
func (*SuperStepBarrierAck) Size ¶
func (m *SuperStepBarrierAck) Size() (n int)
func (*SuperStepBarrierAck) String ¶
func (this *SuperStepBarrierAck) String() string
func (*SuperStepBarrierAck) Unmarshal ¶
func (m *SuperStepBarrierAck) Unmarshal(dAtA []byte) error
func (*SuperStepBarrierAck) XXX_DiscardUnknown ¶
func (m *SuperStepBarrierAck) XXX_DiscardUnknown()
func (*SuperStepBarrierAck) XXX_Marshal ¶
func (m *SuperStepBarrierAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SuperStepBarrierAck) XXX_Merge ¶
func (m *SuperStepBarrierAck) XXX_Merge(src proto.Message)
func (*SuperStepBarrierAck) XXX_Size ¶
func (m *SuperStepBarrierAck) XXX_Size() int
func (*SuperStepBarrierAck) XXX_Unmarshal ¶
func (m *SuperStepBarrierAck) XXX_Unmarshal(b []byte) error
type SuperStepBarrierPartitionAck ¶
type SuperStepBarrierPartitionAck struct {
PartitionId uint64 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
}
func (*SuperStepBarrierPartitionAck) Descriptor ¶
func (*SuperStepBarrierPartitionAck) Descriptor() ([]byte, []int)
func (*SuperStepBarrierPartitionAck) Equal ¶
func (this *SuperStepBarrierPartitionAck) Equal(that interface{}) bool
func (*SuperStepBarrierPartitionAck) GetPartitionId ¶
func (m *SuperStepBarrierPartitionAck) GetPartitionId() uint64
func (*SuperStepBarrierPartitionAck) GoString ¶
func (this *SuperStepBarrierPartitionAck) GoString() string
func (*SuperStepBarrierPartitionAck) Marshal ¶
func (m *SuperStepBarrierPartitionAck) Marshal() (dAtA []byte, err error)
func (*SuperStepBarrierPartitionAck) MarshalTo ¶
func (m *SuperStepBarrierPartitionAck) MarshalTo(dAtA []byte) (int, error)
func (*SuperStepBarrierPartitionAck) ProtoMessage ¶
func (*SuperStepBarrierPartitionAck) ProtoMessage()
func (*SuperStepBarrierPartitionAck) Reset ¶
func (m *SuperStepBarrierPartitionAck) Reset()
func (*SuperStepBarrierPartitionAck) Size ¶
func (m *SuperStepBarrierPartitionAck) Size() (n int)
func (*SuperStepBarrierPartitionAck) String ¶
func (this *SuperStepBarrierPartitionAck) String() string
func (*SuperStepBarrierPartitionAck) Unmarshal ¶
func (m *SuperStepBarrierPartitionAck) Unmarshal(dAtA []byte) error
func (*SuperStepBarrierPartitionAck) XXX_DiscardUnknown ¶
func (m *SuperStepBarrierPartitionAck) XXX_DiscardUnknown()
func (*SuperStepBarrierPartitionAck) XXX_Marshal ¶
func (m *SuperStepBarrierPartitionAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SuperStepBarrierPartitionAck) XXX_Merge ¶
func (m *SuperStepBarrierPartitionAck) XXX_Merge(src proto.Message)
func (*SuperStepBarrierPartitionAck) XXX_Size ¶
func (m *SuperStepBarrierPartitionAck) XXX_Size() int
func (*SuperStepBarrierPartitionAck) XXX_Unmarshal ¶
func (m *SuperStepBarrierPartitionAck) XXX_Unmarshal(b []byte) error
type SuperStepBarrierWorkerAck ¶
type SuperStepBarrierWorkerAck struct {
WorkerPid *actor.PID `protobuf:"bytes,1,opt,name=worker_pid,json=workerPid,proto3" json:"worker_pid,omitempty"`
}
func (*SuperStepBarrierWorkerAck) Descriptor ¶
func (*SuperStepBarrierWorkerAck) Descriptor() ([]byte, []int)
func (*SuperStepBarrierWorkerAck) Equal ¶
func (this *SuperStepBarrierWorkerAck) Equal(that interface{}) bool
func (*SuperStepBarrierWorkerAck) GetWorkerPid ¶
func (m *SuperStepBarrierWorkerAck) GetWorkerPid() *actor.PID
func (*SuperStepBarrierWorkerAck) GoString ¶
func (this *SuperStepBarrierWorkerAck) GoString() string
func (*SuperStepBarrierWorkerAck) Marshal ¶
func (m *SuperStepBarrierWorkerAck) Marshal() (dAtA []byte, err error)
func (*SuperStepBarrierWorkerAck) MarshalTo ¶
func (m *SuperStepBarrierWorkerAck) MarshalTo(dAtA []byte) (int, error)
func (*SuperStepBarrierWorkerAck) ProtoMessage ¶
func (*SuperStepBarrierWorkerAck) ProtoMessage()
func (*SuperStepBarrierWorkerAck) Reset ¶
func (m *SuperStepBarrierWorkerAck) Reset()
func (*SuperStepBarrierWorkerAck) Size ¶
func (m *SuperStepBarrierWorkerAck) Size() (n int)
func (*SuperStepBarrierWorkerAck) String ¶
func (this *SuperStepBarrierWorkerAck) String() string
func (*SuperStepBarrierWorkerAck) Unmarshal ¶
func (m *SuperStepBarrierWorkerAck) Unmarshal(dAtA []byte) error
func (*SuperStepBarrierWorkerAck) XXX_DiscardUnknown ¶
func (m *SuperStepBarrierWorkerAck) XXX_DiscardUnknown()
func (*SuperStepBarrierWorkerAck) XXX_Marshal ¶
func (m *SuperStepBarrierWorkerAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SuperStepBarrierWorkerAck) XXX_Merge ¶
func (m *SuperStepBarrierWorkerAck) XXX_Merge(src proto.Message)
func (*SuperStepBarrierWorkerAck) XXX_Size ¶
func (m *SuperStepBarrierWorkerAck) XXX_Size() int
func (*SuperStepBarrierWorkerAck) XXX_Unmarshal ¶
func (m *SuperStepBarrierWorkerAck) XXX_Unmarshal(b []byte) error
type SuperStepMessage ¶
type SuperStepMessage struct { Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` SuperStep uint64 `protobuf:"varint,2,opt,name=super_step,json=superStep,proto3" json:"super_step,omitempty"` SrcVertexId string `protobuf:"bytes,3,opt,name=src_vertex_id,json=srcVertexId,proto3" json:"src_vertex_id,omitempty"` DestVertexId string `protobuf:"bytes,4,opt,name=dest_vertex_id,json=destVertexId,proto3" json:"dest_vertex_id,omitempty"` Message *types.Any `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"` }
func (*SuperStepMessage) Descriptor ¶
func (*SuperStepMessage) Descriptor() ([]byte, []int)
func (*SuperStepMessage) Equal ¶
func (this *SuperStepMessage) Equal(that interface{}) bool
func (*SuperStepMessage) GetDestVertexId ¶
func (m *SuperStepMessage) GetDestVertexId() string
func (*SuperStepMessage) GetMessage ¶
func (m *SuperStepMessage) GetMessage() *types.Any
func (*SuperStepMessage) GetSrcVertexId ¶
func (m *SuperStepMessage) GetSrcVertexId() string
func (*SuperStepMessage) GetSuperStep ¶
func (m *SuperStepMessage) GetSuperStep() uint64
func (*SuperStepMessage) GetUuid ¶
func (m *SuperStepMessage) GetUuid() string
func (*SuperStepMessage) GoString ¶
func (this *SuperStepMessage) GoString() string
func (*SuperStepMessage) Marshal ¶
func (m *SuperStepMessage) Marshal() (dAtA []byte, err error)
func (*SuperStepMessage) ProtoMessage ¶
func (*SuperStepMessage) ProtoMessage()
func (*SuperStepMessage) Reset ¶
func (m *SuperStepMessage) Reset()
func (*SuperStepMessage) Size ¶
func (m *SuperStepMessage) Size() (n int)
func (*SuperStepMessage) String ¶
func (this *SuperStepMessage) String() string
func (*SuperStepMessage) Unmarshal ¶
func (m *SuperStepMessage) Unmarshal(dAtA []byte) error
func (*SuperStepMessage) XXX_DiscardUnknown ¶
func (m *SuperStepMessage) XXX_DiscardUnknown()
func (*SuperStepMessage) XXX_Marshal ¶
func (m *SuperStepMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SuperStepMessage) XXX_Merge ¶
func (m *SuperStepMessage) XXX_Merge(src proto.Message)
func (*SuperStepMessage) XXX_Size ¶
func (m *SuperStepMessage) XXX_Size() int
func (*SuperStepMessage) XXX_Unmarshal ¶
func (m *SuperStepMessage) XXX_Unmarshal(b []byte) error
type SuperStepMessageAck ¶
type SuperStepMessageAck struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
}
func (*SuperStepMessageAck) Descriptor ¶
func (*SuperStepMessageAck) Descriptor() ([]byte, []int)
func (*SuperStepMessageAck) Equal ¶
func (this *SuperStepMessageAck) Equal(that interface{}) bool
func (*SuperStepMessageAck) GetUuid ¶
func (m *SuperStepMessageAck) GetUuid() string
func (*SuperStepMessageAck) GoString ¶
func (this *SuperStepMessageAck) GoString() string
func (*SuperStepMessageAck) Marshal ¶
func (m *SuperStepMessageAck) Marshal() (dAtA []byte, err error)
func (*SuperStepMessageAck) MarshalTo ¶
func (m *SuperStepMessageAck) MarshalTo(dAtA []byte) (int, error)
func (*SuperStepMessageAck) ProtoMessage ¶
func (*SuperStepMessageAck) ProtoMessage()
func (*SuperStepMessageAck) Reset ¶
func (m *SuperStepMessageAck) Reset()
func (*SuperStepMessageAck) Size ¶
func (m *SuperStepMessageAck) Size() (n int)
func (*SuperStepMessageAck) String ¶
func (this *SuperStepMessageAck) String() string
func (*SuperStepMessageAck) Unmarshal ¶
func (m *SuperStepMessageAck) Unmarshal(dAtA []byte) error
func (*SuperStepMessageAck) XXX_DiscardUnknown ¶
func (m *SuperStepMessageAck) XXX_DiscardUnknown()
func (*SuperStepMessageAck) XXX_Marshal ¶
func (m *SuperStepMessageAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SuperStepMessageAck) XXX_Merge ¶
func (m *SuperStepMessageAck) XXX_Merge(src proto.Message)
func (*SuperStepMessageAck) XXX_Size ¶
func (m *SuperStepMessageAck) XXX_Size() int
func (*SuperStepMessageAck) XXX_Unmarshal ¶
func (m *SuperStepMessageAck) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.