storeprovider

Documentation

Index

• type StoreProvider
  • func New(gossipProvider collcommon.GossipProvider, ...) *StoreProvider
  • func (sp *StoreProvider) Close()
  • func (sp *StoreProvider) OpenStore(channelID string) (api.Store, error)
  • func (sp *StoreProvider) StoreForChannel(channelID string) api.Store

Types

type StoreProvider

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

StoreProvider is a transient data store provider

func New

func New(gossipProvider collcommon.GossipProvider, idProvider collcommon.IdentityDeserializerProvider) *StoreProvider

New returns a new transient data store provider

func (*StoreProvider) Close

func (sp *StoreProvider) Close()

Close shuts down all of the stores

func (*StoreProvider) OpenStore

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

OpenStore opens the transient data store for the given channel

func (*StoreProvider) StoreForChannel

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

StoreForChannel returns the transient data store for the given channel