datas3t

package
v0.1.21 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 9, 2026 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddDatas3tRequest

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

func (*AddDatas3tRequest) Validate

func (r *AddDatas3tRequest) Validate(ctx context.Context) error

type ClearDatas3tRequest added in v0.1.9

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

func (*ClearDatas3tRequest) Validate added in v0.1.9

func (r *ClearDatas3tRequest) Validate(ctx context.Context) error

type ClearDatas3tResponse added in v0.1.9

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

type DatarangeInfo added in v0.1.3

type DatarangeInfo struct {
	Datas3tName    string
	DataObjectKey  string
	IndexObjectKey string
	FirstDatapoint int64
	LastDatapoint  int64
	UploadCounter  int64
	Size           int64
}

DatarangeInfo represents a discovered datarange

type Datas3tInfo

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 Datas3tServer

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

func NewServer

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

func (*Datas3tServer) AddDatas3t

func (s *Datas3tServer) AddDatas3t(ctx context.Context, log *slog.Logger, req *AddDatas3tRequest) (err error)

func (*Datas3tServer) ClearDatas3t added in v0.1.9

func (s *Datas3tServer) ClearDatas3t(ctx context.Context, log *slog.Logger, req *ClearDatas3tRequest) (_ *ClearDatas3tResponse, err error)

func (*Datas3tServer) DeleteDatas3t added in v0.1.16

func (s *Datas3tServer) DeleteDatas3t(ctx context.Context, log *slog.Logger, req *DeleteDatas3tRequest) (_ *DeleteDatas3tResponse, err error)

func (*Datas3tServer) GetDatapointsBitmap added in v0.1.2

func (s *Datas3tServer) GetDatapointsBitmap(ctx context.Context, log *slog.Logger, datas3tName string) (*roaring64.Bitmap, error)

func (*Datas3tServer) GetEncryptor added in v0.1.12

func (s *Datas3tServer) GetEncryptor() *crypto.CredentialEncryptor

func (*Datas3tServer) ImportDatas3t added in v0.1.3

func (s *Datas3tServer) ImportDatas3t(ctx context.Context, log *slog.Logger, req *ImportDatas3tRequest) (_ *ImportDatas3tResponse, err error)

func (*Datas3tServer) ListDatas3ts

func (s *Datas3tServer) ListDatas3ts(ctx context.Context, log *slog.Logger) ([]Datas3tInfo, error)

type DeleteDatas3tRequest added in v0.1.16

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

func (*DeleteDatas3tRequest) Validate added in v0.1.16

func (r *DeleteDatas3tRequest) Validate(ctx context.Context) error

type DeleteDatas3tResponse added in v0.1.16

type DeleteDatas3tResponse struct{}

type ImportDatas3tRequest added in v0.1.3

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

func (*ImportDatas3tRequest) Validate added in v0.1.3

func (r *ImportDatas3tRequest) Validate(ctx context.Context) error

type ImportDatas3tResponse added in v0.1.3

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

type ValidationError

type ValidationError error

Jump to

Keyboard shortcuts

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