Documentation
¶
Index ¶
- type Callbacks
- func (_m *Callbacks) BLOBReceived(peerID string, hash fftypes.Bytes32, size int64, payloadRef string) error
- func (_m *Callbacks) MessageReceived(peerID string, data []byte) (string, error)
- func (_m *Callbacks) TransferResult(trackingID string, status fftypes.OpStatus, info fftypes.TransportStatusUpdate) error
- type Plugin
- func (_m *Plugin) AddPeer(ctx context.Context, peer fftypes.DXInfo) 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.DXInfo, error)
- func (_m *Plugin) Init(ctx context.Context, prefix config.Prefix, nodes []fftypes.DXInfo, ...) error
- func (_m *Plugin) InitPrefix(prefix config.Prefix)
- 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) BLOBReceived ¶
func (_m *Callbacks) BLOBReceived(peerID string, hash fftypes.Bytes32, size int64, payloadRef string) error
BLOBReceived provides a mock function with given fields: peerID, hash, size, payloadRef
func (*Callbacks) MessageReceived ¶
MessageReceived provides a mock function with given fields: peerID, data
func (*Callbacks) TransferResult ¶
func (_m *Callbacks) TransferResult(trackingID string, status fftypes.OpStatus, info fftypes.TransportStatusUpdate) error
TransferResult provides a mock function with given fields: trackingID, status, info
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 ¶
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 ¶
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, prefix config.Prefix, nodes []fftypes.DXInfo, callbacks dataexchange.Callbacks) error
Init provides a mock function with given fields: ctx, prefix, nodes, callbacks
func (*Plugin) InitPrefix ¶
InitPrefix provides a mock function with given fields: prefix
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