Struct NodeTransport

store/transport.go:57–70

NodeTransport is a wrapper around the Raft NetworkTransport, which allows custom configuration of the InstallSnapshot method.

// NodeTransport is a wrapper around the Raft NetworkTransport, which allows
// custom configuration of the InstallSnapshot method.
type NodeTransport struct {
	*raft.NetworkTransport
	compressSnap bool

	aeMu                   sync.RWMutex
	appendEntriesTxHandler func(req *raft.AppendEntriesRequest) error
	appendEntriesRxHandler func(req *raft.AppendEntriesRequest) error

	commandCommitIndex *atomic.Uint64
	leaderCommitIndex  *atomic.Uint64
	done               chan struct{}
	closed             bool
	logger             *log.Logger
}

// NewNodeTransport returns an initialized NodeTransport.
func NewNodeTransport(transport *raft.NetworkTransport, compressSnap bool) *NodeTransport {