vtadmin

package
v0.10.4 Latest Latest
Warning

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

 Go to latest Published: Dec 17, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthVtadmin        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowVtadmin          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupVtadmin = fmt.Errorf("proto: unexpected end of group")
)
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) Marshal added in v0.10.0 

func (m *Cluster) Marshal() (dAtA []byte, err error)

func (*Cluster) MarshalTo added in v0.10.0 

func (m *Cluster) MarshalTo(dAtA []byte) (int, error)

func (*Cluster) MarshalToSizedBuffer added in v0.10.0 

func (m *Cluster) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) Reset 

func (m *Cluster) Reset()

func (*Cluster) Size added in v0.10.0 

func (m *Cluster) Size() (n int)

func (*Cluster) String 

func (m *Cluster) String() string

func (*Cluster) Unmarshal added in v0.10.0 

func (m *Cluster) Unmarshal(dAtA []byte) error

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 ClusterWorkflows added in v0.10.0 

type ClusterWorkflows struct {
	Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// Warnings is a list of non-fatal errors encountered when fetching
	// workflows for a particular cluster.
	Warnings             []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClusterWorkflows) Descriptor added in v0.10.0 

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

func (*ClusterWorkflows) GetWarnings added in v0.10.0 

func (m *ClusterWorkflows) GetWarnings() []string

func (*ClusterWorkflows) GetWorkflows added in v0.10.0 

func (m *ClusterWorkflows) GetWorkflows() []*Workflow

func (*ClusterWorkflows) Marshal added in v0.10.0 

func (m *ClusterWorkflows) Marshal() (dAtA []byte, err error)

func (*ClusterWorkflows) MarshalTo added in v0.10.0 

func (m *ClusterWorkflows) MarshalTo(dAtA []byte) (int, error)

func (*ClusterWorkflows) MarshalToSizedBuffer added in v0.10.0 

func (m *ClusterWorkflows) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClusterWorkflows) ProtoMessage added in v0.10.0 

func (*ClusterWorkflows) ProtoMessage()

func (*ClusterWorkflows) Reset added in v0.10.0 

func (m *ClusterWorkflows) Reset()

func (*ClusterWorkflows) Size added in v0.10.0 

func (m *ClusterWorkflows) Size() (n int)

func (*ClusterWorkflows) String added in v0.10.0 

func (m *ClusterWorkflows) String() string

func (*ClusterWorkflows) Unmarshal added in v0.10.0 

func (m *ClusterWorkflows) Unmarshal(dAtA []byte) error

func (*ClusterWorkflows) XXX_DiscardUnknown added in v0.10.0 

func (m *ClusterWorkflows) XXX_DiscardUnknown()

func (*ClusterWorkflows) XXX_Marshal added in v0.10.0 

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

func (*ClusterWorkflows) XXX_Merge added in v0.10.0 

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

func (*ClusterWorkflows) XXX_Size added in v0.10.0 

func (m *ClusterWorkflows) XXX_Size() int

func (*ClusterWorkflows) XXX_Unmarshal added in v0.10.0 

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

type FindSchemaRequest added in v0.10.0 

type FindSchemaRequest struct {
	Table                string                     `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	ClusterIds           []string                   `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	TableSizeOptions     *GetSchemaTableSizeOptions `protobuf:"bytes,3,opt,name=table_size_options,json=tableSizeOptions,proto3" json:"table_size_options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*FindSchemaRequest) Descriptor added in v0.10.0 

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

func (*FindSchemaRequest) GetClusterIds added in v0.10.0 

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

func (*FindSchemaRequest) GetTable added in v0.10.0 

func (m *FindSchemaRequest) GetTable() string

func (*FindSchemaRequest) GetTableSizeOptions added in v0.10.0 

func (m *FindSchemaRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

func (*FindSchemaRequest) Marshal added in v0.10.0 

func (m *FindSchemaRequest) Marshal() (dAtA []byte, err error)

func (*FindSchemaRequest) MarshalTo added in v0.10.0 

func (m *FindSchemaRequest) MarshalTo(dAtA []byte) (int, error)

func (*FindSchemaRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *FindSchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FindSchemaRequest) ProtoMessage added in v0.10.0 

func (*FindSchemaRequest) ProtoMessage()

func (*FindSchemaRequest) Reset added in v0.10.0 

func (m *FindSchemaRequest) Reset()

func (*FindSchemaRequest) Size added in v0.10.0 

func (m *FindSchemaRequest) Size() (n int)

func (*FindSchemaRequest) String added in v0.10.0 

func (m *FindSchemaRequest) String() string

func (*FindSchemaRequest) Unmarshal added in v0.10.0 

func (m *FindSchemaRequest) Unmarshal(dAtA []byte) error

func (*FindSchemaRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *FindSchemaRequest) XXX_DiscardUnknown()

func (*FindSchemaRequest) XXX_Marshal added in v0.10.0 

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

func (*FindSchemaRequest) XXX_Merge added in v0.10.0 

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

func (*FindSchemaRequest) XXX_Size added in v0.10.0 

func (m *FindSchemaRequest) XXX_Size() int

func (*FindSchemaRequest) XXX_Unmarshal added in v0.10.0 

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

type GetClustersRequest added in v0.10.0 

type GetClustersRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetClustersRequest) Descriptor added in v0.10.0 

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

func (*GetClustersRequest) Marshal added in v0.10.0 

func (m *GetClustersRequest) Marshal() (dAtA []byte, err error)

func (*GetClustersRequest) MarshalTo added in v0.10.0 

func (m *GetClustersRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetClustersRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *GetClustersRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetClustersRequest) ProtoMessage added in v0.10.0 

func (*GetClustersRequest) ProtoMessage()

func (*GetClustersRequest) Reset added in v0.10.0 

func (m *GetClustersRequest) Reset()

func (*GetClustersRequest) Size added in v0.10.0 

func (m *GetClustersRequest) Size() (n int)

func (*GetClustersRequest) String added in v0.10.0 

func (m *GetClustersRequest) String() string

func (*GetClustersRequest) Unmarshal added in v0.10.0 

func (m *GetClustersRequest) Unmarshal(dAtA []byte) error

func (*GetClustersRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetClustersRequest) XXX_DiscardUnknown()

func (*GetClustersRequest) XXX_Marshal added in v0.10.0 

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

func (*GetClustersRequest) XXX_Merge added in v0.10.0 

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

func (*GetClustersRequest) XXX_Size added in v0.10.0 

func (m *GetClustersRequest) XXX_Size() int

func (*GetClustersRequest) XXX_Unmarshal added in v0.10.0 

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

type GetClustersResponse added in v0.10.0 

type GetClustersResponse struct {
	Clusters             []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetClustersResponse) Descriptor added in v0.10.0 

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

func (*GetClustersResponse) GetClusters added in v0.10.0 

func (m *GetClustersResponse) GetClusters() []*Cluster

func (*GetClustersResponse) Marshal added in v0.10.0 

func (m *GetClustersResponse) Marshal() (dAtA []byte, err error)

func (*GetClustersResponse) MarshalTo added in v0.10.0 

func (m *GetClustersResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetClustersResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *GetClustersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetClustersResponse) ProtoMessage added in v0.10.0 

func (*GetClustersResponse) ProtoMessage()

func (*GetClustersResponse) Reset added in v0.10.0 

func (m *GetClustersResponse) Reset()

func (*GetClustersResponse) Size added in v0.10.0 

func (m *GetClustersResponse) Size() (n int)

func (*GetClustersResponse) String added in v0.10.0 

func (m *GetClustersResponse) String() string

func (*GetClustersResponse) Unmarshal added in v0.10.0 

func (m *GetClustersResponse) Unmarshal(dAtA []byte) error

func (*GetClustersResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetClustersResponse) XXX_DiscardUnknown()

func (*GetClustersResponse) XXX_Marshal added in v0.10.0 

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

func (*GetClustersResponse) XXX_Merge added in v0.10.0 

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

func (*GetClustersResponse) XXX_Size added in v0.10.0 

func (m *GetClustersResponse) XXX_Size() int

func (*GetClustersResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetClustersResponse) 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) Marshal added in v0.10.0 

func (m *GetGatesRequest) Marshal() (dAtA []byte, err error)

func (*GetGatesRequest) MarshalTo added in v0.10.0 

func (m *GetGatesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetGatesRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *GetGatesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetGatesRequest) ProtoMessage 

func (*GetGatesRequest) ProtoMessage()

func (*GetGatesRequest) Reset 

func (m *GetGatesRequest) Reset()

func (*GetGatesRequest) Size added in v0.10.0 

func (m *GetGatesRequest) Size() (n int)

func (*GetGatesRequest) String 

func (m *GetGatesRequest) String() string

func (*GetGatesRequest) Unmarshal added in v0.10.0 

func (m *GetGatesRequest) Unmarshal(dAtA []byte) error

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) Marshal added in v0.10.0 

func (m *GetGatesResponse) Marshal() (dAtA []byte, err error)

func (*GetGatesResponse) MarshalTo added in v0.10.0 

func (m *GetGatesResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetGatesResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *GetGatesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetGatesResponse) ProtoMessage 

func (*GetGatesResponse) ProtoMessage()

func (*GetGatesResponse) Reset 

func (m *GetGatesResponse) Reset()

func (*GetGatesResponse) Size added in v0.10.0 

func (m *GetGatesResponse) Size() (n int)

func (*GetGatesResponse) String 

func (m *GetGatesResponse) String() string

func (*GetGatesResponse) Unmarshal added in v0.10.0 

func (m *GetGatesResponse) Unmarshal(dAtA []byte) error

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 GetKeyspacesRequest added in v0.10.0 

type GetKeyspacesRequest 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 (*GetKeyspacesRequest) Descriptor added in v0.10.0 

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

func (*GetKeyspacesRequest) GetClusterIds added in v0.10.0 

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

func (*GetKeyspacesRequest) Marshal added in v0.10.0 

func (m *GetKeyspacesRequest) Marshal() (dAtA []byte, err error)

func (*GetKeyspacesRequest) MarshalTo added in v0.10.0 

func (m *GetKeyspacesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetKeyspacesRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *GetKeyspacesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetKeyspacesRequest) ProtoMessage added in v0.10.0 

func (*GetKeyspacesRequest) ProtoMessage()

func (*GetKeyspacesRequest) Reset added in v0.10.0 

func (m *GetKeyspacesRequest) Reset()

func (*GetKeyspacesRequest) Size added in v0.10.0 

func (m *GetKeyspacesRequest) Size() (n int)

func (*GetKeyspacesRequest) String added in v0.10.0 

func (m *GetKeyspacesRequest) String() string

func (*GetKeyspacesRequest) Unmarshal added in v0.10.0 

func (m *GetKeyspacesRequest) Unmarshal(dAtA []byte) error

func (*GetKeyspacesRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetKeyspacesRequest) XXX_DiscardUnknown()

func (*GetKeyspacesRequest) XXX_Marshal added in v0.10.0 

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

func (*GetKeyspacesRequest) XXX_Merge added in v0.10.0 

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

func (*GetKeyspacesRequest) XXX_Size added in v0.10.0 

func (m *GetKeyspacesRequest) XXX_Size() int

func (*GetKeyspacesRequest) XXX_Unmarshal added in v0.10.0 

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

type GetKeyspacesResponse added in v0.10.0 

type GetKeyspacesResponse struct {
	Keyspaces            []*Keyspace `protobuf:"bytes,1,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*GetKeyspacesResponse) Descriptor added in v0.10.0 

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

func (*GetKeyspacesResponse) GetKeyspaces added in v0.10.0 

func (m *GetKeyspacesResponse) GetKeyspaces() []*Keyspace

func (*GetKeyspacesResponse) Marshal added in v0.10.0 

func (m *GetKeyspacesResponse) Marshal() (dAtA []byte, err error)

func (*GetKeyspacesResponse) MarshalTo added in v0.10.0 

func (m *GetKeyspacesResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetKeyspacesResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *GetKeyspacesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetKeyspacesResponse) ProtoMessage added in v0.10.0 

func (*GetKeyspacesResponse) ProtoMessage()

func (*GetKeyspacesResponse) Reset added in v0.10.0 

func (m *GetKeyspacesResponse) Reset()

func (*GetKeyspacesResponse) Size added in v0.10.0 

func (m *GetKeyspacesResponse) Size() (n int)

func (*GetKeyspacesResponse) String added in v0.10.0 

func (m *GetKeyspacesResponse) String() string

func (*GetKeyspacesResponse) Unmarshal added in v0.10.0 

func (m *GetKeyspacesResponse) Unmarshal(dAtA []byte) error

func (*GetKeyspacesResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetKeyspacesResponse) XXX_DiscardUnknown()

func (*GetKeyspacesResponse) XXX_Marshal added in v0.10.0 

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

func (*GetKeyspacesResponse) XXX_Merge added in v0.10.0 

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

func (*GetKeyspacesResponse) XXX_Size added in v0.10.0 

func (m *GetKeyspacesResponse) XXX_Size() int

func (*GetKeyspacesResponse) XXX_Unmarshal added in v0.10.0 

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

type GetSchemaRequest added in v0.10.0 

type GetSchemaRequest struct {
	ClusterId            string                     `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace             string                     `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Table                string                     `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	TableSizeOptions     *GetSchemaTableSizeOptions `protobuf:"bytes,4,opt,name=table_size_options,json=tableSizeOptions,proto3" json:"table_size_options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*GetSchemaRequest) Descriptor added in v0.10.0 

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

func (*GetSchemaRequest) GetClusterId added in v0.10.0 

func (m *GetSchemaRequest) GetClusterId() string

func (*GetSchemaRequest) GetKeyspace added in v0.10.0 

func (m *GetSchemaRequest) GetKeyspace() string

func (*GetSchemaRequest) GetTable added in v0.10.0 

func (m *GetSchemaRequest) GetTable() string

func (*GetSchemaRequest) GetTableSizeOptions added in v0.10.0 

func (m *GetSchemaRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

func (*GetSchemaRequest) Marshal added in v0.10.0 

func (m *GetSchemaRequest) Marshal() (dAtA []byte, err error)

func (*GetSchemaRequest) MarshalTo added in v0.10.0 

func (m *GetSchemaRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetSchemaRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *GetSchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetSchemaRequest) ProtoMessage added in v0.10.0 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) Reset added in v0.10.0 

func (m *GetSchemaRequest) Reset()

func (*GetSchemaRequest) Size added in v0.10.0 

func (m *GetSchemaRequest) Size() (n int)

func (*GetSchemaRequest) String added in v0.10.0 

func (m *GetSchemaRequest) String() string

func (*GetSchemaRequest) Unmarshal added in v0.10.0 

func (m *GetSchemaRequest) Unmarshal(dAtA []byte) error

func (*GetSchemaRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetSchemaRequest) XXX_DiscardUnknown()

func (*GetSchemaRequest) XXX_Marshal added in v0.10.0 

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

func (*GetSchemaRequest) XXX_Merge added in v0.10.0 

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

func (*GetSchemaRequest) XXX_Size added in v0.10.0 

func (m *GetSchemaRequest) XXX_Size() int

func (*GetSchemaRequest) XXX_Unmarshal added in v0.10.0 

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

type GetSchemaTableSizeOptions added in v0.10.0 

type GetSchemaTableSizeOptions struct {
	AggregateSizes       bool     `protobuf:"varint,1,opt,name=aggregate_sizes,json=aggregateSizes,proto3" json:"aggregate_sizes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSchemaTableSizeOptions) Descriptor added in v0.10.0 

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

func (*GetSchemaTableSizeOptions) GetAggregateSizes added in v0.10.0 

func (m *GetSchemaTableSizeOptions) GetAggregateSizes() bool

func (*GetSchemaTableSizeOptions) Marshal added in v0.10.0 

func (m *GetSchemaTableSizeOptions) Marshal() (dAtA []byte, err error)

func (*GetSchemaTableSizeOptions) MarshalTo added in v0.10.0 

func (m *GetSchemaTableSizeOptions) MarshalTo(dAtA []byte) (int, error)

func (*GetSchemaTableSizeOptions) MarshalToSizedBuffer added in v0.10.0 

func (m *GetSchemaTableSizeOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetSchemaTableSizeOptions) ProtoMessage added in v0.10.0 

func (*GetSchemaTableSizeOptions) ProtoMessage()

func (*GetSchemaTableSizeOptions) Reset added in v0.10.0 

func (m *GetSchemaTableSizeOptions) Reset()

func (*GetSchemaTableSizeOptions) Size added in v0.10.0 

func (m *GetSchemaTableSizeOptions) Size() (n int)

func (*GetSchemaTableSizeOptions) String added in v0.10.0 

func (m *GetSchemaTableSizeOptions) String() string

func (*GetSchemaTableSizeOptions) Unmarshal added in v0.10.0 

func (m *GetSchemaTableSizeOptions) Unmarshal(dAtA []byte) error

func (*GetSchemaTableSizeOptions) XXX_DiscardUnknown added in v0.10.0 

func (m *GetSchemaTableSizeOptions) XXX_DiscardUnknown()

func (*GetSchemaTableSizeOptions) XXX_Marshal added in v0.10.0 

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

func (*GetSchemaTableSizeOptions) XXX_Merge added in v0.10.0 

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

func (*GetSchemaTableSizeOptions) XXX_Size added in v0.10.0 

func (m *GetSchemaTableSizeOptions) XXX_Size() int

func (*GetSchemaTableSizeOptions) XXX_Unmarshal added in v0.10.0 

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

type GetSchemasRequest added in v0.10.0 

type GetSchemasRequest struct {
	ClusterIds           []string                   `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	TableSizeOptions     *GetSchemaTableSizeOptions `protobuf:"bytes,2,opt,name=table_size_options,json=tableSizeOptions,proto3" json:"table_size_options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*GetSchemasRequest) Descriptor added in v0.10.0 

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

func (*GetSchemasRequest) GetClusterIds added in v0.10.0 

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

func (*GetSchemasRequest) GetTableSizeOptions added in v0.10.0 

func (m *GetSchemasRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

func (*GetSchemasRequest) Marshal added in v0.10.0 

func (m *GetSchemasRequest) Marshal() (dAtA []byte, err error)

func (*GetSchemasRequest) MarshalTo added in v0.10.0 

func (m *GetSchemasRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetSchemasRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *GetSchemasRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetSchemasRequest) ProtoMessage added in v0.10.0 

func (*GetSchemasRequest) ProtoMessage()

func (*GetSchemasRequest) Reset added in v0.10.0 

func (m *GetSchemasRequest) Reset()

func (*GetSchemasRequest) Size added in v0.10.0 

func (m *GetSchemasRequest) Size() (n int)

func (*GetSchemasRequest) String added in v0.10.0 

func (m *GetSchemasRequest) String() string

func (*GetSchemasRequest) Unmarshal added in v0.10.0 

func (m *GetSchemasRequest) Unmarshal(dAtA []byte) error

func (*GetSchemasRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetSchemasRequest) XXX_DiscardUnknown()

func (*GetSchemasRequest) XXX_Marshal added in v0.10.0 

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

func (*GetSchemasRequest) XXX_Merge added in v0.10.0 

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

func (*GetSchemasRequest) XXX_Size added in v0.10.0 

func (m *GetSchemasRequest) XXX_Size() int

func (*GetSchemasRequest) XXX_Unmarshal added in v0.10.0 

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

type GetSchemasResponse added in v0.10.0 

type GetSchemasResponse struct {
	Schemas              []*Schema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetSchemasResponse) Descriptor added in v0.10.0 

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

func (*GetSchemasResponse) GetSchemas added in v0.10.0 

func (m *GetSchemasResponse) GetSchemas() []*Schema

func (*GetSchemasResponse) Marshal added in v0.10.0 

func (m *GetSchemasResponse) Marshal() (dAtA []byte, err error)

func (*GetSchemasResponse) MarshalTo added in v0.10.0 

func (m *GetSchemasResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetSchemasResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *GetSchemasResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetSchemasResponse) ProtoMessage added in v0.10.0 

func (*GetSchemasResponse) ProtoMessage()

func (*GetSchemasResponse) Reset added in v0.10.0 

func (m *GetSchemasResponse) Reset()

func (*GetSchemasResponse) Size added in v0.10.0 

func (m *GetSchemasResponse) Size() (n int)

func (*GetSchemasResponse) String added in v0.10.0 

func (m *GetSchemasResponse) String() string

func (*GetSchemasResponse) Unmarshal added in v0.10.0 

func (m *GetSchemasResponse) Unmarshal(dAtA []byte) error

func (*GetSchemasResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetSchemasResponse) XXX_DiscardUnknown()

func (*GetSchemasResponse) XXX_Marshal added in v0.10.0 

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

func (*GetSchemasResponse) XXX_Merge added in v0.10.0 

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

func (*GetSchemasResponse) XXX_Size added in v0.10.0 

func (m *GetSchemasResponse) XXX_Size() int

func (*GetSchemasResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetSchemasResponse) 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) Marshal added in v0.10.0 

func (m *GetTabletRequest) Marshal() (dAtA []byte, err error)

func (*GetTabletRequest) MarshalTo added in v0.10.0 

func (m *GetTabletRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetTabletRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *GetTabletRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetTabletRequest) ProtoMessage 

func (*GetTabletRequest) ProtoMessage()

func (*GetTabletRequest) Reset 

func (m *GetTabletRequest) Reset()

func (*GetTabletRequest) Size added in v0.10.0 

func (m *GetTabletRequest) Size() (n int)

func (*GetTabletRequest) String 

func (m *GetTabletRequest) String() string

func (*GetTabletRequest) Unmarshal added in v0.10.0 

func (m *GetTabletRequest) Unmarshal(dAtA []byte) error

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) Marshal added in v0.10.0 

func (m *GetTabletsRequest) Marshal() (dAtA []byte, err error)

func (*GetTabletsRequest) MarshalTo added in v0.10.0 

func (m *GetTabletsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetTabletsRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *GetTabletsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetTabletsRequest) ProtoMessage 

func (*GetTabletsRequest) ProtoMessage()

func (*GetTabletsRequest) Reset 

func (m *GetTabletsRequest) Reset()

func (*GetTabletsRequest) Size added in v0.10.0 

func (m *GetTabletsRequest) Size() (n int)

func (*GetTabletsRequest) String 

func (m *GetTabletsRequest) String() string

func (*GetTabletsRequest) Unmarshal added in v0.10.0 

func (m *GetTabletsRequest) Unmarshal(dAtA []byte) error

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) Marshal added in v0.10.0 

func (m *GetTabletsResponse) Marshal() (dAtA []byte, err error)

func (*GetTabletsResponse) MarshalTo added in v0.10.0 

func (m *GetTabletsResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetTabletsResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *GetTabletsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetTabletsResponse) ProtoMessage 

func (*GetTabletsResponse) ProtoMessage()

func (*GetTabletsResponse) Reset 

func (m *GetTabletsResponse) Reset()

func (*GetTabletsResponse) Size added in v0.10.0 

func (m *GetTabletsResponse) Size() (n int)

func (*GetTabletsResponse) String 

func (m *GetTabletsResponse) String() string

func (*GetTabletsResponse) Unmarshal added in v0.10.0 

func (m *GetTabletsResponse) Unmarshal(dAtA []byte) error

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 GetVSchemaRequest added in v0.10.0 

type GetVSchemaRequest struct {
	ClusterId            string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace             string   `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetVSchemaRequest) Descriptor added in v0.10.0 

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

func (*GetVSchemaRequest) GetClusterId added in v0.10.0 

func (m *GetVSchemaRequest) GetClusterId() string

func (*GetVSchemaRequest) GetKeyspace added in v0.10.0 

func (m *GetVSchemaRequest) GetKeyspace() string

func (*GetVSchemaRequest) Marshal added in v0.10.0 

func (m *GetVSchemaRequest) Marshal() (dAtA []byte, err error)

func (*GetVSchemaRequest) MarshalTo added in v0.10.0 

func (m *GetVSchemaRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetVSchemaRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *GetVSchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetVSchemaRequest) ProtoMessage added in v0.10.0 

func (*GetVSchemaRequest) ProtoMessage()

func (*GetVSchemaRequest) Reset added in v0.10.0 

func (m *GetVSchemaRequest) Reset()

func (*GetVSchemaRequest) Size added in v0.10.0 

func (m *GetVSchemaRequest) Size() (n int)

func (*GetVSchemaRequest) String added in v0.10.0 

func (m *GetVSchemaRequest) String() string

func (*GetVSchemaRequest) Unmarshal added in v0.10.0 

func (m *GetVSchemaRequest) Unmarshal(dAtA []byte) error

func (*GetVSchemaRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetVSchemaRequest) XXX_DiscardUnknown()

func (*GetVSchemaRequest) XXX_Marshal added in v0.10.0 

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

func (*GetVSchemaRequest) XXX_Merge added in v0.10.0 

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

func (*GetVSchemaRequest) XXX_Size added in v0.10.0 

func (m *GetVSchemaRequest) XXX_Size() int

func (*GetVSchemaRequest) XXX_Unmarshal added in v0.10.0 

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

type GetVSchemasRequest added in v0.10.0 

type GetVSchemasRequest 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 (*GetVSchemasRequest) Descriptor added in v0.10.0 

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

func (*GetVSchemasRequest) GetClusterIds added in v0.10.0 

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

func (*GetVSchemasRequest) Marshal added in v0.10.0 

func (m *GetVSchemasRequest) Marshal() (dAtA []byte, err error)

func (*GetVSchemasRequest) MarshalTo added in v0.10.0 

func (m *GetVSchemasRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetVSchemasRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *GetVSchemasRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetVSchemasRequest) ProtoMessage added in v0.10.0 

func (*GetVSchemasRequest) ProtoMessage()

func (*GetVSchemasRequest) Reset added in v0.10.0 

func (m *GetVSchemasRequest) Reset()

func (*GetVSchemasRequest) Size added in v0.10.0 

func (m *GetVSchemasRequest) Size() (n int)

func (*GetVSchemasRequest) String added in v0.10.0 

func (m *GetVSchemasRequest) String() string

func (*GetVSchemasRequest) Unmarshal added in v0.10.0 

func (m *GetVSchemasRequest) Unmarshal(dAtA []byte) error

func (*GetVSchemasRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetVSchemasRequest) XXX_DiscardUnknown()

func (*GetVSchemasRequest) XXX_Marshal added in v0.10.0 

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

func (*GetVSchemasRequest) XXX_Merge added in v0.10.0 

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

func (*GetVSchemasRequest) XXX_Size added in v0.10.0 

func (m *GetVSchemasRequest) XXX_Size() int

func (*GetVSchemasRequest) XXX_Unmarshal added in v0.10.0 

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

type GetVSchemasResponse added in v0.10.0 

type GetVSchemasResponse struct {
	VSchemas             []*VSchema `protobuf:"bytes,1,rep,name=v_schemas,json=vSchemas,proto3" json:"v_schemas,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetVSchemasResponse) Descriptor added in v0.10.0 

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

func (*GetVSchemasResponse) GetVSchemas added in v0.10.0 

func (m *GetVSchemasResponse) GetVSchemas() []*VSchema

func (*GetVSchemasResponse) Marshal added in v0.10.0 

func (m *GetVSchemasResponse) Marshal() (dAtA []byte, err error)

func (*GetVSchemasResponse) MarshalTo added in v0.10.0 

func (m *GetVSchemasResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetVSchemasResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *GetVSchemasResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetVSchemasResponse) ProtoMessage added in v0.10.0 

func (*GetVSchemasResponse) ProtoMessage()

func (*GetVSchemasResponse) Reset added in v0.10.0 

func (m *GetVSchemasResponse) Reset()

func (*GetVSchemasResponse) Size added in v0.10.0 

func (m *GetVSchemasResponse) Size() (n int)

func (*GetVSchemasResponse) String added in v0.10.0 

func (m *GetVSchemasResponse) String() string

func (*GetVSchemasResponse) Unmarshal added in v0.10.0 

func (m *GetVSchemasResponse) Unmarshal(dAtA []byte) error

func (*GetVSchemasResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetVSchemasResponse) XXX_DiscardUnknown()

func (*GetVSchemasResponse) XXX_Marshal added in v0.10.0 

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

func (*GetVSchemasResponse) XXX_Merge added in v0.10.0 

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

func (*GetVSchemasResponse) XXX_Size added in v0.10.0 

func (m *GetVSchemasResponse) XXX_Size() int

func (*GetVSchemasResponse) XXX_Unmarshal added in v0.10.0 

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

type GetWorkflowRequest added in v0.10.0 

type GetWorkflowRequest struct {
	ClusterId            string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace             string   `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	ActiveOnly           bool     `protobuf:"varint,4,opt,name=active_only,json=activeOnly,proto3" json:"active_only,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetWorkflowRequest) Descriptor added in v0.10.0 

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

func (*GetWorkflowRequest) GetActiveOnly added in v0.10.0 

func (m *GetWorkflowRequest) GetActiveOnly() bool

func (*GetWorkflowRequest) GetClusterId added in v0.10.0 

func (m *GetWorkflowRequest) GetClusterId() string

func (*GetWorkflowRequest) GetKeyspace added in v0.10.0 

func (m *GetWorkflowRequest) GetKeyspace() string

func (*GetWorkflowRequest) GetName added in v0.10.0 

func (m *GetWorkflowRequest) GetName() string

func (*GetWorkflowRequest) Marshal added in v0.10.0 

func (m *GetWorkflowRequest) Marshal() (dAtA []byte, err error)

func (*GetWorkflowRequest) MarshalTo added in v0.10.0 

func (m *GetWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetWorkflowRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *GetWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetWorkflowRequest) ProtoMessage added in v0.10.0 

func (*GetWorkflowRequest) ProtoMessage()

func (*GetWorkflowRequest) Reset added in v0.10.0 

func (m *GetWorkflowRequest) Reset()

func (*GetWorkflowRequest) Size added in v0.10.0 

func (m *GetWorkflowRequest) Size() (n int)

func (*GetWorkflowRequest) String added in v0.10.0 

func (m *GetWorkflowRequest) String() string

func (*GetWorkflowRequest) Unmarshal added in v0.10.0 

func (m *GetWorkflowRequest) Unmarshal(dAtA []byte) error

func (*GetWorkflowRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetWorkflowRequest) XXX_DiscardUnknown()

func (*GetWorkflowRequest) XXX_Marshal added in v0.10.0 

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

func (*GetWorkflowRequest) XXX_Merge added in v0.10.0 

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

func (*GetWorkflowRequest) XXX_Size added in v0.10.0 

func (m *GetWorkflowRequest) XXX_Size() int

func (*GetWorkflowRequest) XXX_Unmarshal added in v0.10.0 

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

type GetWorkflowsRequest added in v0.10.0 

type GetWorkflowsRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// ActiveOnly specifies whether to return workflows that are currently
	// active (running or paused) instead of all workflows.
	ActiveOnly bool `protobuf:"varint,2,opt,name=active_only,json=activeOnly,proto3" json:"active_only,omitempty"`
	// Keyspaces is a list of keyspaces to restrict the workflow search to. Note
	// that the keyspaces list applies across all cluster IDs in the request.
	//
	// If, for example, you have two clusters, each with a keyspace called "foo"
	// and want the workflows from "foo" in cluster1 but not from cluster2, you
	// must make two requests.
	//
	// Keyspaces and IgnoreKeyspaces are mutually-exclusive, and Keyspaces takes
	// precedence; if Keyspaces is a non-empty list, then IgnoreKeyspaces is
	// ignored completely.
	Keyspaces []string `protobuf:"bytes,3,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	// IgnoreKeyspaces is a list of keyspaces to skip during the workflow
	// search. It has the same semantics as the Keyspaces parameter, so refer to
	// that documentation for more details.
	IgnoreKeyspaces      []string `protobuf:"bytes,4,rep,name=ignore_keyspaces,json=ignoreKeyspaces,proto3" json:"ignore_keyspaces,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetWorkflowsRequest) Descriptor added in v0.10.0 

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

func (*GetWorkflowsRequest) GetActiveOnly added in v0.10.0 

func (m *GetWorkflowsRequest) GetActiveOnly() bool

func (*GetWorkflowsRequest) GetClusterIds added in v0.10.0 

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

func (*GetWorkflowsRequest) GetIgnoreKeyspaces added in v0.10.0 

func (m *GetWorkflowsRequest) GetIgnoreKeyspaces() []string

func (*GetWorkflowsRequest) GetKeyspaces added in v0.10.0 

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

func (*GetWorkflowsRequest) Marshal added in v0.10.0 

func (m *GetWorkflowsRequest) Marshal() (dAtA []byte, err error)

func (*GetWorkflowsRequest) MarshalTo added in v0.10.0 

func (m *GetWorkflowsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetWorkflowsRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *GetWorkflowsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetWorkflowsRequest) ProtoMessage added in v0.10.0 

func (*GetWorkflowsRequest) ProtoMessage()

func (*GetWorkflowsRequest) Reset added in v0.10.0 

func (m *GetWorkflowsRequest) Reset()

func (*GetWorkflowsRequest) Size added in v0.10.0 

func (m *GetWorkflowsRequest) Size() (n int)

func (*GetWorkflowsRequest) String added in v0.10.0 

func (m *GetWorkflowsRequest) String() string

func (*GetWorkflowsRequest) Unmarshal added in v0.10.0 

func (m *GetWorkflowsRequest) Unmarshal(dAtA []byte) error

func (*GetWorkflowsRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetWorkflowsRequest) XXX_DiscardUnknown()

func (*GetWorkflowsRequest) XXX_Marshal added in v0.10.0 

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

func (*GetWorkflowsRequest) XXX_Merge added in v0.10.0 

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

func (*GetWorkflowsRequest) XXX_Size added in v0.10.0 

func (m *GetWorkflowsRequest) XXX_Size() int

func (*GetWorkflowsRequest) XXX_Unmarshal added in v0.10.0 

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

type GetWorkflowsResponse added in v0.10.0 

type GetWorkflowsResponse struct {
	WorkflowsByCluster   map[string]*ClusterWorkflows `` /* 205-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*GetWorkflowsResponse) Descriptor added in v0.10.0 

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

func (*GetWorkflowsResponse) GetWorkflowsByCluster added in v0.10.0 

func (m *GetWorkflowsResponse) GetWorkflowsByCluster() map[string]*ClusterWorkflows

func (*GetWorkflowsResponse) Marshal added in v0.10.0 

func (m *GetWorkflowsResponse) Marshal() (dAtA []byte, err error)

func (*GetWorkflowsResponse) MarshalTo added in v0.10.0 

func (m *GetWorkflowsResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetWorkflowsResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *GetWorkflowsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetWorkflowsResponse) ProtoMessage added in v0.10.0 

func (*GetWorkflowsResponse) ProtoMessage()

func (*GetWorkflowsResponse) Reset added in v0.10.0 

func (m *GetWorkflowsResponse) Reset()

func (*GetWorkflowsResponse) Size added in v0.10.0 

func (m *GetWorkflowsResponse) Size() (n int)

func (*GetWorkflowsResponse) String added in v0.10.0 

func (m *GetWorkflowsResponse) String() string

func (*GetWorkflowsResponse) Unmarshal added in v0.10.0 

func (m *GetWorkflowsResponse) Unmarshal(dAtA []byte) error

func (*GetWorkflowsResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetWorkflowsResponse) XXX_DiscardUnknown()

func (*GetWorkflowsResponse) XXX_Marshal added in v0.10.0 

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

func (*GetWorkflowsResponse) XXX_Merge added in v0.10.0 

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

func (*GetWorkflowsResponse) XXX_Size added in v0.10.0 

func (m *GetWorkflowsResponse) XXX_Size() int

func (*GetWorkflowsResponse) XXX_Unmarshal added in v0.10.0 

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

type Keyspace added in v0.10.0 

type Keyspace struct {
	Cluster              *Cluster                    `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace             *vtctldata.Keyspace         `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shards               map[string]*vtctldata.Shard `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Keyspace represents information about a keyspace in a particular Vitess cluster.

func (*Keyspace) Descriptor added in v0.10.0 

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

func (*Keyspace) GetCluster added in v0.10.0 

func (m *Keyspace) GetCluster() *Cluster

func (*Keyspace) GetKeyspace added in v0.10.0 

func (m *Keyspace) GetKeyspace() *vtctldata.Keyspace

func (*Keyspace) GetShards added in v0.10.0 

func (m *Keyspace) GetShards() map[string]*vtctldata.Shard

func (*Keyspace) Marshal added in v0.10.0 

func (m *Keyspace) Marshal() (dAtA []byte, err error)

func (*Keyspace) MarshalTo added in v0.10.0 

func (m *Keyspace) MarshalTo(dAtA []byte) (int, error)

func (*Keyspace) MarshalToSizedBuffer added in v0.10.0 

func (m *Keyspace) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Keyspace) ProtoMessage added in v0.10.0 

func (*Keyspace) ProtoMessage()

func (*Keyspace) Reset added in v0.10.0 

func (m *Keyspace) Reset()

func (*Keyspace) Size added in v0.10.0 

func (m *Keyspace) Size() (n int)

func (*Keyspace) String added in v0.10.0 

func (m *Keyspace) String() string

func (*Keyspace) Unmarshal added in v0.10.0 

func (m *Keyspace) Unmarshal(dAtA []byte) error

func (*Keyspace) XXX_DiscardUnknown added in v0.10.0 

func (m *Keyspace) XXX_DiscardUnknown()

func (*Keyspace) XXX_Marshal added in v0.10.0 

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

func (*Keyspace) XXX_Merge added in v0.10.0 

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

func (*Keyspace) XXX_Size added in v0.10.0 

func (m *Keyspace) XXX_Size() int

func (*Keyspace) XXX_Unmarshal added in v0.10.0 

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

type Schema added in v0.10.0 

type Schema struct {
	Cluster          *Cluster                             `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace         string                               `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	TableDefinitions []*tabletmanagerdata.TableDefinition `protobuf:"bytes,3,rep,name=table_definitions,json=tableDefinitions,proto3" json:"table_definitions,omitempty"`
	// TableSizes is a mapping of table name to TableSize information.
	TableSizes           map[string]*Schema_TableSize `` /* 179-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*Schema) Descriptor added in v0.10.0 

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

func (*Schema) GetCluster added in v0.10.0 

func (m *Schema) GetCluster() *Cluster

func (*Schema) GetKeyspace added in v0.10.0 

func (m *Schema) GetKeyspace() string

func (*Schema) GetTableDefinitions added in v0.10.0 

func (m *Schema) GetTableDefinitions() []*tabletmanagerdata.TableDefinition

func (*Schema) GetTableSizes added in v0.10.0 

func (m *Schema) GetTableSizes() map[string]*Schema_TableSize

func (*Schema) Marshal added in v0.10.0 

func (m *Schema) Marshal() (dAtA []byte, err error)

func (*Schema) MarshalTo added in v0.10.0 

func (m *Schema) MarshalTo(dAtA []byte) (int, error)

func (*Schema) MarshalToSizedBuffer added in v0.10.0 

func (m *Schema) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Schema) ProtoMessage added in v0.10.0 

func (*Schema) ProtoMessage()

func (*Schema) Reset added in v0.10.0 

func (m *Schema) Reset()

func (*Schema) Size added in v0.10.0 

func (m *Schema) Size() (n int)

func (*Schema) String added in v0.10.0 

func (m *Schema) String() string

func (*Schema) Unmarshal added in v0.10.0 

func (m *Schema) Unmarshal(dAtA []byte) error

func (*Schema) XXX_DiscardUnknown added in v0.10.0 

func (m *Schema) XXX_DiscardUnknown()

func (*Schema) XXX_Marshal added in v0.10.0 

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

func (*Schema) XXX_Merge added in v0.10.0 

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

func (*Schema) XXX_Size added in v0.10.0 

func (m *Schema) XXX_Size() int

func (*Schema) XXX_Unmarshal added in v0.10.0 

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

type Schema_ShardTableSize added in v0.10.0 

type Schema_ShardTableSize struct {
	RowCount             uint64   `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	DataLength           uint64   `protobuf:"varint,2,opt,name=data_length,json=dataLength,proto3" json:"data_length,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Schema_ShardTableSize) Descriptor added in v0.10.0 

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

func (*Schema_ShardTableSize) GetDataLength added in v0.10.0 

func (m *Schema_ShardTableSize) GetDataLength() uint64

func (*Schema_ShardTableSize) GetRowCount added in v0.10.0 

func (m *Schema_ShardTableSize) GetRowCount() uint64

func (*Schema_ShardTableSize) Marshal added in v0.10.0 

func (m *Schema_ShardTableSize) Marshal() (dAtA []byte, err error)

func (*Schema_ShardTableSize) MarshalTo added in v0.10.0 

func (m *Schema_ShardTableSize) MarshalTo(dAtA []byte) (int, error)

func (*Schema_ShardTableSize) MarshalToSizedBuffer added in v0.10.0 

func (m *Schema_ShardTableSize) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Schema_ShardTableSize) ProtoMessage added in v0.10.0 

func (*Schema_ShardTableSize) ProtoMessage()

func (*Schema_ShardTableSize) Reset added in v0.10.0 

func (m *Schema_ShardTableSize) Reset()

func (*Schema_ShardTableSize) Size added in v0.10.0 

func (m *Schema_ShardTableSize) Size() (n int)

func (*Schema_ShardTableSize) String added in v0.10.0 

func (m *Schema_ShardTableSize) String() string

func (*Schema_ShardTableSize) Unmarshal added in v0.10.0 

func (m *Schema_ShardTableSize) Unmarshal(dAtA []byte) error

func (*Schema_ShardTableSize) XXX_DiscardUnknown added in v0.10.0 

func (m *Schema_ShardTableSize) XXX_DiscardUnknown()

func (*Schema_ShardTableSize) XXX_Marshal added in v0.10.0 

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

func (*Schema_ShardTableSize) XXX_Merge added in v0.10.0 

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

func (*Schema_ShardTableSize) XXX_Size added in v0.10.0 

func (m *Schema_ShardTableSize) XXX_Size() int

func (*Schema_ShardTableSize) XXX_Unmarshal added in v0.10.0 

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

type Schema_TableSize added in v0.10.0 

type Schema_TableSize struct {
	RowCount             uint64                            `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	DataLength           uint64                            `protobuf:"varint,2,opt,name=data_length,json=dataLength,proto3" json:"data_length,omitempty"`
	ByShard              map[string]*Schema_ShardTableSize `` /* 170-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

TableSize aggregates table size information across all shards containing in the given keyspace and cluster, as well as per-shard size information.

func (*Schema_TableSize) Descriptor added in v0.10.0 

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

func (*Schema_TableSize) GetByShard added in v0.10.0 

func (m *Schema_TableSize) GetByShard() map[string]*Schema_ShardTableSize

func (*Schema_TableSize) GetDataLength added in v0.10.0 

func (m *Schema_TableSize) GetDataLength() uint64

func (*Schema_TableSize) GetRowCount added in v0.10.0 

func (m *Schema_TableSize) GetRowCount() uint64

func (*Schema_TableSize) Marshal added in v0.10.0 

func (m *Schema_TableSize) Marshal() (dAtA []byte, err error)

func (*Schema_TableSize) MarshalTo added in v0.10.0 

func (m *Schema_TableSize) MarshalTo(dAtA []byte) (int, error)

func (*Schema_TableSize) MarshalToSizedBuffer added in v0.10.0 

func (m *Schema_TableSize) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Schema_TableSize) ProtoMessage added in v0.10.0 

func (*Schema_TableSize) ProtoMessage()

func (*Schema_TableSize) Reset added in v0.10.0 

func (m *Schema_TableSize) Reset()

func (*Schema_TableSize) Size added in v0.10.0 

func (m *Schema_TableSize) Size() (n int)

func (*Schema_TableSize) String added in v0.10.0 

func (m *Schema_TableSize) String() string

func (*Schema_TableSize) Unmarshal added in v0.10.0 

func (m *Schema_TableSize) Unmarshal(dAtA []byte) error

func (*Schema_TableSize) XXX_DiscardUnknown added in v0.10.0 

func (m *Schema_TableSize) XXX_DiscardUnknown()

func (*Schema_TableSize) XXX_Marshal added in v0.10.0 

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

func (*Schema_TableSize) XXX_Merge added in v0.10.0 

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

func (*Schema_TableSize) XXX_Size added in v0.10.0 

func (m *Schema_TableSize) XXX_Size() int

func (*Schema_TableSize) XXX_Unmarshal added in v0.10.0 

func (m *Schema_TableSize) 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) Marshal added in v0.10.0 

func (m *Tablet) Marshal() (dAtA []byte, err error)

func (*Tablet) MarshalTo added in v0.10.0 

func (m *Tablet) MarshalTo(dAtA []byte) (int, error)

func (*Tablet) MarshalToSizedBuffer added in v0.10.0 

func (m *Tablet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Tablet) ProtoMessage 

func (*Tablet) ProtoMessage()

func (*Tablet) Reset 

func (m *Tablet) Reset()

func (*Tablet) Size added in v0.10.0 

func (m *Tablet) Size() (n int)

func (*Tablet) String 

func (m *Tablet) String() string

func (*Tablet) Unmarshal added in v0.10.0 

func (m *Tablet) Unmarshal(dAtA []byte) error

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) FindSchema added in v0.10.0 

func (*UnimplementedVTAdminServer) FindSchema(ctx context.Context, req *FindSchemaRequest) (*Schema, error)

func (*UnimplementedVTAdminServer) GetClusters added in v0.10.0 

func (*UnimplementedVTAdminServer) GetClusters(ctx context.Context, req *GetClustersRequest) (*GetClustersResponse, error)

func (*UnimplementedVTAdminServer) GetGates 

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

func (*UnimplementedVTAdminServer) GetKeyspaces added in v0.10.0 

func (*UnimplementedVTAdminServer) GetKeyspaces(ctx context.Context, req *GetKeyspacesRequest) (*GetKeyspacesResponse, error)

func (*UnimplementedVTAdminServer) GetSchema added in v0.10.0 

func (*UnimplementedVTAdminServer) GetSchema(ctx context.Context, req *GetSchemaRequest) (*Schema, error)

func (*UnimplementedVTAdminServer) GetSchemas added in v0.10.0 

func (*UnimplementedVTAdminServer) GetSchemas(ctx context.Context, req *GetSchemasRequest) (*GetSchemasResponse, 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)

func (*UnimplementedVTAdminServer) GetVSchema added in v0.10.0 

func (*UnimplementedVTAdminServer) GetVSchema(ctx context.Context, req *GetVSchemaRequest) (*VSchema, error)

func (*UnimplementedVTAdminServer) GetVSchemas added in v0.10.0 

func (*UnimplementedVTAdminServer) GetVSchemas(ctx context.Context, req *GetVSchemasRequest) (*GetVSchemasResponse, error)

func (*UnimplementedVTAdminServer) GetWorkflow added in v0.10.0 

func (*UnimplementedVTAdminServer) GetWorkflow(ctx context.Context, req *GetWorkflowRequest) (*Workflow, error)

func (*UnimplementedVTAdminServer) GetWorkflows added in v0.10.0 

func (*UnimplementedVTAdminServer) GetWorkflows(ctx context.Context, req *GetWorkflowsRequest) (*GetWorkflowsResponse, error)

func (*UnimplementedVTAdminServer) VTExplain added in v0.10.0 

func (*UnimplementedVTAdminServer) VTExplain(ctx context.Context, req *VTExplainRequest) (*VTExplainResponse, error)

type VSchema added in v0.10.0 

type VSchema struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Name is the name of the keyspace this VSchema is for.
	Name                 string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	VSchema              *vschema.Keyspace `protobuf:"bytes,3,opt,name=v_schema,json=vSchema,proto3" json:"v_schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

VSchema represents the vschema for a keyspace in the cluster it belongs to.

func (*VSchema) Descriptor added in v0.10.0 

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

func (*VSchema) GetCluster added in v0.10.0 

func (m *VSchema) GetCluster() *Cluster

func (*VSchema) GetName added in v0.10.0 

func (m *VSchema) GetName() string

func (*VSchema) GetVSchema added in v0.10.0 

func (m *VSchema) GetVSchema() *vschema.Keyspace

func (*VSchema) Marshal added in v0.10.0 

func (m *VSchema) Marshal() (dAtA []byte, err error)

func (*VSchema) MarshalTo added in v0.10.0 

func (m *VSchema) MarshalTo(dAtA []byte) (int, error)

func (*VSchema) MarshalToSizedBuffer added in v0.10.0 

func (m *VSchema) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VSchema) ProtoMessage added in v0.10.0 

func (*VSchema) ProtoMessage()

func (*VSchema) Reset added in v0.10.0 

func (m *VSchema) Reset()

func (*VSchema) Size added in v0.10.0 

func (m *VSchema) Size() (n int)

func (*VSchema) String added in v0.10.0 

func (m *VSchema) String() string

func (*VSchema) Unmarshal added in v0.10.0 

func (m *VSchema) Unmarshal(dAtA []byte) error

func (*VSchema) XXX_DiscardUnknown added in v0.10.0 

func (m *VSchema) XXX_DiscardUnknown()

func (*VSchema) XXX_Marshal added in v0.10.0 

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

func (*VSchema) XXX_Merge added in v0.10.0 

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

func (*VSchema) XXX_Size added in v0.10.0 

func (m *VSchema) XXX_Size() int

func (*VSchema) XXX_Unmarshal added in v0.10.0 

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

type VTAdminClient 

type VTAdminClient interface {
	// FindSchema returns a single Schema that matches the provided table name
	// across all specified clusters IDs. Not specifying a set of cluster IDs
	// causes the search to span all configured clusters.
	//
	// An error occurs if either no table exists across any of the clusters with
	// the specified table name, or if multiple tables exist with that name.
	FindSchema(ctx context.Context, in *FindSchemaRequest, opts ...grpc.CallOption) (*Schema, error)
	// GetClusters returns all configured clusters.
	GetClusters(ctx context.Context, in *GetClustersRequest, opts ...grpc.CallOption) (*GetClustersResponse, error)
	// GetGates returns all gates across all the specified clusters.
	GetGates(ctx context.Context, in *GetGatesRequest, opts ...grpc.CallOption) (*GetGatesResponse, error)
	// GetKeyspaces returns all keyspaces across the specified clusters.
	GetKeyspaces(ctx context.Context, in *GetKeyspacesRequest, opts ...grpc.CallOption) (*GetKeyspacesResponse, error)
	// GetSchema returns the schema for the specified (cluster, keyspace, table)
	// tuple.
	GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*Schema, error)
	// GetSchemas returns all schemas across the specified clusters.
	GetSchemas(ctx context.Context, in *GetSchemasRequest, opts ...grpc.CallOption) (*GetSchemasResponse, 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)
	// GetVSchema returns a VSchema for the specified keyspace in the specified
	// cluster.
	GetVSchema(ctx context.Context, in *GetVSchemaRequest, opts ...grpc.CallOption) (*VSchema, error)
	// GetVSchemas returns the VSchemas for all specified clusters.
	GetVSchemas(ctx context.Context, in *GetVSchemasRequest, opts ...grpc.CallOption) (*GetVSchemasResponse, error)
	// GetWorkflow returns a single Workflow for a given cluster, keyspace, and
	// workflow name.
	GetWorkflow(ctx context.Context, in *GetWorkflowRequest, opts ...grpc.CallOption) (*Workflow, error)
	// GetWorkflows returns the Workflows for all specified clusters.
	GetWorkflows(ctx context.Context, in *GetWorkflowsRequest, opts ...grpc.CallOption) (*GetWorkflowsResponse, error)
	// VTExplain provides information on how Vitess plans to execute a particular query.
	VTExplain(ctx context.Context, in *VTExplainRequest, opts ...grpc.CallOption) (*VTExplainResponse, 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 {
	// FindSchema returns a single Schema that matches the provided table name
	// across all specified clusters IDs. Not specifying a set of cluster IDs
	// causes the search to span all configured clusters.
	//
	// An error occurs if either no table exists across any of the clusters with
	// the specified table name, or if multiple tables exist with that name.
	FindSchema(context.Context, *FindSchemaRequest) (*Schema, error)
	// GetClusters returns all configured clusters.
	GetClusters(context.Context, *GetClustersRequest) (*GetClustersResponse, error)
	// GetGates returns all gates across all the specified clusters.
	GetGates(context.Context, *GetGatesRequest) (*GetGatesResponse, error)
	// GetKeyspaces returns all keyspaces across the specified clusters.
	GetKeyspaces(context.Context, *GetKeyspacesRequest) (*GetKeyspacesResponse, error)
	// GetSchema returns the schema for the specified (cluster, keyspace, table)
	// tuple.
	GetSchema(context.Context, *GetSchemaRequest) (*Schema, error)
	// GetSchemas returns all schemas across the specified clusters.
	GetSchemas(context.Context, *GetSchemasRequest) (*GetSchemasResponse, 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)
	// GetVSchema returns a VSchema for the specified keyspace in the specified
	// cluster.
	GetVSchema(context.Context, *GetVSchemaRequest) (*VSchema, error)
	// GetVSchemas returns the VSchemas for all specified clusters.
	GetVSchemas(context.Context, *GetVSchemasRequest) (*GetVSchemasResponse, error)
	// GetWorkflow returns a single Workflow for a given cluster, keyspace, and
	// workflow name.
	GetWorkflow(context.Context, *GetWorkflowRequest) (*Workflow, error)
	// GetWorkflows returns the Workflows for all specified clusters.
	GetWorkflows(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error)
	// VTExplain provides information on how Vitess plans to execute a particular query.
	VTExplain(context.Context, *VTExplainRequest) (*VTExplainResponse, error)
}

VTAdminServer is the server API for VTAdmin service.

type VTExplainRequest added in v0.10.0 

type VTExplainRequest struct {
	Cluster              string   `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace             string   `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Sql                  string   `protobuf:"bytes,3,opt,name=sql,proto3" json:"sql,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VTExplainRequest) Descriptor added in v0.10.0 

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

func (*VTExplainRequest) GetCluster added in v0.10.0 

func (m *VTExplainRequest) GetCluster() string

func (*VTExplainRequest) GetKeyspace added in v0.10.0 

func (m *VTExplainRequest) GetKeyspace() string

func (*VTExplainRequest) GetSql added in v0.10.0 

func (m *VTExplainRequest) GetSql() string

func (*VTExplainRequest) Marshal added in v0.10.0 

func (m *VTExplainRequest) Marshal() (dAtA []byte, err error)

func (*VTExplainRequest) MarshalTo added in v0.10.0 

func (m *VTExplainRequest) MarshalTo(dAtA []byte) (int, error)

func (*VTExplainRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *VTExplainRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VTExplainRequest) ProtoMessage added in v0.10.0 

func (*VTExplainRequest) ProtoMessage()

func (*VTExplainRequest) Reset added in v0.10.0 

func (m *VTExplainRequest) Reset()

func (*VTExplainRequest) Size added in v0.10.0 

func (m *VTExplainRequest) Size() (n int)

func (*VTExplainRequest) String added in v0.10.0 

func (m *VTExplainRequest) String() string

func (*VTExplainRequest) Unmarshal added in v0.10.0 

func (m *VTExplainRequest) Unmarshal(dAtA []byte) error

func (*VTExplainRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *VTExplainRequest) XXX_DiscardUnknown()

func (*VTExplainRequest) XXX_Marshal added in v0.10.0 

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

func (*VTExplainRequest) XXX_Merge added in v0.10.0 

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

func (*VTExplainRequest) XXX_Size added in v0.10.0 

func (m *VTExplainRequest) XXX_Size() int

func (*VTExplainRequest) XXX_Unmarshal added in v0.10.0 

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

type VTExplainResponse added in v0.10.0 

type VTExplainResponse struct {
	Response             string   `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VTExplainResponse) Descriptor added in v0.10.0 

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

func (*VTExplainResponse) GetResponse added in v0.10.0 

func (m *VTExplainResponse) GetResponse() string

func (*VTExplainResponse) Marshal added in v0.10.0 

func (m *VTExplainResponse) Marshal() (dAtA []byte, err error)

func (*VTExplainResponse) MarshalTo added in v0.10.0 

func (m *VTExplainResponse) MarshalTo(dAtA []byte) (int, error)

func (*VTExplainResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *VTExplainResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VTExplainResponse) ProtoMessage added in v0.10.0 

func (*VTExplainResponse) ProtoMessage()

func (*VTExplainResponse) Reset added in v0.10.0 

func (m *VTExplainResponse) Reset()

func (*VTExplainResponse) Size added in v0.10.0 

func (m *VTExplainResponse) Size() (n int)

func (*VTExplainResponse) String added in v0.10.0 

func (m *VTExplainResponse) String() string

func (*VTExplainResponse) Unmarshal added in v0.10.0 

func (m *VTExplainResponse) Unmarshal(dAtA []byte) error

func (*VTExplainResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *VTExplainResponse) XXX_DiscardUnknown()

func (*VTExplainResponse) XXX_Marshal added in v0.10.0 

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

func (*VTExplainResponse) XXX_Merge added in v0.10.0 

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

func (*VTExplainResponse) XXX_Size added in v0.10.0 

func (m *VTExplainResponse) XXX_Size() int

func (*VTExplainResponse) XXX_Unmarshal added in v0.10.0 

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

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) Marshal added in v0.10.0 

func (m *VTGate) Marshal() (dAtA []byte, err error)

func (*VTGate) MarshalTo added in v0.10.0 

func (m *VTGate) MarshalTo(dAtA []byte) (int, error)

func (*VTGate) MarshalToSizedBuffer added in v0.10.0 

func (m *VTGate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VTGate) ProtoMessage 

func (*VTGate) ProtoMessage()

func (*VTGate) Reset 

func (m *VTGate) Reset()

func (*VTGate) Size added in v0.10.0 

func (m *VTGate) Size() (n int)

func (*VTGate) String 

func (m *VTGate) String() string

func (*VTGate) Unmarshal added in v0.10.0 

func (m *VTGate) Unmarshal(dAtA []byte) error

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

type Vtctld added in v0.10.0 

type Vtctld struct {
	Hostname             string   `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Cluster              *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Vtctld represents information about a single Vtctld host.

func (*Vtctld) Descriptor added in v0.10.0 

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

func (*Vtctld) GetCluster added in v0.10.0 

func (m *Vtctld) GetCluster() *Cluster

func (*Vtctld) GetHostname added in v0.10.0 

func (m *Vtctld) GetHostname() string

func (*Vtctld) Marshal added in v0.10.0 

func (m *Vtctld) Marshal() (dAtA []byte, err error)

func (*Vtctld) MarshalTo added in v0.10.0 

func (m *Vtctld) MarshalTo(dAtA []byte) (int, error)

func (*Vtctld) MarshalToSizedBuffer added in v0.10.0 

func (m *Vtctld) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Vtctld) ProtoMessage added in v0.10.0 

func (*Vtctld) ProtoMessage()

func (*Vtctld) Reset added in v0.10.0 

func (m *Vtctld) Reset()

func (*Vtctld) Size added in v0.10.0 

func (m *Vtctld) Size() (n int)

func (*Vtctld) String added in v0.10.0 

func (m *Vtctld) String() string

func (*Vtctld) Unmarshal added in v0.10.0 

func (m *Vtctld) Unmarshal(dAtA []byte) error

func (*Vtctld) XXX_DiscardUnknown added in v0.10.0 

func (m *Vtctld) XXX_DiscardUnknown()

func (*Vtctld) XXX_Marshal added in v0.10.0 

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

func (*Vtctld) XXX_Merge added in v0.10.0 

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

func (*Vtctld) XXX_Size added in v0.10.0 

func (m *Vtctld) XXX_Size() int

func (*Vtctld) XXX_Unmarshal added in v0.10.0 

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

type Workflow added in v0.10.0 

type Workflow struct {
	Cluster              *Cluster            `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace             string              `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Workflow             *vtctldata.Workflow `protobuf:"bytes,3,opt,name=workflow,proto3" json:"workflow,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*Workflow) Descriptor added in v0.10.0 

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

func (*Workflow) GetCluster added in v0.10.0 

func (m *Workflow) GetCluster() *Cluster

func (*Workflow) GetKeyspace added in v0.10.0 

func (m *Workflow) GetKeyspace() string

func (*Workflow) GetWorkflow added in v0.10.0 

func (m *Workflow) GetWorkflow() *vtctldata.Workflow

func (*Workflow) Marshal added in v0.10.0 

func (m *Workflow) Marshal() (dAtA []byte, err error)

func (*Workflow) MarshalTo added in v0.10.0 

func (m *Workflow) MarshalTo(dAtA []byte) (int, error)

func (*Workflow) MarshalToSizedBuffer added in v0.10.0 

func (m *Workflow) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Workflow) ProtoMessage added in v0.10.0 

func (*Workflow) ProtoMessage()

func (*Workflow) Reset added in v0.10.0 

func (m *Workflow) Reset()

func (*Workflow) Size added in v0.10.0 

func (m *Workflow) Size() (n int)

func (*Workflow) String added in v0.10.0 

func (m *Workflow) String() string

func (*Workflow) Unmarshal added in v0.10.0 

func (m *Workflow) Unmarshal(dAtA []byte) error

func (*Workflow) XXX_DiscardUnknown added in v0.10.0 

func (m *Workflow) XXX_DiscardUnknown()

func (*Workflow) XXX_Marshal added in v0.10.0 

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

func (*Workflow) XXX_Merge added in v0.10.0 

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

func (*Workflow) XXX_Size added in v0.10.0 

func (m *Workflow) XXX_Size() int

func (*Workflow) XXX_Unmarshal added in v0.10.0 

func (m *Workflow) 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.