generic

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2025 License: Apache-2.0 Imports: 25 Imported by: 0

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(
	kvss *kvs.KVS,
	publisher events.Publisher,
	hasher hash.Hasher,
	tracerProvider trace.TracerProvider,
	metricsProvider metrics.Provider,
	drivers []driver2.NamedDriver,
	newVault VaultConstructor,
	channelConfigProvider driver.ChannelConfigProvider,
	listenerManagerProvider driver.ListenerManagerProvider,
	dependencyResolver committer.DependencyResolver,
	newLedger LedgerConstructor,
	newRWSetLoader RWSetLoaderConstructor,
	newCommitter CommitterConstructor,
	useFilteredDelivery bool,
) *provider

Types

type Channel added in v0.3.0 

type Channel struct {
	ChannelConfig            driver.ChannelConfig
	ConfigService            driver.ConfigService
	ChannelName              string
	FinalityService          driver.Finality
	VaultService             driver.Vault
	TXIDStoreService         driver.TXIDStore
	ES                       driver.EnvelopeService
	TS                       driver.EndorserTransactionService
	MS                       driver.MetadataService
	DeliveryService          *delivery.Service
	RWSetLoaderService       driver.RWSetLoader
	LedgerService            driver.Ledger
	ChannelMembershipService *membership.Service
	ChaincodeManagerService  driver.ChaincodeManager
	CommitterService         CommitterService
	PeerService              *services.ClientFactory
}

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

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

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

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,
	channelConfig driver.ChannelConfig,
	vault driver.Vault,
	envelopeService driver.EnvelopeService,
	ledger driver.Ledger,
	rwsetLoaderService driver.RWSetLoader,
	eventsPublisher events.Publisher,
	channelMembershipService *membership.Service,
	fabricFinality committer.FabricFinality,
	dependencyResolver committer.DependencyResolver,
	quiet bool,
	listenerManager driver.ListenerManager,
	tracerProvider trace.TracerProvider,
	metricsProvider metrics.Provider,
) (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 Delivery 

type Delivery interface {
	Start(ctx context.Context)
	Stop()
}

type LedgerConstructor added in v0.4.0 

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

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

type VaultConstructor = func(
	configService driver.ConfigService,
	channel string,
	drivers []driver2.NamedDriver,
	metricsProvider metrics.Provider,
	tracerProvider trace.TracerProvider,
) (*vault.Vault, driver.TXIDStore, 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
txidstore

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.