Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

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

func New

func New(serverURL string) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) StartStream

func (c *Client) StartStream() (*Stream, error)

type Stream

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

func (*Stream) ACK

func (s *Stream) ACK() error

func (*Stream) Close

func (s *Stream) Close() error

func (*Stream) NACK

func (s *Stream) NACK(err error) error

func (*Stream) RequestAssignments

func (s *Stream) RequestAssignments(clientId string) error

func (*Stream) WaitForAssignments

func (s *Stream) WaitForAssignments() ([]*observability_proto.MonitoringAssignment, error)

Source Files