controllers

Documentation

Index

• type Controller
  • func New(ipAddress string, port int, databaseUrl string, hmacSecret string) *Controller
  • func (s *Controller) InsertBulkTimeSeriesData(ctx context.Context, in *pb.BulkTimeSeriesDataReq) (*empty.Empty, error)
  • func (s *Controller) InsertTimeSeriesData(stream pb.Mothership_InsertTimeSeriesDataServer) error
  • func (s *Controller) InsertTimeSeriesDatum(ctx context.Context, in *pb.TimeSeriesDatumReq) (*empty.Empty, error)
  • func (s *Controller) Login(ctx context.Context, in *pb.LoginReq) (*pb.LoginRes, error)
  • func (s *Controller) RefreshToken(ctx context.Context, in *pb.RefreshTokenReq) (*pb.RefreshTokenRes, error)
  • func (s *Controller) Register(ctx context.Context, in *pb.RegistrationReq) (*pb.RegistrationRes, error)
  • func (s *Controller) RunMainRuntimeLoop()
  • func (s *Controller) SelectBulkTimeSeriesData(ctx context.Context, in *pb.FilterReq) (*pb.SelectBulkRes, error)
  • func (s *Controller) StopMainRuntimeLoop()

Types

type Controller

type Controller struct {
	pb.MothershipServer
	// contains filtered or unexported fields
}

func New

func New(ipAddress string, port int, databaseUrl string, hmacSecret string) *Controller

func (*Controller) InsertBulkTimeSeriesData

func (s *Controller) InsertBulkTimeSeriesData(ctx context.Context, in *pb.BulkTimeSeriesDataReq) (*empty.Empty, error)

func (*Controller) InsertTimeSeriesData

func (s *Controller) InsertTimeSeriesData(stream pb.Mothership_InsertTimeSeriesDataServer) error

func (*Controller) InsertTimeSeriesDatum

func (s *Controller) InsertTimeSeriesDatum(ctx context.Context, in *pb.TimeSeriesDatumReq) (*empty.Empty, error)

func (*Controller) Login

func (s *Controller) Login(ctx context.Context, in *pb.LoginReq) (*pb.LoginRes, error)

func (*Controller) RefreshToken

func (s *Controller) RefreshToken(ctx context.Context, in *pb.RefreshTokenReq) (*pb.RefreshTokenRes, error)

func (*Controller) Register

func (s *Controller) Register(ctx context.Context, in *pb.RegistrationReq) (*pb.RegistrationRes, error)

func (*Controller) RunMainRuntimeLoop

func (s *Controller) RunMainRuntimeLoop()

Function will consume the main runtime loop and run the business logic of the application.

func (*Controller) SelectBulkTimeSeriesData

func (s *Controller) SelectBulkTimeSeriesData(ctx context.Context, in *pb.FilterReq) (*pb.SelectBulkRes, error)

func (*Controller) StopMainRuntimeLoop

func (s *Controller) StopMainRuntimeLoop()

Function will tell the application to stop the main runtime loop when the process has been finished.