fabric

Documentation

Index

• Constants
• type Fabric
  • func (f *Fabric) AddSubscription(ctx context.Context, subscription *fftypes.ContractSubscriptionInput) error
  • func (f *Fabric) Capabilities() *blockchain.Capabilities
  • func (f *Fabric) DeleteSubscription(ctx context.Context, subscription *fftypes.ContractSubscription) error
  • func (f *Fabric) GenerateFFI(ctx context.Context, generationRequest *fftypes.FFIGenerationRequest) (*fftypes.FFI, error)
  • func (f *Fabric) GetFFIParamValidator(ctx context.Context) (fftypes.FFIParamValidator, error)
  • func (f *Fabric) Init(ctx context.Context, prefix config.Prefix, callbacks blockchain.Callbacks) (err error)
  • func (f *Fabric) InitPrefix(prefix config.Prefix)
  • func (f *Fabric) InvokeContract(ctx context.Context, operationID *fftypes.UUID, signingKey string, ...) error
  • func (f *Fabric) Name() string
  • func (f *Fabric) QueryContract(ctx context.Context, location *fftypes.JSONAny, method *fftypes.FFIMethod, ...) (interface{}, error)
  • func (f *Fabric) ResolveSigningKey(ctx context.Context, signingKeyInput string) (string, error)
  • func (f *Fabric) Start() error
  • func (f *Fabric) SubmitBatchPin(ctx context.Context, operationID *fftypes.UUID, ledgerID *fftypes.UUID, ...) error
  • func (f *Fabric) ValidateContractLocation(ctx context.Context, location *fftypes.JSONAny) (err error)
• type Location
• type PayloadSchema
• type PrefixItem

Constants

const (
	// FabconnectConfigKey is a sub-key in the config to contain all the ethconnect specific config,
	FabconnectConfigKey = "fabconnect"

	// FabconnectConfigDefaultChannel is the default Fabric channel to use if no "ledger" is specified in requests
	FabconnectConfigDefaultChannel = "channel"
	// FabconnectConfigChaincode is the Fabric Firefly chaincode deployed to the Firefly channels
	FabconnectConfigChaincode = "chaincode"
	// FabconnectConfigSigner is the signer identity used to subscribe to FireFly chaincode events
	FabconnectConfigSigner = "signer"
	// FabconnectConfigTopic is the websocket listen topic that the node should register on, which is important if there are multiple
	// nodes using a single fabconnect
	FabconnectConfigTopic = "topic"
	// FabconnectConfigBatchSize is the batch size to configure on event streams, when auto-defining them
	FabconnectConfigBatchSize = "batchSize"
	// FabconnectConfigBatchTimeout is the batch timeout to configure on event streams, when auto-defining them
	FabconnectConfigBatchTimeout = "batchTimeout"
	// FabconnectPrefixShort is used in the query string in requests to ethconnect
	FabconnectPrefixShort = "prefixShort"
	// FabconnectPrefixLong is used in HTTP headers in requests to ethconnect
	FabconnectPrefixLong = "prefixLong"
)

Types

type Fabric

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

func (*Fabric) AddSubscription

func (f *Fabric) AddSubscription(ctx context.Context, subscription *fftypes.ContractSubscriptionInput) error

func (*Fabric) Capabilities

func (f *Fabric) Capabilities() *blockchain.Capabilities

func (*Fabric) DeleteSubscription

func (f *Fabric) DeleteSubscription(ctx context.Context, subscription *fftypes.ContractSubscription) error

func (*Fabric) GenerateFFI

func (f *Fabric) GenerateFFI(ctx context.Context, generationRequest *fftypes.FFIGenerationRequest) (*fftypes.FFI, error)

func (*Fabric) GetFFIParamValidator

func (f *Fabric) GetFFIParamValidator(ctx context.Context) (fftypes.FFIParamValidator, error)

func (*Fabric) Init

func (f *Fabric) Init(ctx context.Context, prefix config.Prefix, callbacks blockchain.Callbacks) (err error)

func (*Fabric) InitPrefix

func (f *Fabric) InitPrefix(prefix config.Prefix)

func (*Fabric) InvokeContract

func (f *Fabric) InvokeContract(ctx context.Context, operationID *fftypes.UUID, signingKey string, location *fftypes.JSONAny, method *fftypes.FFIMethod, input map[string]interface{}) error

func (*Fabric) Name

func (f *Fabric) Name() string

func (*Fabric) QueryContract

func (f *Fabric) QueryContract(ctx context.Context, location *fftypes.JSONAny, method *fftypes.FFIMethod, input map[string]interface{}) (interface{}, error)

func (*Fabric) ResolveSigningKey

func (f *Fabric) ResolveSigningKey(ctx context.Context, signingKeyInput string) (string, error)

func (*Fabric) Start

func (f *Fabric) Start() error

func (*Fabric) SubmitBatchPin

func (f *Fabric) SubmitBatchPin(ctx context.Context, operationID *fftypes.UUID, ledgerID *fftypes.UUID, signingKey string, batch *blockchain.BatchPin) error

func (*Fabric) ValidateContractLocation

func (f *Fabric) ValidateContractLocation(ctx context.Context, location *fftypes.JSONAny) (err error)

type Location

type Location struct {
	Channel   string `json:"channel"`
	Chaincode string `json:"chaincode"`
}

type PayloadSchema

type PayloadSchema struct {
	Type        string        `json:"type"`
	PrefixItems []*PrefixItem `json:"prefixItems"`
}

type PrefixItem

type PrefixItem struct {
	Name string `json:"name"`
	Type string `json:"type"`
}