client

Documentation

Index

• func NewResty(l Logger) *resty.Client
• type FireFlyClient
  • func NewFireFly(l Logger, hostname, namespace string) *FireFlyClient
  • func (client *FireFlyClient) BroadcastBlobMessage(t *testing.T, topic string) (*core.Data, *resty.Response, error)
  • func (client *FireFlyClient) BroadcastMessage(t *testing.T, topic, idempotencyKey string, data *core.DataRefOrValue, ...) (*resty.Response, error)
  • func (client *FireFlyClient) BroadcastMessageAsIdentity(t *testing.T, did, topic, idempotencyKey string, data *core.DataRefOrValue, ...) (*resty.Response, error)
  • func (client *FireFlyClient) BurnTokens(t *testing.T, burn *core.TokenTransferInput, confirm bool, ...) *core.TokenTransfer
  • func (client *FireFlyClient) ClaimCustomIdentity(t *testing.T, key, name, desc string, profile fftypes.JSONObject, ...) *core.Identity
  • func (client *FireFlyClient) CleanupExistingSubscription(t *testing.T, namespace, name string)
  • func (client *FireFlyClient) CreateBlob(t *testing.T, dt *core.DatatypeRef) *core.Data
  • func (client *FireFlyClient) CreateContractAPI(t *testing.T, name string, ffiReference *fftypes.FFIReference, ...) (*core.ContractAPI, error)
  • func (client *FireFlyClient) CreateContractAPIListener(t *testing.T, apiName, eventName, topic string) (*core.ContractListener, error)
  • func (client *FireFlyClient) CreateContractListener(t *testing.T, event *fftypes.FFIEvent, location *fftypes.JSONObject) *core.ContractListener
  • func (client *FireFlyClient) CreateDatatype(t *testing.T, datatype *core.Datatype, confirm bool) *core.Datatype
  • func (client *FireFlyClient) CreateFFI(t *testing.T, ffi *fftypes.FFI, publish bool) (*fftypes.FFI, error)
  • func (client *FireFlyClient) CreateFFIContractListener(t *testing.T, ffiReference *fftypes.FFIReference, eventPath string, ...) *core.ContractListener
  • func (client *FireFlyClient) CreateSubscription(t *testing.T, input interface{}, expectedStatus int) *core.Subscription
  • func (client *FireFlyClient) CreateTokenPool(t *testing.T, pool *core.TokenPool, publish, confirm bool) *core.TokenPool
  • func (client *FireFlyClient) DeleteContractAPI(t *testing.T, name string, expectedStatus int)
  • func (client *FireFlyClient) DeleteContractListener(t *testing.T, id *fftypes.UUID)
  • func (client *FireFlyClient) DeleteFFI(t *testing.T, id *fftypes.UUID, expectedStatus int)
  • func (client *FireFlyClient) DeleteSubscription(t *testing.T, id *fftypes.UUID)
  • func (client *FireFlyClient) DeleteTokenPool(t *testing.T, poolID *fftypes.UUID, expectedStatus int)
  • func (client *FireFlyClient) GenerateFFIFromABI(t *testing.T, req *fftypes.FFIGenerationRequest) *fftypes.FFI
  • func (client *FireFlyClient) GetBlob(t *testing.T, data *core.Data, expectedStatus int) []byte
  • func (client *FireFlyClient) GetBlockchainEvent(t *testing.T, eventID string) *core.BlockchainEvent
  • func (client *FireFlyClient) GetBlockchainEvents(t *testing.T, startTime time.Time) (events []*core.BlockchainEvent)
  • func (client *FireFlyClient) GetContractAPI(t *testing.T, name string) (result *core.ContractAPI)
  • func (client *FireFlyClient) GetContractEvents(t *testing.T, startTime time.Time, subscriptionID *fftypes.UUID) (events []*core.BlockchainEvent)
  • func (client *FireFlyClient) GetContractListeners(t *testing.T, startTime time.Time) (subs []*core.ContractListener)
  • func (client *FireFlyClient) GetData(t *testing.T, startTime time.Time) (data core.DataArray)
  • func (client *FireFlyClient) GetDataByID(t *testing.T, id *fftypes.UUID) *core.Data
  • func (client *FireFlyClient) GetDataForMessage(t *testing.T, startTime time.Time, msgID *fftypes.UUID) (data core.DataArray)
  • func (client *FireFlyClient) GetEvent(t *testing.T, eventID string) *core.Event
  • func (client *FireFlyClient) GetFFI(t *testing.T, name, version string) (result *fftypes.FFI)
  • func (client *FireFlyClient) GetIdentity(t *testing.T, id *fftypes.UUID) *core.Identity
  • func (client *FireFlyClient) GetIdentityBlockchainKeys(t *testing.T, identityID *fftypes.UUID, expectedStatus int) (verifiers []*core.Verifier)
  • func (client *FireFlyClient) GetMessageEvents(t *testing.T, startTime time.Time, topic string, expectedStatus int) (events []*core.EnrichedEvent)
  • func (client *FireFlyClient) GetMessages(t *testing.T, startTime time.Time, msgType core.MessageType, topic string) (msgs []*core.Message)
  • func (client *FireFlyClient) GetNamespaces() (*resty.Response, error)
  • func (client *FireFlyClient) GetOperations(t *testing.T, startTime time.Time) (operations []*core.Operation)
  • func (client *FireFlyClient) GetOrganization(t *testing.T, idOrName string) *core.Identity
  • func (client *FireFlyClient) GetOrgs(t *testing.T) (orgs []*core.Identity)
  • func (client *FireFlyClient) GetStatus() (*core.NamespaceStatus, *resty.Response, error)
  • func (client *FireFlyClient) GetTokenAccountPools(t *testing.T, identity string) (pools []*core.TokenAccountPool)
  • func (client *FireFlyClient) GetTokenAccounts(t *testing.T, poolID *fftypes.UUID) (accounts []*core.TokenAccount)
  • func (client *FireFlyClient) GetTokenApprovals(t *testing.T, poolID *fftypes.UUID) (approvals []*core.TokenApproval)
  • func (client *FireFlyClient) GetTokenBalance(t *testing.T, poolID *fftypes.UUID, tokenIndex, key string) (account *core.TokenBalance)
  • func (client *FireFlyClient) GetTokenPool(t *testing.T, poolID *fftypes.UUID) (pool *core.TokenPool)
  • func (client *FireFlyClient) GetTokenPools(t *testing.T, startTime time.Time) (pools []*core.TokenPool)
  • func (client *FireFlyClient) GetTokenTransfers(t *testing.T, poolID *fftypes.UUID) (transfers []*core.TokenTransfer)
  • func (client *FireFlyClient) GetVerifiers(t *testing.T) []*core.Verifier
  • func (client *FireFlyClient) InvokeContractAPIMethod(t *testing.T, apiName string, methodName string, input *fftypes.JSONAny) (interface{}, error)
  • func (client *FireFlyClient) InvokeContractMethod(t *testing.T, req *core.ContractCallRequest, expectedStatus ...int) (interface{}, error)
  • func (client *FireFlyClient) MintTokens(t *testing.T, mint *core.TokenTransferInput, confirm bool, ...) *core.TokenTransfer
  • func (client *FireFlyClient) NetworkAction(t *testing.T, action core.NetworkActionType)
  • func (client *FireFlyClient) PrivateBlobMessageDatatypeTagged(t *testing.T, topic string, members []core.MemberInput, startTime time.Time) (*core.Data, *resty.Response, error)
  • func (client *FireFlyClient) PrivateMessage(topic, idempotencyKey string, data *core.DataRefOrValue, ...) (*resty.Response, error)
  • func (client *FireFlyClient) PrivateMessageWithKey(key, topic, idempotencyKey string, data *core.DataRefOrValue, ...) (*resty.Response, error)
  • func (client *FireFlyClient) PublishContractAPI(t *testing.T, name, networkName string, confirm bool)
  • func (client *FireFlyClient) PublishFFI(t *testing.T, name, version, networkName string, confirm bool)
  • func (client *FireFlyClient) PublishTokenPool(t *testing.T, poolID *fftypes.UUID, networkName string, confirm bool)
  • func (client *FireFlyClient) QueryContractAPIMethod(t *testing.T, apiName string, methodName string, input *fftypes.JSONAny) (interface{}, error)
  • func (client *FireFlyClient) QueryContractMethod(t *testing.T, req *core.ContractCallRequest) (interface{}, error)
  • func (client *FireFlyClient) RegisterSelfNode(t *testing.T, confirm bool)
  • func (client *FireFlyClient) RegisterSelfOrg(t *testing.T, confirm bool)
  • func (client *FireFlyClient) RequestReply(t *testing.T, data *core.DataRefOrValue, orgNames []string, tag string, ...) *core.MessageInOut
  • func (client *FireFlyClient) TokenApproval(t *testing.T, approval *core.TokenApprovalInput, confirm bool, ...) *core.TokenApproval
  • func (client *FireFlyClient) TransferTokens(t *testing.T, transfer *core.TokenTransferInput, confirm bool, ...) *core.TokenTransfer
  • func (client *FireFlyClient) WebSocket(t *testing.T, query string, authHeader http.Header) *websocket.Conn
• type Logger

Functions

func NewResty

func NewResty(l Logger) *resty.Client

Types

type FireFlyClient

type FireFlyClient struct {
	Hostname  string
	Namespace string
	Client    *resty.Client
	// contains filtered or unexported fields
}

func NewFireFly

func NewFireFly(l Logger, hostname, namespace string) *FireFlyClient

func (*FireFlyClient) BroadcastBlobMessage

func (client *FireFlyClient) BroadcastBlobMessage(t *testing.T, topic string) (*core.Data, *resty.Response, error)

func (*FireFlyClient) BroadcastMessage

func (client *FireFlyClient) BroadcastMessage(t *testing.T, topic, idempotencyKey string, data *core.DataRefOrValue, confirm bool) (*resty.Response, error)

func (*FireFlyClient) BroadcastMessageAsIdentity

func (client *FireFlyClient) BroadcastMessageAsIdentity(t *testing.T, did, topic, idempotencyKey string, data *core.DataRefOrValue, confirm bool) (*resty.Response, error)

func (*FireFlyClient) BurnTokens

func (client *FireFlyClient) BurnTokens(t *testing.T, burn *core.TokenTransferInput, confirm bool, expectedStatus ...int) *core.TokenTransfer

func (*FireFlyClient) ClaimCustomIdentity

func (client *FireFlyClient) ClaimCustomIdentity(t *testing.T, key, name, desc string, profile fftypes.JSONObject, parent *fftypes.UUID, confirm bool) *core.Identity

func (*FireFlyClient) CleanupExistingSubscription

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

func (*FireFlyClient) CreateBlob

func (client *FireFlyClient) CreateBlob(t *testing.T, dt *core.DatatypeRef) *core.Data

func (*FireFlyClient) CreateContractAPI

func (client *FireFlyClient) CreateContractAPI(t *testing.T, name string, ffiReference *fftypes.FFIReference, location *fftypes.JSONAny, publish bool) (*core.ContractAPI, error)

func (*FireFlyClient) CreateContractAPIListener

func (client *FireFlyClient) CreateContractAPIListener(t *testing.T, apiName, eventName, topic string) (*core.ContractListener, error)

func (*FireFlyClient) CreateContractListener

func (client *FireFlyClient) CreateContractListener(t *testing.T, event *fftypes.FFIEvent, location *fftypes.JSONObject) *core.ContractListener

func (*FireFlyClient) CreateDatatype

func (client *FireFlyClient) CreateDatatype(t *testing.T, datatype *core.Datatype, confirm bool) *core.Datatype

func (*FireFlyClient) CreateFFI

func (client *FireFlyClient) CreateFFI(t *testing.T, ffi *fftypes.FFI, publish bool) (*fftypes.FFI, error)

func (*FireFlyClient) CreateFFIContractListener

func (client *FireFlyClient) CreateFFIContractListener(t *testing.T, ffiReference *fftypes.FFIReference, eventPath string, location *fftypes.JSONObject) *core.ContractListener

func (*FireFlyClient) CreateSubscription

func (client *FireFlyClient) CreateSubscription(t *testing.T, input interface{}, expectedStatus int) *core.Subscription

func (*FireFlyClient) CreateTokenPool

func (client *FireFlyClient) CreateTokenPool(t *testing.T, pool *core.TokenPool, publish, confirm bool) *core.TokenPool

func (*FireFlyClient) DeleteContractAPI

func (client *FireFlyClient) DeleteContractAPI(t *testing.T, name string, expectedStatus int)

func (*FireFlyClient) DeleteContractListener

func (client *FireFlyClient) DeleteContractListener(t *testing.T, id *fftypes.UUID)

func (*FireFlyClient) DeleteFFI

func (client *FireFlyClient) DeleteFFI(t *testing.T, id *fftypes.UUID, expectedStatus int)

func (*FireFlyClient) DeleteSubscription

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

func (*FireFlyClient) DeleteTokenPool

func (client *FireFlyClient) DeleteTokenPool(t *testing.T, poolID *fftypes.UUID, expectedStatus int)

func (*FireFlyClient) GenerateFFIFromABI

func (client *FireFlyClient) GenerateFFIFromABI(t *testing.T, req *fftypes.FFIGenerationRequest) *fftypes.FFI

func (*FireFlyClient) GetBlob

func (client *FireFlyClient) GetBlob(t *testing.T, data *core.Data, expectedStatus int) []byte

func (*FireFlyClient) GetBlockchainEvent

func (client *FireFlyClient) GetBlockchainEvent(t *testing.T, eventID string) *core.BlockchainEvent

func (*FireFlyClient) GetBlockchainEvents

func (client *FireFlyClient) GetBlockchainEvents(t *testing.T, startTime time.Time) (events []*core.BlockchainEvent)

func (*FireFlyClient) GetContractAPI

func (client *FireFlyClient) GetContractAPI(t *testing.T, name string) (result *core.ContractAPI)

func (*FireFlyClient) GetContractEvents

func (client *FireFlyClient) GetContractEvents(t *testing.T, startTime time.Time, subscriptionID *fftypes.UUID) (events []*core.BlockchainEvent)

func (*FireFlyClient) GetContractListeners

func (client *FireFlyClient) GetContractListeners(t *testing.T, startTime time.Time) (subs []*core.ContractListener)

func (*FireFlyClient) GetData

func (client *FireFlyClient) GetData(t *testing.T, startTime time.Time) (data core.DataArray)

func (*FireFlyClient) GetDataByID

func (client *FireFlyClient) GetDataByID(t *testing.T, id *fftypes.UUID) *core.Data

func (*FireFlyClient) GetDataForMessage

func (client *FireFlyClient) GetDataForMessage(t *testing.T, startTime time.Time, msgID *fftypes.UUID) (data core.DataArray)

func (*FireFlyClient) GetEvent

func (client *FireFlyClient) GetEvent(t *testing.T, eventID string) *core.Event

func (*FireFlyClient) GetFFI

func (client *FireFlyClient) GetFFI(t *testing.T, name, version string) (result *fftypes.FFI)

func (*FireFlyClient) GetIdentity

func (client *FireFlyClient) GetIdentity(t *testing.T, id *fftypes.UUID) *core.Identity

func (*FireFlyClient) GetIdentityBlockchainKeys

func (client *FireFlyClient) GetIdentityBlockchainKeys(t *testing.T, identityID *fftypes.UUID, expectedStatus int) (verifiers []*core.Verifier)

func (*FireFlyClient) GetMessageEvents

func (client *FireFlyClient) GetMessageEvents(t *testing.T, startTime time.Time, topic string, expectedStatus int) (events []*core.EnrichedEvent)

func (*FireFlyClient) GetMessages

func (client *FireFlyClient) GetMessages(t *testing.T, startTime time.Time, msgType core.MessageType, topic string) (msgs []*core.Message)

func (*FireFlyClient) GetNamespaces

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

func (*FireFlyClient) GetOperations

func (client *FireFlyClient) GetOperations(t *testing.T, startTime time.Time) (operations []*core.Operation)

func (*FireFlyClient) GetOrganization

func (client *FireFlyClient) GetOrganization(t *testing.T, idOrName string) *core.Identity

func (*FireFlyClient) GetOrgs

func (client *FireFlyClient) GetOrgs(t *testing.T) (orgs []*core.Identity)

func (*FireFlyClient) GetStatus

func (client *FireFlyClient) GetStatus() (*core.NamespaceStatus, *resty.Response, error)

func (*FireFlyClient) GetTokenAccountPools

func (client *FireFlyClient) GetTokenAccountPools(t *testing.T, identity string) (pools []*core.TokenAccountPool)

func (*FireFlyClient) GetTokenAccounts

func (client *FireFlyClient) GetTokenAccounts(t *testing.T, poolID *fftypes.UUID) (accounts []*core.TokenAccount)

func (*FireFlyClient) GetTokenApprovals

func (client *FireFlyClient) GetTokenApprovals(t *testing.T, poolID *fftypes.UUID) (approvals []*core.TokenApproval)

func (*FireFlyClient) GetTokenBalance

func (client *FireFlyClient) GetTokenBalance(t *testing.T, poolID *fftypes.UUID, tokenIndex, key string) (account *core.TokenBalance)

func (*FireFlyClient) GetTokenPool

func (client *FireFlyClient) GetTokenPool(t *testing.T, poolID *fftypes.UUID) (pool *core.TokenPool)

func (*FireFlyClient) GetTokenPools

func (client *FireFlyClient) GetTokenPools(t *testing.T, startTime time.Time) (pools []*core.TokenPool)

func (*FireFlyClient) GetTokenTransfers

func (client *FireFlyClient) GetTokenTransfers(t *testing.T, poolID *fftypes.UUID) (transfers []*core.TokenTransfer)

func (*FireFlyClient) GetVerifiers

func (client *FireFlyClient) GetVerifiers(t *testing.T) []*core.Verifier

func (*FireFlyClient) InvokeContractAPIMethod

func (client *FireFlyClient) InvokeContractAPIMethod(t *testing.T, apiName string, methodName string, input *fftypes.JSONAny) (interface{}, error)

func (*FireFlyClient) InvokeContractMethod

func (client *FireFlyClient) InvokeContractMethod(t *testing.T, req *core.ContractCallRequest, expectedStatus ...int) (interface{}, error)

func (*FireFlyClient) MintTokens

func (client *FireFlyClient) MintTokens(t *testing.T, mint *core.TokenTransferInput, confirm bool, expectedStatus ...int) *core.TokenTransfer

func (*FireFlyClient) NetworkAction

func (client *FireFlyClient) NetworkAction(t *testing.T, action core.NetworkActionType)

func (*FireFlyClient) PrivateBlobMessageDatatypeTagged

func (client *FireFlyClient) PrivateBlobMessageDatatypeTagged(t *testing.T, topic string, members []core.MemberInput, startTime time.Time) (*core.Data, *resty.Response, error)

func (*FireFlyClient) PrivateMessage

func (client *FireFlyClient) PrivateMessage(topic, idempotencyKey string, data *core.DataRefOrValue, members []core.MemberInput, tag string, txType core.TransactionType, confirm bool, startTime time.Time) (*resty.Response, error)

func (*FireFlyClient) PrivateMessageWithKey

func (client *FireFlyClient) PrivateMessageWithKey(key, topic, idempotencyKey string, data *core.DataRefOrValue, members []core.MemberInput, tag string, txType core.TransactionType, confirm bool, startTime time.Time) (*resty.Response, error)

func (*FireFlyClient) PublishContractAPI

func (client *FireFlyClient) PublishContractAPI(t *testing.T, name, networkName string, confirm bool)

func (*FireFlyClient) PublishFFI

func (client *FireFlyClient) PublishFFI(t *testing.T, name, version, networkName string, confirm bool)

func (*FireFlyClient) PublishTokenPool

func (client *FireFlyClient) PublishTokenPool(t *testing.T, poolID *fftypes.UUID, networkName string, confirm bool)

func (*FireFlyClient) QueryContractAPIMethod

func (client *FireFlyClient) QueryContractAPIMethod(t *testing.T, apiName string, methodName string, input *fftypes.JSONAny) (interface{}, error)

func (*FireFlyClient) QueryContractMethod

func (client *FireFlyClient) QueryContractMethod(t *testing.T, req *core.ContractCallRequest) (interface{}, error)

func (*FireFlyClient) RegisterSelfNode

func (client *FireFlyClient) RegisterSelfNode(t *testing.T, confirm bool)

func (*FireFlyClient) RegisterSelfOrg

func (client *FireFlyClient) RegisterSelfOrg(t *testing.T, confirm bool)

func (*FireFlyClient) RequestReply

func (client *FireFlyClient) RequestReply(t *testing.T, data *core.DataRefOrValue, orgNames []string, tag string, txType core.TransactionType, startTime time.Time) *core.MessageInOut

func (*FireFlyClient) TokenApproval

func (client *FireFlyClient) TokenApproval(t *testing.T, approval *core.TokenApprovalInput, confirm bool, expectedStatus ...int) *core.TokenApproval

func (*FireFlyClient) TransferTokens

func (client *FireFlyClient) TransferTokens(t *testing.T, transfer *core.TokenTransferInput, confirm bool, expectedStatus ...int) *core.TokenTransfer

func (*FireFlyClient) WebSocket

func (client *FireFlyClient) WebSocket(t *testing.T, query string, authHeader http.Header) *websocket.Conn

type Logger

type Logger interface {
	Logf(format string, args ...interface{})
}