common

Documentation

Index

• Constants
• func ConstructQueryResponse(resultsIterator shim.StateQueryIteratorInterface, collection string, ...) ([]byte, error)
• func ExtractCompositeKeys(stub shim.ChaincodeStubInterface, compositeKeyDefs map[string][]string, ...) []string
• func GetActivityInputSchema(ctx activity.Context, name string) (string, error)
• func GetActivityOutputSchema(ctx activity.Context, name string) (string, error)
• func GetChaincodeStub(ctx activity.Context) (shim.ChaincodeStubInterface, error)
• func ResolveFlowData(toResolve string, context activity.Context) (value interface{}, err error)
• func SetChaincodeLogLevel(logger *shim.ChaincodeLogger)
• type ParameterIndex
  • func OrderedParameters(schemaData []byte) ([]ParameterIndex, error)

Constants

const (
	// KeyField attribute used in query response of key-value pairs
	KeyField = "key"
	// ValueField attribute used in query response of key-value pairs
	ValueField = "value"
	// FabricStub is the name of flow property for passing chaincode stub to activities
	FabricStub = "_chaincode_stub"
)

Functions

func ConstructQueryResponse

func ConstructQueryResponse(resultsIterator shim.StateQueryIteratorInterface, collection string, isCompositeKey bool, stub shim.ChaincodeStubInterface) ([]byte, error)

ConstructQueryResponse iterate through query result to create array of key-value pairs, i.e. JSON string of format [{"key":"mykey", "value":{}}, ...]

func ExtractCompositeKeys

func ExtractCompositeKeys(stub shim.ChaincodeStubInterface, compositeKeyDefs map[string][]string, keyValue string, value interface{}) []string

ExtractCompositeKeys collects all valid composite-keys matching composite-key definitions using fields of a value object

func GetActivityInputSchema

func GetActivityInputSchema(ctx activity.Context, name string) (string, error)

GetActivityInputSchema returns schema of an activity input attribute

func GetActivityOutputSchema

func GetActivityOutputSchema(ctx activity.Context, name string) (string, error)

GetActivityOutputSchema returns schema of an activity output attribute

func GetChaincodeStub

func GetChaincodeStub(ctx activity.Context) (shim.ChaincodeStubInterface, error)

GetChaincodeStub returns Fabric chaincode stub from the activity context

func ResolveFlowData

func ResolveFlowData(toResolve string, context activity.Context) (value interface{}, err error)

ResolveFlowData resolves and returns data from the flow's context, unmarshals JSON string to map[string]interface{}. The name to Resolve is a valid output attribute of a flogo activity, e.g., `activity[app_16].value` or `$.content`, which is shown in normal flogo mapper as, e.g., "$.content"

func SetChaincodeLogLevel

func SetChaincodeLogLevel(logger *shim.ChaincodeLogger)

SetChaincodeLogLevel sets log level of a chaincode logger according to env 'CORE_CHAINCODE_LOGGING_LEVEL'

Types

type ParameterIndex

type ParameterIndex struct {
	Name     string
	JSONType string
	// contains filtered or unexported fields
}

ParameterIndex stores transaction parameters and its location in raw JSON schema string start and end location is used to sort the parameter list to match the parameter order in schema

func OrderedParameters

func OrderedParameters(schemaData []byte) ([]ParameterIndex, error)

OrderedParameters returns parameters of a JSON schema object sorted by their position in schema definition This is necessary because Golang JSON parser does not maintain the sequence of object parameters.