Documentation ¶
Index ¶
- type Config
- type Log
- func (l *Log) Append(record *api.Record) (off uint64, err error)
- func (l *Log) Close() error
- func (l *Log) HighestOffset() (uint64, error)
- func (l *Log) LowestOffset() (uint64, error)
- func (l *Log) Read(off uint64) (*api.Record, error)
- func (l *Log) Reader() io.Reader
- func (l *Log) Remove() error
- func (l *Log) Reset() error
- func (l *Log) Truncate(lowest uint64) error
- type Replicator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Log ¶
func (*Log) HighestOffset ¶
func (*Log) LowestOffset ¶
type Replicator ¶
type Replicator struct { DialOptions []grpc.DialOption LocalServer api.LogClient // contains filtered or unexported fields }
func (*Replicator) Close ¶
func (r *Replicator) Close() error
func (*Replicator) Join ¶
func (r *Replicator) Join(name, addr string) error
func (*Replicator) Leave ¶
func (r *Replicator) Leave(name string) error
Click to show internal directories.
Click to hide internal directories.