Versions in this module Expand all Collapse all v0 v0.1.0 Sep 15, 2023 Changes in this version + type JsonClient struct + 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 minio.PutObjectOptions + func (po PutOptions) ToMinioOpts() minio.PutObjectOptions + type S3Driver struct + Bucket string + Endpoint string + Region string + Session *session.Session + func (d *S3Driver) AWSCreds() (*credentials.Credentials, error) + 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 + func (s3 *S3Driver) AddFlags(fs *pflag.FlagSet) + type SwoopS3 struct + 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