Documentation ¶
Index ¶
- Constants
- type AddPin
- type AggregateContent
- type CleanupPreparedRequest
- type CmdParams
- type CommPComplete
- type Command
- type ComputeCommP
- type ContentFetch
- type GarbageCheck
- type Hello
- type Message
- 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
- type TransferStarted
- type TransferStatus
- type UnpinContent
- type UpdatePinStatus
Constants ¶
View Source
const CMD_AddPin = "AddPin"
View Source
const CMD_AggregateContent = "AggregateContent"
View Source
const CMD_CleanupPreparedRequest = "CleanupPreparedRequest"
View Source
const CMD_ComputeCommP = "ComputeCommP"
View Source
const CMD_PrepareForDataRequest = "PrepareForDataRequest"
View Source
const CMD_ReqTxStatus = "ReqTxStatus"
View Source
const CMD_RestartTransfer = "RestartTransfer"
View Source
const CMD_RetrieveContent = "RetrieveContent"
View Source
const CMD_SplitContent = "SplitContent"
View Source
const CMD_StartTransfer = "StartTransfer"
View Source
const CMD_TakeContent = "TakeContent"
View Source
const CMD_UnpinContent = "UnpinContent"
View Source
const OP_CommPComplete = "CommPComplete"
View Source
const OP_GarbageCheck = "GarbageCheck"
View Source
const OP_PinComplete = "PinComplete"
View Source
const OP_ShuttleUpdate = "ShuttleUpdate"
View Source
const OP_SplitComplete = "SplitComplete"
View Source
const OP_TransferStarted = "TransferStarted"
View Source
const OP_TransferStatus = "TransferStatus"
View Source
const OP_UpdatePinStatus = "UpdatePinStatus"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AggregateContent ¶
type CleanupPreparedRequest ¶
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 ¶
HasTraceCarrier returns true iff Command `c` contains a trace.
type ComputeCommP ¶
type ComputeCommP struct {
Data cid.Cid
}
type ContentFetch ¶
type GarbageCheck ¶
type GarbageCheck struct {
Contents []uint
}
type Message ¶
type Message struct { Op string Params MsgParams TraceCarrier *TraceCarrier `json:",omitempty"` }
func (*Message) HasTraceCarrier ¶
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 PrepareForDataRequest ¶
type ReqTxStatus ¶
type RestartTransfer ¶
type RestartTransfer struct {
ChanID datatransfer.ChannelID
}
type RetrieveContent ¶
type RetrieveContent struct { Content uint Cid cid.Cid Deals []StorageDeal }
type ShuttleUpdate ¶
type SplitComplete ¶
type SplitComplete struct {
ID uint
}
type SplitContent ¶
type StartTransfer ¶
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 TransferStatus ¶
type UnpinContent ¶
type UnpinContent struct {
Contents []uint
}
type UpdatePinStatus ¶
type UpdatePinStatus struct { DBID uint Status types.PinningStatus }
Click to show internal directories.
Click to hide internal directories.