file

Jun 6, 2021

Changes in this version

+ const ReplicaClientType

+ type ReplicaClient struct

+ Replica *litestream.Replica

+ func NewReplicaClient(path string) *ReplicaClient

+ func (c *ReplicaClient) DeleteGeneration(ctx context.Context, generation string) error

+ func (c *ReplicaClient) DeleteSnapshot(ctx context.Context, generation string, index int) error

+ func (c *ReplicaClient) DeleteWALSegments(ctx context.Context, a []litestream.Pos) error

+ func (c *ReplicaClient) GenerationDir(generation string) (string, error)

+ func (c *ReplicaClient) Generations(ctx context.Context) ([]string, error)

+ func (c *ReplicaClient) GenerationsDir() (string, error)

+ func (c *ReplicaClient) Path() string

+ func (c *ReplicaClient) SnapshotPath(generation string, index int) (string, error)

+ func (c *ReplicaClient) SnapshotReader(ctx context.Context, generation string, index int) (io.ReadCloser, error)

+ func (c *ReplicaClient) Snapshots(ctx context.Context, generation string) (litestream.SnapshotIterator, error)

+ func (c *ReplicaClient) SnapshotsDir(generation string) (string, error)

+ func (c *ReplicaClient) Type() string

+ func (c *ReplicaClient) WALDir(generation string) (string, error)

+ func (c *ReplicaClient) WALSegmentPath(generation string, index int, offset int64) (string, error)

+ func (c *ReplicaClient) WALSegmentReader(ctx context.Context, pos litestream.Pos) (io.ReadCloser, error)

+ func (c *ReplicaClient) WALSegments(ctx context.Context, generation string) (litestream.WALSegmentIterator, error)

+ func (c *ReplicaClient) WriteSnapshot(ctx context.Context, generation string, index int, rd io.Reader) (info litestream.SnapshotInfo, err error)

+ func (c *ReplicaClient) WriteWALSegment(ctx context.Context, pos litestream.Pos, rd io.Reader) (info litestream.WALSegmentInfo, err error)