vtadmin

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Jan 25, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Tablet_ServingState_name = map[int32]string{
	0: "UNKNOWN",
	1: "SERVING",
	2: "NOT_SERVING",
}
View Source 
var Tablet_ServingState_value = map[string]int32{
	"UNKNOWN":     0,
	"SERVING":     1,
	"NOT_SERVING": 2,
}

Functions

func RegisterVTAdminServer 

func RegisterVTAdminServer(s *grpc.Server, srv VTAdminServer)

Types

type Cluster 

type Cluster struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Cluster represents information about a Vitess cluster.

func (*Cluster) Descriptor 

func (*Cluster) Descriptor() ([]byte, []int)

func (*Cluster) GetId 

func (m *Cluster) GetId() string

func (*Cluster) GetName 

func (m *Cluster) GetName() string

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) Reset 

func (m *Cluster) Reset()

func (*Cluster) String 

func (m *Cluster) String() string

func (*Cluster) XXX_DiscardUnknown 

func (m *Cluster) XXX_DiscardUnknown()

func (*Cluster) XXX_Marshal 

func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Cluster) XXX_Merge 

func (m *Cluster) XXX_Merge(src proto.Message)

func (*Cluster) XXX_Size 

func (m *Cluster) XXX_Size() int

func (*Cluster) XXX_Unmarshal 

func (m *Cluster) XXX_Unmarshal(b []byte) error

type GetGatesRequest 

type GetGatesRequest struct {
	ClusterIds           []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetGatesRequest) Descriptor 

func (*GetGatesRequest) Descriptor() ([]byte, []int)

func (*GetGatesRequest) GetClusterIds 

func (m *GetGatesRequest) GetClusterIds() []string

func (*GetGatesRequest) ProtoMessage 

func (*GetGatesRequest) ProtoMessage()

func (*GetGatesRequest) Reset 

func (m *GetGatesRequest) Reset()

func (*GetGatesRequest) String 

func (m *GetGatesRequest) String() string

func (*GetGatesRequest) XXX_DiscardUnknown 

func (m *GetGatesRequest) XXX_DiscardUnknown()

func (*GetGatesRequest) XXX_Marshal 

func (m *GetGatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetGatesRequest) XXX_Merge 

func (m *GetGatesRequest) XXX_Merge(src proto.Message)

func (*GetGatesRequest) XXX_Size 

func (m *GetGatesRequest) XXX_Size() int

func (*GetGatesRequest) XXX_Unmarshal 

func (m *GetGatesRequest) XXX_Unmarshal(b []byte) error

type GetGatesResponse 

type GetGatesResponse struct {
	Gates                []*VTGate `protobuf:"bytes,1,rep,name=gates,proto3" json:"gates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetGatesResponse) Descriptor 

func (*GetGatesResponse) Descriptor() ([]byte, []int)

func (*GetGatesResponse) GetGates 

func (m *GetGatesResponse) GetGates() []*VTGate

func (*GetGatesResponse) ProtoMessage 

func (*GetGatesResponse) ProtoMessage()

func (*GetGatesResponse) Reset 

func (m *GetGatesResponse) Reset()

func (*GetGatesResponse) String 

func (m *GetGatesResponse) String() string

func (*GetGatesResponse) XXX_DiscardUnknown 

func (m *GetGatesResponse) XXX_DiscardUnknown()

func (*GetGatesResponse) XXX_Marshal 

func (m *GetGatesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetGatesResponse) XXX_Merge 

func (m *GetGatesResponse) XXX_Merge(src proto.Message)

func (*GetGatesResponse) XXX_Size 

func (m *GetGatesResponse) XXX_Size() int

func (*GetGatesResponse) XXX_Unmarshal 

func (m *GetGatesResponse) XXX_Unmarshal(b []byte) error

type GetTabletRequest 

type GetTabletRequest struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// ClusterIDs is an optional parameter to narrow the scope of the search, if
	// the caller knows which cluster the tablet may be in, or, to disamiguate if
	// multiple clusters have a tablet with the same hostname.
	ClusterIds           []string `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTabletRequest) Descriptor 

func (*GetTabletRequest) Descriptor() ([]byte, []int)

func (*GetTabletRequest) GetClusterIds 

func (m *GetTabletRequest) GetClusterIds() []string

func (*GetTabletRequest) GetHostname 

func (m *GetTabletRequest) GetHostname() string

func (*GetTabletRequest) ProtoMessage 

func (*GetTabletRequest) ProtoMessage()

func (*GetTabletRequest) Reset 

func (m *GetTabletRequest) Reset()

func (*GetTabletRequest) String 

func (m *GetTabletRequest) String() string

func (*GetTabletRequest) XXX_DiscardUnknown 

func (m *GetTabletRequest) XXX_DiscardUnknown()

func (*GetTabletRequest) XXX_Marshal 

func (m *GetTabletRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTabletRequest) XXX_Merge 

func (m *GetTabletRequest) XXX_Merge(src proto.Message)

func (*GetTabletRequest) XXX_Size 

func (m *GetTabletRequest) XXX_Size() int

func (*GetTabletRequest) XXX_Unmarshal 

func (m *GetTabletRequest) XXX_Unmarshal(b []byte) error

type GetTabletsRequest 

type GetTabletsRequest struct {
	ClusterIds           []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTabletsRequest) Descriptor 

func (*GetTabletsRequest) Descriptor() ([]byte, []int)

func (*GetTabletsRequest) GetClusterIds 

func (m *GetTabletsRequest) GetClusterIds() []string

func (*GetTabletsRequest) ProtoMessage 

func (*GetTabletsRequest) ProtoMessage()

func (*GetTabletsRequest) Reset 

func (m *GetTabletsRequest) Reset()

func (*GetTabletsRequest) String 

func (m *GetTabletsRequest) String() string

func (*GetTabletsRequest) XXX_DiscardUnknown 

func (m *GetTabletsRequest) XXX_DiscardUnknown()

func (*GetTabletsRequest) XXX_Marshal 

func (m *GetTabletsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTabletsRequest) XXX_Merge 

func (m *GetTabletsRequest) XXX_Merge(src proto.Message)

func (*GetTabletsRequest) XXX_Size 

func (m *GetTabletsRequest) XXX_Size() int

func (*GetTabletsRequest) XXX_Unmarshal 

func (m *GetTabletsRequest) XXX_Unmarshal(b []byte) error

type GetTabletsResponse 

type GetTabletsResponse struct {
	Tablets              []*Tablet `protobuf:"bytes,1,rep,name=tablets,proto3" json:"tablets,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetTabletsResponse) Descriptor 

func (*GetTabletsResponse) Descriptor() ([]byte, []int)

func (*GetTabletsResponse) GetTablets 

func (m *GetTabletsResponse) GetTablets() []*Tablet

func (*GetTabletsResponse) ProtoMessage 

func (*GetTabletsResponse) ProtoMessage()

func (*GetTabletsResponse) Reset 

func (m *GetTabletsResponse) Reset()

func (*GetTabletsResponse) String 

func (m *GetTabletsResponse) String() string

func (*GetTabletsResponse) XXX_DiscardUnknown 

func (m *GetTabletsResponse) XXX_DiscardUnknown()

func (*GetTabletsResponse) XXX_Marshal 

func (m *GetTabletsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTabletsResponse) XXX_Merge 

func (m *GetTabletsResponse) XXX_Merge(src proto.Message)

func (*GetTabletsResponse) XXX_Size 

func (m *GetTabletsResponse) XXX_Size() int

func (*GetTabletsResponse) XXX_Unmarshal 

func (m *GetTabletsResponse) XXX_Unmarshal(b []byte) error

type Tablet 

type Tablet struct {
	Cluster              *Cluster            `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Tablet               *topodata.Tablet    `protobuf:"bytes,2,opt,name=tablet,proto3" json:"tablet,omitempty"`
	State                Tablet_ServingState `protobuf:"varint,3,opt,name=state,proto3,enum=vtadmin.Tablet_ServingState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Tablet groups the topo information of a tablet together with the Vitess cluster it belongs to.

func (*Tablet) Descriptor 

func (*Tablet) Descriptor() ([]byte, []int)

func (*Tablet) GetCluster 

func (m *Tablet) GetCluster() *Cluster

func (*Tablet) GetState 

func (m *Tablet) GetState() Tablet_ServingState

func (*Tablet) GetTablet 

func (m *Tablet) GetTablet() *topodata.Tablet

func (*Tablet) ProtoMessage 

func (*Tablet) ProtoMessage()

func (*Tablet) Reset 

func (m *Tablet) Reset()

func (*Tablet) String 

func (m *Tablet) String() string

func (*Tablet) XXX_DiscardUnknown 

func (m *Tablet) XXX_DiscardUnknown()

func (*Tablet) XXX_Marshal 

func (m *Tablet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tablet) XXX_Merge 

func (m *Tablet) XXX_Merge(src proto.Message)

func (*Tablet) XXX_Size 

func (m *Tablet) XXX_Size() int

func (*Tablet) XXX_Unmarshal 

func (m *Tablet) XXX_Unmarshal(b []byte) error

type Tablet_ServingState 

type Tablet_ServingState int32
const (
	Tablet_UNKNOWN     Tablet_ServingState = 0
	Tablet_SERVING     Tablet_ServingState = 1
	Tablet_NOT_SERVING Tablet_ServingState = 2
)

func (Tablet_ServingState) EnumDescriptor 

func (Tablet_ServingState) EnumDescriptor() ([]byte, []int)

func (Tablet_ServingState) String 

func (x Tablet_ServingState) String() string

type UnimplementedVTAdminServer 

type UnimplementedVTAdminServer struct {
}

UnimplementedVTAdminServer can be embedded to have forward compatible implementations.

func (*UnimplementedVTAdminServer) GetGates 

func (*UnimplementedVTAdminServer) GetGates(ctx context.Context, req *GetGatesRequest) (*GetGatesResponse, error)

func (*UnimplementedVTAdminServer) GetTablet 

func (*UnimplementedVTAdminServer) GetTablet(ctx context.Context, req *GetTabletRequest) (*Tablet, error)

func (*UnimplementedVTAdminServer) GetTablets 

func (*UnimplementedVTAdminServer) GetTablets(ctx context.Context, req *GetTabletsRequest) (*GetTabletsResponse, error)

type VTAdminClient 

type VTAdminClient interface {
	// GetGates returns all gates across all the specified clusters.
	GetGates(ctx context.Context, in *GetGatesRequest, opts ...grpc.CallOption) (*GetGatesResponse, error)
	// GetTablet looks up a tablet by hostname across all clusters and returns
	// the result.
	GetTablet(ctx context.Context, in *GetTabletRequest, opts ...grpc.CallOption) (*Tablet, error)
	// GetTablets returns all tablets across all the specified clusters.
	GetTablets(ctx context.Context, in *GetTabletsRequest, opts ...grpc.CallOption) (*GetTabletsResponse, error)
}

VTAdminClient is the client API for VTAdmin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewVTAdminClient 

func NewVTAdminClient(cc *grpc.ClientConn) VTAdminClient

type VTAdminServer 

type VTAdminServer interface {
	// GetGates returns all gates across all the specified clusters.
	GetGates(context.Context, *GetGatesRequest) (*GetGatesResponse, error)
	// GetTablet looks up a tablet by hostname across all clusters and returns
	// the result.
	GetTablet(context.Context, *GetTabletRequest) (*Tablet, error)
	// GetTablets returns all tablets across all the specified clusters.
	GetTablets(context.Context, *GetTabletsRequest) (*GetTabletsResponse, error)
}

VTAdminServer is the server API for VTAdmin service.

type VTGate 

type VTGate struct {
	// Hostname is the shortname of the VTGate.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Pool is group the VTGate serves queries for. Some deployments segment
	// VTGates into groups or pools, based on the workloads they serve queries
	// for. Use of this field is optional.
	Pool string `protobuf:"bytes,2,opt,name=pool,proto3" json:"pool,omitempty"`
	// Cell is the topology cell the VTGate is in.
	Cell string `protobuf:"bytes,3,opt,name=cell,proto3" json:"cell,omitempty"`
	// Cluster is the cluster the VTGate serves.
	Cluster *Cluster `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Keyspaces is the list of keyspaces-to-watch for the VTGate.
	Keyspaces            []string `protobuf:"bytes,5,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

VTGate represents information about a single VTGate host.

func (*VTGate) Descriptor 

func (*VTGate) Descriptor() ([]byte, []int)

func (*VTGate) GetCell 

func (m *VTGate) GetCell() string

func (*VTGate) GetCluster 

func (m *VTGate) GetCluster() *Cluster

func (*VTGate) GetHostname 

func (m *VTGate) GetHostname() string

func (*VTGate) GetKeyspaces 

func (m *VTGate) GetKeyspaces() []string

func (*VTGate) GetPool 

func (m *VTGate) GetPool() string

func (*VTGate) ProtoMessage 

func (*VTGate) ProtoMessage()

func (*VTGate) Reset 

func (m *VTGate) Reset()

func (*VTGate) String 

func (m *VTGate) String() string

func (*VTGate) XXX_DiscardUnknown 

func (m *VTGate) XXX_DiscardUnknown()

func (*VTGate) XXX_Marshal 

func (m *VTGate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VTGate) XXX_Merge 

func (m *VTGate) XXX_Merge(src proto.Message)

func (*VTGate) XXX_Size 

func (m *VTGate) XXX_Size() int

func (*VTGate) XXX_Unmarshal 

func (m *VTGate) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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