kv

Nov 13, 2023

Changes in this version

type DB

+ func (d *DB) StartDiff(ctx context.Context, other *DB) (*DiffCursor, error)

+ func (s *DB) Roots() ([]string, error)

+ type DiffCursor struct

+ func (dc *DiffCursor) NextEntry(ctx context.Context) (mast.Diff, error)

type OpenOptions

+ OnlyVersions []string

Apr 10, 2023

Changes in this version

+ const DefaultBranchFactor

+ var ErrMACVerificationFailure = errors.New("MAC verification failure")

+ var ErrReadOnly = errors.New("opened as read-only")

+ func DeleteHistoricVersions(ctx context.Context, s *DB, before time.Time) error

+ type Config struct

+ BranchFactor uint

+ CustomMarshal func(interface{}) ([]byte, error)

+ CustomMerge func(key interface{}, v1, v2 crdtpub.Value) crdtpub.Value

+ CustomRootPrefix string

+ CustomUnmarshal func([]byte, interface{}) error

+ KeysLike interface{}

+ LogFunc func(string)

+ MastNodeFormat string

+ NodeCache mast.NodeCache

+ NodeEncryptor Encryptor

+ Storage *S3BucketInfo

+ UnmarshalUsesRegisteredTypes bool

+ ValuesLike interface{}

+ type Cursor struct

+ func (c *Cursor) Get() (interface{}, *crdtpub.Value, bool)

+ type DB struct

+ func Open(ctx context.Context, S3 S3Interface, cfg Config, opts OpenOptions, ...) (*DB, error)

+ func (d *DB) BranchFactor() uint

+ func (d *DB) Cursor(ctx context.Context) (*Cursor, error)

+ func (s *DB) Cancel()

+ func (s *DB) Clone(ctx context.Context) (*DB, error)

+ func (s *DB) Commit(ctx context.Context) (*string, error)

+ func (s *DB) Get(ctx context.Context, key interface{}, value interface{}) (bool, error)

+ func (s *DB) IsTombstoned(ctx context.Context, key interface{}) (bool, error)

+ func (s *DB) RemoveTombstones(ctx context.Context, before time.Time) error

+ func (s *DB) Set(ctx context.Context, when time.Time, key interface{}, value interface{}) error

+ func (s *DB) Tombstone(ctx context.Context, when time.Time, key interface{}) error

+ func (s *DB) TraceHistory(ctx context.Context, key interface{}, after time.Time, ...) error

+ func (s DB) Diff(ctx context.Context, from *DB, ...) error

+ func (s DB) Height() int

+ func (s DB) IsDirty() bool

+ func (s DB) Size() uint64

+ type Encryptor interface

+ Decrypt func(path string, value []byte) ([]byte, error)

+ Encrypt func(path string, value []byte) ([]byte, error)

+ func V1NodeEncryptor(passphrase []byte) Encryptor

+ type OnConflictMerged func(key, v1, v2 interface{}) error

+ type OpenOptions struct

+ ForceRebranch bool

+ ReadOnly bool

+ SingleVersion string

+ type S3BucketInfo struct

+ BucketName string

+ EndpointURL string

+ Prefix string

+ type S3Interface interface

+ DeleteObjectWithContext func(ctx aws.Context, input *s3.DeleteObjectInput, opts ...request.Option) (*s3.DeleteObjectOutput, error)

+ GetObjectWithContext func(ctx aws.Context, input *s3.GetObjectInput, opts ...request.Option) (*s3.GetObjectOutput, error)

+ ListObjectsV2WithContext func(ctx aws.Context, input *s3.ListObjectsV2Input, opts ...request.Option) (*s3.ListObjectsV2Output, error)

+ PutObjectWithContext func(ctx aws.Context, input *s3.PutObjectInput, opts ...request.Option) (*s3.PutObjectOutput, error)