dataranges

Jul 8, 2025

Changes in this version

+ type DatarangeInfo struct

+ DataObjectKey string

+ DatarangeID int64

+ IndexObjectKey string

+ MaxDatapointKey int64

+ MinDatapointKey int64

+ SizeBytes int64

+ type ListDatarangesRequest struct

+ Datas3tName string

+ func (r *ListDatarangesRequest) Validate(ctx context.Context) error

+ type ListDatarangesResponse struct

+ Dataranges []DatarangeInfo

type UploadDatarangeServer

+ func (s *UploadDatarangeServer) ListDataranges(ctx context.Context, log *slog.Logger, req *ListDatarangesRequest) (*ListDatarangesResponse, error)

Jul 7, 2025

Changes in this version

+ var ErrInsufficientDataranges = fmt.Errorf("range must contain at least two dataranges")

+ var ErrRangeNotFullyCovered = fmt.Errorf("range is not fully covered by existing dataranges")

+ type CancelAggregateRequest struct

+ AggregateUploadID int64

+ type CompleteAggregateRequest struct

+ AggregateUploadID int64

+ UploadIDs []string

+ type DatarangeDownloadURL struct

+ DataObjectKey string

+ DatarangeID int64

+ IndexObjectKey string

+ MaxDatapointKey int64

+ MinDatapointKey int64

+ PresignedDataURL string

+ PresignedIndexURL string

+ SizeBytes int64

+ type StartAggregateRequest struct

+ Datas3tName string

+ FirstDatapointIndex uint64

+ LastDatapointIndex uint64

+ func (r *StartAggregateRequest) Validate(ctx context.Context) error

+ type StartAggregateResponse struct

+ AggregateUploadID int64

+ ObjectKey string

+ PresignedDataPutURL string

+ PresignedIndexPutURL string

+ PresignedMultipartUploadPutURLs []string

+ SourceDatarangeDownloadURLs []DatarangeDownloadURL

+ UseDirectPut bool

type UploadDatarangeServer

+ func (s *UploadDatarangeServer) CancelAggregate(ctx context.Context, log *slog.Logger, req *CancelAggregateRequest) (err error)

+ func (s *UploadDatarangeServer) CompleteAggregate(ctx context.Context, log *slog.Logger, req *CompleteAggregateRequest) (err error)

+ func (s *UploadDatarangeServer) StartAggregate(ctx context.Context, log *slog.Logger, req *StartAggregateRequest) (_ *StartAggregateResponse, err error)

Jun 30, 2025

Changes in this version

+ const MaxPartSize

+ const MaxParts

+ const MinPartSize

+ var ErrDatarangeOverlap = fmt.Errorf("datarange overlaps with existing dataranges")

+ type CancelUploadRequest struct

+ DatarangeUploadID int64

+ type CompleteUploadRequest struct

+ DatarangeUploadID int64

+ UploadIDs []string

+ type DeleteDatarangeRequest struct

+ Datas3tName string

+ FirstDatapointKey uint64

+ LastDatapointKey uint64

+ func (r *DeleteDatarangeRequest) Validate(ctx context.Context) error

+ type UploadDatarangeRequest struct

+ DataSize uint64

+ Datas3tName string

+ FirstDatapointIndex uint64

+ NumberOfDatapoints uint64

+ func (r *UploadDatarangeRequest) Validate(ctx context.Context) error

+ type UploadDatarangeResponse struct

+ DatarangeID int64

+ FirstDatapointIndex uint64

+ ObjectKey string

+ PresignedDataPutURL string

+ PresignedIndexPutURL string

+ PresignedMultipartUploadPutURLs []string

+ UseDirectPut bool

+ type UploadDatarangeServer struct

+ func NewServer(db *pgxpool.Pool, encryptionKey string) (*UploadDatarangeServer, error)

+ func (s *UploadDatarangeServer) CancelDatarangeUpload(ctx context.Context, log *slog.Logger, req *CancelUploadRequest) (err error)

+ func (s *UploadDatarangeServer) CompleteDatarangeUpload(ctx context.Context, log *slog.Logger, req *CompleteUploadRequest) (err error)

+ func (s *UploadDatarangeServer) DeleteDatarange(ctx context.Context, log *slog.Logger, req *DeleteDatarangeRequest) (err error)

+ func (s *UploadDatarangeServer) StartDatarangeUpload(ctx context.Context, log *slog.Logger, req *UploadDatarangeRequest) (_ *UploadDatarangeResponse, err error)

+ type ValidationError error