client

Documentation

Index

• type Client
  • func New(address string) (c *Client, err error)
  • func (c *Client) CreateStream(name string, period float64) (s *seer.Stream, err error)
  • func (c *Client) DeleteStream(name string) (err error)
  • func (c *Client) GetForecast(name string, length int) (f *seer.Forecast, err error)
  • func (c *Client) GetStream(name string) (s *seer.Stream, err error)
  • func (c *Client) ListStreams(pageNum, pageSize int) (s []*seer.Stream, err error)
  • func (c *Client) UpdateStream(name string, times []time.Time, values []float64) (s *seer.Stream, err error)

Types

type Client

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

Client is a seer client

func New

func New(address string) (c *Client, err error)

New dials the specified seer server and returns a client.

func (*Client) CreateStream

func (c *Client) CreateStream(name string, period float64) (s *seer.Stream, err error)

CreateStream creates a stream with the specified data on the server.

func (*Client) DeleteStream

func (c *Client) DeleteStream(name string) (err error)

DeleteStream deletes the stream with the specified name.

func (*Client) GetForecast

func (c *Client) GetForecast(name string, length int) (f *seer.Forecast, err error)

GetForecast generates a forecast from the specified stream.

func (*Client) GetStream

func (c *Client) GetStream(name string) (s *seer.Stream, err error)

GetStream retrieves the stream with the specified name.

func (*Client) ListStreams

func (c *Client) ListStreams(pageNum, pageSize int) (s []*seer.Stream, err error)

ListStreams returns a paged slice of streams.

func (*Client) UpdateStream

func (c *Client) UpdateStream(name string, times []time.Time, values []float64) (s *seer.Stream, err error)

UpdateStream sends the provided data to the specific stream.