client

Documentation

Index

• type Client
  • func NewClient(url string) *Client
  • func (c *Client) CreateAsset(asset et.Asset, token uuid.UUID) error
  • func (c *Client) CreateSession(config *config.Config) (uuid.UUID, error)
  • func (c *Client) Query(query string) (string, error)
  • func (c *Client) SessionStats(token uuid.UUID) (*et.SessionStats, error)
  • func (c *Client) Subscribe(token uuid.UUID) (<-chan string, error)
  • func (c *Client) TerminateSession(token uuid.UUID)
• type Handler

Types

type Client

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

func NewClient

func NewClient(url string) *Client

func (*Client) CreateAsset

func (c *Client) CreateAsset(asset et.Asset, token uuid.UUID) error

func (*Client) CreateSession

func (c *Client) CreateSession(config *config.Config) (uuid.UUID, error)

Create a session by sending the config elements as graphql named fields TODO: Not Implemented. The transfromations use "->" in the config YAML, but that is not a valid field name in GraphQL

func (*Client) Query

func (c *Client) Query(query string) (string, error)

func (*Client) SessionStats

func (c *Client) SessionStats(token uuid.UUID) (*et.SessionStats, error)

func (*Client) Subscribe

func (c *Client) Subscribe(token uuid.UUID) (<-chan string, error)

Creates subscription to receove a stream of log messages from the sever

func (*Client) TerminateSession

func (c *Client) TerminateSession(token uuid.UUID)

type Handler

type Handler func(message string)