vtadmin

package
v0.15.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 31, 2024 License: Apache-2.0 Imports: 39 Imported by: 0

README

VTAdmin

VTAdmin is web UI and API that allows users to manage multiple Vitess clusters at once.

For a more detailed writeup, refer to the original RFC.

Setup

The simplest VTAdmin deployment involves a single Vitess cluster. You can look at the local example for a minimal invocation of the vtadmin-api and vtadmin-web binaries.

Important vtadmin-api flags

Please refer to vtadmin --help for the full listing, but a few flags warrant explanation here.

  • --http-origin — this flag sets up the allowed CORS origins that vtadmin-api will serve HTTP requests for, and is required if you are (very likely) running vtadmin-api and vtadmin-web on different domains.

  • --cluster, --cluster-defaults — A DSN-style flag that allows cluster configuration options to be specified on the command-line rather than needing a config file. When both command-line cluster configs and a config file are provided, any options for a given cluster on the command-line take precedence over options for that cluster in the config file.

    For a description of the cluster configuration options, see clusters.example.yaml.

  • --http-tablet-url-tmpl — Go template string to generate a reachable http(s) address for a tablet, used to make passthrough requests to /debug/vars endpoints.

Development

Building vtadmin-api

If you are making changes to .proto files, make sure you run

source dev.env
make proto grpcvtctldclient vtadmin_web_proto_types

Then, you can run make build, and run ./bin/vtadmin with any flags you need (see the local example, and also the section on flags above).

Building and running vtadmin-web

Make sure you are using node version 16.x.

Then, you may run:

cd ./web/vtadmin
npm install

# This should be the address you passed to `./vtadmin --addr`. For example,
# "http://127.0.0.1:14200".
export VITE_VTADMIN_API_ADDRESS="${vtadmin_api_addr}"
export VITE_ENABLE_EXPERIMENTAL_TABLET_DEBUG_VARS="true"
npm run start

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type API 

type API struct {
	vtadminpb.UnimplementedVTAdminServer
	// contains filtered or unexported fields
}

API is the main entrypoint for the vtadmin server. It implements vtadminpb.VTAdminServer.

func NewAPI 

func NewAPI(env *vtenv.Environment, clusters []*cluster.Cluster, opts Options) *API

NewAPI returns a new API, configured to service the given set of clusters, and configured with the given options.

func (*API) ApplySchema 

func (api *API) ApplySchema(ctx context.Context, req *vtadminpb.ApplySchemaRequest) (*vtctldatapb.ApplySchemaResponse, error)

ApplySchema is part of the vtadminpb.VTAdminServer interface.

func (*API) CancelSchemaMigration 

func (api *API) CancelSchemaMigration(ctx context.Context, req *vtadminpb.CancelSchemaMigrationRequest) (*vtctldatapb.CancelSchemaMigrationResponse, error)

CancelSchemaMigration is part of the vtadminpb.VTAdminServer interface.

func (*API) CleanupSchemaMigration 

func (api *API) CleanupSchemaMigration(ctx context.Context, req *vtadminpb.CleanupSchemaMigrationRequest) (*vtctldatapb.CleanupSchemaMigrationResponse, error)

CleanupSchemaMigration is part of the vtadminpb.VTAdminServer interface.

func (*API) Close 

func (api *API) Close() error

Close closes all the clusters in an API concurrently. Its primary function is to gracefully shutdown cache background goroutines to avoid data races in tests, but needs to be exported to be called by those tests. It does not have any production use case.

func (*API) CompleteSchemaMigration 

func (api *API) CompleteSchemaMigration(ctx context.Context, req *vtadminpb.CompleteSchemaMigrationRequest) (*vtctldatapb.CompleteSchemaMigrationResponse, error)

CompleteSchemaMigration is part of the vtadminpb.VTAdminServer interface.

func (*API) CreateKeyspace 

func (api *API) CreateKeyspace(ctx context.Context, req *vtadminpb.CreateKeyspaceRequest) (*vtadminpb.CreateKeyspaceResponse, error)

CreateKeyspace is part of the vtadminpb.VTAdminServer interface.

func (*API) CreateShard 

func (api *API) CreateShard(ctx context.Context, req *vtadminpb.CreateShardRequest) (*vtctldatapb.CreateShardResponse, error)

CreateShard is part of the vtadminpb.VTAdminServer interface.

func (*API) DeleteKeyspace 

func (api *API) DeleteKeyspace(ctx context.Context, req *vtadminpb.DeleteKeyspaceRequest) (*vtctldatapb.DeleteKeyspaceResponse, error)

DeleteKeyspace is part of the vtadminpb.VTAdminServer interface.

func (*API) DeleteShards 

func (api *API) DeleteShards(ctx context.Context, req *vtadminpb.DeleteShardsRequest) (*vtctldatapb.DeleteShardsResponse, error)

DeleteShards is part of the vtadminpb.VTAdminServer interface.

func (*API) DeleteTablet 

func (api *API) DeleteTablet(ctx context.Context, req *vtadminpb.DeleteTabletRequest) (*vtadminpb.DeleteTabletResponse, error)

DeleteTablet is part of the vtadminpb.VTAdminServer interface.

func (*API) EjectDynamicCluster 

func (api *API) EjectDynamicCluster(key string, value any)

func (*API) EmergencyFailoverShard 

func (api *API) EmergencyFailoverShard(ctx context.Context, req *vtadminpb.EmergencyFailoverShardRequest) (*vtadminpb.EmergencyFailoverShardResponse, error)

EmergencyFailoverShard is part of the vtadminpb.VTAdminServer interface.

func (*API) FindSchema 

func (api *API) FindSchema(ctx context.Context, req *vtadminpb.FindSchemaRequest) (*vtadminpb.Schema, error)

FindSchema is part of the vtadminpb.VTAdminServer interface.

func (*API) GetBackups 

func (api *API) GetBackups(ctx context.Context, req *vtadminpb.GetBackupsRequest) (*vtadminpb.GetBackupsResponse, error)

GetBackups is part of the vtadminpb.VTAdminServer interface.

func (*API) GetCellInfos 

func (api *API) GetCellInfos(ctx context.Context, req *vtadminpb.GetCellInfosRequest) (*vtadminpb.GetCellInfosResponse, error)

GetCellInfos is part of the vtadminpb.VTAdminServer interface.

func (*API) GetCellsAliases 

func (api *API) GetCellsAliases(ctx context.Context, req *vtadminpb.GetCellsAliasesRequest) (*vtadminpb.GetCellsAliasesResponse, error)

GetCellsAliases is part of the vtadminpb.VTAdminServer interface.

func (*API) GetClusters 

func (api *API) GetClusters(ctx context.Context, req *vtadminpb.GetClustersRequest) (*vtadminpb.GetClustersResponse, error)

GetClusters is part of the vtadminpb.VTAdminServer interface.

func (*API) GetFullStatus 

func (api *API) GetFullStatus(ctx context.Context, req *vtadminpb.GetFullStatusRequest) (*vtctldatapb.GetFullStatusResponse, error)

GetFullStatus is part of the vtadminpb.VTAdminServer interface.

func (*API) GetGates 

func (api *API) GetGates(ctx context.Context, req *vtadminpb.GetGatesRequest) (*vtadminpb.GetGatesResponse, error)

GetGates is part of the vtadminpb.VTAdminServer interface.

func (*API) GetKeyspace 

func (api *API) GetKeyspace(ctx context.Context, req *vtadminpb.GetKeyspaceRequest) (*vtadminpb.Keyspace, error)

GetKeyspace is part of the vtadminpb.VTAdminServer interface.

func (*API) GetKeyspaces 

func (api *API) GetKeyspaces(ctx context.Context, req *vtadminpb.GetKeyspacesRequest) (*vtadminpb.GetKeyspacesResponse, error)

GetKeyspaces is part of the vtadminpb.VTAdminServer interface.

func (*API) GetSchema 

func (api *API) GetSchema(ctx context.Context, req *vtadminpb.GetSchemaRequest) (*vtadminpb.Schema, error)

GetSchema is part of the vtadminpb.VTAdminServer interface.

func (*API) GetSchemaMigrations 

func (api *API) GetSchemaMigrations(ctx context.Context, req *vtadminpb.GetSchemaMigrationsRequest) (*vtadminpb.GetSchemaMigrationsResponse, error)

GetSchemaMigrations is part of the vtadminpb.VTAdminServer interface.

func (*API) GetSchemas 

func (api *API) GetSchemas(ctx context.Context, req *vtadminpb.GetSchemasRequest) (*vtadminpb.GetSchemasResponse, error)

GetSchemas is part of the vtadminpb.VTAdminServer interface.

func (*API) GetShardReplicationPositions 

func (api *API) GetShardReplicationPositions(ctx context.Context, req *vtadminpb.GetShardReplicationPositionsRequest) (*vtadminpb.GetShardReplicationPositionsResponse, error)

GetShardReplicationPositions is part of the vtadminpb.VTAdminServer interface.

func (*API) GetSrvKeyspace 

func (api *API) GetSrvKeyspace(ctx context.Context, req *vtadminpb.GetSrvKeyspaceRequest) (*vtctldatapb.GetSrvKeyspacesResponse, error)

GetSrvKeyspace is part of the vtadminpb.VTAdminServer interface.

func (*API) GetSrvKeyspaces 

func (api *API) GetSrvKeyspaces(ctx context.Context, req *vtadminpb.GetSrvKeyspacesRequest) (*vtadminpb.GetSrvKeyspacesResponse, error)

GetSrvKeyspaces is part of the vtadminpb.VTAdminServer interface.

func (*API) GetSrvVSchema 

func (api *API) GetSrvVSchema(ctx context.Context, req *vtadminpb.GetSrvVSchemaRequest) (*vtadminpb.SrvVSchema, error)

GetSrvVSchema is part of the vtadminpb.VTAdminServer interface.

func (*API) GetSrvVSchemas 

func (api *API) GetSrvVSchemas(ctx context.Context, req *vtadminpb.GetSrvVSchemasRequest) (*vtadminpb.GetSrvVSchemasResponse, error)

GetSrvVSchemas is part of the vtadminpb.VTAdminServer interface.

func (*API) GetTablet 

func (api *API) GetTablet(ctx context.Context, req *vtadminpb.GetTabletRequest) (*vtadminpb.Tablet, error)

GetTablet is part of the vtadminpb.VTAdminServer interface.

func (*API) GetTablets 

func (api *API) GetTablets(ctx context.Context, req *vtadminpb.GetTabletsRequest) (*vtadminpb.GetTabletsResponse, error)

GetTablets is part of the vtadminpb.VTAdminServer interface.

func (*API) GetTopologyPath 

func (api *API) GetTopologyPath(ctx context.Context, req *vtadminpb.GetTopologyPathRequest) (*vtctldatapb.GetTopologyPathResponse, error)

GetTopologyPath is part of the vtadminpb.VTAdminServer interface.

func (*API) GetVSchema 

func (api *API) GetVSchema(ctx context.Context, req *vtadminpb.GetVSchemaRequest) (*vtadminpb.VSchema, error)

GetVSchema is part of the vtadminpb.VTAdminServer interface.

func (*API) GetVSchemas 

func (api *API) GetVSchemas(ctx context.Context, req *vtadminpb.GetVSchemasRequest) (*vtadminpb.GetVSchemasResponse, error)

GetVSchemas is part of the vtadminpb.VTAdminServer interface.

func (*API) GetVtctlds 

func (api *API) GetVtctlds(ctx context.Context, req *vtadminpb.GetVtctldsRequest) (*vtadminpb.GetVtctldsResponse, error)

GetVtctlds is part of the vtadminpb.VTAdminServer interface.

func (*API) GetWorkflow 

func (api *API) GetWorkflow(ctx context.Context, req *vtadminpb.GetWorkflowRequest) (*vtadminpb.Workflow, error)

GetWorkflow is part of the vtadminpb.VTAdminServer interface.

func (*API) GetWorkflows 

func (api *API) GetWorkflows(ctx context.Context, req *vtadminpb.GetWorkflowsRequest) (*vtadminpb.GetWorkflowsResponse, error)

GetWorkflows is part of the vtadminpb.VTAdminServer interface.

func (*API) Handler 

func (api *API) Handler() http.Handler

Handler handles all routes under "/api" (see above)

func (*API) LaunchSchemaMigration 

func (api *API) LaunchSchemaMigration(ctx context.Context, req *vtadminpb.LaunchSchemaMigrationRequest) (*vtctldatapb.LaunchSchemaMigrationResponse, error)

LaunchSchemaMigration is part of the vtadminpb.VTAdminServer interface.

func (*API) ListenAndServe 

func (api *API) ListenAndServe() error

ListenAndServe starts serving this API on the configured Addr (see grpcserver.Options) until shutdown or irrecoverable error occurs.

func (*API) PingTablet 

func (api *API) PingTablet(ctx context.Context, req *vtadminpb.PingTabletRequest) (*vtadminpb.PingTabletResponse, error)

PingTablet is part of the vtadminpb.VTAdminServer interface.

func (*API) PlannedFailoverShard 

func (api *API) PlannedFailoverShard(ctx context.Context, req *vtadminpb.PlannedFailoverShardRequest) (*vtadminpb.PlannedFailoverShardResponse, error)

PlannedFailoverShard is part of the vtadminpb.VTAdminServer interface.

func (*API) RebuildKeyspaceGraph 

func (api *API) RebuildKeyspaceGraph(ctx context.Context, req *vtadminpb.RebuildKeyspaceGraphRequest) (*vtadminpb.RebuildKeyspaceGraphResponse, error)

RebuildKeyspaceGraph is a part of the vtadminpb.VTAdminServer interface.

func (*API) RefreshState 

func (api *API) RefreshState(ctx context.Context, req *vtadminpb.RefreshStateRequest) (*vtadminpb.RefreshStateResponse, error)

RefreshState is part of the vtadminpb.VTAdminServer interface.

func (*API) RefreshTabletReplicationSource 

func (api *API) RefreshTabletReplicationSource(ctx context.Context, req *vtadminpb.RefreshTabletReplicationSourceRequest) (*vtadminpb.RefreshTabletReplicationSourceResponse, error)

RefreshTabletReplicationSource is part of the vtadminpb.VTAdminServer interface.

func (*API) ReloadSchemaShard 

func (api *API) ReloadSchemaShard(ctx context.Context, req *vtadminpb.ReloadSchemaShardRequest) (*vtadminpb.ReloadSchemaShardResponse, error)

ReloadSchemaShard is part of the vtadminpb.VTAdminServer interface.

func (*API) ReloadSchemas 

func (api *API) ReloadSchemas(ctx context.Context, req *vtadminpb.ReloadSchemasRequest) (*vtadminpb.ReloadSchemasResponse, error)

ReloadSchemas is part of the vtadminpb.VTAdminServer interface.

func (*API) RemoveKeyspaceCell 

func (api *API) RemoveKeyspaceCell(ctx context.Context, req *vtadminpb.RemoveKeyspaceCellRequest) (*vtadminpb.RemoveKeyspaceCellResponse, error)

RemoveKeyspaceCell is a part of the vtadminpb.VTAdminServer interface.

func (*API) RetrySchemaMigration 

func (api *API) RetrySchemaMigration(ctx context.Context, req *vtadminpb.RetrySchemaMigrationRequest) (*vtctldatapb.RetrySchemaMigrationResponse, error)

RetrySchemaMigration is part of the vtadminpb.VTAdminServer interface.

func (*API) RunHealthCheck 

func (api *API) RunHealthCheck(ctx context.Context, req *vtadminpb.RunHealthCheckRequest) (*vtadminpb.RunHealthCheckResponse, error)

RunHealthCheck is part of the vtadminpb.VTAdminServer interface.

func (*API) ServeHTTP 

func (api *API) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP serves all routes matching path "/api" (see above) It first processes cookies, and acts accordingly Primarily, it sets up a dynamic API if HttpOpts.EnableDynamicClusters is set to true.

func (*API) SetReadOnly 

func (api *API) SetReadOnly(ctx context.Context, req *vtadminpb.SetReadOnlyRequest) (*vtadminpb.SetReadOnlyResponse, error)

SetReadOnly is part of the vtadminpb.VTAdminServer interface.

func (*API) SetReadWrite 

func (api *API) SetReadWrite(ctx context.Context, req *vtadminpb.SetReadWriteRequest) (*vtadminpb.SetReadWriteResponse, error)

SetReadWrite is part of the vtadminpb.VTAdminServer interface.

func (*API) StartReplication 

func (api *API) StartReplication(ctx context.Context, req *vtadminpb.StartReplicationRequest) (*vtadminpb.StartReplicationResponse, error)

StartReplication is part of the vtadminpb.VTAdminServer interface.

func (*API) StopReplication 

func (api *API) StopReplication(ctx context.Context, req *vtadminpb.StopReplicationRequest) (*vtadminpb.StopReplicationResponse, error)

StopReplication is part of the vtadminpb.VTAdminServer interface.

func (*API) TabletExternallyPromoted 

func (api *API) TabletExternallyPromoted(ctx context.Context, req *vtadminpb.TabletExternallyPromotedRequest) (*vtadminpb.TabletExternallyPromotedResponse, error)

TabletExternallyPromoted is part of the vtadminpb.VTAdminServer interface.

func (*API) VTExplain 

func (api *API) VTExplain(ctx context.Context, req *vtadminpb.VTExplainRequest) (*vtadminpb.VTExplainResponse, error)

VTExplain is part of the vtadminpb.VTAdminServer interface.

func (*API) Validate 

func (api *API) Validate(ctx context.Context, req *vtadminpb.ValidateRequest) (*vtctldatapb.ValidateResponse, error)

Validate is part of the vtadminpb.VTAdminServer interface.

func (*API) ValidateKeyspace 

func (api *API) ValidateKeyspace(ctx context.Context, req *vtadminpb.ValidateKeyspaceRequest) (*vtctldatapb.ValidateKeyspaceResponse, error)

ValidateKeyspace is part of the vtadminpb.VTAdminServer interface.

func (*API) ValidateSchemaKeyspace 

func (api *API) ValidateSchemaKeyspace(ctx context.Context, req *vtadminpb.ValidateSchemaKeyspaceRequest) (*vtctldatapb.ValidateSchemaKeyspaceResponse, error)

ValidateSchemaKeyspace is part of the vtadminpb.VTAdminServer interface.

func (*API) ValidateShard 

func (api *API) ValidateShard(ctx context.Context, req *vtadminpb.ValidateShardRequest) (*vtctldatapb.ValidateShardResponse, error)

ValidateShard is part of the vtadminpb.VTAdminServer interface.

func (*API) ValidateVersionKeyspace 

func (api *API) ValidateVersionKeyspace(ctx context.Context, req *vtadminpb.ValidateVersionKeyspaceRequest) (*vtctldatapb.ValidateVersionKeyspaceResponse, error)

ValidateVersionKeyspace is part of the vtadminpb.VTAdminServer interface.

func (*API) ValidateVersionShard 

func (api *API) ValidateVersionShard(ctx context.Context, req *vtadminpb.ValidateVersionShardRequest) (*vtctldatapb.ValidateVersionShardResponse, error)

ValidateVersionShard is part of the vtadminpb.VTAdminServer interface.

func (*API) WithCluster 

func (api *API) WithCluster(c *cluster.Cluster, id string) dynamic.API

WithCluster returns a dynamic API with the given cluster. If `c` is non-nil, it is used as the selected cluster. If the cluster is nil, then a cluster with the given id is retrieved from the API and used in the dynamic API.

Callers must ensure that: 1. If c is non-nil, c.ID == id. 2. id is non-empty.

Note that using dynamic.ClusterFromString ensures both of these preconditions.

type Options 

type Options struct {
	GRPCOpts grpcserver.Options
	HTTPOpts vtadminhttp.Options
	RBAC     *rbac.Config
	// EnableDynamicClusters makes it so that clients can pass clusters dynamically
	// in a session-like way, either via HTTP cookies or gRPC metadata.
	EnableDynamicClusters bool
}

Options wraps the configuration options for different components of the vtadmin API.

Source Files

View all Source files

Directories

Path Synopsis
Package cache provides a generic key/value cache with support for background filling.
 Package cache provides a generic key/value cache with support for background filling.
discovery
discovery/fakediscovery
Package fakediscovery provides a fake, in-memory discovery implementation.
 Package fakediscovery provides a fake, in-memory discovery implementation.
dynamic
internal/caches/schemacache
Package schemacache provides wrapper functions for interacting with instances of the generic (vtadmin/cache).Cache that store schemas.
 Package schemacache provides wrapper functions for interacting with instances of the generic (vtadmin/cache).Cache that store schemas.
resolver
Package resolver provides a discovery-based resolver for VTAdmin clusters.
 Package resolver provides a discovery-based resolver for VTAdmin clusters.
debug
experimental
handlers
internal
backoff
Package backoff implements different backoff strategies for retrying failed operations in VTAdmin.
 Package backoff implements different backoff strategies for retrying failed operations in VTAdmin.
Package rbac provides role-based access control for vtadmin API endpoints.
 Package rbac provides role-based access control for vtadmin API endpoints.
example
Package sort provides convenience wrappers for sorting various vtadmin types.
 Package sort provides convenience wrappers for sorting various vtadmin types.
authztestgen
Package vtadminproto provides helper functions for working with vtadminpb protobuf types.
 Package vtadminproto provides helper functions for working with vtadminpb protobuf types.
fakevtctldclient
fakevtsql
Package fakevtsql provides an interface for mocking out sql.DB responses in tests that depend on a vtsql.DB instance.
 Package fakevtsql provides an interface for mocking out sql.DB responses in tests that depend on a vtsql.DB instance.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.