Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Transfer ¶
type Transfer struct { Id primitive.ObjectID `json:"id" bson:"_id,omitempty"` TargetId uuid.UUID `json:"targetId" bson:"target_id"` Inputs map[uuid.UUID][]uuid.UUID `json:"inputs" bson:"inputs"` // tracks which input has responded Outputs map[uuid.UUID]bool `json:"-" bson:"outputs"` Status TransferStatus `json:"status" bson:"status"` FailureReason string `json:"failureReason" bson:"failure_reason"` Expiry time.Time `json:"expiry" bson:"expiry"` }
func NewTransferModel ¶
func (*Transfer) AllNodesHandled ¶
func (*Transfer) ToApiResponse ¶
type TransferRepository ¶
type TransferRepository interface { Save(ctx context.Context, d *Transfer) error GetById(ctx context.Context, objectId primitive.ObjectID) (*Transfer, error) }
func NewTransferRepository ¶
func NewTransferRepository(ctx context.Context) (TransferRepository, error)
type TransferStatus ¶
type TransferStatus string
const ( StatusInProgress TransferStatus = "in_progress" StatusPending TransferStatus = "pending" StatusProcessComplete TransferStatus = "processing_complete" StatusComplete TransferStatus = "complete" StatusFailed TransferStatus = "failed" StatusExpired TransferStatus = "expired" )
Click to show internal directories.
Click to hide internal directories.