Versions in this module Expand all Collapse all v0 v0.0.0 Feb 25, 2025 Changes in this version + type Backend struct + func NewBackend(h Handle, l hclog.Logger) (*Backend, error) + func (b *Backend) Apply(buf []byte, idx uint64) any + func (b *Backend) DeleteCAS(ctx context.Context, id *pbresource.ID, version string) error + func (b *Backend) HandleConnection(conn net.Conn) + func (b *Backend) LeaderChanged() + func (b *Backend) List(ctx context.Context, consistency storage.ReadConsistency, ...) ([]*pbresource.Resource, error) + func (b *Backend) ListByOwner(_ context.Context, id *pbresource.ID) ([]*pbresource.Resource, error) + func (b *Backend) Read(ctx context.Context, consistency storage.ReadConsistency, id *pbresource.ID) (*pbresource.Resource, error) + func (b *Backend) Restore() (*Restoration, error) + func (b *Backend) Run(ctx context.Context) + func (b *Backend) Snapshot() (*Snapshot, error) + func (b *Backend) WatchList(_ context.Context, resType storage.UnversionedType, ...) (storage.Watch, error) + func (b *Backend) WriteCAS(ctx context.Context, res *pbresource.Resource) (*pbresource.Resource, error) + type Handle interface + Apply func(msg []byte) (any, error) + DialLeader func() (*grpc.ClientConn, error) + EnsureStrongConsistency func(ctx context.Context) error + IsLeader func() bool + type Restoration struct + func (r *Restoration) Abort() + func (r *Restoration) Apply(msg []byte) error + func (r *Restoration) Commit() + type Snapshot struct + func (s *Snapshot) Next() ([]byte, error)
Go to main page