datasync

package

Go to main page

Versions in this module

v1

v1.3.0

Aug 3, 2026

v1.2.0

Aug 3, 2026

Changes in this version

+ type FilterRule struct

+ FilterType string

+ Value string

type LocationAzureBlob

+ AuthenticationType string

type LocationFsxOntap

+ FsxFilesystemArn string

type LocationS3

+ AgentArns []string

type LocationSmb

+ AuthenticationType string

type Task

+ Excludes []FilterRule

+ Includes []FilterRule

+ ManifestConfig map[string]any

+ Options map[string]any

+ Schedule *TaskSchedule

+ TaskMode string

+ TaskReportConfig map[string]any

+ type TaskSchedule struct

+ ScheduleExpression string

+ Status string

+ type TaskSettings struct

+ Excludes []FilterRule

+ Includes []FilterRule

+ ManifestConfig map[string]any

+ Options map[string]any

+ Schedule *TaskSchedule

+ TaskMode string

+ TaskReportConfig map[string]any

v1.1.4

Jul 20, 2026

v1.1.3

Jul 20, 2026

v1.1.2

Jul 20, 2026

v1.1.1

Jul 20, 2026

v1.1.0

Jul 19, 2026

Changes in this version

+ var ErrAlreadyExists = awserr.New(conflictExceptionType, awserr.ErrAlreadyExists)

+ var ErrInvalidParameter = awserr.New(invalidRequestType, awserr.ErrInvalidParameter)

+ var ErrNilAppContext = errors.New("datasync: nil app context")

+ var ErrNotFound = awserr.New(resourceNotFoundType, awserr.ErrNotFound)

+ type Agent struct

+ AgentArn string

+ CreationTime time.Time

+ EndpointType string

+ Name string

+ Status string

+ Tags map[string]string

+ type AgentListEntry struct

+ AgentArn string

+ Name string

+ Status string

+ type Ec2Config struct

+ SecurityGroupArns []string

+ SubnetArn string

+ type FsxNfsProtocol struct

+ MountOptions *MountOptions

+ type FsxProtocol struct

+ NFS *FsxNfsProtocol

+ SMB *FsxSmbProtocol

+ type FsxSmbProtocol struct

+ Domain string

+ MountOptions *MountOptions

+ Password string

+ User string

+ type Handler struct

+ Backend StorageBackend

+ func NewHandler(b StorageBackend) *Handler

+ func (h *Handler) ExtractOperation(c *echo.Context) string

+ func (h *Handler) ExtractResource(_ *echo.Context) string

+ func (h *Handler) GetSupportedOperations() []string

+ func (h *Handler) Handler() echo.HandlerFunc

+ func (h *Handler) MatchPriority() int

+ func (h *Handler) Name() string

+ func (h *Handler) Reset()

+ func (h *Handler) Restore(ctx context.Context, data []byte) error

+ func (h *Handler) RouteMatcher() service.Matcher

+ func (h *Handler) Snapshot(ctx context.Context) []byte

+ type HdfsNameNode struct

+ Hostname string

+ Port int32

+ type InMemoryBackend struct

+ func NewInMemoryBackend(accountID, region string) *InMemoryBackend

+ func (b *InMemoryBackend) AccountID() string

+ func (b *InMemoryBackend) CancelTaskExecution(taskExecutionArn string) error

+ func (b *InMemoryBackend) CreateAgent(name, _ string, tags map[string]string) (*Agent, error)

+ func (b *InMemoryBackend) CreateLocationAzureBlob(containerURL, subdirectory, blobType, accessTier string, ...) (*Location, error)

+ func (b *InMemoryBackend) CreateLocationEfs(...) (*Location, error)

+ func (b *InMemoryBackend) CreateLocationFsxLustre(fsxFilesystemArn, subdirectory string, securityGroupArns []string, ...) (*Location, error)

+ func (b *InMemoryBackend) CreateLocationFsxOntap(storageVirtualMachineArn, subdirectory string, protocol *FsxProtocol, ...) (*Location, error)

+ func (b *InMemoryBackend) CreateLocationFsxOpenZfs(fsxFilesystemArn, subdirectory string, protocol *FsxProtocol, ...) (*Location, error)

+ func (b *InMemoryBackend) CreateLocationFsxWindows(fsxFilesystemArn, subdirectory, domain, user, password string, ...) (*Location, error)

+ func (b *InMemoryBackend) CreateLocationHdfs(subdirectory, authenticationType, simpleUser string, ...) (*Location, error)

+ func (b *InMemoryBackend) CreateLocationNfs(serverHostname, subdirectory string, mountOptions *MountOptions, ...) (*Location, error)

+ func (b *InMemoryBackend) CreateLocationObjectStorage(...) (*Location, error)

+ func (b *InMemoryBackend) CreateLocationS3(subdirectory, s3BucketArn, s3StorageClass string, s3Config S3Config, ...) (*Location, error)

+ func (b *InMemoryBackend) CreateLocationSmb(serverHostname, subdirectory, domain, user, password string, ...) (*Location, error)

+ func (b *InMemoryBackend) CreateTask(sourceLocationArn, destinationLocationArn, name, cloudWatchLogGroupArn string, ...) (*Task, error)

+ func (b *InMemoryBackend) DeleteAgent(agentArn string) error

+ func (b *InMemoryBackend) DeleteLocation(locationArn string) error

+ func (b *InMemoryBackend) DeleteTask(taskArn string) error

+ func (b *InMemoryBackend) DescribeAgent(agentArn string) (*Agent, error)

+ func (b *InMemoryBackend) DescribeLocationAzureBlob(locationArn string) (*LocationAzureBlob, error)

+ func (b *InMemoryBackend) DescribeLocationEfs(locationArn string) (*LocationEfs, error)

+ func (b *InMemoryBackend) DescribeLocationFsxLustre(locationArn string) (*LocationFsxLustre, error)

+ func (b *InMemoryBackend) DescribeLocationFsxOntap(locationArn string) (*LocationFsxOntap, error)

+ func (b *InMemoryBackend) DescribeLocationFsxOpenZfs(locationArn string) (*LocationFsxOpenZfs, error)

+ func (b *InMemoryBackend) DescribeLocationFsxWindows(locationArn string) (*LocationFsxWindows, error)

+ func (b *InMemoryBackend) DescribeLocationHdfs(locationArn string) (*LocationHdfs, error)

+ func (b *InMemoryBackend) DescribeLocationNfs(locationArn string) (*LocationNfs, error)

+ func (b *InMemoryBackend) DescribeLocationObjectStorage(locationArn string) (*LocationObjectStorage, error)

+ func (b *InMemoryBackend) DescribeLocationS3(locationArn string) (*LocationS3, error)

+ func (b *InMemoryBackend) DescribeLocationSmb(locationArn string) (*LocationSmb, error)

+ func (b *InMemoryBackend) DescribeTask(taskArn string) (*Task, error)

+ func (b *InMemoryBackend) DescribeTaskExecution(taskExecutionArn string) (*TaskExecution, error)

+ func (b *InMemoryBackend) ListAgents(maxResults int32, nextToken string) ([]*AgentListEntry, string, error)

+ func (b *InMemoryBackend) ListLocations(maxResults int32, nextToken string) ([]*LocationListEntry, string, error)

+ func (b *InMemoryBackend) ListTagsForResource(resourceArn string, maxResults int32, nextToken string) (map[string]string, string, error)

+ func (b *InMemoryBackend) ListTaskExecutions(taskArn string, maxResults int32, nextToken string) ([]*TaskExecutionListEntry, string, error)

+ func (b *InMemoryBackend) ListTasks(maxResults int32, nextToken string) ([]*TaskListEntry, string, error)

+ func (b *InMemoryBackend) Region() string

+ func (b *InMemoryBackend) Reset()

+ func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error

+ func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte

+ func (b *InMemoryBackend) StartTaskExecution(taskArn string) (*TaskExecution, error)

+ func (b *InMemoryBackend) TagResource(resourceArn string, tags map[string]string) error

+ func (b *InMemoryBackend) UntagResource(resourceArn string, keys []string) error

+ func (b *InMemoryBackend) UpdateAgent(agentArn, name string) error

+ func (b *InMemoryBackend) UpdateLocationAzureBlob(locationArn, containerURL, subdirectory, blobType, accessTier string, ...) error

+ func (b *InMemoryBackend) UpdateLocationEfs(locationArn, subdirectory, accessPointArn, fileSystemAccessRoleArn, ... string, ...) error

+ func (b *InMemoryBackend) UpdateLocationFsxLustre(locationArn, subdirectory string) error

+ func (b *InMemoryBackend) UpdateLocationFsxOntap(locationArn, subdirectory string, protocol *FsxProtocol) error

+ func (b *InMemoryBackend) UpdateLocationFsxOpenZfs(locationArn, subdirectory string, protocol *FsxProtocol) error

+ func (b *InMemoryBackend) UpdateLocationFsxWindows(locationArn, subdirectory, domain, user, password string) error

+ func (b *InMemoryBackend) UpdateLocationHdfs(locationArn, subdirectory, authenticationType, simpleUser string, ...) error

+ func (b *InMemoryBackend) UpdateLocationNfs(locationArn, subdirectory string, mountOptions *MountOptions, ...) error

+ func (b *InMemoryBackend) UpdateLocationObjectStorage(locationArn, serverProtocol, subdirectory, accessKey, secretKey string, ...) error

+ func (b *InMemoryBackend) UpdateLocationS3(locationArn, subdirectory, s3StorageClass string, s3Config S3Config) error

+ func (b *InMemoryBackend) UpdateLocationSmb(locationArn, subdirectory, domain, user, password string, ...) error

+ func (b *InMemoryBackend) UpdateTask(taskArn, name, cloudWatchLogGroupArn string) error

+ func (b *InMemoryBackend) UpdateTaskExecution(taskExecutionArn string, options map[string]any) error

+ type Location struct

+ CreationTime time.Time

+ LocationArn string

+ LocationURI string

+ type LocationAzureBlob struct

+ AccessTier string

+ AgentArns []string

+ BlobType string

+ ContainerURL string

+ CreationTime time.Time

+ LocationArn string

+ LocationURI string

+ SasConfiguration *SasConfiguration

+ Subdirectory string

+ type LocationEfs struct

+ AccessPointArn string

+ CreationTime time.Time

+ Ec2Config *Ec2Config

+ EfsFilesystemArn string

+ FileSystemAccessRoleArn string

+ InTransitEncryption string

+ LocationArn string

+ LocationURI string

+ Subdirectory string

+ type LocationFsxLustre struct

+ CreationTime time.Time

+ FsxFilesystemArn string

+ LocationArn string

+ LocationURI string

+ SecurityGroupArns []string

+ Subdirectory string

+ type LocationFsxOntap struct

+ CreationTime time.Time

+ LocationArn string

+ LocationURI string

+ Protocol *FsxProtocol

+ SecurityGroupArns []string

+ StorageVirtualMachineArn string

+ Subdirectory string

+ type LocationFsxOpenZfs struct

+ CreationTime time.Time

+ FsxFilesystemArn string

+ LocationArn string

+ LocationURI string

+ Protocol *FsxProtocol

+ SecurityGroupArns []string

+ Subdirectory string

+ type LocationFsxWindows struct

+ CreationTime time.Time

+ Domain string

+ FsxFilesystemArn string

+ LocationArn string

+ LocationURI string

+ SecurityGroupArns []string

+ Subdirectory string

+ User string

+ type LocationHdfs struct

+ AgentArns []string

+ AuthenticationType string

+ BlockSize int64

+ CreationTime time.Time

+ KerberosPrincipal string

+ KmsKeyProviderURI string

+ LocationArn string

+ LocationURI string

+ NameNodes []HdfsNameNode

+ QopConfiguration *QopConfiguration

+ ReplicationFactor int32

+ SimpleUser string

+ Subdirectory string

+ type LocationListEntry struct

+ CreationTime time.Time

+ LocationArn string

+ LocationURI string

+ type LocationNfs struct

+ AgentArns []string

+ CreationTime time.Time

+ LocationArn string

+ LocationURI string

+ MountOptions *MountOptions

+ ServerHostname string

+ Subdirectory string

+ type LocationObjectStorage struct

+ AccessKey string

+ AgentArns []string

+ BucketName string

+ CreationTime time.Time

+ LocationArn string

+ LocationURI string

+ ServerHostname string

+ ServerPort int32

+ ServerProtocol string

+ Subdirectory string

+ type LocationS3 struct

+ CreationTime time.Time

+ LocationArn string

+ LocationURI string

+ S3BucketArn string

+ S3Config S3Config

+ S3StorageClass string

+ Subdirectory string

+ type LocationSmb struct

+ AgentArns []string

+ CreationTime time.Time

+ Domain string

+ LocationArn string

+ LocationURI string

+ MountOptions *MountOptions

+ ServerHostname string

+ Subdirectory string

+ User string

+ type MountOptions struct

+ Version string

+ type Provider struct

+ func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

+ func (p *Provider) Name() string

+ type QopConfiguration struct

+ DataTransferProtection string

+ RPCProtection string

+ type S3Config struct

+ BucketAccessRoleArn string

+ type SasConfiguration struct

+ Token string

+ type StorageBackend interface

+ AccountID func() string

+ CancelTaskExecution func(taskExecutionArn string) error

+ CreateAgent func(name string, activationKey string, tags map[string]string) (*Agent, error)

+ CreateLocationAzureBlob func(containerURL, subdirectory, blobType, accessTier string, ...) (*Location, error)

+ CreateLocationEfs func(...) (*Location, error)

+ CreateLocationFsxLustre func(fsxFilesystemArn, subdirectory string, securityGroupArns []string, ...) (*Location, error)

+ CreateLocationFsxOntap func(storageVirtualMachineArn, subdirectory string, protocol *FsxProtocol, ...) (*Location, error)

+ CreateLocationFsxOpenZfs func(fsxFilesystemArn, subdirectory string, protocol *FsxProtocol, ...) (*Location, error)

+ CreateLocationFsxWindows func(fsxFilesystemArn, subdirectory, domain, user, password string, ...) (*Location, error)

+ CreateLocationHdfs func(subdirectory, authenticationType, simpleUser string, ...) (*Location, error)

+ CreateLocationNfs func(serverHostname, subdirectory string, mountOptions *MountOptions, ...) (*Location, error)

+ CreateLocationObjectStorage func(...) (*Location, error)

+ CreateLocationS3 func(subdirectory, s3BucketArn, s3StorageClass string, s3Config S3Config, ...) (*Location, error)

+ CreateLocationSmb func(serverHostname, subdirectory, domain, user, password string, ...) (*Location, error)

+ CreateTask func(sourceLocationArn, destinationLocationArn, name, cloudWatchLogGroupArn string, ...) (*Task, error)

+ DeleteAgent func(agentArn string) error

+ DeleteLocation func(locationArn string) error

+ DeleteTask func(taskArn string) error

+ DescribeAgent func(agentArn string) (*Agent, error)

+ DescribeLocationAzureBlob func(locationArn string) (*LocationAzureBlob, error)

+ DescribeLocationEfs func(locationArn string) (*LocationEfs, error)

+ DescribeLocationFsxLustre func(locationArn string) (*LocationFsxLustre, error)

+ DescribeLocationFsxOntap func(locationArn string) (*LocationFsxOntap, error)

+ DescribeLocationFsxOpenZfs func(locationArn string) (*LocationFsxOpenZfs, error)

+ DescribeLocationFsxWindows func(locationArn string) (*LocationFsxWindows, error)

+ DescribeLocationHdfs func(locationArn string) (*LocationHdfs, error)

+ DescribeLocationNfs func(locationArn string) (*LocationNfs, error)

+ DescribeLocationObjectStorage func(locationArn string) (*LocationObjectStorage, error)

+ DescribeLocationS3 func(locationArn string) (*LocationS3, error)

+ DescribeLocationSmb func(locationArn string) (*LocationSmb, error)

+ DescribeTask func(taskArn string) (*Task, error)

+ DescribeTaskExecution func(taskExecutionArn string) (*TaskExecution, error)

+ ListAgents func(maxResults int32, nextToken string) ([]*AgentListEntry, string, error)

+ ListLocations func(maxResults int32, nextToken string) ([]*LocationListEntry, string, error)

+ ListTagsForResource func(resourceArn string, maxResults int32, nextToken string) (map[string]string, string, error)

+ ListTaskExecutions func(taskArn string, maxResults int32, nextToken string) ([]*TaskExecutionListEntry, string, error)

+ ListTasks func(maxResults int32, nextToken string) ([]*TaskListEntry, string, error)

+ Region func() string

+ Reset func()

+ Restore func(ctx context.Context, data []byte) error

+ Snapshot func(ctx context.Context) []byte

+ StartTaskExecution func(taskArn string) (*TaskExecution, error)

+ TagResource func(resourceArn string, tags map[string]string) error

+ UntagResource func(resourceArn string, keys []string) error

+ UpdateAgent func(agentArn, name string) error

+ UpdateLocationAzureBlob func(locationArn, containerURL, subdirectory, blobType, accessTier string, ...) error

+ UpdateLocationEfs func(locationArn, subdirectory, accessPointArn, fileSystemAccessRoleArn, ... string, ...) error

+ UpdateLocationFsxLustre func(locationArn, subdirectory string) error

+ UpdateLocationFsxOntap func(locationArn, subdirectory string, protocol *FsxProtocol) error

+ UpdateLocationFsxOpenZfs func(locationArn, subdirectory string, protocol *FsxProtocol) error

+ UpdateLocationFsxWindows func(locationArn, subdirectory, domain, user, password string) error

+ UpdateLocationHdfs func(locationArn, subdirectory, authenticationType, simpleUser string, ...) error

+ UpdateLocationNfs func(locationArn, subdirectory string, mountOptions *MountOptions, ...) error

+ UpdateLocationObjectStorage func(locationArn, serverProtocol, subdirectory, accessKey, secretKey string, ...) error

+ UpdateLocationS3 func(locationArn, subdirectory, s3StorageClass string, s3Config S3Config) error

+ UpdateLocationSmb func(locationArn, subdirectory, domain, user, password string, ...) error

+ UpdateTask func(taskArn, name, cloudWatchLogGroupArn string) error

+ UpdateTaskExecution func(taskExecutionArn string, options map[string]any) error

+ type Task struct

+ CloudWatchLogGroupArn string

+ CreationTime time.Time

+ CurrentTaskExecutionArn string

+ DestinationLocationArn string

+ Name string

+ SourceLocationArn string

+ Status string

+ Tags map[string]string

+ TaskArn string

+ type TaskExecution struct

+ BytesTransferred int64

+ EstimatedBytesToTransfer int64

+ EstimatedFilesToTransfer int64

+ FilesTransferred int64

+ Options map[string]any

+ StartTime time.Time

+ Status string

+ TaskExecutionArn string

+ type TaskExecutionListEntry struct

+ Status string

+ TaskExecutionArn string

+ type TaskListEntry struct

+ Name string

+ Status string

+ TaskArn string

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