split

Documentation

Index

• Constants
• type UpdateResult
• type Updater
• type UpdaterImpl
  • func NewSplitUpdater(splitStorage storage.SplitStorage, splitFetcher service.SplitFetcher, ...) *UpdaterImpl
  • func (s *UpdaterImpl) LocalKill(splitName string, defaultTreatment string, changeNumber int64)
  • func (s *UpdaterImpl) SynchronizeFeatureFlags(ffChange *dtos.SplitChangeUpdate) (*UpdateResult, error)
  • func (s *UpdaterImpl) SynchronizeSplits(till *int64) (*UpdateResult, error)

Constants

const (
	Active   = "ACTIVE"
	Archived = "ARCHIVED"
)

Types

type UpdateResult

type UpdateResult struct {
	UpdatedSplits      []string
	ReferencedSegments []string
	NewChangeNumber    int64
	RequiresFetch      bool
}

UpdateResult encapsulates information regarding the split update performed

type Updater

type Updater interface {
	SynchronizeSplits(till *int64) (*UpdateResult, error)
	SynchronizeFeatureFlags(ffChange *dtos.SplitChangeUpdate) (*UpdateResult, error)
	LocalKill(splitName string, defaultTreatment string, changeNumber int64)
}

Updater interface

type UpdaterImpl

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

UpdaterImpl struct for split sync

func NewSplitUpdater

func NewSplitUpdater(
	splitStorage storage.SplitStorage,
	splitFetcher service.SplitFetcher,
	logger logging.LoggerInterface,
	runtimeTelemetry storage.TelemetryRuntimeProducer,
	hcMonitor application.MonitorProducerInterface,
) *UpdaterImpl

NewSplitUpdater creates new split synchronizer for processing split updates

func (*UpdaterImpl) LocalKill

func (s *UpdaterImpl) LocalKill(splitName string, defaultTreatment string, changeNumber int64)

LocalKill marks a spit as killed in local storage

func (*UpdaterImpl) SynchronizeFeatureFlags

func (s *UpdaterImpl) SynchronizeFeatureFlags(ffChange *dtos.SplitChangeUpdate) (*UpdateResult, error)

func (*UpdaterImpl) SynchronizeSplits

func (s *UpdaterImpl) SynchronizeSplits(till *int64) (*UpdateResult, error)