awsi

Documentation

Index

• func DownloadFromS3(bucket, region, objKey string, fileHd *os.File) (int64, error)
• func GetConfig() (aws.Config, error)
• func GetDsnFromJson(dsnJson string, useLocalhost bool, poolSize int) (string, error)
• func GetDsnFromSecret(secret string, useLocalhost bool, poolSize int) (string, error)
• func GetPrivateIp() (string, error)
• func GetSecretValue(secret string) (string, error)
• func LogMetric(metricName string, dimentions *map[string]string, count int)
• func StartExecution(stateMachineARN string, stateMachineInput map[string]interface{}, name string) (string, error)
• func SyncS3Files(dbpool *pgxpool.Pool, workspaceName, keyPrefix, trimPrefix, contentType string) error
• func UploadToS3(bucket, region, objKey string, fileHd *os.File) error
• type S3Object
  • func ListS3Objects(prefix *string) ([]*S3Object, error)

Functions

func DownloadFromS3

func DownloadFromS3(bucket, region, objKey string, fileHd *os.File) (int64, error)

Download obj from s3 into fileHd (must be writable), return size of download in bytes

func GetConfig

func GetConfig() (aws.Config, error)

func GetDsnFromJson

func GetDsnFromJson(dsnJson string, useLocalhost bool, poolSize int) (string, error)

func GetDsnFromSecret

func GetDsnFromSecret(secret string, useLocalhost bool, poolSize int) (string, error)

func GetPrivateIp

func GetPrivateIp() (string, error)

func GetSecretValue

func GetSecretValue(secret string) (string, error)

func LogMetric

func LogMetric(metricName string, dimentions *map[string]string, count int)

func StartExecution

func StartExecution(stateMachineARN string, stateMachineInput map[string]interface{}, name string) (string, error)

func SyncS3Files

func SyncS3Files(dbpool *pgxpool.Pool, workspaceName, keyPrefix, trimPrefix, contentType string) error

func UploadToS3

func UploadToS3(bucket, region, objKey string, fileHd *os.File) error

upload object to S3, reading the obj from fileHd (from current position to EOF)

Types

type S3Object

type S3Object struct {
	Key  string
	Size int64
}

func ListS3Objects

func ListS3Objects(prefix *string) ([]*S3Object, error)

ListObjects lists the objects in a bucket with prefix if not nil.