storeprovider

Documentation

Index

• func NewOffLedgerProvider(identifierProvider collcommon.IdentifierProvider, ...) olapi.StoreProvider
• type StoreProvider
  • func New() *StoreProvider
  • func (sp *StoreProvider) Close()
  • func (sp *StoreProvider) Initialize(tDataProvider tdapi.StoreProvider, olProvider olapi.StoreProvider) *StoreProvider
  • func (sp *StoreProvider) OpenStore(channelID string) (storeapi.Store, error)
  • func (sp *StoreProvider) StoreForChannel(channelID string) storeapi.Store

Functions

func NewOffLedgerProvider

func NewOffLedgerProvider(identifierProvider collcommon.IdentifierProvider, idDProvider collcommon.IdentityDeserializerProvider, collConfigProvider collcommon.CollectionConfigProvider) olapi.StoreProvider

NewOffLedgerProvider creates a new off-ledger store provider that supports DCAS

Types

type StoreProvider

type StoreProvider struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

StoreProvider is a store provider that creates delegating stores. A delegating store delegates requests to collection-specific store. For example, transient data store, Off-ledger store, etc.

func New

func New() *StoreProvider

New returns a new store provider factory

func (*StoreProvider) Close

func (sp *StoreProvider) Close()

Close shuts down all of the stores

func (*StoreProvider) Initialize

func (sp *StoreProvider) Initialize(tDataProvider tdapi.StoreProvider, olProvider olapi.StoreProvider) *StoreProvider

Initialize is called at startup by the resource manager

func (*StoreProvider) OpenStore

func (sp *StoreProvider) OpenStore(channelID string) (storeapi.Store, error)

OpenStore opens the store for the given channel

func (*StoreProvider) StoreForChannel

func (sp *StoreProvider) StoreForChannel(channelID string) storeapi.Store

StoreForChannel returns the store for the given channel