rafthttp

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

type Processor interface {
	Process(ctx context.Context, m raftpb.Message) error
}

type Sender interface {
	// StartStreaming enables streaming in the sender using the given writer,
	// which provides a fast and effecient way to send appendEntry messages.
	StartStreaming(w WriteFlusher, to types.ID, term uint64) (done <-chan struct{}, err error)
	Update(u string)
	// Send sends the data to the remote node. It is always non-blocking.
	// It may be fail to send data if it returns nil error.
	Send(m raftpb.Message) error
	// Stop performs any necessary finalization and terminates the Sender
	// elegantly.
	Stop()
}

type SenderFinder interface {
	// Sender returns the sender of the given id.
	Sender(id types.ID) Sender
}

type WriteFlusher interface {
	io.Writer
	http.Flusher
}