dataexchangemocks

Documentation

Index

• type Callbacks
  • func NewCallbacks(t interface{ ... }) *Callbacks
  • func (_m *Callbacks) DXEvent(plugin dataexchange.Plugin, event dataexchange.DXEvent) error
• type DXEvent
  • func NewDXEvent(t interface{ ... }) *DXEvent
  • func (_m *DXEvent) Ack()
  • func (_m *DXEvent) AckWithManifest(manifest string)
  • func (_m *DXEvent) EventID() string
  • func (_m *DXEvent) MessageReceived() *dataexchange.MessageReceived
  • func (_m *DXEvent) PrivateBlobReceived() *dataexchange.PrivateBlobReceived
  • func (_m *DXEvent) Type() dataexchange.DXEventType
• type Plugin
  • func NewPlugin(t interface{ ... }) *Plugin
  • func (_m *Plugin) AddNode(ctx context.Context, networkNamespace string, nodeName string, ...) error
  • func (_m *Plugin) Capabilities() *dataexchange.Capabilities
  • func (_m *Plugin) DeleteBlob(ctx context.Context, payloadRef string) error
  • func (_m *Plugin) DownloadBlob(ctx context.Context, payloadRef string) (io.ReadCloser, error)
  • func (_m *Plugin) GetEndpointInfo(ctx context.Context, nodeName string) (fftypes.JSONObject, error)
  • func (_m *Plugin) GetPeerID(peer fftypes.JSONObject) string
  • func (_m *Plugin) Init(ctx context.Context, cancelCtx context.CancelFunc, _a2 config.Section) error
  • func (_m *Plugin) InitConfig(_a0 config.Section)
  • func (_m *Plugin) Name() string
  • func (_m *Plugin) SendMessage(ctx context.Context, nsOpID string, peer fftypes.JSONObject, ...) error
  • func (_m *Plugin) SetHandler(networkNamespace string, nodeName string, handler dataexchange.Callbacks)
  • func (_m *Plugin) SetOperationHandler(namespace string, handler core.OperationCallbacks)
  • func (_m *Plugin) Start() error
  • func (_m *Plugin) TransferBlob(ctx context.Context, nsOpID string, peer fftypes.JSONObject, ...) error
  • func (_m *Plugin) UploadBlob(ctx context.Context, ns string, id fftypes.UUID, content io.Reader) (string, *fftypes.Bytes32, int64, error)

Types

type Callbacks

type Callbacks struct {
	mock.Mock
}

Callbacks is an autogenerated mock type for the Callbacks type

func NewCallbacks

func NewCallbacks(t interface {
	mock.TestingT
	Cleanup(func())
}) *Callbacks

NewCallbacks creates a new instance of Callbacks. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Callbacks) DXEvent

func (_m *Callbacks) DXEvent(plugin dataexchange.Plugin, event dataexchange.DXEvent) error

DXEvent provides a mock function with given fields: plugin, event

type DXEvent

type DXEvent struct {
	mock.Mock
}

DXEvent is an autogenerated mock type for the DXEvent type

func NewDXEvent

func NewDXEvent(t interface {
	mock.TestingT
	Cleanup(func())
}) *DXEvent

NewDXEvent creates a new instance of DXEvent. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*DXEvent) Ack

func (_m *DXEvent) Ack()

Ack provides a mock function with given fields:

func (*DXEvent) AckWithManifest

func (_m *DXEvent) AckWithManifest(manifest string)

AckWithManifest provides a mock function with given fields: manifest

func (*DXEvent) EventID

func (_m *DXEvent) EventID() string

EventID provides a mock function with given fields:

func (*DXEvent) MessageReceived

func (_m *DXEvent) MessageReceived() *dataexchange.MessageReceived

MessageReceived provides a mock function with given fields:

func (*DXEvent) PrivateBlobReceived

func (_m *DXEvent) PrivateBlobReceived() *dataexchange.PrivateBlobReceived

PrivateBlobReceived provides a mock function with given fields:

func (*DXEvent) Type

func (_m *DXEvent) Type() dataexchange.DXEventType

Type provides a mock function with given fields:

type Plugin

type Plugin struct {
	mock.Mock
}

Plugin is an autogenerated mock type for the Plugin type

func NewPlugin

func NewPlugin(t interface {
	mock.TestingT
	Cleanup(func())
}) *Plugin

NewPlugin creates a new instance of Plugin. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Plugin) AddNode

func (_m *Plugin) AddNode(ctx context.Context, networkNamespace string, nodeName string, peer fftypes.JSONObject) error

AddNode provides a mock function with given fields: ctx, networkNamespace, nodeName, peer

func (*Plugin) Capabilities

func (_m *Plugin) Capabilities() *dataexchange.Capabilities

Capabilities provides a mock function with given fields:

func (*Plugin) DeleteBlob

func (_m *Plugin) DeleteBlob(ctx context.Context, payloadRef string) error

DeleteBlob provides a mock function with given fields: ctx, payloadRef

func (*Plugin) DownloadBlob

func (_m *Plugin) DownloadBlob(ctx context.Context, payloadRef string) (io.ReadCloser, error)

DownloadBlob provides a mock function with given fields: ctx, payloadRef

func (*Plugin) GetEndpointInfo

func (_m *Plugin) GetEndpointInfo(ctx context.Context, nodeName string) (fftypes.JSONObject, error)

GetEndpointInfo provides a mock function with given fields: ctx, nodeName

func (*Plugin) GetPeerID

func (_m *Plugin) GetPeerID(peer fftypes.JSONObject) string

GetPeerID provides a mock function with given fields: peer

func (*Plugin) Init

func (_m *Plugin) Init(ctx context.Context, cancelCtx context.CancelFunc, _a2 config.Section) error

Init provides a mock function with given fields: ctx, cancelCtx, _a2

func (*Plugin) InitConfig

func (_m *Plugin) InitConfig(_a0 config.Section)

InitConfig provides a mock function with given fields: _a0

func (*Plugin) Name

func (_m *Plugin) Name() string

Name provides a mock function with given fields:

func (*Plugin) SendMessage

func (_m *Plugin) SendMessage(ctx context.Context, nsOpID string, peer fftypes.JSONObject, sender fftypes.JSONObject, data []byte) error

SendMessage provides a mock function with given fields: ctx, nsOpID, peer, sender, data

func (*Plugin) SetHandler

func (_m *Plugin) SetHandler(networkNamespace string, nodeName string, handler dataexchange.Callbacks)

SetHandler provides a mock function with given fields: networkNamespace, nodeName, handler

func (*Plugin) SetOperationHandler

func (_m *Plugin) SetOperationHandler(namespace string, handler core.OperationCallbacks)

SetOperationHandler provides a mock function with given fields: namespace, handler

func (*Plugin) Start

func (_m *Plugin) Start() error

Start provides a mock function with given fields:

func (*Plugin) TransferBlob

func (_m *Plugin) TransferBlob(ctx context.Context, nsOpID string, peer fftypes.JSONObject, sender fftypes.JSONObject, payloadRef string) error

TransferBlob provides a mock function with given fields: ctx, nsOpID, peer, sender, payloadRef

func (*Plugin) UploadBlob

func (_m *Plugin) UploadBlob(ctx context.Context, ns string, id fftypes.UUID, content io.Reader) (string, *fftypes.Bytes32, int64, error)

UploadBlob provides a mock function with given fields: ctx, ns, id, content