calculator

Documentation

Index

• func NewExperimentCalculate(httpStan *stan.Stan, stanModelID string, ...) jobs.Job
• type ExperimentLock
  • func NewExperimentLock(client redisv3.Client, lockTTL time.Duration) *ExperimentLock
  • func (el *ExperimentLock) Lock(ctx context.Context, environmentID, experimentID string) (bool, string, error)
  • func (el *ExperimentLock) Unlock(ctx context.Context, environmentID, experimentID, value string) (bool, error)

Functions

func NewExperimentCalculate

func NewExperimentCalculate(
	httpStan *stan.Stan,
	stanModelID string,
	environmentClient environmentclient.Client,
	experimentClient experimentclient.Client,
	ecClient ecclient.Client,
	mysqlClient mysql.Client,
	experimentLock *ExperimentLock,
	location *time.Location,
	opts ...jobs.Option,
) jobs.Job

Types

type ExperimentLock

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

ExperimentLock represents a distributed lock for experiments

func NewExperimentLock

func NewExperimentLock(client redisv3.Client, lockTTL time.Duration) *ExperimentLock

NewExperimentLock creates a new ExperimentLock

func (*ExperimentLock) Lock

func (el *ExperimentLock) Lock(ctx context.Context, environmentID, experimentID string) (bool, string, error)

Lock attempts to acquire the lock for a specific experiment

func (*ExperimentLock) Unlock

func (el *ExperimentLock) Unlock(ctx context.Context, environmentID, experimentID, value string) (bool, error)

Unlock releases the lock for a specific experiment