client

Documentation

Overview

Package client is an HTTP client for Controller.

Index

• type Client
  • func New(address dax.Address, logger logger.Logger) *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) ([]dax.ComputeNode, error)
  • func (c *Client) CreateDatabase(ctx context.Context, qdb *dax.QualifiedDatabase) 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) DatabaseByID(ctx context.Context, qdbid dax.QualifiedDatabaseID) (*dax.QualifiedDatabase, error)
  • func (c *Client) DatabaseByName(ctx context.Context, orgID dax.OrganizationID, name dax.DatabaseName) (*dax.QualifiedDatabase, error)
  • func (c *Client) Databases(ctx context.Context, orgID dax.OrganizationID, ids ...dax.DatabaseID) ([]*dax.QualifiedDatabase, error)
  • func (c *Client) DropDatabase(ctx context.Context, qdbid dax.QualifiedDatabaseID) 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
  • 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) SetDatabaseOption(ctx context.Context, qdbid dax.QualifiedDatabaseID, option string, ...) 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) TableByID(ctx context.Context, qtid dax.QualifiedTableID) (*dax.QualifiedTable, error)
  • func (c *Client) TableByName(ctx context.Context, qdbid dax.QualifiedDatabaseID, tname dax.TableName) (*dax.QualifiedTable, error)
  • func (c *Client) TableID(ctx context.Context, qdbid dax.QualifiedDatabaseID, name dax.TableName) (dax.QualifiedTableID, error)
  • func (c *Client) Tables(ctx context.Context, qdbid dax.QualifiedDatabaseID, ids ...dax.TableID) ([]*dax.QualifiedTable, error)
  • func (c *Client) TranslateNodes(ctx context.Context, qtid dax.QualifiedTableID, partitions ...dax.PartitionNum) ([]dax.TranslateNode, error)

Types

type Client

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

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

func New

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

New returns a new instance of Client.

func (*Client) CheckInNode

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

func (*Client) ComputeNodes

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

func (*Client) CreateDatabase

func (c *Client) CreateDatabase(ctx context.Context, qdb *dax.QualifiedDatabase) error

func (*Client) CreateField

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

func (*Client) CreateTable

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

func (*Client) DatabaseByID

func (c *Client) DatabaseByID(ctx context.Context, qdbid dax.QualifiedDatabaseID) (*dax.QualifiedDatabase, error)

func (*Client) DatabaseByName

func (c *Client) DatabaseByName(ctx context.Context, orgID dax.OrganizationID, name dax.DatabaseName) (*dax.QualifiedDatabase, error)

func (*Client) Databases

func (c *Client) Databases(ctx context.Context, orgID dax.OrganizationID, ids ...dax.DatabaseID) ([]*dax.QualifiedDatabase, error)

func (*Client) DropDatabase

func (c *Client) DropDatabase(ctx context.Context, qdbid dax.QualifiedDatabaseID) error

func (*Client) DropField

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

func (*Client) DropTable

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

func (*Client) Health

func (c *Client) Health() bool

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

func (*Client) IngestPartition

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

func (*Client) IngestShard

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

func (*Client) RegisterNode

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

func (*Client) SetDatabaseOption

func (c *Client) SetDatabaseOption(ctx context.Context, qdbid dax.QualifiedDatabaseID, option string, value string) error

func (*Client) SnapshotTable

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

func (*Client) Table

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

func (*Client) TableByID

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

TODO(tlt): collapse Table into this

func (*Client) TableByName

func (c *Client) TableByName(ctx context.Context, qdbid dax.QualifiedDatabaseID, tname dax.TableName) (*dax.QualifiedTable, error)

TODO(tlt): collapse TableID into this

func (*Client) TableID

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

func (*Client) Tables

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

func (*Client) TranslateNodes

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