ccloud

Documentation

Index

• func ParseArgs() (*string, *string)
• func ReadCCloudConfig(configFile string) map[string]string
• type RecordValue

Functions

func ParseArgs

func ParseArgs() (*string, *string)

ParseArgs parses the command line arguments and returns the config file and topic on success, or exits on error

func ReadCCloudConfig

func ReadCCloudConfig(configFile string) map[string]string

ReadCCloudConfig reads the file specified by configFile and creates a map of key-value pairs that correspond to each line of the file. ReadCCloudConfig returns the map on success, or exits on error

Types

type RecordValue

type RecordValue struct {
	Longitude              float64 `json:"longitude"`
	Satellite_count        int     `json:"satellite_count"`
	External_power_voltage int     `json:"external_power_voltage"`
	Version                int     `json:"version"`
	Peername               string  `json:"peername"`
	Timestamp              int64   `json:"timestamp"`
	Thing_id               string  `json:"thing_id"`
	Id                     string  `json:"id"`
	Hdop                   int     `json:"hdop"`
	Inputs                 int     `json:"inputs"`
	Protocol               string  `json:"protocol"`
	Received_timestamp     int64   `json:"received_timestamp"`
	Ignition_status        bool    `json:"ignition_status"`
	Speed                  int     `json:"speed"`
	Carrier                int     `json:"carrier"`
	Seq_num                int     `json:"seq_num"`
	Fix_timestamp          int64   `json:"fix_timestamp"`
	Latitude               float64 `json:"latitude"`
	Horometer              int     `json:"horometer"`
	Temperature            int     `json:"temperature"`
	Raw                    string  `json:"raw"`
	Device_id              string  `json:"device_id"`
	Ingestion_timestamp    int64   `json:"ingestion_timestamp"`
	Altitude               float64 `json:"altitude"`
	Main_power_on          bool    `json:"main_power_on"`
	Odometer               int     `json:"odometer"`
	Battery_level          int     `json:"battery_level"`
	Event_code             int     `json:"event_code"`
	Fix_status             int     `json:"fix_status"`
	Gprs_status            int     `json:"gprs_status"`
	Is_buffered            bool    `json:"is_buffered"`
	Rssi                   int     `json:"rssi"`
	Heading                int     `json:"heading"`
	Index                  int     `json:"index"`
}

RecordValue represents the struct of the value in a Kafka message