client

package

v3.26.0 Latest Latest Go to latest Published: Dec 12, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Package client is an HTTP client for MDS.

This section is empty.

This section is empty.

This section is empty.

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

Client is an HTTP client that operates on the MDS endpoints exposed by the main MDS service.

func New(address dax.Address, logger logger.Logger) *Client

New returns a new instance of Client.

func (c *Client) CheckInNode(ctx context.Context, node *dax.Node) error

func (c *Client) ComputeNodes(ctx context.Context, qtid dax.QualifiedTableID, shards ...dax.ShardNum) ([]controller.ComputeNode, error)

func (c *Client) CreateField(ctx context.Context, qtid dax.QualifiedTableID, fld *dax.Field) error

func (c *Client) CreateTable(ctx context.Context, qtbl *dax.QualifiedTable) error

func (c *Client) DropField(ctx context.Context, qtid dax.QualifiedTableID, fldName dax.FieldName) error

func (c *Client) DropTable(ctx context.Context, qtid dax.QualifiedTableID) error

func (c *Client) Health() bool

Health returns true if the client address returns status OK at its /health endpoint.

func (c *Client) IngestPartition(ctx context.Context, qtid dax.QualifiedTableID, partition dax.PartitionNum) (dax.Address, error)

func (c *Client) IngestShard(ctx context.Context, qtid dax.QualifiedTableID, shard dax.ShardNum) (dax.Address, error)

func (c *Client) RegisterNode(ctx context.Context, node *dax.Node) error

func (c *Client) SnapshotTable(ctx context.Context, qtid dax.QualifiedTableID) error

func (c *Client) Table(ctx context.Context, qtid dax.QualifiedTableID) (*dax.QualifiedTable, error)

func (c *Client) TableID(ctx context.Context, qual dax.TableQualifier, name dax.TableName) (dax.QualifiedTableID, error)

func (c *Client) Tables(ctx context.Context, qual dax.TableQualifier, ids ...dax.TableID) ([]*dax.QualifiedTable, error)

func (c *Client) TranslateNodes(ctx context.Context, qtid dax.QualifiedTableID, partitions ...dax.PartitionNum) ([]controller.TranslateNode, error)