Versions in this module Expand all Collapse all v0 v0.1.0 Nov 13, 2019 Changes in this version + func MarshalDynamoAttributeMap(attrs map[string]*dynamodb.AttributeValue) ([]byte, error) + type AwsHelper struct + AwsSession client.ConfigProvider + DataPipe chan map[string]*dynamodb.AttributeValue + DynamoSvc dynamodbiface.DynamoDBAPI + ManifestS3 S3Manifest + Wg sync.WaitGroup + func NewAwsHelper(region string) *AwsHelper + func (h *AwsHelper) ChannelToS3(bucketName, s3Folder string, s3BufferSize int, destination *AwsHelper) + func (h *AwsHelper) ChannelToTable(tableName string, batchSize int64, waitPeriod time.Duration) + func (h *AwsHelper) CheckTableEmpty(tbl string) (int64, error) + func (h *AwsHelper) DumpBuffer(bucketName, s3Folder string, buff *bytes.Buffer) + func (h *AwsHelper) ExistsInS3(bucketName, s3Path string) (bool, error) + func (h *AwsHelper) GetFromS3(bucketName, s3Path string) (*io.ReadCloser, error) + func (h *AwsHelper) LoadManifestFromS3(bucketName, manifestPath string) error + func (h *AwsHelper) ReaderToChannel(dataReader *io.ReadCloser) error + func (h *AwsHelper) S3ToDynamo(tableName string, batchSize int64, waitPeriod time.Duration) error + func (h *AwsHelper) TableToChannel(tableName string, batchSize int64, waitPeriod time.Duration) error + func (h *AwsHelper) UploadToS3(bucketName, s3Key string, data []byte) + type CustomAttributeValue struct + B []byte + BOOL *bool + BS [][]byte + L []*CustomAttributeValue + M map[string]*CustomAttributeValue + N *string + NS []*string + NULL *bool + S *string + SS []*string + func (attr *CustomAttributeValue) Marshal(in *dynamodb.AttributeValue) + func (attr *CustomAttributeValue) Unmarshal(out *dynamodb.AttributeValue) + type S3Manifest struct + Entries []S3ManifestEntry + Name string + Version int + type S3ManifestEntry struct + Mandatory bool + URL string
Go to main page