s3

package
v0.0.16 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 22, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	IntegrationActionType_UploadObject   = "upload_object"
	IntegrationActionType_DownloadObject = "download_object"
	IntegrationActionType_DeleteObject   = "delete_object"
	IntegrationActionType_ListObjects    = "list_objects"
	IntegrationActionType_CopyObject     = "copy_object"
	IntegrationActionType_GetObjectInfo  = "get_object_info"
	IntegrationActionType_CreateBucket   = "create_bucket"
	IntegrationActionType_DeleteBucket   = "delete_bucket"
)
View Source 
const (
	S3IntegrationPeekable_Buckets  = "buckets"
	S3IntegrationPeekable_Objects  = "objects"
	S3IntegrationPeekable_Prefixes = "prefixes"
	S3IntegrationPeekable_Regions  = "regions"
)

Variables

View Source 
var (
	Schema = schema
)

Functions

func NewS3IntegrationCreator 

func NewS3IntegrationCreator(deps domain.IntegrationDeps) domain.IntegrationCreator

Types

type CopyObjectParams 

type CopyObjectParams struct {
	SourceBucket      string `json:"source_bucket"`
	SourceKey         string `json:"source_key"`
	DestinationBucket string `json:"destination_bucket"`
	DestinationKey    string `json:"destination_key"`
}

Copy Object

type CreateBucketParams 

type CreateBucketParams struct {
	Bucket string `json:"bucket"`
	ACL    string `json:"acl"`
}

Create Bucket

type DeleteBucketParams 

type DeleteBucketParams struct {
	Bucket string `json:"bucket"`
}

Delete Bucket

type DeleteObjectParams 

type DeleteObjectParams struct {
	Bucket string `json:"bucket"`
	Key    string `json:"key"`
}

Delete Object

type DownloadObjectParams 

type DownloadObjectParams struct {
	Bucket string `json:"bucket"`
	Key    string `json:"key"`
}

type GetObjectInfoParams 

type GetObjectInfoParams struct {
	Bucket string `json:"bucket"`
	Key    string `json:"key"`
}

Get Object Info

type ListObjectsParams 

type ListObjectsParams struct {
	Bucket  string `json:"bucket"`
	Prefix  string `json:"prefix"`
	MaxKeys int64  `json:"max_keys"`
}

List Objects

type PeekObjectsParams 

type PeekObjectsParams struct {
	Bucket string `json:"bucket"`
	Prefix string `json:"prefix"`
}

type PeekPrefixesParams 

type PeekPrefixesParams struct {
	Bucket string `json:"bucket"`
}

type S3Credential 

type S3Credential struct {
	AccessKeyID     string `json:"access_key_id"`
	SecretAccessKey string `json:"secret_access_key"`
	Region          string `json:"region"`
}

type S3Integration 

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

func NewS3Integration 

func NewS3Integration(ctx context.Context, deps S3IntegrationDependencies) (*S3Integration, error)

func (*S3Integration) CopyObject 

func (i *S3Integration) CopyObject(ctx context.Context, params domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*S3Integration) CreateBucket 

func (i *S3Integration) CreateBucket(ctx context.Context, params domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*S3Integration) DeleteBucket 

func (i *S3Integration) DeleteBucket(ctx context.Context, params domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*S3Integration) DeleteObject 

func (i *S3Integration) DeleteObject(ctx context.Context, params domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*S3Integration) DownloadObject 

func (i *S3Integration) DownloadObject(ctx context.Context, params domain.IntegrationInput, item domain.Item) (domain.ItemWithFile, error)

func (*S3Integration) Execute 

func (i *S3Integration) Execute(ctx context.Context, params domain.IntegrationInput) (domain.IntegrationOutput, error)

func (*S3Integration) GetObjectInfo 

func (i *S3Integration) GetObjectInfo(ctx context.Context, params domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*S3Integration) ListObjects 

func (i *S3Integration) ListObjects(ctx context.Context, params domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*S3Integration) Peek 

func (i *S3Integration) Peek(ctx context.Context, params domain.PeekParams) (domain.PeekResult, error)

func (*S3Integration) PeekBuckets 

func (i *S3Integration) PeekBuckets(ctx context.Context, params domain.PeekParams) (domain.PeekResult, error)

Peek functions

func (*S3Integration) PeekObjects 

func (i *S3Integration) PeekObjects(ctx context.Context, params domain.PeekParams) (domain.PeekResult, error)

func (*S3Integration) PeekPrefixes 

func (i *S3Integration) PeekPrefixes(ctx context.Context, params domain.PeekParams) (domain.PeekResult, error)

func (*S3Integration) PeekRegions 

func (i *S3Integration) PeekRegions(ctx context.Context, params domain.PeekParams) (domain.PeekResult, error)

func (*S3Integration) UploadObject 

func (i *S3Integration) UploadObject(ctx context.Context, params domain.IntegrationInput, item domain.Item) (domain.Item, error)

type S3IntegrationCreator 

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

func (*S3IntegrationCreator) CreateIntegration 

func (c *S3IntegrationCreator) CreateIntegration(ctx context.Context, p domain.CreateIntegrationParams) (domain.IntegrationExecutor, error)

type S3IntegrationDependencies 

type S3IntegrationDependencies struct {
	WorkspaceID  string
	CredentialID string

	CredentialGetter       domain.CredentialGetter[S3Credential]
	ParameterBinder        domain.IntegrationParameterBinder
	ExecutorStorageManager domain.ExecutorStorageManager
}

type UploadObjectParams 

type UploadObjectParams struct {
	Bucket       string          `json:"bucket"`
	Key          string          `json:"key"`
	Content      domain.FileItem `json:"content"`
	ContentType  string          `json:"content_type"`
	MetadataJSON string          `json:"metadata"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.