combinedsewageoverflow

Documentation

Index

• Variables
• type CombinedSewageOverflow
  • func (cso CombinedSewageOverflow) Body() []byte
  • func (cso CombinedSewageOverflow) ContentType() string
  • func (cso *CombinedSewageOverflow) Handle(ctx context.Context, itm messaging.IncomingTopicMessage, tc things.Client) (bool, error)
  • func (cso CombinedSewageOverflow) TopicName() string
• type Overflow

Variables

var CombinedSewageOverflowFactory = func(id, tenant string) *CombinedSewageOverflow {
	return &CombinedSewageOverflow{
		ID:             id,
		Type:           "CombinedSewageOverflow",
		Tenant:         tenant,
		DateObserved:   time.Now().UTC(),
		CumulativeTime: 0,
	}
}

Types

type CombinedSewageOverflow

type CombinedSewageOverflow struct {
	ID                     string        `json:"id"`
	Type                   string        `json:"type"`
	CumulativeTime         time.Duration `json:"cumulativeTime"`                   // total time for all overflows
	DateObserved           time.Time     `json:"dateObserved"`                     // last time
	Overflows              []Overflow    `json:"overflow"`                         // all detected overflows
	OverflowDetected       bool          `json:"overflowDetected"`                 // true if last handled message created/updated an overflow
	OverflowObserved       *time.Time    `json:"overflowObserved,omitempty"`       // time for last overflow observation
	State                  bool          `json:"state"`                            // current state
	StateChanged           bool          `json:"stateChanged"`                     // true if last handled message changed state
	Tenant                 string        `json:"tenant"`                           // tenant
	CombinedSewageOverflow *things.Thing `json:"combinedsewageoverflow,omitempty"` // related thing
}

func (CombinedSewageOverflow) Body

func (cso CombinedSewageOverflow) Body() []byte

func (CombinedSewageOverflow) ContentType

func (cso CombinedSewageOverflow) ContentType() string

func (*CombinedSewageOverflow) Handle

func (cso *CombinedSewageOverflow) Handle(ctx context.Context, itm messaging.IncomingTopicMessage, tc things.Client) (bool, error)

func (CombinedSewageOverflow) TopicName

func (cso CombinedSewageOverflow) TopicName() string

type Overflow

type Overflow struct {
	ID        string        `json:"id"`
	State     bool          `json:"state"`
	StartTime time.Time     `json:"startTime"`
	StopTime  *time.Time    `json:"stopTime"`
	Duration  time.Duration `json:"duration"`
}