interfaces

Documentation

Index

• type DBClient

Types

type DBClient

type DBClient interface {
	CloseSession()

	AddEvent(e model.Event) (model.Event, errors.EdgeX)
	EventById(id string) (model.Event, errors.EdgeX)
	DeleteEventById(id string) errors.EdgeX
	EventTotalCount() (uint32, errors.EdgeX)
	EventCountByDeviceName(deviceName string) (uint32, errors.EdgeX)
	EventCountByTimeRange(start int64, end int64) (uint32, errors.EdgeX)
	AllEvents(offset int, limit int) ([]model.Event, errors.EdgeX)
	EventsByDeviceName(offset int, limit int, name string) ([]model.Event, errors.EdgeX)
	DeleteEventsByDeviceName(deviceName string) errors.EdgeX
	EventsByTimeRange(start int64, end int64, offset int, limit int) ([]model.Event, errors.EdgeX)
	DeleteEventsByAge(age int64) errors.EdgeX
	ReadingTotalCount() (uint32, errors.EdgeX)
	AllReadings(offset int, limit int) ([]model.Reading, errors.EdgeX)
	ReadingsByTimeRange(start int64, end int64, offset int, limit int) ([]model.Reading, errors.EdgeX)
	ReadingsByResourceName(offset int, limit int, resourceName string) ([]model.Reading, errors.EdgeX)
	ReadingsByDeviceName(offset int, limit int, name string) ([]model.Reading, errors.EdgeX)
	ReadingsByDeviceNameAndResourceName(deviceName string, resourceName string, offset int, limit int) ([]model.Reading, errors.EdgeX)
	ReadingsByDeviceNameAndResourceNameAndTimeRange(deviceName string, resourceName string, start int64, end int64, offset int, limit int) ([]model.Reading, errors.EdgeX)
	ReadingCountByDeviceName(deviceName string) (uint32, errors.EdgeX)
	ReadingCountByResourceName(resourceName string) (uint32, errors.EdgeX)
	ReadingCountByResourceNameAndTimeRange(resourceName string, start int64, end int64) (uint32, errors.EdgeX)
	ReadingCountByDeviceNameAndResourceName(deviceName string, resourceName string) (uint32, errors.EdgeX)
	ReadingCountByDeviceNameAndResourceNameAndTimeRange(deviceName string, resourceName string, start int64, end int64) (uint32, errors.EdgeX)
	ReadingCountByTimeRange(start int64, end int64) (uint32, errors.EdgeX)
	ReadingsByResourceNameAndTimeRange(resourceName string, start int64, end int64, offset int, limit int) ([]model.Reading, errors.EdgeX)
	ReadingsByDeviceNameAndResourceNamesAndTimeRange(deviceName string, resourceNames []string, start int64, end int64, offset, limit int) ([]model.Reading, errors.EdgeX)
	ReadingCountByDeviceNameAndResourceNamesAndTimeRange(deviceName string, resourceName []string, start int64, end int64) (uint32, errors.EdgeX)
	ReadingsByDeviceNameAndTimeRange(deviceName string, start int64, end int64, offset int, limit int) ([]model.Reading, errors.EdgeX)
	ReadingCountByDeviceNameAndTimeRange(deviceName string, start int64, end int64) (uint32, errors.EdgeX)
	LatestReadingByOffset(offset uint32) (model.Reading, errors.EdgeX)
}