ledgermgmt

Documentation

Index

• Variables
• func InitializeExistingTestEnvWithInitializer(initializer *Initializer) (cleanup func(), err error)
• func InitializeTestEnv(t *testing.T) (cleanup func())
• func InitializeTestEnvWithInitializer(initializer *Initializer) (cleanup func(), err error)
• type Initializer
• type LedgerMgr
  • func NewLedgerMgr(initializer *Initializer) *LedgerMgr
  • func (m *LedgerMgr) Close()
  • func (m *LedgerMgr) CreateLedger(id string, genesisBlock *common.Block) (ledger.PeerLedger, error)
  • func (m *LedgerMgr) GetLedgerIDs() ([]string, error)
  • func (m *LedgerMgr) OpenLedger(id string) (ledger.PeerLedger, error)

Variables

var ErrLedgerAlreadyOpened = errors.New("ledger already opened")

var ErrLedgerMgmtNotInitialized = errors.New("ledger mgmt should be initialized before using")

Functions

func InitializeExistingTestEnvWithInitializer

func InitializeExistingTestEnvWithInitializer(initializer *Initializer) (cleanup func(), err error)

func InitializeTestEnv

func InitializeTestEnv(t *testing.T) (cleanup func())

func InitializeTestEnvWithInitializer

func InitializeTestEnvWithInitializer(initializer *Initializer) (cleanup func(), err error)

Types

type Initializer

type Initializer struct {
	CustomTxProcessors              map[common.HeaderType]ledger.CustomTxProcessor
	StateListeners                  []ledger.StateListener
	DeployedChaincodeInfoProvider   ledger.DeployedChaincodeInfoProvider
	MembershipInfoProvider          ledger.MembershipInfoProvider
	ChaincodeLifecycleEventProvider ledger.ChaincodeLifecycleEventProvider
	MetricsProvider                 metrics.Provider
	HealthCheckRegistry             ledger.HealthCheckRegistry
	Config                          *ledger.Config
}

type LedgerMgr

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

func NewLedgerMgr

func NewLedgerMgr(initializer *Initializer) *LedgerMgr

func (*LedgerMgr) Close

func (m *LedgerMgr) Close()

func (*LedgerMgr) CreateLedger

func (m *LedgerMgr) CreateLedger(id string, genesisBlock *common.Block) (ledger.PeerLedger, error)

func (*LedgerMgr) GetLedgerIDs

func (m *LedgerMgr) GetLedgerIDs() ([]string, error)

func (*LedgerMgr) OpenLedger

func (m *LedgerMgr) OpenLedger(id string) (ledger.PeerLedger, error)