olap

package

v0.86.17 Latest Latest Go to latest Published: May 13, 2026 License: MIT Imports: 36 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type OLAPController interface {
	Start(ctx context.Context) error
}

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

func New(fs ...OLAPControllerOpt) (*OLAPControllerImpl, error)

func (o *OLAPControllerImpl) Start() (func() error, error)

type OLAPControllerOpt func(*OLAPControllerOpts)

func WithAlerter(a hatcheterrors.Alerter) OLAPControllerOpt

func WithAnalyzeCronInterval(interval time.Duration) OLAPControllerOpt

func WithDataDecoderValidator(dv datautils.DataDecoderValidator) OLAPControllerOpt

func WithLogger(l *zerolog.Logger) OLAPControllerOpt

func WithMQQos(qos int) OLAPControllerOpt

func WithMaxRequeueCount(count int) OLAPControllerOpt

func WithMessageQueue(mq msgqueue.MessageQueue) OLAPControllerOpt

func WithOLAPStatusUpdateBatchSizeLimits(limits v1.StatusUpdateBatchSizeLimits) OLAPControllerOpt

func WithOperationsConfig(c server.ConfigFileOperations) OLAPControllerOpt

func WithPartition(p *partition.Partition) OLAPControllerOpt

func WithPrometheusMetricsEnabled(enabled bool) OLAPControllerOpt

func WithRepository(r v1.Repository) OLAPControllerOpt

func WithSamplingConfig(c server.ConfigFileSampling) OLAPControllerOpt

func WithTenantAlertManager(ta *alerting.TenantAlertManager) OLAPControllerOpt

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

Path	Synopsis
signal