lead

Documentation

Index

• type Config
• type CreateRequest
• type DatasetConfig
• type Lead
  • func New(ctx context.Context, log *slog.Logger, cfg Config) (*Lead, error)
  • func (l *Lead) AppendSingle(w http.ResponseWriter, r *http.Request)
  • func (l *Lead) Create(w http.ResponseWriter, r *http.Request)
  • func (l *Lead) GetDatasetInfo(w http.ResponseWriter, r *http.Request)
• type S3

Types

type Config

type Config struct {
	S3       S3
	StateDir string
}

type CreateRequest

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

type DatasetConfig

type DatasetConfig struct {
	Name           string `json:"name"`
	MaxArchiveSize uint64 `json:"max_archive_size"`
	MaxArchiveTime uint64 `json:"max_archive_time"`
}

type Lead

type Lead struct {
	http.Handler
	// contains filtered or unexported fields
}

func New

func New(
	ctx context.Context,
	log *slog.Logger,
	cfg Config,
) (*Lead, error)

func (*Lead) AppendSingle

func (l *Lead) AppendSingle(w http.ResponseWriter, r *http.Request)

func (*Lead) Create

func (l *Lead) Create(w http.ResponseWriter, r *http.Request)

func (*Lead) GetDatasetInfo

func (l *Lead) GetDatasetInfo(w http.ResponseWriter, r *http.Request)

type S3

type S3 struct {
	Endpoint        string
	AccessKeyID     string
	SecretAccessKey string
	Region          string
	Bucket          string
}