e2e

Documentation

Index

• func BroadcastBlobMessage(t *testing.T, client *resty.Client) (*resty.Response, error)
• func BroadcastMessage(client *resty.Client, data *fftypes.DataRefOrValue) (*resty.Response, error)
• func CleanupExistingSubscription(t *testing.T, client *resty.Client, namespace, name string)
• func CreateBlob(t *testing.T, client *resty.Client) *fftypes.Data
• func CreateSubscription(t *testing.T, client *resty.Client, input interface{}, expectedStatus int) *fftypes.Subscription
• func CreateTokenPool(client *resty.Client, pool *fftypes.TokenPool) (*resty.Response, error)
• func DeleteSubscription(t *testing.T, client *resty.Client, id *fftypes.UUID)
• func GetBlob(t *testing.T, client *resty.Client, data *fftypes.Data, expectedStatus int) []byte
• func GetData(t *testing.T, client *resty.Client, startTime time.Time, expectedStatus int) (data []*fftypes.Data)
• func GetMemberHostname(filename string, n int) (string, error)
• func GetMemberPort(filename string, n int) (int, error)
• func GetMessages(t *testing.T, client *resty.Client, startTime time.Time, ...) (msgs []*fftypes.Message)
• func GetNamespaces(client *resty.Client) (*resty.Response, error)
• func GetOrgs(t *testing.T, client *resty.Client, expectedStatus int) (orgs []*fftypes.Organization)
• func NewResty(t *testing.T) *resty.Client
• func PrivateBlobMessage(t *testing.T, client *resty.Client, orgNames []string) (*resty.Response, error)
• func PrivateMessage(t *testing.T, client *resty.Client, data *fftypes.DataRefOrValue, ...) (*resty.Response, error)
• func RequestReply(t *testing.T, client *resty.Client, data *fftypes.DataRefOrValue, ...) *fftypes.MessageInOut
• type Member
• type Stack
  • func ReadStack(filename string) (*Stack, error)

Functions

func BroadcastBlobMessage

func BroadcastBlobMessage(t *testing.T, client *resty.Client) (*resty.Response, error)

func BroadcastMessage

func BroadcastMessage(client *resty.Client, data *fftypes.DataRefOrValue) (*resty.Response, error)

func CleanupExistingSubscription

func CleanupExistingSubscription(t *testing.T, client *resty.Client, namespace, name string)

func CreateBlob

func CreateBlob(t *testing.T, client *resty.Client) *fftypes.Data

func CreateSubscription

func CreateSubscription(t *testing.T, client *resty.Client, input interface{}, expectedStatus int) *fftypes.Subscription

func CreateTokenPool

func CreateTokenPool(client *resty.Client, pool *fftypes.TokenPool) (*resty.Response, error)

func DeleteSubscription

func DeleteSubscription(t *testing.T, client *resty.Client, id *fftypes.UUID)

func GetBlob

func GetBlob(t *testing.T, client *resty.Client, data *fftypes.Data, expectedStatus int) []byte

func GetData

func GetData(t *testing.T, client *resty.Client, startTime time.Time, expectedStatus int) (data []*fftypes.Data)

func GetMemberHostname

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

func GetMemberPort

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

func GetMessages

func GetMessages(t *testing.T, client *resty.Client, startTime time.Time, msgType fftypes.MessageType, expectedStatus int) (msgs []*fftypes.Message)

func GetNamespaces

func GetNamespaces(client *resty.Client) (*resty.Response, error)

func GetOrgs

func GetOrgs(t *testing.T, client *resty.Client, expectedStatus int) (orgs []*fftypes.Organization)

func NewResty

func NewResty(t *testing.T) *resty.Client

func PrivateBlobMessage

func PrivateBlobMessage(t *testing.T, client *resty.Client, orgNames []string) (*resty.Response, error)

func PrivateMessage

func PrivateMessage(t *testing.T, client *resty.Client, data *fftypes.DataRefOrValue, orgNames []string, tag string, txType fftypes.TransactionType) (*resty.Response, error)

func RequestReply

func RequestReply(t *testing.T, client *resty.Client, data *fftypes.DataRefOrValue, orgNames []string, tag string, txType fftypes.TransactionType) *fftypes.MessageInOut

Types

type Member

type Member struct {
	ExposedFireflyPort int    `json:"exposedFireflyPort,omitempty"`
	FireflyHostname    string `json:"fireflyHostname,omitempty"`
	Username           string `json:"username,omitempty"`
	Password           string `json:"password,omitempty"`
	UseHTTPS           bool   `json:"useHttps,omitempty"`
}

type Stack

type Stack struct {
	Members []*Member `json:"members,omitempty"`
}

func ReadStack

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