grpc

Nov 3, 2022

Changes in this version

+ var File_net_grpc_grpctransport_proto protoreflect.FileDescriptor

+ var GrpcTransport_ServiceDesc = grpc.ServiceDesc

+ func RegisterGrpcTransportServer(s grpc.ServiceRegistrar, srv GrpcTransportServer)

+ type ByeBye struct

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

+ func (*ByeBye) ProtoMessage()

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

+ func (x *ByeBye) Reset()

+ func (x *ByeBye) String() string

+ type GrpcMessage struct

+ Msg *messagepb.Message

+ Sender string

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

+ func (*GrpcMessage) ProtoMessage()

+ func (x *GrpcMessage) GetMsg() *messagepb.Message

+ func (x *GrpcMessage) GetSender() string

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

+ func (x *GrpcMessage) Reset()

+ func (x *GrpcMessage) String() string

+ type GrpcTransportClient interface

+ Listen func(ctx context.Context, opts ...grpc.CallOption) (GrpcTransport_ListenClient, error)

+ func NewGrpcTransportClient(cc grpc.ClientConnInterface) GrpcTransportClient

+ type GrpcTransportServer interface

+ Listen func(GrpcTransport_ListenServer) error

+ type GrpcTransport_ListenClient interface

+ CloseAndRecv func() (*ByeBye, error)

+ Send func(*GrpcMessage) error

+ type GrpcTransport_ListenServer interface

+ Recv func() (*GrpcMessage, error)

+ SendAndClose func(*ByeBye) error

+ type Transport struct

+ func NewTransport(id t.NodeID, addr t.NodeAddress, l logging.Logger) (*Transport, error)

+ func (gt *Transport) ApplyEvents(ctx context.Context, eventList *events.EventList) error

+ func (gt *Transport) CloseOldConnections(newNodes map[t.NodeID]t.NodeAddress)

+ func (gt *Transport) Connect(nodes map[t.NodeID]t.NodeAddress)

+ func (gt *Transport) EventsOut() <-chan *events.EventList

+ func (gt *Transport) ImplementsModule()

+ func (gt *Transport) Listen(srv GrpcTransport_ListenServer) error

+ func (gt *Transport) Send(dest t.NodeID, msg *messagepb.Message) error

+ func (gt *Transport) ServerError() error

+ func (gt *Transport) Start() error

+ func (gt *Transport) Stop()

+ func (gt *Transport) WaitFor(n int)

+ type UnimplementedGrpcTransportServer struct

+ func (UnimplementedGrpcTransportServer) Listen(GrpcTransport_ListenServer) error

+ type UnsafeGrpcTransportServer interface