snapshot

type CloudPodInspector interface {
	GetCloudPod(ctx context.Context, authToken, podName string) (*api.CloudPodDetails, error)
}

type CloudPodLister interface {
	ListCloudPods(ctx context.Context, authToken, creator string) ([]api.CloudPod, error)
}

type Destination struct {
	Kind  DestinationKind
	Value string
}

type DestinationKind int

type LocalLoadClient interface {
	// ImportState posts a zip to /_localstack/pods[?merge=strategy] and streams
	// the NDJSON response. strategy is passed as-is; empty means server default.
	ImportState(ctx context.Context, host string, src io.Reader, strategy string) error
	// ResetState wipes all running state via POST /_localstack/state/reset.
	// Used to implement overwrite client-side before importing.
	ResetState(ctx context.Context, host string) error
}

type PodLoader interface {
	// LoadPodSnapshot issues PUT /_localstack/pods/{name}?merge=strategy and
	// streams the NDJSON response.
	LoadPodSnapshot(ctx context.Context, host, podName, authToken, strategy string) ([]string, error)
}

type PodRemover interface {
	RemovePodSnapshot(ctx context.Context, host, podName, authToken string) error
}

type PodSaveResult struct {
	Version  int
	Services []string
	Size     int64
}

type PodSaver interface {
	SavePodSnapshot(ctx context.Context, host, podName, authToken string) (PodSaveResult, error)
}

type RemoteClient interface {
	// S3BucketExists reports whether the named S3 bucket exists. Used to reject a
	// missing bucket before an operation, rather than letting the emulator
	// auto-create it.
	S3BucketExists(ctx context.Context, bucket string) (bool, error)
	// RegisterRemote upserts a named remote on the running emulator
	// (POST /_localstack/pods/remotes/<name>). remoteURL may contain {placeholder}
	// tokens that the emulator renders with the per-request params.
	RegisterRemote(ctx context.Context, host, name, remoteURL string) error
	// SavePodRemote saves the running state to podName on the named remote.
	SavePodRemote(ctx context.Context, host, podName, remoteName string, params map[string]string, authToken string) (PodSaveResult, error)
	// LoadPodRemote loads podName from the named remote with the given merge strategy.
	LoadPodRemote(ctx context.Context, host, podName, remoteName string, params map[string]string, authToken, strategy string) ([]string, error)
	// ListPodsRemote lists the snapshots stored on the named remote.
	ListPodsRemote(ctx context.Context, host, remoteName string, params map[string]string, authToken, creator string) ([]RemotePod, error)
}

type RemotePod struct {
	Name       string
	MaxVersion int
}

type S3Credentials struct {
	AccessKeyID     string
	SecretAccessKey string
	SessionToken    string
}

type Starter func(ctx context.Context, sink output.Sink) error

type StateExporter interface {
	ExportState(ctx context.Context, host string, dst io.Writer) error
}