e2e

package

v1.5.0 Latest Latest Go to latest Published: Aug 4, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/hyperledger-firefly/firefly

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func AddNamespace(data map[string]interface{}, ns map[string]interface{})
func AddPluginBroadcastName(data map[string]interface{}, pluginType, broadcastName string)
func ChangeDefaultNSPluginLocalName(data map[string]interface{}, pluginType, newLocalName string)
func GetMemberHostname(filename string, n int) (string, error)
func GetMemberPort(filename string, n int) (int, error)
func PickTopic(i int, options []string) string
func PollForUp(t *testing.T, client *client.FireFlyClient)
func RandomName(t *testing.T) string
func ReadConfig(t *testing.T, configFile string) map[string]interface{}
func ResetFireFly(t *testing.T, client *resty.Client)
func ValidateAccountBalances(t *testing.T, client *client.FireFlyClient, poolID *fftypes.UUID, ...)
func VerifyAllOperationsSucceeded(t *testing.T, clients []*client.FireFlyClient, startTime time.Time)
func VerifyOperationsAlreadyMarkedFailed(t *testing.T, clients []*client.FireFlyClient, startTime time.Time)
func WaitForContractEvent(t *testing.T, client *client.FireFlyClient, c chan *core.EventDelivery, ...) map[string]interface{}
func WaitForEvent(t *testing.T, c chan *core.EventDelivery, eventType core.EventType, ...)
func WaitForIdentityConfirmed(t *testing.T, c chan *core.EventDelivery) *core.EventDelivery
func WaitForMessageConfirmed(t *testing.T, c chan *core.EventDelivery, msgType core.MessageType) *core.EventDelivery
func WaitForMessageRejected(t *testing.T, c chan *core.EventDelivery, msgType core.MessageType) *core.EventDelivery
func WaitForOperationSucceeded(t *testing.T, client *client.FireFlyClient, operationID *fftypes.UUID) *core.Operation
func WriteConfig(t *testing.T, configFile string, data map[string]interface{})
func WsReader(conn *websocket.Conn) chan *core.EventDelivery
type Member
type Stack
- func ReadStack(t *testing.T) *Stack
- func ReadStackFile(filename string) (*Stack, error)
type StackState
- func ReadStackState(t *testing.T) *StackState
- func ReadStackStateFile(filename string) (*StackState, error)
type TestState

Constants ¶

This section is empty.

Variables ¶

View Source

var WidgetSchemaJSON = []byte(`{
	"$id": "https://example.com/widget.schema.json",
	"$schema": "https://json-schema.org/draft/2020-12/schema",
	"title": "Widget",
	"type": "object",
	"properties": {
		"id": {
			"type": "string",
			"description": "The unique identifier for the widget."
		},
		"name": {
			"type": "string",
			"description": "The person's last name."
		}
	},
	"additionalProperties": false
}`)

Functions ¶

func AddNamespace ¶

func AddNamespace(data map[string]interface{}, ns map[string]interface{})

func AddPluginBroadcastName ¶

func AddPluginBroadcastName(data map[string]interface{}, pluginType, broadcastName string)

func ChangeDefaultNSPluginLocalName ¶

func ChangeDefaultNSPluginLocalName(data map[string]interface{}, pluginType, newLocalName string)

ChangeDefaultNSPluginLocalName changes the plugin local name and updates the plugin list for the default namespace

func GetMemberHostname ¶

func GetMemberHostname(filename string, n int) (string, error)

func GetMemberPort ¶

func GetMemberPort(filename string, n int) (int, error)

func PickTopic ¶

func PickTopic(i int, options []string) string

func PollForUp ¶

func PollForUp(t *testing.T, client *client.FireFlyClient)

func RandomName ¶

func RandomName(t *testing.T) string

func ReadConfig ¶

func ReadConfig(t *testing.T, configFile string) map[string]interface{}

func ResetFireFly ¶

func ResetFireFly(t *testing.T, client *resty.Client)

func ValidateAccountBalances ¶

func ValidateAccountBalances(t *testing.T, client *client.FireFlyClient, poolID *fftypes.UUID, tokenIndex string, balances map[string]int64)

func VerifyAllOperationsSucceeded ¶

func VerifyAllOperationsSucceeded(t *testing.T, clients []*client.FireFlyClient, startTime time.Time)

func VerifyOperationsAlreadyMarkedFailed ¶

func VerifyOperationsAlreadyMarkedFailed(t *testing.T, clients []*client.FireFlyClient, startTime time.Time)

func WaitForContractEvent ¶

func WaitForContractEvent(t *testing.T, client *client.FireFlyClient, c chan *core.EventDelivery, match map[string]interface{}) map[string]interface{}

func WaitForEvent ¶

func WaitForEvent(t *testing.T, c chan *core.EventDelivery, eventType core.EventType, ref *fftypes.UUID)

func WaitForIdentityConfirmed ¶

func WaitForIdentityConfirmed(t *testing.T, c chan *core.EventDelivery) *core.EventDelivery

func WaitForMessageConfirmed ¶

func WaitForMessageConfirmed(t *testing.T, c chan *core.EventDelivery, msgType core.MessageType) *core.EventDelivery

func WaitForMessageRejected ¶

func WaitForMessageRejected(t *testing.T, c chan *core.EventDelivery, msgType core.MessageType) *core.EventDelivery

func WaitForOperationSucceeded ¶

func WaitForOperationSucceeded(t *testing.T, client *client.FireFlyClient, operationID *fftypes.UUID) *core.Operation

func WriteConfig ¶

func WriteConfig(t *testing.T, configFile string, data map[string]interface{})

func WsReader ¶

func WsReader(conn *websocket.Conn) chan *core.EventDelivery

Types ¶

type Member ¶

type Member struct {
	ExposedFireflyPort   int         `json:"exposedFireflyPort,omitempty"`
	ExposedAdminPort     int         `json:"exposedFireflyAdminPort,omitempty"`
	FireflyHostname      string      `json:"fireflyHostname,omitempty"`
	Username             string      `json:"username,omitempty"`
	Password             string      `json:"password,omitempty"`
	UseHTTPS             bool        `json:"useHttps,omitempty"`
	ExposedConnectorPort int         `json:"exposedConnectorPort,omitempty"`
	OrgName              string      `json:"orgName,omitempty"`
	Account              interface{} `json:"account,omitempty"`
}

type Stack ¶

type Stack struct {
	Name                  string    `json:"name,omitempty"`
	ExposedBlockchainPort int       `json:"exposedBlockchainPort,omitempty"`
	BlockchainProvider    string    `json:"blockchainProvider"`
	TokenProviders        []string  `json:"tokenProviders"`
	Members               []*Member `json:"members,omitempty"`
	Database              string    `json:"database"`
}

func ReadStack ¶

func ReadStack(t *testing.T) *Stack

func ReadStackFile ¶

func ReadStackFile(filename string) (*Stack, error)

type StackState ¶

type StackState struct {
	Accounts []interface{} `json:"accounts"`
}

func ReadStackState ¶

func ReadStackState(t *testing.T) *StackState

func ReadStackStateFile ¶

func ReadStackStateFile(filename string) (*StackState, error)

type TestState ¶

type TestState interface {
	T() *testing.T
	StartTime() time.Time
	Done() func()
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
client
gateway
multiparty
runners

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL