committer

package

v0.1.0 Latest Latest Go to latest Published: Nov 16, 2022 License: Apache-2.0 Imports: 18 Imported by: 5

Documentation ¶

Index ¶

Constants
func Drivers() []string
func New(channel string, network Network, finality Finality, ...) (*committer, error)
func Register(name string, driver driver.Driver)
type ChaincodeEvent
- func (chaincodeEvent *ChaincodeEvent) Message() interface{}
- func (chaincodeEvent *ChaincodeEvent) Topic() string
type ExternalCommitter
- func GetExternalCommitter(name string, sp view2.ServiceProvider, vault driver.Vault) (*ExternalCommitter, error)
type Finality
type Metrics
type Network
type TxEvent
type ValidationFlags

Constants ¶

const (
	ConfigTXPrefix = "configtx_"
)

Variables ¶

This section is empty.

Functions ¶

func Drivers ¶

func Drivers() []string

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

func New ¶

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

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 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 Metrics ¶

type Metrics interface {
	EmitKey(val float32, event ...string)
}

type Network ¶

type Network interface {
	Committer(channel string) (driver.Committer, error)
	PickPeer() *grpc.ConnectionConfig
	Ledger(channel string) (driver.Ledger, 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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
driver

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL