committer

package
v0.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 16, 2025 License: Apache-2.0 Imports: 31 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	ConfigTXPrefix = "configtx_"
)

Variables

View Source 
var (

	// ErrDiscardTX this error can be used to signal that a valid transaction should be discarded anyway
	ErrDiscardTX = errors.New("discard tx")
)

Functions

func MapValidationCode added in v0.4.0 

func MapValidationCode(code int32) (int, string)

func NewParallelDependencyResolver added in v0.4.0 

func NewParallelDependencyResolver() *parallelDependencyResolver

func NewSerialDependencyResolver added in v0.4.0 

func NewSerialDependencyResolver() *serialDependencyResolver

Types

type ChaincodeEvent 

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

ChaincodeEvent models the chaincode event details.

func (*ChaincodeEvent) Message 

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

func (*ChaincodeEvent) Topic 

func (chaincodeEvent *ChaincodeEvent) Topic() string

type CommitTx added in v0.4.0 

type CommitTx struct {
	BlkNum driver2.BlockNum
	TxNum  driver2.TxNum
	TxID   driver2.TxID
	Type   common.HeaderType

	Raw      []byte
	Envelope *common.Envelope
}

type Committer added in v0.2.0 

type Committer struct {
	ConfigService driver.ConfigService
	ChannelConfig driver.ChannelConfig

	Vault              driver.Vault
	EnvelopeService    driver.EnvelopeService
	TransactionFilters *committer.AggregatedTransactionFilter
	ProcessNamespaces  []string
	Ledger             driver.Ledger
	RWSetLoaderService driver.RWSetLoader
	ProcessorManager   driver.ProcessorManager
	MembershipService  *membership.Service
	OrderingService    OrderingService
	FabricFinality     FabricFinality

	TransactionManager driver.TransactionManager
	DependencyResolver DependencyResolver

	// events
	FinalityManager *FinalityManager
	EventsPublisher events.Publisher

	Handlers      map[common.HeaderType]TransactionHandler
	QuietNotifier bool
	// contains filtered or unexported fields
}

func New 

func New(
	configService driver.ConfigService,
	channelConfig driver.ChannelConfig,
	vault driver.Vault,
	envelopeService driver.EnvelopeService,
	ledger driver.Ledger,
	rwsetLoaderService driver.RWSetLoader,
	processorManager driver.ProcessorManager,
	eventsPublisher events.Publisher,
	channelMembershipService *membership.Service,
	orderingService OrderingService,
	fabricFinality FabricFinality,
	transactionManager driver.TransactionManager,
	dependencyResolver DependencyResolver,
	quiet bool,
	listenerManager driver.ListenerManager,
	tracerProvider tracing.Provider,
	metricsProvider metrics.Provider,
) *Committer

func (*Committer) AddFinalityListener added in v0.4.0 

func (c *Committer) AddFinalityListener(txID string, listener driver.FinalityListener) error

func (*Committer) AddTransactionFilter added in v0.4.0 

func (c *Committer) AddTransactionFilter(sr driver.TransactionFilter) error

func (*Committer) Commit added in v0.2.0 

func (c *Committer) Commit(ctx context.Context, block *common.Block) error

Commit commits the transactions in the block passed as argument

func (*Committer) CommitConfig added in v0.4.0 

func (c *Committer) CommitConfig(ctx context.Context, blockNumber driver2.BlockNum, raw []byte, env *common.Envelope) error

CommitConfig is used to validate and apply configuration transactions for a Channel.

func (*Committer) CommitEndorserTransaction added in v0.2.0 

func (c *Committer) CommitEndorserTransaction(ctx context.Context, txID string, blockNum driver2.BlockNum, indexInBlock uint64, env *common.Envelope, event *FinalityEvent) (bool, error)

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

func (*Committer) CommitTX added in v0.4.0 

func (c *Committer) CommitTX(ctx context.Context, txID string, block driver.BlockNum, indexInBlock driver.TxNum, envelope *common.Envelope) (err error)

func (*Committer) DiscardEndorserTransaction added in v0.2.0 

func (c *Committer) DiscardEndorserTransaction(ctx context.Context, txID string, blockNum driver2.BlockNum, envRaw []byte, event *FinalityEvent) error

DiscardEndorserTransaction discards the transaction from the vault

func (*Committer) DiscardTx added in v0.4.0 

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

func (*Committer) GetChaincodeEvents added in v0.3.0 

func (c *Committer) GetChaincodeEvents(env *common.Envelope, blockNum driver2.BlockNum) error

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

func (*Committer) GetProcessNamespace added in v0.4.0 

func (c *Committer) GetProcessNamespace() []string

func (*Committer) HandleConfig added in v0.3.0 

func (c *Committer) HandleConfig(ctx context.Context, block *common.BlockMetadata, tx CommitTx) (*FinalityEvent, error)

func (*Committer) HandleEndorserTransaction added in v0.3.0 

func (c *Committer) HandleEndorserTransaction(ctx context.Context, block *common.BlockMetadata, tx CommitTx) (*FinalityEvent, error)

func (*Committer) IsFinal added in v0.2.0 

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) ProcessNamespace added in v0.4.0 

func (c *Committer) ProcessNamespace(nss ...string) error

func (*Committer) ReloadConfigTransactions added in v0.4.0 

func (c *Committer) ReloadConfigTransactions() error

func (*Committer) RemoveFinalityListener added in v0.4.0 

func (c *Committer) RemoveFinalityListener(txID string, listener driver.FinalityListener) error

func (*Committer) Start added in v0.4.0 

func (c *Committer) Start(context context.Context) error

func (*Committer) Status added in v0.4.0 

func (c *Committer) Status(ctx context.Context, txID driver2.TxID) (driver.ValidationCode, string, error)

type DependencyResolver added in v0.4.0 

type DependencyResolver interface {
	// Resolve returns a two-dimensional array that indicates how commits can be parallelized.
	// The transactions in each SerialExecutable slice have to follow the order indicated.
	// Each slice of the ParallelExecutable slice can be committed independently without waiting on the others.
	// Hence, for each element of the ParallelExecutable slice, a new goroutine can be launched.
	Resolve([]CommitTx) ParallelExecutable[SerialExecutable[CommitTx]]
}

DependencyResolver analyzes the dependencies between the transactions of a block and indicates which commits can take place in parallel and which have to take place serially

type FabricFinality added in v0.4.0 

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

type FinalityEvent added in v0.4.0 

type FinalityEvent = driver2.FinalityEvent[driver.ValidationCode]

func MapFinalityEvent added in v0.4.0 

func MapFinalityEvent(ctx context.Context, block *common.BlockMetadata, txNum driver.TxNum, txID string) (uint8, *FinalityEvent, error)

type FinalityManager added in v0.4.0 

type FinalityManager = committer.FinalityManager[driver.ValidationCode]

type Metrics 

type Metrics struct {
	NotifyStatusDuration   metrics.Histogram
	NotifyFinalityDuration metrics.Histogram
	PostFinalityDuration   metrics.Histogram
	HandlerDuration        metrics.Histogram
	EventQueueDuration     metrics.Histogram
	BlockCommitDuration    metrics.Histogram
	EventQueueLength       metrics.Gauge

	Commits trace.Tracer
	Listens trace.Tracer
}

func NewMetrics added in v0.4.0 

func NewMetrics(p tracing.Provider, m metrics.Provider) *Metrics

type OrderingService added in v0.4.0 

type OrderingService interface {
	Configure(consensusType string, orderers []*grpc.ConnectionConfig) error
}

type ParallelExecutable added in v0.4.0 

type ParallelExecutable[V any] []V

ParallelExecutable is a marker type for processes that can take place in parallel

type SerialExecutable added in v0.4.0 

type SerialExecutable[V any] []V

SerialExecutable is a marker type for processes that must take place serially

type TransactionHandler added in v0.3.0 

type TransactionHandler = func(ctx context.Context, block *common.BlockMetadata, tx CommitTx) (*FinalityEvent, error)

type ValidationFlags 

type ValidationFlags []uint8

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.