server

Documentation

Index

• type Server
  • func New(path string) (srv *Server, err error)
  • func (srv *Server) CreateStream(c context.Context, in *seer.CreateStreamRequest) (s *seer.Stream, err error)
  • func (srv *Server) DeleteStream(c context.Context, in *seer.DeleteStreamRequest) (em *empty.Empty, err error)
  • func (srv *Server) GetForecast(c context.Context, in *seer.GetForecastRequest) (f *seer.Forecast, err error)
  • func (srv *Server) GetStream(c context.Context, in *seer.GetStreamRequest) (s *seer.Stream, err error)
  • func (srv *Server) ListStreams(c context.Context, in *seer.ListStreamsRequest) (s *seer.ListStreamsResponse, err error)
  • func (srv *Server) UpdateStream(c context.Context, in *seer.UpdateStreamRequest) (s *seer.Stream, err error)

Types

type Server

type Server struct {
	DB store.StreamStore
}

Server fulfills the protocol buffer's SeerServer interface.

func New

func New(path string) (srv *Server, err error)

New creates a database connection and returns a Server.

func (*Server) CreateStream

func (srv *Server) CreateStream(c context.Context, in *seer.CreateStreamRequest) (s *seer.Stream, err error)

CreateStream creates the provided stream.

func (*Server) DeleteStream

func (srv *Server) DeleteStream(c context.Context, in *seer.DeleteStreamRequest) (em *empty.Empty, err error)

DeleteStream removes the requested stream.

func (*Server) GetForecast

func (srv *Server) GetForecast(c context.Context, in *seer.GetForecastRequest) (f *seer.Forecast, err error)

GetForecast generates a forecast from a stream from its current time.

func (*Server) GetStream

func (srv *Server) GetStream(c context.Context, in *seer.GetStreamRequest) (s *seer.Stream, err error)

GetStream retrieves and returns the requested stream.

func (*Server) ListStreams

func (srv *Server) ListStreams(c context.Context, in *seer.ListStreamsRequest) (s *seer.ListStreamsResponse, err error)

ListStreams returns a paged set of streams.

func (*Server) UpdateStream

func (srv *Server) UpdateStream(c context.Context, in *seer.UpdateStreamRequest) (s *seer.Stream, err error)

UpdateStream applies an adaptive filter update using the provided events.