generic

package
v0.5.0 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: 22 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewChannelConfigProvider added in v0.4.0 

func NewChannelConfigProvider(nsp config.Provider) driver.ChannelConfigProvider

func NewChannelProvider added in v0.4.0 

func NewChannelProvider(
	configProvider config.Provider,
	envelopeKVS driver.EnvelopeStore,
	metadataKVS driver.MetadataStore,
	endorserTxKVS driver.EndorseTxStore,
	hasher hash.Hasher,
	drivers multiplexed.Driver,
	newVault VaultConstructor,
	channelConfigProvider driver.ChannelConfigProvider,
	newLedger LedgerConstructor,
	newRWSetLoader RWSetLoaderConstructor,
	newCommitter CommitterConstructor,
	newDelivery DeliveryConstructor,
	newMembership MembershipConstructor,
	useFilteredDelivery bool,
) *provider

Types

type Channel added in v0.3.0 

type Channel struct {
	ChannelName              string
	FinalityService          driver.Finality
	VaultService             driver.Vault
	VaultStoreService        driver.VaultStore
	ES                       driver.EnvelopeService
	TS                       driver.EndorserTransactionService
	MS                       driver.MetadataService
	DeliveryService          DeliveryService
	RWSetLoaderService       driver.RWSetLoader
	LedgerService            driver.Ledger
	ChannelMembershipService driver.ChannelMembership
	ChaincodeManagerService  driver.ChaincodeManager
	CommitterService         CommitterService
}

func (*Channel) ChaincodeManager added in v0.4.0 

func (c *Channel) ChaincodeManager() driver.ChaincodeManager

func (*Channel) ChannelMembership added in v0.4.0 

func (c *Channel) ChannelMembership() driver.ChannelMembership

func (*Channel) Close added in v0.3.0 

func (c *Channel) Close() error

func (*Channel) Committer added in v0.4.0 

func (c *Channel) Committer() driver.Committer

func (*Channel) Delivery added in v0.4.0 

func (c *Channel) Delivery() driver.Delivery

func (*Channel) EnvelopeService added in v0.3.0 

func (c *Channel) EnvelopeService() driver.EnvelopeService

func (*Channel) Finality added in v0.3.0 

func (c *Channel) Finality() driver.Finality

func (*Channel) Init added in v0.3.0 

func (c *Channel) Init() error

func (*Channel) Ledger added in v0.4.0 

func (c *Channel) Ledger() driver.Ledger

func (*Channel) MetadataService added in v0.3.0 

func (c *Channel) MetadataService() driver.MetadataService

func (*Channel) Name added in v0.3.0 

func (c *Channel) Name() string

func (*Channel) RWSetLoader added in v0.3.0 

func (c *Channel) RWSetLoader() driver.RWSetLoader

func (*Channel) TransactionService added in v0.3.0 

func (c *Channel) TransactionService() driver.EndorserTransactionService

func (*Channel) Vault added in v0.3.0 

func (c *Channel) Vault() driver.Vault

func (*Channel) VaultStore added in v0.4.1 

func (c *Channel) VaultStore() driver.VaultStore

type ChannelProvider added in v0.4.0 

type ChannelProvider interface {
	NewChannel(nw driver.FabricNetworkService, name string, quiet bool) (driver.Channel, error)
}

type CommitterConstructor added in v0.4.0 

type CommitterConstructor func(
	nw driver.FabricNetworkService,
	channel string,
	vault driver.Vault,
	envelopeService driver.EnvelopeService,
	ledger driver.Ledger,
	rwsetLoaderService driver.RWSetLoader,
	channelMembershipService driver.MembershipService,
	fabricFinality committer.FabricFinality,
	quiet bool,
) (CommitterService, error)

type CommitterService added in v0.4.0 

type CommitterService interface {
	driver.Finality
	driver.Committer
	ReloadConfigTransactions() error
	Commit(ctx context.Context, block *common.Block) error
}

type DeliveryConstructor added in v0.4.1 

type DeliveryConstructor func(
	nw driver.FabricNetworkService,
	channel string,
	peerManager delivery.Services,
	ledger driver.Ledger,
	vault delivery.Vault,
	callback driver.BlockCallback,
) (DeliveryService, error)

type DeliveryService added in v0.4.1 

type DeliveryService interface {
	driver.Delivery
	StoppableService
}

type LedgerConstructor added in v0.4.0 

type LedgerConstructor func(
	channelName string,
	nw driver.FabricNetworkService,
	chaincodeManager driver.ChaincodeManager,
) (driver.Ledger, error)

type MembershipConstructor added in v0.5.0 

type MembershipConstructor func(channelName string) driver.MembershipService

type Network added in v0.3.0 

type Network struct {
	ConsensusType string
	Ordering      driver.Ordering

	Metrics *metrics.Metrics

	NewChannel   NewChannelFunc
	ChannelMap   map[string]driver.Channel
	ChannelMutex sync.RWMutex
	// contains filtered or unexported fields
}

func NewNetwork 

func NewNetwork(
	name string,
	config driver.ConfigService,
	idProvider driver.IdentityProvider,
	localMembership driver.LocalMembership,
	sigService driver.SignerService,
	metrics *metrics.Metrics,
	newChannel NewChannelFunc,
) (*Network, error)

func (*Network) Channel added in v0.3.0 

func (f *Network) Channel(name string) (driver.Channel, error)

func (*Network) Committer added in v0.3.0 

func (f *Network) Committer(name string) (driver.Committer, error)

func (*Network) ConfigService added in v0.3.0 

func (f *Network) ConfigService() driver.ConfigService

func (*Network) Driver added in v0.4.0 

func (f *Network) Driver() string

func (*Network) IdentityProvider added in v0.3.0 

func (f *Network) IdentityProvider() driver.IdentityProvider

func (*Network) Init added in v0.3.0 

func (f *Network) Init() error

func (*Network) Ledger added in v0.3.0 

func (f *Network) Ledger(name string) (driver.Ledger, error)

func (*Network) LocalMembership added in v0.3.0 

func (f *Network) LocalMembership() driver.LocalMembership

func (*Network) Name added in v0.3.0 

func (f *Network) Name() string

func (*Network) OrderingService added in v0.4.0 

func (f *Network) OrderingService() driver.Ordering

func (*Network) ProcessorManager added in v0.3.0 

func (f *Network) ProcessorManager() driver.ProcessorManager

func (*Network) SetProcessorManager added in v0.4.0 

func (f *Network) SetProcessorManager(pm driver.ProcessorManager)

func (*Network) SetTransactionManager added in v0.4.0 

func (f *Network) SetTransactionManager(tm driver.TransactionManager)

func (*Network) SignerService added in v0.3.0 

func (f *Network) SignerService() driver.SignerService

func (*Network) TransactionManager added in v0.3.0 

func (f *Network) TransactionManager() driver.TransactionManager

type NewChannelFunc added in v0.3.0 

type NewChannelFunc = func(network driver.FabricNetworkService, name string, quiet bool) (driver.Channel, error)

type OrdererClientFactory added in v0.4.0 

type OrdererClientFactory struct {
	*services.ClientFactory
}

func (*OrdererClientFactory) NewOrdererClient added in v0.4.0 

func (o *OrdererClientFactory) NewOrdererClient(cc grpc.ConnectionConfig) (ordering.Client, error)

type RWSetLoaderConstructor added in v0.4.0 

type RWSetLoaderConstructor func(
	channel string,
	nw driver.FabricNetworkService,
	envelopeService driver.EnvelopeService,
	transactionService driver.EndorserTransactionService,
	vault driver.RWSetInspector,
) (driver.RWSetLoader, error)

type StoppableService added in v0.4.1 

type StoppableService interface {
	Stop()
}

type VaultConstructor added in v0.4.0 

type VaultConstructor = func(
	channelName string,
	configService driver.ConfigService,
	vaultStore driver3.VaultStore,
) (*vault.Vault, error)

Source Files

View all Source files

Directories

Path Synopsis
config
identity
msp
driver
driver/mock
Code generated by counterfeiter.
 Code generated by counterfeiter.
idemix
x509
x509/pkcs11

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.