Documentation ¶
Index ¶
- Constants
- type FFDX
- func (h *FFDX) AddPeer(ctx context.Context, peer fftypes.JSONObject) (err error)
- func (h *FFDX) Capabilities() *dataexchange.Capabilities
- func (h *FFDX) CheckBlobReceived(ctx context.Context, peerID, ns string, id fftypes.UUID) (hash *fftypes.Bytes32, size int64, err error)
- func (h *FFDX) DownloadBlob(ctx context.Context, payloadRef string) (content io.ReadCloser, err error)
- func (h *FFDX) GetEndpointInfo(ctx context.Context) (peer fftypes.JSONObject, err error)
- func (h *FFDX) Init(ctx context.Context, prefix config.Prefix, nodes []fftypes.JSONObject, ...) (err error)
- func (h *FFDX) InitPrefix(prefix config.Prefix)
- func (h *FFDX) Name() string
- func (h *FFDX) SendMessage(ctx context.Context, opID *fftypes.UUID, peerID string, data []byte) (err error)
- func (h *FFDX) Start() error
- func (h *FFDX) TransferBlob(ctx context.Context, opID *fftypes.UUID, peerID, payloadRef string) (err error)
- func (h *FFDX) UploadBlob(ctx context.Context, ns string, id fftypes.UUID, content io.Reader) (payloadRef string, hash *fftypes.Bytes32, size int64, err error)
Constants ¶
View Source
const ( // DataExchangeManifestEnabled determines whether to require+validate a manifest from other DX instances in the network. Must be supported by the connector DataExchangeManifestEnabled = "manifestEnabled" // DataExchangeInitEnabled instructs FireFly to always post all current nodes to the /init API before connecting or reconnecting to the connector DataExchangeInitEnabled = "initEnabled" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FFDX ¶
type FFDX struct {
// contains filtered or unexported fields
}
func (*FFDX) Capabilities ¶
func (h *FFDX) Capabilities() *dataexchange.Capabilities
func (*FFDX) CheckBlobReceived ¶ added in v1.0.0
func (*FFDX) DownloadBlob ¶ added in v1.0.0
func (*FFDX) GetEndpointInfo ¶
func (*FFDX) Init ¶
func (h *FFDX) Init(ctx context.Context, prefix config.Prefix, nodes []fftypes.JSONObject, callbacks dataexchange.Callbacks) (err error)
func (*FFDX) InitPrefix ¶
func (*FFDX) SendMessage ¶
func (*FFDX) TransferBlob ¶ added in v1.0.0
Click to show internal directories.
Click to hide internal directories.