collapsar

README

optional coalescing of raft apply log request for enhanced performance

waiting for a time slice, and when it is about to enter the next time slice, merge all requests in this time slice. Or when the count of requests in a time slice reaches the maximum threshold that can be set, all requests are merged.

issues#33 - https://github.com/RealFax/RedQueen/issues/33

Documentation

Index

• type Binary
• type Reader
  • func NewReader(r io.Reader) (Reader, error)
• type Writer
  • func NewWriter(max int32) Writer

Types

type Binary

type Binary struct {
	Size    int32
	Entries [][]byte
}

type Reader

type Reader interface {
	Next() ([]byte, error)
}

func NewReader

func NewReader(r io.Reader) (Reader, error)

type Writer

type Writer interface {
	Encode(w io.Writer) error
	Add(entry []byte) error
	Wait()
	Close() error
}

func NewWriter

func NewWriter(max int32) Writer