communicator

package

Go to main page

Versions in this module

v0

v0.2.6

Feb 16, 2024

Changes in this version

type InitRequest

+ Seed int64

+ func (x *InitRequest) GetSeed() int64

v0.2.5

Oct 19, 2023

v0.2.4

Sep 8, 2023

v0.2.3

Aug 27, 2023

v0.2.2

Aug 25, 2023

v0.2.1

Aug 22, 2023

v0.2.0

Aug 20, 2023

Changes in this version

type InitRequest

+ Kind *Schedule

+ func (x *InitRequest) GetKind() Schedule

type Schedule

+ const Schedule_GUIDED

v0.1.1

Jul 25, 2023

v0.1.0

Jul 24, 2023

Changes in this version

+ const Communicator_Bcast_FullMethodName

+ const Communicator_Finalize_FullMethodName

+ const Communicator_Init_FullMethodName

+ var Communicator_ServiceDesc = grpc.ServiceDesc

+ var File_communicator_proto protoreflect.FileDescriptor

+ var Schedule_name = map[int32]string

+ var Schedule_value = map[string]int32

+ func RegisterCommunicatorServer(s grpc.ServiceRegistrar, srv CommunicatorServer)

+ type BcastRequest struct

+ Coefficient *float64

+ Epoch int64

+ Intercept *float64

+ Rank int64

+ func (*BcastRequest) Descriptor() ([]byte, []int)

+ func (*BcastRequest) ProtoMessage()

+ func (x *BcastRequest) GetCoefficient() float64

+ func (x *BcastRequest) GetEpoch() int64

+ func (x *BcastRequest) GetIntercept() float64

+ func (x *BcastRequest) GetRank() int64

+ func (x *BcastRequest) ProtoReflect() protoreflect.Message

+ func (x *BcastRequest) Reset()

+ func (x *BcastRequest) String() string

+ type BcastResponse struct

+ Indices []int64

+ func (*BcastResponse) Descriptor() ([]byte, []int)

+ func (*BcastResponse) ProtoMessage()

+ func (x *BcastResponse) GetIndices() []int64

+ func (x *BcastResponse) ProtoReflect() protoreflect.Message

+ func (x *BcastResponse) Reset()

+ func (x *BcastResponse) String() string

+ type CommunicatorClient interface

+ Bcast func(ctx context.Context, in *BcastRequest, opts ...grpc.CallOption) (*BcastResponse, error)

+ Finalize func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)

+ Init func(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ func NewCommunicatorClient(cc grpc.ClientConnInterface) CommunicatorClient

+ type CommunicatorServer interface

+ Bcast func(context.Context, *BcastRequest) (*BcastResponse, error)

+ Finalize func(context.Context, *empty.Empty) (*empty.Empty, error)

+ Init func(context.Context, *InitRequest) (*empty.Empty, error)

+ func NewCommunicatorServer(done chan<- os.Signal, worldSize int) CommunicatorServer

+ type InitRequest struct

+ BatchSize int64

+ Groups []int64

+ Partition *bool

+ Rank int64

+ Sizes []int64

+ Type *Schedule

+ func (*InitRequest) Descriptor() ([]byte, []int)

+ func (*InitRequest) ProtoMessage()

+ func (x *InitRequest) GetBatchSize() int64

+ func (x *InitRequest) GetGroups() []int64

+ func (x *InitRequest) GetPartition() bool

+ func (x *InitRequest) GetRank() int64

+ func (x *InitRequest) GetSizes() []int64

+ func (x *InitRequest) GetType() Schedule

+ func (x *InitRequest) ProtoReflect() protoreflect.Message

+ func (x *InitRequest) Reset()

+ func (x *InitRequest) String() string

+ type Schedule int32

+ const Schedule_DYNAMIC

+ const Schedule_STATIC

+ func (Schedule) Descriptor() protoreflect.EnumDescriptor

+ func (Schedule) EnumDescriptor() ([]byte, []int)

+ func (Schedule) Type() protoreflect.EnumType

+ func (x Schedule) Enum() *Schedule

+ func (x Schedule) Number() protoreflect.EnumNumber

+ func (x Schedule) String() string

+ type UnimplementedCommunicatorServer struct

+ func (UnimplementedCommunicatorServer) Bcast(context.Context, *BcastRequest) (*BcastResponse, error)

+ func (UnimplementedCommunicatorServer) Finalize(context.Context, *empty.Empty) (*empty.Empty, error)

+ func (UnimplementedCommunicatorServer) Init(context.Context, *InitRequest) (*empty.Empty, error)

+ type UnsafeCommunicatorServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL