server

package

v1.1.0 Latest Latest Go to latest Published: Sep 3, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kaisawind/mongodb-proxy

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AnnotationQuery(params simple_json.AnnotationQueryParams) middleware.Responder
func Error(err error) middleware.Responder
func MetricFindQuery(params simple_json.MetricFindQueryParams) middleware.Responder
func MongoAddress() string
func Query(params simple_json.QueryParams) middleware.Responder
func TestDatasource(params simple_json.TestDatasourceParams) middleware.Responder
type Cube
type Timeserie

Constants ¶

View Source

const (
	EnvPrefix           = "proxy"
	MongoAddressKey     = "mongo.address"
	MongoAddressDefault = "localhost:27017"
)

Default value

View Source

const (
	ProductURL         = "products/products"
	AertlistURL        = "alert/alertlist"
	AlarmlistURL       = "alert/alarmlist"
	DeviceURL          = "devices/"
	LogrdbURL          = "logrdb/"
	UsersURL           = "users/users"
	CubeURL            = "cube/cube_message"
	CubeVoltageURL     = "cube/cube_message/voltage"
	CubeTemperatureURL = "cube/cube_message/temperature"
	CubeCurrentURL     = "cube/cube_message/current"
	CubeFrequencyURL   = "cube/cube_message/frequency"
)

database url

Variables ¶

View Source

var (
	// Adapter mongodb instance
	Adapter database.Adapter
)

Functions ¶

func AnnotationQuery ¶

func AnnotationQuery(params simple_json.AnnotationQueryParams) middleware.Responder

AnnotationQuery POST /annotations

func Error ¶

func Error(err error) middleware.Responder

Error ...

func MetricFindQuery ¶

func MetricFindQuery(params simple_json.MetricFindQueryParams) middleware.Responder

MetricFindQuery POST /search

func MongoAddress ¶

func MongoAddress() string

MongoAddress get mongo address from env(default:"localhost:27017")

func Query ¶

func Query(params simple_json.QueryParams) middleware.Responder

Query POST /query

func TestDatasource ¶

func TestDatasource(params simple_json.TestDatasourceParams) middleware.Responder

TestDatasource GET /

Types ¶

type Cube ¶

type Cube struct {
	Voltage     int   `json:"voltage,omitempty" bson:"voltage,omitempty"`
	Temperature int   `json:"temperature,omitempty" bson:"temperature,omitempty"`
	Current     int   `json:"current,omitempty" bson:"current,omitempty"`
	Frequency   int   `json:"frequency,omitempty" bson:"frequency,omitempty"`
	Timestamp   int64 `json:"timeStamp,omitempty" bson:"timeStamp,omitempty"`
}

Cube ...

type Timeserie ¶

type Timeserie struct {
	Total     int       `json:"total,omitempty" bson:"total,omitempty"`
	Timestamp time.Time `json:"timestamp,omitempty" bson:"timestamp,omitempty"`
}

Timeserie ...

func GetCubeCurrentTimeserie ¶

func GetCubeCurrentTimeserie(dbName, cName string, options *v1.Query) ([]*Timeserie, error)

GetCubeCurrentTimeserie ...

func GetCubeFrequencyTimeserie ¶

func GetCubeFrequencyTimeserie(dbName, cName string, options *v1.Query) ([]*Timeserie, error)

GetCubeFrequencyTimeserie ...

func GetCubeTemperatureTimeserie ¶

func GetCubeTemperatureTimeserie(dbName, cName string, options *v1.Query) ([]*Timeserie, error)

GetCubeTemperatureTimeserie ...

func GetCubeTimeserie ¶

func GetCubeTimeserie(dbName, cName string, options *v1.Query) ([]*Timeserie, error)

GetCubeTimeserie ...

func GetCubeVoltageTimeserie ¶

func GetCubeVoltageTimeserie(dbName, cName string, options *v1.Query) ([]*Timeserie, error)

GetCubeVoltageTimeserie ...

func GetDevicesTimeserie ¶

func GetDevicesTimeserie(dbName, cName string, options *v1.Query) ([]*Timeserie, error)

GetDevicesTimeserie ...

func GetLogrdbTimeserie ¶

func GetLogrdbTimeserie(dbName, cName string, options *v1.Query) ([]*Timeserie, error)

GetLogrdbTimeserie ...

func GetProductsTimeserie ¶

func GetProductsTimeserie(dbName, cName string, options *v1.Query) ([]*Timeserie, error)

GetProductsTimeserie ...

db.getCollection('products').aggregate([

{
	'$match':{
		'created_at': {'$gte': "2019-03-13T10:30:56Z", '$lte': "2019-03-14T09:25:50Z"}
	}
},
{
	'$group': {
		'_id': {
			'$subtract': [
				{'$toDate': '$created_at'},
				{
					'$mod': [
						{'$toLong': {'$toDate': '$created_at'}},
						60 * 60 * 24 * 1000
					]
				}
			]
		},
		'total': {'$sum': 1}
	}
},
{
	'$project': { '_id': 0, 'timestamp': '$_id', 'total': 1}
},
{
	'$sort': { 'timestamp': 1 }
}

])

func GetUsersTimeserie ¶

func GetUsersTimeserie(dbName, cName string, options *v1.Query) ([]*Timeserie, error)

GetUsersTimeserie ...

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
database
mongodb-adapter

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL