atomic

Documentation

Index

• func WriteAll(baseBatch database.Batch, batches ...database.Batch) error
• type Element
• type Memory
  • func (m *Memory) GetDatabase(sharedID ids.ID) (*versiondb.Database, database.Database)
  • func (m *Memory) Initialize(log logging.Logger, db database.Database) error
  • func (m *Memory) NewSharedMemory(id ids.ID) SharedMemory
  • func (m *Memory) ReleaseDatabase(sharedID ids.ID)
• type SharedMemory

Functions

func WriteAll

func WriteAll(baseBatch database.Batch, batches ...database.Batch) error

WriteAll assumes all batches have the same underlying database. Batches should not be modified after being passed to this function.

Types

type Element

type Element struct {
	Key    []byte
	Value  []byte
	Traits [][]byte
}

Element ...

type Memory

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

Memory is the interface for shared memory inside a subnet

func (*Memory) GetDatabase

func (m *Memory) GetDatabase(sharedID ids.ID) (*versiondb.Database, database.Database)

GetDatabase returns and locks the provided DB

func (*Memory) Initialize

func (m *Memory) Initialize(log logging.Logger, db database.Database) error

Initialize the SharedMemory

func (*Memory) NewSharedMemory

func (m *Memory) NewSharedMemory(id ids.ID) SharedMemory

NewSharedMemory returns a new SharedMemory

func (*Memory) ReleaseDatabase

func (m *Memory) ReleaseDatabase(sharedID ids.ID)

ReleaseDatabase unlocks the provided DB

type SharedMemory

type SharedMemory interface {
	// Adds to the peer chain's side
	Put(peerChainID ids.ID, elems []*Element, batches ...database.Batch) error

	// Fetches from this chain's side
	Get(peerChainID ids.ID, keys [][]byte) (values [][]byte, err error)
	Indexed(
		peerChainID ids.ID,
		traits [][]byte,
		startTrait,
		startKey []byte,
		limit int,
	) (
		values [][]byte,
		lastTrait,
		lastKey []byte,
		err error,
	)
	Remove(peerChainID ids.ID, keys [][]byte, batches ...database.Batch) error
}

SharedMemory ...