client

Documentation

Index

• type Client
  • func NewClient(serverURL string) *Client
  • func (c *Client) CreateEvent(event *models.Event) error
  • func (c *Client) ListEvents() ([]*models.Event, error)
  • func (c *Client) ListRules() ([]*models.Rule, error)
  • func (c *Client) RegisterWorker(worker *models.Worker) error
  • func (c *Client) ReportWorker(worker *models.Worker) error
  • func (c *Client) WatchEvents() <-chan models.Event

Types

type Client

type Client struct {
	ServerURL string
}

Client is used to talk to the API server

func NewClient

func NewClient(serverURL string) *Client

NewClient initializes a new REST client to the API server

func (*Client) CreateEvent

func (c *Client) CreateEvent(event *models.Event) error

CreateEvent creates a new Event

func (*Client) ListEvents

func (c *Client) ListEvents() ([]*models.Event, error)

ListEvents lists all events

func (*Client) ListRules

func (c *Client) ListRules() ([]*models.Rule, error)

ListRules lists all rules

func (*Client) RegisterWorker

func (c *Client) RegisterWorker(worker *models.Worker) error

RegisterWorker creates a worker

func (*Client) ReportWorker

func (c *Client) ReportWorker(worker *models.Worker) error

ReportWorker sends a worker heartbeat

func (*Client) WatchEvents

func (c *Client) WatchEvents() <-chan models.Event

WatchEvents setup a HTTP channel to receive event stream