message

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, isPull bool, vtype datatransfer.TypeIdentifier, ...) (datatransfer.Request, error)
• func NewResponse(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)

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, 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 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