Documentation ¶
Index ¶
- Constants
- Variables
- type AddPin
- type AggregateContent
- type AggregateContents
- type CleanupPreparedRequest
- type CmdParams
- type CommPComplete
- type Command
- type ComputeCommP
- type ContentFetch
- type GarbageCheck
- type Hello
- type Hi
- type Message
- type MsgParams
- type PinComplete
- type PinObj
- type PrepareForDataRequest
- type ReqTxStatus
- type RestartTransfer
- type RetrieveContent
- type SanityCheck
- type ShuttleUpdate
- type SplitComplete
- type SplitContent
- type StartTransfer
- type StorageDeal
- type TakeContent
- type TraceCarrier
- type TransferStartedOrFinished
- 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_SanityCheck = "SanityCheck"
const OP_ShuttleUpdate = "ShuttleUpdate"
const OP_SplitComplete = "SplitComplete"
const OP_TransferFinished = "TransferFinished"
const OP_TransferStarted = "TransferStarted"
const OP_TransferStatus = "TransferStatus"
const OP_UpdatePinStatus = "UpdatePinStatus"
Variables ¶
var CommandTopics = map[string]bool{ CMD_ComputeCommP: true, CMD_AddPin: true, CMD_TakeContent: true, CMD_AggregateContent: true, CMD_StartTransfer: true, CMD_PrepareForDataRequest: true, CMD_CleanupPreparedRequest: true, CMD_ReqTxStatus: true, CMD_SplitContent: true, CMD_RetrieveContent: true, CMD_UnpinContent: true, CMD_RestartTransfer: true, }
add new estuary command topic here, so shuttle consumers can be registered for them
var MessageTopics = map[string]bool{ OP_UpdatePinStatus: true, OP_PinComplete: true, OP_CommPComplete: true, OP_TransferStarted: true, OP_TransferFinished: true, OP_TransferStatus: true, OP_ShuttleUpdate: true, OP_GarbageCheck: true, OP_SplitComplete: true, OP_SanityCheck: true, }
add new shuttle operation topic here, so estaury consumers can be registered for them
Functions ¶
This section is empty.
Types ¶
type AggregateContent ¶
type AggregateContents ¶
type AggregateContents struct { DBID uint UserID uint Contents []AggregateContent }
type CleanupPreparedRequest ¶
type CmdParams ¶
type CmdParams struct { AddPin *AddPin `json:",omitempty"` ComputeCommP *ComputeCommP `json:",omitempty"` TakeContent *TakeContent `json:",omitempty"` AggregateContent *AggregateContents `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"` Handle string }
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"` Handle string }
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 *TransferStartedOrFinished `json:",omitempty"` TransferFinished *TransferStartedOrFinished `json:",omitempty"` ShuttleUpdate *ShuttleUpdate `json:",omitempty"` GarbageCheck *GarbageCheck `json:",omitempty"` SplitComplete *SplitComplete `json:",omitempty"` SanityCheck *SanityCheck `json:",omitempty"` }
type PinComplete ¶
type PrepareForDataRequest ¶
type ReqTxStatus ¶
type RestartTransfer ¶
type RestartTransfer struct { ChanID datatransfer.ChannelID DealDBID uint ContentID uint }
type RetrieveContent ¶
type RetrieveContent struct { UserID uint Content uint Cid cid.Cid Deals []StorageDeal }
type SanityCheck ¶
type SanityCheck struct { CID cid.Cid ErrMsg string }
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
}
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 TransferStartedOrFinished ¶
type TransferStartedOrFinished struct { DealDBID uint Chanid string State *filclient.ChannelState }
type TransferStatus ¶
type UnpinContent ¶
type UnpinContent struct {
Contents []uint
}
type UpdatePinStatus ¶
type UpdatePinStatus struct { DBID uint Status types.PinningStatus }