Documentation
¶
Index ¶
- type Client
- func (c *Client) FindNextRow(ctx context.Context, lakeName LakeName) (int, error)
- func (c *Client) ReadMeasurements(ctx context.Context, lakeName LakeName) ([]*lakeinfov1.LakeInfoMeasurement, error)
- func (c *Client) WriteMeasurement(ctx context.Context, lakeName LakeName, ...) error
- func (c *Client) WriteMeasurements(ctx context.Context, lakeName LakeName, ...) error
- type LakeName
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 (*Client) FindNextRow ¶
func (*Client) ReadMeasurements ¶
func (c *Client) ReadMeasurements(ctx context.Context, lakeName LakeName) ([]*lakeinfov1.LakeInfoMeasurement, error)
func (*Client) WriteMeasurement ¶
func (c *Client) WriteMeasurement(ctx context.Context, lakeName LakeName, measurement *lakeinfov1.LakeInfoMeasurement) error
func (*Client) WriteMeasurements ¶
func (c *Client) WriteMeasurements(ctx context.Context, lakeName LakeName, measurements []*lakeinfov1.LakeInfoMeasurement) error
Click to show internal directories.
Click to hide internal directories.