Documentation ¶
Index ¶
- type API
- func (api *API) CreateKeyspace(ctx context.Context, req *vtadminpb.CreateKeyspaceRequest) (*vtadminpb.CreateKeyspaceResponse, error)
- func (api *API) DeleteKeyspace(ctx context.Context, req *vtadminpb.DeleteKeyspaceRequest) (*vtctldatapb.DeleteKeyspaceResponse, error)
- func (api *API) FindSchema(ctx context.Context, req *vtadminpb.FindSchemaRequest) (*vtadminpb.Schema, error)
- func (api *API) GetBackups(ctx context.Context, req *vtadminpb.GetBackupsRequest) (*vtadminpb.GetBackupsResponse, error)
- func (api *API) GetClusters(ctx context.Context, req *vtadminpb.GetClustersRequest) (*vtadminpb.GetClustersResponse, error)
- func (api *API) GetGates(ctx context.Context, req *vtadminpb.GetGatesRequest) (*vtadminpb.GetGatesResponse, error)
- func (api *API) GetKeyspace(ctx context.Context, req *vtadminpb.GetKeyspaceRequest) (*vtadminpb.Keyspace, error)
- func (api *API) GetKeyspaces(ctx context.Context, req *vtadminpb.GetKeyspacesRequest) (*vtadminpb.GetKeyspacesResponse, error)
- func (api *API) GetSchema(ctx context.Context, req *vtadminpb.GetSchemaRequest) (*vtadminpb.Schema, error)
- func (api *API) GetSchemas(ctx context.Context, req *vtadminpb.GetSchemasRequest) (*vtadminpb.GetSchemasResponse, error)
- func (api *API) GetShardReplicationPositions(ctx context.Context, req *vtadminpb.GetShardReplicationPositionsRequest) (*vtadminpb.GetShardReplicationPositionsResponse, error)
- func (api *API) GetSrvVSchema(ctx context.Context, req *vtadminpb.GetSrvVSchemaRequest) (*vtadminpb.SrvVSchema, error)
- func (api *API) GetSrvVSchemas(ctx context.Context, req *vtadminpb.GetSrvVSchemasRequest) (*vtadminpb.GetSrvVSchemasResponse, error)
- func (api *API) GetTablet(ctx context.Context, req *vtadminpb.GetTabletRequest) (*vtadminpb.Tablet, error)
- func (api *API) GetTablets(ctx context.Context, req *vtadminpb.GetTabletsRequest) (*vtadminpb.GetTabletsResponse, error)
- func (api *API) GetVSchema(ctx context.Context, req *vtadminpb.GetVSchemaRequest) (*vtadminpb.VSchema, error)
- func (api *API) GetVSchemas(ctx context.Context, req *vtadminpb.GetVSchemasRequest) (*vtadminpb.GetVSchemasResponse, error)
- func (api *API) GetVtctlds(ctx context.Context, req *vtadminpb.GetVtctldsRequest) (*vtadminpb.GetVtctldsResponse, error)
- func (api *API) GetWorkflow(ctx context.Context, req *vtadminpb.GetWorkflowRequest) (*vtadminpb.Workflow, error)
- func (api *API) GetWorkflows(ctx context.Context, req *vtadminpb.GetWorkflowsRequest) (*vtadminpb.GetWorkflowsResponse, error)
- func (api *API) ListenAndServe() error
- func (api *API) VTExplain(ctx context.Context, req *vtadminpb.VTExplainRequest) (*vtadminpb.VTExplainResponse, error)
- type Options
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 ¶
NewAPI returns a new API, configured to service the given set of clusters, and configured with the given options.
If opts.GRPCOpts.Services is nil, NewAPI will automatically add "vtadmin.VTAdminServer" to the list of services queryable in the healthcheck service. Callers can opt-out of this behavior by explicitly setting this value to the empty slice.
func (*API) CreateKeyspace ¶ added in v0.12.0
func (api *API) CreateKeyspace(ctx context.Context, req *vtadminpb.CreateKeyspaceRequest) (*vtadminpb.CreateKeyspaceResponse, error)
CreateKeyspace is part of the vtadminpb.VTAdminServer interface.
func (*API) DeleteKeyspace ¶ added in v0.12.0
func (api *API) DeleteKeyspace(ctx context.Context, req *vtadminpb.DeleteKeyspaceRequest) (*vtctldatapb.DeleteKeyspaceResponse, error)
DeleteKeyspace is part of the vtadminpb.VTAdminServer interface.
func (*API) FindSchema ¶ added in v0.10.0
func (api *API) FindSchema(ctx context.Context, req *vtadminpb.FindSchemaRequest) (*vtadminpb.Schema, error)
FindSchema is part of the vtadminpb.VTAdminServer interface.
func (*API) GetBackups ¶ added in v0.11.0
func (api *API) GetBackups(ctx context.Context, req *vtadminpb.GetBackupsRequest) (*vtadminpb.GetBackupsResponse, error)
GetBackups is part of the vtadminpb.VTAdminServer interface.
func (*API) GetClusters ¶ added in v0.10.0
func (api *API) GetClusters(ctx context.Context, req *vtadminpb.GetClustersRequest) (*vtadminpb.GetClustersResponse, error)
GetClusters 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 ¶ added in v0.11.0
func (api *API) GetKeyspace(ctx context.Context, req *vtadminpb.GetKeyspaceRequest) (*vtadminpb.Keyspace, error)
GetKeyspace is part of the vtadminpb.VTAdminServer interface.
func (*API) GetKeyspaces ¶ added in v0.10.0
func (api *API) GetKeyspaces(ctx context.Context, req *vtadminpb.GetKeyspacesRequest) (*vtadminpb.GetKeyspacesResponse, error)
GetKeyspaces is part of the vtadminpb.VTAdminServer interface.
func (*API) GetSchema ¶ added in v0.10.0
func (api *API) GetSchema(ctx context.Context, req *vtadminpb.GetSchemaRequest) (*vtadminpb.Schema, error)
GetSchema is part of the vtadminpb.VTAdminServer interface.
func (*API) GetSchemas ¶ added in v0.10.0
func (api *API) GetSchemas(ctx context.Context, req *vtadminpb.GetSchemasRequest) (*vtadminpb.GetSchemasResponse, error)
GetSchemas is part of the vtadminpb.VTAdminServer interface.
func (*API) GetShardReplicationPositions ¶ added in v0.12.0
func (api *API) GetShardReplicationPositions(ctx context.Context, req *vtadminpb.GetShardReplicationPositionsRequest) (*vtadminpb.GetShardReplicationPositionsResponse, error)
GetShardReplicationPositions is part of the vtadminpb.VTAdminServer interface.
func (*API) GetSrvVSchema ¶ added in v0.11.0
func (api *API) GetSrvVSchema(ctx context.Context, req *vtadminpb.GetSrvVSchemaRequest) (*vtadminpb.SrvVSchema, error)
GetSrvVSchema is part of the vtadminpb.VTAdminServer interface.
func (*API) GetSrvVSchemas ¶ added in v0.11.0
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) GetVSchema ¶ added in v0.10.0
func (api *API) GetVSchema(ctx context.Context, req *vtadminpb.GetVSchemaRequest) (*vtadminpb.VSchema, error)
GetVSchema is part of the vtadminpb.VTAdminServer interface.
func (*API) GetVSchemas ¶ added in v0.10.0
func (api *API) GetVSchemas(ctx context.Context, req *vtadminpb.GetVSchemasRequest) (*vtadminpb.GetVSchemasResponse, error)
GetVSchemas is part of the vtadminpb.VTAdminServer interface.
func (*API) GetVtctlds ¶ added in v0.12.0
func (api *API) GetVtctlds(ctx context.Context, req *vtadminpb.GetVtctldsRequest) (*vtadminpb.GetVtctldsResponse, error)
GetVtctlds is part of the vtadminpb.VTAdminServer interface.
func (*API) GetWorkflow ¶ added in v0.10.0
func (api *API) GetWorkflow(ctx context.Context, req *vtadminpb.GetWorkflowRequest) (*vtadminpb.Workflow, error)
GetWorkflow is part of the vtadminpb.VTAdminServer interface.
func (*API) GetWorkflows ¶ added in v0.10.0
func (api *API) GetWorkflows(ctx context.Context, req *vtadminpb.GetWorkflowsRequest) (*vtadminpb.GetWorkflowsResponse, error)
GetWorkflows is part of the vtadminpb.VTAdminServer interface.
func (*API) ListenAndServe ¶
ListenAndServe starts serving this API on the configured Addr (see grpcserver.Options) until shutdown or irrecoverable error occurs.
func (*API) VTExplain ¶ added in v0.10.0
func (api *API) VTExplain(ctx context.Context, req *vtadminpb.VTExplainRequest) (*vtadminpb.VTExplainResponse, error)
VTExplain is part of the vtadminpb.VTAdminServer interface.
type Options ¶ added in v0.12.0
type Options struct { GRPCOpts grpcserver.Options HTTPOpts vtadminhttp.Options RBAC *rbac.Config }
Options wraps the configuration options for different components of the vtadmin API.
Directories ¶
Path | Synopsis |
---|---|
discovery/fakediscovery
Package fakediscovery provides a fake, in-memory discovery implementation.
|
Package fakediscovery provides a fake, in-memory discovery implementation. |
Package rbac provides role-based access control for vtadmin API endpoints.
|
Package rbac provides role-based access control for vtadmin API endpoints. |
Package sort provides convenience wrappers for sorting various vtadmin types.
|
Package sort provides convenience wrappers for sorting various vtadmin types. |
Package vtadminproto provides helper functions for working with vtadminpb protobuf types.
|
Package vtadminproto provides helper functions for working with vtadminpb protobuf types. |
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. |