sampler

Documentation

Index

• type OpenSlots
• type SampleInfos
• type Sampler
  • func NewSampler(instanceID string, dbService SamplerDBService) *Sampler
  • func (s Sampler) GetSamplerInfos() SampleInfos
  • func (s Sampler) HasAvailableFreeSlots() bool
  • func (s *Sampler) InitFromSampleCSV(filePath string, target int, minVal int)
  • func (s *Sampler) LoadSlotCurveFromDB()
  • func (s Sampler) NeedsRefresh() bool
  • func (s Sampler) SaveSlotCurveToDB()
• type SamplerDBService
• type SlotCurve

Types

type OpenSlots

type OpenSlots struct {
	T     int `bson:"t" json:"t"`
	Value int `bson:"value" json:"value"`
}

type SampleInfos

type SampleInfos struct {
	CurrentTime     int64 `json:"currentTimeInInterval"`
	OpenSlotsTarget int   `json:"openSlotsTarget"`
	UsedSlots       int   `json:"usedSlots"`
	AvailableSlots  int   `json:"availableSlots"`
	MaxSlots        int   `json:"maxSlots"`
}

type Sampler

type Sampler struct {
	SlotCurve SlotCurve
	// contains filtered or unexported fields
}

func NewSampler

func NewSampler(
	instanceID string,
	dbService SamplerDBService,
) *Sampler

func (Sampler) GetSamplerInfos

func (s Sampler) GetSamplerInfos() SampleInfos

func (Sampler) HasAvailableFreeSlots

func (s Sampler) HasAvailableFreeSlots() bool

func (*Sampler) InitFromSampleCSV

func (s *Sampler) InitFromSampleCSV(filePath string, target int, minVal int)

func (*Sampler) LoadSlotCurveFromDB

func (s *Sampler) LoadSlotCurveFromDB()

func (Sampler) NeedsRefresh

func (s Sampler) NeedsRefresh() bool

func (Sampler) SaveSlotCurveToDB

func (s Sampler) SaveSlotCurveToDB()

type SamplerDBService

type SamplerDBService interface {
	LoadLatestSlotCurve(instanceID string) (res SlotCurve, err error)
	SaveNewSlotCurve(instanceID string, res SlotCurve) (err error)
	GetUsedSlotsCountSince(instanceID string, ref int64) (count int64, err error)
}

type SlotCurve

type SlotCurve struct {
	ID            primitive.ObjectID `bson:"_id,omitempty" json:"id,omitempty"`
	IntervalStart int64              `bson:"intervalStart,omitempty" json:"intervalStart,omitempty"`
	OpenSlots     []OpenSlots        `bson:"openSlots,omitempty" json:"openSlots,omitempty"`
}