rpc

Documentation

Index

• type RPC
  • func NewServer(appConfig *config.Conf, uuidProvider uuid.Provider, timeProvider time.Provider, ...) *RPC
  • func (rpc *RPC) DeleteEntityByPrimaryKey(entityID *uint64, res *dtos.EntityResponseDTO) error
  • func (rpc *RPC) DeleteObservationByPrimaryKey(req *dtos.ObservationPrimaryKeyRequestDTO, res *dtos.ObservationResponseDTO) error
  • func (rpc *RPC) DeleteTimeKeysByFilter(req *dtos.TimeKeyFilterRequestDTO, res *dtos.TimeKeyResponseDTO) error
  • func (rpc *RPC) InsertEntity(req *dtos.EntityInsertRequestDTO, res *dtos.EntityResponseDTO) error
  • func (rpc *RPC) InsertObservation(req *dtos.ObservationInsertRequestDTO, res *dtos.ObservationResponseDTO) error
  • func (rpc *RPC) InsertTimeKey(req *dtos.TimeKeyInsertRequestDTO, res *dtos.TimeKeyResponseDTO) error
  • func (rpc *RPC) ListEntities(req *dtos.EntityFilterRequestDTO, res *dtos.EntityListResponseDTO) error
  • func (rpc *RPC) ListObservationAverages(req *dtos.ObservationAverageFilterRequestDTO, ...) error
  • func (rpc *RPC) ListObservationCounts(req *dtos.ObservationCountFilterRequestDTO, ...) error
  • func (rpc *RPC) ListObservationSummations(req *dtos.ObservationSummationFilterRequestDTO, ...) error
  • func (rpc *RPC) ListObservations(req *dtos.ObservationFilterRequestDTO, res *dtos.ObservationListResponseDTO) error
  • func (rpc *RPC) ListTimeKeys(req *dtos.TimeKeyFilterRequestDTO, res *dtos.TimeKeyListResponseDTO) error
  • func (rpcServer *RPC) ListenAndServe() error

Types

type RPC

type RPC struct {
	Time    time.Provider
	UUID    uuid.Provider
	KMutext kmutex.Provider

	Services app.Services
	// contains filtered or unexported fields
}

func NewServer

func NewServer(appConfig *config.Conf, uuidProvider uuid.Provider, timeProvider time.Provider, kmutexProvider kmutex.Provider, appServices app.Services) *RPC

func (*RPC) DeleteEntityByPrimaryKey

func (rpc *RPC) DeleteEntityByPrimaryKey(entityID *uint64, res *dtos.EntityResponseDTO) error

func (*RPC) DeleteObservationByPrimaryKey

func (rpc *RPC) DeleteObservationByPrimaryKey(req *dtos.ObservationPrimaryKeyRequestDTO, res *dtos.ObservationResponseDTO) error

func (*RPC) DeleteTimeKeysByFilter

func (rpc *RPC) DeleteTimeKeysByFilter(req *dtos.TimeKeyFilterRequestDTO, res *dtos.TimeKeyResponseDTO) error

func (*RPC) InsertEntity

func (rpc *RPC) InsertEntity(req *dtos.EntityInsertRequestDTO, res *dtos.EntityResponseDTO) error

func (*RPC) InsertObservation

func (rpc *RPC) InsertObservation(req *dtos.ObservationInsertRequestDTO, res *dtos.ObservationResponseDTO) error

func (*RPC) InsertTimeKey

func (rpc *RPC) InsertTimeKey(req *dtos.TimeKeyInsertRequestDTO, res *dtos.TimeKeyResponseDTO) error

func (*RPC) ListEntities

func (rpc *RPC) ListEntities(req *dtos.EntityFilterRequestDTO, res *dtos.EntityListResponseDTO) error

func (*RPC) ListObservationAverages

func (rpc *RPC) ListObservationAverages(req *dtos.ObservationAverageFilterRequestDTO, res *dtos.ObservationAverageListResponseDTO) error

func (*RPC) ListObservationCounts

func (rpc *RPC) ListObservationCounts(req *dtos.ObservationCountFilterRequestDTO, res *dtos.ObservationCountListResponseDTO) error

func (*RPC) ListObservationSummations

func (rpc *RPC) ListObservationSummations(req *dtos.ObservationSummationFilterRequestDTO, res *dtos.ObservationSummationListResponseDTO) error

func (*RPC) ListObservations

func (rpc *RPC) ListObservations(req *dtos.ObservationFilterRequestDTO, res *dtos.ObservationListResponseDTO) error

func (*RPC) ListTimeKeys

func (rpc *RPC) ListTimeKeys(req *dtos.TimeKeyFilterRequestDTO, res *dtos.TimeKeyListResponseDTO) error

func (*RPC) ListenAndServe

func (rpcServer *RPC) ListenAndServe() error