Documentation
¶
Overview ¶
******************************************************************************
- Copyright 2017 Dell Inc.
- Copyright (c) 2019 Intel Corporation *
- Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
- in compliance with the License. You may obtain a copy of the License at *
- http://www.apache.org/licenses/LICENSE-2.0 *
- Unless required by applicable law or agreed to in writing, software distributed under the License
- is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
- or implied. See the License for the specific language governing permissions and limitations under
- the License. ******************************************************************************
******************************************************************************
- Copyright 2017 Dell Inc.
- Copyright (c) 2019 Intel Corporation *
- Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
- in compliance with the License. You may obtain a copy of the License at *
- http://www.apache.org/licenses/LICENSE-2.0 *
- Unless required by applicable law or agreed to in writing, software distributed under the License
- is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
- or implied. See the License for the specific language governing permissions and limitations under
- the License. ******************************************************************************
Index ¶
- Constants
- func NewClient(config dtos.Configuration, lc logger.LoggingClient) (c interfaces.DataDBClient, errEdgeX error)
- type Client
- func (c *Client) AddDatabaseField(ctx context.Context, tableName string, specsType constants.SpecsType, ...) (err error)
- func (c *Client) CloseSession()
- func (c *Client) CreateStable(ctx context.Context, product models.Product) (err error)
- func (c *Client) CreateTable(ctx context.Context, stable, table string) (err error)
- func (c *Client) DelDatabaseField(ctx context.Context, tableName, code string) (err error)
- func (c *Client) DropStable(ctx context.Context, table string) (err error)
- func (c *Client) DropTable(ctx context.Context, table string) (err error)
- func (c *Client) GetDataDBType() constants.DataType
- func (c *Client) GetDeviceEvent(req dtos.ThingModelEventDataRequest, device models.Device, ...) ([]dtos.EventData, int, error)
- func (c *Client) GetDeviceEventCount(req dtos.ThingModelEventDataRequest) (int, error)
- func (c *Client) GetDeviceMsgCountByGiveTime(deviceId string, startTime, endTime int64) (int, error)
- func (c *Client) GetDeviceProperty(req dtos.ThingModelPropertyDataRequest, device models.Device) ([]dtos.ReportData, int, error)
- func (c *Client) GetDevicePropertyCount(req dtos.ThingModelPropertyDataRequest) (int, error)
- func (c *Client) GetDeviceService(req dtos.ThingModelServiceDataRequest, device models.Device, ...) ([]dtos.SaveServiceIssueData, int, error)
- func (c *Client) Insert(ctx context.Context, table string, data map[string]interface{}) (err error)
- func (c *Client) ModifyDatabaseField(ctx context.Context, tableName string, specsType constants.SpecsType, ...) (err error)
- type DriverStorageClient
- func (dsc *DriverStorageClient) All() (map[string][]byte, error)
- func (dsc *DriverStorageClient) CloseSession()
- func (dsc *DriverStorageClient) Delete(keys []string) error
- func (dsc *DriverStorageClient) Get(keys []string) (map[string][]byte, error)
- func (dsc *DriverStorageClient) Put(kvs map[string][]byte) error
- type LevelDB
Constants ¶
View Source
const ( DeviceIdDpId = "DeviceIdDpId" Tab = ":" )
Variables ¶
This section is empty.
Functions ¶
func NewClient ¶
func NewClient(config dtos.Configuration, lc logger.LoggingClient) (c interfaces.DataDBClient, errEdgeX error)
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) AddDatabaseField ¶
func (*Client) CloseSession ¶
func (c *Client) CloseSession()
func (*Client) CreateStable ¶
func (*Client) CreateTable ¶
func (*Client) DelDatabaseField ¶
func (*Client) DropStable ¶
func (*Client) GetDataDBType ¶
func (*Client) GetDeviceEvent ¶
func (*Client) GetDeviceEventCount ¶
func (c *Client) GetDeviceEventCount(req dtos.ThingModelEventDataRequest) (int, error)
func (*Client) GetDeviceMsgCountByGiveTime ¶
func (*Client) GetDeviceProperty ¶
func (c *Client) GetDeviceProperty(req dtos.ThingModelPropertyDataRequest, device models.Device) ([]dtos.ReportData, int, error)
func (*Client) GetDevicePropertyCount ¶
func (c *Client) GetDevicePropertyCount(req dtos.ThingModelPropertyDataRequest) (int, error)
func (*Client) GetDeviceService ¶
type DriverStorageClient ¶
type DriverStorageClient struct {
// contains filtered or unexported fields
}
func NewDriverStorageClient ¶
func NewDriverStorageClient(filePath, subPath string, lc logger.LoggingClient) (*DriverStorageClient, error)
func (*DriverStorageClient) CloseSession ¶
func (dsc *DriverStorageClient) CloseSession()
func (*DriverStorageClient) Delete ¶
func (dsc *DriverStorageClient) Delete(keys []string) error
Source Files
Click to show internal directories.
Click to hide internal directories.