client

Documentation

Index

• type Client
  • func New(serverURL string) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) StartStream() (*Stream, error)
• type Stream
  • func (s *Stream) ACK() error
  • func (s *Stream) Close() error
  • func (s *Stream) NACK(err error) error
  • func (s *Stream) RequestAssignments(clientId string) error
  • func (s *Stream) WaitForAssignments() ([]*observability_proto.MonitoringAssignment, error)

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)