logreader

Documentation

Index

• type Cached
  • func (l *Cached) QueryRaftLog(ctx context.Context, clusterID uint64, logRange dragonboat.LogRange, ...) ([]raftpb.Entry, error)
• type Interface
• type ShardCache
  • func NewShardCache(size int) *ShardCache
  • func (l *ShardCache) LogCompacted(shardID uint64)
  • func (l *ShardCache) NodeDeleted(shardID uint64)
• type Simple
  • func (l *Simple) QueryRaftLog(ctx context.Context, clusterID uint64, logRange dragonboat.LogRange, ...) ([]raftpb.Entry, error)

Types

type Cached

type Cached struct {
	LogQuerier logQuerier
	*ShardCache
}

func (*Cached) QueryRaftLog

func (l *Cached) QueryRaftLog(ctx context.Context, clusterID uint64, logRange dragonboat.LogRange, maxSize uint64) ([]raftpb.Entry, error)

type Interface

type Interface interface {
	// QueryRaftLog for all the entries in a given cluster within the right half-open range
	// defined by dragonboat.LogRange. MaxSize denotes the maximum cumulative size of the entries,
	// but this serves only as a hint and the actual size of returned entries may be larger than maxSize.
	QueryRaftLog(context.Context, uint64, dragonboat.LogRange, uint64) ([]raftpb.Entry, error)
}

type ShardCache

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

func NewShardCache

func NewShardCache(size int) *ShardCache

func (*ShardCache) LogCompacted

func (l *ShardCache) LogCompacted(shardID uint64)

func (*ShardCache) NodeDeleted

func (l *ShardCache) NodeDeleted(shardID uint64)

type Simple

type Simple struct {
	LogQuerier logQuerier
}

func (*Simple) QueryRaftLog

func (l *Simple) QueryRaftLog(ctx context.Context, clusterID uint64, logRange dragonboat.LogRange, maxSize uint64) ([]raftpb.Entry, error)