pkg

Documentation

Index

• Constants
• Variables
• func ByteToUInt64(sensorID []byte) uint64
• func ParsedFrameConstructor(segmentData protocols.ISegment, id uint64, timestamp time.Time) ([]byte, error)
• type ArcStorage
  • func NewArcStorage(config *config.ArcConfig, logger logging.ILogger, ...) (*ArcStorage, error)
  • func (arc *ArcStorage) Close()
  • func (arc *ArcStorage) SetupWeb(root echoswagger.ApiRoot, base, selfServiceName string)
  • func (arc *ArcStorage) Start(stop chan struct{})
• type SensorIDResponse
• type SensorItem
• type SensorQuery

Constants

const (
	// ArcStorageAPI Arc Storage Data API
	ArcStorageAPI = "Arc Storage Data"
	// DataBaseName arc
	DataBaseName = "arc"
)

const (
	// Success -
	Success = 0
)

const (
	// TypeArc "Arc"
	TypeArc = "Arc"
)

Variables

var ArcStorageVersion = "appversion"

ArcStorageVersion add to file suffix name

Functions

func ByteToUInt64

func ByteToUInt64(sensorID []byte) uint64

ByteToUInt64 convert sensor []byte to uint64.

func ParsedFrameConstructor

func ParsedFrameConstructor(segmentData protocols.ISegment, id uint64, timestamp time.Time) ([]byte, error)

ParsedFrameConstructor - construct frame structure

Types

type ArcStorage

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

ArcStorage arc storage struct

func NewArcStorage

func NewArcStorage(config *config.ArcConfig, logger logging.ILogger, gossipKVCache *microComponent.GossipKVCacheComponent, k kafka.Handler) (*ArcStorage, error)

NewArcStorage Instantiation object

func (*ArcStorage) Close

func (arc *ArcStorage) Close()

Close kafka & haystack store

func (*ArcStorage) SetupWeb

func (arc *ArcStorage) SetupWeb(root echoswagger.ApiRoot, base, selfServiceName string)

SetupWeb Set interface

func (*ArcStorage) Start

func (arc *ArcStorage) Start(stop chan struct{})

Start Connect kafka Store & taoClient

type SensorIDResponse

type SensorIDResponse struct {
	Code int      `json:"code,omitempty"`
	Msg  string   `json:"msg,omitempty"`
	Data []string `json:"data,omitempty"`
}

SensorIDResponse is the response for getting sensor ids

type SensorItem

type SensorItem struct {
	SensorID     string      `json:"sensorid,omitempty"`
	DataType     string      `json:"data_type,omitempty"`
	Query        SensorQuery `json:"query,omitempty"`
	TimeFrom     int64       `json:"time_from,omitempty"`
	TimeTo       int64       `json:"time_to,omitempty"`
	TimeDuration int64       `json:"time_duration,omitempty"`
}

SensorItem response sensor information

type SensorQuery

type SensorQuery struct {
	URL      string `json:"url,omitempty"`
	Scheme   string `json:"scheme,omitempty"`
	Domain   string `json:"domain,omitempty"`
	Port     int    `json:"port,omitempty"`
	FullPath string `json:"full_path,omitempty"`
	Path     string `json:"path,omitempty"`
	SensorID string `json:"sensorid,omitempty"`
	Type     string `json:"type,omitempty"`
	TimeFrom int64  `json:"time_from,omitempty"`
	TimeTo   int64  `json:"time_to,omitempty"`
}

SensorQuery query details