photon_download_workflow

Documentation

Index

• func Create()
• func PhotonDownload(ctx workflow.Context) error
• func Worker()
• type CheckForNewArchiveActivityResult
• type CreateLatestArchiveActivityParams
• type DownloadArchiveActivityResult
• type FetchArchiveResult
• type PhotonDownloadActivityObject
  • func (o *PhotonDownloadActivityObject) CheckForNewArchiveActivity(ctx context.Context) (*CheckForNewArchiveActivityResult, error)
  • func (o *PhotonDownloadActivityObject) CreateLatestArchiveActivity(ctx context.Context, params CreateLatestArchiveActivityParams) error
  • func (o *PhotonDownloadActivityObject) DownloadArchiveActivity(ctx context.Context) (*DownloadArchiveActivityResult, error)
  • func (o *PhotonDownloadActivityObject) UploadArchiveActivity(ctx context.Context, param UploadArchiveActivityParams) (*UploadArchiveActivityResult, error)
• type UploadArchiveActivityParams
• type UploadArchiveActivityResult

Functions

func Create

func Create()

func PhotonDownload

func PhotonDownload(ctx workflow.Context) error

func Worker

func Worker()

Types

type CheckForNewArchiveActivityResult

type CheckForNewArchiveActivityResult struct {
	NewArchiveAvailable bool
}

type CreateLatestArchiveActivityParams

type CreateLatestArchiveActivityParams struct {
	Key string
}

type DownloadArchiveActivityResult

type DownloadArchiveActivityResult struct {
	FilePath string
	Etag     string
}

type FetchArchiveResult

type FetchArchiveResult struct {
	File *os.File
	Etag string
}

type PhotonDownloadActivityObject

type PhotonDownloadActivityObject struct{}

func (*PhotonDownloadActivityObject) CheckForNewArchiveActivity

func (o *PhotonDownloadActivityObject) CheckForNewArchiveActivity(ctx context.Context) (*CheckForNewArchiveActivityResult, error)

func (*PhotonDownloadActivityObject) CreateLatestArchiveActivity

func (o *PhotonDownloadActivityObject) CreateLatestArchiveActivity(ctx context.Context, params CreateLatestArchiveActivityParams) error

func (*PhotonDownloadActivityObject) DownloadArchiveActivity

func (o *PhotonDownloadActivityObject) DownloadArchiveActivity(ctx context.Context) (*DownloadArchiveActivityResult, error)

func (*PhotonDownloadActivityObject) UploadArchiveActivity

func (o *PhotonDownloadActivityObject) UploadArchiveActivity(ctx context.Context, param UploadArchiveActivityParams) (*UploadArchiveActivityResult, error)

type UploadArchiveActivityParams

type UploadArchiveActivityParams struct {
	FilePath string
	Etag     string
}

type UploadArchiveActivityResult

type UploadArchiveActivityResult struct {
	Key string
}