s3

Documentation

Index

• func ParsePublishedKey(key string, execution *models.Execution, archive bool) string
• type Publisher
  • func NewPublisher(params PublisherParams) *Publisher
  • func (publisher *Publisher) IsInstalled(_ context.Context) (bool, error)
  • func (publisher *Publisher) PublishResult(ctx context.Context, execution *models.Execution, resultPath string) (models.SpecConfig, error)
  • func (publisher *Publisher) ValidateJob(_ context.Context, j models.Job) error
• type PublisherParams

Functions

func ParsePublishedKey

func ParsePublishedKey(key string, execution *models.Execution, archive bool) string

Types

type Publisher

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

func NewPublisher

func NewPublisher(params PublisherParams) *Publisher

func (*Publisher) IsInstalled

func (publisher *Publisher) IsInstalled(_ context.Context) (bool, error)

IsInstalled returns true if the S3 client is installed.

func (*Publisher) PublishResult

func (publisher *Publisher) PublishResult(
	ctx context.Context,
	execution *models.Execution,
	resultPath string,
) (models.SpecConfig, error)

func (*Publisher) ValidateJob

func (publisher *Publisher) ValidateJob(_ context.Context, j models.Job) error

ValidateJob validates the job spec and returns an error if the job is invalid.

type PublisherParams

type PublisherParams struct {
	LocalDir       string
	ClientProvider *s3helper.ClientProvider
}