generic

Documentation

Index

• Constants
• func NewEndpointResolver(resolver Resolver, es EndpointService) (*endpointResolver, error)
• func NewNetwork(sp view2.ServiceProvider, name string, config *config2.Config, ...) (*network, error)
• type Block
  • func (b *Block) DataAt(i int) []byte
  • func (b *Block) ProcessedTransaction(i int) (driver.ProcessedTransaction, error)
• type Delivery
• type EndpointService
• type MSPManager
• type Resolver
• type SerializableSigner
• type SigService
  • func NewSigService(sp view2.ServiceProvider) *SigService
  • func (s *SigService) GetSigner(id view.Identity) (driver.Signer, error)
  • func (s *SigService) GetSigningIdentity(id view.Identity) (driver.SigningIdentity, error)
  • func (s *SigService) GetVerifier(id view.Identity) (driver.Verifier, error)
  • func (s *SigService) RegisterSigner(identity view.Identity, signer driver.Signer, verifier driver.Verifier) error
• type TXIDStore
  • func NewVault(sp view2.ServiceProvider, config *config.Config, channel string) (*vault.Vault, TXIDStore, error)
• type TxEventsListener
  • func (l *TxEventsListener) OnReceive(event events.Event)
• type ValidationFlags

Constants

const (
	GetBlockByNumber   string = "GetBlockByNumber"
	GetTransactionByID string = "GetTransactionByID"
	GetBlockByTxID     string = "GetBlockByTxID"
	DefaultNumRetries         = 3
	DefaultRetrySleep         = 1 * time.Second
)

These are function names from Invoke first parameter

Functions

func NewEndpointResolver

func NewEndpointResolver(resolver Resolver, es EndpointService) (*endpointResolver, error)

func NewNetwork

func NewNetwork(
	sp view2.ServiceProvider,
	name string,
	config *config2.Config,
	idProvider driver.IdentityProvider,
	localMembership driver.LocalMembership,
	sigService driver.SignerService,
) (*network, error)

Types

type Block

type Block struct {
	*common.Block
}

Block wraps a Fabric block

func (*Block) DataAt

func (b *Block) DataAt(i int) []byte

DataAt returns the data stored at the passed index

func (*Block) ProcessedTransaction

func (b *Block) ProcessedTransaction(i int) (driver.ProcessedTransaction, error)

ProcessedTransaction returns the ProcessedTransaction at passed index

type Delivery

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

type EndpointService

type EndpointService interface {
	GetIdentity(label string, pkiID []byte) (view.Identity, error)
}

type MSPManager

type MSPManager interface {
	DeserializeIdentity(serializedIdentity []byte) (msp.Identity, error)
}

type Resolver

type Resolver interface {
	// GetIdentity returns the identity associated to the passed label
	GetIdentity(label string) view.Identity
}

type SerializableSigner

type SerializableSigner interface {
	Sign(message []byte) ([]byte, error)

	Serialize() ([]byte, error)
}

type SigService

type SigService struct {
	// contains filtered or unexported fields
}

func NewSigService

func NewSigService(sp view2.ServiceProvider) *SigService

func (*SigService) GetSigner

func (s *SigService) GetSigner(id view.Identity) (driver.Signer, error)

func (*SigService) GetSigningIdentity

func (s *SigService) GetSigningIdentity(id view.Identity) (driver.SigningIdentity, error)

func (*SigService) GetVerifier

func (s *SigService) GetVerifier(id view.Identity) (driver.Verifier, error)

func (*SigService) RegisterSigner

func (s *SigService) RegisterSigner(identity view.Identity, signer driver.Signer, verifier driver.Verifier) error

type TXIDStore

type TXIDStore interface {
	fdriver.TXIDStore
	Get(txid string) (fdriver.ValidationCode, error)
	Set(txid string, code fdriver.ValidationCode) error
}

func NewVault

func NewVault(sp view2.ServiceProvider, config *config.Config, channel string) (*vault.Vault, TXIDStore, error)

type TxEventsListener

type TxEventsListener struct {
	// contains filtered or unexported fields
}

func (*TxEventsListener) OnReceive

func (l *TxEventsListener) OnReceive(event events.Event)

type ValidationFlags

type ValidationFlags []uint8