stopwatch

Documentation

Index

• Constants
• type Stopwatch
• type StopwatchImpl
  • func New() *StopwatchImpl
  • func (sw *StopwatchImpl) Handle(ctx context.Context, e *events.MessageAccepted, ...) (bool, error)

Constants

const FunctionTypeName = "stopwatch"

Types

type Stopwatch

type Stopwatch interface {
	Handle(ctx context.Context, e *events.MessageAccepted, onchange func(prop string, value float64, ts time.Time) error) (bool, error)
}

type StopwatchImpl

type StopwatchImpl struct {
	StartTime time.Time      `json:"startTime"`
	StopTime  *time.Time     `json:"stopTime,omitempty"`
	Duration  *time.Duration `json:"duration,omitempty"`

	State bool  `json:"state"`
	Count int32 `json:"count"`

	CumulativeTime time.Duration `json:"cumulativeTime"`
}

func New

func New() *StopwatchImpl

func (*StopwatchImpl) Handle

func (sw *StopwatchImpl) Handle(ctx context.Context, e *events.MessageAccepted, onchange func(prop string, value float64, ts time.Time) error) (bool, error)