TestBlock is a test block
var TestBlock = &po.DeliverResponse{ Type: &po.DeliverResponse_Block{ Block: &common.Block{ Data: &common.BlockData{ Data: [][]byte{[]byte("test")}, }, }, }, }
func CreateBlockWithCCEvent(events *pp.ChaincodeEvent, txID string, channelID string) (*common.Block, error)
CreateBlockWithCCEvent creates a mock block
func CreateBlockWithCCEventAndTxStatus(events *pp.ChaincodeEvent, txID string, channelID string, txValidationCode pp.TxValidationCode) (*common.Block, error)
CreateBlockWithCCEventAndTxStatus creates a mock block with the given CC event and TX validation code
func NewMockCAClient(orgName string, cryptoProvider core.CryptoSuite) (api.CAClient, error)
NewMockCAClient Constructor for a CA client.
func NewMockCryptoConfig() core.CryptoSuiteConfig
NewMockCryptoConfig ...
func NewMockCryptoConfigCustomized(tlsEnabled, mutualTLSEnabled, errorCase bool) core.CryptoSuiteConfig
NewMockCryptoConfigCustomized ...
func NewMockEndpointConfig() fab.EndpointConfig
NewMockEndpointConfig ...
func NewMockEndpointConfigCustomized(tlsEnabled, mutualTLSEnabled, errorCase bool) fab.EndpointConfig
NewMockEndpointConfigCustomized ...
func NewMockIdentity(err error) (msp.Identity, error)
NewMockIdentity creates new mock identity
func NewMockIdentityConfig() msp.IdentityConfig
NewMockIdentityConfig ...
func NewMockIdentityConfigCustomized(tlsEnabled, mutualTLSEnabled, errorCase bool) msp.IdentityConfig
NewMockIdentityConfigCustomized ...
func NewMockIdentityManager(opts ...UsersOption) msp.IdentityManager
NewMockIdentityManager Constructor for a identity manager.
func NewMockSigningIdentity() (msp.SigningIdentity, error)
NewMockSigningIdentity ...
func NewMockTransactionHeader(channelID string) (fab.TransactionHeader, error)
NewMockTransactionHeader creates mock TxnID based on mock user.
func NewRwSet(ccID string) *rwsetutil.NsRwSet
NewRwSet returns a new read-write set for the given chaincode
func NewSimpleMockBlock() *common.Block
NewSimpleMockBlock returns a simple mock block
func NewSimpleMockError() error
NewSimpleMockError returns a error
Channel supplies the configuration for channel context client
type Channel struct {
context.Client
// contains filtered or unexported fields
}
func NewMockChannel(channelID string) (*Channel, error)
NewMockChannel creates new mock channel
func (c *Channel) ChannelID() string
ChannelID returns channel ID
func (c *Channel) ChannelService() fab.ChannelService
ChannelService returns channel service
func (c *Channel) Providers() context.Client
Providers returns core providers
LocalContext supplies the configuration for channel context client
type LocalContext struct {
*MockContext
// contains filtered or unexported fields
}
func NewMockLocalContext(client *MockContext, discoveryProvider fab.LocalDiscoveryProvider) *LocalContext
NewMockLocalContext creates new mock local context
func (c *LocalContext) LocalDiscoveryService() fab.DiscoveryService
LocalDiscoveryService returns the local discovery service
MockBroadcastServer mock broadcast server
type MockBroadcastServer struct {
DeliverError error
BroadcastError error
Creds credentials.TransportCredentials
DeliverResponse *po.DeliverResponse
BroadcastCustomResponse *po.BroadcastResponse
BroadcastInternalServerError bool
// Use the MockBroadCastServer with either a common.Block or a pb.FilteredBlock channel (do not set both)
Deliveries chan *common.Block
FilteredDeliveries chan *pb.FilteredBlock
// contains filtered or unexported fields
}
func (m *MockBroadcastServer) Broadcast(server po.AtomicBroadcast_BroadcastServer) error
Broadcast mock broadcast
func (m *MockBroadcastServer) Deliver(server po.AtomicBroadcast_DeliverServer) error
Deliver mock deliver
func (m *MockBroadcastServer) Start(address string) string
Start the mock broadcast server
func (m *MockBroadcastServer) Stop()
Stop the mock broadcast server and wait for completion.
MockCAClient is a mock CAClient
type MockCAClient struct {
}
func (mgr *MockCAClient) AddAffiliation(request *api.AffiliationRequest) (*api.AffiliationResponse, error)
AddAffiliation add affiliation
func (mgr *MockCAClient) CreateIdentity(request *api.IdentityRequest) (*api.IdentityResponse, error)
CreateIdentity creates an identity
func (mgr *MockCAClient) Enroll(request *api.EnrollmentRequest) error
Enroll enrolls a user with a Fabric network
func (mgr *MockCAClient) GetAffiliation(affiliation, caname string) (*api.AffiliationResponse, error)
GetAffiliation get an affiliation
func (mgr *MockCAClient) GetAllAffiliations(caname string) (*api.AffiliationResponse, error)
GetAllAffiliations get all affiliations
func (mgr *MockCAClient) GetAllIdentities(caname string) ([]*api.IdentityResponse, error)
GetAllIdentities returns all identities that the caller is authorized to see
func (mgr *MockCAClient) GetCAInfo() (*api.GetCAInfoResponse, error)
GetCAInfo returns generic CA information
func (mgr *MockCAClient) GetIdentity(id, caname string) (*api.IdentityResponse, error)
GetIdentity returns an identity by id
func (mgr *MockCAClient) ModifyAffiliation(request *api.ModifyAffiliationRequest) (*api.AffiliationResponse, error)
ModifyAffiliation update an affiliation
func (mgr *MockCAClient) ModifyIdentity(request *api.IdentityRequest) (*api.IdentityResponse, error)
ModifyIdentity updates identity
func (mgr *MockCAClient) Reenroll(request *api.ReenrollmentRequest) error
Reenroll re-enrolls a user
func (mgr *MockCAClient) Register(request *api.RegistrationRequest) (string, error)
Register registers a user with a Fabric network
func (mgr *MockCAClient) RemoveAffiliation(request *api.AffiliationRequest) (*api.AffiliationResponse, error)
RemoveAffiliation remove an affiliation
func (mgr *MockCAClient) RemoveIdentity(request *api.RemoveIdentityRequest) (*api.IdentityResponse, error)
RemoveIdentity removes identity
func (mgr *MockCAClient) Revoke(request *api.RevocationRequest) (*api.RevocationResponse, error)
Revoke revokes a user
MockChannelCfg contains mock channel configuration
type MockChannelCfg struct {
MockID string
MockBlockNumber uint64
MockMSPs []*msp.MSPConfig
MockAnchorPeers []*fab.OrgAnchorPeer
MockOrderers []string
MockVersions *fab.Versions
MockMembership fab.ChannelMembership
MockCapabilities map[fab.ConfigGroupKey]map[string]bool
}
func NewMockChannelCfg(id string) *MockChannelCfg
NewMockChannelCfg ...
func (cfg *MockChannelCfg) AnchorPeers() []*fab.OrgAnchorPeer
AnchorPeers returns anchor peers
func (cfg *MockChannelCfg) BlockNumber() uint64
BlockNumber returns block number
func (cfg *MockChannelCfg) HasCapability(group fab.ConfigGroupKey, capability string) bool
HasCapability indicates whether or not the given group has the given capability
func (cfg *MockChannelCfg) ID() string
ID returns name
func (cfg *MockChannelCfg) MSPs() []*msp.MSPConfig
MSPs returns msps
func (cfg *MockChannelCfg) Orderers() []string
Orderers returns orderers
func (cfg *MockChannelCfg) Versions() *fab.Versions
Versions returns versions
MockChannelConfig mockcore query channel configuration
type MockChannelConfig struct {
// contains filtered or unexported fields
}
func NewMockChannelConfig(ctx context.Client, channelID string) (*MockChannelConfig, error)
NewMockChannelConfig mockcore channel config implementation
func (c *MockChannelConfig) Query(reqCtx reqContext.Context) (fab.ChannelCfg, error)
Query mockcore query for channel configuration
MockChannelContext holds the client context plus channel-specific entities
type MockChannelContext struct {
*MockContext
Channel fab.ChannelService
// contains filtered or unexported fields
}
func NewMockChannelContext(context *MockContext, channelID string) *MockChannelContext
NewMockChannelContext returns a new MockChannelContext
func (c *MockChannelContext) ChannelID() string
ChannelID returns the channel ID
func (c *MockChannelContext) ChannelService() fab.ChannelService
ChannelService returns the ChannelService
func (c *MockChannelContext) GetMetrics() *metrics.ClientMetrics
GetMetrics not used in this mockcontext
MockChannelProvider holds a mock channel provider.
type MockChannelProvider struct {
// contains filtered or unexported fields
}
func NewMockChannelProvider(ctx core.Providers) (*MockChannelProvider, error)
NewMockChannelProvider returns a mock ChannelProvider
func (cp *MockChannelProvider) ChannelService(ctx fab.ClientContext, channelID string) (fab.ChannelService, error)
ChannelService returns a mock ChannelService
func (cp *MockChannelProvider) SetCustomChannelService(customChannelService fab.ChannelService)
SetCustomChannelService sets custom channel service for unit-test purposes
MockChannelService holds a mock channel service.
type MockChannelService struct {
// contains filtered or unexported fields
}
func (cs *MockChannelService) ChannelConfig() (fab.ChannelCfg, error)
ChannelConfig returns channel config
func (cs *MockChannelService) Config() (fab.ChannelConfig, error)
Config ...
func (cs *MockChannelService) Discovery() (fab.DiscoveryService, error)
Discovery returns a mock DiscoveryService
func (cs *MockChannelService) EventService(opts ...options.Opt) (fab.EventService, error)
EventService returns a mock event service
func (cs *MockChannelService) Membership() (fab.ChannelMembership, error)
Membership returns member identification
func (cs *MockChannelService) Selection() (fab.SelectionService, error)
Selection returns a mock SelectionService
func (cs *MockChannelService) SetCustomMembership(customMembership fab.ChannelMembership)
SetCustomMembership sets custom channel membership for unit-test purposes
func (cs *MockChannelService) SetDiscovery(discovery fab.DiscoveryService)
SetDiscovery sets the mock DiscoveryService
func (cs *MockChannelService) SetOrderers(orderers []string)
SetOrderers sets orderes to mock channel service for unit-test purposes
func (cs *MockChannelService) SetSelection(selection fab.SelectionService)
SetSelection sets the mock SelectionService
func (cs *MockChannelService) SetTransactor(t fab.Transactor)
SetTransactor changes the return value of Transactor
func (cs *MockChannelService) Transactor(reqCtx reqContext.Context) (fab.Transactor, error)
Transactor returns a mock transactor
MockConfig ...
type MockConfig struct {
CustomTLSCACertPool fab.CertPool
// contains filtered or unexported fields
}
func (c *MockConfig) CAClientCert(org string) ([]byte, bool)
CAClientCert Read configuration option for the fabric CA client cert for given org
func (c *MockConfig) CAClientKey(org string) ([]byte, bool)
CAClientKey Read configuration option for the fabric CA client key for given org
func (c *MockConfig) CAConfig(org string) (*msp.CAConfig, bool)
CAConfig not implemented
func (c *MockConfig) CAKeyStorePath() string
CAKeyStorePath not implemented
func (c *MockConfig) CAServerCerts(org string) ([][]byte, bool)
CAServerCerts Read configuration option for the server certificates for given org
func (c *MockConfig) ChannelConfig(channelID string) *fab.ChannelEndpointConfig
ChannelConfig returns the channel configuration
func (c *MockConfig) ChannelOrderers(name string) []fab.OrdererConfig
ChannelOrderers returns a list of channel orderers
func (c *MockConfig) ChannelPeers(name string) []fab.ChannelPeer
ChannelPeers returns the channel peers configuration
func (c *MockConfig) Client() *msp.ClientConfig
Client ...
func (c *MockConfig) CredentialStorePath() string
CredentialStorePath ...
func (c *MockConfig) CryptoConfigPath() string
CryptoConfigPath ...
func (c *MockConfig) IsSecurityEnabled() bool
IsSecurityEnabled ...
func (c *MockConfig) KeyStorePath() string
KeyStorePath ...
func (c *MockConfig) Lookup(key string) (interface{}, bool)
Lookup gets the Value from config file by Key
func (c *MockConfig) NetworkConfig() *fab.NetworkConfig
NetworkConfig not implemented
func (c *MockConfig) NetworkPeers() []fab.NetworkPeer
NetworkPeers returns the mock network peers configuration
func (c *MockConfig) OrdererConfig(name string) (*fab.OrdererConfig, bool)
OrdererConfig not implemented
func (c *MockConfig) OrderersConfig() []fab.OrdererConfig
OrderersConfig returns a list of defined orderers
func (c *MockConfig) PeerConfig(nameOrURL string) (*fab.PeerConfig, bool)
PeerConfig Retrieves a specific peer from the configuration by org and name
func (c *MockConfig) PeersConfig(org string) ([]fab.PeerConfig, bool)
PeersConfig Retrieves the fabric peers from the config file provided
func (c *MockConfig) SecurityAlgorithm() string
SecurityAlgorithm ...
func (c *MockConfig) SecurityLevel() int
SecurityLevel ...
func (c *MockConfig) SecurityProvider() string
SecurityProvider ...
func (c *MockConfig) SecurityProviderLabel() string
SecurityProviderLabel ...
func (c *MockConfig) SecurityProviderLibPath() string
SecurityProviderLibPath will be set only if provider is PKCS11
func (c *MockConfig) SecurityProviderPin() string
SecurityProviderPin ...
func (c *MockConfig) SetCustomChannelConfig(channelID string, config *fab.ChannelEndpointConfig)
SetCustomChannelConfig sets the config for the given channel
func (c *MockConfig) SetCustomNetworkPeerCfg(customNetworkPeerCfg []fab.NetworkPeer)
SetCustomNetworkPeerCfg sets custom orderer config for unit-tests
func (c *MockConfig) SetCustomOrdererCfg(customOrdererCfg *fab.OrdererConfig)
SetCustomOrdererCfg sets custom orderer config for unit-tests
func (c *MockConfig) SetCustomPeerCfg(customPeerCfg *fab.PeerConfig)
SetCustomPeerCfg sets custom orderer config for unit-tests
func (c *MockConfig) SetCustomRandomOrdererCfg(customRandomOrdererCfg *fab.OrdererConfig)
SetCustomRandomOrdererCfg sets custom random orderer config for unit-tests
func (c *MockConfig) SoftVerify() bool
SoftVerify flag
func (c *MockConfig) TLSCACertPool() fab.CertPool
TLSCACertPool ...
func (c *MockConfig) TLSClientCerts() []tls.Certificate
TLSClientCerts ...
func (c *MockConfig) TcertBatchSize() int
TcertBatchSize ...
func (c *MockConfig) Timeout(arg fab.TimeoutType) time.Duration
Timeout not implemented
MockConfigBlockBuilder is used to build a mock Chain configuration block
type MockConfigBlockBuilder struct {
MockConfigGroupBuilder
Index uint64
LastConfigIndex uint64
}
func (b *MockConfigBlockBuilder) Build() *common.Block
Build creates a mock Chain configuration Block
MockConfigGroupBuilder is used to build a mock ConfigGroup
type MockConfigGroupBuilder struct {
Version uint64
ModPolicy string
OrdererAddress string
MSPNames []string
RootCA string
Groups map[string]*common.ConfigGroup
ChannelCapabilities []string
ApplicationCapabilities []string
OrdererCapabilities []string
}
MockConfigUpdateEnvelopeBuilder builds a mock ConfigUpdateEnvelope
type MockConfigUpdateEnvelopeBuilder struct {
MockConfigGroupBuilder
ChannelID string
}
func (b *MockConfigUpdateEnvelopeBuilder) Build() *common.Envelope
Build builds an Envelope that contains a mock ConfigUpdateEnvelope
func (b *MockConfigUpdateEnvelopeBuilder) BuildBytes() []byte
BuildBytes builds an Envelope that contains a mock ConfigUpdateEnvelope and returns the marshaled bytes
func (b *MockConfigUpdateEnvelopeBuilder) BuildConfigUpdateBytes() []byte
BuildConfigUpdateBytes builds an mock ConfigUpdate returns the marshaled bytes
MockContext holds core providers and identity to enable mocking.
type MockContext struct {
*MockProviderContext
SigningIdentity msp.SigningIdentity
}
func NewMockContext(si msp.SigningIdentity) *MockContext
NewMockContext creates a MockContext consisting of defaults and an identity
func (m MockContext) EnrollmentCertificate() []byte
EnrollmentCertificate Returns the underlying ECert representing this user’s identity.
func (m MockContext) Identifier() *msp.IdentityIdentifier
Identifier returns the identifier of that identity
func (m MockContext) PrivateKey() core.Key
PrivateKey returns the crypto suite representation of the private key
func (m MockContext) PublicVersion() msp.Identity
PublicVersion returns the public parts of this identity
func (m MockContext) Serialize() ([]byte, error)
Serialize converts an identity to bytes
func (m MockContext) Sign(msg []byte) ([]byte, error)
Sign the message
func (m MockContext) Verify(msg []byte, sig []byte) error
Verify a signature over some message using this identity as reference
MockCryptoSuite implementation
type MockCryptoSuite struct {
}
func (m *MockCryptoSuite) GetHash(opts core.HashOpts) (hash.Hash, error)
GetHash mock get hash
func (m *MockCryptoSuite) GetKey(ski []byte) (k core.Key, err error)
GetKey mock get key
func (m *MockCryptoSuite) Hash(msg []byte, opts core.HashOpts) (hash []byte, err error)
Hash mock hash
func (m *MockCryptoSuite) KeyGen(opts core.KeyGenOpts) (k core.Key, err error)
KeyGen mock key gen
func (m *MockCryptoSuite) KeyImport(raw interface{}, opts core.KeyImportOpts) (k core.Key, err error)
KeyImport mock key import
func (m *MockCryptoSuite) Sign(k core.Key, digest []byte, opts core.SignerOpts) (signature []byte, err error)
Sign mock signing
func (m *MockCryptoSuite) Verify(k core.Key, signature, digest []byte, opts core.SignerOpts) (valid bool, err error)
Verify mock verify implementation
MockEndorserServer mock endoreser server to process endorsement proposals
type MockEndorserServer struct {
Creds credentials.TransportCredentials
ProposalError error
AddkvWrite bool
// contains filtered or unexported fields
}
func (m *MockEndorserServer) ProcessProposal(context context.Context, proposal *pb.SignedProposal) (*pb.ProposalResponse, error)
ProcessProposal mock implementation that returns success if error is not set error if it is
func (m *MockEndorserServer) Start(address string) string
Start the mock broadcast server
func (m *MockEndorserServer) Stop()
Stop the mock broadcast server and wait for completion.
MockEventService implements a mock event service
type MockEventService struct {
TxStatusRegCh chan *dispatcher.TxStatusReg
TxValidationCode pb.TxValidationCode
Timeout bool
}
func NewMockEventService() *MockEventService
NewMockEventService returns a new mock event service
func (m *MockEventService) RegisterBlockEvent(filter ...fab.BlockFilter) (fab.Registration, <-chan *fab.BlockEvent, error)
RegisterBlockEvent registers for block events.
func (m *MockEventService) RegisterChaincodeEvent(ccID, eventFilter string) (fab.Registration, <-chan *fab.CCEvent, error)
RegisterChaincodeEvent registers for chaincode events.
func (m *MockEventService) RegisterFilteredBlockEvent() (fab.Registration, <-chan *fab.FilteredBlockEvent, error)
RegisterFilteredBlockEvent registers for filtered block events.
func (m *MockEventService) RegisterTxStatusEvent(txID string) (fab.Registration, <-chan *fab.TxStatusEvent, error)
RegisterTxStatusEvent registers for transaction status events.
func (m *MockEventService) Unregister(reg fab.Registration)
Unregister removes the given registration.
MockGrpcOrderer is a mock fabricclient.Orderer to test connectivity to the orderer. It only wraps a GRPC server. Note that calling broadcast doesn't deliver anythng. This implies that the broadcast side and the deliver side are totally independent from the mocking point of view.
type MockGrpcOrderer struct {
Creds credentials.TransportCredentials
OrdererURL string
// contains filtered or unexported fields
}
func NewMockGrpcOrderer(url string, tls credentials.TransportCredentials) *MockGrpcOrderer
NewMockGrpcOrderer will create a new instance for the given url and TLS credentials (optional)
func (o *MockGrpcOrderer) SendBroadcast(ctx reqContext.Context, envelope *fab.SignedEnvelope) (*common.Status, error)
SendBroadcast accepts client broadcast calls and attempts connection to the grpc server it does not attempt to broadcast the envelope, it only tries to connect to the server
func (o *MockGrpcOrderer) SendDeliver(ctx reqContext.Context, envelope *fab.SignedEnvelope) (chan *common.Block, chan error)
SendDeliver is not used and can be implemented for special GRPC connectivity in the future
func (o *MockGrpcOrderer) Start() string
Start with start the underlying GRPC server for this MockGrpcOrderer it updates the OrdererUrl with the address returned by the GRPC server
func (o *MockGrpcOrderer) Stop()
Stop the mock broadcast server and wait for completion.
func (o *MockGrpcOrderer) URL() string
URL returns the URL of the mock GRPC Orderer
MockIdentity implements identity
type MockIdentity struct {
Err error
}
func (id *MockIdentity) Anonymous() bool
Anonymous ...
func (id *MockIdentity) ExpiresAt() time.Time
ExpiresAt returns the time at which the Identity expires.
func (id *MockIdentity) GetIdentifier() *msp.IdentityIdentifier
GetIdentifier returns the identifier (MSPID/IDID) for this instance
func (id *MockIdentity) GetMSPIdentifier() string
GetMSPIdentifier returns the MSP identifier for this instance
func (id *MockIdentity) GetOrganizationalUnits() []*msp.OUIdentifier
GetOrganizationalUnits returns the OU for this instance
func (id *MockIdentity) SatisfiesPrincipal(principal *msp_protos.MSPPrincipal) error
SatisfiesPrincipal returns null if this instance matches the supplied principal or an error otherwise
func (id *MockIdentity) Serialize() ([]byte, error)
Serialize returns a byte array representation of this identity
func (id *MockIdentity) Validate() error
Validate returns nil if this instance is a valid identity or an error otherwise
func (id *MockIdentity) Verify(msg []byte, sig []byte) error
Verify checks against a signature and a message to determine whether this identity produced the signature; it returns nil if so or an error otherwise
MockIdentityManager is a mock IdentityManager
type MockIdentityManager struct {
// contains filtered or unexported fields
}
func (mgr *MockIdentityManager) CreateSigningIdentity(opts ...msp.SigningIdentityOption) (msp.SigningIdentity, error)
CreateSigningIdentity creates a signing identity with the given options
func (mgr *MockIdentityManager) GetSigningIdentity(id string) (msp.SigningIdentity, error)
GetSigningIdentity will return an identity that can be used to cryptographically sign an object
MockInfraProvider represents the default implementation of Fabric objects.
type MockInfraProvider struct {
// contains filtered or unexported fields
}
func (f *MockInfraProvider) Close()
Close mock close function
func (f *MockInfraProvider) CommManager() fab.CommManager
CommManager returns comm provider
func (f *MockInfraProvider) CreateChannelCfg(ctx fab.ClientContext, name string) (fab.ChannelCfg, error)
CreateChannelCfg creates the channel configuration
func (f *MockInfraProvider) CreateChannelConfig(channelID string) (fab.ChannelConfig, error)
CreateChannelConfig initializes the channel config
func (f *MockInfraProvider) CreateChannelMembership(ctx fab.ClientContext, channel string) (fab.ChannelMembership, error)
CreateChannelMembership returns a channel member identifier
func (f *MockInfraProvider) CreateEventService(ic fab.ClientContext, channelID string, opts ...options.Opt) (fab.EventService, error)
CreateEventService creates the event service.
func (f *MockInfraProvider) CreateOrdererFromConfig(cfg *fab.OrdererConfig) (fab.Orderer, error)
CreateOrdererFromConfig creates a default implementation of Orderer based on configuration.
func (f *MockInfraProvider) CreatePeerFromConfig(peerCfg *fab.NetworkPeer) (fab.Peer, error)
CreatePeerFromConfig returns a new default implementation of Peer based configuration
func (f *MockInfraProvider) SetCustomOrderer(customOrderer fab.Orderer)
SetCustomOrderer creates a default implementation of Orderer based on configuration.
MockMSP implements mock msp
type MockMSP struct {
Err error
}
func NewMockMSP(err error) *MockMSP
NewMockMSP creates mock msp
func (m *MockMSP) DeserializeIdentity(serializedIdentity []byte) (msp.Identity, error)
DeserializeIdentity mockcore deserialize identity
func (m *MockMSP) GetDefaultSigningIdentity() (msp.SigningIdentity, error)
GetDefaultSigningIdentity returns the default signing identity
func (m *MockMSP) GetIdentifier() (string, error)
GetIdentifier returns the provider identifier
func (m *MockMSP) GetMSPs() (map[string]msp.MSP, error)
GetMSPs Provides a list of Membership Service providers
func (m *MockMSP) GetSigningIdentity(identifier *msp.IdentityIdentifier) (msp.SigningIdentity, error)
GetSigningIdentity returns a signing identity corresponding to the provided identifier
func (m *MockMSP) GetTLSIntermediateCerts() [][]byte
GetTLSIntermediateCerts returns the TLS intermediate root certificates for this MSP
func (m *MockMSP) GetTLSRootCerts() [][]byte
GetTLSRootCerts returns the TLS root certificates for this MSP
func (m *MockMSP) GetType() msp.ProviderType
GetType returns the provider type
func (m *MockMSP) GetVersion() msp.MSPVersion
GetVersion returns the version of this MSP
func (m *MockMSP) IsWellFormed(identity *msp_protos.SerializedIdentity) error
IsWellFormed checks if the given identity can be deserialized into its provider-specific form
func (m *MockMSP) SatisfiesPrincipal(id msp.Identity, principal *msp_protos.MSPPrincipal) error
SatisfiesPrincipal checks whether the identity matches the description supplied in MSPPrincipal.
func (m *MockMSP) Setup(config *msp_protos.MSPConfig) error
Setup the MSP instance according to configuration information
func (m *MockMSP) Validate(id msp.Identity) error
Validate checks whether the supplied identity is valid
MockMSPManager implements mock msp manager
type MockMSPManager struct {
MSPs map[string]msp.MSP
Err error
}
func NewMockMSPManager(msps map[string]msp.MSP) *MockMSPManager
NewMockMSPManager mockcore msp manager
func NewMockMSPManagerWithError(msps map[string]msp.MSP, err error) *MockMSPManager
NewMockMSPManagerWithError mockcore msp manager
func (mgr *MockMSPManager) DeserializeIdentity(serializedIdentity []byte) (msp.Identity, error)
DeserializeIdentity mockcore deserialize identity
func (mgr *MockMSPManager) GetMSPs() (map[string]msp.MSP, error)
GetMSPs Provides a list of Membership Service providers
func (mgr *MockMSPManager) IsWellFormed(identity *msp_protos.SerializedIdentity) error
IsWellFormed checks if the given identity can be deserialized into its provider-specific form
func (mgr *MockMSPManager) Setup(msps []msp.MSP) error
Setup the MSP manager instance according to configuration information
MockMembership mock member id
type MockMembership struct {
ValidateErr error
VerifyErr error
// contains filtered or unexported fields
}
func NewMockMembership() *MockMembership
NewMockMembership new mock member id
func NewMockMembershipWithMSPFilter(mspsToBeExlcluded []string) *MockMembership
NewMockMembershipWithMSPFilter return new mock membership where given MSPs will be excluded for ContainsMSP test
func (m *MockMembership) ContainsMSP(msp string) bool
ContainsMSP mocks membership.ContainsMSP
func (m *MockMembership) Validate(serializedID []byte) error
Validate if the given ID was issued by the channel's members
func (m *MockMembership) Verify(serializedID []byte, msg []byte, sig []byte) error
Verify the given signature
MockOrderer is a mock fabricclient.Orderer Note that calling broadcast doesn't deliver anythng. This implies that the broadcast side and the deliver side are totally independent from the mocking point of view.
type MockOrderer struct {
OrdererURL string
BroadcastListener chan *fab.SignedEnvelope
BroadcastErrors chan error
Deliveries chan *common.Block
DeliveryErrors chan error
// These queues are used to detach the client, to avoid deadlocks
BroadcastQueue chan *fab.SignedEnvelope
DeliveryQueue chan interface{}
}
func NewMockOrderer(url string, broadcastListener chan *fab.SignedEnvelope) *MockOrderer
NewMockOrderer ...
func (o *MockOrderer) CloseQueue()
CloseQueue ends the mock broadcast and delivery queues
func (o *MockOrderer) EnqueueForSendDeliver(value interface{})
EnqueueForSendDeliver enqueues a mock value (block or error) for delivery
func (o *MockOrderer) EnqueueSendBroadcastError(err error)
EnqueueSendBroadcastError enqueues error
func (o *MockOrderer) SendBroadcast(ctx reqContext.Context, envelope *fab.SignedEnvelope) (*common.Status, error)
SendBroadcast accepts client broadcast calls and reports them to the listener channel Returns the first enqueued error, or nil if there are no enqueued errors
func (o *MockOrderer) SendDeliver(ctx reqContext.Context, envelope *fab.SignedEnvelope) (chan *common.Block, chan error)
SendDeliver returns the channels for delivery of prepared mock values and errors (if any)
func (o *MockOrderer) URL() string
URL returns the URL of the mock Orderer
MockPeer is a mock fabricsdk.Peer.
type MockPeer struct {
RWLock *sync.RWMutex
Error error
MockName string
MockURL string
MockRoles []string
MockCert *pem.Block
Payload []byte
ResponseMessage string
MockMSP string
Status int32
ProcessProposalCalls int
Endorser []byte
ChaincodeID string
RwSets []*rwsetutil.NsRwSet
}
func NewMockPeer(name string, url string) *MockPeer
NewMockPeer creates basic mock peer
func (p *MockPeer) EnrollmentCertificate() *pem.Block
EnrollmentCertificate returns the mock peer's mock enrollment certificate
func (p *MockPeer) MSPID() string
MSPID gets the Peer mspID.
func (p *MockPeer) Name() string
Name returns the mock peer's mock name
func (p *MockPeer) ProcessTransactionProposal(ctx reqContext.Context, tp fab.ProcessProposalRequest) (*fab.TransactionProposalResponse, error)
ProcessTransactionProposal does not send anything anywhere but returns an empty mock ProposalResponse
func (p *MockPeer) Roles() []string
Roles returns the mock peer's mock roles
func (p *MockPeer) SetChaincodeID(ccID string)
SetChaincodeID sets the ID of the chaincode that was invoked. This ID will be set in the ChaincodeAction of the proposal response payload.
func (p *MockPeer) SetEnrollmentCertificate(pem *pem.Block)
SetEnrollmentCertificate sets the mock peer's mock enrollment certificate
func (p *MockPeer) SetMSPID(mspID string)
SetMSPID sets the Peer mspID.
func (p *MockPeer) SetName(name string)
SetName sets the mock peer's mock name
func (p *MockPeer) SetRoles(roles []string)
SetRoles sets the mock peer's mock roles
func (p *MockPeer) SetRwSets(rwSets ...*rwsetutil.NsRwSet)
SetRwSets sets the read-write sets that will be set in the proposal response payload
func (p *MockPeer) URL() string
URL returns the mock peer's mock URL
MockProviderContext holds core providers to enable mocking.
type MockProviderContext struct {
// contains filtered or unexported fields
}
func NewMockProviderContext(userOpts ...ProviderOption) *MockProviderContext
NewMockProviderContext creates a MockProviderContext consisting of defaults
func NewMockProviderContextCustom(cryptoConfig core.CryptoSuiteConfig, endpointConfig fab.EndpointConfig, identityConfig msp.IdentityConfig, cryptoSuite core.CryptoSuite, signer core.SigningManager, userStore msp.UserStore, identityManager map[string]msp.IdentityManager) *MockProviderContext
NewMockProviderContextCustom creates a MockProviderContext consisting of the arguments
func (pc *MockProviderContext) ChannelProvider() fab.ChannelProvider
ChannelProvider returns channel provider
func (pc *MockProviderContext) CryptoSuite() core.CryptoSuite
CryptoSuite returns the mock crypto suite.
func (pc *MockProviderContext) CryptoSuiteConfig() core.CryptoSuiteConfig
CryptoSuiteConfig ...
func (pc *MockProviderContext) EndpointConfig() fab.EndpointConfig
EndpointConfig returns mock end point config
func (pc *MockProviderContext) GetMetrics() *metrics.ClientMetrics
GetMetrics not used in this mockcontext
func (pc *MockProviderContext) IdentityConfig() msp.IdentityConfig
IdentityConfig returns the Identity config
func (pc *MockProviderContext) IdentityManager(orgName string) (msp.IdentityManager, bool)
IdentityManager returns the identity manager
func (pc *MockProviderContext) InfraProvider() fab.InfraProvider
InfraProvider returns fabric provider
func (pc *MockProviderContext) LocalDiscoveryProvider() fab.LocalDiscoveryProvider
LocalDiscoveryProvider returns a local discovery provider
func (pc *MockProviderContext) PrivateKey() core.Key
PrivateKey returns the crypto suite representation of the private key
func (pc *MockProviderContext) PublicVersion() msp.Identity
PublicVersion returns the public parts of this identity
func (pc *MockProviderContext) SetCryptoSuiteConfig(config core.CryptoSuiteConfig)
SetCryptoSuiteConfig sets the mock cryptosuite configuration.
func (pc *MockProviderContext) SetCustomChannelProvider(customChannelProvider fab.ChannelProvider)
SetCustomChannelProvider sets custom channel provider for unit-test purposes
func (pc *MockProviderContext) SetCustomInfraProvider(customInfraProvider fab.InfraProvider)
SetCustomInfraProvider sets custom fabric provider for unit-test purposes
func (pc *MockProviderContext) SetEndpointConfig(config fab.EndpointConfig)
SetEndpointConfig sets the mock endpoint configuration.
func (pc *MockProviderContext) SetIdentityConfig(config msp.IdentityConfig)
SetIdentityConfig sets the mock msp identity configuration.
func (pc *MockProviderContext) Sign(msg []byte) ([]byte, error)
Sign the message
func (pc *MockProviderContext) SigningManager() core.SigningManager
SigningManager returns the mock signing manager.
func (pc *MockProviderContext) UserStore() msp.UserStore
UserStore returns the mock usser store
MockSelectionService implements mock selection service
type MockSelectionService struct {
Error error
Peers []fab.Peer
}
func NewMockSelectionService(err error, peers ...fab.Peer) *MockSelectionService
NewMockSelectionService returns mock selection service
func (ds *MockSelectionService) GetEndorsersForChaincode(chaincodes []*fab.ChaincodeCall, opts ...options.Opt) ([]fab.Peer, error)
GetEndorsersForChaincode mockcore retrieving endorsing peers
MockSigningIdentity ...
type MockSigningIdentity struct {
// we embed everything from a base identity
MockIdentity
// signer corresponds to the object that can produce signatures from this identity
Signer crypto.Signer
}
func (id *MockSigningIdentity) GetPublicVersion() msp.Identity
GetPublicVersion ...
func (id *MockSigningIdentity) Sign(msg []byte) ([]byte, error)
Sign produces a signature over msg, signed by this instance
MockStaticDiscoveryProvider implements mock discovery provider
type MockStaticDiscoveryProvider struct {
Error error
Peers []fab.Peer
// contains filtered or unexported fields
}
func NewMockDiscoveryProvider(err error, peers []fab.Peer) *MockStaticDiscoveryProvider
NewMockDiscoveryProvider returns mock discovery provider
func (dp *MockStaticDiscoveryProvider) CreateLocalDiscoveryService(mspID string) (fab.DiscoveryService, error)
CreateLocalDiscoveryService return local discovery service
func (dp *MockStaticDiscoveryProvider) SetCustomDiscoveryService(customDiscoveryService fab.DiscoveryService)
SetCustomDiscoveryService sets custom discoveryService
MockStaticDiscoveryService implements mock discovery service
type MockStaticDiscoveryService struct {
Error error
Peers []fab.Peer
}
func NewMockDiscoveryService(err error, peers ...fab.Peer) *MockStaticDiscoveryService
NewMockDiscoveryService returns a new MockStaticDiscoveryService
func (ds *MockStaticDiscoveryService) GetPeers() ([]fab.Peer, error)
GetPeers is used to discover eligible peers for chaincode
MockTransactionHeader supplies a transaction ID and metadata.
type MockTransactionHeader struct {
MockID fab.TransactionID
MockCreator []byte
MockNonce []byte
MockChannelID string
}
func (th *MockTransactionHeader) ChannelID() string
ChannelID returns the transaction's target channel identifier.
func (th *MockTransactionHeader) Creator() []byte
Creator returns the transaction creator's identity bytes.
func (th *MockTransactionHeader) Nonce() []byte
Nonce returns the transaction's generated nonce.
func (th *MockTransactionHeader) TransactionID() fab.TransactionID
TransactionID returns the transaction's computed identifier.
MockTransactor provides an implementation of Transactor that exposes all its context.
type MockTransactor struct {
Ctx reqContex.Context
ChannelID string
Orderers []fab.Orderer
}
func (t *MockTransactor) CreateTransaction(request fab.TransactionRequest) (*fab.Transaction, error)
CreateTransaction create a transaction with proposal response.
func (t *MockTransactor) CreateTransactionHeader(opts ...fab.TxnHeaderOpt) (fab.TransactionHeader, error)
CreateTransactionHeader creates a Transaction Header based on the current context.
func (t *MockTransactor) SendTransaction(tx *fab.Transaction) (*fab.TransactionResponse, error)
SendTransaction send a transaction to the chain’s orderer service (one or more orderer endpoints) for consensus and committing to the ledger.
func (t *MockTransactor) SendTransactionProposal(proposal *fab.TransactionProposal, targets []fab.ProposalProcessor) ([]*fab.TransactionProposalResponse, error)
SendTransactionProposal sends a TransactionProposal to the target peers.
ProviderOption describes a functional parameter for the New constructor
type ProviderOption func(*ProviderUsersOptions) error
func WithProviderUser(username string, org string) ProviderOption
WithProviderUser option
ProviderUsersOptions ...
type ProviderUsersOptions struct {
// contains filtered or unexported fields
}
UsersOption describes a functional parameter for the New constructor
type UsersOption func(*UsersOptions) error
func WithUser(username string, org string) UsersOption
WithUser option
func WithUsers(users map[string]msp.SigningIdentity) UsersOption
WithUsers option
UsersOptions holds optional users
type UsersOptions struct {
// contains filtered or unexported fields
}