stats

Documentation

Index

• type DefaultIMetrics
  • func (d DefaultIMetrics) Get() []string
• type DefaultTSMetrics
  • func (d DefaultTSMetrics) Get() []string
• type InstanceID
• type InstanceStats
  • func InstanceStatsNew(outputLoc string, registerIDs []string, ...) *InstanceStats
  • func (stats *InstanceStats) Close()
  • func (stats *InstanceStats) OutputRecord(id InstanceID)
  • func (stats *InstanceStats) RecordCommitted(id InstanceID, atmts int, time time.Time)
  • func (stat *InstanceStats) RecordComplexStatEnd(inst InstanceID, statName, end string)
  • func (stat *InstanceStats) RecordComplexStatStart(inst InstanceID, statName, start string)
  • func (stats *InstanceStats) RecordExecuted(id InstanceID, time time.Time)
  • func (stats *InstanceStats) RecordOccurrence(inst InstanceID, stat string, count int)
  • func (stats *InstanceStats) RecordOpened(id InstanceID, time time.Time)
• type MultiOutcomeStat
  • func (stat *MultiOutcomeStat) RecordOutcome(outcome string)
• type MultiStageConditionStatConstructor
• type MultiStartMultiOutStatConstructor
  • func (stat *MultiStartMultiOutStatConstructor) Construct() *MutliStartMultiOutcomeStat
• type MutliStartMultiOutcomeStat
  • func (stat *MutliStartMultiOutcomeStat) Begin(start string)
  • func (stat *MutliStartMultiOutcomeStat) End(outcome string)
  • func (stat *MutliStartMultiOutcomeStat) OutputResult() string
• type ProposalStats
  • func ProposalStatsNew(addtitionalOrderedKeys []string, outputLoc string) *ProposalStats
  • func (stat *ProposalStats) CloseAndOutput(id InstanceID, ballot lwcproto.ConfigBal, why WhyClosedProposal)
  • func (stat *ProposalStats) CloseOutput()
  • func (stat *ProposalStats) Open(id InstanceID, ballot lwcproto.ConfigBal)
  • func (stat *ProposalStats) RecordClientValuesProposed(id InstanceID, ballot lwcproto.ConfigBal, num int)
  • func (stat *ProposalStats) RecordNoopProposed(id InstanceID, ballot lwcproto.ConfigBal)
  • func (stat *ProposalStats) RecordOccurence(id InstanceID, ballot lwcproto.ConfigBal, key string, num int)
  • func (stat *ProposalStats) RecordPreviousValueProposed(id InstanceID, ballot lwcproto.ConfigBal, num int)
• type TimeseriesStats
  • func TimeseriesStatsNew(initalRegisters []string, loc string, tick time.Duration) *TimeseriesStats
  • func (s *TimeseriesStats) Close()
  • func (s *TimeseriesStats) Get(stat string) int32
  • func (s *TimeseriesStats) GoClock()
  • func (s *TimeseriesStats) Print()
  • func (s *TimeseriesStats) PrintAndReset()
  • func (s *TimeseriesStats) Reset()
  • func (s *TimeseriesStats) Update(stat string, count int32)
• type WhyClosedProposal
  • func (why WhyClosedProposal) Int() int
  • func (why WhyClosedProposal) String() string

Types

type DefaultIMetrics

type DefaultIMetrics struct{}

func (DefaultIMetrics) Get

func (d DefaultIMetrics) Get() []string

type DefaultTSMetrics

type DefaultTSMetrics struct{}

func (DefaultTSMetrics) Get

func (d DefaultTSMetrics) Get() []string

type InstanceID

type InstanceID struct {
	Log int32
	Seq int32
}

type InstanceStats

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

func InstanceStatsNew

func InstanceStatsNew(outputLoc string, registerIDs []string, complexStatsConstructors []MultiStartMultiOutStatConstructor) *InstanceStats

func (*InstanceStats) Close

func (stats *InstanceStats) Close()

func (*InstanceStats) OutputRecord

func (stats *InstanceStats) OutputRecord(id InstanceID)

func (*InstanceStats) RecordCommitted

func (stats *InstanceStats) RecordCommitted(id InstanceID, atmts int, time time.Time)

func (*InstanceStats) RecordComplexStatEnd

func (stat *InstanceStats) RecordComplexStatEnd(inst InstanceID, statName, end string)

func (*InstanceStats) RecordComplexStatStart

func (stat *InstanceStats) RecordComplexStatStart(inst InstanceID, statName, start string)

func (*InstanceStats) RecordExecuted

func (stats *InstanceStats) RecordExecuted(id InstanceID, time time.Time)

func (*InstanceStats) RecordOccurrence

func (stats *InstanceStats) RecordOccurrence(inst InstanceID, stat string, count int)

func (*InstanceStats) RecordOpened

func (stats *InstanceStats) RecordOpened(id InstanceID, time time.Time)

type MultiOutcomeStat

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

func (*MultiOutcomeStat) RecordOutcome

func (stat *MultiOutcomeStat) RecordOutcome(outcome string)

type MultiStageConditionStatConstructor

type MultiStageConditionStatConstructor struct {
}

type MultiStartMultiOutStatConstructor

type MultiStartMultiOutStatConstructor struct {
	Name             string
	Starts           []string
	Outcomes         map[string][]string
	NegativeOutcomes map[string]string
	AssumeNegNoEnd   bool
}

func (*MultiStartMultiOutStatConstructor) Construct

func (stat *MultiStartMultiOutStatConstructor) Construct() *MutliStartMultiOutcomeStat

type MutliStartMultiOutcomeStat

type MutliStartMultiOutcomeStat struct {
	Outcomes map[string]*MultiOutcomeStat
	// contains filtered or unexported fields
}

if we start a stat it might end or might not. Need to sum up all stats that do not end properly

func (*MutliStartMultiOutcomeStat) Begin

func (stat *MutliStartMultiOutcomeStat) Begin(start string)

func (*MutliStartMultiOutcomeStat) End

func (stat *MutliStartMultiOutcomeStat) End(outcome string)

func (*MutliStartMultiOutcomeStat) OutputResult

func (stat *MutliStartMultiOutcomeStat) OutputResult() string

type ProposalStats

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

func ProposalStatsNew

func ProposalStatsNew(addtitionalOrderedKeys []string, outputLoc string) *ProposalStats

func (*ProposalStats) CloseAndOutput

func (stat *ProposalStats) CloseAndOutput(id InstanceID, ballot lwcproto.ConfigBal, why WhyClosedProposal)

func (*ProposalStats) CloseOutput

func (stat *ProposalStats) CloseOutput()

func (*ProposalStats) Open

func (stat *ProposalStats) Open(id InstanceID, ballot lwcproto.ConfigBal)

func (*ProposalStats) RecordClientValuesProposed

func (stat *ProposalStats) RecordClientValuesProposed(id InstanceID, ballot lwcproto.ConfigBal, num int)

func (*ProposalStats) RecordNoopProposed

func (stat *ProposalStats) RecordNoopProposed(id InstanceID, ballot lwcproto.ConfigBal)

func (*ProposalStats) RecordOccurence

func (stat *ProposalStats) RecordOccurence(id InstanceID, ballot lwcproto.ConfigBal, key string, num int)

func (*ProposalStats) RecordPreviousValueProposed

func (stat *ProposalStats) RecordPreviousValueProposed(id InstanceID, ballot lwcproto.ConfigBal, num int)

type TimeseriesStats

type TimeseriesStats struct {
	C chan struct{}
	// contains filtered or unexported fields
}

func TimeseriesStatsNew

func TimeseriesStatsNew(initalRegisters []string, loc string, tick time.Duration) *TimeseriesStats

func (*TimeseriesStats) Close

func (s *TimeseriesStats) Close()

func (*TimeseriesStats) Get

func (s *TimeseriesStats) Get(stat string) int32

func (*TimeseriesStats) GoClock

func (s *TimeseriesStats) GoClock()

func (*TimeseriesStats) Print

func (s *TimeseriesStats) Print()

func (*TimeseriesStats) PrintAndReset

func (s *TimeseriesStats) PrintAndReset()

func (*TimeseriesStats) Reset

func (s *TimeseriesStats) Reset()

func (*TimeseriesStats) Update

func (s *TimeseriesStats) Update(stat string, count int32)

type WhyClosedProposal

type WhyClosedProposal int

const (
	UNKNOWN WhyClosedProposal = iota
	ITWASCHOSEN
	HIGHERPROPOSALONGOING
	LOWERPROPOSALCHOSEN
)

func (WhyClosedProposal) Int

func (why WhyClosedProposal) Int() int

func (WhyClosedProposal) String

func (why WhyClosedProposal) String() string