Documentation
¶
Index ¶
- type Callbacks
- type DXEvent
- func (_m *DXEvent) Ack()
- func (_m *DXEvent) AckWithManifest(manifest string)
- func (_m *DXEvent) ID() string
- func (_m *DXEvent) MessageReceived() *dataexchange.MessageReceived
- func (_m *DXEvent) PrivateBlobReceived() *dataexchange.PrivateBlobReceived
- func (_m *DXEvent) TransferResult() *dataexchange.TransferResult
- func (_m *DXEvent) Type() dataexchange.DXEventType
- type Plugin
- func (_m *Plugin) AddPeer(ctx context.Context, peer fftypes.JSONObject) error
- func (_m *Plugin) Capabilities() *dataexchange.Capabilities
- func (_m *Plugin) CheckBlobReceived(ctx context.Context, peerID string, ns string, id fftypes.UUID) (*fftypes.Bytes32, int64, error)
- func (_m *Plugin) DownloadBlob(ctx context.Context, payloadRef string) (io.ReadCloser, error)
- func (_m *Plugin) GetEndpointInfo(ctx context.Context) (fftypes.JSONObject, error)
- func (_m *Plugin) Init(ctx context.Context, _a1 config.Section, nodes []fftypes.JSONObject, ...) error
- func (_m *Plugin) InitConfig(_a0 config.Section)
- func (_m *Plugin) Name() string
- func (_m *Plugin) SendMessage(ctx context.Context, opID *fftypes.UUID, peerID string, data []byte) error
- func (_m *Plugin) Start() error
- func (_m *Plugin) TransferBlob(ctx context.Context, opID *fftypes.UUID, peerID string, payloadRef string) error
- func (_m *Plugin) UploadBlob(ctx context.Context, ns string, id fftypes.UUID, content io.Reader) (string, *fftypes.Bytes32, int64, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Callbacks ¶
Callbacks is an autogenerated mock type for the Callbacks type
func (*Callbacks) DXEvent ¶ added in v1.0.0
func (_m *Callbacks) DXEvent(event dataexchange.DXEvent)
DXEvent provides a mock function with given fields: event
type DXEvent ¶ added in v1.0.0
DXEvent is an autogenerated mock type for the DXEvent type
func (*DXEvent) Ack ¶ added in v1.0.0
func (_m *DXEvent) Ack()
Ack provides a mock function with given fields:
func (*DXEvent) AckWithManifest ¶ added in v1.0.0
AckWithManifest provides a mock function with given fields: manifest
func (*DXEvent) MessageReceived ¶ added in v1.0.0
func (_m *DXEvent) MessageReceived() *dataexchange.MessageReceived
MessageReceived provides a mock function with given fields:
func (*DXEvent) PrivateBlobReceived ¶ added in v1.0.0
func (_m *DXEvent) PrivateBlobReceived() *dataexchange.PrivateBlobReceived
PrivateBlobReceived provides a mock function with given fields:
func (*DXEvent) TransferResult ¶ added in v1.0.0
func (_m *DXEvent) TransferResult() *dataexchange.TransferResult
TransferResult provides a mock function with given fields:
func (*DXEvent) Type ¶ added in v1.0.0
func (_m *DXEvent) Type() dataexchange.DXEventType
Type provides a mock function with given fields:
type Plugin ¶
Plugin is an autogenerated mock type for the Plugin type
func (*Plugin) Capabilities ¶
func (_m *Plugin) Capabilities() *dataexchange.Capabilities
Capabilities provides a mock function with given fields:
func (*Plugin) CheckBlobReceived ¶ added in v1.0.0
func (_m *Plugin) CheckBlobReceived(ctx context.Context, peerID string, ns string, id fftypes.UUID) (*fftypes.Bytes32, int64, error)
CheckBlobReceived provides a mock function with given fields: ctx, peerID, ns, id
func (*Plugin) DownloadBlob ¶ added in v1.0.0
DownloadBlob provides a mock function with given fields: ctx, payloadRef
func (*Plugin) GetEndpointInfo ¶
GetEndpointInfo provides a mock function with given fields: ctx
func (*Plugin) Init ¶
func (_m *Plugin) Init(ctx context.Context, _a1 config.Section, nodes []fftypes.JSONObject, callbacks dataexchange.Callbacks) error
Init provides a mock function with given fields: ctx, _a1, nodes, callbacks
func (*Plugin) InitConfig ¶ added in v1.1.0
InitConfig provides a mock function with given fields: _a0
func (*Plugin) SendMessage ¶
func (_m *Plugin) SendMessage(ctx context.Context, opID *fftypes.UUID, peerID string, data []byte) error
SendMessage provides a mock function with given fields: ctx, opID, peerID, data
Source Files