storage

Documentation

Index

• type BatchCommittedResult
• type MemStorage
  • func (ms *MemStorage) GetState(ns, key string) ([]byte, error)
  • func (ms *MemStorage) Write(batchCommittedResult *BatchCommittedResult)
• type Storage

Types

type BatchCommittedResult

type BatchCommittedResult struct {
	TransactionContexts []*transaction.Context
	BatchNum            int64
	BatchMetadata       []byte
	WrittenSignal       chan struct{}
	SyncedSignal        chan struct{}
}

type MemStorage

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

func (*MemStorage) GetState

func (ms *MemStorage) GetState(ns, key string) ([]byte, error)

func (*MemStorage) Write

func (ms *MemStorage) Write(batchCommittedResult *BatchCommittedResult)

type Storage

type Storage interface {
	// GetState reads a value for a specific key. The value may be read from cache
	// and not persistent yet.
	GetState(ns, key string) ([]byte, error)

	// Write writes the transaction batch and updated state to underlying storage.
	Write(batchCommittedResult *BatchCommittedResult)
}