ffdx

package
v1.0.0-rc.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 11, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

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) AddPeer

func (h *FFDX) AddPeer(ctx context.Context, peer fftypes.JSONObject) (err error)

func (*FFDX) Capabilities

func (h *FFDX) Capabilities() *dataexchange.Capabilities

func (*FFDX) CheckBlobReceived added in v1.0.0

func (h *FFDX) CheckBlobReceived(ctx context.Context, peerID, ns string, id fftypes.UUID) (hash *fftypes.Bytes32, size int64, err error)

func (*FFDX) DownloadBlob added in v1.0.0

func (h *FFDX) DownloadBlob(ctx context.Context, payloadRef string) (content io.ReadCloser, err error)

func (*FFDX) GetEndpointInfo

func (h *FFDX) GetEndpointInfo(ctx context.Context) (peer fftypes.JSONObject, err error)

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 (h *FFDX) InitPrefix(prefix config.Prefix)

func (*FFDX) Name

func (h *FFDX) Name() string

func (*FFDX) SendMessage

func (h *FFDX) SendMessage(ctx context.Context, opID *fftypes.UUID, peerID string, data []byte) (err error)

func (*FFDX) Start

func (h *FFDX) Start() error

func (*FFDX) TransferBlob added in v1.0.0

func (h *FFDX) TransferBlob(ctx context.Context, opID *fftypes.UUID, peerID, payloadRef string) (err error)

func (*FFDX) UploadBlob added in v1.0.0

func (h *FFDX) UploadBlob(ctx context.Context, ns string, id fftypes.UUID, content io.Reader) (payloadRef string, hash *fftypes.Bytes32, size int64, err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL