committer

Documentation

Index

• Constants
• func Drivers() []string
• func Register(name string, driver driver.Driver)
• type ChaincodeEvent
  • func (chaincodeEvent *ChaincodeEvent) Message() interface{}
  • func (chaincodeEvent *ChaincodeEvent) Topic() string
• type Committer
  • func New(channel string, network Network, finality Finality, ...) (*Committer, error)
  • func (c *Committer) Commit(block *common.Block) error
  • func (c *Committer) CommitEndorserTransaction(txID string, block *common.Block, indexInBlock int, env *common.Envelope, ...) (bool, error)
  • func (c *Committer) DiscardEndorserTransaction(txID string, block *common.Block, event *TxEvent, ...) error
  • func (c *Committer) GetChaincodeEvents(env *common.Envelope, block *common.Block) error
  • func (c *Committer) HandleConfig(block *common.Block, i int, event *TxEvent, env *common.Envelope, ...) error
  • func (c *Committer) HandleEndorserTransaction(block *common.Block, i int, event *TxEvent, env *common.Envelope, ...) error
  • func (c *Committer) IsFinal(ctx context.Context, txID string) error
  • func (c *Committer) Notify(event TxEvent)
• type ExternalCommitter
  • func GetExternalCommitter(name string, sp view2.ServiceProvider, vault driver.Vault) (*ExternalCommitter, error)
  • func (c *ExternalCommitter) CommitTX(txid string, block uint64, indexInBloc int) error
  • func (c *ExternalCommitter) DiscardTX(txid string) error
  • func (c *ExternalCommitter) Status(txid string) (fdriver.ValidationCode, []string, []view.Identity, error)
  • func (c *ExternalCommitter) Validate(txid string) (fdriver.ValidationCode, error)
• type Finality
• type Network
• type TransactionHandler
• type TxEvent
• type ValidationFlags

Constants

const (
	ConfigTXPrefix = "configtx_"
)

Functions

func Drivers

func Drivers() []string

Drivers returns a sorted list of the names of the registered drivers.

func Register

func Register(name string, driver driver.Driver)

Register makes a kvs driver available by the provided name. If Register is called twice with the same name or if driver is nil, it panics.

Types

type ChaincodeEvent

type ChaincodeEvent struct {
	BlockNumber   uint64
	TransactionID string
	ChaincodeID   string
	EventName     string
	Payload       []byte
}

ChaincodeEvent models the chaincode event details.

func (*ChaincodeEvent) Message

func (chaincodeEvent *ChaincodeEvent) Message() interface{}

func (*ChaincodeEvent) Topic

func (chaincodeEvent *ChaincodeEvent) Topic() string

type Committer

type Committer struct {
	Channel             string
	Network             Network
	Finality            Finality
	WaitForEventTimeout time.Duration
	Tracer              tracing.Tracer
	Handlers            map[common.HeaderType]TransactionHandler
	QuietNotifier       bool
	// contains filtered or unexported fields
}

func New

func New(channel string, network Network, finality Finality, waitForEventTimeout time.Duration, quiet bool, metrics tracing.Tracer, publisher events.Publisher) (*Committer, error)

func (*Committer) Commit

func (c *Committer) Commit(block *common.Block) error

Commit commits the transactions in the block passed as argument

func (*Committer) CommitEndorserTransaction

func (c *Committer) CommitEndorserTransaction(txID string, block *common.Block, indexInBlock int, env *common.Envelope, event *TxEvent) (bool, error)

CommitEndorserTransaction commits the transaction to the vault. It returns true, if the transaction was already processed, false otherwise.

func (*Committer) DiscardEndorserTransaction

func (c *Committer) DiscardEndorserTransaction(txID string, block *common.Block, event *TxEvent, validationCode pb.TxValidationCode) error

DiscardEndorserTransaction discards the transaction from the vault

func (*Committer) GetChaincodeEvents

func (c *Committer) GetChaincodeEvents(env *common.Envelope, block *common.Block) error

GetChaincodeEvents reads the chaincode events and notifies the listeners registered to the specific chaincode.

func (*Committer) HandleConfig

func (c *Committer) HandleConfig(block *common.Block, i int, event *TxEvent, env *common.Envelope, chHdr *common.ChannelHeader) error

func (*Committer) HandleEndorserTransaction

func (c *Committer) HandleEndorserTransaction(block *common.Block, i int, event *TxEvent, env *common.Envelope, chHdr *common.ChannelHeader) error

func (*Committer) IsFinal

func (c *Committer) IsFinal(ctx context.Context, txID string) error

IsFinal takes in input a transaction id and waits for its confirmation with the respect to the passed context that can be used to set a deadline for the waiting time.

func (*Committer) Notify

func (c *Committer) Notify(event TxEvent)

type ExternalCommitter

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

func GetExternalCommitter

func GetExternalCommitter(name string, sp view2.ServiceProvider, vault driver.Vault) (*ExternalCommitter, error)

func (*ExternalCommitter) CommitTX

func (c *ExternalCommitter) CommitTX(txid string, block uint64, indexInBloc int) error

func (*ExternalCommitter) DiscardTX

func (c *ExternalCommitter) DiscardTX(txid string) error

func (*ExternalCommitter) Status

func (c *ExternalCommitter) Status(txid string) (fdriver.ValidationCode, []string, []view.Identity, error)

func (*ExternalCommitter) Validate

func (c *ExternalCommitter) Validate(txid string) (fdriver.ValidationCode, error)

type Finality

type Finality interface {
	IsFinal(txID string, address string) error
}

type Network

type Network interface {
	Committer(channel string) (driver.Committer, error)
	Channel(channel string) (driver.Channel, error)
	PickPeer(funcType driver.PeerFunctionType) *grpc.ConnectionConfig
	Ledger(channel string) (driver.Ledger, error)
}

type TransactionHandler

type TransactionHandler = func(block *common.Block, i int, event *TxEvent, env *common.Envelope, chHdr *common.ChannelHeader) error

type TxEvent

type TxEvent struct {
	Txid           string
	DependantTxIDs []string
	Committed      bool
	Block          uint64
	IndexInBlock   int
	CommitPeer     string
	Err            error
}

TxEvent contains information for token transaction commit

type ValidationFlags

type ValidationFlags []uint8