Documentation
¶
Index ¶
- func CancelRequest(id datatransfer.TransferID) datatransfer.Request
- func CancelResponse(id datatransfer.TransferID) datatransfer.Response
- func CompleteResponse(id datatransfer.TransferID, isAccepted bool, isPaused bool, ...) (datatransfer.Response, error)
- func FromNet(r io.Reader) (datatransfer.Message, error)
- func NewRequest(id datatransfer.TransferID, isRestart bool, isPull bool, ...) (datatransfer.Request, error)
- func NewResponse(id datatransfer.TransferID, accepted bool, isPaused bool, ...) (datatransfer.Response, error)
- func RestartExistingChannelRequest(channelId datatransfer.ChannelID) datatransfer.Request
- func RestartResponse(id datatransfer.TransferID, accepted bool, isPaused bool, ...) (datatransfer.Response, error)
- func UpdateRequest(id datatransfer.TransferID, isPaused bool) datatransfer.Request
- func UpdateResponse(id datatransfer.TransferID, isPaused bool) datatransfer.Response
- func VoucherRequest(id datatransfer.TransferID, vtype datatransfer.TypeIdentifier, ...) (datatransfer.Request, error)
- func VoucherResultResponse(id datatransfer.TransferID, accepted bool, isPaused bool, ...) (datatransfer.Response, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CancelRequest ¶
func CancelRequest(id datatransfer.TransferID) datatransfer.Request
CancelRequest request generates a request to cancel an in progress request
func CancelResponse ¶
func CancelResponse(id datatransfer.TransferID) datatransfer.Response
CancelResponse makes a new cancel response message
func CompleteResponse ¶
func CompleteResponse(id datatransfer.TransferID, isAccepted bool, isPaused bool, voucherResultType datatransfer.TypeIdentifier, voucherResult encoding.Encodable) (datatransfer.Response, error)
CompleteResponse returns a new complete response message
func FromNet ¶
func FromNet(r io.Reader) (datatransfer.Message, error)
FromNet can read a network stream to deserialize a GraphSyncMessage
func NewRequest ¶
func NewRequest(id datatransfer.TransferID, isRestart bool, isPull bool, vtype datatransfer.TypeIdentifier, voucher encoding.Encodable, baseCid cid.Cid, selector ipld.Node) (datatransfer.Request, error)
NewRequest generates a new request for the data transfer protocol
func NewResponse ¶
func NewResponse(id datatransfer.TransferID, accepted bool, isPaused bool, voucherResultType datatransfer.TypeIdentifier, voucherResult encoding.Encodable) (datatransfer.Response, error)
NewResponse builds a new Data Transfer response
func RestartExistingChannelRequest ¶
func RestartExistingChannelRequest(channelId datatransfer.ChannelID) datatransfer.Request
RestartExistingChannelRequest creates a request to ask the other side to restart an existing channel
func RestartResponse ¶
func RestartResponse(id datatransfer.TransferID, accepted bool, isPaused bool, voucherResultType datatransfer.TypeIdentifier, voucherResult encoding.Encodable) (datatransfer.Response, error)
RestartResponse builds a new Data Transfer response
func UpdateRequest ¶
func UpdateRequest(id datatransfer.TransferID, isPaused bool) datatransfer.Request
UpdateRequest generates a new request update
func UpdateResponse ¶
func UpdateResponse(id datatransfer.TransferID, isPaused bool) datatransfer.Response
UpdateResponse returns a new update response
func VoucherRequest ¶
func VoucherRequest(id datatransfer.TransferID, vtype datatransfer.TypeIdentifier, voucher encoding.Encodable) (datatransfer.Request, error)
VoucherRequest generates a new request for the data transfer protocol
func VoucherResultResponse ¶
func VoucherResultResponse(id datatransfer.TransferID, accepted bool, isPaused bool, voucherResultType datatransfer.TypeIdentifier, voucherResult encoding.Encodable) (datatransfer.Response, error)
VoucherResultResponse builds a new response for a voucher result
Types ¶
This section is empty.
Source Files