multichannel

Documentation

Index

• func ConfigBlock(reader blockledger.Reader) *cb.Block
• type BlockWriter
  • func (bw *BlockWriter) CreateNextBlock(messages []*cb.Envelope) *cb.Block
  • func (bw *BlockWriter) WriteBlock(block *cb.Block, encodedMetadataValue []byte)
  • func (bw *BlockWriter) WriteConfigBlock(block *cb.Block, encodedMetadataValue []byte)
• type ChainSupport
  • func (cs *ChainSupport) Append(block *cb.Block) error
  • func (cs *ChainSupport) Block(number uint64) *cb.Block
  • func (cs *ChainSupport) BlockCutter() blockcutter.Receiver
  • func (cs *ChainSupport) ChannelID() string
  • func (cs *ChainSupport) ConfigProto() *cb.Config
  • func (cs *ChainSupport) ProposeConfigUpdate(configtx *cb.Envelope) (*cb.ConfigEnvelope, error)
  • func (cs *ChainSupport) Reader() blockledger.Reader
  • func (cs *ChainSupport) Sequence() uint64
  • func (cs *ChainSupport) Signer() identity.SignerSerializer
  • func (cs *ChainSupport) Validate(configEnv *cb.ConfigEnvelope) error
  • func (cs *ChainSupport) VerifyBlockSignature(sd []*protoutil.SignedData, envelope *cb.ConfigEnvelope) error
• type Registrar
  • func NewRegistrar(config localconfig.TopLevel, ledgerFactory blockledger.Factory, ...) *Registrar
  • func (r *Registrar) BroadcastChannelSupport(msg *cb.Envelope) (*cb.ChannelHeader, bool, *ChainSupport, error)
  • func (r *Registrar) ChannelsCount() int
  • func (r *Registrar) CreateBundle(channelID string, config *cb.Config) (channelconfig.Resources, error)
  • func (r *Registrar) CreateChain(chainName string)
  • func (r *Registrar) GetChain(chainID string) *ChainSupport
  • func (r *Registrar) Initialize(consenters map[string]consensus.Consenter)
  • func (r *Registrar) NewChannelConfig(envConfigUpdate *cb.Envelope) (channelconfig.Resources, error)
  • func (r *Registrar) SystemChannelID() string

Functions

func ConfigBlock

func ConfigBlock(reader blockledger.Reader) *cb.Block

Types

type BlockWriter

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

func (*BlockWriter) CreateNextBlock

func (bw *BlockWriter) CreateNextBlock(messages []*cb.Envelope) *cb.Block

func (*BlockWriter) WriteBlock

func (bw *BlockWriter) WriteBlock(block *cb.Block, encodedMetadataValue []byte)

func (*BlockWriter) WriteConfigBlock

func (bw *BlockWriter) WriteConfigBlock(block *cb.Block, encodedMetadataValue []byte)

type ChainSupport

type ChainSupport struct {
	msgprocessor.Processor
	*BlockWriter
	consensus.Chain

	identity.SignerSerializer

	consensus.MetadataValidator
	// contains filtered or unexported fields
}

func (*ChainSupport) Append

func (cs *ChainSupport) Append(block *cb.Block) error

func (*ChainSupport) Block

func (cs *ChainSupport) Block(number uint64) *cb.Block

func (*ChainSupport) BlockCutter

func (cs *ChainSupport) BlockCutter() blockcutter.Receiver

func (*ChainSupport) ChannelID

func (cs *ChainSupport) ChannelID() string

func (*ChainSupport) ConfigProto

func (cs *ChainSupport) ConfigProto() *cb.Config

func (*ChainSupport) ProposeConfigUpdate

func (cs *ChainSupport) ProposeConfigUpdate(configtx *cb.Envelope) (*cb.ConfigEnvelope, error)

func (*ChainSupport) Reader

func (cs *ChainSupport) Reader() blockledger.Reader

func (*ChainSupport) Sequence

func (cs *ChainSupport) Sequence() uint64

func (*ChainSupport) Signer

func (cs *ChainSupport) Signer() identity.SignerSerializer

func (*ChainSupport) Validate

func (cs *ChainSupport) Validate(configEnv *cb.ConfigEnvelope) error

func (*ChainSupport) VerifyBlockSignature

func (cs *ChainSupport) VerifyBlockSignature(sd []*protoutil.SignedData, envelope *cb.ConfigEnvelope) error

type Registrar

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

func NewRegistrar

func NewRegistrar(
	config localconfig.TopLevel,
	ledgerFactory blockledger.Factory,
	signer identity.SignerSerializer,
	metricsProvider metrics.Provider,
	callbacks ...channelconfig.BundleActor,
) *Registrar

func (*Registrar) BroadcastChannelSupport

func (r *Registrar) BroadcastChannelSupport(msg *cb.Envelope) (*cb.ChannelHeader, bool, *ChainSupport, error)

func (*Registrar) ChannelsCount

func (r *Registrar) ChannelsCount() int

func (*Registrar) CreateBundle

func (r *Registrar) CreateBundle(channelID string, config *cb.Config) (channelconfig.Resources, error)

func (*Registrar) CreateChain

func (r *Registrar) CreateChain(chainName string)

func (*Registrar) GetChain

func (r *Registrar) GetChain(chainID string) *ChainSupport

func (*Registrar) Initialize

func (r *Registrar) Initialize(consenters map[string]consensus.Consenter)

func (*Registrar) NewChannelConfig

func (r *Registrar) NewChannelConfig(envConfigUpdate *cb.Envelope) (channelconfig.Resources, error)

func (*Registrar) SystemChannelID

func (r *Registrar) SystemChannelID() string