event

Documentation

Index

• Constants
• Variables
• type AddPin
• type AggregateContent
• type AggregateContents
• type CleanupPreparedRequest
• type CmdParams
• type CommPComplete
• type Command
  • func (c *Command) HasTraceCarrier() bool
• type ComputeCommP
• type ContentFetch
• type GarbageCheck
• type Hello
• type Hi
• type Message
  • func (m *Message) HasTraceCarrier() bool
• 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
  • 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 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

Types

type AddPin

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

type AggregateContent

type AggregateContent struct {
	ID   uint
	CID  cid.Cid
	Name string
}

type AggregateContents

type AggregateContents struct {
	DBID     uint
	UserID   uint
	Contents []AggregateContent
}

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       *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

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
	Peers  []*peer.AddrInfo
}

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
	ContentAddingDisabled bool
	QueueEngEnabled       bool
}

type Hi

type Hi struct {
	QueueEngEnabled bool
}

type Message

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

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  *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 PinComplete struct {
	DBID    uint
	Size    int64
	CID     cid.Cid
	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
	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 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
}

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 TransferStatus struct {
	Message  string
	Chanid   string
	DealDBID uint
	State    *filclient.ChannelState
	Failed   bool
}

type UnpinContent

type UnpinContent struct {
	Contents []uint
}

type UpdatePinStatus

type UpdatePinStatus struct {
	DBID   uint
	Status types.PinningStatus
}