upload

package
v0.0.0-...-e6616ac Latest Latest
Warning

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

Go to latest
Published: Jan 20, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConfigLoader

type ConfigLoader func(ctx context.Context, optFns ...func(*config.LoadOptions) error) (aws.Config, error)

type FileUploader

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

func NewFileUploader

func NewFileUploader(filePath string) *FileUploader

func (*FileUploader) Upload

func (u *FileUploader) Upload(ctx context.Context, prefix string, data []byte, schema *arrow.Schema) error

type S3Client

type S3Client interface {
	PutObject(ctx context.Context, params *s3.PutObjectInput, optFns ...func(*s3.Options)) (*s3.PutObjectOutput, error)
}

type S3Uploader

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

func NewS3Uploader

func NewS3Uploader(dstPath string, cfg aws.Config) (*S3Uploader, error)

func (*S3Uploader) Upload

func (u *S3Uploader) Upload(ctx context.Context, suffix string, data []byte, _ *arrow.Schema) error

type Uploader

type Uploader interface {
	Upload(ctx context.Context, randomSnip string, data []byte, schema *arrow.Schema) error
}

func NewUploader

func NewUploader(ctx context.Context, tp string, dstPath string, loader ConfigLoader) (Uploader, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL