datasync

Documentation

Index

• func ErrCode(msg string, err error) error
• type Datasync
  • func New(opts ...DatasyncOption) Datasync
  • func (d *Datasync) CreateDatasyncLocationEfs(ctx context.Context, input *datasync.CreateLocationEfsInput) (*datasync.CreateLocationEfsOutput, error)
  • func (d *Datasync) CreateDatasyncLocationS3(ctx context.Context, input *datasync.CreateLocationS3Input) (*datasync.CreateLocationS3Output, error)
  • func (d *Datasync) CreateDatasyncTask(ctx context.Context, input *datasync.CreateTaskInput) (*datasync.CreateTaskOutput, error)
  • func (d *Datasync) DeleteDatasyncLocation(ctx context.Context, input *datasync.DeleteLocationInput) (*datasync.DeleteLocationOutput, error)
  • func (d *Datasync) DeleteDatasyncTask(ctx context.Context, input *datasync.DeleteTaskInput) (*datasync.DeleteTaskOutput, error)
  • func (d *Datasync) DescribeDatasyncLocationEfs(ctx context.Context, lArn string) (*datasync.DescribeLocationEfsOutput, error)
  • func (d *Datasync) DescribeDatasyncLocationNfs(ctx context.Context, lArn string) (*datasync.DescribeLocationNfsOutput, error)
  • func (d *Datasync) DescribeDatasyncLocationS3(ctx context.Context, lArn string) (*datasync.DescribeLocationS3Output, error)
  • func (d *Datasync) DescribeDatasyncLocationSmb(ctx context.Context, lArn string) (*datasync.DescribeLocationSmbOutput, error)
  • func (d *Datasync) DescribeDatasyncTask(ctx context.Context, tArn string) (*datasync.DescribeTaskOutput, error)
  • func (d *Datasync) DescribeTaskExecution(ctx context.Context, eArn string) (*datasync.DescribeTaskExecutionOutput, error)
  • func (d *Datasync) GetDatasyncTags(ctx context.Context, tArn string) ([]*datasync.TagListEntry, error)
  • func (d *Datasync) ListDatasyncLocations(ctx context.Context) (map[string]string, error)
  • func (d *Datasync) ListDatasyncTaskExecutions(ctx context.Context, taskArn string) ([]string, error)
  • func (d *Datasync) ListDatasyncTasks(ctx context.Context) ([]string, error)
  • func (d *Datasync) StartTaskExecution(ctx context.Context, taskArn string) (*datasync.StartTaskExecutionOutput, error)
  • func (d *Datasync) StopTaskExecution(ctx context.Context, taskArn string) error
• type DatasyncOption
  • func WithCredentials(key, secret, token, region string) DatasyncOption
  • func WithDefaultKMSKeyId(keyId string) DatasyncOption
  • func WithSession(sess *session.Session) DatasyncOption

Functions

func ErrCode

func ErrCode(msg string, err error) error

Types

type Datasync

type Datasync struct {
	Service         datasynciface.DataSyncAPI
	DefaultKMSKeyId string
	// contains filtered or unexported fields
}

Datasync is a wrapper around the aws docdb service

func New

func New(opts ...DatasyncOption) Datasync

func (*Datasync) CreateDatasyncLocationEfs

func (d *Datasync) CreateDatasyncLocationEfs(ctx context.Context, input *datasync.CreateLocationEfsInput) (*datasync.CreateLocationEfsOutput, error)

CreateDatasyncLocationEfs creates Efs datasync location

func (*Datasync) CreateDatasyncLocationS3

func (d *Datasync) CreateDatasyncLocationS3(ctx context.Context, input *datasync.CreateLocationS3Input) (*datasync.CreateLocationS3Output, error)

CreateDatasyncLocationS3 creates S3 datasync location

func (*Datasync) CreateDatasyncTask

func (d *Datasync) CreateDatasyncTask(ctx context.Context, input *datasync.CreateTaskInput) (*datasync.CreateTaskOutput, error)

CreateDatasyncTask creates a datasync task

func (*Datasync) DeleteDatasyncLocation

func (d *Datasync) DeleteDatasyncLocation(ctx context.Context, input *datasync.DeleteLocationInput) (*datasync.DeleteLocationOutput, error)

DeleteDatasyncLocation deletes a datasync location

func (*Datasync) DeleteDatasyncTask

func (d *Datasync) DeleteDatasyncTask(ctx context.Context, input *datasync.DeleteTaskInput) (*datasync.DeleteTaskOutput, error)

DeleteDatasyncTask deletes a datasync task

func (*Datasync) DescribeDatasyncLocationEfs

func (d *Datasync) DescribeDatasyncLocationEfs(ctx context.Context, lArn string) (*datasync.DescribeLocationEfsOutput, error)

DescribeDatasyncLocationEfs returns details about an EFS datasync location

func (*Datasync) DescribeDatasyncLocationNfs

func (d *Datasync) DescribeDatasyncLocationNfs(ctx context.Context, lArn string) (*datasync.DescribeLocationNfsOutput, error)

DescribeDatasyncLocationNfs returns details about an NFS datasync location

func (*Datasync) DescribeDatasyncLocationS3

func (d *Datasync) DescribeDatasyncLocationS3(ctx context.Context, lArn string) (*datasync.DescribeLocationS3Output, error)

DescribeDatasyncLocationS3 return details about an S3 datasync location

func (*Datasync) DescribeDatasyncLocationSmb

func (d *Datasync) DescribeDatasyncLocationSmb(ctx context.Context, lArn string) (*datasync.DescribeLocationSmbOutput, error)

DescribeDatasyncLocationSmb returns details about an SMB datasync location

func (*Datasync) DescribeDatasyncTask

func (d *Datasync) DescribeDatasyncTask(ctx context.Context, tArn string) (*datasync.DescribeTaskOutput, error)

DescribeDatasyncTask return details about a datasync task

func (*Datasync) DescribeTaskExecution

func (d *Datasync) DescribeTaskExecution(ctx context.Context, eArn string) (*datasync.DescribeTaskExecutionOutput, error)

func (*Datasync) GetDatasyncTags

func (d *Datasync) GetDatasyncTags(ctx context.Context, tArn string) ([]*datasync.TagListEntry, error)

GetDatasyncTags gets the tags for a documentDB cluster

func (*Datasync) ListDatasyncLocations

func (d *Datasync) ListDatasyncLocations(ctx context.Context) (map[string]string, error)

ListDatasyncLocations lists all datasync locations returns a map of Location ARNs to Location Types (s3, efs, smb, nfs)

func (*Datasync) ListDatasyncTaskExecutions

func (d *Datasync) ListDatasyncTaskExecutions(ctx context.Context, taskArn string) ([]string, error)

func (*Datasync) ListDatasyncTasks

func (d *Datasync) ListDatasyncTasks(ctx context.Context) ([]string, error)

ListDatasyncTasks lists all datasync tasks

func (*Datasync) StartTaskExecution

func (d *Datasync) StartTaskExecution(ctx context.Context, taskArn string) (*datasync.StartTaskExecutionOutput, error)

StartTaskExecution starts the execution and returns the taskexecution ARN

func (*Datasync) StopTaskExecution

func (d *Datasync) StopTaskExecution(ctx context.Context, taskArn string) error

StopTaskExecution stops the execution and returns the taskexecution ARN

type DatasyncOption

type DatasyncOption func(*Datasync)

func WithCredentials

func WithCredentials(key, secret, token, region string) DatasyncOption

func WithDefaultKMSKeyId

func WithDefaultKMSKeyId(keyId string) DatasyncOption

func WithSession

func WithSession(sess *session.Session) DatasyncOption