dataset

Documentation

Index

• type CreateOptions
• type Dataset
  • func Create(ctx context.Context, opts CreateOptions) (*Dataset, error)
  • func Open(ctx context.Context, log *slog.Logger, opts OpenOptions) (*Dataset, error)
  • func (d *Dataset) Append(w http.ResponseWriter, r *http.Request)
  • func (d *Dataset) Close() error
  • func (d *Dataset) Get(w http.ResponseWriter, r *http.Request)
  • func (d *Dataset) GetInfo(w http.ResponseWriter, r *http.Request)
• type DatasetConfig
• type DatasetInfo
• type OpenOptions

Types

type CreateOptions

type CreateOptions struct {
	Log      *slog.Logger
	S3Client *s3.Client
	S3Bucket string
	Config   DatasetConfig
	Name     string
	LocalDir string
}

type Dataset

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

func Create

func Create(
	ctx context.Context,
	opts CreateOptions,
) (*Dataset, error)

func Open

func Open(
	ctx context.Context,
	log *slog.Logger,
	opts OpenOptions,
) (*Dataset, error)

func (*Dataset) Append

func (d *Dataset) Append(w http.ResponseWriter, r *http.Request)

func (*Dataset) Close

func (d *Dataset) Close() error

func (*Dataset) Get

func (d *Dataset) Get(w http.ResponseWriter, r *http.Request)

func (*Dataset) GetInfo

func (d *Dataset) GetInfo(w http.ResponseWriter, r *http.Request)

type DatasetConfig

type DatasetConfig struct {
	MaxArchiveSize uint64        `json:"max_archive_size"`
	MaxArchiveTime time.Duration `json:"max_archive_time"`
}

type DatasetInfo

type DatasetInfo struct {
	Name         string        `json:"name"`
	Config       DatasetConfig `json:"config"`
	FirstIndex   uint64        `json:"first_index"`
	LastIndex    uint64        `json:"last_index"`
	StorageBytes uint64        `json:"bytes"`
}

type OpenOptions

type OpenOptions struct {
	S3Client *s3.Client
	S3Bucket string
	Name     string
	LocalDir string
}