mock

Documentation

Index

• type 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) Generations(ctx context.Context) ([]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) Type() string
  • 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, r io.Reader) (litestream.SnapshotInfo, error)
  • func (c *ReplicaClient) WriteWALSegment(ctx context.Context, pos litestream.Pos, r io.Reader) (litestream.WALSegmentInfo, error)

Types

type ReplicaClient

type ReplicaClient struct {
	GenerationsFunc       func(ctx context.Context) ([]string, error)
	DeleteGenerationFunc  func(ctx context.Context, generation string) error
	SnapshotsFunc         func(ctx context.Context, generation string) (litestream.SnapshotIterator, error)
	WriteSnapshotFunc     func(ctx context.Context, generation string, index int, r io.Reader) (litestream.SnapshotInfo, error)
	DeleteSnapshotFunc    func(ctx context.Context, generation string, index int) error
	SnapshotReaderFunc    func(ctx context.Context, generation string, index int) (io.ReadCloser, error)
	WALSegmentsFunc       func(ctx context.Context, generation string) (litestream.WALSegmentIterator, error)
	WriteWALSegmentFunc   func(ctx context.Context, pos litestream.Pos, r io.Reader) (litestream.WALSegmentInfo, error)
	DeleteWALSegmentsFunc func(ctx context.Context, a []litestream.Pos) error
	WALSegmentReaderFunc  func(ctx context.Context, pos litestream.Pos) (io.ReadCloser, error)
}

func (*ReplicaClient) DeleteGeneration

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

func (*ReplicaClient) DeleteSnapshot

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

func (*ReplicaClient) DeleteWALSegments

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

func (*ReplicaClient) Generations

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

func (*ReplicaClient) SnapshotReader

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

func (*ReplicaClient) Snapshots

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

func (*ReplicaClient) Type

func (c *ReplicaClient) Type() string

func (*ReplicaClient) WALSegmentReader

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

func (*ReplicaClient) WALSegments

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

func (*ReplicaClient) WriteSnapshot

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

func (*ReplicaClient) WriteWALSegment

func (c *ReplicaClient) WriteWALSegment(ctx context.Context, pos litestream.Pos, r io.Reader) (litestream.WALSegmentInfo, error)