warehouse

Documentation

Index

• type Warehouse
  • func NewWarehouse(ctx context.Context, logger *slog.Logger, name string, ...) (*Warehouse, error)
  • func (obj *Warehouse) Run(ctx context.Context) error

Types

type Warehouse

type Warehouse struct {
	TableRegistry operations.ITableRegistry
	Inserter      operations.IInserter
	Tasker        *tasker.Tasker
	// contains filtered or unexported fields
}

func NewWarehouse

func NewWarehouse(
	ctx context.Context,
	logger *slog.Logger,
	name string,
	tableRegistry *operations.TableRegistry,
	keyStorageOptions storage.KeyStorageOptions,
	objectStorageOptions storage.ObjectStorageOptions,
	manifestStorageOptions storage.ManifestStorageOptions,
	taskerOptions tasker.Options,
) (*Warehouse, error)

func (*Warehouse) Run

func (obj *Warehouse) Run(ctx context.Context) error