aws

package

v1.8.1 Latest Latest Go to latest Published: Aug 24, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/patterninc/heimdall

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func GetTableMetadata(ctx context.Context, catalogID, tableName string) ([]byte, error)
func PullLogs(ctx context.Context, writer *os.File, logGroup, logStream string, ...) error
func ReadFromS3(ctx context.Context, name string) (io.ReadCloser, int64, error)
func StreamToS3(ctx context.Context, name string, write func(io.Writer) error) error
func WriteToS3(ctx context.Context, name string, data []byte, _ os.FileMode) error

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrNoTableName                 = fmt.Errorf(`no table and / or namespace name provided`)
	ErrMissingCatalogTableMetadata = fmt.Errorf(`missing table metadata in the glue catalog`)
)

Functions ¶

func GetTableMetadata ¶

func GetTableMetadata(ctx context.Context, catalogID, tableName string) ([]byte, error)

func PullLogs ¶ added in v1.3.0

func PullLogs(ctx context.Context, writer *os.File, logGroup, logStream string, chunkSize int, memoryLimit int64) error

func ReadFromS3 ¶

func ReadFromS3(ctx context.Context, name string) (io.ReadCloser, int64, error)

ReadFromS3 returns the object body as a streaming reader plus its content length. The caller is responsible for closing the reader.

func StreamToS3 ¶ added in v1.8.0

func StreamToS3(ctx context.Context, name string, write func(io.Writer) error) error

func WriteToS3 ¶

func WriteToS3(ctx context.Context, name string, data []byte, _ os.FileMode) error

WriteToS3 writes a file to S3, providing the same interface as os.WriteFile function

Types ¶

This section is empty.

Source Files ¶

View all Source files

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