s3

Documentation

Index

• type JsonClient
  • func NewJsonClient(driver *S3Driver) *JsonClient
  • func (s *JsonClient) GetJsonFromObject(ctx context.Context, key string) (any, error)
  • func (s *JsonClient) PutJsonIntoObject(ctx context.Context, key string, j any) error
• type PutOptions
  • func (po PutOptions) ToMinioOpts() minio.PutObjectOptions
• type S3Driver
  • func (d *S3Driver) AWSCreds() (*credentials.Credentials, error)
  • func (s3 *S3Driver) AddFlags(fs *pflag.FlagSet)
  • func (d *S3Driver) CheckConnect(ctx context.Context) error
  • func (d *S3Driver) Get(ctx context.Context, key string) (*minio.Object, error)
  • func (d *S3Driver) GetCredentials() (*credentials.Credentials, error)
  • func (d *S3Driver) MakeBucket(ctx context.Context) error
  • func (d *S3Driver) Put(ctx context.Context, key string, stream io.Reader, length int64, ...) error
  • func (d *S3Driver) RemoveBucket(ctx context.Context) error
• type SwoopS3
  • func NewSwoopS3(jsonClient *JsonClient) *SwoopS3
  • func (s *SwoopS3) GetCallbackParams(ctx context.Context, callbackUuid uuid.UUID) (any, error)
  • func (s *SwoopS3) GetInput(ctx context.Context, workflowUuid uuid.UUID) (any, error)
  • func (s *SwoopS3) GetOutput(ctx context.Context, workflowUuid uuid.UUID) (any, error)
  • func (s *SwoopS3) PutCallbackHttp(ctx context.Context, callbackUuid uuid.UUID, json any) error
  • func (s *SwoopS3) PutCallbackParams(ctx context.Context, callbackUuid uuid.UUID, json any) error
  • func (s *SwoopS3) PutWorkflowResource(ctx context.Context, workflowUuid uuid.UUID, json any) error

Types

type JsonClient

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

func NewJsonClient

func NewJsonClient(driver *S3Driver) *JsonClient

func (*JsonClient) GetJsonFromObject

func (s *JsonClient) GetJsonFromObject(ctx context.Context, key string) (any, error)

func (*JsonClient) PutJsonIntoObject

func (s *JsonClient) PutJsonIntoObject(ctx context.Context, key string, j any) error

type PutOptions

type PutOptions minio.PutObjectOptions

func (PutOptions) ToMinioOpts

func (po PutOptions) ToMinioOpts() minio.PutObjectOptions

type S3Driver

type S3Driver struct {
	Bucket   string
	Endpoint string
	Region   string
	Session  *session.Session
}

S3Driver is a driver for Object Storage (MinIO, S3, etc)

func (*S3Driver) AWSCreds

func (d *S3Driver) AWSCreds() (*credentials.Credentials, error)

func (*S3Driver) AddFlags

func (s3 *S3Driver) AddFlags(fs *pflag.FlagSet)

func (*S3Driver) CheckConnect

func (d *S3Driver) CheckConnect(ctx context.Context) error

func (*S3Driver) Get

func (d *S3Driver) Get(ctx context.Context, key string) (*minio.Object, error)

func (*S3Driver) GetCredentials

func (d *S3Driver) GetCredentials() (*credentials.Credentials, error)

func (*S3Driver) MakeBucket

func (d *S3Driver) MakeBucket(ctx context.Context) error

func (*S3Driver) Put

func (d *S3Driver) Put(
	ctx context.Context,
	key string,
	stream io.Reader,
	length int64,
	opts *PutOptions,
) error

func (*S3Driver) RemoveBucket

func (d *S3Driver) RemoveBucket(ctx context.Context) error

type SwoopS3

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

func NewSwoopS3

func NewSwoopS3(jsonClient *JsonClient) *SwoopS3

func (*SwoopS3) GetCallbackParams

func (s *SwoopS3) GetCallbackParams(ctx context.Context, callbackUuid uuid.UUID) (any, error)

func (*SwoopS3) GetInput

func (s *SwoopS3) GetInput(ctx context.Context, workflowUuid uuid.UUID) (any, error)

func (*SwoopS3) GetOutput

func (s *SwoopS3) GetOutput(ctx context.Context, workflowUuid uuid.UUID) (any, error)

func (*SwoopS3) PutCallbackHttp

func (s *SwoopS3) PutCallbackHttp(ctx context.Context, callbackUuid uuid.UUID, json any) error

func (*SwoopS3) PutCallbackParams

func (s *SwoopS3) PutCallbackParams(ctx context.Context, callbackUuid uuid.UUID, json any) error

func (*SwoopS3) PutWorkflowResource

func (s *SwoopS3) PutWorkflowResource(ctx context.Context, workflowUuid uuid.UUID, json any) error