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(),
	}
}

Types

type CombinedSewageOverflow

type CombinedSewageOverflow struct {
	ID                     string        `json:"id"`
	Type                   string        `json:"type"`
	CumulativeTime         time.Duration `json:"cumulativeTime"`
	DateObserved           time.Time     `json:"dateObserved"`
	Overflows              []Overflow    `json:"overflow"`
	State                  bool          `json:"state"`
	Tenant                 string        `json:"tenant"`
	CombinedSewageOverflow *things.Thing `json:"combinedsewageoverflow,omitempty"`
}

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"`
}