protobuf

package
v0.0.0-...-71aaec9 Latest Latest
Warning

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

 Go to latest Published: Dec 28, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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.