client

type AddDatas3tRequest struct {
	Name   string `json:"name"`
	Bucket string `json:"bucket"`
}

type AggregateOptions struct {
	MaxParallelism   int              // Maximum number of concurrent downloads/uploads (default: 4)
	MaxRetries       int              // Maximum number of retry attempts per operation (default: 3)
	ProgressCallback ProgressCallback // Optional progress callback
	TempDir          string           // Directory for temporary files (default: os.TempDir())
}

type BucketInfo struct {
	Name      string `json:"name"`
	Endpoint  string `json:"endpoint"`
	Bucket    string `json:"bucket"`
	AccessKey string `json:"access_key"`
	SecretKey string `json:"secret_key"`
}

type BucketListInfo struct {
	Name     string `json:"name"`
	Endpoint string `json:"endpoint"`
	Bucket   string `json:"bucket"`
}

type CancelAggregateRequest struct {
	AggregateUploadID int64 `json:"aggregate_upload_id"`
}

type CancelUploadRequest struct {
	DatarangeUploadID int64 `json:"datarange_upload_id"`
}

type ClearDatas3tRequest struct {
	Name string `json:"name"`
}

type ClearDatas3tResponse struct {
	DatarangesDeleted int `json:"dataranges_deleted"`
	ObjectsScheduled  int `json:"objects_scheduled"`
}

type Client struct {
	// contains filtered or unexported fields
}

type CompleteAggregateRequest struct {
	AggregateUploadID int64    `json:"aggregate_upload_id"`
	UploadIDs         []string `json:"upload_ids,omitempty"` // For multipart uploads
}

type CompleteUploadRequest struct {
	DatarangeUploadID int64    `json:"datarange_upload_id"`
	UploadIDs         []string `json:"upload_ids,omitempty"` // For multipart uploads
}

type DatarangeDownloadURL struct {
	DatarangeID       int64  `json:"datarange_id"`
	DataObjectKey     string `json:"data_object_key"`
	IndexObjectKey    string `json:"index_object_key"`
	MinDatapointKey   int64  `json:"min_datapoint_key"`
	MaxDatapointKey   int64  `json:"max_datapoint_key"`
	SizeBytes         int64  `json:"size_bytes"`
	PresignedDataURL  string `json:"presigned_data_url"`
	PresignedIndexURL string `json:"presigned_index_url"`
}

type DatarangeInfo struct {
	DatarangeID     int64  `json:"datarange_id"`
	DataObjectKey   string `json:"data_object_key"`
	IndexObjectKey  string `json:"index_object_key"`
	MinDatapointKey int64  `json:"min_datapoint_key"`
	MaxDatapointKey int64  `json:"max_datapoint_key"`
	SizeBytes       int64  `json:"size_bytes"`
}

type Datas3tInfo struct {
	Datas3tName      string `json:"datas3t_name"`
	BucketName       string `json:"bucket_name"`
	DatarangeCount   int64  `json:"datarange_count"`
	TotalDatapoints  int64  `json:"total_datapoints"`
	LowestDatapoint  int64  `json:"lowest_datapoint"`
	HighestDatapoint int64  `json:"highest_datapoint"`
	TotalBytes       int64  `json:"total_bytes"`
}

type DeleteDatarangeRequest struct {
	Datas3tName       string `json:"datas3t_name"`
	FirstDatapointKey uint64 `json:"first_datapoint_key"`
	LastDatapointKey  uint64 `json:"last_datapoint_key"`
}

type DownloadOptions struct {
	MaxParallelism int   // Maximum number of concurrent downloads (default: 4)
	MaxRetries     int   // Maximum number of retry attempts per chunk (default: 3)
	ChunkSize      int64 // Size of each chunk in bytes (default: 5MB)
}

type DownloadSegment struct {
	PresignedURL string `json:"presigned_url"`
	Range        string `json:"range"`
}

type ImportDatas3tRequest struct {
	BucketName string `json:"bucket_name"`
}

type ImportDatas3tResponse struct {
	ImportedDatas3ts []string `json:"imported_datas3ts"`
	ImportedCount    int      `json:"imported_count"`
}

type ListDatarangesRequest struct {
	Datas3tName string `json:"datas3t_name"`
}

type ListDatarangesResponse struct {
	Dataranges []DatarangeInfo `json:"dataranges"`
}

type PreSignDownloadForDatapointsRequest struct {
	Datas3tName    string `json:"datas3t_name"`
	FirstDatapoint uint64 `json:"first_datapoint"`
	LastDatapoint  uint64 `json:"last_datapoint"`
}

type PreSignDownloadForDatapointsResponse struct {
	DownloadSegments []DownloadSegment `json:"download_segments"`
}

type ProgressCallback func(info ProgressInfo)

type ProgressInfo struct {
	Phase           ProgressPhase
	TotalBytes      int64
	CompletedBytes  int64
	PercentComplete float64
	CurrentStep     string
	TotalSteps      int
	CompletedSteps  int
	EstimatedETA    time.Duration
	Speed           float64 // bytes per second
	StartTime       time.Time
}

type ProgressPhase string

type StartAggregateRequest struct {
	Datas3tName         string `json:"datas3t_name"`
	FirstDatapointIndex uint64 `json:"first_datapoint_index"`
	LastDatapointIndex  uint64 `json:"last_datapoint_index"`
}

type StartAggregateResponse struct {
	AggregateUploadID int64  `json:"aggregate_upload_id"`
	ObjectKey         string `json:"object_key"`

	// Source datarange information
	SourceDatarangeDownloadURLs []DatarangeDownloadURL `json:"source_datarange_download_urls"`

	// Upload configuration
	UseDirectPut                    bool     `json:"use_direct_put"`
	PresignedMultipartUploadPutURLs []string `json:"presigned_multipart_upload_urls,omitempty"`
	PresignedDataPutURL             string   `json:"presigned_data_put_url,omitempty"`
	PresignedIndexPutURL            string   `json:"presigned_index_put_url"`
}

type TarInfo struct {
	FirstDatapointIndex int64
	NumDatapoints       int
}

type UploadDatarangeRequest struct {
	Datas3tName         string `json:"datas3t_name"`
	DataSize            uint64 `json:"data_size"`
	NumberOfDatapoints  uint64 `json:"number_of_datapoints"`
	FirstDatapointIndex uint64 `json:"first_datapoint_index"`
}

type UploadDatarangeResponse struct {
	DatarangeID         int64  `json:"datarange_id"`
	ObjectKey           string `json:"object_key"`
	FirstDatapointIndex uint64 `json:"first_datapoint_index"`
	UseDirectPut        bool   `json:"use_direct_put"`

	// For multipart uploads
	PresignedMultipartUploadPutURLs []string `json:"presigned_multipart_upload_urls,omitempty"`

	// For direct PUT uploads
	PresignedDataPutURL string `json:"presigned_data_put_url,omitempty"`

	// Common fields
	PresignedIndexPutURL string `json:"presigned_index_put_url"`
}

type UploadOptions struct {
	MaxParallelism   int              // Maximum number of concurrent uploads (default: 4)
	MaxRetries       int              // Maximum number of retry attempts per chunk (default: 3)
	ProgressCallback ProgressCallback // Optional progress callback
}

type ValidationError error