Versions in this module Expand all Collapse all v1 v1.0.0 Sep 2, 2024 Changes in this version + var CheckpointMsgHandler func(msg *pb.CheckpointMsg, senderID int32) + var ClientRequestHandler func(msg *pb.ClientRequest) + var Crashed = false + var OrdererMsgHandler func(msg *pb.ProtocolMessage) + var StateTransferMsgHandler func(msg *pb.ProtocolMessage) + func AnnounceBucketAssignment(assignment *pb.BucketAssignment) + func ConfigureTLS(certFile string, keyFile string) *tls.Config + func Connect() + func ConnectToOrderers(ownClientID int32, clientLog zerolog.Logger, ordererIDs []int32) (map[int32]pb.Messenger_RequestClient, map[int32]pb.Messenger_BucketsClient, ...) + func EnqueueMsg(msg *pb.ProtocolMessage, destNodeID int32) + func EnqueuePriorityMsg(msg *pb.ProtocolMessage, destNodeID int32) + func RespondToClient(clientID int32, response *pb.ClientResponse) + func Start(wg *sync.WaitGroup) + type BatchedConnection struct + func NewBatchedConnection(pc PeerConnection, period time.Duration) *BatchedConnection + func (bc *BatchedConnection) Close() + func (bc *BatchedConnection) Send(msg *pb.ProtocolMessage) + func (bc *BatchedConnection) SendPriority(msg *pb.ProtocolMessage) + type BufferedMultiConnection struct + func NewBufferedMultiConnection(msgSinks []pb.Messenger_ListenClient, ...) *BufferedMultiConnection + func (bmc *BufferedMultiConnection) Close() + func (bmc *BufferedMultiConnection) Send(msg *pb.ProtocolMessage) + func (bmc *BufferedMultiConnection) SendPriority(msg *pb.ProtocolMessage) + type LockedSimpleConnection struct + func NewLockedSimpleConnection(msgSink pb.Messenger_ListenClient, priorityMsgSink pb.Messenger_ListenClient) *LockedSimpleConnection + func (lsc *LockedSimpleConnection) Close() + func (lsc *LockedSimpleConnection) Send(msg *pb.ProtocolMessage) + func (lsc *LockedSimpleConnection) SendPriority(msg *pb.ProtocolMessage) + type LockingMultiConnection struct + func NewLockingMultiConnection(msgSinks []pb.Messenger_ListenClient, ...) *LockingMultiConnection + func (lmc *LockingMultiConnection) Close() + func (lmc *LockingMultiConnection) Send(msg *pb.ProtocolMessage) + func (lmc *LockingMultiConnection) SendPriority(msg *pb.ProtocolMessage) + type PeerConnection interface + Close func() + Send func(msg *pb.ProtocolMessage) + SendPriority func(msg *pb.ProtocolMessage)
Go to main page