dal

Dec 18, 2023

Changes in this version

+ var ErrIncompleteTimeRange = status.Error(codes.InvalidArgument, ...)

+ var ErrInvalidTimeRange = status.Error(codes.InvalidArgument, ...)

+ var ErrLakeNameEmpty = status.Error(codes.InvalidArgument, "lake name cannot be empty")

+ func NewConnectionAsync(ctx context.Context, cancel context.CancelFunc, endpoint string, ...) error

+ type Client struct

+ func New(opts ...ClientOption) (*Client, error)

+ func (m *Client) Close() error

+ func (m *Client) GetLakeInfo(ctx context.Context, lakeName string, startTime, endTime time.Time, ...) ([]*lakeinfov1.LakeInfoMeasurement, error)

+ func (m *Client) Ping() error

+ func (m *Client) Setup(ctx context.Context) error

+ func (m *Client) StoreLakeInfo(ctx context.Context, measurements []*lakeinfov1.LakeInfoMeasurement) error

+ type ClientOption func(*Client)