Documentation ¶
Index ¶
- Constants
- type Params
- type Transport
- func (tr *Transport) ApplyEvents(_ context.Context, eventList *events.EventList) error
- func (tr *Transport) CloseOldConnections(newMembership *trantorpbtypes.Membership)
- func (tr *Transport) Connect(membership *trantorpbtypes.Membership)
- func (tr *Transport) EventsOut() <-chan *events.EventList
- func (tr *Transport) ImplementsModule()
- func (tr *Transport) Send(dest t.NodeID, msg *messagepb.Message) error
- func (tr *Transport) Start() error
- func (tr *Transport) Stop()
- func (tr *Transport) WaitFor(n int) error
- type TransportMessage
Constants ¶
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Params ¶
type Params struct { ProtocolID protocol.ID ConnectionTTL time.Duration ConnectionBufferSize int StreamWriteTimeout time.Duration ReconnectionPeriod time.Duration }
func DefaultParams ¶
func DefaultParams() Params
type Transport ¶
type Transport struct {
// contains filtered or unexported fields
}
func NewTransport ¶
func (*Transport) ApplyEvents ¶
func (*Transport) CloseOldConnections ¶
func (tr *Transport) CloseOldConnections(newMembership *trantorpbtypes.Membership)
func (*Transport) Connect ¶
func (tr *Transport) Connect(membership *trantorpbtypes.Membership)
func (*Transport) ImplementsModule ¶
func (tr *Transport) ImplementsModule()
type TransportMessage ¶
func (*TransportMessage) MarshalCBOR ¶
func (t *TransportMessage) MarshalCBOR(w io.Writer) error
func (*TransportMessage) UnmarshalCBOR ¶
func (t *TransportMessage) UnmarshalCBOR(r io.Reader) (err error)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.