recorder

Documentation

Index

• Variables
• func HandleFunc(w http.ResponseWriter, r *http.Request)
• type AdStructure
• type BigQueryRecorder
  • func NewBigQueryRecorder(ctx context.Context, projectID string) (*BigQueryRecorder, error)
  • func (r *BigQueryRecorder) Close()
  • func (r *BigQueryRecorder) Record(ctx context.Context, records []Record) error
• type DevicesSchema
• type Parser
  • func NewParser() *Parser
  • func (p *Parser) ParseMessage(msg string) ([]Record, error)
• type Record
• type RecordType
• type Recorder
• type StdoutRecorder
  • func NewStdoutRecorder() *StdoutRecorder
  • func (r *StdoutRecorder) Close()
  • func (r *StdoutRecorder) Record(ctx context.Context, records []Record) error

Variables

var RecordTypes = struct {
	Battery,
	Temperature,
	Humidity,
	PowerOn,
	Load RecordType
}{
	Battery:     "Battery",
	Temperature: "Temperature",
	Humidity:    "Humidity",
	PowerOn:     "PowerOn",
	Load:        "Load",
}

Functions

func HandleFunc

func HandleFunc(w http.ResponseWriter, r *http.Request)

Types

type AdStructure

type AdStructure struct {
	Time          time.Time
	DeviceAddress string
	AdType        int
	Data          string
}

type BigQueryRecorder

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

func NewBigQueryRecorder

func NewBigQueryRecorder(ctx context.Context, projectID string) (*BigQueryRecorder, error)

func (*BigQueryRecorder) Close

func (r *BigQueryRecorder) Close()

func (*BigQueryRecorder) Record

func (r *BigQueryRecorder) Record(ctx context.Context, records []Record) error

type DevicesSchema

type DevicesSchema struct {
	StatusCode int `json:"statusCode"`
	Body       struct {
		DeviceList []struct {
			DeviceId           string `json:"deviceId"`
			DeviceName         string `json:"deviceName"`
			DeviceType         string `json:"deviceType"`
			EnableCloudService bool   `json:"enableCloudService"`
			HubDeviceId        string `json:"hubDeviceId"`
		} `json:"deviceList"`
		InfraredRemoteList []struct {
			DeviceId    string `json:"deviceId"`
			DeviceName  string `json:"deviceName"`
			RemoteType  string `json:"remoteType"`
			HubDeviceId string `json:"hubDeviceId"`
		} `json:"infraredRemoteList"`
	} `json:"body"`
	Message string `json:"message"`
}

type Parser

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

func NewParser

func NewParser() *Parser

func (*Parser) ParseMessage

func (p *Parser) ParseMessage(msg string) ([]Record, error)

type Record

type Record struct {
	Time     time.Time
	DeviceId string
	Type     RecordType
	Value    float32
}

type RecordType

type RecordType string

type Recorder

type Recorder interface {
	Record(ctx context.Context, r []Record) error
	Close()
}

type StdoutRecorder

type StdoutRecorder struct{}

func NewStdoutRecorder

func NewStdoutRecorder() *StdoutRecorder

func (*StdoutRecorder) Close

func (r *StdoutRecorder) Close()

func (*StdoutRecorder) Record

func (r *StdoutRecorder) Record(ctx context.Context, records []Record) error