command

package
v0.0.0-...-4dc66ed Latest Latest
Warning

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

 Go to latest Published: Jul 4, 2019 License: MIT Imports: 9 Imported by: 0

Documentation

Index

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

func (m *ClusterInfo) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Compute) Equal 

func (this *Compute) Equal(that interface{}) bool

func (*Compute) GetAggregatedValues 

func (m *Compute) GetAggregatedValues() map[string]*types.Any

func (*Compute) GetSuperStep 

func (m *Compute) GetSuperStep() uint64

func (*Compute) GoString 

func (this *Compute) GoString() string

func (*Compute) Marshal 

func (m *Compute) Marshal() (dAtA []byte, err error)

func (*Compute) MarshalTo 

func (m *Compute) MarshalTo(dAtA []byte) (int, error)

func (*Compute) ProtoMessage 

func (*Compute) ProtoMessage()

func (*Compute) Reset 

func (m *Compute) Reset()

func (*Compute) Size 

func (m *Compute) Size() (n int)

func (*Compute) String 

func (this *Compute) String() string

func (*Compute) Unmarshal 

func (m *Compute) Unmarshal(dAtA []byte) error

func (*Compute) XXX_DiscardUnknown 

func (m *Compute) XXX_DiscardUnknown()

func (*Compute) XXX_Marshal 

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

func (*Compute) XXX_Merge 

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

func (*Compute) XXX_Size 

func (m *Compute) XXX_Size() int

func (*Compute) XXX_Unmarshal 

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

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

func (m *ComputeAck) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ComputeWorkerAck) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *CoordinatorStats) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *GetVertexValue) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *InitPartition) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *InitPartitionAck) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *InitWorker) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *InitWorkerAck) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *LoadVertex) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *LoadVertexAck) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *NewCluster) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *NewClusterAck) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Shutdown) Equal 

func (this *Shutdown) Equal(that interface{}) bool

func (*Shutdown) GoString 

func (this *Shutdown) GoString() string

func (*Shutdown) Marshal 

func (m *Shutdown) Marshal() (dAtA []byte, err error)

func (*Shutdown) MarshalTo 

func (m *Shutdown) MarshalTo(dAtA []byte) (int, error)

func (*Shutdown) ProtoMessage 

func (*Shutdown) ProtoMessage()

func (*Shutdown) Reset 

func (m *Shutdown) Reset()

func (*Shutdown) Size 

func (m *Shutdown) Size() (n int)

func (*Shutdown) String 

func (this *Shutdown) String() string

func (*Shutdown) Unmarshal 

func (m *Shutdown) Unmarshal(dAtA []byte) error

func (*Shutdown) XXX_DiscardUnknown 

func (m *Shutdown) XXX_DiscardUnknown()

func (*Shutdown) XXX_Marshal 

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

func (*Shutdown) XXX_Merge 

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

func (*Shutdown) XXX_Size 

func (m *Shutdown) XXX_Size() int

func (*Shutdown) XXX_Unmarshal 

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

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

func (m *ShutdownAck) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *StartSuperStep) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SuperStepBarrier) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SuperStepMessage) MarshalTo(dAtA []byte) (int, 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

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.