message

Documentation

Index

• func IsTerminalFailureCode(status graphsync.ResponseStatusCode) bool
• func IsTerminalResponseCode(status graphsync.ResponseStatusCode) bool
• func IsTerminalSuccessCode(status graphsync.ResponseStatusCode) bool
• type Exportable
• type GraphSyncMessage
  • func FromNet(r io.Reader) (GraphSyncMessage, error)
  • func FromPBReader(pbr ggio.Reader) (GraphSyncMessage, error)
  • func New() GraphSyncMessage
• type GraphSyncRequest
  • func CancelRequest(id graphsync.RequestID) GraphSyncRequest
  • func NewRequest(id graphsync.RequestID, root cid.Cid, selector []byte, ...) GraphSyncRequest
  • func (gsr GraphSyncRequest) Extension(name graphsync.ExtensionName) ([]byte, bool)
  • func (gsr GraphSyncRequest) ID() graphsync.RequestID
  • func (gsr GraphSyncRequest) IsCancel() bool
  • func (gsr GraphSyncRequest) Priority() graphsync.Priority
  • func (gsr GraphSyncRequest) Root() cid.Cid
  • func (gsr GraphSyncRequest) Selector() []byte
• type GraphSyncResponse
  • func NewResponse(requestID graphsync.RequestID, status graphsync.ResponseStatusCode, ...) GraphSyncResponse
  • func (gsr GraphSyncResponse) Extension(name graphsync.ExtensionName) ([]byte, bool)
  • func (gsr GraphSyncResponse) RequestID() graphsync.RequestID
  • func (gsr GraphSyncResponse) Status() graphsync.ResponseStatusCode

Functions

func IsTerminalFailureCode

func IsTerminalFailureCode(status graphsync.ResponseStatusCode) bool

IsTerminalFailureCode returns true if the response code indicates the request terminated in failure.

func IsTerminalResponseCode

func IsTerminalResponseCode(status graphsync.ResponseStatusCode) bool

IsTerminalResponseCode returns true if the response code signals the end of the request

func IsTerminalSuccessCode

func IsTerminalSuccessCode(status graphsync.ResponseStatusCode) bool

IsTerminalSuccessCode returns true if the response code indicates the request terminated successfully.

Types

type Exportable

type Exportable interface {
	ToProto() *pb.Message
	ToNet(w io.Writer) error
}

Exportable is an interface that can serialize to a protobuf

type GraphSyncMessage

type GraphSyncMessage interface {
	Requests() []GraphSyncRequest

	Responses() []GraphSyncResponse

	Blocks() []blocks.Block

	AddRequest(graphSyncRequest GraphSyncRequest)

	AddResponse(graphSyncResponse GraphSyncResponse)

	AddBlock(blocks.Block)

	Empty() bool

	Exportable

	Loggable() map[string]interface{}
}

GraphSyncMessage is interface that can be serialized and deserialized to send over the GraphSync network

func FromNet

func FromNet(r io.Reader) (GraphSyncMessage, error)

FromNet can read a network stream to deserialized a GraphSyncMessage

func FromPBReader

func FromPBReader(pbr ggio.Reader) (GraphSyncMessage, error)

FromPBReader can deserialize a protobuf message into a GraphySyncMessage.

func New

func New() GraphSyncMessage

New initializes a new blank GraphSyncMessage

type GraphSyncRequest

type GraphSyncRequest struct {
	// contains filtered or unexported fields
}

GraphSyncRequest is a struct to capture data on a request contained in a GraphSyncMessage.

func CancelRequest

func CancelRequest(id graphsync.RequestID) GraphSyncRequest

CancelRequest request generates a request to cancel an in progress request

func NewRequest

func NewRequest(id graphsync.RequestID,
	root cid.Cid,
	selector []byte,
	priority graphsync.Priority,
	extensions ...graphsync.ExtensionData) GraphSyncRequest

NewRequest builds a new Graphsync request

func (GraphSyncRequest) Extension

func (gsr GraphSyncRequest) Extension(name graphsync.ExtensionName) ([]byte, bool)

Extension returns the content for an extension on a response, or errors if extension is not present

func (GraphSyncRequest) ID

func (gsr GraphSyncRequest) ID() graphsync.RequestID

ID Returns the request ID for this Request

func (GraphSyncRequest) IsCancel

func (gsr GraphSyncRequest) IsCancel() bool

IsCancel returns true if this particular request is being cancelled

func (GraphSyncRequest) Priority

func (gsr GraphSyncRequest) Priority() graphsync.Priority

Priority returns the priority of this request

func (GraphSyncRequest) Root

func (gsr GraphSyncRequest) Root() cid.Cid

Root returns the CID to the root block of this request

func (GraphSyncRequest) Selector

func (gsr GraphSyncRequest) Selector() []byte

Selector returns the byte representation of the selector for this request

type GraphSyncResponse

type GraphSyncResponse struct {
	// contains filtered or unexported fields
}

GraphSyncResponse is an struct to capture data on a response sent back in a GraphSyncMessage.

func NewResponse

func NewResponse(requestID graphsync.RequestID,
	status graphsync.ResponseStatusCode,
	extensions ...graphsync.ExtensionData) GraphSyncResponse

NewResponse builds a new Graphsync response

func (GraphSyncResponse) Extension

func (gsr GraphSyncResponse) Extension(name graphsync.ExtensionName) ([]byte, bool)

Extension returns the content for an extension on a response, or errors if extension is not present

func (GraphSyncResponse) RequestID

func (gsr GraphSyncResponse) RequestID() graphsync.RequestID

RequestID returns the request ID for this response

func (GraphSyncResponse) Status

func (gsr GraphSyncResponse) Status() graphsync.ResponseStatusCode

Status returns the status for a response