flusher

Documentation

Index

• type Flusher
  • func New(confSource config.Source, dataShards, parityShards int, ...) (*Flusher, error)
  • func (f *Flusher) AddTransaction(op uint8, seq uint64, content []byte, index, timestamp int64) error
  • func (f *Flusher) Flush() (int, error)

Types

type Flusher

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

Flusher defines a tlog flusher

func New

func New(confSource config.Source, dataShards, parityShards int, vdiskID, privKey string) (*Flusher, error)

New creates a new flusher

func (*Flusher) AddTransaction

func (f *Flusher) AddTransaction(op uint8, seq uint64, content []byte, index, timestamp int64) error

AddTransaction add transaction to this flusher and flush it if it reach FlushSize

func (*Flusher) Flush

func (f *Flusher) Flush() (int, error)

Flush flushes the transactions in buffer