vtadmin

Oct 29, 2024

Changes in this version

+ type ConcludeTransactionRequest struct

+ ClusterId string

+ Dtid string

+ func (*ConcludeTransactionRequest) Descriptor() ([]byte, []int)

+ func (*ConcludeTransactionRequest) ProtoMessage()

+ func (m *ConcludeTransactionRequest) CloneMessageVT() proto.Message

+ func (m *ConcludeTransactionRequest) CloneVT() *ConcludeTransactionRequest

+ func (m *ConcludeTransactionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ConcludeTransactionRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ConcludeTransactionRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ConcludeTransactionRequest) SizeVT() (n int)

+ func (m *ConcludeTransactionRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ConcludeTransactionRequest) GetClusterId() string

+ func (x *ConcludeTransactionRequest) GetDtid() string

+ func (x *ConcludeTransactionRequest) ProtoReflect() protoreflect.Message

+ func (x *ConcludeTransactionRequest) Reset()

+ func (x *ConcludeTransactionRequest) String() string

+ type GetUnresolvedTransactionsRequest struct

+ AbandonAge int64

+ ClusterId string

+ Keyspace string

+ func (*GetUnresolvedTransactionsRequest) Descriptor() ([]byte, []int)

+ func (*GetUnresolvedTransactionsRequest) ProtoMessage()

+ func (m *GetUnresolvedTransactionsRequest) CloneMessageVT() proto.Message

+ func (m *GetUnresolvedTransactionsRequest) CloneVT() *GetUnresolvedTransactionsRequest

+ func (m *GetUnresolvedTransactionsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetUnresolvedTransactionsRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetUnresolvedTransactionsRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetUnresolvedTransactionsRequest) SizeVT() (n int)

+ func (m *GetUnresolvedTransactionsRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetUnresolvedTransactionsRequest) GetAbandonAge() int64

+ func (x *GetUnresolvedTransactionsRequest) GetClusterId() string

+ func (x *GetUnresolvedTransactionsRequest) GetKeyspace() string

+ func (x *GetUnresolvedTransactionsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetUnresolvedTransactionsRequest) Reset()

+ func (x *GetUnresolvedTransactionsRequest) String() string

+ type GetWorkflowStatusRequest struct

+ ClusterId string

+ Keyspace string

+ Name string

+ func (*GetWorkflowStatusRequest) Descriptor() ([]byte, []int)

+ func (*GetWorkflowStatusRequest) ProtoMessage()

+ func (m *GetWorkflowStatusRequest) CloneMessageVT() proto.Message

+ func (m *GetWorkflowStatusRequest) CloneVT() *GetWorkflowStatusRequest

+ func (m *GetWorkflowStatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetWorkflowStatusRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetWorkflowStatusRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetWorkflowStatusRequest) SizeVT() (n int)

+ func (m *GetWorkflowStatusRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetWorkflowStatusRequest) GetClusterId() string

+ func (x *GetWorkflowStatusRequest) GetKeyspace() string

+ func (x *GetWorkflowStatusRequest) GetName() string

+ func (x *GetWorkflowStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *GetWorkflowStatusRequest) Reset()

+ func (x *GetWorkflowStatusRequest) String() string

+ type MoveTablesCreateRequest struct

+ ClusterId string

+ Request *vtctldata.MoveTablesCreateRequest

+ func (*MoveTablesCreateRequest) Descriptor() ([]byte, []int)

+ func (*MoveTablesCreateRequest) ProtoMessage()

+ func (m *MoveTablesCreateRequest) CloneMessageVT() proto.Message

+ func (m *MoveTablesCreateRequest) CloneVT() *MoveTablesCreateRequest

+ func (m *MoveTablesCreateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *MoveTablesCreateRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *MoveTablesCreateRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *MoveTablesCreateRequest) SizeVT() (n int)

+ func (m *MoveTablesCreateRequest) UnmarshalVT(dAtA []byte) error

+ func (x *MoveTablesCreateRequest) GetClusterId() string

+ func (x *MoveTablesCreateRequest) GetRequest() *vtctldata.MoveTablesCreateRequest

+ func (x *MoveTablesCreateRequest) ProtoReflect() protoreflect.Message

+ func (x *MoveTablesCreateRequest) Reset()

+ func (x *MoveTablesCreateRequest) String() string

+ type StartWorkflowRequest struct

+ ClusterId string

+ Keyspace string

+ Workflow string

+ func (*StartWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*StartWorkflowRequest) ProtoMessage()

+ func (m *StartWorkflowRequest) CloneMessageVT() proto.Message

+ func (m *StartWorkflowRequest) CloneVT() *StartWorkflowRequest

+ func (m *StartWorkflowRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *StartWorkflowRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *StartWorkflowRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *StartWorkflowRequest) SizeVT() (n int)

+ func (m *StartWorkflowRequest) UnmarshalVT(dAtA []byte) error

+ func (x *StartWorkflowRequest) GetClusterId() string

+ func (x *StartWorkflowRequest) GetKeyspace() string

+ func (x *StartWorkflowRequest) GetWorkflow() string

+ func (x *StartWorkflowRequest) ProtoReflect() protoreflect.Message

+ func (x *StartWorkflowRequest) Reset()

+ func (x *StartWorkflowRequest) String() string

+ type StopWorkflowRequest struct

+ ClusterId string

+ Keyspace string

+ Workflow string

+ func (*StopWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*StopWorkflowRequest) ProtoMessage()

+ func (m *StopWorkflowRequest) CloneMessageVT() proto.Message

+ func (m *StopWorkflowRequest) CloneVT() *StopWorkflowRequest

+ func (m *StopWorkflowRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *StopWorkflowRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *StopWorkflowRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *StopWorkflowRequest) SizeVT() (n int)

+ func (m *StopWorkflowRequest) UnmarshalVT(dAtA []byte) error

+ func (x *StopWorkflowRequest) GetClusterId() string

+ func (x *StopWorkflowRequest) GetKeyspace() string

+ func (x *StopWorkflowRequest) GetWorkflow() string

+ func (x *StopWorkflowRequest) ProtoReflect() protoreflect.Message

+ func (x *StopWorkflowRequest) Reset()

+ func (x *StopWorkflowRequest) String() string

type UnimplementedVTAdminServer

+ func (UnimplementedVTAdminServer) ConcludeTransaction(context.Context, *ConcludeTransactionRequest) (*vtctldata.ConcludeTransactionResponse, error)

+ func (UnimplementedVTAdminServer) GetUnresolvedTransactions(context.Context, *GetUnresolvedTransactionsRequest) (*vtctldata.GetUnresolvedTransactionsResponse, error)

+ func (UnimplementedVTAdminServer) GetWorkflowStatus(context.Context, *GetWorkflowStatusRequest) (*vtctldata.WorkflowStatusResponse, error)

+ func (UnimplementedVTAdminServer) MoveTablesCreate(context.Context, *MoveTablesCreateRequest) (*vtctldata.WorkflowStatusResponse, error)

+ func (UnimplementedVTAdminServer) StartWorkflow(context.Context, *StartWorkflowRequest) (*vtctldata.WorkflowUpdateResponse, error)

+ func (UnimplementedVTAdminServer) StopWorkflow(context.Context, *StopWorkflowRequest) (*vtctldata.WorkflowUpdateResponse, error)

type VTAdminClient

+ ConcludeTransaction func(ctx context.Context, in *ConcludeTransactionRequest, opts ...grpc.CallOption) (*vtctldata.ConcludeTransactionResponse, error)

+ GetUnresolvedTransactions func(ctx context.Context, in *GetUnresolvedTransactionsRequest, ...) (*vtctldata.GetUnresolvedTransactionsResponse, error)

+ GetWorkflowStatus func(ctx context.Context, in *GetWorkflowStatusRequest, opts ...grpc.CallOption) (*vtctldata.WorkflowStatusResponse, error)

+ MoveTablesCreate func(ctx context.Context, in *MoveTablesCreateRequest, opts ...grpc.CallOption) (*vtctldata.WorkflowStatusResponse, error)

+ StartWorkflow func(ctx context.Context, in *StartWorkflowRequest, opts ...grpc.CallOption) (*vtctldata.WorkflowUpdateResponse, error)

+ StopWorkflow func(ctx context.Context, in *StopWorkflowRequest, opts ...grpc.CallOption) (*vtctldata.WorkflowUpdateResponse, error)

type VTAdminServer

+ ConcludeTransaction func(context.Context, *ConcludeTransactionRequest) (*vtctldata.ConcludeTransactionResponse, error)

+ GetUnresolvedTransactions func(context.Context, *GetUnresolvedTransactionsRequest) (*vtctldata.GetUnresolvedTransactionsResponse, error)

+ GetWorkflowStatus func(context.Context, *GetWorkflowStatusRequest) (*vtctldata.WorkflowStatusResponse, error)

+ MoveTablesCreate func(context.Context, *MoveTablesCreateRequest) (*vtctldata.WorkflowStatusResponse, error)

+ StartWorkflow func(context.Context, *StartWorkflowRequest) (*vtctldata.WorkflowUpdateResponse, error)

+ StopWorkflow func(context.Context, *StopWorkflowRequest) (*vtctldata.WorkflowUpdateResponse, error)

Apr 4, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Apr 4, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Mar 14, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Mar 6, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ type ApplySchemaRequest struct

+ ClusterId string

+ Request *vtctldata.ApplySchemaRequest

+ func (*ApplySchemaRequest) Descriptor() ([]byte, []int)

+ func (*ApplySchemaRequest) ProtoMessage()

+ func (m *ApplySchemaRequest) CloneMessageVT() proto.Message

+ func (m *ApplySchemaRequest) CloneVT() *ApplySchemaRequest

+ func (m *ApplySchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ApplySchemaRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ApplySchemaRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ApplySchemaRequest) SizeVT() (n int)

+ func (m *ApplySchemaRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ApplySchemaRequest) GetClusterId() string

+ func (x *ApplySchemaRequest) GetRequest() *vtctldata.ApplySchemaRequest

+ func (x *ApplySchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *ApplySchemaRequest) Reset()

+ func (x *ApplySchemaRequest) String() string

+ type CancelSchemaMigrationRequest struct

+ ClusterId string

+ Request *vtctldata.CancelSchemaMigrationRequest

+ func (*CancelSchemaMigrationRequest) Descriptor() ([]byte, []int)

+ func (*CancelSchemaMigrationRequest) ProtoMessage()

+ func (m *CancelSchemaMigrationRequest) CloneMessageVT() proto.Message

+ func (m *CancelSchemaMigrationRequest) CloneVT() *CancelSchemaMigrationRequest

+ func (m *CancelSchemaMigrationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *CancelSchemaMigrationRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *CancelSchemaMigrationRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *CancelSchemaMigrationRequest) SizeVT() (n int)

+ func (m *CancelSchemaMigrationRequest) UnmarshalVT(dAtA []byte) error

+ func (x *CancelSchemaMigrationRequest) GetClusterId() string

+ func (x *CancelSchemaMigrationRequest) GetRequest() *vtctldata.CancelSchemaMigrationRequest

+ func (x *CancelSchemaMigrationRequest) ProtoReflect() protoreflect.Message

+ func (x *CancelSchemaMigrationRequest) Reset()

+ func (x *CancelSchemaMigrationRequest) String() string

+ type CleanupSchemaMigrationRequest struct

+ ClusterId string

+ Request *vtctldata.CleanupSchemaMigrationRequest

+ func (*CleanupSchemaMigrationRequest) Descriptor() ([]byte, []int)

+ func (*CleanupSchemaMigrationRequest) ProtoMessage()

+ func (m *CleanupSchemaMigrationRequest) CloneMessageVT() proto.Message

+ func (m *CleanupSchemaMigrationRequest) CloneVT() *CleanupSchemaMigrationRequest

+ func (m *CleanupSchemaMigrationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *CleanupSchemaMigrationRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *CleanupSchemaMigrationRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *CleanupSchemaMigrationRequest) SizeVT() (n int)

+ func (m *CleanupSchemaMigrationRequest) UnmarshalVT(dAtA []byte) error

+ func (x *CleanupSchemaMigrationRequest) GetClusterId() string

+ func (x *CleanupSchemaMigrationRequest) GetRequest() *vtctldata.CleanupSchemaMigrationRequest

+ func (x *CleanupSchemaMigrationRequest) ProtoReflect() protoreflect.Message

+ func (x *CleanupSchemaMigrationRequest) Reset()

+ func (x *CleanupSchemaMigrationRequest) String() string

+ type CompleteSchemaMigrationRequest struct

+ ClusterId string

+ Request *vtctldata.CompleteSchemaMigrationRequest

+ func (*CompleteSchemaMigrationRequest) Descriptor() ([]byte, []int)

+ func (*CompleteSchemaMigrationRequest) ProtoMessage()

+ func (m *CompleteSchemaMigrationRequest) CloneMessageVT() proto.Message

+ func (m *CompleteSchemaMigrationRequest) CloneVT() *CompleteSchemaMigrationRequest

+ func (m *CompleteSchemaMigrationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *CompleteSchemaMigrationRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *CompleteSchemaMigrationRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *CompleteSchemaMigrationRequest) SizeVT() (n int)

+ func (m *CompleteSchemaMigrationRequest) UnmarshalVT(dAtA []byte) error

+ func (x *CompleteSchemaMigrationRequest) GetClusterId() string

+ func (x *CompleteSchemaMigrationRequest) GetRequest() *vtctldata.CompleteSchemaMigrationRequest

+ func (x *CompleteSchemaMigrationRequest) ProtoReflect() protoreflect.Message

+ func (x *CompleteSchemaMigrationRequest) Reset()

+ func (x *CompleteSchemaMigrationRequest) String() string

+ type GetSchemaMigrationsRequest struct

+ ClusterRequests []*GetSchemaMigrationsRequest_ClusterRequest

+ func (*GetSchemaMigrationsRequest) Descriptor() ([]byte, []int)

+ func (*GetSchemaMigrationsRequest) ProtoMessage()

+ func (m *GetSchemaMigrationsRequest) CloneMessageVT() proto.Message

+ func (m *GetSchemaMigrationsRequest) CloneVT() *GetSchemaMigrationsRequest

+ func (m *GetSchemaMigrationsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSchemaMigrationsRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSchemaMigrationsRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSchemaMigrationsRequest) SizeVT() (n int)

+ func (m *GetSchemaMigrationsRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetSchemaMigrationsRequest) GetClusterRequests() []*GetSchemaMigrationsRequest_ClusterRequest

+ func (x *GetSchemaMigrationsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSchemaMigrationsRequest) Reset()

+ func (x *GetSchemaMigrationsRequest) String() string

+ type GetSchemaMigrationsRequest_ClusterRequest struct

+ ClusterId string

+ Request *vtctldata.GetSchemaMigrationsRequest

+ func (*GetSchemaMigrationsRequest_ClusterRequest) Descriptor() ([]byte, []int)

+ func (*GetSchemaMigrationsRequest_ClusterRequest) ProtoMessage()

+ func (m *GetSchemaMigrationsRequest_ClusterRequest) CloneMessageVT() proto.Message

+ func (m *GetSchemaMigrationsRequest_ClusterRequest) CloneVT() *GetSchemaMigrationsRequest_ClusterRequest

+ func (m *GetSchemaMigrationsRequest_ClusterRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSchemaMigrationsRequest_ClusterRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSchemaMigrationsRequest_ClusterRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSchemaMigrationsRequest_ClusterRequest) SizeVT() (n int)

+ func (m *GetSchemaMigrationsRequest_ClusterRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetSchemaMigrationsRequest_ClusterRequest) GetClusterId() string

+ func (x *GetSchemaMigrationsRequest_ClusterRequest) GetRequest() *vtctldata.GetSchemaMigrationsRequest

+ func (x *GetSchemaMigrationsRequest_ClusterRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSchemaMigrationsRequest_ClusterRequest) Reset()

+ func (x *GetSchemaMigrationsRequest_ClusterRequest) String() string

+ type GetSchemaMigrationsResponse struct

+ SchemaMigrations []*SchemaMigration

+ func (*GetSchemaMigrationsResponse) Descriptor() ([]byte, []int)

+ func (*GetSchemaMigrationsResponse) ProtoMessage()

+ func (m *GetSchemaMigrationsResponse) CloneMessageVT() proto.Message

+ func (m *GetSchemaMigrationsResponse) CloneVT() *GetSchemaMigrationsResponse

+ func (m *GetSchemaMigrationsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSchemaMigrationsResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSchemaMigrationsResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSchemaMigrationsResponse) SizeVT() (n int)

+ func (m *GetSchemaMigrationsResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetSchemaMigrationsResponse) GetSchemaMigrations() []*SchemaMigration

+ func (x *GetSchemaMigrationsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetSchemaMigrationsResponse) Reset()

+ func (x *GetSchemaMigrationsResponse) String() string

+ type LaunchSchemaMigrationRequest struct

+ ClusterId string

+ Request *vtctldata.LaunchSchemaMigrationRequest

+ func (*LaunchSchemaMigrationRequest) Descriptor() ([]byte, []int)

+ func (*LaunchSchemaMigrationRequest) ProtoMessage()

+ func (m *LaunchSchemaMigrationRequest) CloneMessageVT() proto.Message

+ func (m *LaunchSchemaMigrationRequest) CloneVT() *LaunchSchemaMigrationRequest

+ func (m *LaunchSchemaMigrationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *LaunchSchemaMigrationRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *LaunchSchemaMigrationRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *LaunchSchemaMigrationRequest) SizeVT() (n int)

+ func (m *LaunchSchemaMigrationRequest) UnmarshalVT(dAtA []byte) error

+ func (x *LaunchSchemaMigrationRequest) GetClusterId() string

+ func (x *LaunchSchemaMigrationRequest) GetRequest() *vtctldata.LaunchSchemaMigrationRequest

+ func (x *LaunchSchemaMigrationRequest) ProtoReflect() protoreflect.Message

+ func (x *LaunchSchemaMigrationRequest) Reset()

+ func (x *LaunchSchemaMigrationRequest) String() string

+ type RetrySchemaMigrationRequest struct

+ ClusterId string

+ Request *vtctldata.RetrySchemaMigrationRequest

+ func (*RetrySchemaMigrationRequest) Descriptor() ([]byte, []int)

+ func (*RetrySchemaMigrationRequest) ProtoMessage()

+ func (m *RetrySchemaMigrationRequest) CloneMessageVT() proto.Message

+ func (m *RetrySchemaMigrationRequest) CloneVT() *RetrySchemaMigrationRequest

+ func (m *RetrySchemaMigrationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RetrySchemaMigrationRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RetrySchemaMigrationRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *RetrySchemaMigrationRequest) SizeVT() (n int)

+ func (m *RetrySchemaMigrationRequest) UnmarshalVT(dAtA []byte) error

+ func (x *RetrySchemaMigrationRequest) GetClusterId() string

+ func (x *RetrySchemaMigrationRequest) GetRequest() *vtctldata.RetrySchemaMigrationRequest

+ func (x *RetrySchemaMigrationRequest) ProtoReflect() protoreflect.Message

+ func (x *RetrySchemaMigrationRequest) Reset()

+ func (x *RetrySchemaMigrationRequest) String() string

+ type SchemaMigration struct

+ Cluster *Cluster

+ SchemaMigration *vtctldata.SchemaMigration

+ func (*SchemaMigration) Descriptor() ([]byte, []int)

+ func (*SchemaMigration) ProtoMessage()

+ func (m *SchemaMigration) CloneMessageVT() proto.Message

+ func (m *SchemaMigration) CloneVT() *SchemaMigration

+ func (m *SchemaMigration) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SchemaMigration) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SchemaMigration) MarshalVT() (dAtA []byte, err error)

+ func (m *SchemaMigration) SizeVT() (n int)

+ func (m *SchemaMigration) UnmarshalVT(dAtA []byte) error

+ func (x *SchemaMigration) GetCluster() *Cluster

+ func (x *SchemaMigration) GetSchemaMigration() *vtctldata.SchemaMigration

+ func (x *SchemaMigration) ProtoReflect() protoreflect.Message

+ func (x *SchemaMigration) Reset()

+ func (x *SchemaMigration) String() string

type UnimplementedVTAdminServer

+ func (UnimplementedVTAdminServer) ApplySchema(context.Context, *ApplySchemaRequest) (*vtctldata.ApplySchemaResponse, error)

+ func (UnimplementedVTAdminServer) CancelSchemaMigration(context.Context, *CancelSchemaMigrationRequest) (*vtctldata.CancelSchemaMigrationResponse, error)

+ func (UnimplementedVTAdminServer) CleanupSchemaMigration(context.Context, *CleanupSchemaMigrationRequest) (*vtctldata.CleanupSchemaMigrationResponse, error)

+ func (UnimplementedVTAdminServer) CompleteSchemaMigration(context.Context, *CompleteSchemaMigrationRequest) (*vtctldata.CompleteSchemaMigrationResponse, error)

+ func (UnimplementedVTAdminServer) GetSchemaMigrations(context.Context, *GetSchemaMigrationsRequest) (*GetSchemaMigrationsResponse, error)

+ func (UnimplementedVTAdminServer) LaunchSchemaMigration(context.Context, *LaunchSchemaMigrationRequest) (*vtctldata.LaunchSchemaMigrationResponse, error)

+ func (UnimplementedVTAdminServer) RetrySchemaMigration(context.Context, *RetrySchemaMigrationRequest) (*vtctldata.RetrySchemaMigrationResponse, error)

type VTAdminClient

+ ApplySchema func(ctx context.Context, in *ApplySchemaRequest, opts ...grpc.CallOption) (*vtctldata.ApplySchemaResponse, error)

+ CancelSchemaMigration func(ctx context.Context, in *CancelSchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldata.CancelSchemaMigrationResponse, error)

+ CleanupSchemaMigration func(ctx context.Context, in *CleanupSchemaMigrationRequest, ...) (*vtctldata.CleanupSchemaMigrationResponse, error)

+ CompleteSchemaMigration func(ctx context.Context, in *CompleteSchemaMigrationRequest, ...) (*vtctldata.CompleteSchemaMigrationResponse, error)

+ GetSchemaMigrations func(ctx context.Context, in *GetSchemaMigrationsRequest, opts ...grpc.CallOption) (*GetSchemaMigrationsResponse, error)

+ LaunchSchemaMigration func(ctx context.Context, in *LaunchSchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldata.LaunchSchemaMigrationResponse, error)

+ RetrySchemaMigration func(ctx context.Context, in *RetrySchemaMigrationRequest, opts ...grpc.CallOption) (*vtctldata.RetrySchemaMigrationResponse, error)

type VTAdminServer

+ ApplySchema func(context.Context, *ApplySchemaRequest) (*vtctldata.ApplySchemaResponse, error)

+ CancelSchemaMigration func(context.Context, *CancelSchemaMigrationRequest) (*vtctldata.CancelSchemaMigrationResponse, error)

+ CleanupSchemaMigration func(context.Context, *CleanupSchemaMigrationRequest) (*vtctldata.CleanupSchemaMigrationResponse, error)

+ CompleteSchemaMigration func(context.Context, *CompleteSchemaMigrationRequest) (*vtctldata.CompleteSchemaMigrationResponse, error)

+ GetSchemaMigrations func(context.Context, *GetSchemaMigrationsRequest) (*GetSchemaMigrationsResponse, error)

+ LaunchSchemaMigration func(context.Context, *LaunchSchemaMigrationRequest) (*vtctldata.LaunchSchemaMigrationResponse, error)

+ RetrySchemaMigration func(context.Context, *RetrySchemaMigrationRequest) (*vtctldata.RetrySchemaMigrationResponse, error)

Apr 4, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Mar 14, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 20, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Nov 22, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Nov 6, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

type Cluster

+ func (m *Cluster) CloneMessageVT() proto.Message

+ func (m *Cluster) CloneVT() *Cluster

type ClusterBackup

+ func (m *ClusterBackup) CloneMessageVT() proto.Message

+ func (m *ClusterBackup) CloneVT() *ClusterBackup

type ClusterCellInfo

+ func (m *ClusterCellInfo) CloneMessageVT() proto.Message

+ func (m *ClusterCellInfo) CloneVT() *ClusterCellInfo

type ClusterCellsAliases

+ func (m *ClusterCellsAliases) CloneMessageVT() proto.Message

+ func (m *ClusterCellsAliases) CloneVT() *ClusterCellsAliases

type ClusterShardReplicationPosition

+ func (m *ClusterShardReplicationPosition) CloneMessageVT() proto.Message

+ func (m *ClusterShardReplicationPosition) CloneVT() *ClusterShardReplicationPosition

type ClusterWorkflows

+ func (m *ClusterWorkflows) CloneMessageVT() proto.Message

+ func (m *ClusterWorkflows) CloneVT() *ClusterWorkflows

type CreateKeyspaceRequest

+ func (m *CreateKeyspaceRequest) CloneMessageVT() proto.Message

+ func (m *CreateKeyspaceRequest) CloneVT() *CreateKeyspaceRequest

type CreateKeyspaceResponse

+ func (m *CreateKeyspaceResponse) CloneMessageVT() proto.Message

+ func (m *CreateKeyspaceResponse) CloneVT() *CreateKeyspaceResponse

type CreateShardRequest

+ func (m *CreateShardRequest) CloneMessageVT() proto.Message

+ func (m *CreateShardRequest) CloneVT() *CreateShardRequest

type DeleteKeyspaceRequest

+ func (m *DeleteKeyspaceRequest) CloneMessageVT() proto.Message

+ func (m *DeleteKeyspaceRequest) CloneVT() *DeleteKeyspaceRequest

type DeleteShardsRequest

+ func (m *DeleteShardsRequest) CloneMessageVT() proto.Message

+ func (m *DeleteShardsRequest) CloneVT() *DeleteShardsRequest

type DeleteTabletRequest

+ func (m *DeleteTabletRequest) CloneMessageVT() proto.Message

+ func (m *DeleteTabletRequest) CloneVT() *DeleteTabletRequest

type DeleteTabletResponse

+ func (m *DeleteTabletResponse) CloneMessageVT() proto.Message

+ func (m *DeleteTabletResponse) CloneVT() *DeleteTabletResponse

type EmergencyFailoverShardRequest

+ func (m *EmergencyFailoverShardRequest) CloneMessageVT() proto.Message

+ func (m *EmergencyFailoverShardRequest) CloneVT() *EmergencyFailoverShardRequest

type EmergencyFailoverShardResponse

+ func (m *EmergencyFailoverShardResponse) CloneMessageVT() proto.Message

+ func (m *EmergencyFailoverShardResponse) CloneVT() *EmergencyFailoverShardResponse

type FindSchemaRequest

+ func (m *FindSchemaRequest) CloneMessageVT() proto.Message

+ func (m *FindSchemaRequest) CloneVT() *FindSchemaRequest

type GetBackupsRequest

+ func (m *GetBackupsRequest) CloneMessageVT() proto.Message

+ func (m *GetBackupsRequest) CloneVT() *GetBackupsRequest

type GetBackupsResponse

+ func (m *GetBackupsResponse) CloneMessageVT() proto.Message

+ func (m *GetBackupsResponse) CloneVT() *GetBackupsResponse

type GetCellInfosRequest

+ func (m *GetCellInfosRequest) CloneMessageVT() proto.Message

+ func (m *GetCellInfosRequest) CloneVT() *GetCellInfosRequest

type GetCellInfosResponse

+ func (m *GetCellInfosResponse) CloneMessageVT() proto.Message

+ func (m *GetCellInfosResponse) CloneVT() *GetCellInfosResponse

type GetCellsAliasesRequest

+ func (m *GetCellsAliasesRequest) CloneMessageVT() proto.Message

+ func (m *GetCellsAliasesRequest) CloneVT() *GetCellsAliasesRequest

type GetCellsAliasesResponse

+ func (m *GetCellsAliasesResponse) CloneMessageVT() proto.Message

+ func (m *GetCellsAliasesResponse) CloneVT() *GetCellsAliasesResponse

type GetClustersRequest

+ func (m *GetClustersRequest) CloneMessageVT() proto.Message

+ func (m *GetClustersRequest) CloneVT() *GetClustersRequest

type GetClustersResponse

+ func (m *GetClustersResponse) CloneMessageVT() proto.Message

+ func (m *GetClustersResponse) CloneVT() *GetClustersResponse

type GetFullStatusRequest

+ func (m *GetFullStatusRequest) CloneMessageVT() proto.Message

+ func (m *GetFullStatusRequest) CloneVT() *GetFullStatusRequest

type GetGatesRequest

+ func (m *GetGatesRequest) CloneMessageVT() proto.Message

+ func (m *GetGatesRequest) CloneVT() *GetGatesRequest

type GetGatesResponse

+ func (m *GetGatesResponse) CloneMessageVT() proto.Message

+ func (m *GetGatesResponse) CloneVT() *GetGatesResponse

type GetKeyspaceRequest

+ func (m *GetKeyspaceRequest) CloneMessageVT() proto.Message

+ func (m *GetKeyspaceRequest) CloneVT() *GetKeyspaceRequest

type GetKeyspacesRequest

+ func (m *GetKeyspacesRequest) CloneMessageVT() proto.Message

+ func (m *GetKeyspacesRequest) CloneVT() *GetKeyspacesRequest

type GetKeyspacesResponse

+ func (m *GetKeyspacesResponse) CloneMessageVT() proto.Message

+ func (m *GetKeyspacesResponse) CloneVT() *GetKeyspacesResponse

type GetSchemaRequest

+ func (m *GetSchemaRequest) CloneMessageVT() proto.Message

+ func (m *GetSchemaRequest) CloneVT() *GetSchemaRequest

type GetSchemaTableSizeOptions

+ func (m *GetSchemaTableSizeOptions) CloneMessageVT() proto.Message

+ func (m *GetSchemaTableSizeOptions) CloneVT() *GetSchemaTableSizeOptions

type GetSchemasRequest

+ func (m *GetSchemasRequest) CloneMessageVT() proto.Message

+ func (m *GetSchemasRequest) CloneVT() *GetSchemasRequest

type GetSchemasResponse

+ func (m *GetSchemasResponse) CloneMessageVT() proto.Message

+ func (m *GetSchemasResponse) CloneVT() *GetSchemasResponse

type GetShardReplicationPositionsRequest

+ func (m *GetShardReplicationPositionsRequest) CloneMessageVT() proto.Message

+ func (m *GetShardReplicationPositionsRequest) CloneVT() *GetShardReplicationPositionsRequest

type GetShardReplicationPositionsResponse

+ func (m *GetShardReplicationPositionsResponse) CloneMessageVT() proto.Message

+ func (m *GetShardReplicationPositionsResponse) CloneVT() *GetShardReplicationPositionsResponse

type GetSrvKeyspaceRequest

+ func (m *GetSrvKeyspaceRequest) CloneMessageVT() proto.Message

+ func (m *GetSrvKeyspaceRequest) CloneVT() *GetSrvKeyspaceRequest

type GetSrvKeyspacesRequest

+ func (m *GetSrvKeyspacesRequest) CloneMessageVT() proto.Message

+ func (m *GetSrvKeyspacesRequest) CloneVT() *GetSrvKeyspacesRequest

type GetSrvKeyspacesResponse

+ func (m *GetSrvKeyspacesResponse) CloneMessageVT() proto.Message

+ func (m *GetSrvKeyspacesResponse) CloneVT() *GetSrvKeyspacesResponse

type GetSrvVSchemaRequest

+ func (m *GetSrvVSchemaRequest) CloneMessageVT() proto.Message

+ func (m *GetSrvVSchemaRequest) CloneVT() *GetSrvVSchemaRequest

type GetSrvVSchemasRequest

+ func (m *GetSrvVSchemasRequest) CloneMessageVT() proto.Message

+ func (m *GetSrvVSchemasRequest) CloneVT() *GetSrvVSchemasRequest

type GetSrvVSchemasResponse

+ func (m *GetSrvVSchemasResponse) CloneMessageVT() proto.Message

+ func (m *GetSrvVSchemasResponse) CloneVT() *GetSrvVSchemasResponse

type GetTabletRequest

+ func (m *GetTabletRequest) CloneMessageVT() proto.Message

+ func (m *GetTabletRequest) CloneVT() *GetTabletRequest

type GetTabletsRequest

+ func (m *GetTabletsRequest) CloneMessageVT() proto.Message

+ func (m *GetTabletsRequest) CloneVT() *GetTabletsRequest

type GetTabletsResponse

+ func (m *GetTabletsResponse) CloneMessageVT() proto.Message

+ func (m *GetTabletsResponse) CloneVT() *GetTabletsResponse

type GetTopologyPathRequest

+ func (m *GetTopologyPathRequest) CloneMessageVT() proto.Message

+ func (m *GetTopologyPathRequest) CloneVT() *GetTopologyPathRequest

type GetVSchemaRequest

+ func (m *GetVSchemaRequest) CloneMessageVT() proto.Message

+ func (m *GetVSchemaRequest) CloneVT() *GetVSchemaRequest

type GetVSchemasRequest

+ func (m *GetVSchemasRequest) CloneMessageVT() proto.Message

+ func (m *GetVSchemasRequest) CloneVT() *GetVSchemasRequest

type GetVSchemasResponse

+ func (m *GetVSchemasResponse) CloneMessageVT() proto.Message

+ func (m *GetVSchemasResponse) CloneVT() *GetVSchemasResponse

type GetVtctldsRequest

+ func (m *GetVtctldsRequest) CloneMessageVT() proto.Message

+ func (m *GetVtctldsRequest) CloneVT() *GetVtctldsRequest

type GetVtctldsResponse

+ func (m *GetVtctldsResponse) CloneMessageVT() proto.Message

+ func (m *GetVtctldsResponse) CloneVT() *GetVtctldsResponse

type GetWorkflowRequest

+ func (m *GetWorkflowRequest) CloneMessageVT() proto.Message

+ func (m *GetWorkflowRequest) CloneVT() *GetWorkflowRequest

type GetWorkflowsRequest

+ func (m *GetWorkflowsRequest) CloneMessageVT() proto.Message

+ func (m *GetWorkflowsRequest) CloneVT() *GetWorkflowsRequest

type GetWorkflowsResponse

+ func (m *GetWorkflowsResponse) CloneMessageVT() proto.Message

+ func (m *GetWorkflowsResponse) CloneVT() *GetWorkflowsResponse

type Keyspace

+ func (m *Keyspace) CloneMessageVT() proto.Message

+ func (m *Keyspace) CloneVT() *Keyspace

type PingTabletRequest

+ func (m *PingTabletRequest) CloneMessageVT() proto.Message

+ func (m *PingTabletRequest) CloneVT() *PingTabletRequest

type PingTabletResponse

+ func (m *PingTabletResponse) CloneMessageVT() proto.Message

+ func (m *PingTabletResponse) CloneVT() *PingTabletResponse

type PlannedFailoverShardRequest

+ func (m *PlannedFailoverShardRequest) CloneMessageVT() proto.Message

+ func (m *PlannedFailoverShardRequest) CloneVT() *PlannedFailoverShardRequest

type PlannedFailoverShardResponse

+ func (m *PlannedFailoverShardResponse) CloneMessageVT() proto.Message

+ func (m *PlannedFailoverShardResponse) CloneVT() *PlannedFailoverShardResponse

type RebuildKeyspaceGraphRequest

+ func (m *RebuildKeyspaceGraphRequest) CloneMessageVT() proto.Message

+ func (m *RebuildKeyspaceGraphRequest) CloneVT() *RebuildKeyspaceGraphRequest

type RebuildKeyspaceGraphResponse

+ func (m *RebuildKeyspaceGraphResponse) CloneMessageVT() proto.Message

+ func (m *RebuildKeyspaceGraphResponse) CloneVT() *RebuildKeyspaceGraphResponse

type RefreshStateRequest

+ func (m *RefreshStateRequest) CloneMessageVT() proto.Message

+ func (m *RefreshStateRequest) CloneVT() *RefreshStateRequest

type RefreshStateResponse

+ func (m *RefreshStateResponse) CloneMessageVT() proto.Message

+ func (m *RefreshStateResponse) CloneVT() *RefreshStateResponse

type RefreshTabletReplicationSourceRequest

+ func (m *RefreshTabletReplicationSourceRequest) CloneMessageVT() proto.Message

+ func (m *RefreshTabletReplicationSourceRequest) CloneVT() *RefreshTabletReplicationSourceRequest

type RefreshTabletReplicationSourceResponse

+ func (m *RefreshTabletReplicationSourceResponse) CloneMessageVT() proto.Message

+ func (m *RefreshTabletReplicationSourceResponse) CloneVT() *RefreshTabletReplicationSourceResponse

type ReloadSchemaShardRequest

+ func (m *ReloadSchemaShardRequest) CloneMessageVT() proto.Message

+ func (m *ReloadSchemaShardRequest) CloneVT() *ReloadSchemaShardRequest

type ReloadSchemaShardResponse

+ func (m *ReloadSchemaShardResponse) CloneMessageVT() proto.Message

+ func (m *ReloadSchemaShardResponse) CloneVT() *ReloadSchemaShardResponse

type ReloadSchemasRequest

+ func (m *ReloadSchemasRequest) CloneMessageVT() proto.Message

+ func (m *ReloadSchemasRequest) CloneVT() *ReloadSchemasRequest

type ReloadSchemasResponse

+ func (m *ReloadSchemasResponse) CloneMessageVT() proto.Message

+ func (m *ReloadSchemasResponse) CloneVT() *ReloadSchemasResponse

type ReloadSchemasResponse_KeyspaceResult

+ func (m *ReloadSchemasResponse_KeyspaceResult) CloneMessageVT() proto.Message

+ func (m *ReloadSchemasResponse_KeyspaceResult) CloneVT() *ReloadSchemasResponse_KeyspaceResult

type ReloadSchemasResponse_ShardResult

+ func (m *ReloadSchemasResponse_ShardResult) CloneMessageVT() proto.Message

+ func (m *ReloadSchemasResponse_ShardResult) CloneVT() *ReloadSchemasResponse_ShardResult

type ReloadSchemasResponse_TabletResult

+ func (m *ReloadSchemasResponse_TabletResult) CloneMessageVT() proto.Message

+ func (m *ReloadSchemasResponse_TabletResult) CloneVT() *ReloadSchemasResponse_TabletResult

type RemoveKeyspaceCellRequest

+ func (m *RemoveKeyspaceCellRequest) CloneMessageVT() proto.Message

+ func (m *RemoveKeyspaceCellRequest) CloneVT() *RemoveKeyspaceCellRequest

type RemoveKeyspaceCellResponse

+ func (m *RemoveKeyspaceCellResponse) CloneMessageVT() proto.Message

+ func (m *RemoveKeyspaceCellResponse) CloneVT() *RemoveKeyspaceCellResponse

type RunHealthCheckRequest

+ func (m *RunHealthCheckRequest) CloneMessageVT() proto.Message

+ func (m *RunHealthCheckRequest) CloneVT() *RunHealthCheckRequest

type RunHealthCheckResponse

+ func (m *RunHealthCheckResponse) CloneMessageVT() proto.Message

+ func (m *RunHealthCheckResponse) CloneVT() *RunHealthCheckResponse

type Schema

+ func (m *Schema) CloneMessageVT() proto.Message

+ func (m *Schema) CloneVT() *Schema

type Schema_ShardTableSize

+ func (m *Schema_ShardTableSize) CloneMessageVT() proto.Message

+ func (m *Schema_ShardTableSize) CloneVT() *Schema_ShardTableSize

type Schema_TableSize

+ func (m *Schema_TableSize) CloneMessageVT() proto.Message

+ func (m *Schema_TableSize) CloneVT() *Schema_TableSize

type SetReadOnlyRequest

+ func (m *SetReadOnlyRequest) CloneMessageVT() proto.Message

+ func (m *SetReadOnlyRequest) CloneVT() *SetReadOnlyRequest

type SetReadOnlyResponse

+ func (m *SetReadOnlyResponse) CloneMessageVT() proto.Message

+ func (m *SetReadOnlyResponse) CloneVT() *SetReadOnlyResponse

type SetReadWriteRequest

+ func (m *SetReadWriteRequest) CloneMessageVT() proto.Message

+ func (m *SetReadWriteRequest) CloneVT() *SetReadWriteRequest

type SetReadWriteResponse

+ func (m *SetReadWriteResponse) CloneMessageVT() proto.Message

+ func (m *SetReadWriteResponse) CloneVT() *SetReadWriteResponse

type Shard

+ func (m *Shard) CloneMessageVT() proto.Message

+ func (m *Shard) CloneVT() *Shard

type SrvVSchema

+ func (m *SrvVSchema) CloneMessageVT() proto.Message

+ func (m *SrvVSchema) CloneVT() *SrvVSchema

type StartReplicationRequest

+ func (m *StartReplicationRequest) CloneMessageVT() proto.Message

+ func (m *StartReplicationRequest) CloneVT() *StartReplicationRequest

type StartReplicationResponse

+ func (m *StartReplicationResponse) CloneMessageVT() proto.Message

+ func (m *StartReplicationResponse) CloneVT() *StartReplicationResponse

type StopReplicationRequest

+ func (m *StopReplicationRequest) CloneMessageVT() proto.Message

+ func (m *StopReplicationRequest) CloneVT() *StopReplicationRequest

type StopReplicationResponse

+ func (m *StopReplicationResponse) CloneMessageVT() proto.Message

+ func (m *StopReplicationResponse) CloneVT() *StopReplicationResponse

type Tablet

+ func (m *Tablet) CloneMessageVT() proto.Message

+ func (m *Tablet) CloneVT() *Tablet

type TabletExternallyPromotedRequest

+ func (m *TabletExternallyPromotedRequest) CloneMessageVT() proto.Message

+ func (m *TabletExternallyPromotedRequest) CloneVT() *TabletExternallyPromotedRequest

type TabletExternallyPromotedResponse

+ func (m *TabletExternallyPromotedResponse) CloneMessageVT() proto.Message

+ func (m *TabletExternallyPromotedResponse) CloneVT() *TabletExternallyPromotedResponse

type TabletExternallyReparentedRequest

+ func (m *TabletExternallyReparentedRequest) CloneMessageVT() proto.Message

+ func (m *TabletExternallyReparentedRequest) CloneVT() *TabletExternallyReparentedRequest

type VSchema

+ func (m *VSchema) CloneMessageVT() proto.Message

+ func (m *VSchema) CloneVT() *VSchema

type VTExplainRequest

+ func (m *VTExplainRequest) CloneMessageVT() proto.Message

+ func (m *VTExplainRequest) CloneVT() *VTExplainRequest

type VTExplainResponse

+ func (m *VTExplainResponse) CloneMessageVT() proto.Message

+ func (m *VTExplainResponse) CloneVT() *VTExplainResponse

type VTGate

+ func (m *VTGate) CloneMessageVT() proto.Message

+ func (m *VTGate) CloneVT() *VTGate

type ValidateKeyspaceRequest

+ func (m *ValidateKeyspaceRequest) CloneMessageVT() proto.Message

+ func (m *ValidateKeyspaceRequest) CloneVT() *ValidateKeyspaceRequest

type ValidateRequest

+ func (m *ValidateRequest) CloneMessageVT() proto.Message

+ func (m *ValidateRequest) CloneVT() *ValidateRequest

type ValidateSchemaKeyspaceRequest

+ func (m *ValidateSchemaKeyspaceRequest) CloneMessageVT() proto.Message

+ func (m *ValidateSchemaKeyspaceRequest) CloneVT() *ValidateSchemaKeyspaceRequest

type ValidateShardRequest

+ func (m *ValidateShardRequest) CloneMessageVT() proto.Message

+ func (m *ValidateShardRequest) CloneVT() *ValidateShardRequest

type ValidateVersionKeyspaceRequest

+ func (m *ValidateVersionKeyspaceRequest) CloneMessageVT() proto.Message

+ func (m *ValidateVersionKeyspaceRequest) CloneVT() *ValidateVersionKeyspaceRequest

type ValidateVersionShardRequest

+ func (m *ValidateVersionShardRequest) CloneMessageVT() proto.Message

+ func (m *ValidateVersionShardRequest) CloneVT() *ValidateVersionShardRequest

type Vtctld

+ func (m *Vtctld) CloneMessageVT() proto.Message

+ func (m *Vtctld) CloneVT() *Vtctld

type Workflow

+ func (m *Workflow) CloneMessageVT() proto.Message

+ func (m *Workflow) CloneVT() *Workflow

Mar 14, 2024 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 20, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Nov 13, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Oct 3, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Aug 18, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 28, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jun 27, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ type GetSrvKeyspaceRequest struct

+ Cells []string

+ ClusterId string

+ Keyspace string

+ func (*GetSrvKeyspaceRequest) Descriptor() ([]byte, []int)

+ func (*GetSrvKeyspaceRequest) ProtoMessage()

+ func (m *GetSrvKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSrvKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSrvKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSrvKeyspaceRequest) SizeVT() (n int)

+ func (m *GetSrvKeyspaceRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetSrvKeyspaceRequest) GetCells() []string

+ func (x *GetSrvKeyspaceRequest) GetClusterId() string

+ func (x *GetSrvKeyspaceRequest) GetKeyspace() string

+ func (x *GetSrvKeyspaceRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSrvKeyspaceRequest) Reset()

+ func (x *GetSrvKeyspaceRequest) String() string

+ type GetSrvKeyspacesRequest struct

+ Cells []string

+ ClusterIds []string

+ func (*GetSrvKeyspacesRequest) Descriptor() ([]byte, []int)

+ func (*GetSrvKeyspacesRequest) ProtoMessage()

+ func (m *GetSrvKeyspacesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSrvKeyspacesRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSrvKeyspacesRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSrvKeyspacesRequest) SizeVT() (n int)

+ func (m *GetSrvKeyspacesRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetSrvKeyspacesRequest) GetCells() []string

+ func (x *GetSrvKeyspacesRequest) GetClusterIds() []string

+ func (x *GetSrvKeyspacesRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSrvKeyspacesRequest) Reset()

+ func (x *GetSrvKeyspacesRequest) String() string

+ type GetSrvKeyspacesResponse struct

+ SrvKeyspaces map[string]*vtctldata.GetSrvKeyspacesResponse

+ func (*GetSrvKeyspacesResponse) Descriptor() ([]byte, []int)

+ func (*GetSrvKeyspacesResponse) ProtoMessage()

+ func (m *GetSrvKeyspacesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSrvKeyspacesResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSrvKeyspacesResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSrvKeyspacesResponse) SizeVT() (n int)

+ func (m *GetSrvKeyspacesResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetSrvKeyspacesResponse) GetSrvKeyspaces() map[string]*vtctldata.GetSrvKeyspacesResponse

+ func (x *GetSrvKeyspacesResponse) ProtoReflect() protoreflect.Message

+ func (x *GetSrvKeyspacesResponse) Reset()

+ func (x *GetSrvKeyspacesResponse) String() string

type UnimplementedVTAdminServer

+ func (UnimplementedVTAdminServer) GetSrvKeyspace(context.Context, *GetSrvKeyspaceRequest) (*vtctldata.GetSrvKeyspacesResponse, error)

+ func (UnimplementedVTAdminServer) GetSrvKeyspaces(context.Context, *GetSrvKeyspacesRequest) (*GetSrvKeyspacesResponse, error)

type VTAdminClient

+ GetSrvKeyspace func(ctx context.Context, in *GetSrvKeyspaceRequest, opts ...grpc.CallOption) (*vtctldata.GetSrvKeyspacesResponse, error)

+ GetSrvKeyspaces func(ctx context.Context, in *GetSrvKeyspacesRequest, opts ...grpc.CallOption) (*GetSrvKeyspacesResponse, error)

type VTAdminServer

+ GetSrvKeyspace func(context.Context, *GetSrvKeyspaceRequest) (*vtctldata.GetSrvKeyspacesResponse, error)

+ GetSrvKeyspaces func(context.Context, *GetSrvKeyspacesRequest) (*GetSrvKeyspacesResponse, error)

Jun 13, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jun 6, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 20, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Nov 13, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Oct 3, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Aug 18, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 28, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

May 9, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Mar 30, 2023 GO-2024-2826

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Feb 28, 2023 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Feb 8, 2023 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Oct 3, 2023 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 28, 2023 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Mar 30, 2023 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 14, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Nov 29, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Oct 25, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ type GetFullStatusRequest struct

+ Alias *topodata.TabletAlias

+ ClusterId string

+ func (*GetFullStatusRequest) Descriptor() ([]byte, []int)

+ func (*GetFullStatusRequest) ProtoMessage()

+ func (m *GetFullStatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetFullStatusRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetFullStatusRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetFullStatusRequest) SizeVT() (n int)

+ func (m *GetFullStatusRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetFullStatusRequest) GetAlias() *topodata.TabletAlias

+ func (x *GetFullStatusRequest) GetClusterId() string

+ func (x *GetFullStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *GetFullStatusRequest) Reset()

+ func (x *GetFullStatusRequest) String() string

+ type GetTopologyPathRequest struct

+ ClusterId string

+ Path string

+ func (*GetTopologyPathRequest) Descriptor() ([]byte, []int)

+ func (*GetTopologyPathRequest) ProtoMessage()

+ func (m *GetTopologyPathRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetTopologyPathRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetTopologyPathRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetTopologyPathRequest) SizeVT() (n int)

+ func (m *GetTopologyPathRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetTopologyPathRequest) GetClusterId() string

+ func (x *GetTopologyPathRequest) GetPath() string

+ func (x *GetTopologyPathRequest) ProtoReflect() protoreflect.Message

+ func (x *GetTopologyPathRequest) Reset()

+ func (x *GetTopologyPathRequest) String() string

+ type RebuildKeyspaceGraphRequest struct

+ AllowPartial bool

+ Cells []string

+ ClusterId string

+ Keyspace string

+ func (*RebuildKeyspaceGraphRequest) Descriptor() ([]byte, []int)

+ func (*RebuildKeyspaceGraphRequest) ProtoMessage()

+ func (m *RebuildKeyspaceGraphRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RebuildKeyspaceGraphRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RebuildKeyspaceGraphRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *RebuildKeyspaceGraphRequest) SizeVT() (n int)

+ func (m *RebuildKeyspaceGraphRequest) UnmarshalVT(dAtA []byte) error

+ func (x *RebuildKeyspaceGraphRequest) GetAllowPartial() bool

+ func (x *RebuildKeyspaceGraphRequest) GetCells() []string

+ func (x *RebuildKeyspaceGraphRequest) GetClusterId() string

+ func (x *RebuildKeyspaceGraphRequest) GetKeyspace() string

+ func (x *RebuildKeyspaceGraphRequest) ProtoReflect() protoreflect.Message

+ func (x *RebuildKeyspaceGraphRequest) Reset()

+ func (x *RebuildKeyspaceGraphRequest) String() string

+ type RebuildKeyspaceGraphResponse struct

+ Status string

+ func (*RebuildKeyspaceGraphResponse) Descriptor() ([]byte, []int)

+ func (*RebuildKeyspaceGraphResponse) ProtoMessage()

+ func (m *RebuildKeyspaceGraphResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RebuildKeyspaceGraphResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RebuildKeyspaceGraphResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *RebuildKeyspaceGraphResponse) SizeVT() (n int)

+ func (m *RebuildKeyspaceGraphResponse) UnmarshalVT(dAtA []byte) error

+ func (x *RebuildKeyspaceGraphResponse) GetStatus() string

+ func (x *RebuildKeyspaceGraphResponse) ProtoReflect() protoreflect.Message

+ func (x *RebuildKeyspaceGraphResponse) Reset()

+ func (x *RebuildKeyspaceGraphResponse) String() string

+ type ReloadSchemaShardRequest struct

+ ClusterId string

+ Concurrency uint32

+ IncludePrimary bool

+ Keyspace string

+ Shard string

+ WaitPosition string

+ func (*ReloadSchemaShardRequest) Descriptor() ([]byte, []int)

+ func (*ReloadSchemaShardRequest) ProtoMessage()

+ func (m *ReloadSchemaShardRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemaShardRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemaShardRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ReloadSchemaShardRequest) SizeVT() (n int)

+ func (m *ReloadSchemaShardRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ReloadSchemaShardRequest) GetClusterId() string

+ func (x *ReloadSchemaShardRequest) GetConcurrency() uint32

+ func (x *ReloadSchemaShardRequest) GetIncludePrimary() bool

+ func (x *ReloadSchemaShardRequest) GetKeyspace() string

+ func (x *ReloadSchemaShardRequest) GetShard() string

+ func (x *ReloadSchemaShardRequest) GetWaitPosition() string

+ func (x *ReloadSchemaShardRequest) ProtoReflect() protoreflect.Message

+ func (x *ReloadSchemaShardRequest) Reset()

+ func (x *ReloadSchemaShardRequest) String() string

+ type ReloadSchemaShardResponse struct

+ Events []*logutil.Event

+ func (*ReloadSchemaShardResponse) Descriptor() ([]byte, []int)

+ func (*ReloadSchemaShardResponse) ProtoMessage()

+ func (m *ReloadSchemaShardResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemaShardResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemaShardResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *ReloadSchemaShardResponse) SizeVT() (n int)

+ func (m *ReloadSchemaShardResponse) UnmarshalVT(dAtA []byte) error

+ func (x *ReloadSchemaShardResponse) GetEvents() []*logutil.Event

+ func (x *ReloadSchemaShardResponse) ProtoReflect() protoreflect.Message

+ func (x *ReloadSchemaShardResponse) Reset()

+ func (x *ReloadSchemaShardResponse) String() string

+ type RemoveKeyspaceCellRequest struct

+ Cell string

+ ClusterId string

+ Force bool

+ Keyspace string

+ Recursive bool

+ func (*RemoveKeyspaceCellRequest) Descriptor() ([]byte, []int)

+ func (*RemoveKeyspaceCellRequest) ProtoMessage()

+ func (m *RemoveKeyspaceCellRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RemoveKeyspaceCellRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RemoveKeyspaceCellRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *RemoveKeyspaceCellRequest) SizeVT() (n int)

+ func (m *RemoveKeyspaceCellRequest) UnmarshalVT(dAtA []byte) error

+ func (x *RemoveKeyspaceCellRequest) GetCell() string

+ func (x *RemoveKeyspaceCellRequest) GetClusterId() string

+ func (x *RemoveKeyspaceCellRequest) GetForce() bool

+ func (x *RemoveKeyspaceCellRequest) GetKeyspace() string

+ func (x *RemoveKeyspaceCellRequest) GetRecursive() bool

+ func (x *RemoveKeyspaceCellRequest) ProtoReflect() protoreflect.Message

+ func (x *RemoveKeyspaceCellRequest) Reset()

+ func (x *RemoveKeyspaceCellRequest) String() string

+ type RemoveKeyspaceCellResponse struct

+ Status string

+ func (*RemoveKeyspaceCellResponse) Descriptor() ([]byte, []int)

+ func (*RemoveKeyspaceCellResponse) ProtoMessage()

+ func (m *RemoveKeyspaceCellResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RemoveKeyspaceCellResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RemoveKeyspaceCellResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *RemoveKeyspaceCellResponse) SizeVT() (n int)

+ func (m *RemoveKeyspaceCellResponse) UnmarshalVT(dAtA []byte) error

+ func (x *RemoveKeyspaceCellResponse) GetStatus() string

+ func (x *RemoveKeyspaceCellResponse) ProtoReflect() protoreflect.Message

+ func (x *RemoveKeyspaceCellResponse) Reset()

+ func (x *RemoveKeyspaceCellResponse) String() string

+ type TabletExternallyReparentedRequest struct

+ Alias *topodata.TabletAlias

+ ClusterIds []string

+ func (*TabletExternallyReparentedRequest) Descriptor() ([]byte, []int)

+ func (*TabletExternallyReparentedRequest) ProtoMessage()

+ func (m *TabletExternallyReparentedRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *TabletExternallyReparentedRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *TabletExternallyReparentedRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *TabletExternallyReparentedRequest) SizeVT() (n int)

+ func (m *TabletExternallyReparentedRequest) UnmarshalVT(dAtA []byte) error

+ func (x *TabletExternallyReparentedRequest) GetAlias() *topodata.TabletAlias

+ func (x *TabletExternallyReparentedRequest) GetClusterIds() []string

+ func (x *TabletExternallyReparentedRequest) ProtoReflect() protoreflect.Message

+ func (x *TabletExternallyReparentedRequest) Reset()

+ func (x *TabletExternallyReparentedRequest) String() string

type UnimplementedVTAdminServer

+ func (UnimplementedVTAdminServer) GetFullStatus(context.Context, *GetFullStatusRequest) (*vtctldata.GetFullStatusResponse, error)

+ func (UnimplementedVTAdminServer) GetTopologyPath(context.Context, *GetTopologyPathRequest) (*vtctldata.GetTopologyPathResponse, error)

+ func (UnimplementedVTAdminServer) RebuildKeyspaceGraph(context.Context, *RebuildKeyspaceGraphRequest) (*RebuildKeyspaceGraphResponse, error)

+ func (UnimplementedVTAdminServer) ReloadSchemaShard(context.Context, *ReloadSchemaShardRequest) (*ReloadSchemaShardResponse, error)

+ func (UnimplementedVTAdminServer) RemoveKeyspaceCell(context.Context, *RemoveKeyspaceCellRequest) (*RemoveKeyspaceCellResponse, error)

+ func (UnimplementedVTAdminServer) Validate(context.Context, *ValidateRequest) (*vtctldata.ValidateResponse, error)

+ func (UnimplementedVTAdminServer) ValidateShard(context.Context, *ValidateShardRequest) (*vtctldata.ValidateShardResponse, error)

+ func (UnimplementedVTAdminServer) ValidateVersionShard(context.Context, *ValidateVersionShardRequest) (*vtctldata.ValidateVersionShardResponse, error)

type VTAdminClient

+ GetFullStatus func(ctx context.Context, in *GetFullStatusRequest, opts ...grpc.CallOption) (*vtctldata.GetFullStatusResponse, error)

+ GetTopologyPath func(ctx context.Context, in *GetTopologyPathRequest, opts ...grpc.CallOption) (*vtctldata.GetTopologyPathResponse, error)

+ RebuildKeyspaceGraph func(ctx context.Context, in *RebuildKeyspaceGraphRequest, opts ...grpc.CallOption) (*RebuildKeyspaceGraphResponse, error)

+ ReloadSchemaShard func(ctx context.Context, in *ReloadSchemaShardRequest, opts ...grpc.CallOption) (*ReloadSchemaShardResponse, error)

+ RemoveKeyspaceCell func(ctx context.Context, in *RemoveKeyspaceCellRequest, opts ...grpc.CallOption) (*RemoveKeyspaceCellResponse, error)

+ Validate func(ctx context.Context, in *ValidateRequest, opts ...grpc.CallOption) (*vtctldata.ValidateResponse, error)

+ ValidateShard func(ctx context.Context, in *ValidateShardRequest, opts ...grpc.CallOption) (*vtctldata.ValidateShardResponse, error)

+ ValidateVersionShard func(ctx context.Context, in *ValidateVersionShardRequest, opts ...grpc.CallOption) (*vtctldata.ValidateVersionShardResponse, error)

type VTAdminServer

+ GetFullStatus func(context.Context, *GetFullStatusRequest) (*vtctldata.GetFullStatusResponse, error)

+ GetTopologyPath func(context.Context, *GetTopologyPathRequest) (*vtctldata.GetTopologyPathResponse, error)

+ RebuildKeyspaceGraph func(context.Context, *RebuildKeyspaceGraphRequest) (*RebuildKeyspaceGraphResponse, error)

+ ReloadSchemaShard func(context.Context, *ReloadSchemaShardRequest) (*ReloadSchemaShardResponse, error)

+ RemoveKeyspaceCell func(context.Context, *RemoveKeyspaceCellRequest) (*RemoveKeyspaceCellResponse, error)

+ Validate func(context.Context, *ValidateRequest) (*vtctldata.ValidateResponse, error)

+ ValidateShard func(context.Context, *ValidateShardRequest) (*vtctldata.ValidateShardResponse, error)

+ ValidateVersionShard func(context.Context, *ValidateVersionShardRequest) (*vtctldata.ValidateVersionShardResponse, error)

+ type ValidateRequest struct

+ ClusterId string

+ PingTablets bool

+ func (*ValidateRequest) Descriptor() ([]byte, []int)

+ func (*ValidateRequest) ProtoMessage()

+ func (m *ValidateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ValidateRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ValidateRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ValidateRequest) SizeVT() (n int)

+ func (m *ValidateRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ValidateRequest) GetClusterId() string

+ func (x *ValidateRequest) GetPingTablets() bool

+ func (x *ValidateRequest) ProtoReflect() protoreflect.Message

+ func (x *ValidateRequest) Reset()

+ func (x *ValidateRequest) String() string

+ type ValidateShardRequest struct

+ ClusterId string

+ Keyspace string

+ PingTablets bool

+ Shard string

+ func (*ValidateShardRequest) Descriptor() ([]byte, []int)

+ func (*ValidateShardRequest) ProtoMessage()

+ func (m *ValidateShardRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ValidateShardRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ValidateShardRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ValidateShardRequest) SizeVT() (n int)

+ func (m *ValidateShardRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ValidateShardRequest) GetClusterId() string

+ func (x *ValidateShardRequest) GetKeyspace() string

+ func (x *ValidateShardRequest) GetPingTablets() bool

+ func (x *ValidateShardRequest) GetShard() string

+ func (x *ValidateShardRequest) ProtoReflect() protoreflect.Message

+ func (x *ValidateShardRequest) Reset()

+ func (x *ValidateShardRequest) String() string

+ type ValidateVersionShardRequest struct

+ ClusterId string

+ Keyspace string

+ Shard string

+ func (*ValidateVersionShardRequest) Descriptor() ([]byte, []int)

+ func (*ValidateVersionShardRequest) ProtoMessage()

+ func (m *ValidateVersionShardRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ValidateVersionShardRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ValidateVersionShardRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ValidateVersionShardRequest) SizeVT() (n int)

+ func (m *ValidateVersionShardRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ValidateVersionShardRequest) GetClusterId() string

+ func (x *ValidateVersionShardRequest) GetKeyspace() string

+ func (x *ValidateVersionShardRequest) GetShard() string

+ func (x *ValidateVersionShardRequest) ProtoReflect() protoreflect.Message

+ func (x *ValidateVersionShardRequest) Reset()

+ func (x *ValidateVersionShardRequest) String() string

Mar 30, 2023 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Nov 29, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Sep 1, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 26, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jun 28, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ type ClusterCellInfo struct

+ CellInfo *topodata.CellInfo

+ Cluster *Cluster

+ Name string

+ func (*ClusterCellInfo) Descriptor() ([]byte, []int)

+ func (*ClusterCellInfo) ProtoMessage()

+ func (m *ClusterCellInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ClusterCellInfo) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ClusterCellInfo) MarshalVT() (dAtA []byte, err error)

+ func (m *ClusterCellInfo) SizeVT() (n int)

+ func (m *ClusterCellInfo) UnmarshalVT(dAtA []byte) error

+ func (x *ClusterCellInfo) GetCellInfo() *topodata.CellInfo

+ func (x *ClusterCellInfo) GetCluster() *Cluster

+ func (x *ClusterCellInfo) GetName() string

+ func (x *ClusterCellInfo) ProtoReflect() protoreflect.Message

+ func (x *ClusterCellInfo) Reset()

+ func (x *ClusterCellInfo) String() string

+ type ClusterCellsAliases struct

+ Aliases map[string]*topodata.CellsAlias

+ Cluster *Cluster

+ func (*ClusterCellsAliases) Descriptor() ([]byte, []int)

+ func (*ClusterCellsAliases) ProtoMessage()

+ func (m *ClusterCellsAliases) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ClusterCellsAliases) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ClusterCellsAliases) MarshalVT() (dAtA []byte, err error)

+ func (m *ClusterCellsAliases) SizeVT() (n int)

+ func (m *ClusterCellsAliases) UnmarshalVT(dAtA []byte) error

+ func (x *ClusterCellsAliases) GetAliases() map[string]*topodata.CellsAlias

+ func (x *ClusterCellsAliases) GetCluster() *Cluster

+ func (x *ClusterCellsAliases) ProtoReflect() protoreflect.Message

+ func (x *ClusterCellsAliases) Reset()

+ func (x *ClusterCellsAliases) String() string

type DeleteTabletRequest

+ AllowPrimary bool

+ func (x *DeleteTabletRequest) GetAllowPrimary() bool

type DeleteTabletResponse

+ Cluster *Cluster

+ func (x *DeleteTabletResponse) GetCluster() *Cluster

+ type EmergencyFailoverShardRequest struct

+ ClusterId string

+ Options *vtctldata.EmergencyReparentShardRequest

+ func (*EmergencyFailoverShardRequest) Descriptor() ([]byte, []int)

+ func (*EmergencyFailoverShardRequest) ProtoMessage()

+ func (m *EmergencyFailoverShardRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *EmergencyFailoverShardRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *EmergencyFailoverShardRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *EmergencyFailoverShardRequest) SizeVT() (n int)

+ func (m *EmergencyFailoverShardRequest) UnmarshalVT(dAtA []byte) error

+ func (x *EmergencyFailoverShardRequest) GetClusterId() string

+ func (x *EmergencyFailoverShardRequest) GetOptions() *vtctldata.EmergencyReparentShardRequest

+ func (x *EmergencyFailoverShardRequest) ProtoReflect() protoreflect.Message

+ func (x *EmergencyFailoverShardRequest) Reset()

+ func (x *EmergencyFailoverShardRequest) String() string

+ type EmergencyFailoverShardResponse struct

+ Cluster *Cluster

+ Events []*logutil.Event

+ Keyspace string

+ PromotedPrimary *topodata.TabletAlias

+ Shard string

+ func (*EmergencyFailoverShardResponse) Descriptor() ([]byte, []int)

+ func (*EmergencyFailoverShardResponse) ProtoMessage()

+ func (m *EmergencyFailoverShardResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *EmergencyFailoverShardResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *EmergencyFailoverShardResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *EmergencyFailoverShardResponse) SizeVT() (n int)

+ func (m *EmergencyFailoverShardResponse) UnmarshalVT(dAtA []byte) error

+ func (x *EmergencyFailoverShardResponse) GetCluster() *Cluster

+ func (x *EmergencyFailoverShardResponse) GetEvents() []*logutil.Event

+ func (x *EmergencyFailoverShardResponse) GetKeyspace() string

+ func (x *EmergencyFailoverShardResponse) GetPromotedPrimary() *topodata.TabletAlias

+ func (x *EmergencyFailoverShardResponse) GetShard() string

+ func (x *EmergencyFailoverShardResponse) ProtoReflect() protoreflect.Message

+ func (x *EmergencyFailoverShardResponse) Reset()

+ func (x *EmergencyFailoverShardResponse) String() string

+ type GetCellInfosRequest struct

+ Cells []string

+ ClusterIds []string

+ NamesOnly bool

+ func (*GetCellInfosRequest) Descriptor() ([]byte, []int)

+ func (*GetCellInfosRequest) ProtoMessage()

+ func (m *GetCellInfosRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetCellInfosRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetCellInfosRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetCellInfosRequest) SizeVT() (n int)

+ func (m *GetCellInfosRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetCellInfosRequest) GetCells() []string

+ func (x *GetCellInfosRequest) GetClusterIds() []string

+ func (x *GetCellInfosRequest) GetNamesOnly() bool

+ func (x *GetCellInfosRequest) ProtoReflect() protoreflect.Message

+ func (x *GetCellInfosRequest) Reset()

+ func (x *GetCellInfosRequest) String() string

+ type GetCellInfosResponse struct

+ CellInfos []*ClusterCellInfo

+ func (*GetCellInfosResponse) Descriptor() ([]byte, []int)

+ func (*GetCellInfosResponse) ProtoMessage()

+ func (m *GetCellInfosResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetCellInfosResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetCellInfosResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetCellInfosResponse) SizeVT() (n int)

+ func (m *GetCellInfosResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetCellInfosResponse) GetCellInfos() []*ClusterCellInfo

+ func (x *GetCellInfosResponse) ProtoReflect() protoreflect.Message

+ func (x *GetCellInfosResponse) Reset()

+ func (x *GetCellInfosResponse) String() string

+ type GetCellsAliasesRequest struct

+ ClusterIds []string

+ func (*GetCellsAliasesRequest) Descriptor() ([]byte, []int)

+ func (*GetCellsAliasesRequest) ProtoMessage()

+ func (m *GetCellsAliasesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetCellsAliasesRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetCellsAliasesRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetCellsAliasesRequest) SizeVT() (n int)

+ func (m *GetCellsAliasesRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetCellsAliasesRequest) GetClusterIds() []string

+ func (x *GetCellsAliasesRequest) ProtoReflect() protoreflect.Message

+ func (x *GetCellsAliasesRequest) Reset()

+ func (x *GetCellsAliasesRequest) String() string

+ type GetCellsAliasesResponse struct

+ Aliases []*ClusterCellsAliases

+ func (*GetCellsAliasesResponse) Descriptor() ([]byte, []int)

+ func (*GetCellsAliasesResponse) ProtoMessage()

+ func (m *GetCellsAliasesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetCellsAliasesResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetCellsAliasesResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetCellsAliasesResponse) SizeVT() (n int)

+ func (m *GetCellsAliasesResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetCellsAliasesResponse) GetAliases() []*ClusterCellsAliases

+ func (x *GetCellsAliasesResponse) ProtoReflect() protoreflect.Message

+ func (x *GetCellsAliasesResponse) Reset()

+ func (x *GetCellsAliasesResponse) String() string

type PingTabletResponse

+ Cluster *Cluster

+ func (x *PingTabletResponse) GetCluster() *Cluster

+ type PlannedFailoverShardRequest struct

+ ClusterId string

+ Options *vtctldata.PlannedReparentShardRequest

+ func (*PlannedFailoverShardRequest) Descriptor() ([]byte, []int)

+ func (*PlannedFailoverShardRequest) ProtoMessage()

+ func (m *PlannedFailoverShardRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PlannedFailoverShardRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PlannedFailoverShardRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *PlannedFailoverShardRequest) SizeVT() (n int)

+ func (m *PlannedFailoverShardRequest) UnmarshalVT(dAtA []byte) error

+ func (x *PlannedFailoverShardRequest) GetClusterId() string

+ func (x *PlannedFailoverShardRequest) GetOptions() *vtctldata.PlannedReparentShardRequest

+ func (x *PlannedFailoverShardRequest) ProtoReflect() protoreflect.Message

+ func (x *PlannedFailoverShardRequest) Reset()

+ func (x *PlannedFailoverShardRequest) String() string

+ type PlannedFailoverShardResponse struct

+ Cluster *Cluster

+ Events []*logutil.Event

+ Keyspace string

+ PromotedPrimary *topodata.TabletAlias

+ Shard string

+ func (*PlannedFailoverShardResponse) Descriptor() ([]byte, []int)

+ func (*PlannedFailoverShardResponse) ProtoMessage()

+ func (m *PlannedFailoverShardResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PlannedFailoverShardResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PlannedFailoverShardResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *PlannedFailoverShardResponse) SizeVT() (n int)

+ func (m *PlannedFailoverShardResponse) UnmarshalVT(dAtA []byte) error

+ func (x *PlannedFailoverShardResponse) GetCluster() *Cluster

+ func (x *PlannedFailoverShardResponse) GetEvents() []*logutil.Event

+ func (x *PlannedFailoverShardResponse) GetKeyspace() string

+ func (x *PlannedFailoverShardResponse) GetPromotedPrimary() *topodata.TabletAlias

+ func (x *PlannedFailoverShardResponse) GetShard() string

+ func (x *PlannedFailoverShardResponse) ProtoReflect() protoreflect.Message

+ func (x *PlannedFailoverShardResponse) Reset()

+ func (x *PlannedFailoverShardResponse) String() string

type RefreshStateResponse

+ Cluster *Cluster

+ func (x *RefreshStateResponse) GetCluster() *Cluster

+ type RefreshTabletReplicationSourceRequest struct

+ Alias *topodata.TabletAlias

+ ClusterIds []string

+ func (*RefreshTabletReplicationSourceRequest) Descriptor() ([]byte, []int)

+ func (*RefreshTabletReplicationSourceRequest) ProtoMessage()

+ func (m *RefreshTabletReplicationSourceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RefreshTabletReplicationSourceRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RefreshTabletReplicationSourceRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *RefreshTabletReplicationSourceRequest) SizeVT() (n int)

+ func (m *RefreshTabletReplicationSourceRequest) UnmarshalVT(dAtA []byte) error

+ func (x *RefreshTabletReplicationSourceRequest) GetAlias() *topodata.TabletAlias

+ func (x *RefreshTabletReplicationSourceRequest) GetClusterIds() []string

+ func (x *RefreshTabletReplicationSourceRequest) ProtoReflect() protoreflect.Message

+ func (x *RefreshTabletReplicationSourceRequest) Reset()

+ func (x *RefreshTabletReplicationSourceRequest) String() string

+ type RefreshTabletReplicationSourceResponse struct

+ Cluster *Cluster

+ Keyspace string

+ Primary *topodata.TabletAlias

+ Shard string

+ func (*RefreshTabletReplicationSourceResponse) Descriptor() ([]byte, []int)

+ func (*RefreshTabletReplicationSourceResponse) ProtoMessage()

+ func (m *RefreshTabletReplicationSourceResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RefreshTabletReplicationSourceResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RefreshTabletReplicationSourceResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *RefreshTabletReplicationSourceResponse) SizeVT() (n int)

+ func (m *RefreshTabletReplicationSourceResponse) UnmarshalVT(dAtA []byte) error

+ func (x *RefreshTabletReplicationSourceResponse) GetCluster() *Cluster

+ func (x *RefreshTabletReplicationSourceResponse) GetKeyspace() string

+ func (x *RefreshTabletReplicationSourceResponse) GetPrimary() *topodata.TabletAlias

+ func (x *RefreshTabletReplicationSourceResponse) GetShard() string

+ func (x *RefreshTabletReplicationSourceResponse) ProtoReflect() protoreflect.Message

+ func (x *RefreshTabletReplicationSourceResponse) Reset()

+ func (x *RefreshTabletReplicationSourceResponse) String() string

+ type ReloadSchemasRequest struct

+ ClusterIds []string

+ Concurrency uint32

+ IncludePrimary bool

+ KeyspaceShards []string

+ Keyspaces []string

+ Tablets []*topodata.TabletAlias

+ WaitPosition string

+ func (*ReloadSchemasRequest) Descriptor() ([]byte, []int)

+ func (*ReloadSchemasRequest) ProtoMessage()

+ func (m *ReloadSchemasRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemasRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemasRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ReloadSchemasRequest) SizeVT() (n int)

+ func (m *ReloadSchemasRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ReloadSchemasRequest) GetClusterIds() []string

+ func (x *ReloadSchemasRequest) GetConcurrency() uint32

+ func (x *ReloadSchemasRequest) GetIncludePrimary() bool

+ func (x *ReloadSchemasRequest) GetKeyspaceShards() []string

+ func (x *ReloadSchemasRequest) GetKeyspaces() []string

+ func (x *ReloadSchemasRequest) GetTablets() []*topodata.TabletAlias

+ func (x *ReloadSchemasRequest) GetWaitPosition() string

+ func (x *ReloadSchemasRequest) ProtoReflect() protoreflect.Message

+ func (x *ReloadSchemasRequest) Reset()

+ func (x *ReloadSchemasRequest) String() string

+ type ReloadSchemasResponse struct

+ KeyspaceResults []*ReloadSchemasResponse_KeyspaceResult

+ ShardResults []*ReloadSchemasResponse_ShardResult

+ TabletResults []*ReloadSchemasResponse_TabletResult

+ func (*ReloadSchemasResponse) Descriptor() ([]byte, []int)

+ func (*ReloadSchemasResponse) ProtoMessage()

+ func (m *ReloadSchemasResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemasResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemasResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *ReloadSchemasResponse) SizeVT() (n int)

+ func (m *ReloadSchemasResponse) UnmarshalVT(dAtA []byte) error

+ func (x *ReloadSchemasResponse) GetKeyspaceResults() []*ReloadSchemasResponse_KeyspaceResult

+ func (x *ReloadSchemasResponse) GetShardResults() []*ReloadSchemasResponse_ShardResult

+ func (x *ReloadSchemasResponse) GetTabletResults() []*ReloadSchemasResponse_TabletResult

+ func (x *ReloadSchemasResponse) ProtoReflect() protoreflect.Message

+ func (x *ReloadSchemasResponse) Reset()

+ func (x *ReloadSchemasResponse) String() string

+ type ReloadSchemasResponse_KeyspaceResult struct

+ Events []*logutil.Event

+ Keyspace *Keyspace

+ func (*ReloadSchemasResponse_KeyspaceResult) Descriptor() ([]byte, []int)

+ func (*ReloadSchemasResponse_KeyspaceResult) ProtoMessage()

+ func (m *ReloadSchemasResponse_KeyspaceResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemasResponse_KeyspaceResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemasResponse_KeyspaceResult) MarshalVT() (dAtA []byte, err error)

+ func (m *ReloadSchemasResponse_KeyspaceResult) SizeVT() (n int)

+ func (m *ReloadSchemasResponse_KeyspaceResult) UnmarshalVT(dAtA []byte) error

+ func (x *ReloadSchemasResponse_KeyspaceResult) GetEvents() []*logutil.Event

+ func (x *ReloadSchemasResponse_KeyspaceResult) GetKeyspace() *Keyspace

+ func (x *ReloadSchemasResponse_KeyspaceResult) ProtoReflect() protoreflect.Message

+ func (x *ReloadSchemasResponse_KeyspaceResult) Reset()

+ func (x *ReloadSchemasResponse_KeyspaceResult) String() string

+ type ReloadSchemasResponse_ShardResult struct

+ Events []*logutil.Event

+ Shard *Shard

+ func (*ReloadSchemasResponse_ShardResult) Descriptor() ([]byte, []int)

+ func (*ReloadSchemasResponse_ShardResult) ProtoMessage()

+ func (m *ReloadSchemasResponse_ShardResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemasResponse_ShardResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemasResponse_ShardResult) MarshalVT() (dAtA []byte, err error)

+ func (m *ReloadSchemasResponse_ShardResult) SizeVT() (n int)

+ func (m *ReloadSchemasResponse_ShardResult) UnmarshalVT(dAtA []byte) error

+ func (x *ReloadSchemasResponse_ShardResult) GetEvents() []*logutil.Event

+ func (x *ReloadSchemasResponse_ShardResult) GetShard() *Shard

+ func (x *ReloadSchemasResponse_ShardResult) ProtoReflect() protoreflect.Message

+ func (x *ReloadSchemasResponse_ShardResult) Reset()

+ func (x *ReloadSchemasResponse_ShardResult) String() string

+ type ReloadSchemasResponse_TabletResult struct

+ Result string

+ Tablet *Tablet

+ func (*ReloadSchemasResponse_TabletResult) Descriptor() ([]byte, []int)

+ func (*ReloadSchemasResponse_TabletResult) ProtoMessage()

+ func (m *ReloadSchemasResponse_TabletResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemasResponse_TabletResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReloadSchemasResponse_TabletResult) MarshalVT() (dAtA []byte, err error)

+ func (m *ReloadSchemasResponse_TabletResult) SizeVT() (n int)

+ func (m *ReloadSchemasResponse_TabletResult) UnmarshalVT(dAtA []byte) error

+ func (x *ReloadSchemasResponse_TabletResult) GetResult() string

+ func (x *ReloadSchemasResponse_TabletResult) GetTablet() *Tablet

+ func (x *ReloadSchemasResponse_TabletResult) ProtoReflect() protoreflect.Message

+ func (x *ReloadSchemasResponse_TabletResult) Reset()

+ func (x *ReloadSchemasResponse_TabletResult) String() string

type RunHealthCheckResponse

+ Cluster *Cluster

+ func (x *RunHealthCheckResponse) GetCluster() *Cluster

+ type SetReadOnlyRequest struct

+ Alias *topodata.TabletAlias

+ ClusterIds []string

+ func (*SetReadOnlyRequest) Descriptor() ([]byte, []int)

+ func (*SetReadOnlyRequest) ProtoMessage()

+ func (m *SetReadOnlyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SetReadOnlyRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SetReadOnlyRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *SetReadOnlyRequest) SizeVT() (n int)

+ func (m *SetReadOnlyRequest) UnmarshalVT(dAtA []byte) error

+ func (x *SetReadOnlyRequest) GetAlias() *topodata.TabletAlias

+ func (x *SetReadOnlyRequest) GetClusterIds() []string

+ func (x *SetReadOnlyRequest) ProtoReflect() protoreflect.Message

+ func (x *SetReadOnlyRequest) Reset()

+ func (x *SetReadOnlyRequest) String() string

+ type SetReadOnlyResponse struct

+ func (*SetReadOnlyResponse) Descriptor() ([]byte, []int)

+ func (*SetReadOnlyResponse) ProtoMessage()

+ func (m *SetReadOnlyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SetReadOnlyResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SetReadOnlyResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *SetReadOnlyResponse) SizeVT() (n int)

+ func (m *SetReadOnlyResponse) UnmarshalVT(dAtA []byte) error

+ func (x *SetReadOnlyResponse) ProtoReflect() protoreflect.Message

+ func (x *SetReadOnlyResponse) Reset()

+ func (x *SetReadOnlyResponse) String() string

+ type SetReadWriteRequest struct

+ Alias *topodata.TabletAlias

+ ClusterIds []string

+ func (*SetReadWriteRequest) Descriptor() ([]byte, []int)

+ func (*SetReadWriteRequest) ProtoMessage()

+ func (m *SetReadWriteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SetReadWriteRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SetReadWriteRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *SetReadWriteRequest) SizeVT() (n int)

+ func (m *SetReadWriteRequest) UnmarshalVT(dAtA []byte) error

+ func (x *SetReadWriteRequest) GetAlias() *topodata.TabletAlias

+ func (x *SetReadWriteRequest) GetClusterIds() []string

+ func (x *SetReadWriteRequest) ProtoReflect() protoreflect.Message

+ func (x *SetReadWriteRequest) Reset()

+ func (x *SetReadWriteRequest) String() string

+ type SetReadWriteResponse struct

+ func (*SetReadWriteResponse) Descriptor() ([]byte, []int)

+ func (*SetReadWriteResponse) ProtoMessage()

+ func (m *SetReadWriteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SetReadWriteResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SetReadWriteResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *SetReadWriteResponse) SizeVT() (n int)

+ func (m *SetReadWriteResponse) UnmarshalVT(dAtA []byte) error

+ func (x *SetReadWriteResponse) ProtoReflect() protoreflect.Message

+ func (x *SetReadWriteResponse) Reset()

+ func (x *SetReadWriteResponse) String() string

+ type Shard struct

+ Cluster *Cluster

+ Shard *vtctldata.Shard

+ func (*Shard) Descriptor() ([]byte, []int)

+ func (*Shard) ProtoMessage()

+ func (m *Shard) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Shard) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Shard) MarshalVT() (dAtA []byte, err error)

+ func (m *Shard) SizeVT() (n int)

+ func (m *Shard) UnmarshalVT(dAtA []byte) error

+ func (x *Shard) GetCluster() *Cluster

+ func (x *Shard) GetShard() *vtctldata.Shard

+ func (x *Shard) ProtoReflect() protoreflect.Message

+ func (x *Shard) Reset()

+ func (x *Shard) String() string

type StartReplicationResponse

+ Cluster *Cluster

+ func (x *StartReplicationResponse) GetCluster() *Cluster

type StopReplicationResponse

+ Cluster *Cluster

+ func (x *StopReplicationResponse) GetCluster() *Cluster

+ type TabletExternallyPromotedRequest struct

+ Alias *topodata.TabletAlias

+ ClusterIds []string

+ func (*TabletExternallyPromotedRequest) Descriptor() ([]byte, []int)

+ func (*TabletExternallyPromotedRequest) ProtoMessage()

+ func (m *TabletExternallyPromotedRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *TabletExternallyPromotedRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *TabletExternallyPromotedRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *TabletExternallyPromotedRequest) SizeVT() (n int)

+ func (m *TabletExternallyPromotedRequest) UnmarshalVT(dAtA []byte) error

+ func (x *TabletExternallyPromotedRequest) GetAlias() *topodata.TabletAlias

+ func (x *TabletExternallyPromotedRequest) GetClusterIds() []string

+ func (x *TabletExternallyPromotedRequest) ProtoReflect() protoreflect.Message

+ func (x *TabletExternallyPromotedRequest) Reset()

+ func (x *TabletExternallyPromotedRequest) String() string

+ type TabletExternallyPromotedResponse struct

+ Cluster *Cluster

+ Keyspace string

+ NewPrimary *topodata.TabletAlias

+ OldPrimary *topodata.TabletAlias

+ Shard string

+ func (*TabletExternallyPromotedResponse) Descriptor() ([]byte, []int)

+ func (*TabletExternallyPromotedResponse) ProtoMessage()

+ func (m *TabletExternallyPromotedResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *TabletExternallyPromotedResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *TabletExternallyPromotedResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *TabletExternallyPromotedResponse) SizeVT() (n int)

+ func (m *TabletExternallyPromotedResponse) UnmarshalVT(dAtA []byte) error

+ func (x *TabletExternallyPromotedResponse) GetCluster() *Cluster

+ func (x *TabletExternallyPromotedResponse) GetKeyspace() string

+ func (x *TabletExternallyPromotedResponse) GetNewPrimary() *topodata.TabletAlias

+ func (x *TabletExternallyPromotedResponse) GetOldPrimary() *topodata.TabletAlias

+ func (x *TabletExternallyPromotedResponse) GetShard() string

+ func (x *TabletExternallyPromotedResponse) ProtoReflect() protoreflect.Message

+ func (x *TabletExternallyPromotedResponse) Reset()

+ func (x *TabletExternallyPromotedResponse) String() string

type UnimplementedVTAdminServer

+ func (UnimplementedVTAdminServer) EmergencyFailoverShard(context.Context, *EmergencyFailoverShardRequest) (*EmergencyFailoverShardResponse, error)

+ func (UnimplementedVTAdminServer) GetCellInfos(context.Context, *GetCellInfosRequest) (*GetCellInfosResponse, error)

+ func (UnimplementedVTAdminServer) GetCellsAliases(context.Context, *GetCellsAliasesRequest) (*GetCellsAliasesResponse, error)

+ func (UnimplementedVTAdminServer) PlannedFailoverShard(context.Context, *PlannedFailoverShardRequest) (*PlannedFailoverShardResponse, error)

+ func (UnimplementedVTAdminServer) RefreshTabletReplicationSource(context.Context, *RefreshTabletReplicationSourceRequest) (*RefreshTabletReplicationSourceResponse, error)

+ func (UnimplementedVTAdminServer) ReloadSchemas(context.Context, *ReloadSchemasRequest) (*ReloadSchemasResponse, error)

+ func (UnimplementedVTAdminServer) SetReadOnly(context.Context, *SetReadOnlyRequest) (*SetReadOnlyResponse, error)

+ func (UnimplementedVTAdminServer) SetReadWrite(context.Context, *SetReadWriteRequest) (*SetReadWriteResponse, error)

+ func (UnimplementedVTAdminServer) TabletExternallyPromoted(context.Context, *TabletExternallyPromotedRequest) (*TabletExternallyPromotedResponse, error)

+ func (UnimplementedVTAdminServer) ValidateKeyspace(context.Context, *ValidateKeyspaceRequest) (*vtctldata.ValidateKeyspaceResponse, error)

+ func (UnimplementedVTAdminServer) ValidateSchemaKeyspace(context.Context, *ValidateSchemaKeyspaceRequest) (*vtctldata.ValidateSchemaKeyspaceResponse, error)

+ func (UnimplementedVTAdminServer) ValidateVersionKeyspace(context.Context, *ValidateVersionKeyspaceRequest) (*vtctldata.ValidateVersionKeyspaceResponse, error)

type VTAdminClient

+ EmergencyFailoverShard func(ctx context.Context, in *EmergencyFailoverShardRequest, ...) (*EmergencyFailoverShardResponse, error)

+ GetCellInfos func(ctx context.Context, in *GetCellInfosRequest, opts ...grpc.CallOption) (*GetCellInfosResponse, error)

+ GetCellsAliases func(ctx context.Context, in *GetCellsAliasesRequest, opts ...grpc.CallOption) (*GetCellsAliasesResponse, error)

+ PlannedFailoverShard func(ctx context.Context, in *PlannedFailoverShardRequest, opts ...grpc.CallOption) (*PlannedFailoverShardResponse, error)

+ RefreshTabletReplicationSource func(ctx context.Context, in *RefreshTabletReplicationSourceRequest, ...) (*RefreshTabletReplicationSourceResponse, error)

+ ReloadSchemas func(ctx context.Context, in *ReloadSchemasRequest, opts ...grpc.CallOption) (*ReloadSchemasResponse, error)

+ SetReadOnly func(ctx context.Context, in *SetReadOnlyRequest, opts ...grpc.CallOption) (*SetReadOnlyResponse, error)

+ SetReadWrite func(ctx context.Context, in *SetReadWriteRequest, opts ...grpc.CallOption) (*SetReadWriteResponse, error)

+ TabletExternallyPromoted func(ctx context.Context, in *TabletExternallyPromotedRequest, ...) (*TabletExternallyPromotedResponse, error)

+ ValidateKeyspace func(ctx context.Context, in *ValidateKeyspaceRequest, opts ...grpc.CallOption) (*vtctldata.ValidateKeyspaceResponse, error)

+ ValidateSchemaKeyspace func(ctx context.Context, in *ValidateSchemaKeyspaceRequest, ...) (*vtctldata.ValidateSchemaKeyspaceResponse, error)

+ ValidateVersionKeyspace func(ctx context.Context, in *ValidateVersionKeyspaceRequest, ...) (*vtctldata.ValidateVersionKeyspaceResponse, error)

type VTAdminServer

+ EmergencyFailoverShard func(context.Context, *EmergencyFailoverShardRequest) (*EmergencyFailoverShardResponse, error)

+ GetCellInfos func(context.Context, *GetCellInfosRequest) (*GetCellInfosResponse, error)

+ GetCellsAliases func(context.Context, *GetCellsAliasesRequest) (*GetCellsAliasesResponse, error)

+ PlannedFailoverShard func(context.Context, *PlannedFailoverShardRequest) (*PlannedFailoverShardResponse, error)

+ RefreshTabletReplicationSource func(context.Context, *RefreshTabletReplicationSourceRequest) (*RefreshTabletReplicationSourceResponse, error)

+ ReloadSchemas func(context.Context, *ReloadSchemasRequest) (*ReloadSchemasResponse, error)

+ SetReadOnly func(context.Context, *SetReadOnlyRequest) (*SetReadOnlyResponse, error)

+ SetReadWrite func(context.Context, *SetReadWriteRequest) (*SetReadWriteResponse, error)

+ TabletExternallyPromoted func(context.Context, *TabletExternallyPromotedRequest) (*TabletExternallyPromotedResponse, error)

+ ValidateKeyspace func(context.Context, *ValidateKeyspaceRequest) (*vtctldata.ValidateKeyspaceResponse, error)

+ ValidateSchemaKeyspace func(context.Context, *ValidateSchemaKeyspaceRequest) (*vtctldata.ValidateSchemaKeyspaceResponse, error)

+ ValidateVersionKeyspace func(context.Context, *ValidateVersionKeyspaceRequest) (*vtctldata.ValidateVersionKeyspaceResponse, error)

+ type ValidateKeyspaceRequest struct

+ ClusterId string

+ Keyspace string

+ PingTablets bool

+ func (*ValidateKeyspaceRequest) Descriptor() ([]byte, []int)

+ func (*ValidateKeyspaceRequest) ProtoMessage()

+ func (m *ValidateKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ValidateKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ValidateKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ValidateKeyspaceRequest) SizeVT() (n int)

+ func (m *ValidateKeyspaceRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ValidateKeyspaceRequest) GetClusterId() string

+ func (x *ValidateKeyspaceRequest) GetKeyspace() string

+ func (x *ValidateKeyspaceRequest) GetPingTablets() bool

+ func (x *ValidateKeyspaceRequest) ProtoReflect() protoreflect.Message

+ func (x *ValidateKeyspaceRequest) Reset()

+ func (x *ValidateKeyspaceRequest) String() string

+ type ValidateSchemaKeyspaceRequest struct

+ ClusterId string

+ Keyspace string

+ func (*ValidateSchemaKeyspaceRequest) Descriptor() ([]byte, []int)

+ func (*ValidateSchemaKeyspaceRequest) ProtoMessage()

+ func (m *ValidateSchemaKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ValidateSchemaKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ValidateSchemaKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ValidateSchemaKeyspaceRequest) SizeVT() (n int)

+ func (m *ValidateSchemaKeyspaceRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ValidateSchemaKeyspaceRequest) GetClusterId() string

+ func (x *ValidateSchemaKeyspaceRequest) GetKeyspace() string

+ func (x *ValidateSchemaKeyspaceRequest) ProtoReflect() protoreflect.Message

+ func (x *ValidateSchemaKeyspaceRequest) Reset()

+ func (x *ValidateSchemaKeyspaceRequest) String() string

+ type ValidateVersionKeyspaceRequest struct

+ ClusterId string

+ Keyspace string

+ func (*ValidateVersionKeyspaceRequest) Descriptor() ([]byte, []int)

+ func (*ValidateVersionKeyspaceRequest) ProtoMessage()

+ func (m *ValidateVersionKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ValidateVersionKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ValidateVersionKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ValidateVersionKeyspaceRequest) SizeVT() (n int)

+ func (m *ValidateVersionKeyspaceRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ValidateVersionKeyspaceRequest) GetClusterId() string

+ func (x *ValidateVersionKeyspaceRequest) GetKeyspace() string

+ func (x *ValidateVersionKeyspaceRequest) ProtoReflect() protoreflect.Message

+ func (x *ValidateVersionKeyspaceRequest) Reset()

+ func (x *ValidateVersionKeyspaceRequest) String() string

Sep 1, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 26, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Apr 14, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Feb 22, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ type CreateShardRequest struct

+ ClusterId string

+ Options *vtctldata.CreateShardRequest

+ func (*CreateShardRequest) Descriptor() ([]byte, []int)

+ func (*CreateShardRequest) ProtoMessage()

+ func (m *CreateShardRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *CreateShardRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *CreateShardRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *CreateShardRequest) SizeVT() (n int)

+ func (m *CreateShardRequest) UnmarshalVT(dAtA []byte) error

+ func (x *CreateShardRequest) GetClusterId() string

+ func (x *CreateShardRequest) GetOptions() *vtctldata.CreateShardRequest

+ func (x *CreateShardRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateShardRequest) Reset()

+ func (x *CreateShardRequest) String() string

+ type DeleteShardsRequest struct

+ ClusterId string

+ Options *vtctldata.DeleteShardsRequest

+ func (*DeleteShardsRequest) Descriptor() ([]byte, []int)

+ func (*DeleteShardsRequest) ProtoMessage()

+ func (m *DeleteShardsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DeleteShardsRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DeleteShardsRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *DeleteShardsRequest) SizeVT() (n int)

+ func (m *DeleteShardsRequest) UnmarshalVT(dAtA []byte) error

+ func (x *DeleteShardsRequest) GetClusterId() string

+ func (x *DeleteShardsRequest) GetOptions() *vtctldata.DeleteShardsRequest

+ func (x *DeleteShardsRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteShardsRequest) Reset()

+ func (x *DeleteShardsRequest) String() string

+ type DeleteTabletRequest struct

+ Alias string

+ ClusterIds []string

+ func (*DeleteTabletRequest) Descriptor() ([]byte, []int)

+ func (*DeleteTabletRequest) ProtoMessage()

+ func (m *DeleteTabletRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DeleteTabletRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DeleteTabletRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *DeleteTabletRequest) SizeVT() (n int)

+ func (m *DeleteTabletRequest) UnmarshalVT(dAtA []byte) error

+ func (x *DeleteTabletRequest) GetAlias() string

+ func (x *DeleteTabletRequest) GetClusterIds() []string

+ func (x *DeleteTabletRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteTabletRequest) Reset()

+ func (x *DeleteTabletRequest) String() string

+ type DeleteTabletResponse struct

+ Status string

+ func (*DeleteTabletResponse) Descriptor() ([]byte, []int)

+ func (*DeleteTabletResponse) ProtoMessage()

+ func (m *DeleteTabletResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DeleteTabletResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DeleteTabletResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *DeleteTabletResponse) SizeVT() (n int)

+ func (m *DeleteTabletResponse) UnmarshalVT(dAtA []byte) error

+ func (x *DeleteTabletResponse) GetStatus() string

+ func (x *DeleteTabletResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteTabletResponse) Reset()

+ func (x *DeleteTabletResponse) String() string

+ type PingTabletRequest struct

+ Alias string

+ ClusterIds []string

+ func (*PingTabletRequest) Descriptor() ([]byte, []int)

+ func (*PingTabletRequest) ProtoMessage()

+ func (m *PingTabletRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PingTabletRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PingTabletRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *PingTabletRequest) SizeVT() (n int)

+ func (m *PingTabletRequest) UnmarshalVT(dAtA []byte) error

+ func (x *PingTabletRequest) GetAlias() string

+ func (x *PingTabletRequest) GetClusterIds() []string

+ func (x *PingTabletRequest) ProtoReflect() protoreflect.Message

+ func (x *PingTabletRequest) Reset()

+ func (x *PingTabletRequest) String() string

+ type PingTabletResponse struct

+ Status string

+ func (*PingTabletResponse) Descriptor() ([]byte, []int)

+ func (*PingTabletResponse) ProtoMessage()

+ func (m *PingTabletResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PingTabletResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PingTabletResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *PingTabletResponse) SizeVT() (n int)

+ func (m *PingTabletResponse) UnmarshalVT(dAtA []byte) error

+ func (x *PingTabletResponse) GetStatus() string

+ func (x *PingTabletResponse) ProtoReflect() protoreflect.Message

+ func (x *PingTabletResponse) Reset()

+ func (x *PingTabletResponse) String() string

+ type RefreshStateRequest struct

+ Alias string

+ ClusterIds []string

+ func (*RefreshStateRequest) Descriptor() ([]byte, []int)

+ func (*RefreshStateRequest) ProtoMessage()

+ func (m *RefreshStateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RefreshStateRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RefreshStateRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *RefreshStateRequest) SizeVT() (n int)

+ func (m *RefreshStateRequest) UnmarshalVT(dAtA []byte) error

+ func (x *RefreshStateRequest) GetAlias() string

+ func (x *RefreshStateRequest) GetClusterIds() []string

+ func (x *RefreshStateRequest) ProtoReflect() protoreflect.Message

+ func (x *RefreshStateRequest) Reset()

+ func (x *RefreshStateRequest) String() string

+ type RefreshStateResponse struct

+ Status string

+ func (*RefreshStateResponse) Descriptor() ([]byte, []int)

+ func (*RefreshStateResponse) ProtoMessage()

+ func (m *RefreshStateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RefreshStateResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RefreshStateResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *RefreshStateResponse) SizeVT() (n int)

+ func (m *RefreshStateResponse) UnmarshalVT(dAtA []byte) error

+ func (x *RefreshStateResponse) GetStatus() string

+ func (x *RefreshStateResponse) ProtoReflect() protoreflect.Message

+ func (x *RefreshStateResponse) Reset()

+ func (x *RefreshStateResponse) String() string

+ type ReparentTabletRequest struct

+ Alias string

+ ClusterIds []string

+ func (*ReparentTabletRequest) Descriptor() ([]byte, []int)

+ func (*ReparentTabletRequest) ProtoMessage()

+ func (m *ReparentTabletRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReparentTabletRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReparentTabletRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ReparentTabletRequest) SizeVT() (n int)

+ func (m *ReparentTabletRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ReparentTabletRequest) GetAlias() string

+ func (x *ReparentTabletRequest) GetClusterIds() []string

+ func (x *ReparentTabletRequest) ProtoReflect() protoreflect.Message

+ func (x *ReparentTabletRequest) Reset()

+ func (x *ReparentTabletRequest) String() string

+ type ReparentTabletResponse struct

+ Keyspace string

+ Primary string

+ Shard string

+ func (*ReparentTabletResponse) Descriptor() ([]byte, []int)

+ func (*ReparentTabletResponse) ProtoMessage()

+ func (m *ReparentTabletResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReparentTabletResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReparentTabletResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *ReparentTabletResponse) SizeVT() (n int)

+ func (m *ReparentTabletResponse) UnmarshalVT(dAtA []byte) error

+ func (x *ReparentTabletResponse) GetKeyspace() string

+ func (x *ReparentTabletResponse) GetPrimary() string

+ func (x *ReparentTabletResponse) GetShard() string

+ func (x *ReparentTabletResponse) ProtoReflect() protoreflect.Message

+ func (x *ReparentTabletResponse) Reset()

+ func (x *ReparentTabletResponse) String() string

+ type RunHealthCheckRequest struct

+ Alias string

+ ClusterIds []string

+ func (*RunHealthCheckRequest) Descriptor() ([]byte, []int)

+ func (*RunHealthCheckRequest) ProtoMessage()

+ func (m *RunHealthCheckRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RunHealthCheckRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RunHealthCheckRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *RunHealthCheckRequest) SizeVT() (n int)

+ func (m *RunHealthCheckRequest) UnmarshalVT(dAtA []byte) error

+ func (x *RunHealthCheckRequest) GetAlias() string

+ func (x *RunHealthCheckRequest) GetClusterIds() []string

+ func (x *RunHealthCheckRequest) ProtoReflect() protoreflect.Message

+ func (x *RunHealthCheckRequest) Reset()

+ func (x *RunHealthCheckRequest) String() string

+ type RunHealthCheckResponse struct

+ Status string

+ func (*RunHealthCheckResponse) Descriptor() ([]byte, []int)

+ func (*RunHealthCheckResponse) ProtoMessage()

+ func (m *RunHealthCheckResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RunHealthCheckResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RunHealthCheckResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *RunHealthCheckResponse) SizeVT() (n int)

+ func (m *RunHealthCheckResponse) UnmarshalVT(dAtA []byte) error

+ func (x *RunHealthCheckResponse) GetStatus() string

+ func (x *RunHealthCheckResponse) ProtoReflect() protoreflect.Message

+ func (x *RunHealthCheckResponse) Reset()

+ func (x *RunHealthCheckResponse) String() string

+ type StartReplicationRequest struct

+ Alias string

+ ClusterIds []string

+ func (*StartReplicationRequest) Descriptor() ([]byte, []int)

+ func (*StartReplicationRequest) ProtoMessage()

+ func (m *StartReplicationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *StartReplicationRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *StartReplicationRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *StartReplicationRequest) SizeVT() (n int)

+ func (m *StartReplicationRequest) UnmarshalVT(dAtA []byte) error

+ func (x *StartReplicationRequest) GetAlias() string

+ func (x *StartReplicationRequest) GetClusterIds() []string

+ func (x *StartReplicationRequest) ProtoReflect() protoreflect.Message

+ func (x *StartReplicationRequest) Reset()

+ func (x *StartReplicationRequest) String() string

+ type StartReplicationResponse struct

+ Status string

+ func (*StartReplicationResponse) Descriptor() ([]byte, []int)

+ func (*StartReplicationResponse) ProtoMessage()

+ func (m *StartReplicationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *StartReplicationResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *StartReplicationResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *StartReplicationResponse) SizeVT() (n int)

+ func (m *StartReplicationResponse) UnmarshalVT(dAtA []byte) error

+ func (x *StartReplicationResponse) GetStatus() string

+ func (x *StartReplicationResponse) ProtoReflect() protoreflect.Message

+ func (x *StartReplicationResponse) Reset()

+ func (x *StartReplicationResponse) String() string

+ type StopReplicationRequest struct

+ Alias string

+ ClusterIds []string

+ func (*StopReplicationRequest) Descriptor() ([]byte, []int)

+ func (*StopReplicationRequest) ProtoMessage()

+ func (m *StopReplicationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *StopReplicationRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *StopReplicationRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *StopReplicationRequest) SizeVT() (n int)

+ func (m *StopReplicationRequest) UnmarshalVT(dAtA []byte) error

+ func (x *StopReplicationRequest) GetAlias() string

+ func (x *StopReplicationRequest) GetClusterIds() []string

+ func (x *StopReplicationRequest) ProtoReflect() protoreflect.Message

+ func (x *StopReplicationRequest) Reset()

+ func (x *StopReplicationRequest) String() string

+ type StopReplicationResponse struct

+ Status string

+ func (*StopReplicationResponse) Descriptor() ([]byte, []int)

+ func (*StopReplicationResponse) ProtoMessage()

+ func (m *StopReplicationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *StopReplicationResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *StopReplicationResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *StopReplicationResponse) SizeVT() (n int)

+ func (m *StopReplicationResponse) UnmarshalVT(dAtA []byte) error

+ func (x *StopReplicationResponse) GetStatus() string

+ func (x *StopReplicationResponse) ProtoReflect() protoreflect.Message

+ func (x *StopReplicationResponse) Reset()

+ func (x *StopReplicationResponse) String() string

type UnimplementedVTAdminServer

+ func (UnimplementedVTAdminServer) CreateShard(context.Context, *CreateShardRequest) (*vtctldata.CreateShardResponse, error)

+ func (UnimplementedVTAdminServer) DeleteShards(context.Context, *DeleteShardsRequest) (*vtctldata.DeleteShardsResponse, error)

+ func (UnimplementedVTAdminServer) DeleteTablet(context.Context, *DeleteTabletRequest) (*DeleteTabletResponse, error)

+ func (UnimplementedVTAdminServer) PingTablet(context.Context, *PingTabletRequest) (*PingTabletResponse, error)

+ func (UnimplementedVTAdminServer) RefreshState(context.Context, *RefreshStateRequest) (*RefreshStateResponse, error)

+ func (UnimplementedVTAdminServer) ReparentTablet(context.Context, *ReparentTabletRequest) (*ReparentTabletResponse, error)

+ func (UnimplementedVTAdminServer) RunHealthCheck(context.Context, *RunHealthCheckRequest) (*RunHealthCheckResponse, error)

+ func (UnimplementedVTAdminServer) StartReplication(context.Context, *StartReplicationRequest) (*StartReplicationResponse, error)

+ func (UnimplementedVTAdminServer) StopReplication(context.Context, *StopReplicationRequest) (*StopReplicationResponse, error)

type VTAdminClient

+ CreateShard func(ctx context.Context, in *CreateShardRequest, opts ...grpc.CallOption) (*vtctldata.CreateShardResponse, error)

+ DeleteShards func(ctx context.Context, in *DeleteShardsRequest, opts ...grpc.CallOption) (*vtctldata.DeleteShardsResponse, error)

+ DeleteTablet func(ctx context.Context, in *DeleteTabletRequest, opts ...grpc.CallOption) (*DeleteTabletResponse, error)

+ PingTablet func(ctx context.Context, in *PingTabletRequest, opts ...grpc.CallOption) (*PingTabletResponse, error)

+ RefreshState func(ctx context.Context, in *RefreshStateRequest, opts ...grpc.CallOption) (*RefreshStateResponse, error)

+ ReparentTablet func(ctx context.Context, in *ReparentTabletRequest, opts ...grpc.CallOption) (*ReparentTabletResponse, error)

+ RunHealthCheck func(ctx context.Context, in *RunHealthCheckRequest, opts ...grpc.CallOption) (*RunHealthCheckResponse, error)

+ StartReplication func(ctx context.Context, in *StartReplicationRequest, opts ...grpc.CallOption) (*StartReplicationResponse, error)

+ StopReplication func(ctx context.Context, in *StopReplicationRequest, opts ...grpc.CallOption) (*StopReplicationResponse, error)

type VTAdminServer

+ CreateShard func(context.Context, *CreateShardRequest) (*vtctldata.CreateShardResponse, error)

+ DeleteShards func(context.Context, *DeleteShardsRequest) (*vtctldata.DeleteShardsResponse, error)

+ DeleteTablet func(context.Context, *DeleteTabletRequest) (*DeleteTabletResponse, error)

+ PingTablet func(context.Context, *PingTabletRequest) (*PingTabletResponse, error)

+ RefreshState func(context.Context, *RefreshStateRequest) (*RefreshStateResponse, error)

+ ReparentTablet func(context.Context, *ReparentTabletRequest) (*ReparentTabletResponse, error)

+ RunHealthCheck func(context.Context, *RunHealthCheckRequest) (*RunHealthCheckResponse, error)

+ StartReplication func(context.Context, *StartReplicationRequest) (*StartReplicationResponse, error)

+ StopReplication func(context.Context, *StopReplicationRequest) (*StopReplicationResponse, error)

Sep 1, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 27, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

May 20, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jan 10, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 17, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 14, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Oct 26, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ type ClusterShardReplicationPosition struct

+ Cluster *Cluster

+ Keyspace string

+ PositionInfo *vtctldata.ShardReplicationPositionsResponse

+ Shard string

+ func (*ClusterShardReplicationPosition) Descriptor() ([]byte, []int)

+ func (*ClusterShardReplicationPosition) ProtoMessage()

+ func (m *ClusterShardReplicationPosition) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ClusterShardReplicationPosition) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ClusterShardReplicationPosition) MarshalVT() (dAtA []byte, err error)

+ func (m *ClusterShardReplicationPosition) SizeVT() (n int)

+ func (m *ClusterShardReplicationPosition) UnmarshalVT(dAtA []byte) error

+ func (x *ClusterShardReplicationPosition) GetCluster() *Cluster

+ func (x *ClusterShardReplicationPosition) GetKeyspace() string

+ func (x *ClusterShardReplicationPosition) GetPositionInfo() *vtctldata.ShardReplicationPositionsResponse

+ func (x *ClusterShardReplicationPosition) GetShard() string

+ func (x *ClusterShardReplicationPosition) ProtoReflect() protoreflect.Message

+ func (x *ClusterShardReplicationPosition) Reset()

+ func (x *ClusterShardReplicationPosition) String() string

+ type CreateKeyspaceRequest struct

+ ClusterId string

+ Options *vtctldata.CreateKeyspaceRequest

+ func (*CreateKeyspaceRequest) Descriptor() ([]byte, []int)

+ func (*CreateKeyspaceRequest) ProtoMessage()

+ func (m *CreateKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *CreateKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *CreateKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *CreateKeyspaceRequest) SizeVT() (n int)

+ func (m *CreateKeyspaceRequest) UnmarshalVT(dAtA []byte) error

+ func (x *CreateKeyspaceRequest) GetClusterId() string

+ func (x *CreateKeyspaceRequest) GetOptions() *vtctldata.CreateKeyspaceRequest

+ func (x *CreateKeyspaceRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateKeyspaceRequest) Reset()

+ func (x *CreateKeyspaceRequest) String() string

+ type CreateKeyspaceResponse struct

+ Keyspace *Keyspace

+ func (*CreateKeyspaceResponse) Descriptor() ([]byte, []int)

+ func (*CreateKeyspaceResponse) ProtoMessage()

+ func (m *CreateKeyspaceResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *CreateKeyspaceResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *CreateKeyspaceResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *CreateKeyspaceResponse) SizeVT() (n int)

+ func (m *CreateKeyspaceResponse) UnmarshalVT(dAtA []byte) error

+ func (x *CreateKeyspaceResponse) GetKeyspace() *Keyspace

+ func (x *CreateKeyspaceResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateKeyspaceResponse) Reset()

+ func (x *CreateKeyspaceResponse) String() string

+ type DeleteKeyspaceRequest struct

+ ClusterId string

+ Options *vtctldata.DeleteKeyspaceRequest

+ func (*DeleteKeyspaceRequest) Descriptor() ([]byte, []int)

+ func (*DeleteKeyspaceRequest) ProtoMessage()

+ func (m *DeleteKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DeleteKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DeleteKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *DeleteKeyspaceRequest) SizeVT() (n int)

+ func (m *DeleteKeyspaceRequest) UnmarshalVT(dAtA []byte) error

+ func (x *DeleteKeyspaceRequest) GetClusterId() string

+ func (x *DeleteKeyspaceRequest) GetOptions() *vtctldata.DeleteKeyspaceRequest

+ func (x *DeleteKeyspaceRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteKeyspaceRequest) Reset()

+ func (x *DeleteKeyspaceRequest) String() string

+ type GetShardReplicationPositionsRequest struct

+ ClusterIds []string

+ KeyspaceShards []string

+ Keyspaces []string

+ func (*GetShardReplicationPositionsRequest) Descriptor() ([]byte, []int)

+ func (*GetShardReplicationPositionsRequest) ProtoMessage()

+ func (m *GetShardReplicationPositionsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetShardReplicationPositionsRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetShardReplicationPositionsRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetShardReplicationPositionsRequest) SizeVT() (n int)

+ func (m *GetShardReplicationPositionsRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetShardReplicationPositionsRequest) GetClusterIds() []string

+ func (x *GetShardReplicationPositionsRequest) GetKeyspaceShards() []string

+ func (x *GetShardReplicationPositionsRequest) GetKeyspaces() []string

+ func (x *GetShardReplicationPositionsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetShardReplicationPositionsRequest) Reset()

+ func (x *GetShardReplicationPositionsRequest) String() string

+ type GetShardReplicationPositionsResponse struct

+ ReplicationPositions []*ClusterShardReplicationPosition

+ func (*GetShardReplicationPositionsResponse) Descriptor() ([]byte, []int)

+ func (*GetShardReplicationPositionsResponse) ProtoMessage()

+ func (m *GetShardReplicationPositionsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetShardReplicationPositionsResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetShardReplicationPositionsResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetShardReplicationPositionsResponse) SizeVT() (n int)

+ func (m *GetShardReplicationPositionsResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetShardReplicationPositionsResponse) GetReplicationPositions() []*ClusterShardReplicationPosition

+ func (x *GetShardReplicationPositionsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetShardReplicationPositionsResponse) Reset()

+ func (x *GetShardReplicationPositionsResponse) String() string

+ type GetVtctldsRequest struct

+ ClusterIds []string

+ func (*GetVtctldsRequest) Descriptor() ([]byte, []int)

+ func (*GetVtctldsRequest) ProtoMessage()

+ func (m *GetVtctldsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetVtctldsRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetVtctldsRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetVtctldsRequest) SizeVT() (n int)

+ func (m *GetVtctldsRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetVtctldsRequest) GetClusterIds() []string

+ func (x *GetVtctldsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetVtctldsRequest) Reset()

+ func (x *GetVtctldsRequest) String() string

+ type GetVtctldsResponse struct

+ Vtctlds []*Vtctld

+ func (*GetVtctldsResponse) Descriptor() ([]byte, []int)

+ func (*GetVtctldsResponse) ProtoMessage()

+ func (m *GetVtctldsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetVtctldsResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetVtctldsResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetVtctldsResponse) SizeVT() (n int)

+ func (m *GetVtctldsResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetVtctldsResponse) GetVtctlds() []*Vtctld

+ func (x *GetVtctldsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetVtctldsResponse) Reset()

+ func (x *GetVtctldsResponse) String() string

type UnimplementedVTAdminServer

+ func (UnimplementedVTAdminServer) CreateKeyspace(context.Context, *CreateKeyspaceRequest) (*CreateKeyspaceResponse, error)

+ func (UnimplementedVTAdminServer) DeleteKeyspace(context.Context, *DeleteKeyspaceRequest) (*vtctldata.DeleteKeyspaceResponse, error)

+ func (UnimplementedVTAdminServer) GetShardReplicationPositions(context.Context, *GetShardReplicationPositionsRequest) (*GetShardReplicationPositionsResponse, error)

+ func (UnimplementedVTAdminServer) GetVtctlds(context.Context, *GetVtctldsRequest) (*GetVtctldsResponse, error)

type VTAdminClient

+ CreateKeyspace func(ctx context.Context, in *CreateKeyspaceRequest, opts ...grpc.CallOption) (*CreateKeyspaceResponse, error)

+ DeleteKeyspace func(ctx context.Context, in *DeleteKeyspaceRequest, opts ...grpc.CallOption) (*vtctldata.DeleteKeyspaceResponse, error)

+ GetShardReplicationPositions func(ctx context.Context, in *GetShardReplicationPositionsRequest, ...) (*GetShardReplicationPositionsResponse, error)

+ GetVtctlds func(ctx context.Context, in *GetVtctldsRequest, opts ...grpc.CallOption) (*GetVtctldsResponse, error)

type VTAdminServer

+ CreateKeyspace func(context.Context, *CreateKeyspaceRequest) (*CreateKeyspaceResponse, error)

+ DeleteKeyspace func(context.Context, *DeleteKeyspaceRequest) (*vtctldata.DeleteKeyspaceResponse, error)

+ GetShardReplicationPositions func(context.Context, *GetShardReplicationPositionsRequest) (*GetShardReplicationPositionsResponse, error)

+ GetVtctlds func(context.Context, *GetVtctldsRequest) (*GetVtctldsResponse, error)

Jan 10, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 17, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 14, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Sep 9, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jul 27, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ var ErrIntOverflow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")

+ var File_vtadmin_proto protoreflect.FileDescriptor

+ var VTAdmin_ServiceDesc = grpc.ServiceDesc

type Cluster

+ func (m *Cluster) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Cluster) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Cluster) MarshalVT() (dAtA []byte, err error)

+ func (m *Cluster) SizeVT() (n int)

+ func (m *Cluster) UnmarshalVT(dAtA []byte) error

+ func (x *Cluster) ProtoReflect() protoreflect.Message

+ type ClusterBackup struct

+ Backup *mysqlctl.BackupInfo

+ Cluster *Cluster

+ func (*ClusterBackup) Descriptor() ([]byte, []int)

+ func (*ClusterBackup) ProtoMessage()

+ func (m *ClusterBackup) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ClusterBackup) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ClusterBackup) MarshalVT() (dAtA []byte, err error)

+ func (m *ClusterBackup) SizeVT() (n int)

+ func (m *ClusterBackup) UnmarshalVT(dAtA []byte) error

+ func (x *ClusterBackup) GetBackup() *mysqlctl.BackupInfo

+ func (x *ClusterBackup) GetCluster() *Cluster

+ func (x *ClusterBackup) ProtoReflect() protoreflect.Message

+ func (x *ClusterBackup) Reset()

+ func (x *ClusterBackup) String() string

type ClusterWorkflows

+ func (m *ClusterWorkflows) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ClusterWorkflows) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ClusterWorkflows) MarshalVT() (dAtA []byte, err error)

+ func (m *ClusterWorkflows) SizeVT() (n int)

+ func (m *ClusterWorkflows) UnmarshalVT(dAtA []byte) error

+ func (x *ClusterWorkflows) ProtoReflect() protoreflect.Message

type FindSchemaRequest

+ func (m *FindSchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *FindSchemaRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *FindSchemaRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *FindSchemaRequest) SizeVT() (n int)

+ func (m *FindSchemaRequest) UnmarshalVT(dAtA []byte) error

+ func (x *FindSchemaRequest) ProtoReflect() protoreflect.Message

+ type GetBackupsRequest struct

+ ClusterIds []string

+ KeyspaceShards []string

+ Keyspaces []string

+ RequestOptions *vtctldata.GetBackupsRequest

+ func (*GetBackupsRequest) Descriptor() ([]byte, []int)

+ func (*GetBackupsRequest) ProtoMessage()

+ func (m *GetBackupsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetBackupsRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetBackupsRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetBackupsRequest) SizeVT() (n int)

+ func (m *GetBackupsRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetBackupsRequest) GetClusterIds() []string

+ func (x *GetBackupsRequest) GetKeyspaceShards() []string

+ func (x *GetBackupsRequest) GetKeyspaces() []string

+ func (x *GetBackupsRequest) GetRequestOptions() *vtctldata.GetBackupsRequest

+ func (x *GetBackupsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetBackupsRequest) Reset()

+ func (x *GetBackupsRequest) String() string

+ type GetBackupsResponse struct

+ Backups []*ClusterBackup

+ func (*GetBackupsResponse) Descriptor() ([]byte, []int)

+ func (*GetBackupsResponse) ProtoMessage()

+ func (m *GetBackupsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetBackupsResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetBackupsResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetBackupsResponse) SizeVT() (n int)

+ func (m *GetBackupsResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetBackupsResponse) GetBackups() []*ClusterBackup

+ func (x *GetBackupsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetBackupsResponse) Reset()

+ func (x *GetBackupsResponse) String() string

type GetClustersRequest

+ func (m *GetClustersRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetClustersRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetClustersRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetClustersRequest) SizeVT() (n int)

+ func (m *GetClustersRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetClustersRequest) ProtoReflect() protoreflect.Message

type GetClustersResponse

+ func (m *GetClustersResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetClustersResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetClustersResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetClustersResponse) SizeVT() (n int)

+ func (m *GetClustersResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetClustersResponse) ProtoReflect() protoreflect.Message

type GetGatesRequest

+ func (m *GetGatesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetGatesRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetGatesRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetGatesRequest) SizeVT() (n int)

+ func (m *GetGatesRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetGatesRequest) ProtoReflect() protoreflect.Message

type GetGatesResponse

+ func (m *GetGatesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetGatesResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetGatesResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetGatesResponse) SizeVT() (n int)

+ func (m *GetGatesResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetGatesResponse) ProtoReflect() protoreflect.Message

+ type GetKeyspaceRequest struct

+ ClusterId string

+ Keyspace string

+ func (*GetKeyspaceRequest) Descriptor() ([]byte, []int)

+ func (*GetKeyspaceRequest) ProtoMessage()

+ func (m *GetKeyspaceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetKeyspaceRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetKeyspaceRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetKeyspaceRequest) SizeVT() (n int)

+ func (m *GetKeyspaceRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetKeyspaceRequest) GetClusterId() string

+ func (x *GetKeyspaceRequest) GetKeyspace() string

+ func (x *GetKeyspaceRequest) ProtoReflect() protoreflect.Message

+ func (x *GetKeyspaceRequest) Reset()

+ func (x *GetKeyspaceRequest) String() string

type GetKeyspacesRequest

+ func (m *GetKeyspacesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetKeyspacesRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetKeyspacesRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetKeyspacesRequest) SizeVT() (n int)

+ func (m *GetKeyspacesRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetKeyspacesRequest) ProtoReflect() protoreflect.Message

type GetKeyspacesResponse

+ func (m *GetKeyspacesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetKeyspacesResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetKeyspacesResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetKeyspacesResponse) SizeVT() (n int)

+ func (m *GetKeyspacesResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetKeyspacesResponse) ProtoReflect() protoreflect.Message

type GetSchemaRequest

+ func (m *GetSchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSchemaRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSchemaRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSchemaRequest) SizeVT() (n int)

+ func (m *GetSchemaRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message

type GetSchemaTableSizeOptions

+ IncludeNonServingShards bool

+ func (m *GetSchemaTableSizeOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSchemaTableSizeOptions) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSchemaTableSizeOptions) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSchemaTableSizeOptions) SizeVT() (n int)

+ func (m *GetSchemaTableSizeOptions) UnmarshalVT(dAtA []byte) error

+ func (x *GetSchemaTableSizeOptions) GetIncludeNonServingShards() bool

+ func (x *GetSchemaTableSizeOptions) ProtoReflect() protoreflect.Message

type GetSchemasRequest

+ func (m *GetSchemasRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSchemasRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSchemasRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSchemasRequest) SizeVT() (n int)

+ func (m *GetSchemasRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetSchemasRequest) ProtoReflect() protoreflect.Message

type GetSchemasResponse

+ func (m *GetSchemasResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSchemasResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSchemasResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSchemasResponse) SizeVT() (n int)

+ func (m *GetSchemasResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetSchemasResponse) ProtoReflect() protoreflect.Message

+ type GetSrvVSchemaRequest struct

+ Cell string

+ ClusterId string

+ func (*GetSrvVSchemaRequest) Descriptor() ([]byte, []int)

+ func (*GetSrvVSchemaRequest) ProtoMessage()

+ func (m *GetSrvVSchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSrvVSchemaRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSrvVSchemaRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSrvVSchemaRequest) SizeVT() (n int)

+ func (m *GetSrvVSchemaRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetSrvVSchemaRequest) GetCell() string

+ func (x *GetSrvVSchemaRequest) GetClusterId() string

+ func (x *GetSrvVSchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSrvVSchemaRequest) Reset()

+ func (x *GetSrvVSchemaRequest) String() string

+ type GetSrvVSchemasRequest struct

+ Cells []string

+ ClusterIds []string

+ func (*GetSrvVSchemasRequest) Descriptor() ([]byte, []int)

+ func (*GetSrvVSchemasRequest) ProtoMessage()

+ func (m *GetSrvVSchemasRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSrvVSchemasRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSrvVSchemasRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSrvVSchemasRequest) SizeVT() (n int)

+ func (m *GetSrvVSchemasRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetSrvVSchemasRequest) GetCells() []string

+ func (x *GetSrvVSchemasRequest) GetClusterIds() []string

+ func (x *GetSrvVSchemasRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSrvVSchemasRequest) Reset()

+ func (x *GetSrvVSchemasRequest) String() string

+ type GetSrvVSchemasResponse struct

+ SrvVSchemas []*SrvVSchema

+ func (*GetSrvVSchemasResponse) Descriptor() ([]byte, []int)

+ func (*GetSrvVSchemasResponse) ProtoMessage()

+ func (m *GetSrvVSchemasResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetSrvVSchemasResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetSrvVSchemasResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetSrvVSchemasResponse) SizeVT() (n int)

+ func (m *GetSrvVSchemasResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetSrvVSchemasResponse) GetSrvVSchemas() []*SrvVSchema

+ func (x *GetSrvVSchemasResponse) ProtoReflect() protoreflect.Message

+ func (x *GetSrvVSchemasResponse) Reset()

+ func (x *GetSrvVSchemasResponse) String() string

type GetTabletRequest

+ Alias string

+ func (m *GetTabletRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetTabletRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetTabletRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetTabletRequest) SizeVT() (n int)

+ func (m *GetTabletRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetTabletRequest) GetAlias() string

+ func (x *GetTabletRequest) ProtoReflect() protoreflect.Message

type GetTabletsRequest

+ func (m *GetTabletsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetTabletsRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetTabletsRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetTabletsRequest) SizeVT() (n int)

+ func (m *GetTabletsRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetTabletsRequest) ProtoReflect() protoreflect.Message

type GetTabletsResponse

+ func (m *GetTabletsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetTabletsResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetTabletsResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetTabletsResponse) SizeVT() (n int)

+ func (m *GetTabletsResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetTabletsResponse) ProtoReflect() protoreflect.Message

type GetVSchemaRequest

+ func (m *GetVSchemaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetVSchemaRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetVSchemaRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetVSchemaRequest) SizeVT() (n int)

+ func (m *GetVSchemaRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetVSchemaRequest) ProtoReflect() protoreflect.Message

type GetVSchemasRequest

+ func (m *GetVSchemasRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetVSchemasRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetVSchemasRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetVSchemasRequest) SizeVT() (n int)

+ func (m *GetVSchemasRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetVSchemasRequest) ProtoReflect() protoreflect.Message

type GetVSchemasResponse

+ func (m *GetVSchemasResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetVSchemasResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetVSchemasResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetVSchemasResponse) SizeVT() (n int)

+ func (m *GetVSchemasResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetVSchemasResponse) ProtoReflect() protoreflect.Message

type GetWorkflowRequest

+ func (m *GetWorkflowRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetWorkflowRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetWorkflowRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetWorkflowRequest) SizeVT() (n int)

+ func (m *GetWorkflowRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetWorkflowRequest) ProtoReflect() protoreflect.Message

type GetWorkflowsRequest

+ func (m *GetWorkflowsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetWorkflowsRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetWorkflowsRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetWorkflowsRequest) SizeVT() (n int)

+ func (m *GetWorkflowsRequest) UnmarshalVT(dAtA []byte) error

+ func (x *GetWorkflowsRequest) ProtoReflect() protoreflect.Message

type GetWorkflowsResponse

+ func (m *GetWorkflowsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetWorkflowsResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetWorkflowsResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetWorkflowsResponse) SizeVT() (n int)

+ func (m *GetWorkflowsResponse) UnmarshalVT(dAtA []byte) error

+ func (x *GetWorkflowsResponse) ProtoReflect() protoreflect.Message

type Keyspace

+ func (m *Keyspace) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Keyspace) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Keyspace) MarshalVT() (dAtA []byte, err error)

+ func (m *Keyspace) SizeVT() (n int)

+ func (m *Keyspace) UnmarshalVT(dAtA []byte) error

+ func (x *Keyspace) ProtoReflect() protoreflect.Message

type Schema

+ func (m *Schema) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Schema) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Schema) MarshalVT() (dAtA []byte, err error)

+ func (m *Schema) SizeVT() (n int)

+ func (m *Schema) UnmarshalVT(dAtA []byte) error

+ func (x *Schema) ProtoReflect() protoreflect.Message

type Schema_ShardTableSize

+ func (m *Schema_ShardTableSize) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Schema_ShardTableSize) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Schema_ShardTableSize) MarshalVT() (dAtA []byte, err error)

+ func (m *Schema_ShardTableSize) SizeVT() (n int)

+ func (m *Schema_ShardTableSize) UnmarshalVT(dAtA []byte) error

+ func (x *Schema_ShardTableSize) ProtoReflect() protoreflect.Message

type Schema_TableSize

+ func (m *Schema_TableSize) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Schema_TableSize) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Schema_TableSize) MarshalVT() (dAtA []byte, err error)

+ func (m *Schema_TableSize) SizeVT() (n int)

+ func (m *Schema_TableSize) UnmarshalVT(dAtA []byte) error

+ func (x *Schema_TableSize) ProtoReflect() protoreflect.Message

+ type SrvVSchema struct

+ Cell string

+ Cluster *Cluster

+ SrvVSchema *vschema.SrvVSchema

+ func (*SrvVSchema) Descriptor() ([]byte, []int)

+ func (*SrvVSchema) ProtoMessage()

+ func (m *SrvVSchema) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SrvVSchema) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SrvVSchema) MarshalVT() (dAtA []byte, err error)

+ func (m *SrvVSchema) SizeVT() (n int)

+ func (m *SrvVSchema) UnmarshalVT(dAtA []byte) error

+ func (x *SrvVSchema) GetCell() string

+ func (x *SrvVSchema) GetCluster() *Cluster

+ func (x *SrvVSchema) GetSrvVSchema() *vschema.SrvVSchema

+ func (x *SrvVSchema) ProtoReflect() protoreflect.Message

+ func (x *SrvVSchema) Reset()

+ func (x *SrvVSchema) String() string

type Tablet

+ FQDN string

+ func (m *Tablet) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Tablet) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Tablet) MarshalVT() (dAtA []byte, err error)

+ func (m *Tablet) SizeVT() (n int)

+ func (m *Tablet) UnmarshalVT(dAtA []byte) error

+ func (x *Tablet) GetFQDN() string

+ func (x *Tablet) ProtoReflect() protoreflect.Message

type Tablet_ServingState

+ func (Tablet_ServingState) Descriptor() protoreflect.EnumDescriptor

+ func (Tablet_ServingState) Type() protoreflect.EnumType

+ func (x Tablet_ServingState) Enum() *Tablet_ServingState

+ func (x Tablet_ServingState) Number() protoreflect.EnumNumber

type UnimplementedVTAdminServer

+ func (UnimplementedVTAdminServer) GetBackups(context.Context, *GetBackupsRequest) (*GetBackupsResponse, error)

+ func (UnimplementedVTAdminServer) GetKeyspace(context.Context, *GetKeyspaceRequest) (*Keyspace, error)

+ func (UnimplementedVTAdminServer) GetSrvVSchema(context.Context, *GetSrvVSchemaRequest) (*SrvVSchema, error)

+ func (UnimplementedVTAdminServer) GetSrvVSchemas(context.Context, *GetSrvVSchemasRequest) (*GetSrvVSchemasResponse, error)

+ type UnsafeVTAdminServer interface

type VSchema

+ func (m *VSchema) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *VSchema) MarshalToVT(dAtA []byte) (int, error)

+ func (m *VSchema) MarshalVT() (dAtA []byte, err error)

+ func (m *VSchema) SizeVT() (n int)

+ func (m *VSchema) UnmarshalVT(dAtA []byte) error

+ func (x *VSchema) ProtoReflect() protoreflect.Message

type VTAdminClient

+ GetBackups func(ctx context.Context, in *GetBackupsRequest, opts ...grpc.CallOption) (*GetBackupsResponse, error)

+ GetKeyspace func(ctx context.Context, in *GetKeyspaceRequest, opts ...grpc.CallOption) (*Keyspace, error)

+ GetSrvVSchema func(ctx context.Context, in *GetSrvVSchemaRequest, opts ...grpc.CallOption) (*SrvVSchema, error)

+ GetSrvVSchemas func(ctx context.Context, in *GetSrvVSchemasRequest, opts ...grpc.CallOption) (*GetSrvVSchemasResponse, error)

type VTAdminServer

+ GetBackups func(context.Context, *GetBackupsRequest) (*GetBackupsResponse, error)

+ GetKeyspace func(context.Context, *GetKeyspaceRequest) (*Keyspace, error)

+ GetSrvVSchema func(context.Context, *GetSrvVSchemaRequest) (*SrvVSchema, error)

+ GetSrvVSchemas func(context.Context, *GetSrvVSchemasRequest) (*GetSrvVSchemasResponse, error)

type VTExplainRequest

+ func (m *VTExplainRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *VTExplainRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *VTExplainRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *VTExplainRequest) SizeVT() (n int)

+ func (m *VTExplainRequest) UnmarshalVT(dAtA []byte) error

+ func (x *VTExplainRequest) ProtoReflect() protoreflect.Message

type VTExplainResponse

+ func (m *VTExplainResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *VTExplainResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *VTExplainResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *VTExplainResponse) SizeVT() (n int)

+ func (m *VTExplainResponse) UnmarshalVT(dAtA []byte) error

+ func (x *VTExplainResponse) ProtoReflect() protoreflect.Message

type VTGate

+ FQDN string

+ func (m *VTGate) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *VTGate) MarshalToVT(dAtA []byte) (int, error)

+ func (m *VTGate) MarshalVT() (dAtA []byte, err error)

+ func (m *VTGate) SizeVT() (n int)

+ func (m *VTGate) UnmarshalVT(dAtA []byte) error

+ func (x *VTGate) GetFQDN() string

+ func (x *VTGate) ProtoReflect() protoreflect.Message

type Vtctld

+ FQDN string

+ func (m *Vtctld) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Vtctld) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Vtctld) MarshalVT() (dAtA []byte, err error)

+ func (m *Vtctld) SizeVT() (n int)

+ func (m *Vtctld) UnmarshalVT(dAtA []byte) error

+ func (x *Vtctld) GetFQDN() string

+ func (x *Vtctld) ProtoReflect() protoreflect.Message

type Workflow

+ func (m *Workflow) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Workflow) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Workflow) MarshalVT() (dAtA []byte, err error)

+ func (m *Workflow) SizeVT() (n int)

+ func (m *Workflow) UnmarshalVT(dAtA []byte) error

+ func (x *Workflow) ProtoReflect() protoreflect.Message

Jan 10, 2022 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 17, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Dec 14, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

May 27, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

May 4, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Apr 27, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ var ErrIntOverflowVtadmin = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthVtadmin = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupVtadmin = fmt.Errorf("proto: unexpected end of group")

type Cluster

+ func (m *Cluster) Marshal() (dAtA []byte, err error)

+ func (m *Cluster) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Cluster) Size() (n int)

+ func (m *Cluster) Unmarshal(dAtA []byte) error

+ type ClusterWorkflows struct

+ Warnings []string

+ Workflows []*Workflow

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClusterWorkflows) Descriptor() ([]byte, []int)

+ func (*ClusterWorkflows) ProtoMessage()

+ func (m *ClusterWorkflows) GetWarnings() []string

+ func (m *ClusterWorkflows) GetWorkflows() []*Workflow

+ func (m *ClusterWorkflows) Marshal() (dAtA []byte, err error)

+ func (m *ClusterWorkflows) MarshalTo(dAtA []byte) (int, error)

+ func (m *ClusterWorkflows) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ClusterWorkflows) Reset()

+ func (m *ClusterWorkflows) Size() (n int)

+ func (m *ClusterWorkflows) String() string

+ func (m *ClusterWorkflows) Unmarshal(dAtA []byte) error

+ func (m *ClusterWorkflows) XXX_DiscardUnknown()

+ func (m *ClusterWorkflows) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClusterWorkflows) XXX_Merge(src proto.Message)

+ func (m *ClusterWorkflows) XXX_Size() int

+ func (m *ClusterWorkflows) XXX_Unmarshal(b []byte) error

+ type FindSchemaRequest struct

+ ClusterIds []string

+ Table string

+ TableSizeOptions *GetSchemaTableSizeOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FindSchemaRequest) Descriptor() ([]byte, []int)

+ func (*FindSchemaRequest) ProtoMessage()

+ func (m *FindSchemaRequest) GetClusterIds() []string

+ func (m *FindSchemaRequest) GetTable() string

+ func (m *FindSchemaRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

+ func (m *FindSchemaRequest) Marshal() (dAtA []byte, err error)

+ func (m *FindSchemaRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *FindSchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FindSchemaRequest) Reset()

+ func (m *FindSchemaRequest) Size() (n int)

+ func (m *FindSchemaRequest) String() string

+ func (m *FindSchemaRequest) Unmarshal(dAtA []byte) error

+ func (m *FindSchemaRequest) XXX_DiscardUnknown()

+ func (m *FindSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FindSchemaRequest) XXX_Merge(src proto.Message)

+ func (m *FindSchemaRequest) XXX_Size() int

+ func (m *FindSchemaRequest) XXX_Unmarshal(b []byte) error

+ type GetClustersRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetClustersRequest) Descriptor() ([]byte, []int)

+ func (*GetClustersRequest) ProtoMessage()

+ func (m *GetClustersRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetClustersRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetClustersRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetClustersRequest) Reset()

+ func (m *GetClustersRequest) Size() (n int)

+ func (m *GetClustersRequest) String() string

+ func (m *GetClustersRequest) Unmarshal(dAtA []byte) error

+ func (m *GetClustersRequest) XXX_DiscardUnknown()

+ func (m *GetClustersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetClustersRequest) XXX_Merge(src proto.Message)

+ func (m *GetClustersRequest) XXX_Size() int

+ func (m *GetClustersRequest) XXX_Unmarshal(b []byte) error

+ type GetClustersResponse struct

+ Clusters []*Cluster

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetClustersResponse) Descriptor() ([]byte, []int)

+ func (*GetClustersResponse) ProtoMessage()

+ func (m *GetClustersResponse) GetClusters() []*Cluster

+ func (m *GetClustersResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetClustersResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetClustersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetClustersResponse) Reset()

+ func (m *GetClustersResponse) Size() (n int)

+ func (m *GetClustersResponse) String() string

+ func (m *GetClustersResponse) Unmarshal(dAtA []byte) error

+ func (m *GetClustersResponse) XXX_DiscardUnknown()

+ func (m *GetClustersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetClustersResponse) XXX_Merge(src proto.Message)

+ func (m *GetClustersResponse) XXX_Size() int

+ func (m *GetClustersResponse) XXX_Unmarshal(b []byte) error

type GetGatesRequest

+ func (m *GetGatesRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetGatesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetGatesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetGatesRequest) Size() (n int)

+ func (m *GetGatesRequest) Unmarshal(dAtA []byte) error

type GetGatesResponse

+ func (m *GetGatesResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetGatesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetGatesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetGatesResponse) Size() (n int)

+ func (m *GetGatesResponse) Unmarshal(dAtA []byte) error

+ type GetKeyspacesRequest struct

+ ClusterIds []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetKeyspacesRequest) Descriptor() ([]byte, []int)

+ func (*GetKeyspacesRequest) ProtoMessage()

+ func (m *GetKeyspacesRequest) GetClusterIds() []string

+ func (m *GetKeyspacesRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetKeyspacesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetKeyspacesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetKeyspacesRequest) Reset()

+ func (m *GetKeyspacesRequest) Size() (n int)

+ func (m *GetKeyspacesRequest) String() string

+ func (m *GetKeyspacesRequest) Unmarshal(dAtA []byte) error

+ func (m *GetKeyspacesRequest) XXX_DiscardUnknown()

+ func (m *GetKeyspacesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetKeyspacesRequest) XXX_Merge(src proto.Message)

+ func (m *GetKeyspacesRequest) XXX_Size() int

+ func (m *GetKeyspacesRequest) XXX_Unmarshal(b []byte) error

+ type GetKeyspacesResponse struct

+ Keyspaces []*Keyspace

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetKeyspacesResponse) Descriptor() ([]byte, []int)

+ func (*GetKeyspacesResponse) ProtoMessage()

+ func (m *GetKeyspacesResponse) GetKeyspaces() []*Keyspace

+ func (m *GetKeyspacesResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetKeyspacesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetKeyspacesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetKeyspacesResponse) Reset()

+ func (m *GetKeyspacesResponse) Size() (n int)

+ func (m *GetKeyspacesResponse) String() string

+ func (m *GetKeyspacesResponse) Unmarshal(dAtA []byte) error

+ func (m *GetKeyspacesResponse) XXX_DiscardUnknown()

+ func (m *GetKeyspacesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetKeyspacesResponse) XXX_Merge(src proto.Message)

+ func (m *GetKeyspacesResponse) XXX_Size() int

+ func (m *GetKeyspacesResponse) XXX_Unmarshal(b []byte) error

+ type GetSchemaRequest struct

+ ClusterId string

+ Keyspace string

+ Table string

+ TableSizeOptions *GetSchemaTableSizeOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetSchemaRequest) Descriptor() ([]byte, []int)

+ func (*GetSchemaRequest) ProtoMessage()

+ func (m *GetSchemaRequest) GetClusterId() string

+ func (m *GetSchemaRequest) GetKeyspace() string

+ func (m *GetSchemaRequest) GetTable() string

+ func (m *GetSchemaRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

+ func (m *GetSchemaRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetSchemaRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetSchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetSchemaRequest) Reset()

+ func (m *GetSchemaRequest) Size() (n int)

+ func (m *GetSchemaRequest) String() string

+ func (m *GetSchemaRequest) Unmarshal(dAtA []byte) error

+ func (m *GetSchemaRequest) XXX_DiscardUnknown()

+ func (m *GetSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetSchemaRequest) XXX_Merge(src proto.Message)

+ func (m *GetSchemaRequest) XXX_Size() int

+ func (m *GetSchemaRequest) XXX_Unmarshal(b []byte) error

+ type GetSchemaTableSizeOptions struct

+ AggregateSizes bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetSchemaTableSizeOptions) Descriptor() ([]byte, []int)

+ func (*GetSchemaTableSizeOptions) ProtoMessage()

+ func (m *GetSchemaTableSizeOptions) GetAggregateSizes() bool

+ func (m *GetSchemaTableSizeOptions) Marshal() (dAtA []byte, err error)

+ func (m *GetSchemaTableSizeOptions) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetSchemaTableSizeOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetSchemaTableSizeOptions) Reset()

+ func (m *GetSchemaTableSizeOptions) Size() (n int)

+ func (m *GetSchemaTableSizeOptions) String() string

+ func (m *GetSchemaTableSizeOptions) Unmarshal(dAtA []byte) error

+ func (m *GetSchemaTableSizeOptions) XXX_DiscardUnknown()

+ func (m *GetSchemaTableSizeOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetSchemaTableSizeOptions) XXX_Merge(src proto.Message)

+ func (m *GetSchemaTableSizeOptions) XXX_Size() int

+ func (m *GetSchemaTableSizeOptions) XXX_Unmarshal(b []byte) error

+ type GetSchemasRequest struct

+ ClusterIds []string

+ TableSizeOptions *GetSchemaTableSizeOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetSchemasRequest) Descriptor() ([]byte, []int)

+ func (*GetSchemasRequest) ProtoMessage()

+ func (m *GetSchemasRequest) GetClusterIds() []string

+ func (m *GetSchemasRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

+ func (m *GetSchemasRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetSchemasRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetSchemasRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetSchemasRequest) Reset()

+ func (m *GetSchemasRequest) Size() (n int)

+ func (m *GetSchemasRequest) String() string

+ func (m *GetSchemasRequest) Unmarshal(dAtA []byte) error

+ func (m *GetSchemasRequest) XXX_DiscardUnknown()

+ func (m *GetSchemasRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetSchemasRequest) XXX_Merge(src proto.Message)

+ func (m *GetSchemasRequest) XXX_Size() int

+ func (m *GetSchemasRequest) XXX_Unmarshal(b []byte) error

+ type GetSchemasResponse struct

+ Schemas []*Schema

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetSchemasResponse) Descriptor() ([]byte, []int)

+ func (*GetSchemasResponse) ProtoMessage()

+ func (m *GetSchemasResponse) GetSchemas() []*Schema

+ func (m *GetSchemasResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetSchemasResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetSchemasResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetSchemasResponse) Reset()

+ func (m *GetSchemasResponse) Size() (n int)

+ func (m *GetSchemasResponse) String() string

+ func (m *GetSchemasResponse) Unmarshal(dAtA []byte) error

+ func (m *GetSchemasResponse) XXX_DiscardUnknown()

+ func (m *GetSchemasResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetSchemasResponse) XXX_Merge(src proto.Message)

+ func (m *GetSchemasResponse) XXX_Size() int

+ func (m *GetSchemasResponse) XXX_Unmarshal(b []byte) error

type GetTabletRequest

+ func (m *GetTabletRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetTabletRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetTabletRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetTabletRequest) Size() (n int)

+ func (m *GetTabletRequest) Unmarshal(dAtA []byte) error

type GetTabletsRequest

+ func (m *GetTabletsRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetTabletsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetTabletsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetTabletsRequest) Size() (n int)

+ func (m *GetTabletsRequest) Unmarshal(dAtA []byte) error

type GetTabletsResponse

+ func (m *GetTabletsResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetTabletsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetTabletsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetTabletsResponse) Size() (n int)

+ func (m *GetTabletsResponse) Unmarshal(dAtA []byte) error

+ type GetVSchemaRequest struct

+ ClusterId string

+ Keyspace string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetVSchemaRequest) Descriptor() ([]byte, []int)

+ func (*GetVSchemaRequest) ProtoMessage()

+ func (m *GetVSchemaRequest) GetClusterId() string

+ func (m *GetVSchemaRequest) GetKeyspace() string

+ func (m *GetVSchemaRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetVSchemaRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetVSchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetVSchemaRequest) Reset()

+ func (m *GetVSchemaRequest) Size() (n int)

+ func (m *GetVSchemaRequest) String() string

+ func (m *GetVSchemaRequest) Unmarshal(dAtA []byte) error

+ func (m *GetVSchemaRequest) XXX_DiscardUnknown()

+ func (m *GetVSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetVSchemaRequest) XXX_Merge(src proto.Message)

+ func (m *GetVSchemaRequest) XXX_Size() int

+ func (m *GetVSchemaRequest) XXX_Unmarshal(b []byte) error

+ type GetVSchemasRequest struct

+ ClusterIds []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetVSchemasRequest) Descriptor() ([]byte, []int)

+ func (*GetVSchemasRequest) ProtoMessage()

+ func (m *GetVSchemasRequest) GetClusterIds() []string

+ func (m *GetVSchemasRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetVSchemasRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetVSchemasRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetVSchemasRequest) Reset()

+ func (m *GetVSchemasRequest) Size() (n int)

+ func (m *GetVSchemasRequest) String() string

+ func (m *GetVSchemasRequest) Unmarshal(dAtA []byte) error

+ func (m *GetVSchemasRequest) XXX_DiscardUnknown()

+ func (m *GetVSchemasRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetVSchemasRequest) XXX_Merge(src proto.Message)

+ func (m *GetVSchemasRequest) XXX_Size() int

+ func (m *GetVSchemasRequest) XXX_Unmarshal(b []byte) error

+ type GetVSchemasResponse struct

+ VSchemas []*VSchema

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetVSchemasResponse) Descriptor() ([]byte, []int)

+ func (*GetVSchemasResponse) ProtoMessage()

+ func (m *GetVSchemasResponse) GetVSchemas() []*VSchema

+ func (m *GetVSchemasResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetVSchemasResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetVSchemasResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetVSchemasResponse) Reset()

+ func (m *GetVSchemasResponse) Size() (n int)

+ func (m *GetVSchemasResponse) String() string

+ func (m *GetVSchemasResponse) Unmarshal(dAtA []byte) error

+ func (m *GetVSchemasResponse) XXX_DiscardUnknown()

+ func (m *GetVSchemasResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetVSchemasResponse) XXX_Merge(src proto.Message)

+ func (m *GetVSchemasResponse) XXX_Size() int

+ func (m *GetVSchemasResponse) XXX_Unmarshal(b []byte) error

+ type GetWorkflowRequest struct

+ ActiveOnly bool

+ ClusterId string

+ Keyspace string

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*GetWorkflowRequest) ProtoMessage()

+ func (m *GetWorkflowRequest) GetActiveOnly() bool

+ func (m *GetWorkflowRequest) GetClusterId() string

+ func (m *GetWorkflowRequest) GetKeyspace() string

+ func (m *GetWorkflowRequest) GetName() string

+ func (m *GetWorkflowRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetWorkflowRequest) Reset()

+ func (m *GetWorkflowRequest) Size() (n int)

+ func (m *GetWorkflowRequest) String() string

+ func (m *GetWorkflowRequest) Unmarshal(dAtA []byte) error

+ func (m *GetWorkflowRequest) XXX_DiscardUnknown()

+ func (m *GetWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetWorkflowRequest) XXX_Merge(src proto.Message)

+ func (m *GetWorkflowRequest) XXX_Size() int

+ func (m *GetWorkflowRequest) XXX_Unmarshal(b []byte) error

+ type GetWorkflowsRequest struct

+ ActiveOnly bool

+ ClusterIds []string

+ IgnoreKeyspaces []string

+ Keyspaces []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetWorkflowsRequest) Descriptor() ([]byte, []int)

+ func (*GetWorkflowsRequest) ProtoMessage()

+ func (m *GetWorkflowsRequest) GetActiveOnly() bool

+ func (m *GetWorkflowsRequest) GetClusterIds() []string

+ func (m *GetWorkflowsRequest) GetIgnoreKeyspaces() []string

+ func (m *GetWorkflowsRequest) GetKeyspaces() []string

+ func (m *GetWorkflowsRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetWorkflowsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetWorkflowsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetWorkflowsRequest) Reset()

+ func (m *GetWorkflowsRequest) Size() (n int)

+ func (m *GetWorkflowsRequest) String() string

+ func (m *GetWorkflowsRequest) Unmarshal(dAtA []byte) error

+ func (m *GetWorkflowsRequest) XXX_DiscardUnknown()

+ func (m *GetWorkflowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetWorkflowsRequest) XXX_Merge(src proto.Message)

+ func (m *GetWorkflowsRequest) XXX_Size() int

+ func (m *GetWorkflowsRequest) XXX_Unmarshal(b []byte) error

+ type GetWorkflowsResponse struct

+ WorkflowsByCluster map[string]*ClusterWorkflows

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetWorkflowsResponse) Descriptor() ([]byte, []int)

+ func (*GetWorkflowsResponse) ProtoMessage()

+ func (m *GetWorkflowsResponse) GetWorkflowsByCluster() map[string]*ClusterWorkflows

+ func (m *GetWorkflowsResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetWorkflowsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetWorkflowsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetWorkflowsResponse) Reset()

+ func (m *GetWorkflowsResponse) Size() (n int)

+ func (m *GetWorkflowsResponse) String() string

+ func (m *GetWorkflowsResponse) Unmarshal(dAtA []byte) error

+ func (m *GetWorkflowsResponse) XXX_DiscardUnknown()

+ func (m *GetWorkflowsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetWorkflowsResponse) XXX_Merge(src proto.Message)

+ func (m *GetWorkflowsResponse) XXX_Size() int

+ func (m *GetWorkflowsResponse) XXX_Unmarshal(b []byte) error

+ type Keyspace struct

+ Cluster *Cluster

+ Keyspace *vtctldata.Keyspace

+ Shards map[string]*vtctldata.Shard

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Keyspace) Descriptor() ([]byte, []int)

+ func (*Keyspace) ProtoMessage()

+ func (m *Keyspace) GetCluster() *Cluster

+ func (m *Keyspace) GetKeyspace() *vtctldata.Keyspace

+ func (m *Keyspace) GetShards() map[string]*vtctldata.Shard

+ func (m *Keyspace) Marshal() (dAtA []byte, err error)

+ func (m *Keyspace) MarshalTo(dAtA []byte) (int, error)

+ func (m *Keyspace) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Keyspace) Reset()

+ func (m *Keyspace) Size() (n int)

+ func (m *Keyspace) String() string

+ func (m *Keyspace) Unmarshal(dAtA []byte) error

+ func (m *Keyspace) XXX_DiscardUnknown()

+ func (m *Keyspace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Keyspace) XXX_Merge(src proto.Message)

+ func (m *Keyspace) XXX_Size() int

+ func (m *Keyspace) XXX_Unmarshal(b []byte) error

+ type Schema struct

+ Cluster *Cluster

+ Keyspace string

+ TableDefinitions []*tabletmanagerdata.TableDefinition

+ TableSizes map[string]*Schema_TableSize

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Schema) Descriptor() ([]byte, []int)

+ func (*Schema) ProtoMessage()

+ func (m *Schema) GetCluster() *Cluster

+ func (m *Schema) GetKeyspace() string

+ func (m *Schema) GetTableDefinitions() []*tabletmanagerdata.TableDefinition

+ func (m *Schema) GetTableSizes() map[string]*Schema_TableSize

+ func (m *Schema) Marshal() (dAtA []byte, err error)

+ func (m *Schema) MarshalTo(dAtA []byte) (int, error)

+ func (m *Schema) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Schema) Reset()

+ func (m *Schema) Size() (n int)

+ func (m *Schema) String() string

+ func (m *Schema) Unmarshal(dAtA []byte) error

+ func (m *Schema) XXX_DiscardUnknown()

+ func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Schema) XXX_Merge(src proto.Message)

+ func (m *Schema) XXX_Size() int

+ func (m *Schema) XXX_Unmarshal(b []byte) error

+ type Schema_ShardTableSize struct

+ DataLength uint64

+ RowCount uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Schema_ShardTableSize) Descriptor() ([]byte, []int)

+ func (*Schema_ShardTableSize) ProtoMessage()

+ func (m *Schema_ShardTableSize) GetDataLength() uint64

+ func (m *Schema_ShardTableSize) GetRowCount() uint64

+ func (m *Schema_ShardTableSize) Marshal() (dAtA []byte, err error)

+ func (m *Schema_ShardTableSize) MarshalTo(dAtA []byte) (int, error)

+ func (m *Schema_ShardTableSize) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Schema_ShardTableSize) Reset()

+ func (m *Schema_ShardTableSize) Size() (n int)

+ func (m *Schema_ShardTableSize) String() string

+ func (m *Schema_ShardTableSize) Unmarshal(dAtA []byte) error

+ func (m *Schema_ShardTableSize) XXX_DiscardUnknown()

+ func (m *Schema_ShardTableSize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Schema_ShardTableSize) XXX_Merge(src proto.Message)

+ func (m *Schema_ShardTableSize) XXX_Size() int

+ func (m *Schema_ShardTableSize) XXX_Unmarshal(b []byte) error

+ type Schema_TableSize struct

+ ByShard map[string]*Schema_ShardTableSize

+ DataLength uint64

+ RowCount uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Schema_TableSize) Descriptor() ([]byte, []int)

+ func (*Schema_TableSize) ProtoMessage()

+ func (m *Schema_TableSize) GetByShard() map[string]*Schema_ShardTableSize

+ func (m *Schema_TableSize) GetDataLength() uint64

+ func (m *Schema_TableSize) GetRowCount() uint64

+ func (m *Schema_TableSize) Marshal() (dAtA []byte, err error)

+ func (m *Schema_TableSize) MarshalTo(dAtA []byte) (int, error)

+ func (m *Schema_TableSize) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Schema_TableSize) Reset()

+ func (m *Schema_TableSize) Size() (n int)

+ func (m *Schema_TableSize) String() string

+ func (m *Schema_TableSize) Unmarshal(dAtA []byte) error

+ func (m *Schema_TableSize) XXX_DiscardUnknown()

+ func (m *Schema_TableSize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Schema_TableSize) XXX_Merge(src proto.Message)

+ func (m *Schema_TableSize) XXX_Size() int

+ func (m *Schema_TableSize) XXX_Unmarshal(b []byte) error

type Tablet

+ func (m *Tablet) Marshal() (dAtA []byte, err error)

+ func (m *Tablet) MarshalTo(dAtA []byte) (int, error)

+ func (m *Tablet) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Tablet) Size() (n int)

+ func (m *Tablet) Unmarshal(dAtA []byte) error

type UnimplementedVTAdminServer

+ func (*UnimplementedVTAdminServer) FindSchema(ctx context.Context, req *FindSchemaRequest) (*Schema, error)

+ func (*UnimplementedVTAdminServer) GetClusters(ctx context.Context, req *GetClustersRequest) (*GetClustersResponse, error)

+ func (*UnimplementedVTAdminServer) GetKeyspaces(ctx context.Context, req *GetKeyspacesRequest) (*GetKeyspacesResponse, error)

+ func (*UnimplementedVTAdminServer) GetSchema(ctx context.Context, req *GetSchemaRequest) (*Schema, error)

+ func (*UnimplementedVTAdminServer) GetSchemas(ctx context.Context, req *GetSchemasRequest) (*GetSchemasResponse, error)

+ func (*UnimplementedVTAdminServer) GetVSchema(ctx context.Context, req *GetVSchemaRequest) (*VSchema, error)

+ func (*UnimplementedVTAdminServer) GetVSchemas(ctx context.Context, req *GetVSchemasRequest) (*GetVSchemasResponse, error)

+ func (*UnimplementedVTAdminServer) GetWorkflow(ctx context.Context, req *GetWorkflowRequest) (*Workflow, error)

+ func (*UnimplementedVTAdminServer) GetWorkflows(ctx context.Context, req *GetWorkflowsRequest) (*GetWorkflowsResponse, error)

+ func (*UnimplementedVTAdminServer) VTExplain(ctx context.Context, req *VTExplainRequest) (*VTExplainResponse, error)

+ type VSchema struct

+ Cluster *Cluster

+ Name string

+ VSchema *vschema.Keyspace

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*VSchema) Descriptor() ([]byte, []int)

+ func (*VSchema) ProtoMessage()

+ func (m *VSchema) GetCluster() *Cluster

+ func (m *VSchema) GetName() string

+ func (m *VSchema) GetVSchema() *vschema.Keyspace

+ func (m *VSchema) Marshal() (dAtA []byte, err error)

+ func (m *VSchema) MarshalTo(dAtA []byte) (int, error)

+ func (m *VSchema) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VSchema) Reset()

+ func (m *VSchema) Size() (n int)

+ func (m *VSchema) String() string

+ func (m *VSchema) Unmarshal(dAtA []byte) error

+ func (m *VSchema) XXX_DiscardUnknown()

+ func (m *VSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VSchema) XXX_Merge(src proto.Message)

+ func (m *VSchema) XXX_Size() int

+ func (m *VSchema) XXX_Unmarshal(b []byte) error

type VTAdminClient

+ FindSchema func(ctx context.Context, in *FindSchemaRequest, opts ...grpc.CallOption) (*Schema, error)

+ GetClusters func(ctx context.Context, in *GetClustersRequest, opts ...grpc.CallOption) (*GetClustersResponse, error)

+ GetKeyspaces func(ctx context.Context, in *GetKeyspacesRequest, opts ...grpc.CallOption) (*GetKeyspacesResponse, error)

+ GetSchema func(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*Schema, error)

+ GetSchemas func(ctx context.Context, in *GetSchemasRequest, opts ...grpc.CallOption) (*GetSchemasResponse, error)

+ GetVSchema func(ctx context.Context, in *GetVSchemaRequest, opts ...grpc.CallOption) (*VSchema, error)

+ GetVSchemas func(ctx context.Context, in *GetVSchemasRequest, opts ...grpc.CallOption) (*GetVSchemasResponse, error)

+ GetWorkflow func(ctx context.Context, in *GetWorkflowRequest, opts ...grpc.CallOption) (*Workflow, error)

+ GetWorkflows func(ctx context.Context, in *GetWorkflowsRequest, opts ...grpc.CallOption) (*GetWorkflowsResponse, error)

+ VTExplain func(ctx context.Context, in *VTExplainRequest, opts ...grpc.CallOption) (*VTExplainResponse, error)

type VTAdminServer

+ FindSchema func(context.Context, *FindSchemaRequest) (*Schema, error)

+ GetClusters func(context.Context, *GetClustersRequest) (*GetClustersResponse, error)

+ GetKeyspaces func(context.Context, *GetKeyspacesRequest) (*GetKeyspacesResponse, error)

+ GetSchema func(context.Context, *GetSchemaRequest) (*Schema, error)

+ GetSchemas func(context.Context, *GetSchemasRequest) (*GetSchemasResponse, error)

+ GetVSchema func(context.Context, *GetVSchemaRequest) (*VSchema, error)

+ GetVSchemas func(context.Context, *GetVSchemasRequest) (*GetVSchemasResponse, error)

+ GetWorkflow func(context.Context, *GetWorkflowRequest) (*Workflow, error)

+ GetWorkflows func(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error)

+ VTExplain func(context.Context, *VTExplainRequest) (*VTExplainResponse, error)

+ type VTExplainRequest struct

+ Cluster string

+ Keyspace string

+ Sql string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*VTExplainRequest) Descriptor() ([]byte, []int)

+ func (*VTExplainRequest) ProtoMessage()

+ func (m *VTExplainRequest) GetCluster() string

+ func (m *VTExplainRequest) GetKeyspace() string

+ func (m *VTExplainRequest) GetSql() string

+ func (m *VTExplainRequest) Marshal() (dAtA []byte, err error)

+ func (m *VTExplainRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *VTExplainRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VTExplainRequest) Reset()

+ func (m *VTExplainRequest) Size() (n int)

+ func (m *VTExplainRequest) String() string

+ func (m *VTExplainRequest) Unmarshal(dAtA []byte) error

+ func (m *VTExplainRequest) XXX_DiscardUnknown()

+ func (m *VTExplainRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VTExplainRequest) XXX_Merge(src proto.Message)

+ func (m *VTExplainRequest) XXX_Size() int

+ func (m *VTExplainRequest) XXX_Unmarshal(b []byte) error

+ type VTExplainResponse struct

+ Response string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*VTExplainResponse) Descriptor() ([]byte, []int)

+ func (*VTExplainResponse) ProtoMessage()

+ func (m *VTExplainResponse) GetResponse() string

+ func (m *VTExplainResponse) Marshal() (dAtA []byte, err error)

+ func (m *VTExplainResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *VTExplainResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VTExplainResponse) Reset()

+ func (m *VTExplainResponse) Size() (n int)

+ func (m *VTExplainResponse) String() string

+ func (m *VTExplainResponse) Unmarshal(dAtA []byte) error

+ func (m *VTExplainResponse) XXX_DiscardUnknown()

+ func (m *VTExplainResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VTExplainResponse) XXX_Merge(src proto.Message)

+ func (m *VTExplainResponse) XXX_Size() int

+ func (m *VTExplainResponse) XXX_Unmarshal(b []byte) error

type VTGate

+ func (m *VTGate) Marshal() (dAtA []byte, err error)

+ func (m *VTGate) MarshalTo(dAtA []byte) (int, error)

+ func (m *VTGate) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VTGate) Size() (n int)

+ func (m *VTGate) Unmarshal(dAtA []byte) error

+ type Vtctld struct

+ Cluster *Cluster

+ Hostname string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Vtctld) Descriptor() ([]byte, []int)

+ func (*Vtctld) ProtoMessage()

+ func (m *Vtctld) GetCluster() *Cluster

+ func (m *Vtctld) GetHostname() string

+ func (m *Vtctld) Marshal() (dAtA []byte, err error)

+ func (m *Vtctld) MarshalTo(dAtA []byte) (int, error)

+ func (m *Vtctld) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Vtctld) Reset()

+ func (m *Vtctld) Size() (n int)

+ func (m *Vtctld) String() string

+ func (m *Vtctld) Unmarshal(dAtA []byte) error

+ func (m *Vtctld) XXX_DiscardUnknown()

+ func (m *Vtctld) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Vtctld) XXX_Merge(src proto.Message)

+ func (m *Vtctld) XXX_Size() int

+ func (m *Vtctld) XXX_Unmarshal(b []byte) error

+ type Workflow struct

+ Cluster *Cluster

+ Keyspace string

+ Workflow *vtctldata.Workflow

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Workflow) Descriptor() ([]byte, []int)

+ func (*Workflow) ProtoMessage()

+ func (m *Workflow) GetCluster() *Cluster

+ func (m *Workflow) GetKeyspace() string

+ func (m *Workflow) GetWorkflow() *vtctldata.Workflow

+ func (m *Workflow) Marshal() (dAtA []byte, err error)

+ func (m *Workflow) MarshalTo(dAtA []byte) (int, error)

+ func (m *Workflow) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Workflow) Reset()

+ func (m *Workflow) Size() (n int)

+ func (m *Workflow) String() string

+ func (m *Workflow) Unmarshal(dAtA []byte) error

+ func (m *Workflow) XXX_DiscardUnknown()

+ func (m *Workflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Workflow) XXX_Merge(src proto.Message)

+ func (m *Workflow) XXX_Size() int

+ func (m *Workflow) XXX_Unmarshal(b []byte) error

May 25, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

May 6, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Jan 25, 2021 GO-2023-1717 +1 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ var Tablet_ServingState_name = map[int32]string

+ var Tablet_ServingState_value = map[string]int32

+ func RegisterVTAdminServer(s *grpc.Server, srv VTAdminServer)

+ type Cluster struct

+ Id string

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster) Descriptor() ([]byte, []int)

+ func (*Cluster) ProtoMessage()

+ func (m *Cluster) GetId() string

+ func (m *Cluster) GetName() string

+ func (m *Cluster) Reset()

+ func (m *Cluster) String() string

+ func (m *Cluster) XXX_DiscardUnknown()

+ func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster) XXX_Merge(src proto.Message)

+ func (m *Cluster) XXX_Size() int

+ func (m *Cluster) XXX_Unmarshal(b []byte) error

+ type GetGatesRequest struct

+ ClusterIds []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetGatesRequest) Descriptor() ([]byte, []int)

+ func (*GetGatesRequest) ProtoMessage()

+ func (m *GetGatesRequest) GetClusterIds() []string

+ func (m *GetGatesRequest) Reset()

+ func (m *GetGatesRequest) String() string

+ func (m *GetGatesRequest) XXX_DiscardUnknown()

+ func (m *GetGatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetGatesRequest) XXX_Merge(src proto.Message)

+ func (m *GetGatesRequest) XXX_Size() int

+ func (m *GetGatesRequest) XXX_Unmarshal(b []byte) error

+ type GetGatesResponse struct

+ Gates []*VTGate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetGatesResponse) Descriptor() ([]byte, []int)

+ func (*GetGatesResponse) ProtoMessage()

+ func (m *GetGatesResponse) GetGates() []*VTGate

+ func (m *GetGatesResponse) Reset()

+ func (m *GetGatesResponse) String() string

+ func (m *GetGatesResponse) XXX_DiscardUnknown()

+ func (m *GetGatesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetGatesResponse) XXX_Merge(src proto.Message)

+ func (m *GetGatesResponse) XXX_Size() int

+ func (m *GetGatesResponse) XXX_Unmarshal(b []byte) error

+ type GetTabletRequest struct

+ ClusterIds []string

+ Hostname string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTabletRequest) Descriptor() ([]byte, []int)

+ func (*GetTabletRequest) ProtoMessage()

+ func (m *GetTabletRequest) GetClusterIds() []string

+ func (m *GetTabletRequest) GetHostname() string

+ func (m *GetTabletRequest) Reset()

+ func (m *GetTabletRequest) String() string

+ func (m *GetTabletRequest) XXX_DiscardUnknown()

+ func (m *GetTabletRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTabletRequest) XXX_Merge(src proto.Message)

+ func (m *GetTabletRequest) XXX_Size() int

+ func (m *GetTabletRequest) XXX_Unmarshal(b []byte) error

+ type GetTabletsRequest struct

+ ClusterIds []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTabletsRequest) Descriptor() ([]byte, []int)

+ func (*GetTabletsRequest) ProtoMessage()

+ func (m *GetTabletsRequest) GetClusterIds() []string

+ func (m *GetTabletsRequest) Reset()

+ func (m *GetTabletsRequest) String() string

+ func (m *GetTabletsRequest) XXX_DiscardUnknown()

+ func (m *GetTabletsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTabletsRequest) XXX_Merge(src proto.Message)

+ func (m *GetTabletsRequest) XXX_Size() int

+ func (m *GetTabletsRequest) XXX_Unmarshal(b []byte) error

+ type GetTabletsResponse struct

+ Tablets []*Tablet

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTabletsResponse) Descriptor() ([]byte, []int)

+ func (*GetTabletsResponse) ProtoMessage()

+ func (m *GetTabletsResponse) GetTablets() []*Tablet

+ func (m *GetTabletsResponse) Reset()

+ func (m *GetTabletsResponse) String() string

+ func (m *GetTabletsResponse) XXX_DiscardUnknown()

+ func (m *GetTabletsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTabletsResponse) XXX_Merge(src proto.Message)

+ func (m *GetTabletsResponse) XXX_Size() int

+ func (m *GetTabletsResponse) XXX_Unmarshal(b []byte) error

+ type Tablet struct

+ Cluster *Cluster

+ State Tablet_ServingState

+ Tablet *topodata.Tablet

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Tablet) Descriptor() ([]byte, []int)

+ func (*Tablet) ProtoMessage()

+ func (m *Tablet) GetCluster() *Cluster

+ func (m *Tablet) GetState() Tablet_ServingState

+ func (m *Tablet) GetTablet() *topodata.Tablet

+ func (m *Tablet) Reset()

+ func (m *Tablet) String() string

+ func (m *Tablet) XXX_DiscardUnknown()

+ func (m *Tablet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Tablet) XXX_Merge(src proto.Message)

+ func (m *Tablet) XXX_Size() int

+ func (m *Tablet) XXX_Unmarshal(b []byte) error

+ type Tablet_ServingState int32

+ const Tablet_NOT_SERVING

+ const Tablet_SERVING

+ const Tablet_UNKNOWN

+ func (Tablet_ServingState) EnumDescriptor() ([]byte, []int)

+ func (x Tablet_ServingState) String() string

+ type UnimplementedVTAdminServer struct

+ func (*UnimplementedVTAdminServer) GetGates(ctx context.Context, req *GetGatesRequest) (*GetGatesResponse, error)

+ func (*UnimplementedVTAdminServer) GetTablet(ctx context.Context, req *GetTabletRequest) (*Tablet, error)

+ func (*UnimplementedVTAdminServer) GetTablets(ctx context.Context, req *GetTabletsRequest) (*GetTabletsResponse, error)

+ type VTAdminClient interface

+ GetGates func(ctx context.Context, in *GetGatesRequest, opts ...grpc.CallOption) (*GetGatesResponse, error)

+ GetTablet func(ctx context.Context, in *GetTabletRequest, opts ...grpc.CallOption) (*Tablet, error)

+ GetTablets func(ctx context.Context, in *GetTabletsRequest, opts ...grpc.CallOption) (*GetTabletsResponse, error)

+ func NewVTAdminClient(cc *grpc.ClientConn) VTAdminClient

+ type VTAdminServer interface

+ GetGates func(context.Context, *GetGatesRequest) (*GetGatesResponse, error)

+ GetTablet func(context.Context, *GetTabletRequest) (*Tablet, error)

+ GetTablets func(context.Context, *GetTabletsRequest) (*GetTabletsResponse, error)

+ type VTGate struct

+ Cell string

+ Cluster *Cluster

+ Hostname string

+ Keyspaces []string

+ Pool string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*VTGate) Descriptor() ([]byte, []int)

+ func (*VTGate) ProtoMessage()

+ func (m *VTGate) GetCell() string

+ func (m *VTGate) GetCluster() *Cluster

+ func (m *VTGate) GetHostname() string

+ func (m *VTGate) GetKeyspaces() []string

+ func (m *VTGate) GetPool() string

+ func (m *VTGate) Reset()

+ func (m *VTGate) String() string

+ func (m *VTGate) XXX_DiscardUnknown()

+ func (m *VTGate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VTGate) XXX_Merge(src proto.Message)

+ func (m *VTGate) XXX_Size() int

+ func (m *VTGate) XXX_Unmarshal(b []byte) error