message1_1

package
v1.15.3 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2023 License: Apache-2.0, MIT Imports: 15 Imported by: 0

Documentation

Index

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 FromIPLD added in v1.15.0 

func FromIPLD(nd datamodel.Node) (datatransfer.Message, error)

FromNet can read a network stream to deserialize a GraphSyncMessage

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

type TransferMessage1_1 added in v1.15.0 

type TransferMessage1_1 struct {
	IsRq bool

	Request  *TransferRequest1_1
	Response *TransferResponse1_1
}

transferMessage1_1 is the transfer message for the 1.1 Data Transfer Protocol.

func (*TransferMessage1_1) IsRequest added in v1.15.0 

func (tm *TransferMessage1_1) IsRequest() bool

IsRequest returns true if this message is a data request

func (*TransferMessage1_1) MarshalCBOR added in v1.15.0 

func (t *TransferMessage1_1) MarshalCBOR(w io.Writer) error

func (*TransferMessage1_1) ToIPLD added in v1.15.0 

func (tm *TransferMessage1_1) ToIPLD() (datamodel.Node, error)

ToNet serializes a transfer message type. It is simply a wrapper for MarshalCBOR, to provide symmetry with FromNet

func (*TransferMessage1_1) ToNet added in v1.15.0 

func (tm *TransferMessage1_1) ToNet(w io.Writer) error

ToNet serializes a transfer message type. It is simply a wrapper for MarshalCBOR, to provide symmetry with FromNet

func (*TransferMessage1_1) TransferID added in v1.15.0 

func (tm *TransferMessage1_1) TransferID() datatransfer.TransferID

TransferID returns the TransferID of this message

func (*TransferMessage1_1) UnmarshalCBOR added in v1.15.0 

func (t *TransferMessage1_1) UnmarshalCBOR(r io.Reader) error

type TransferRequest1_1 added in v1.15.0 

type TransferRequest1_1 struct {
	BCid   *cid.Cid
	Type   uint64
	Paus   bool
	Part   bool
	Pull   bool
	Stor   *cbg.Deferred
	Vouch  *cbg.Deferred
	VTyp   datatransfer.TypeIdentifier
	XferID uint64

	RestartChannel datatransfer.ChannelID
}

TransferRequest1_1 is a struct for the 1.1 Data Transfer Protocol that fulfills the datatransfer.Request interface. its members are exported to be used by cbor-gen

func (*TransferRequest1_1) BaseCid added in v1.15.0 

func (trq *TransferRequest1_1) BaseCid() cid.Cid

BaseCid returns the Base CID

func (*TransferRequest1_1) EmptyVoucher added in v1.15.0 

func (trq *TransferRequest1_1) EmptyVoucher() bool

func (*TransferRequest1_1) IsCancel added in v1.15.0 

func (trq *TransferRequest1_1) IsCancel() bool

IsCancel returns true if this is a cancel request

func (*TransferRequest1_1) IsNew added in v1.15.0 

func (trq *TransferRequest1_1) IsNew() bool

func (*TransferRequest1_1) IsPartial added in v1.15.0 

func (trq *TransferRequest1_1) IsPartial() bool

IsPartial returns true if this is a partial request

func (*TransferRequest1_1) IsPaused added in v1.15.0 

func (trq *TransferRequest1_1) IsPaused() bool

func (*TransferRequest1_1) IsPull added in v1.15.0 

func (trq *TransferRequest1_1) IsPull() bool

========= datatransfer.Request interface IsPull returns true if this is a data pull request

func (*TransferRequest1_1) IsRequest added in v1.15.0 

func (trq *TransferRequest1_1) IsRequest() bool

IsRequest always returns true in this case because this is a transfer request

func (*TransferRequest1_1) IsRestart added in v1.15.0 

func (trq *TransferRequest1_1) IsRestart() bool

func (*TransferRequest1_1) IsRestartExistingChannelRequest added in v1.15.0 

func (trq *TransferRequest1_1) IsRestartExistingChannelRequest() bool

func (*TransferRequest1_1) IsUpdate added in v1.15.0 

func (trq *TransferRequest1_1) IsUpdate() bool

func (*TransferRequest1_1) IsVoucher added in v1.15.0 

func (trq *TransferRequest1_1) IsVoucher() bool

func (*TransferRequest1_1) MarshalCBOR added in v1.15.0 

func (t *TransferRequest1_1) MarshalCBOR(w io.Writer) error

func (*TransferRequest1_1) MessageForProtocol added in v1.15.0 

func (trq *TransferRequest1_1) MessageForProtocol(targetProtocol protocol.ID) (datatransfer.Message, error)

func (*TransferRequest1_1) RestartChannelId added in v1.15.0 

func (trq *TransferRequest1_1) RestartChannelId() (datatransfer.ChannelID, error)

func (*TransferRequest1_1) Selector added in v1.15.0 

func (trq *TransferRequest1_1) Selector() (ipld.Node, error)

Selector returns the message Selector bytes

func (*TransferRequest1_1) ToIPLD added in v1.15.0 

func (trq *TransferRequest1_1) ToIPLD() (datamodel.Node, error)

func (*TransferRequest1_1) ToNet added in v1.15.0 

func (trq *TransferRequest1_1) ToNet(w io.Writer) error

ToNet serializes a transfer request. It's a wrapper for MarshalCBOR to provide symmetry with FromNet

func (*TransferRequest1_1) TransferID added in v1.15.0 

func (trq *TransferRequest1_1) TransferID() datatransfer.TransferID

func (*TransferRequest1_1) UnmarshalCBOR added in v1.15.0 

func (t *TransferRequest1_1) UnmarshalCBOR(r io.Reader) error

func (*TransferRequest1_1) Voucher added in v1.15.0 

func (trq *TransferRequest1_1) Voucher(decoder encoding.Decoder) (encoding.Encodable, error)

Voucher returns the Voucher bytes

func (*TransferRequest1_1) VoucherType added in v1.15.0 

func (trq *TransferRequest1_1) VoucherType() datatransfer.TypeIdentifier

VoucherType returns the Voucher ID

type TransferResponse1_1 added in v1.15.0 

type TransferResponse1_1 struct {
	Type   uint64
	Acpt   bool
	Paus   bool
	XferID uint64
	VRes   *cbg.Deferred
	VTyp   datatransfer.TypeIdentifier
}

TransferResponse1_1 is a private struct that satisfies the datatransfer.Response interface It is the response message for the Data Transfer 1.1 and 1.2 Protocol.

func (*TransferResponse1_1) Accepted added in v1.15.0 

func (trsp *TransferResponse1_1) Accepted() bool

Accepted returns true if the request is accepted in the response

func (*TransferResponse1_1) EmptyVoucherResult added in v1.15.0 

func (trsp *TransferResponse1_1) EmptyVoucherResult() bool

func (*TransferResponse1_1) IsCancel added in v1.15.0 

func (trsp *TransferResponse1_1) IsCancel() bool

IsCancel returns true if the responder has cancelled this response

func (*TransferResponse1_1) IsComplete added in v1.15.0 

func (trsp *TransferResponse1_1) IsComplete() bool

IsComplete returns true if the responder has completed this response

func (*TransferResponse1_1) IsNew added in v1.15.0 

func (trsp *TransferResponse1_1) IsNew() bool

IsNew returns true if this is the first response sent

func (*TransferResponse1_1) IsPaused added in v1.15.0 

func (trsp *TransferResponse1_1) IsPaused() bool

IsPaused returns true if the responder is paused

func (*TransferResponse1_1) IsRequest added in v1.15.0 

func (trsp *TransferResponse1_1) IsRequest() bool

IsRequest always returns false in this case because this is a transfer response

func (*TransferResponse1_1) IsRestart added in v1.15.0 

func (trq *TransferResponse1_1) IsRestart() bool

func (*TransferResponse1_1) IsUpdate added in v1.15.0 

func (trsp *TransferResponse1_1) IsUpdate() bool

IsUpdate returns true if this response is an update

func (*TransferResponse1_1) IsVoucherResult added in v1.15.0 

func (trsp *TransferResponse1_1) IsVoucherResult() bool

func (*TransferResponse1_1) MarshalCBOR added in v1.15.0 

func (t *TransferResponse1_1) MarshalCBOR(w io.Writer) error

func (*TransferResponse1_1) MessageForProtocol added in v1.15.0 

func (trsp *TransferResponse1_1) MessageForProtocol(targetProtocol protocol.ID) (datatransfer.Message, error)

func (*TransferResponse1_1) ToIPLD added in v1.15.0 

func (trsp *TransferResponse1_1) ToIPLD() (datamodel.Node, error)

func (*TransferResponse1_1) ToNet added in v1.15.0 

func (trsp *TransferResponse1_1) ToNet(w io.Writer) error

ToNet serializes a transfer response. It's a wrapper for MarshalCBOR to provide symmetry with FromNet

func (*TransferResponse1_1) TransferID added in v1.15.0 

func (trsp *TransferResponse1_1) TransferID() datatransfer.TransferID

func (*TransferResponse1_1) UnmarshalCBOR added in v1.15.0 

func (t *TransferResponse1_1) UnmarshalCBOR(r io.Reader) error

func (*TransferResponse1_1) VoucherResult added in v1.15.0 

func (trsp *TransferResponse1_1) VoucherResult(decoder encoding.Decoder) (encoding.Encodable, error)

func (*TransferResponse1_1) VoucherResultType added in v1.15.0 

func (trsp *TransferResponse1_1) VoucherResultType() datatransfer.TypeIdentifier

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.