transport

type Chunk struct {
	// contains filtered or unexported fields
}

type Connection interface {
	// Close closes the Connection instance.
	Close()
	// SendMessageBatch sends the specified message batch to the target. It is
	// recommended to deliver the message batch to the target in order to enjoy
	// best possible performance, but out of order delivery is allowed at the
	// cost of reduced performance.
	SendMessageBatch(batch meta.RaftMessageBatch) error
}

type ContainerResolver func(storeID uint64) (string, error)

type MessageHandler func(meta.RaftMessageBatch)

type SnapshotChunkHandler func(meta.SnapshotChunk) bool

type SnapshotConnection interface {
	// Close closes the SnapshotConnection instance.
	Close()
	// SendChunk sends the snapshot chunk to the target. It is
	// recommended to have the snapshot chunk delivered in order for the best
	// performance, but out of order delivery is allowed at the cost of reduced
	// performance.
	SendChunk(chunk meta.SnapshotChunk) error
}

type SnapshotStatusHandler func(uint64, uint64, raftpb.Snapshot, bool)

type TCP struct {
	// contains filtered or unexported fields
}

type TCPConnection struct {
	// contains filtered or unexported fields
}

type TCPSnapshotConnection struct {
	// contains filtered or unexported fields
}

type Trans interface {
	Send(meta.RaftMessage) bool
	SendSnapshot(meta.RaftMessage) bool
	SetFilter(func(meta.RaftMessage) bool)
	SendingSnapshotCount() uint64
	Start() error
	Close() error
}

type TransImpl interface {
	// Name returns the type name of the TransImpl instance.
	Name() string
	// Start launches the transport module and make it ready to start sending and
	// receiving Raft messages. If necessary, TransImpl may take this opportunity
	// to start listening for incoming data.
	Start() error
	// Close closes the transport module.
	Close() error
	// GetConnection returns an Connection instance used for sending messages
	// to the specified target store instance.
	GetConnection(ctx context.Context, target string) (Connection, error)
	// GetSnapshotConnection returns an Connection instance used for transporting
	// snapshots to the specified store instance.
	GetSnapshotConnection(ctx context.Context,
		target string) (SnapshotConnection, error)
}

type Transport struct {
	// contains filtered or unexported fields
}

type UnreachableHandler func(uint64, uint64)