transaction

Documentation

Index

• type ConcurrentWriteTransaction
  • func NewConcurrentWriteTransaction(space SpaceMeta) *ConcurrentWriteTransaction
  • func (t *ConcurrentWriteTransaction) Commit() error
  • func (t *ConcurrentWriteTransaction) Delete(reader array.RecordReader) Transaction
  • func (t *ConcurrentWriteTransaction) Write(reader array.RecordReader, options *options.WriteOptions) Transaction
  • func (t *ConcurrentWriteTransaction) WriteBlob(content []byte, name string, replace bool) Transaction
• type DeleteOperation
  • func (o *DeleteOperation) Execute() error
• type Operation
• type SpaceMeta
• type Transaction
• type WriteBlobOperation
  • func (o *WriteBlobOperation) Execute() error
• type WriteOperation
  • func (w *WriteOperation) Execute() error

Types

type ConcurrentWriteTransaction

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

func NewConcurrentWriteTransaction

func NewConcurrentWriteTransaction(space SpaceMeta) *ConcurrentWriteTransaction

func (*ConcurrentWriteTransaction) Commit

func (t *ConcurrentWriteTransaction) Commit() error

func (*ConcurrentWriteTransaction) Delete

func (t *ConcurrentWriteTransaction) Delete(reader array.RecordReader) Transaction

func (*ConcurrentWriteTransaction) Write

func (t *ConcurrentWriteTransaction) Write(reader array.RecordReader, options *options.WriteOptions) Transaction

func (*ConcurrentWriteTransaction) WriteBlob

func (t *ConcurrentWriteTransaction) WriteBlob(content []byte, name string, replace bool) Transaction

type DeleteOperation

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

func (*DeleteOperation) Execute

func (o *DeleteOperation) Execute() error

type Operation

type Operation interface {
	Execute() error
}

type SpaceMeta

type SpaceMeta interface {
	Path() string
	Fs() fs.Fs
	Manifest() *manifest.Manifest
	LockManager() lock.LockManager
	SetManifest(manifest *manifest.Manifest)
}

type Transaction

type Transaction interface {
	Write(reader array.RecordReader, options *options.WriteOptions) Transaction
	Delete(reader array.RecordReader) Transaction
	WriteBlob(content []byte, name string, replace bool) Transaction
	Commit() error
}

type WriteBlobOperation

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

func (*WriteBlobOperation) Execute

func (o *WriteBlobOperation) Execute() error

type WriteOperation

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

func (*WriteOperation) Execute

func (w *WriteOperation) Execute() error