ipld

Documentation

Index

• func MarshalCBOR(o cbor.Marshaler) (cid.Cid, []byte, error)
• func NewADTStore(ctx context.Context) adt.Store
• func NewSyncADTStore(ctx context.Context) adt.Store
• type BlockStoreInMemory
  • func NewBlockStoreInMemory() *BlockStoreInMemory
  • func (mb *BlockStoreInMemory) Get(ctx context.Context, c cid.Cid) (block.Block, error)
  • func (mb *BlockStoreInMemory) Put(ctx context.Context, b block.Block) error
• type MetricsBlockStore
  • func NewMetricsBlockStore(underlying cbor.IpldBlockstore) *MetricsBlockStore
  • func (ms *MetricsBlockStore) Get(ctx context.Context, c cid.Cid) (block.Block, error)
  • func (ms *MetricsBlockStore) Put(ctx context.Context, b block.Block) error
  • func (ms *MetricsBlockStore) ReadCount() uint64
  • func (ms *MetricsBlockStore) ReadSize() uint64
  • func (ms *MetricsBlockStore) WriteCount() uint64
  • func (ms *MetricsBlockStore) WriteSize() uint64
• type SyncBlockStoreInMemory
  • func NewSyncBlockStoreInMemory() *SyncBlockStoreInMemory
  • func (ss *SyncBlockStoreInMemory) Get(ctx context.Context, c cid.Cid) (block.Block, error)
  • func (ss *SyncBlockStoreInMemory) Put(ctx context.Context, b block.Block) error

Functions

func MarshalCBOR

func MarshalCBOR(o cbor.Marshaler) (cid.Cid, []byte, error)

Marshals an object to bytes for storing in state.

func NewADTStore

func NewADTStore(ctx context.Context) adt.Store

Creates a new, empty IPLD store in memory.

func NewSyncADTStore

func NewSyncADTStore(ctx context.Context) adt.Store

Creates a new, threadsafe, empty IPLD store in memory

Types

type BlockStoreInMemory

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

func NewBlockStoreInMemory

func NewBlockStoreInMemory() *BlockStoreInMemory

func (*BlockStoreInMemory) Get

func (mb *BlockStoreInMemory) Get(ctx context.Context, c cid.Cid) (block.Block, error)

func (*BlockStoreInMemory) Put

func (mb *BlockStoreInMemory) Put(ctx context.Context, b block.Block) error

type MetricsBlockStore

type MetricsBlockStore struct {
	Writes     uint64
	WriteBytes uint64
	Reads      uint64
	ReadBytes  uint64
	// contains filtered or unexported fields
}

func NewMetricsBlockStore

func NewMetricsBlockStore(underlying cbor.IpldBlockstore) *MetricsBlockStore

func (*MetricsBlockStore) Get

func (ms *MetricsBlockStore) Get(ctx context.Context, c cid.Cid) (block.Block, error)

func (*MetricsBlockStore) Put

func (ms *MetricsBlockStore) Put(ctx context.Context, b block.Block) error

func (*MetricsBlockStore) ReadCount

func (ms *MetricsBlockStore) ReadCount() uint64

func (*MetricsBlockStore) ReadSize

func (ms *MetricsBlockStore) ReadSize() uint64

func (*MetricsBlockStore) WriteCount

func (ms *MetricsBlockStore) WriteCount() uint64

func (*MetricsBlockStore) WriteSize

func (ms *MetricsBlockStore) WriteSize() uint64

type SyncBlockStoreInMemory

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

func NewSyncBlockStoreInMemory

func NewSyncBlockStoreInMemory() *SyncBlockStoreInMemory

func (*SyncBlockStoreInMemory) Get

func (ss *SyncBlockStoreInMemory) Get(ctx context.Context, c cid.Cid) (block.Block, error)

func (*SyncBlockStoreInMemory) Put

func (ss *SyncBlockStoreInMemory) Put(ctx context.Context, b block.Block) error