Documentation ¶
Index ¶
- type StockYardRPCClient
- func (s *StockYardRPCClient) DeleteEntityByPrimaryKey(entityID uint64) error
- func (s *StockYardRPCClient) DeleteObservationByPrimaryKey(dto *dtos.ObservationPrimaryKeyRequestDTO) error
- func (s *StockYardRPCClient) DeleteTimeKeysByFilter(dto *dtos.TimeKeyFilterRequestDTO) error
- func (s *StockYardRPCClient) InsertEntity(name string, dataType int8, meta string) (*dtos.EntityResponseDTO, error)
- func (s *StockYardRPCClient) InsertObservation(dto *dtos.ObservationInsertRequestDTO) (*dtos.ObservationResponseDTO, error)
- func (s *StockYardRPCClient) InsertTimeKey(dto *dtos.TimeKeyInsertRequestDTO) (*dtos.TimeKeyResponseDTO, error)
- func (s *StockYardRPCClient) ListEntities(dto *dtos.EntityFilterRequestDTO) (*dtos.EntityListResponseDTO, error)
- func (s *StockYardRPCClient) ListObservationAverages(dto *dtos.ObservationAverageFilterRequestDTO) (*dtos.ObservationAverageListResponseDTO, error)
- func (s *StockYardRPCClient) ListObservationCounts(dto *dtos.ObservationCountFilterRequestDTO) (*dtos.ObservationCountListResponseDTO, error)
- func (s *StockYardRPCClient) ListObservationSummations(dto *dtos.ObservationSummationFilterRequestDTO) (*dtos.ObservationSummationListResponseDTO, error)
- func (s *StockYardRPCClient) ListObservations(dto *dtos.ObservationFilterRequestDTO) (*dtos.ObservationListResponseDTO, error)
- func (s *StockYardRPCClient) ListTimeKeys(dto *dtos.TimeKeyFilterRequestDTO) (*dtos.TimeKeyListResponseDTO, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StockYardRPCClient ¶
type StockYardRPCClient struct { Logger *zerolog.Logger Client *rpc.Client RetryLimit uint8 DelayDuration time.Duration // contains filtered or unexported fields }
func (*StockYardRPCClient) DeleteEntityByPrimaryKey ¶
func (s *StockYardRPCClient) DeleteEntityByPrimaryKey(entityID uint64) error
func (*StockYardRPCClient) DeleteObservationByPrimaryKey ¶
func (s *StockYardRPCClient) DeleteObservationByPrimaryKey(dto *dtos.ObservationPrimaryKeyRequestDTO) error
func (*StockYardRPCClient) DeleteTimeKeysByFilter ¶
func (s *StockYardRPCClient) DeleteTimeKeysByFilter(dto *dtos.TimeKeyFilterRequestDTO) error
func (*StockYardRPCClient) InsertEntity ¶
func (s *StockYardRPCClient) InsertEntity(name string, dataType int8, meta string) (*dtos.EntityResponseDTO, error)
func (*StockYardRPCClient) InsertObservation ¶
func (s *StockYardRPCClient) InsertObservation(dto *dtos.ObservationInsertRequestDTO) (*dtos.ObservationResponseDTO, error)
func (*StockYardRPCClient) InsertTimeKey ¶
func (s *StockYardRPCClient) InsertTimeKey(dto *dtos.TimeKeyInsertRequestDTO) (*dtos.TimeKeyResponseDTO, error)
func (*StockYardRPCClient) ListEntities ¶
func (s *StockYardRPCClient) ListEntities(dto *dtos.EntityFilterRequestDTO) (*dtos.EntityListResponseDTO, error)
func (*StockYardRPCClient) ListObservationAverages ¶
func (s *StockYardRPCClient) ListObservationAverages(dto *dtos.ObservationAverageFilterRequestDTO) (*dtos.ObservationAverageListResponseDTO, error)
func (*StockYardRPCClient) ListObservationCounts ¶
func (s *StockYardRPCClient) ListObservationCounts(dto *dtos.ObservationCountFilterRequestDTO) (*dtos.ObservationCountListResponseDTO, error)
func (*StockYardRPCClient) ListObservationSummations ¶
func (s *StockYardRPCClient) ListObservationSummations(dto *dtos.ObservationSummationFilterRequestDTO) (*dtos.ObservationSummationListResponseDTO, error)
func (*StockYardRPCClient) ListObservations ¶
func (s *StockYardRPCClient) ListObservations(dto *dtos.ObservationFilterRequestDTO) (*dtos.ObservationListResponseDTO, error)
func (*StockYardRPCClient) ListTimeKeys ¶
func (s *StockYardRPCClient) ListTimeKeys(dto *dtos.TimeKeyFilterRequestDTO) (*dtos.TimeKeyListResponseDTO, error)
Click to show internal directories.
Click to hide internal directories.