Documentation
¶
Index ¶
- type AddDatas3tRequest
- type ClearDatas3tRequest
- type ClearDatas3tResponse
- type DatarangeInfo
- type Datas3tInfo
- type Datas3tServer
- func (s *Datas3tServer) AddDatas3t(ctx context.Context, log *slog.Logger, req *AddDatas3tRequest) (err error)
- func (s *Datas3tServer) ClearDatas3t(ctx context.Context, log *slog.Logger, req *ClearDatas3tRequest) (_ *ClearDatas3tResponse, err error)
- func (s *Datas3tServer) DeleteDatas3t(ctx context.Context, log *slog.Logger, req *DeleteDatas3tRequest) (_ *DeleteDatas3tResponse, err error)
- func (s *Datas3tServer) GetDatapointsBitmap(ctx context.Context, log *slog.Logger, datas3tName string) (*roaring64.Bitmap, error)
- func (s *Datas3tServer) GetEncryptor() *crypto.CredentialEncryptor
- func (s *Datas3tServer) ImportDatas3t(ctx context.Context, log *slog.Logger, req *ImportDatas3tRequest) (_ *ImportDatas3tResponse, err error)
- func (s *Datas3tServer) ListDatas3ts(ctx context.Context, log *slog.Logger) ([]Datas3tInfo, error)
- type DeleteDatas3tRequest
- type DeleteDatas3tResponse
- type ImportDatas3tRequest
- type ImportDatas3tResponse
- type ValidationError
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddDatas3tRequest ¶
type ClearDatas3tRequest ¶ added in v0.1.9
type ClearDatas3tRequest struct {
Name string `json:"name"`
}
type ClearDatas3tResponse ¶ added in v0.1.9
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 (*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 (*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"`
}
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"`
}
type ImportDatas3tResponse ¶ added in v0.1.3
type ValidationError ¶
type ValidationError error
Click to show internal directories.
Click to hide internal directories.