stream

Documentation

Index

• type StreamTracker
  • func (st *StreamTracker) Apply(l *raft.Log) interface{}
  • func (f *StreamTracker) Restore(r io.ReadCloser) error
  • func (f *StreamTracker) Snapshot() (raft.FSMSnapshot, error)

Types

type StreamTracker

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

func (*StreamTracker) Apply

func (st *StreamTracker) Apply(l *raft.Log) interface{}

func (*StreamTracker) Restore

func (f *StreamTracker) Restore(r io.ReadCloser) error

func (*StreamTracker) Snapshot

func (f *StreamTracker) Snapshot() (raft.FSMSnapshot, error)