collection

Documentation

Index

• Constants
• func InitProcessingWorkflow(ctx context.Context, c client.Client, event *watcher.BlobEvent) error
• func NewService(db *sql.DB, cc cadenceclient.Client) *collectionImpl
• func TriggerProcessingWorkflow(ctx context.Context, c client.Client, event *watcher.BlobEvent, ...) error
• type Collection
  • func (c Collection) Goa() *goacollection.EnduroStoredCollection
• type Service
• type Status
  • func NewStatus(status string) Status
  • func (p Status) MarshalJSON() ([]byte, error)
  • func (p Status) String() string
  • func (p *Status) UnmarshalJSON(b []byte) error

Constants

const (
	// Name of the collection processing workflow.
	ProcessingWorkflowName = "processing-workflow"

	// Maximum duration of the processing workflow. Cadence does not support
	// workflows with infinite duration for now, but high values are fine.
	// We consider a week more than enough.
	ProcessingWorkflowStartToCloseTimeout = time.Hour * 24 * 7
)

Functions

func InitProcessingWorkflow

func InitProcessingWorkflow(ctx context.Context, c client.Client, event *watcher.BlobEvent) error

func NewService

func NewService(db *sql.DB, cc cadenceclient.Client) *collectionImpl

func TriggerProcessingWorkflow

func TriggerProcessingWorkflow(ctx context.Context, c client.Client, event *watcher.BlobEvent, collectionID uint, workflowID string) error

Types

type Collection

type Collection struct {
	ID         uint   `db:"id"`
	Name       string `db:"name"`
	WorkflowID string `db:"workflow_id"`
	RunID      string `db:"run_id"`
	TransferID string `db:"transfer_id"`
	AIPID      string `db:"aip_id"`
	OriginalID string `db:"original_id"`
	Status     Status `db:"status"`

	// It defaults to CURRENT_TIMESTAMP(6) so populated as soon as possible.
	CreatedAt time.Time `db:"created_at"`

	// Nullable and only populated as soon as ingest completes.
	CompletedAt sql.NullTime `db:"completed_at"`
}

Collection represents a collection in the collection table.

func (Collection) Goa

func (c Collection) Goa() *goacollection.EnduroStoredCollection

Goa returns the API representation of the collection.

type Service

type Service interface {
	Goa() goacollection.Service
	Create(context.Context, *Collection) error
	UpdateWorkflowStatus(ctx context.Context, ID uint, name string, workflowID, runID, transferID, aipID string, status Status, storedAt time.Time) error
}

type Status

type Status uint

const (
	StatusNew Status = iota
	StatusInProgress
	StatusDone
	StatusError
	StatusUnknown
)

func NewStatus

func NewStatus(status string) Status

func (Status) MarshalJSON

func (p Status) MarshalJSON() ([]byte, error)

func (Status) String

func (p Status) String() string

func (*Status) UnmarshalJSON

func (p *Status) UnmarshalJSON(b []byte) error