drpc

Documentation

Index

• Constants
• type AddPin
• type AggregateContent
• type CleanupPreparedRequest
• type CmdParams
• type CommPComplete
• type Command
  • func (c *Command) HasTraceCarrier() bool
• type ComputeCommP
• type ContentFetch
• type GarbageCheck
• type Hello
• type Message
  • func (m *Message) HasTraceCarrier() bool
• type MsgParams
• type PinComplete
• type PinObj
• type PrepareForDataRequest
• type ReqTxStatus
• type RestartTransfer
• type RetrieveContent
• type ShuttleUpdate
• type SplitComplete
• type SplitContent
• type StartTransfer
• type StorageDeal
• type TakeContent
• type TraceCarrier
  • func NewTraceCarrier(sc trace.SpanContext) *TraceCarrier
  • func (c *TraceCarrier) AsSpanContext() trace.SpanContext
  • func (c *TraceCarrier) MarshalJSON() ([]byte, error)
  • func (c *TraceCarrier) UnmarshalJSON(b []byte) error
• type TransferStarted
• type TransferStatus
• type UnpinContent
• type UpdatePinStatus

Constants

const CMD_AddPin = "AddPin"

const CMD_AggregateContent = "AggregateContent"

const CMD_CleanupPreparedRequest = "CleanupPreparedRequest"

const CMD_ComputeCommP = "ComputeCommP"

const CMD_PrepareForDataRequest = "PrepareForDataRequest"

const CMD_ReqTxStatus = "ReqTxStatus"

const CMD_RestartTransfer = "RestartTransfer"

const CMD_RetrieveContent = "RetrieveContent"

const CMD_SplitContent = "SplitContent"

const CMD_StartTransfer = "StartTransfer"

const CMD_TakeContent = "TakeContent"

const CMD_UnpinContent = "UnpinContent"

const OP_CommPComplete = "CommPComplete"

const OP_GarbageCheck = "GarbageCheck"

const OP_PinComplete = "PinComplete"

const OP_ShuttleUpdate = "ShuttleUpdate"

const OP_SplitComplete = "SplitComplete"

const OP_TransferStarted = "TransferStarted"

const OP_TransferStatus = "TransferStatus"

const OP_UpdatePinStatus = "UpdatePinStatus"

Types

type AddPin

type AddPin struct {
	DBID   uint
	UserId uint
	Cid    cid.Cid
	Peers  []*peer.AddrInfo
}

type AggregateContent

type AggregateContent struct {
	DBID     uint
	UserID   uint
	Contents []uint
	Root     cid.Cid
	ObjData  []byte
}

type CleanupPreparedRequest

type CleanupPreparedRequest struct {
	DealDBID  uint
	AuthToken string
}

type CmdParams

type CmdParams struct {
	AddPin                 *AddPin                 `json:",omitempty"`
	ComputeCommP           *ComputeCommP           `json:",omitempty"`
	TakeContent            *TakeContent            `json:",omitempty"`
	AggregateContent       *AggregateContent       `json:",omitempty"`
	StartTransfer          *StartTransfer          `json:",omitempty"`
	PrepareForDataRequest  *PrepareForDataRequest  `json:",omitempty"`
	CleanupPreparedRequest *CleanupPreparedRequest `json:",omitempty"`
	ReqTxStatus            *ReqTxStatus            `json:",omitempty"`
	SplitContent           *SplitContent           `json:",omitempty"`
	RetrieveContent        *RetrieveContent        `json:",omitempty"`
	UnpinContent           *UnpinContent           `json:",omitempty"`
	RestartTransfer        *RestartTransfer        `json:",omitempty"`
}

type CommPComplete

type CommPComplete struct {
	Data    cid.Cid
	CommP   cid.Cid
	CarSize uint64
	Size    abi.UnpaddedPieceSize
}

type Command

type Command struct {
	Op           string
	Params       CmdParams
	TraceCarrier *TraceCarrier `json:",omitempty"`
}

func (*Command) HasTraceCarrier

func (c *Command) HasTraceCarrier() bool

HasTraceCarrier returns true iff Command `c` contains a trace.

type ComputeCommP

type ComputeCommP struct {
	Data cid.Cid
}

type ContentFetch

type ContentFetch struct {
	ID     uint
	Cid    cid.Cid
	UserID uint
}

type GarbageCheck

type GarbageCheck struct {
	Contents []uint
}

type Hello

type Hello struct {
	Host   string
	PeerID string

	DiskSpaceFree int64

	Address  address.Address
	AddrInfo peer.AddrInfo
	Private  bool
}

type Message

type Message struct {
	Op           string
	Params       MsgParams
	TraceCarrier *TraceCarrier `json:",omitempty"`
}

func (*Message) HasTraceCarrier

func (m *Message) HasTraceCarrier() bool

HasTraceCarrier returns true iff Message `m` contains a trace.

type MsgParams

type MsgParams struct {
	UpdatePinStatus *UpdatePinStatus `json:",omitempty"`
	PinComplete     *PinComplete     `json:",omitempty"`
	CommPComplete   *CommPComplete   `json:",omitempty"`
	TransferStatus  *TransferStatus  `json:",omitempty"`
	TransferStarted *TransferStarted `json:",omitempty"`
	ShuttleUpdate   *ShuttleUpdate   `json:",omitempty"`
	GarbageCheck    *GarbageCheck    `json:",omitempty"`
	SplitComplete   *SplitComplete   `json:",omitempty"`
}

type PinComplete

type PinComplete struct {
	DBID uint
	Size int64

	Objects []PinObj
}

type PinObj

type PinObj struct {
	Cid  cid.Cid
	Size int
}

type PrepareForDataRequest

type PrepareForDataRequest struct {
	DealDBID    uint
	AuthToken   string
	ProposalCid cid.Cid
	PayloadCid  cid.Cid
	Size        uint64
}

type ReqTxStatus

type ReqTxStatus struct {
	DealDBID uint
	ChanID   string
}

type RestartTransfer

type RestartTransfer struct {
	ChanID datatransfer.ChannelID
}

type RetrieveContent

type RetrieveContent struct {
	Content uint
	Cid     cid.Cid
	Deals   []StorageDeal
}

type ShuttleUpdate

type ShuttleUpdate struct {
	BlockstoreSize uint64
	BlockstoreFree uint64
	NumPins        int64
	PinQueueSize   int
}

type SplitComplete

type SplitComplete struct {
	ID uint
}

type SplitContent

type SplitContent struct {
	Content uint
	Size    int64
}

type StartTransfer

type StartTransfer struct {
	DealDBID  uint
	ContentID uint
	Miner     address.Address
	PropCid   cid.Cid
	DataCid   cid.Cid
}

type StorageDeal

type StorageDeal struct {
	Miner  address.Address
	DealID int64
}

type TakeContent

type TakeContent struct {
	Contents []ContentFetch
	Sources  []peer.AddrInfo
}

type TraceCarrier

type TraceCarrier struct {
	TraceID trace.TraceID `json:"traceID"`
	SpanID  trace.SpanID  `json:"spanID"`
	Remote  bool          `json:"remote"`
}

TraceCarrier is a wrapper that allows trace.SpanContext's to be round-tripped through JSON.

func NewTraceCarrier

func NewTraceCarrier(sc trace.SpanContext) *TraceCarrier

NewTraceCarrier accepts a trace.SpanContext and returns a TraceCarrier.

func (*TraceCarrier) AsSpanContext

func (c *TraceCarrier) AsSpanContext() trace.SpanContext

AsSpanContext converts TraceCarrier to a trace.SpanContext.

func (*TraceCarrier) MarshalJSON

func (c *TraceCarrier) MarshalJSON() ([]byte, error)

MarshalJSON converts TraceCarrier to a trace.SpanContext and marshals it to JSON.

func (*TraceCarrier) UnmarshalJSON

func (c *TraceCarrier) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshalls a serialized trace.SpanContext to a TraceCarrier.

type TransferStarted

type TransferStarted struct {
	DealDBID uint
	Chanid   string
}

type TransferStatus

type TransferStatus struct {
	Chanid   string
	DealDBID uint

	State *filclient.ChannelState

	Failed  bool
	Message string
}

type UnpinContent

type UnpinContent struct {
	Contents []uint
}

type UpdatePinStatus

type UpdatePinStatus struct {
	DBID   uint
	Status types.PinningStatus
}