processors

Documentation

Index

• type FenceData
• type Privacy
  • func (g *Privacy) Define() *goka.GroupGraph
• type PrivacyV2
  • func (g *PrivacyV2) DefineV2() *goka.GroupGraph
• type SignalData
• type StatusData
  • func (d *StatusData) MarshalJSON() ([]byte, error)
  • func (d *StatusData) UnmarshalJSON(data []byte) error
• type StatusEventV2
• type StatusV2Data
• type Vehicle

Types

type FenceData

type FenceData struct {
	H3Indexes []string `json:"h3Indexes"`
}

type Privacy

type Privacy struct {
	Group        goka.Group
	StatusInput  goka.Stream
	FenceTable   goka.Table
	StatusOutput goka.Stream

	Logger *zerolog.Logger
}

func (*Privacy) Define

func (g *Privacy) Define() *goka.GroupGraph

type PrivacyV2

type PrivacyV2 struct {
	Group        goka.Group
	StatusInput  goka.Stream
	FenceTable   goka.Table
	StatusOutput goka.Stream

	Logger *zerolog.Logger
}

func (*PrivacyV2) DefineV2

func (g *PrivacyV2) DefineV2() *goka.GroupGraph

type SignalData

type SignalData struct {
	// Timestamp is in unix millis, when signal was queried
	Timestamp int64  `json:"timestamp,omitempty"`
	Name      string `json:"name,omitempty"`
	Value     any    `json:"value,omitempty"`
}

type StatusData

type StatusData struct {
	Latitude   *float64       `json:"latitude"`
	Longitude  *float64       `json:"longitude"`
	IsRedacted *bool          `json:"isRedacted"`
	Overflow   map[string]any `json:"-"`
}

func (*StatusData) MarshalJSON

func (d *StatusData) MarshalJSON() ([]byte, error)

func (*StatusData) UnmarshalJSON

func (d *StatusData) UnmarshalJSON(data []byte) error

type StatusEventV2

type StatusEventV2[A any] struct {
	shared.CloudEvent[A]
	Signature string `json:"signature"`
}

type StatusV2Data

type StatusV2Data struct {
	// Timestamp is in unix millis, when payload was sent
	Timestamp int64                  `json:"timestamp,omitempty"`
	Device    map[string]interface{} `json:"device,omitempty"`
	Vehicle   Vehicle                `json:"vehicle,omitempty"`
}

type Vehicle

type Vehicle struct {
	Make    string       `json:"make,omitempty"`
	Model   string       `json:"model,omitempty"`
	Year    int          `json:"year,omitempty"`
	Signals []SignalData `json:"signals,omitempty"`
}