dal

Documentation

Index

• Variables
• func NewConnectionAsync(ctx context.Context, cancel context.CancelFunc, endpoint string, ...) error
• type Client
  • 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

Variables

var (
	ErrIncompleteTimeRange = status.Error(codes.InvalidArgument, "invalid time range, if specifying start or end time, you must specify both")
	ErrInvalidTimeRange    = status.Error(codes.InvalidArgument, "invalid time range, start time must be before end time")
	ErrLakeNameEmpty       = status.Error(codes.InvalidArgument, "lake name cannot be empty")
)

Functions

func NewConnectionAsync

func NewConnectionAsync(ctx context.Context, cancel context.CancelFunc, endpoint string, ch chan *Client) error

Types

type Client

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

func New

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

func (*Client) Close

func (m *Client) Close() error

func (*Client) GetLakeInfo

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

func (*Client) Ping

func (m *Client) Ping() error

func (*Client) Setup

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

func (*Client) StoreLakeInfo

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

type ClientOption

type ClientOption func(*Client)