Documentation ¶
Index ¶
- Variables
- func RegisterMasterServer(s *grpc.Server, srv MasterServer)
- func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)
- type AssembleResponse
- func (*AssembleResponse) Descriptor() ([]byte, []int)
- func (m *AssembleResponse) Marshal() (dAtA []byte, err error)
- func (m *AssembleResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AssembleResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AssembleResponse) ProtoMessage()
- func (m *AssembleResponse) Reset()
- func (m *AssembleResponse) Size() (n int)
- func (m *AssembleResponse) String() string
- func (m *AssembleResponse) Unmarshal(dAtA []byte) error
- func (m *AssembleResponse) XXX_DiscardUnknown()
- func (m *AssembleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AssembleResponse) XXX_Merge(src proto.Message)
- func (m *AssembleResponse) XXX_Size() int
- func (m *AssembleResponse) XXX_Unmarshal(b []byte) error
- type CalculateFinishRequest
- func (*CalculateFinishRequest) Descriptor() ([]byte, []int)
- func (m *CalculateFinishRequest) Marshal() (dAtA []byte, err error)
- func (m *CalculateFinishRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CalculateFinishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CalculateFinishRequest) ProtoMessage()
- func (m *CalculateFinishRequest) Reset()
- func (m *CalculateFinishRequest) Size() (n int)
- func (m *CalculateFinishRequest) String() string
- func (m *CalculateFinishRequest) Unmarshal(dAtA []byte) error
- func (m *CalculateFinishRequest) XXX_DiscardUnknown()
- func (m *CalculateFinishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CalculateFinishRequest) XXX_Merge(src proto.Message)
- func (m *CalculateFinishRequest) XXX_Size() int
- func (m *CalculateFinishRequest) XXX_Unmarshal(b []byte) error
- type CalculateFinishResponse
- func (*CalculateFinishResponse) Descriptor() ([]byte, []int)
- func (m *CalculateFinishResponse) Marshal() (dAtA []byte, err error)
- func (m *CalculateFinishResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CalculateFinishResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CalculateFinishResponse) ProtoMessage()
- func (m *CalculateFinishResponse) Reset()
- func (m *CalculateFinishResponse) Size() (n int)
- func (m *CalculateFinishResponse) String() string
- func (m *CalculateFinishResponse) Unmarshal(dAtA []byte) error
- func (m *CalculateFinishResponse) XXX_DiscardUnknown()
- func (m *CalculateFinishResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CalculateFinishResponse) XXX_Merge(src proto.Message)
- func (m *CalculateFinishResponse) XXX_Size() int
- func (m *CalculateFinishResponse) XXX_Unmarshal(b []byte) error
- type EmptyRequest
- func (*EmptyRequest) Descriptor() ([]byte, []int)
- func (m *EmptyRequest) Marshal() (dAtA []byte, err error)
- func (m *EmptyRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *EmptyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EmptyRequest) ProtoMessage()
- func (m *EmptyRequest) Reset()
- func (m *EmptyRequest) Size() (n int)
- func (m *EmptyRequest) String() string
- func (m *EmptyRequest) Unmarshal(dAtA []byte) error
- func (m *EmptyRequest) XXX_DiscardUnknown()
- func (m *EmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmptyRequest) XXX_Merge(src proto.Message)
- func (m *EmptyRequest) XXX_Size() int
- func (m *EmptyRequest) XXX_Unmarshal(b []byte) error
- type EmptyResponse
- func (*EmptyResponse) Descriptor() ([]byte, []int)
- func (m *EmptyResponse) Marshal() (dAtA []byte, err error)
- func (m *EmptyResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *EmptyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EmptyResponse) ProtoMessage()
- func (m *EmptyResponse) Reset()
- func (m *EmptyResponse) Size() (n int)
- func (m *EmptyResponse) String() string
- func (m *EmptyResponse) Unmarshal(dAtA []byte) error
- func (m *EmptyResponse) XXX_DiscardUnknown()
- func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmptyResponse) XXX_Merge(src proto.Message)
- func (m *EmptyResponse) XXX_Size() int
- func (m *EmptyResponse) XXX_Unmarshal(b []byte) error
- type ExchangeResponse
- func (*ExchangeResponse) Descriptor() ([]byte, []int)
- func (m *ExchangeResponse) Marshal() (dAtA []byte, err error)
- func (m *ExchangeResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ExchangeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExchangeResponse) ProtoMessage()
- func (m *ExchangeResponse) Reset()
- func (m *ExchangeResponse) Size() (n int)
- func (m *ExchangeResponse) String() string
- func (m *ExchangeResponse) Unmarshal(dAtA []byte) error
- func (m *ExchangeResponse) XXX_DiscardUnknown()
- func (m *ExchangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExchangeResponse) XXX_Merge(src proto.Message)
- func (m *ExchangeResponse) XXX_Size() int
- func (m *ExchangeResponse) XXX_Unmarshal(b []byte) error
- type FinishRequest
- func (*FinishRequest) Descriptor() ([]byte, []int)
- func (m *FinishRequest) Marshal() (dAtA []byte, err error)
- func (m *FinishRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *FinishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FinishRequest) ProtoMessage()
- func (m *FinishRequest) Reset()
- func (m *FinishRequest) Size() (n int)
- func (m *FinishRequest) String() string
- func (m *FinishRequest) Unmarshal(dAtA []byte) error
- func (m *FinishRequest) XXX_DiscardUnknown()
- func (m *FinishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FinishRequest) XXX_Merge(src proto.Message)
- func (m *FinishRequest) XXX_Size() int
- func (m *FinishRequest) XXX_Unmarshal(b []byte) error
- type FinishResponse
- func (*FinishResponse) Descriptor() ([]byte, []int)
- func (m *FinishResponse) Marshal() (dAtA []byte, err error)
- func (m *FinishResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *FinishResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FinishResponse) ProtoMessage()
- func (m *FinishResponse) Reset()
- func (m *FinishResponse) Size() (n int)
- func (m *FinishResponse) String() string
- func (m *FinishResponse) Unmarshal(dAtA []byte) error
- func (m *FinishResponse) XXX_DiscardUnknown()
- func (m *FinishResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FinishResponse) XXX_Merge(src proto.Message)
- func (m *FinishResponse) XXX_Size() int
- func (m *FinishResponse) XXX_Unmarshal(b []byte) error
- type IncEvalResponse
- func (*IncEvalResponse) Descriptor() ([]byte, []int)
- func (m *IncEvalResponse) Marshal() (dAtA []byte, err error)
- func (m *IncEvalResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *IncEvalResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IncEvalResponse) ProtoMessage()
- func (m *IncEvalResponse) Reset()
- func (m *IncEvalResponse) Size() (n int)
- func (m *IncEvalResponse) String() string
- func (m *IncEvalResponse) Unmarshal(dAtA []byte) error
- func (m *IncEvalResponse) XXX_DiscardUnknown()
- func (m *IncEvalResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IncEvalResponse) XXX_Merge(src proto.Message)
- func (m *IncEvalResponse) XXX_Size() int
- func (m *IncEvalResponse) XXX_Unmarshal(b []byte) error
- type MasterClient
- type MasterServer
- type MessageRequest
- func (*MessageRequest) Descriptor() ([]byte, []int)
- func (m *MessageRequest) Marshal() (dAtA []byte, err error)
- func (m *MessageRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MessageRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessageRequest) ProtoMessage()
- func (m *MessageRequest) Reset()
- func (m *MessageRequest) Size() (n int)
- func (m *MessageRequest) String() string
- func (m *MessageRequest) Unmarshal(dAtA []byte) error
- func (m *MessageRequest) XXX_DiscardUnknown()
- func (m *MessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessageRequest) XXX_Merge(src proto.Message)
- func (m *MessageRequest) XXX_Size() int
- func (m *MessageRequest) XXX_Unmarshal(b []byte) error
- type MessageStruct
- func (*MessageStruct) Descriptor() ([]byte, []int)
- func (m *MessageStruct) Marshal() (dAtA []byte, err error)
- func (m *MessageStruct) MarshalTo(dAtA []byte) (int, error)
- func (m *MessageStruct) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessageStruct) ProtoMessage()
- func (m *MessageStruct) Reset()
- func (m *MessageStruct) Size() (n int)
- func (m *MessageStruct) String() string
- func (m *MessageStruct) Unmarshal(dAtA []byte) error
- func (m *MessageStruct) XXX_DiscardUnknown()
- func (m *MessageStruct) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessageStruct) XXX_Merge(src proto.Message)
- func (m *MessageStruct) XXX_Size() int
- func (m *MessageStruct) XXX_Unmarshal(b []byte) error
- type PEvalResponse
- func (*PEvalResponse) Descriptor() ([]byte, []int)
- func (m *PEvalResponse) Marshal() (dAtA []byte, err error)
- func (m *PEvalResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PEvalResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PEvalResponse) ProtoMessage()
- func (m *PEvalResponse) Reset()
- func (m *PEvalResponse) Size() (n int)
- func (m *PEvalResponse) String() string
- func (m *PEvalResponse) Unmarshal(dAtA []byte) error
- func (m *PEvalResponse) XXX_DiscardUnknown()
- func (m *PEvalResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PEvalResponse) XXX_Merge(src proto.Message)
- func (m *PEvalResponse) XXX_Size() int
- func (m *PEvalResponse) XXX_Unmarshal(b []byte) error
- type RecoveryRequest
- func (*RecoveryRequest) Descriptor() ([]byte, []int)
- func (m *RecoveryRequest) Marshal() (dAtA []byte, err error)
- func (m *RecoveryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RecoveryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RecoveryRequest) ProtoMessage()
- func (m *RecoveryRequest) Reset()
- func (m *RecoveryRequest) Size() (n int)
- func (m *RecoveryRequest) String() string
- func (m *RecoveryRequest) Unmarshal(dAtA []byte) error
- func (m *RecoveryRequest) XXX_DiscardUnknown()
- func (m *RecoveryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecoveryRequest) XXX_Merge(src proto.Message)
- func (m *RecoveryRequest) XXX_Size() int
- func (m *RecoveryRequest) XXX_Unmarshal(b []byte) error
- type RegisterRequest
- func (*RegisterRequest) Descriptor() ([]byte, []int)
- func (m *RegisterRequest) Marshal() (dAtA []byte, err error)
- func (m *RegisterRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RegisterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegisterRequest) ProtoMessage()
- func (m *RegisterRequest) Reset()
- func (m *RegisterRequest) Size() (n int)
- func (m *RegisterRequest) String() string
- func (m *RegisterRequest) Unmarshal(dAtA []byte) error
- func (m *RegisterRequest) XXX_DiscardUnknown()
- func (m *RegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterRequest) XXX_Merge(src proto.Message)
- func (m *RegisterRequest) XXX_Size() int
- func (m *RegisterRequest) XXX_Unmarshal(b []byte) error
- type RegisterResponse
- func (*RegisterResponse) Descriptor() ([]byte, []int)
- func (m *RegisterResponse) Marshal() (dAtA []byte, err error)
- func (m *RegisterResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RegisterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegisterResponse) ProtoMessage()
- func (m *RegisterResponse) Reset()
- func (m *RegisterResponse) Size() (n int)
- func (m *RegisterResponse) String() string
- func (m *RegisterResponse) Unmarshal(dAtA []byte) error
- func (m *RegisterResponse) XXX_DiscardUnknown()
- func (m *RegisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterResponse) XXX_Merge(src proto.Message)
- func (m *RegisterResponse) XXX_Size() int
- func (m *RegisterResponse) XXX_Unmarshal(b []byte) error
- type ShutDownResponse
- func (*ShutDownResponse) Descriptor() ([]byte, []int)
- func (m *ShutDownResponse) Marshal() (dAtA []byte, err error)
- func (m *ShutDownResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ShutDownResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShutDownResponse) ProtoMessage()
- func (m *ShutDownResponse) Reset()
- func (m *ShutDownResponse) Size() (n int)
- func (m *ShutDownResponse) String() string
- func (m *ShutDownResponse) Unmarshal(dAtA []byte) error
- func (m *ShutDownResponse) XXX_DiscardUnknown()
- func (m *ShutDownResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShutDownResponse) XXX_Merge(src proto.Message)
- func (m *ShutDownResponse) XXX_Size() int
- func (m *ShutDownResponse) XXX_Unmarshal(b []byte) error
- type SyncRequest
- func (*SyncRequest) Descriptor() ([]byte, []int)
- func (m *SyncRequest) Marshal() (dAtA []byte, err error)
- func (m *SyncRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SyncRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncRequest) ProtoMessage()
- func (m *SyncRequest) Reset()
- func (m *SyncRequest) Size() (n int)
- func (m *SyncRequest) String() string
- func (m *SyncRequest) Unmarshal(dAtA []byte) error
- func (m *SyncRequest) XXX_DiscardUnknown()
- func (m *SyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncRequest) XXX_Merge(src proto.Message)
- func (m *SyncRequest) XXX_Size() int
- func (m *SyncRequest) XXX_Unmarshal(b []byte) error
- type SyncStruct
- func (*SyncStruct) Descriptor() ([]byte, []int)
- func (m *SyncStruct) Marshal() (dAtA []byte, err error)
- func (m *SyncStruct) MarshalTo(dAtA []byte) (int, error)
- func (m *SyncStruct) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncStruct) ProtoMessage()
- func (m *SyncStruct) Reset()
- func (m *SyncStruct) Size() (n int)
- func (m *SyncStruct) String() string
- func (m *SyncStruct) Unmarshal(dAtA []byte) error
- func (m *SyncStruct) XXX_DiscardUnknown()
- func (m *SyncStruct) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncStruct) XXX_Merge(src proto.Message)
- func (m *SyncStruct) XXX_Size() int
- func (m *SyncStruct) XXX_Unmarshal(b []byte) error
- type UnimplementedMasterServer
- func (*UnimplementedMasterServer) CalculateFinish(ctx context.Context, req *CalculateFinishRequest) (*CalculateFinishResponse, error)
- func (*UnimplementedMasterServer) Register(ctx context.Context, req *RegisterRequest) (*RegisterResponse, error)
- func (*UnimplementedMasterServer) SuperStepFinish(ctx context.Context, req *FinishRequest) (*FinishResponse, error)
- type UnimplementedWorkerServer
- func (*UnimplementedWorkerServer) Assemble(ctx context.Context, req *EmptyRequest) (*AssembleResponse, error)
- func (*UnimplementedWorkerServer) BeatHeart(ctx context.Context, req *EmptyRequest) (*EmptyResponse, error)
- func (*UnimplementedWorkerServer) ExchangeMessage(ctx context.Context, req *EmptyRequest) (*ExchangeResponse, error)
- func (*UnimplementedWorkerServer) IncEval(ctx context.Context, req *EmptyRequest) (*IncEvalResponse, error)
- func (*UnimplementedWorkerServer) MessageSend(ctx context.Context, req *MessageRequest) (*EmptyResponse, error)
- func (*UnimplementedWorkerServer) PEval(ctx context.Context, req *EmptyRequest) (*PEvalResponse, error)
- func (*UnimplementedWorkerServer) Recovery(ctx context.Context, req *RecoveryRequest) (*EmptyResponse, error)
- func (*UnimplementedWorkerServer) ShutDown(ctx context.Context, req *EmptyRequest) (*ShutDownResponse, error)
- func (*UnimplementedWorkerServer) SyncVal(ctx context.Context, req *SyncRequest) (*EmptyResponse, error)
- type WorkerClient
- type WorkerCommunicationSize
- func (*WorkerCommunicationSize) Descriptor() ([]byte, []int)
- func (m *WorkerCommunicationSize) Marshal() (dAtA []byte, err error)
- func (m *WorkerCommunicationSize) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkerCommunicationSize) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkerCommunicationSize) ProtoMessage()
- func (m *WorkerCommunicationSize) Reset()
- func (m *WorkerCommunicationSize) Size() (n int)
- func (m *WorkerCommunicationSize) String() string
- func (m *WorkerCommunicationSize) Unmarshal(dAtA []byte) error
- func (m *WorkerCommunicationSize) XXX_DiscardUnknown()
- func (m *WorkerCommunicationSize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkerCommunicationSize) XXX_Merge(src proto.Message)
- func (m *WorkerCommunicationSize) XXX_Size() int
- func (m *WorkerCommunicationSize) XXX_Unmarshal(b []byte) error
- type WorkerServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthMasterService = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMasterService = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthWorkerService = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowWorkerService = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterMasterServer ¶
func RegisterMasterServer(s *grpc.Server, srv MasterServer)
func RegisterWorkerServer ¶
func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)
Types ¶
type AssembleResponse ¶
type AssembleResponse struct { Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AssembleResponse) Descriptor ¶
func (*AssembleResponse) Descriptor() ([]byte, []int)
func (*AssembleResponse) Marshal ¶
func (m *AssembleResponse) Marshal() (dAtA []byte, err error)
func (*AssembleResponse) MarshalToSizedBuffer ¶
func (m *AssembleResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AssembleResponse) ProtoMessage ¶
func (*AssembleResponse) ProtoMessage()
func (*AssembleResponse) Reset ¶
func (m *AssembleResponse) Reset()
func (*AssembleResponse) Size ¶
func (m *AssembleResponse) Size() (n int)
func (*AssembleResponse) String ¶
func (m *AssembleResponse) String() string
func (*AssembleResponse) Unmarshal ¶
func (m *AssembleResponse) Unmarshal(dAtA []byte) error
func (*AssembleResponse) XXX_DiscardUnknown ¶
func (m *AssembleResponse) XXX_DiscardUnknown()
func (*AssembleResponse) XXX_Marshal ¶
func (m *AssembleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AssembleResponse) XXX_Merge ¶
func (m *AssembleResponse) XXX_Merge(src proto.Message)
func (*AssembleResponse) XXX_Size ¶
func (m *AssembleResponse) XXX_Size() int
func (*AssembleResponse) XXX_Unmarshal ¶
func (m *AssembleResponse) XXX_Unmarshal(b []byte) error
type CalculateFinishRequest ¶
type CalculateFinishRequest struct { WorkerIndex int32 `protobuf:"varint,1,opt,name=workerIndex,proto3" json:"workerIndex,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CalculateFinishRequest) Descriptor ¶
func (*CalculateFinishRequest) Descriptor() ([]byte, []int)
func (*CalculateFinishRequest) Marshal ¶
func (m *CalculateFinishRequest) Marshal() (dAtA []byte, err error)
func (*CalculateFinishRequest) MarshalTo ¶
func (m *CalculateFinishRequest) MarshalTo(dAtA []byte) (int, error)
func (*CalculateFinishRequest) MarshalToSizedBuffer ¶
func (m *CalculateFinishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CalculateFinishRequest) ProtoMessage ¶
func (*CalculateFinishRequest) ProtoMessage()
func (*CalculateFinishRequest) Reset ¶
func (m *CalculateFinishRequest) Reset()
func (*CalculateFinishRequest) Size ¶
func (m *CalculateFinishRequest) Size() (n int)
func (*CalculateFinishRequest) String ¶
func (m *CalculateFinishRequest) String() string
func (*CalculateFinishRequest) Unmarshal ¶
func (m *CalculateFinishRequest) Unmarshal(dAtA []byte) error
func (*CalculateFinishRequest) XXX_DiscardUnknown ¶
func (m *CalculateFinishRequest) XXX_DiscardUnknown()
func (*CalculateFinishRequest) XXX_Marshal ¶
func (m *CalculateFinishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CalculateFinishRequest) XXX_Merge ¶
func (m *CalculateFinishRequest) XXX_Merge(src proto.Message)
func (*CalculateFinishRequest) XXX_Size ¶
func (m *CalculateFinishRequest) XXX_Size() int
func (*CalculateFinishRequest) XXX_Unmarshal ¶
func (m *CalculateFinishRequest) XXX_Unmarshal(b []byte) error
type CalculateFinishResponse ¶
type CalculateFinishResponse struct { Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CalculateFinishResponse) Descriptor ¶
func (*CalculateFinishResponse) Descriptor() ([]byte, []int)
func (*CalculateFinishResponse) Marshal ¶
func (m *CalculateFinishResponse) Marshal() (dAtA []byte, err error)
func (*CalculateFinishResponse) MarshalTo ¶
func (m *CalculateFinishResponse) MarshalTo(dAtA []byte) (int, error)
func (*CalculateFinishResponse) MarshalToSizedBuffer ¶
func (m *CalculateFinishResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CalculateFinishResponse) ProtoMessage ¶
func (*CalculateFinishResponse) ProtoMessage()
func (*CalculateFinishResponse) Reset ¶
func (m *CalculateFinishResponse) Reset()
func (*CalculateFinishResponse) Size ¶
func (m *CalculateFinishResponse) Size() (n int)
func (*CalculateFinishResponse) String ¶
func (m *CalculateFinishResponse) String() string
func (*CalculateFinishResponse) Unmarshal ¶
func (m *CalculateFinishResponse) Unmarshal(dAtA []byte) error
func (*CalculateFinishResponse) XXX_DiscardUnknown ¶
func (m *CalculateFinishResponse) XXX_DiscardUnknown()
func (*CalculateFinishResponse) XXX_Marshal ¶
func (m *CalculateFinishResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CalculateFinishResponse) XXX_Merge ¶
func (m *CalculateFinishResponse) XXX_Merge(src proto.Message)
func (*CalculateFinishResponse) XXX_Size ¶
func (m *CalculateFinishResponse) XXX_Size() int
func (*CalculateFinishResponse) XXX_Unmarshal ¶
func (m *CalculateFinishResponse) XXX_Unmarshal(b []byte) error
type EmptyRequest ¶
type EmptyRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EmptyRequest) Descriptor ¶
func (*EmptyRequest) Descriptor() ([]byte, []int)
func (*EmptyRequest) Marshal ¶
func (m *EmptyRequest) Marshal() (dAtA []byte, err error)
func (*EmptyRequest) MarshalToSizedBuffer ¶
func (m *EmptyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EmptyRequest) ProtoMessage ¶
func (*EmptyRequest) ProtoMessage()
func (*EmptyRequest) Reset ¶
func (m *EmptyRequest) Reset()
func (*EmptyRequest) Size ¶
func (m *EmptyRequest) Size() (n int)
func (*EmptyRequest) String ¶
func (m *EmptyRequest) String() string
func (*EmptyRequest) Unmarshal ¶
func (m *EmptyRequest) Unmarshal(dAtA []byte) error
func (*EmptyRequest) XXX_DiscardUnknown ¶
func (m *EmptyRequest) XXX_DiscardUnknown()
func (*EmptyRequest) XXX_Marshal ¶
func (m *EmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmptyRequest) XXX_Merge ¶
func (m *EmptyRequest) XXX_Merge(src proto.Message)
func (*EmptyRequest) XXX_Size ¶
func (m *EmptyRequest) XXX_Size() int
func (*EmptyRequest) XXX_Unmarshal ¶
func (m *EmptyRequest) XXX_Unmarshal(b []byte) error
type EmptyResponse ¶
type EmptyResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EmptyResponse) Descriptor ¶
func (*EmptyResponse) Descriptor() ([]byte, []int)
func (*EmptyResponse) Marshal ¶
func (m *EmptyResponse) Marshal() (dAtA []byte, err error)
func (*EmptyResponse) MarshalToSizedBuffer ¶
func (m *EmptyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EmptyResponse) ProtoMessage ¶
func (*EmptyResponse) ProtoMessage()
func (*EmptyResponse) Reset ¶
func (m *EmptyResponse) Reset()
func (*EmptyResponse) Size ¶
func (m *EmptyResponse) Size() (n int)
func (*EmptyResponse) String ¶
func (m *EmptyResponse) String() string
func (*EmptyResponse) Unmarshal ¶
func (m *EmptyResponse) Unmarshal(dAtA []byte) error
func (*EmptyResponse) XXX_DiscardUnknown ¶
func (m *EmptyResponse) XXX_DiscardUnknown()
func (*EmptyResponse) XXX_Marshal ¶
func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmptyResponse) XXX_Merge ¶
func (m *EmptyResponse) XXX_Merge(src proto.Message)
func (*EmptyResponse) XXX_Size ¶
func (m *EmptyResponse) XXX_Size() int
func (*EmptyResponse) XXX_Unmarshal ¶
func (m *EmptyResponse) XXX_Unmarshal(b []byte) error
type ExchangeResponse ¶
type ExchangeResponse struct { Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ExchangeResponse) Descriptor ¶
func (*ExchangeResponse) Descriptor() ([]byte, []int)
func (*ExchangeResponse) Marshal ¶
func (m *ExchangeResponse) Marshal() (dAtA []byte, err error)
func (*ExchangeResponse) MarshalToSizedBuffer ¶
func (m *ExchangeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExchangeResponse) ProtoMessage ¶
func (*ExchangeResponse) ProtoMessage()
func (*ExchangeResponse) Reset ¶
func (m *ExchangeResponse) Reset()
func (*ExchangeResponse) Size ¶
func (m *ExchangeResponse) Size() (n int)
func (*ExchangeResponse) String ¶
func (m *ExchangeResponse) String() string
func (*ExchangeResponse) Unmarshal ¶
func (m *ExchangeResponse) Unmarshal(dAtA []byte) error
func (*ExchangeResponse) XXX_DiscardUnknown ¶
func (m *ExchangeResponse) XXX_DiscardUnknown()
func (*ExchangeResponse) XXX_Marshal ¶
func (m *ExchangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExchangeResponse) XXX_Merge ¶
func (m *ExchangeResponse) XXX_Merge(src proto.Message)
func (*ExchangeResponse) XXX_Size ¶
func (m *ExchangeResponse) XXX_Size() int
func (*ExchangeResponse) XXX_Unmarshal ¶
func (m *ExchangeResponse) XXX_Unmarshal(b []byte) error
type FinishRequest ¶
type FinishRequest struct { //duration time of aggregator AggregatorSeconds float64 `protobuf:"fixed64,1,opt,name=aggregatorSeconds,proto3" json:"aggregatorSeconds,omitempty"` AggregatorOriSize int32 `protobuf:"varint,2,opt,name=aggregatorOriSize,proto3" json:"aggregatorOriSize,omitempty"` AggregatorReducedSize int32 `protobuf:"varint,3,opt,name=aggregatorReducedSize,proto3" json:"aggregatorReducedSize,omitempty"` IterationNum int64 `protobuf:"varint,4,opt,name=iterationNum,proto3" json:"iterationNum,omitempty"` //duration time of partial SSSP loop IterationSeconds float64 `protobuf:"fixed64,5,opt,name=iterationSeconds,proto3" json:"iterationSeconds,omitempty"` //duration time of combine message CombineSeconds float64 `protobuf:"fixed64,6,opt,name=combineSeconds,proto3" json:"combineSeconds,omitempty"` //number of updated boarders node pair UpdatePairNum int32 `protobuf:"varint,7,opt,name=updatePairNum,proto3" json:"updatePairNum,omitempty"` //number of destinations which message send to DstPartitionNum int32 `protobuf:"varint,8,opt,name=dstPartitionNum,proto3" json:"dstPartitionNum,omitempty"` //duration of a worker send to message to all other workers AllPeerSend float64 `protobuf:"fixed64,9,opt,name=allPeerSend,proto3" json:"allPeerSend,omitempty"` //size of worker to worker communication pairs PairNum []*WorkerCommunicationSize `protobuf:"bytes,10,rep,name=pairNum,proto3" json:"pairNum,omitempty"` WorkerID int32 `protobuf:"varint,11,opt,name=workerID,proto3" json:"workerID,omitempty"` MessageToSend bool `protobuf:"varint,12,opt,name=MessageToSend,proto3" json:"MessageToSend,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FinishRequest) Descriptor ¶
func (*FinishRequest) Descriptor() ([]byte, []int)
func (*FinishRequest) Marshal ¶
func (m *FinishRequest) Marshal() (dAtA []byte, err error)
func (*FinishRequest) MarshalToSizedBuffer ¶
func (m *FinishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FinishRequest) ProtoMessage ¶
func (*FinishRequest) ProtoMessage()
func (*FinishRequest) Reset ¶
func (m *FinishRequest) Reset()
func (*FinishRequest) Size ¶
func (m *FinishRequest) Size() (n int)
func (*FinishRequest) String ¶
func (m *FinishRequest) String() string
func (*FinishRequest) Unmarshal ¶
func (m *FinishRequest) Unmarshal(dAtA []byte) error
func (*FinishRequest) XXX_DiscardUnknown ¶
func (m *FinishRequest) XXX_DiscardUnknown()
func (*FinishRequest) XXX_Marshal ¶
func (m *FinishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FinishRequest) XXX_Merge ¶
func (m *FinishRequest) XXX_Merge(src proto.Message)
func (*FinishRequest) XXX_Size ¶
func (m *FinishRequest) XXX_Size() int
func (*FinishRequest) XXX_Unmarshal ¶
func (m *FinishRequest) XXX_Unmarshal(b []byte) error
type FinishResponse ¶
type FinishResponse struct { Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FinishResponse) Descriptor ¶
func (*FinishResponse) Descriptor() ([]byte, []int)
func (*FinishResponse) Marshal ¶
func (m *FinishResponse) Marshal() (dAtA []byte, err error)
func (*FinishResponse) MarshalToSizedBuffer ¶
func (m *FinishResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FinishResponse) ProtoMessage ¶
func (*FinishResponse) ProtoMessage()
func (*FinishResponse) Reset ¶
func (m *FinishResponse) Reset()
func (*FinishResponse) Size ¶
func (m *FinishResponse) Size() (n int)
func (*FinishResponse) String ¶
func (m *FinishResponse) String() string
func (*FinishResponse) Unmarshal ¶
func (m *FinishResponse) Unmarshal(dAtA []byte) error
func (*FinishResponse) XXX_DiscardUnknown ¶
func (m *FinishResponse) XXX_DiscardUnknown()
func (*FinishResponse) XXX_Marshal ¶
func (m *FinishResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FinishResponse) XXX_Merge ¶
func (m *FinishResponse) XXX_Merge(src proto.Message)
func (*FinishResponse) XXX_Size ¶
func (m *FinishResponse) XXX_Size() int
func (*FinishResponse) XXX_Unmarshal ¶
func (m *FinishResponse) XXX_Unmarshal(b []byte) error
type IncEvalResponse ¶
type IncEvalResponse struct { Update bool `protobuf:"varint,1,opt,name=update,proto3" json:"update,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IncEvalResponse) Descriptor ¶
func (*IncEvalResponse) Descriptor() ([]byte, []int)
func (*IncEvalResponse) Marshal ¶
func (m *IncEvalResponse) Marshal() (dAtA []byte, err error)
func (*IncEvalResponse) MarshalToSizedBuffer ¶
func (m *IncEvalResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IncEvalResponse) ProtoMessage ¶
func (*IncEvalResponse) ProtoMessage()
func (*IncEvalResponse) Reset ¶
func (m *IncEvalResponse) Reset()
func (*IncEvalResponse) Size ¶
func (m *IncEvalResponse) Size() (n int)
func (*IncEvalResponse) String ¶
func (m *IncEvalResponse) String() string
func (*IncEvalResponse) Unmarshal ¶
func (m *IncEvalResponse) Unmarshal(dAtA []byte) error
func (*IncEvalResponse) XXX_DiscardUnknown ¶
func (m *IncEvalResponse) XXX_DiscardUnknown()
func (*IncEvalResponse) XXX_Marshal ¶
func (m *IncEvalResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IncEvalResponse) XXX_Merge ¶
func (m *IncEvalResponse) XXX_Merge(src proto.Message)
func (*IncEvalResponse) XXX_Size ¶
func (m *IncEvalResponse) XXX_Size() int
func (*IncEvalResponse) XXX_Unmarshal ¶
func (m *IncEvalResponse) XXX_Unmarshal(b []byte) error
type MasterClient ¶
type MasterClient interface { Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error) SuperStepFinish(ctx context.Context, in *FinishRequest, opts ...grpc.CallOption) (*FinishResponse, error) CalculateFinish(ctx context.Context, in *CalculateFinishRequest, opts ...grpc.CallOption) (*CalculateFinishResponse, error) }
MasterClient is the client API for Master service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMasterClient ¶
func NewMasterClient(cc *grpc.ClientConn) MasterClient
type MasterServer ¶
type MasterServer interface { Register(context.Context, *RegisterRequest) (*RegisterResponse, error) SuperStepFinish(context.Context, *FinishRequest) (*FinishResponse, error) CalculateFinish(context.Context, *CalculateFinishRequest) (*CalculateFinishResponse, error) }
MasterServer is the server API for Master service.
type MessageRequest ¶
type MessageRequest struct { Pair []*MessageStruct `protobuf:"bytes,1,rep,name=pair,proto3" json:"pair,omitempty"` CalculateStep bool `protobuf:"varint,2,opt,name=calculateStep,proto3" json:"calculateStep,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MessageRequest) Descriptor ¶
func (*MessageRequest) Descriptor() ([]byte, []int)
func (*MessageRequest) Marshal ¶
func (m *MessageRequest) Marshal() (dAtA []byte, err error)
func (*MessageRequest) MarshalToSizedBuffer ¶
func (m *MessageRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessageRequest) ProtoMessage ¶
func (*MessageRequest) ProtoMessage()
func (*MessageRequest) Reset ¶
func (m *MessageRequest) Reset()
func (*MessageRequest) Size ¶
func (m *MessageRequest) Size() (n int)
func (*MessageRequest) String ¶
func (m *MessageRequest) String() string
func (*MessageRequest) Unmarshal ¶
func (m *MessageRequest) Unmarshal(dAtA []byte) error
func (*MessageRequest) XXX_DiscardUnknown ¶
func (m *MessageRequest) XXX_DiscardUnknown()
func (*MessageRequest) XXX_Marshal ¶
func (m *MessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageRequest) XXX_Merge ¶
func (m *MessageRequest) XXX_Merge(src proto.Message)
func (*MessageRequest) XXX_Size ¶
func (m *MessageRequest) XXX_Size() int
func (*MessageRequest) XXX_Unmarshal ¶
func (m *MessageRequest) XXX_Unmarshal(b []byte) error
type MessageStruct ¶
type MessageStruct struct { NodeID int32 `protobuf:"varint,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"` Val float32 `protobuf:"fixed32,2,opt,name=val,proto3" json:"val,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MessageStruct) Descriptor ¶
func (*MessageStruct) Descriptor() ([]byte, []int)
func (*MessageStruct) Marshal ¶
func (m *MessageStruct) Marshal() (dAtA []byte, err error)
func (*MessageStruct) MarshalToSizedBuffer ¶
func (m *MessageStruct) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessageStruct) ProtoMessage ¶
func (*MessageStruct) ProtoMessage()
func (*MessageStruct) Reset ¶
func (m *MessageStruct) Reset()
func (*MessageStruct) Size ¶
func (m *MessageStruct) Size() (n int)
func (*MessageStruct) String ¶
func (m *MessageStruct) String() string
func (*MessageStruct) Unmarshal ¶
func (m *MessageStruct) Unmarshal(dAtA []byte) error
func (*MessageStruct) XXX_DiscardUnknown ¶
func (m *MessageStruct) XXX_DiscardUnknown()
func (*MessageStruct) XXX_Marshal ¶
func (m *MessageStruct) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageStruct) XXX_Merge ¶
func (m *MessageStruct) XXX_Merge(src proto.Message)
func (*MessageStruct) XXX_Size ¶
func (m *MessageStruct) XXX_Size() int
func (*MessageStruct) XXX_Unmarshal ¶
func (m *MessageStruct) XXX_Unmarshal(b []byte) error
type PEvalResponse ¶
type PEvalResponse struct { Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PEvalResponse) Descriptor ¶
func (*PEvalResponse) Descriptor() ([]byte, []int)
func (*PEvalResponse) Marshal ¶
func (m *PEvalResponse) Marshal() (dAtA []byte, err error)
func (*PEvalResponse) MarshalToSizedBuffer ¶
func (m *PEvalResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PEvalResponse) ProtoMessage ¶
func (*PEvalResponse) ProtoMessage()
func (*PEvalResponse) Reset ¶
func (m *PEvalResponse) Reset()
func (*PEvalResponse) Size ¶
func (m *PEvalResponse) Size() (n int)
func (*PEvalResponse) String ¶
func (m *PEvalResponse) String() string
func (*PEvalResponse) Unmarshal ¶
func (m *PEvalResponse) Unmarshal(dAtA []byte) error
func (*PEvalResponse) XXX_DiscardUnknown ¶
func (m *PEvalResponse) XXX_DiscardUnknown()
func (*PEvalResponse) XXX_Marshal ¶
func (m *PEvalResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PEvalResponse) XXX_Merge ¶
func (m *PEvalResponse) XXX_Merge(src proto.Message)
func (*PEvalResponse) XXX_Size ¶
func (m *PEvalResponse) XXX_Size() int
func (*PEvalResponse) XXX_Unmarshal ¶
func (m *PEvalResponse) XXX_Unmarshal(b []byte) error
type RecoveryRequest ¶
type RecoveryRequest struct { CrashId int32 `protobuf:"varint,1,opt,name=crash_id,json=crashId,proto3" json:"crash_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RecoveryRequest) Descriptor ¶
func (*RecoveryRequest) Descriptor() ([]byte, []int)
func (*RecoveryRequest) Marshal ¶
func (m *RecoveryRequest) Marshal() (dAtA []byte, err error)
func (*RecoveryRequest) MarshalToSizedBuffer ¶
func (m *RecoveryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RecoveryRequest) ProtoMessage ¶
func (*RecoveryRequest) ProtoMessage()
func (*RecoveryRequest) Reset ¶
func (m *RecoveryRequest) Reset()
func (*RecoveryRequest) Size ¶
func (m *RecoveryRequest) Size() (n int)
func (*RecoveryRequest) String ¶
func (m *RecoveryRequest) String() string
func (*RecoveryRequest) Unmarshal ¶
func (m *RecoveryRequest) Unmarshal(dAtA []byte) error
func (*RecoveryRequest) XXX_DiscardUnknown ¶
func (m *RecoveryRequest) XXX_DiscardUnknown()
func (*RecoveryRequest) XXX_Marshal ¶
func (m *RecoveryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecoveryRequest) XXX_Merge ¶
func (m *RecoveryRequest) XXX_Merge(src proto.Message)
func (*RecoveryRequest) XXX_Size ¶
func (m *RecoveryRequest) XXX_Size() int
func (*RecoveryRequest) XXX_Unmarshal ¶
func (m *RecoveryRequest) XXX_Unmarshal(b []byte) error
type RegisterRequest ¶
type RegisterRequest struct { WorkerIndex int32 `protobuf:"varint,1,opt,name=workerIndex,proto3" json:"workerIndex,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RegisterRequest) Descriptor ¶
func (*RegisterRequest) Descriptor() ([]byte, []int)
func (*RegisterRequest) Marshal ¶
func (m *RegisterRequest) Marshal() (dAtA []byte, err error)
func (*RegisterRequest) MarshalToSizedBuffer ¶
func (m *RegisterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RegisterRequest) ProtoMessage ¶
func (*RegisterRequest) ProtoMessage()
func (*RegisterRequest) Reset ¶
func (m *RegisterRequest) Reset()
func (*RegisterRequest) Size ¶
func (m *RegisterRequest) Size() (n int)
func (*RegisterRequest) String ¶
func (m *RegisterRequest) String() string
func (*RegisterRequest) Unmarshal ¶
func (m *RegisterRequest) Unmarshal(dAtA []byte) error
func (*RegisterRequest) XXX_DiscardUnknown ¶
func (m *RegisterRequest) XXX_DiscardUnknown()
func (*RegisterRequest) XXX_Marshal ¶
func (m *RegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterRequest) XXX_Merge ¶
func (m *RegisterRequest) XXX_Merge(src proto.Message)
func (*RegisterRequest) XXX_Size ¶
func (m *RegisterRequest) XXX_Size() int
func (*RegisterRequest) XXX_Unmarshal ¶
func (m *RegisterRequest) XXX_Unmarshal(b []byte) error
type RegisterResponse ¶
type RegisterResponse struct { Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RegisterResponse) Descriptor ¶
func (*RegisterResponse) Descriptor() ([]byte, []int)
func (*RegisterResponse) Marshal ¶
func (m *RegisterResponse) Marshal() (dAtA []byte, err error)
func (*RegisterResponse) MarshalToSizedBuffer ¶
func (m *RegisterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RegisterResponse) ProtoMessage ¶
func (*RegisterResponse) ProtoMessage()
func (*RegisterResponse) Reset ¶
func (m *RegisterResponse) Reset()
func (*RegisterResponse) Size ¶
func (m *RegisterResponse) Size() (n int)
func (*RegisterResponse) String ¶
func (m *RegisterResponse) String() string
func (*RegisterResponse) Unmarshal ¶
func (m *RegisterResponse) Unmarshal(dAtA []byte) error
func (*RegisterResponse) XXX_DiscardUnknown ¶
func (m *RegisterResponse) XXX_DiscardUnknown()
func (*RegisterResponse) XXX_Marshal ¶
func (m *RegisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterResponse) XXX_Merge ¶
func (m *RegisterResponse) XXX_Merge(src proto.Message)
func (*RegisterResponse) XXX_Size ¶
func (m *RegisterResponse) XXX_Size() int
func (*RegisterResponse) XXX_Unmarshal ¶
func (m *RegisterResponse) XXX_Unmarshal(b []byte) error
type ShutDownResponse ¶
type ShutDownResponse struct { IterationNum int32 `protobuf:"varint,1,opt,name=iterationNum,proto3" json:"iterationNum,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ShutDownResponse) Descriptor ¶
func (*ShutDownResponse) Descriptor() ([]byte, []int)
func (*ShutDownResponse) Marshal ¶
func (m *ShutDownResponse) Marshal() (dAtA []byte, err error)
func (*ShutDownResponse) MarshalToSizedBuffer ¶
func (m *ShutDownResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShutDownResponse) ProtoMessage ¶
func (*ShutDownResponse) ProtoMessage()
func (*ShutDownResponse) Reset ¶
func (m *ShutDownResponse) Reset()
func (*ShutDownResponse) Size ¶
func (m *ShutDownResponse) Size() (n int)
func (*ShutDownResponse) String ¶
func (m *ShutDownResponse) String() string
func (*ShutDownResponse) Unmarshal ¶
func (m *ShutDownResponse) Unmarshal(dAtA []byte) error
func (*ShutDownResponse) XXX_DiscardUnknown ¶
func (m *ShutDownResponse) XXX_DiscardUnknown()
func (*ShutDownResponse) XXX_Marshal ¶
func (m *ShutDownResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShutDownResponse) XXX_Merge ¶
func (m *ShutDownResponse) XXX_Merge(src proto.Message)
func (*ShutDownResponse) XXX_Size ¶
func (m *ShutDownResponse) XXX_Size() int
func (*ShutDownResponse) XXX_Unmarshal ¶
func (m *ShutDownResponse) XXX_Unmarshal(b []byte) error
type SyncRequest ¶
type SyncRequest struct { Pair []*SyncStruct `protobuf:"bytes,1,rep,name=pair,proto3" json:"pair,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SyncRequest) Descriptor ¶
func (*SyncRequest) Descriptor() ([]byte, []int)
func (*SyncRequest) Marshal ¶
func (m *SyncRequest) Marshal() (dAtA []byte, err error)
func (*SyncRequest) MarshalToSizedBuffer ¶
func (m *SyncRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SyncRequest) ProtoMessage ¶
func (*SyncRequest) ProtoMessage()
func (*SyncRequest) Reset ¶
func (m *SyncRequest) Reset()
func (*SyncRequest) Size ¶
func (m *SyncRequest) Size() (n int)
func (*SyncRequest) String ¶
func (m *SyncRequest) String() string
func (*SyncRequest) Unmarshal ¶
func (m *SyncRequest) Unmarshal(dAtA []byte) error
func (*SyncRequest) XXX_DiscardUnknown ¶
func (m *SyncRequest) XXX_DiscardUnknown()
func (*SyncRequest) XXX_Marshal ¶
func (m *SyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncRequest) XXX_Merge ¶
func (m *SyncRequest) XXX_Merge(src proto.Message)
func (*SyncRequest) XXX_Size ¶
func (m *SyncRequest) XXX_Size() int
func (*SyncRequest) XXX_Unmarshal ¶
func (m *SyncRequest) XXX_Unmarshal(b []byte) error
type SyncStruct ¶
type SyncStruct struct { NodeID int32 `protobuf:"varint,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"` Val float32 `protobuf:"fixed32,2,opt,name=val,proto3" json:"val,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SyncStruct) Descriptor ¶
func (*SyncStruct) Descriptor() ([]byte, []int)
func (*SyncStruct) Marshal ¶
func (m *SyncStruct) Marshal() (dAtA []byte, err error)
func (*SyncStruct) MarshalToSizedBuffer ¶
func (m *SyncStruct) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SyncStruct) ProtoMessage ¶
func (*SyncStruct) ProtoMessage()
func (*SyncStruct) Reset ¶
func (m *SyncStruct) Reset()
func (*SyncStruct) Size ¶
func (m *SyncStruct) Size() (n int)
func (*SyncStruct) String ¶
func (m *SyncStruct) String() string
func (*SyncStruct) Unmarshal ¶
func (m *SyncStruct) Unmarshal(dAtA []byte) error
func (*SyncStruct) XXX_DiscardUnknown ¶
func (m *SyncStruct) XXX_DiscardUnknown()
func (*SyncStruct) XXX_Marshal ¶
func (m *SyncStruct) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncStruct) XXX_Merge ¶
func (m *SyncStruct) XXX_Merge(src proto.Message)
func (*SyncStruct) XXX_Size ¶
func (m *SyncStruct) XXX_Size() int
func (*SyncStruct) XXX_Unmarshal ¶
func (m *SyncStruct) XXX_Unmarshal(b []byte) error
type UnimplementedMasterServer ¶
type UnimplementedMasterServer struct { }
UnimplementedMasterServer can be embedded to have forward compatible implementations.
func (*UnimplementedMasterServer) CalculateFinish ¶
func (*UnimplementedMasterServer) CalculateFinish(ctx context.Context, req *CalculateFinishRequest) (*CalculateFinishResponse, error)
func (*UnimplementedMasterServer) Register ¶
func (*UnimplementedMasterServer) Register(ctx context.Context, req *RegisterRequest) (*RegisterResponse, error)
func (*UnimplementedMasterServer) SuperStepFinish ¶
func (*UnimplementedMasterServer) SuperStepFinish(ctx context.Context, req *FinishRequest) (*FinishResponse, error)
type UnimplementedWorkerServer ¶
type UnimplementedWorkerServer struct { }
UnimplementedWorkerServer can be embedded to have forward compatible implementations.
func (*UnimplementedWorkerServer) Assemble ¶
func (*UnimplementedWorkerServer) Assemble(ctx context.Context, req *EmptyRequest) (*AssembleResponse, error)
func (*UnimplementedWorkerServer) BeatHeart ¶
func (*UnimplementedWorkerServer) BeatHeart(ctx context.Context, req *EmptyRequest) (*EmptyResponse, error)
func (*UnimplementedWorkerServer) ExchangeMessage ¶
func (*UnimplementedWorkerServer) ExchangeMessage(ctx context.Context, req *EmptyRequest) (*ExchangeResponse, error)
func (*UnimplementedWorkerServer) IncEval ¶
func (*UnimplementedWorkerServer) IncEval(ctx context.Context, req *EmptyRequest) (*IncEvalResponse, error)
func (*UnimplementedWorkerServer) MessageSend ¶
func (*UnimplementedWorkerServer) MessageSend(ctx context.Context, req *MessageRequest) (*EmptyResponse, error)
func (*UnimplementedWorkerServer) PEval ¶
func (*UnimplementedWorkerServer) PEval(ctx context.Context, req *EmptyRequest) (*PEvalResponse, error)
func (*UnimplementedWorkerServer) Recovery ¶
func (*UnimplementedWorkerServer) Recovery(ctx context.Context, req *RecoveryRequest) (*EmptyResponse, error)
func (*UnimplementedWorkerServer) ShutDown ¶
func (*UnimplementedWorkerServer) ShutDown(ctx context.Context, req *EmptyRequest) (*ShutDownResponse, error)
func (*UnimplementedWorkerServer) SyncVal ¶
func (*UnimplementedWorkerServer) SyncVal(ctx context.Context, req *SyncRequest) (*EmptyResponse, error)
type WorkerClient ¶
type WorkerClient interface { //service from master ShutDown(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*ShutDownResponse, error) PEval(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*PEvalResponse, error) IncEval(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*IncEvalResponse, error) ExchangeMessage(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*ExchangeResponse, error) Assemble(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*AssembleResponse, error) //service from worker MessageSend(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*EmptyResponse, error) SyncVal(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*EmptyResponse, error) // fault tolerance BeatHeart(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*EmptyResponse, error) // rpc Terminate(emptyRequest) returns (emptyResponse) {} Recovery(ctx context.Context, in *RecoveryRequest, opts ...grpc.CallOption) (*EmptyResponse, error) }
WorkerClient is the client API for Worker service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewWorkerClient ¶
func NewWorkerClient(cc *grpc.ClientConn) WorkerClient
type WorkerCommunicationSize ¶
type WorkerCommunicationSize struct { WorkerID int32 `protobuf:"varint,1,opt,name=workerID,proto3" json:"workerID,omitempty"` CommunicationSize int32 `protobuf:"varint,2,opt,name=communicationSize,proto3" json:"communicationSize,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WorkerCommunicationSize) Descriptor ¶
func (*WorkerCommunicationSize) Descriptor() ([]byte, []int)
func (*WorkerCommunicationSize) Marshal ¶
func (m *WorkerCommunicationSize) Marshal() (dAtA []byte, err error)
func (*WorkerCommunicationSize) MarshalTo ¶
func (m *WorkerCommunicationSize) MarshalTo(dAtA []byte) (int, error)
func (*WorkerCommunicationSize) MarshalToSizedBuffer ¶
func (m *WorkerCommunicationSize) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkerCommunicationSize) ProtoMessage ¶
func (*WorkerCommunicationSize) ProtoMessage()
func (*WorkerCommunicationSize) Reset ¶
func (m *WorkerCommunicationSize) Reset()
func (*WorkerCommunicationSize) Size ¶
func (m *WorkerCommunicationSize) Size() (n int)
func (*WorkerCommunicationSize) String ¶
func (m *WorkerCommunicationSize) String() string
func (*WorkerCommunicationSize) Unmarshal ¶
func (m *WorkerCommunicationSize) Unmarshal(dAtA []byte) error
func (*WorkerCommunicationSize) XXX_DiscardUnknown ¶
func (m *WorkerCommunicationSize) XXX_DiscardUnknown()
func (*WorkerCommunicationSize) XXX_Marshal ¶
func (m *WorkerCommunicationSize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkerCommunicationSize) XXX_Merge ¶
func (m *WorkerCommunicationSize) XXX_Merge(src proto.Message)
func (*WorkerCommunicationSize) XXX_Size ¶
func (m *WorkerCommunicationSize) XXX_Size() int
func (*WorkerCommunicationSize) XXX_Unmarshal ¶
func (m *WorkerCommunicationSize) XXX_Unmarshal(b []byte) error
type WorkerServer ¶
type WorkerServer interface { //service from master ShutDown(context.Context, *EmptyRequest) (*ShutDownResponse, error) PEval(context.Context, *EmptyRequest) (*PEvalResponse, error) IncEval(context.Context, *EmptyRequest) (*IncEvalResponse, error) ExchangeMessage(context.Context, *EmptyRequest) (*ExchangeResponse, error) Assemble(context.Context, *EmptyRequest) (*AssembleResponse, error) //service from worker MessageSend(context.Context, *MessageRequest) (*EmptyResponse, error) SyncVal(context.Context, *SyncRequest) (*EmptyResponse, error) // fault tolerance BeatHeart(context.Context, *EmptyRequest) (*EmptyResponse, error) // rpc Terminate(emptyRequest) returns (emptyResponse) {} Recovery(context.Context, *RecoveryRequest) (*EmptyResponse, error) }
WorkerServer is the server API for Worker service.
Click to show internal directories.
Click to hide internal directories.