activities

Documentation

Index

• Constants
• func ParseNameLocalActivity(ctx context.Context, name string) (*nha.NameInfo, error)
• type UpdateHARIActivity
  • func NewUpdateHARIActivity(m *manager.Manager) *UpdateHARIActivity
  • func (a UpdateHARIActivity) Execute(ctx context.Context, params *UpdateHARIActivityParams) error
• type UpdateHARIActivityParams
• type UpdateProductionSystemActivity
  • func NewUpdateProductionSystemActivity(m *manager.Manager) *UpdateProductionSystemActivity
  • func (a *UpdateProductionSystemActivity) Execute(ctx context.Context, params *UpdateProductionSystemActivityParams) error
• type UpdateProductionSystemActivityParams

Constants

const (
	UpdateHARIActivityName             = "update-hari-activity"
	UpdateProductionSystemActivityName = "update-production-system-activity"
)

Functions

func ParseNameLocalActivity

func ParseNameLocalActivity(ctx context.Context, name string) (*nha.NameInfo, error)

Types

type UpdateHARIActivity

type UpdateHARIActivity struct {
	// contains filtered or unexported fields
}

func NewUpdateHARIActivity

func NewUpdateHARIActivity(m *manager.Manager) *UpdateHARIActivity

func (UpdateHARIActivity) Execute

func (a UpdateHARIActivity) Execute(ctx context.Context, params *UpdateHARIActivityParams) error

type UpdateHARIActivityParams

type UpdateHARIActivityParams struct {
	SIPID        string
	StoredAt     time.Time
	FullPath     string
	PipelineName string
	NameInfo     nha.NameInfo
}

type UpdateProductionSystemActivity

type UpdateProductionSystemActivity struct {
	// contains filtered or unexported fields
}

UpdateProductionSystemActivity sends a receipt to the production system using their filesystem interface using GoAnywhere.

func NewUpdateProductionSystemActivity

func NewUpdateProductionSystemActivity(m *manager.Manager) *UpdateProductionSystemActivity

func (*UpdateProductionSystemActivity) Execute

func (a *UpdateProductionSystemActivity) Execute(ctx context.Context, params *UpdateProductionSystemActivityParams) error

type UpdateProductionSystemActivityParams

type UpdateProductionSystemActivityParams struct {
	StoredAt     time.Time
	PipelineName string
	Status       collection.Status
	NameInfo     nha.NameInfo
}