Versions in this module Expand all Collapse all v1 v1.0.0 Jul 19, 2024 Changes in this version + var ErrClosed = errors.New("connection closed") + var ErrFailedToConnect = errors.New("failed to connect") + func NewChanTransport(nhConfig config.NodeHostConfig, requestHandler raftio.MessageHandler, ...) raftio.ITransport + type ChanConnection struct + func (cc *ChanConnection) Close() + func (cc *ChanConnection) SendMessageBatch(batch pb.MessageBatch) error + type ChanSSConnection struct + func (csc *ChanSSConnection) Close() + func (csc *ChanSSConnection) SendChunk(chunk pb.Chunk) error + type ChanTransport struct + func (ct *ChanTransport) Close() error + func (ct *ChanTransport) GetConnection(ctx context.Context, target string) (raftio.IConnection, error) + func (ct *ChanTransport) GetSnapshotConnection(ctx context.Context, target string) (raftio.ISnapshotConnection, error) + func (ct *ChanTransport) Name() string + func (ct *ChanTransport) Start() error + type ChanTransportFactory struct + func (ctm *ChanTransportFactory) Create(nhConfig config.NodeHostConfig, handler raftio.MessageHandler, ...) raftio.ITransport + func (ctm *ChanTransportFactory) Validate(addr string) bool Other modules containing this package github.com/foreeest/dragonboat/v2