serverpb

package
v1.1.4 Latest Latest
Warning

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

 Go to latest Published: Jan 1, 2018 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Overview 

Package serverpb is a generated protocol buffer package.

It is generated from these files:
	cockroach/pkg/server/serverpb/admin.proto
	cockroach/pkg/server/serverpb/authentication.proto
	cockroach/pkg/server/serverpb/init.proto
	cockroach/pkg/server/serverpb/status.proto

It has these top-level messages:
	DatabasesRequest
	DatabasesResponse
	DatabaseDetailsRequest
	DatabaseDetailsResponse
	TableDetailsRequest
	TableDetailsResponse
	TableStatsRequest
	TableStatsResponse
	UsersRequest
	UsersResponse
	EventsRequest
	EventsResponse
	SetUIDataRequest
	SetUIDataResponse
	GetUIDataRequest
	GetUIDataResponse
	ClusterRequest
	ClusterResponse
	DrainRequest
	DrainResponse
	DecommissionStatusRequest
	DecommissionRequest
	DecommissionStatusResponse
	SettingsRequest
	SettingsResponse
	HealthRequest
	HealthResponse
	LivenessRequest
	LivenessResponse
	JobsRequest
	JobsResponse
	RangeLogRequest
	RangeLogResponse
	QueryPlanRequest
	QueryPlanResponse
	UserLoginRequest
	UserLoginResponse
	UserLogoutRequest
	UserLogoutResponse
	SessionCookie
	BootstrapRequest
	BootstrapResponse
	CertificatesRequest
	CertificateDetails
	CertificatesResponse
	DetailsRequest
	DetailsResponse
	NodesRequest
	NodesResponse
	NodeRequest
	RaftState
	RangeProblems
	RangeStatistics
	PrettySpan
	CommandQueueMetrics
	RangeInfo
	RangesRequest
	RangesResponse
	GossipRequest
	AllocatorDryRun
	AllocatorRangeRequest
	AllocatorRangeResponse
	AllocatorRequest
	AllocatorResponse
	JSONResponse
	LogsRequest
	LogEntriesResponse
	LogFilesListRequest
	LogFilesListResponse
	LogFileRequest
	StacksRequest
	MetricsRequest
	RaftRangeNode
	RaftRangeError
	RaftRangeStatus
	RaftDebugRequest
	RaftDebugResponse
	ActiveQuery
	ListSessionsRequest
	Session
	ListSessionsError
	ListSessionsResponse
	CancelQueryRequest
	CancelQueryResponse
	SpanStatsRequest
	SpanStatsResponse
	ProblemRangesRequest
	ProblemRangesResponse
	RangeRequest
	RangeResponse

Package serverpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package serverpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package serverpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAdmin = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAdmin   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthAuthentication = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAuthentication   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthInit = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowInit   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthStatus = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStatus   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ActiveQuery_Phase_name = map[int32]string{
	0: "PREPARING",
	1: "EXECUTING",
}
View Source 
var ActiveQuery_Phase_value = map[string]int32{
	"PREPARING": 0,
	"EXECUTING": 1,
}
View Source 
var CertificateDetails_CertificateType_name = map[int32]string{
	0: "CA",
	1: "NODE",
}
View Source 
var CertificateDetails_CertificateType_value = map[string]int32{
	"CA":   0,
	"NODE": 1,
}
View Source 
var DrainMode_name = map[int32]string{
	0: "CLIENT",
	1: "LEASES",
}
View Source 
var DrainMode_value = map[string]int32{
	"CLIENT": 0,
	"LEASES": 1,
}
View Source 
var ZoneConfigurationLevel_name = map[int32]string{
	0: "UNKNOWN",
	1: "CLUSTER",
	2: "DATABASE",
	3: "TABLE",
}
View Source 
var ZoneConfigurationLevel_value = map[string]int32{
	"UNKNOWN":  0,
	"CLUSTER":  1,
	"DATABASE": 2,
	"TABLE":    3,
}

Functions

func RegisterAdminHandler 

func RegisterAdminHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAdminHandler registers the http handlers for service Admin to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAdminHandlerFromEndpoint 

func RegisterAdminHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAdminHandlerFromEndpoint is same as RegisterAdminHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAdminServer 

func RegisterAdminServer(s *grpc.Server, srv AdminServer)

func RegisterAuthenticationHandler 

func RegisterAuthenticationHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAuthenticationHandler registers the http handlers for service Authentication to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAuthenticationHandlerFromEndpoint 

func RegisterAuthenticationHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAuthenticationHandlerFromEndpoint is same as RegisterAuthenticationHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAuthenticationServer 

func RegisterAuthenticationServer(s *grpc.Server, srv AuthenticationServer)

func RegisterInitServer 

func RegisterInitServer(s *grpc.Server, srv InitServer)

func RegisterStatusHandler 

func RegisterStatusHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterStatusHandler registers the http handlers for service Status to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterStatusHandlerFromEndpoint 

func RegisterStatusHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterStatusHandlerFromEndpoint is same as RegisterStatusHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterStatusServer 

func RegisterStatusServer(s *grpc.Server, srv StatusServer)

Types

type ActiveQuery 

type ActiveQuery struct {
	// ID of the query (uint128 presented as a hexadecimal string).
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// SQL query string specified by the user.
	Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	// Start timestamp of this query.
	Start time.Time `protobuf:"bytes,3,opt,name=start,stdtime" json:"start"`
	// True if this query is distributed.
	IsDistributed bool `protobuf:"varint,4,opt,name=is_distributed,json=isDistributed,proto3" json:"is_distributed,omitempty"`
	// phase stores the current phase of execution for this query.
	Phase ActiveQuery_Phase `protobuf:"varint,5,opt,name=phase,proto3,enum=cockroach.server.serverpb.ActiveQuery_Phase" json:"phase,omitempty"`
}

ActiveQuery represents a query in flight on some Session.

func (*ActiveQuery) Descriptor 

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

func (*ActiveQuery) Marshal 

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

func (*ActiveQuery) MarshalTo 

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

func (*ActiveQuery) ProtoMessage 

func (*ActiveQuery) ProtoMessage()

func (*ActiveQuery) Reset 

func (m *ActiveQuery) Reset()

func (*ActiveQuery) Size 

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

func (*ActiveQuery) String 

func (m *ActiveQuery) String() string

func (*ActiveQuery) Unmarshal 

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

type ActiveQuery_Phase 

type ActiveQuery_Phase int32

Enum for phase of execution. 

const (
	ActiveQuery_PREPARING ActiveQuery_Phase = 0
	ActiveQuery_EXECUTING ActiveQuery_Phase = 1
)

func (ActiveQuery_Phase) EnumDescriptor 

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

func (ActiveQuery_Phase) String 

func (x ActiveQuery_Phase) String() string

type AdminClient 

type AdminClient interface {
	// URL: /_admin/v1/users
	Users(ctx context.Context, in *UsersRequest, opts ...grpc.CallOption) (*UsersResponse, error)
	// URL: /_admin/v1/databases
	Databases(ctx context.Context, in *DatabasesRequest, opts ...grpc.CallOption) (*DatabasesResponse, error)
	// Example URL: /_admin/v1/databases/system
	DatabaseDetails(ctx context.Context, in *DatabaseDetailsRequest, opts ...grpc.CallOption) (*DatabaseDetailsResponse, error)
	// Example URL: /_admin/v1/databases/system/tables/ui
	TableDetails(ctx context.Context, in *TableDetailsRequest, opts ...grpc.CallOption) (*TableDetailsResponse, error)
	// Example URL: /_admin/v1/databases/system/tables/ui/stats
	TableStats(ctx context.Context, in *TableStatsRequest, opts ...grpc.CallOption) (*TableStatsResponse, error)
	// Example URLs:
	// Example URLs:
	// - /_admin/v1/events
	// - /_admin/v1/events?limit=100
	// - /_admin/v1/events?type=create_table
	// - /_admin/v1/events?type=create_table&limit=100
	// - /_admin/v1/events?type=drop_table&target_id=4
	// - /_admin/v1/events?type=drop_table&target_id=4&limit=100
	Events(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (*EventsResponse, error)
	// This requires a POST. Because of the libraries we're using, the POST body
	// must be in the following format:
	//
	// {"key_values":
	//   { "key1": "base64_encoded_value1"},
	//   ...
	//   { "keyN": "base64_encoded_valueN"},
	// }
	//
	// Note that all keys are quoted strings and that all values are base64-
	// encoded.
	//
	// Together, SetUIData and GetUIData provide access to a "cookie jar" for the
	// admin UI. The structure of the underlying data is meant to be opaque to the
	// server.
	SetUIData(ctx context.Context, in *SetUIDataRequest, opts ...grpc.CallOption) (*SetUIDataResponse, error)
	// Example URLs:
	// - /_admin/v1/uidata?keys=MYKEY
	// - /_admin/v1/uidata?keys=MYKEY1&keys=MYKEY2
	//
	// Yes, it's a little odd that the query parameter is named "keys" instead of
	// "key". I would've preferred that the URL parameter be named "key". However,
	// it's clearer for the protobuf field to be named "keys," which makes the URL
	// parameter "keys" as well.
	GetUIData(ctx context.Context, in *GetUIDataRequest, opts ...grpc.CallOption) (*GetUIDataResponse, error)
	// Cluster returns metadata for the cluster.
	Cluster(ctx context.Context, in *ClusterRequest, opts ...grpc.CallOption) (*ClusterResponse, error)
	// Settings returns the cluster-wide settings for the cluster.
	Settings(ctx context.Context, in *SettingsRequest, opts ...grpc.CallOption) (*SettingsResponse, error)
	// Health returns liveness for the node target of the request.
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
	// Liveness returns the liveness state of all nodes on the cluster.
	Liveness(ctx context.Context, in *LivenessRequest, opts ...grpc.CallOption) (*LivenessResponse, error)
	// Jobs returns the job records for all jobs of the given status and type.
	Jobs(ctx context.Context, in *JobsRequest, opts ...grpc.CallOption) (*JobsResponse, error)
	// QueryPlan returns the query plans for a SQL string.
	QueryPlan(ctx context.Context, in *QueryPlanRequest, opts ...grpc.CallOption) (*QueryPlanResponse, error)
	// Drain puts the node into the specified drain mode(s) and optionally
	// instructs the process to terminate.
	Drain(ctx context.Context, in *DrainRequest, opts ...grpc.CallOption) (Admin_DrainClient, error)
	// Decommission puts the node(s) into the specified decommissioning state.
	Decommission(ctx context.Context, in *DecommissionRequest, opts ...grpc.CallOption) (*DecommissionStatusResponse, error)
	// DecommissionStatus retrieves the decommissioning status of the specified nodes.
	DecommissionStatus(ctx context.Context, in *DecommissionStatusRequest, opts ...grpc.CallOption) (*DecommissionStatusResponse, error)
	// URL: /_admin/v1/rangelog
	// URL: /_admin/v1/rangelog?limit=100
	// URL: /_admin/v1/rangelog/1
	// URL: /_admin/v1/rangelog/1?limit=100
	RangeLog(ctx context.Context, in *RangeLogRequest, opts ...grpc.CallOption) (*RangeLogResponse, error)
}

func NewAdminClient 

func NewAdminClient(cc *grpc.ClientConn) AdminClient

type AdminServer 

type AdminServer interface {
	// URL: /_admin/v1/users
	Users(context.Context, *UsersRequest) (*UsersResponse, error)
	// URL: /_admin/v1/databases
	Databases(context.Context, *DatabasesRequest) (*DatabasesResponse, error)
	// Example URL: /_admin/v1/databases/system
	DatabaseDetails(context.Context, *DatabaseDetailsRequest) (*DatabaseDetailsResponse, error)
	// Example URL: /_admin/v1/databases/system/tables/ui
	TableDetails(context.Context, *TableDetailsRequest) (*TableDetailsResponse, error)
	// Example URL: /_admin/v1/databases/system/tables/ui/stats
	TableStats(context.Context, *TableStatsRequest) (*TableStatsResponse, error)
	// Example URLs:
	// Example URLs:
	// - /_admin/v1/events
	// - /_admin/v1/events?limit=100
	// - /_admin/v1/events?type=create_table
	// - /_admin/v1/events?type=create_table&limit=100
	// - /_admin/v1/events?type=drop_table&target_id=4
	// - /_admin/v1/events?type=drop_table&target_id=4&limit=100
	Events(context.Context, *EventsRequest) (*EventsResponse, error)
	// This requires a POST. Because of the libraries we're using, the POST body
	// must be in the following format:
	//
	// {"key_values":
	//   { "key1": "base64_encoded_value1"},
	//   ...
	//   { "keyN": "base64_encoded_valueN"},
	// }
	//
	// Note that all keys are quoted strings and that all values are base64-
	// encoded.
	//
	// Together, SetUIData and GetUIData provide access to a "cookie jar" for the
	// admin UI. The structure of the underlying data is meant to be opaque to the
	// server.
	SetUIData(context.Context, *SetUIDataRequest) (*SetUIDataResponse, error)
	// Example URLs:
	// - /_admin/v1/uidata?keys=MYKEY
	// - /_admin/v1/uidata?keys=MYKEY1&keys=MYKEY2
	//
	// Yes, it's a little odd that the query parameter is named "keys" instead of
	// "key". I would've preferred that the URL parameter be named "key". However,
	// it's clearer for the protobuf field to be named "keys," which makes the URL
	// parameter "keys" as well.
	GetUIData(context.Context, *GetUIDataRequest) (*GetUIDataResponse, error)
	// Cluster returns metadata for the cluster.
	Cluster(context.Context, *ClusterRequest) (*ClusterResponse, error)
	// Settings returns the cluster-wide settings for the cluster.
	Settings(context.Context, *SettingsRequest) (*SettingsResponse, error)
	// Health returns liveness for the node target of the request.
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	// Liveness returns the liveness state of all nodes on the cluster.
	Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error)
	// Jobs returns the job records for all jobs of the given status and type.
	Jobs(context.Context, *JobsRequest) (*JobsResponse, error)
	// QueryPlan returns the query plans for a SQL string.
	QueryPlan(context.Context, *QueryPlanRequest) (*QueryPlanResponse, error)
	// Drain puts the node into the specified drain mode(s) and optionally
	// instructs the process to terminate.
	Drain(*DrainRequest, Admin_DrainServer) error
	// Decommission puts the node(s) into the specified decommissioning state.
	Decommission(context.Context, *DecommissionRequest) (*DecommissionStatusResponse, error)
	// DecommissionStatus retrieves the decommissioning status of the specified nodes.
	DecommissionStatus(context.Context, *DecommissionStatusRequest) (*DecommissionStatusResponse, error)
	// URL: /_admin/v1/rangelog
	// URL: /_admin/v1/rangelog?limit=100
	// URL: /_admin/v1/rangelog/1
	// URL: /_admin/v1/rangelog/1?limit=100
	RangeLog(context.Context, *RangeLogRequest) (*RangeLogResponse, error)
}

type Admin_DrainClient 

type Admin_DrainClient interface {
	Recv() (*DrainResponse, error)
	grpc.ClientStream
}

type Admin_DrainServer 

type Admin_DrainServer interface {
	Send(*DrainResponse) error
	grpc.ServerStream
}

type AllocatorDryRun 

type AllocatorDryRun struct {
	RangeID github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 145-byte string literal not displayed */
	Events  []*AllocatorDryRun_Event                             `protobuf:"bytes,2,rep,name=events" json:"events,omitempty"`
}

func (*AllocatorDryRun) Descriptor 

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

func (*AllocatorDryRun) Marshal 

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

func (*AllocatorDryRun) MarshalTo 

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

func (*AllocatorDryRun) ProtoMessage 

func (*AllocatorDryRun) ProtoMessage()

func (*AllocatorDryRun) Reset 

func (m *AllocatorDryRun) Reset()

func (*AllocatorDryRun) Size 

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

func (*AllocatorDryRun) String 

func (m *AllocatorDryRun) String() string

func (*AllocatorDryRun) Unmarshal 

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

type AllocatorDryRun_Event 

type AllocatorDryRun_Event struct {
	Time    time.Time `protobuf:"bytes,1,opt,name=time,stdtime" json:"time"`
	Message string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*AllocatorDryRun_Event) Descriptor 

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

func (*AllocatorDryRun_Event) Marshal 

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

func (*AllocatorDryRun_Event) MarshalTo 

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

func (*AllocatorDryRun_Event) ProtoMessage 

func (*AllocatorDryRun_Event) ProtoMessage()

func (*AllocatorDryRun_Event) Reset 

func (m *AllocatorDryRun_Event) Reset()

func (*AllocatorDryRun_Event) Size 

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

func (*AllocatorDryRun_Event) String 

func (m *AllocatorDryRun_Event) String() string

func (*AllocatorDryRun_Event) Unmarshal 

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

type AllocatorRangeRequest 

type AllocatorRangeRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	RangeId int64 `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
}

func (*AllocatorRangeRequest) Descriptor 

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

func (*AllocatorRangeRequest) Marshal 

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

func (*AllocatorRangeRequest) MarshalTo 

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

func (*AllocatorRangeRequest) ProtoMessage 

func (*AllocatorRangeRequest) ProtoMessage()

func (*AllocatorRangeRequest) Reset 

func (m *AllocatorRangeRequest) Reset()

func (*AllocatorRangeRequest) Size 

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

func (*AllocatorRangeRequest) String 

func (m *AllocatorRangeRequest) String() string

func (*AllocatorRangeRequest) Unmarshal 

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

type AllocatorRangeResponse 

type AllocatorRangeResponse struct {
	// The NodeID of the store whose dry run is returned. Only the leaseholder
	// for a given range will do an allocator dry run for it.
	NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */
	DryRun *AllocatorDryRun                                    `protobuf:"bytes,2,opt,name=dry_run,json=dryRun" json:"dry_run,omitempty"`
}

func (*AllocatorRangeResponse) Descriptor 

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

func (*AllocatorRangeResponse) Marshal 

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

func (*AllocatorRangeResponse) MarshalTo 

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

func (*AllocatorRangeResponse) ProtoMessage 

func (*AllocatorRangeResponse) ProtoMessage()

func (*AllocatorRangeResponse) Reset 

func (m *AllocatorRangeResponse) Reset()

func (*AllocatorRangeResponse) Size 

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

func (*AllocatorRangeResponse) String 

func (m *AllocatorRangeResponse) String() string

func (*AllocatorRangeResponse) Unmarshal 

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

type AllocatorRequest 

type AllocatorRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	NodeId   string                                                 `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	RangeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 148-byte string literal not displayed */
}

func (*AllocatorRequest) Descriptor 

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

func (*AllocatorRequest) Marshal 

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

func (*AllocatorRequest) MarshalTo 

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

func (*AllocatorRequest) ProtoMessage 

func (*AllocatorRequest) ProtoMessage()

func (*AllocatorRequest) Reset 

func (m *AllocatorRequest) Reset()

func (*AllocatorRequest) Size 

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

func (*AllocatorRequest) String 

func (m *AllocatorRequest) String() string

func (*AllocatorRequest) Unmarshal 

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

type AllocatorResponse 

type AllocatorResponse struct {
	DryRuns []*AllocatorDryRun `protobuf:"bytes,1,rep,name=dry_runs,json=dryRuns" json:"dry_runs,omitempty"`
}

func (*AllocatorResponse) Descriptor 

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

func (*AllocatorResponse) Marshal 

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

func (*AllocatorResponse) MarshalTo 

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

func (*AllocatorResponse) ProtoMessage 

func (*AllocatorResponse) ProtoMessage()

func (*AllocatorResponse) Reset 

func (m *AllocatorResponse) Reset()

func (*AllocatorResponse) Size 

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

func (*AllocatorResponse) String 

func (m *AllocatorResponse) String() string

func (*AllocatorResponse) Unmarshal 

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

type AuthenticationClient 

type AuthenticationClient interface {
	// UserLogin is used to create a web authentication session.
	UserLogin(ctx context.Context, in *UserLoginRequest, opts ...grpc.CallOption) (*UserLoginResponse, error)
	// UserLogout terminates an active authentication session.
	UserLogout(ctx context.Context, in *UserLogoutRequest, opts ...grpc.CallOption) (*UserLogoutResponse, error)
}

func NewAuthenticationClient 

func NewAuthenticationClient(cc *grpc.ClientConn) AuthenticationClient

type AuthenticationServer 

type AuthenticationServer interface {
	// UserLogin is used to create a web authentication session.
	UserLogin(context.Context, *UserLoginRequest) (*UserLoginResponse, error)
	// UserLogout terminates an active authentication session.
	UserLogout(context.Context, *UserLogoutRequest) (*UserLogoutResponse, error)
}

type BootstrapRequest 

type BootstrapRequest struct {
}

func (*BootstrapRequest) Descriptor 

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

func (*BootstrapRequest) Marshal 

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

func (*BootstrapRequest) MarshalTo 

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

func (*BootstrapRequest) ProtoMessage 

func (*BootstrapRequest) ProtoMessage()

func (*BootstrapRequest) Reset 

func (m *BootstrapRequest) Reset()

func (*BootstrapRequest) Size 

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

func (*BootstrapRequest) String 

func (m *BootstrapRequest) String() string

func (*BootstrapRequest) Unmarshal 

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

type BootstrapResponse 

type BootstrapResponse struct {
}

func (*BootstrapResponse) Descriptor 

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

func (*BootstrapResponse) Marshal 

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

func (*BootstrapResponse) MarshalTo 

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

func (*BootstrapResponse) ProtoMessage 

func (*BootstrapResponse) ProtoMessage()

func (*BootstrapResponse) Reset 

func (m *BootstrapResponse) Reset()

func (*BootstrapResponse) Size 

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

func (*BootstrapResponse) String 

func (m *BootstrapResponse) String() string

func (*BootstrapResponse) Unmarshal 

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

type CancelQueryRequest 

type CancelQueryRequest struct {
	// ID of gateway node for the query to be cancelled.
	//
	// figure out how to teach grpc-gateway about custom names.
	//
	// node_id is a string so that "local" can be used to specify that no
	// forwarding is necessary.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// ID of query to be cancelled (converted to string).
	QueryID string `protobuf:"bytes,2,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	// Username of the user making this cancellation request.
	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
}

Request object for issing a query cancel request.

func (*CancelQueryRequest) Descriptor 

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

func (*CancelQueryRequest) Marshal 

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

func (*CancelQueryRequest) MarshalTo 

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

func (*CancelQueryRequest) ProtoMessage 

func (*CancelQueryRequest) ProtoMessage()

func (*CancelQueryRequest) Reset 

func (m *CancelQueryRequest) Reset()

func (*CancelQueryRequest) Size 

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

func (*CancelQueryRequest) String 

func (m *CancelQueryRequest) String() string

func (*CancelQueryRequest) Unmarshal 

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

type CancelQueryResponse 

type CancelQueryResponse struct {
	// Whether the cancellation request succeeded and the query was cancelled.
	Cancelled bool `protobuf:"varint,1,opt,name=cancelled,proto3" json:"cancelled,omitempty"`
	// Error message (accompanied with cancelled = false).
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

Response returned by target query's gateway node.

func (*CancelQueryResponse) Descriptor 

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

func (*CancelQueryResponse) Marshal 

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

func (*CancelQueryResponse) MarshalTo 

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

func (*CancelQueryResponse) ProtoMessage 

func (*CancelQueryResponse) ProtoMessage()

func (*CancelQueryResponse) Reset 

func (m *CancelQueryResponse) Reset()

func (*CancelQueryResponse) Size 

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

func (*CancelQueryResponse) String 

func (m *CancelQueryResponse) String() string

func (*CancelQueryResponse) Unmarshal 

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

type CertificateDetails 

type CertificateDetails struct {
	Type CertificateDetails_CertificateType `` /* 128-byte string literal not displayed */
	// "error_message" and "data" are mutually exclusive.
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// data is the raw file contents of the certificate. This means PEM-encoded DER data.
	Data   []byte                      `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Fields []CertificateDetails_Fields `protobuf:"bytes,4,rep,name=fields" json:"fields"`
}

func (*CertificateDetails) Descriptor 

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

func (*CertificateDetails) Marshal 

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

func (*CertificateDetails) MarshalTo 

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

func (*CertificateDetails) ProtoMessage 

func (*CertificateDetails) ProtoMessage()

func (*CertificateDetails) Reset 

func (m *CertificateDetails) Reset()

func (*CertificateDetails) Size 

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

func (*CertificateDetails) String 

func (m *CertificateDetails) String() string

func (*CertificateDetails) Unmarshal 

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

type CertificateDetails_CertificateType 

type CertificateDetails_CertificateType int32

We use an enum to allow reporting of client certs and potential others (eg: UI). 

const (
	CertificateDetails_CA   CertificateDetails_CertificateType = 0
	CertificateDetails_NODE CertificateDetails_CertificateType = 1
)

func (CertificateDetails_CertificateType) EnumDescriptor 

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

func (CertificateDetails_CertificateType) String 

func (x CertificateDetails_CertificateType) String() string

type CertificateDetails_Fields 

type CertificateDetails_Fields struct {
	Issuer             string   `protobuf:"bytes,1,opt,name=issuer,proto3" json:"issuer,omitempty"`
	Subject            string   `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	ValidFrom          int64    `protobuf:"varint,3,opt,name=valid_from,json=validFrom,proto3" json:"valid_from,omitempty"`
	ValidUntil         int64    `protobuf:"varint,4,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"`
	Addresses          []string `protobuf:"bytes,5,rep,name=addresses" json:"addresses,omitempty"`
	SignatureAlgorithm string   `protobuf:"bytes,6,opt,name=signature_algorithm,json=signatureAlgorithm,proto3" json:"signature_algorithm,omitempty"`
	PublicKey          string   `protobuf:"bytes,7,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	KeyUsage           []string `protobuf:"bytes,8,rep,name=key_usage,json=keyUsage" json:"key_usage,omitempty"`
	ExtendedKeyUsage   []string `protobuf:"bytes,9,rep,name=extended_key_usage,json=extendedKeyUsage" json:"extended_key_usage,omitempty"`
}

func (*CertificateDetails_Fields) Descriptor 

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

func (*CertificateDetails_Fields) Marshal 

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

func (*CertificateDetails_Fields) MarshalTo 

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

func (*CertificateDetails_Fields) ProtoMessage 

func (*CertificateDetails_Fields) ProtoMessage()

func (*CertificateDetails_Fields) Reset 

func (m *CertificateDetails_Fields) Reset()

func (*CertificateDetails_Fields) Size 

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

func (*CertificateDetails_Fields) String 

func (m *CertificateDetails_Fields) String() string

func (*CertificateDetails_Fields) Unmarshal 

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

type CertificatesRequest 

type CertificatesRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	//
	// node_id is a string so that "local" can be used to specify that no
	// forwarding is necessary.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

func (*CertificatesRequest) Descriptor 

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

func (*CertificatesRequest) Marshal 

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

func (*CertificatesRequest) MarshalTo 

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

func (*CertificatesRequest) ProtoMessage 

func (*CertificatesRequest) ProtoMessage()

func (*CertificatesRequest) Reset 

func (m *CertificatesRequest) Reset()

func (*CertificatesRequest) Size 

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

func (*CertificatesRequest) String 

func (m *CertificatesRequest) String() string

func (*CertificatesRequest) Unmarshal 

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

type CertificatesResponse 

type CertificatesResponse struct {
	Certificates []CertificateDetails `protobuf:"bytes,1,rep,name=certificates" json:"certificates"`
}

func (*CertificatesResponse) Descriptor 

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

func (*CertificatesResponse) Marshal 

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

func (*CertificatesResponse) MarshalTo 

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

func (*CertificatesResponse) ProtoMessage 

func (*CertificatesResponse) ProtoMessage()

func (*CertificatesResponse) Reset 

func (m *CertificatesResponse) Reset()

func (*CertificatesResponse) Size 

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

func (*CertificatesResponse) String 

func (m *CertificatesResponse) String() string

func (*CertificatesResponse) Unmarshal 

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

type ClusterRequest 

type ClusterRequest struct {
}

ClusterRequest requests metadata for the cluster.

func (*ClusterRequest) Descriptor 

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

func (*ClusterRequest) Marshal 

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

func (*ClusterRequest) MarshalTo 

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

func (*ClusterRequest) ProtoMessage 

func (*ClusterRequest) ProtoMessage()

func (*ClusterRequest) Reset 

func (m *ClusterRequest) Reset()

func (*ClusterRequest) Size 

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

func (*ClusterRequest) String 

func (m *ClusterRequest) String() string

func (*ClusterRequest) Unmarshal 

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

type ClusterResponse 

type ClusterResponse struct {
	// The unique ID used to identify this cluster.
	ClusterID string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// True if diagnostics reporting is enabled for the cluster.
	ReportingEnabled bool `protobuf:"varint,2,opt,name=reporting_enabled,json=reportingEnabled,proto3" json:"reporting_enabled,omitempty"`
	// True if enterprise features are enabled for the cluster.
	EnterpriseEnabled bool `protobuf:"varint,3,opt,name=enterprise_enabled,json=enterpriseEnabled,proto3" json:"enterprise_enabled,omitempty"`
}

ClusterResponse contains metadata for the cluster.

func (*ClusterResponse) Descriptor 

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

func (*ClusterResponse) Marshal 

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

func (*ClusterResponse) MarshalTo 

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

func (*ClusterResponse) ProtoMessage 

func (*ClusterResponse) ProtoMessage()

func (*ClusterResponse) Reset 

func (m *ClusterResponse) Reset()

func (*ClusterResponse) Size 

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

func (*ClusterResponse) String 

func (m *ClusterResponse) String() string

func (*ClusterResponse) Unmarshal 

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

type CommandQueueMetrics 

type CommandQueueMetrics struct {
	WriteCommands   int64 `protobuf:"varint,1,opt,name=write_commands,json=writeCommands,proto3" json:"write_commands,omitempty"`
	ReadCommands    int64 `protobuf:"varint,2,opt,name=read_commands,json=readCommands,proto3" json:"read_commands,omitempty"`
	MaxOverlapsSeen int64 `protobuf:"varint,3,opt,name=max_overlaps_seen,json=maxOverlapsSeen,proto3" json:"max_overlaps_seen,omitempty"`
	TreeSize        int32 `protobuf:"varint,4,opt,name=tree_size,json=treeSize,proto3" json:"tree_size,omitempty"`
}

func (*CommandQueueMetrics) Descriptor 

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

func (*CommandQueueMetrics) Marshal 

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

func (*CommandQueueMetrics) MarshalTo 

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

func (*CommandQueueMetrics) ProtoMessage 

func (*CommandQueueMetrics) ProtoMessage()

func (*CommandQueueMetrics) Reset 

func (m *CommandQueueMetrics) Reset()

func (*CommandQueueMetrics) Size 

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

func (*CommandQueueMetrics) String 

func (m *CommandQueueMetrics) String() string

func (*CommandQueueMetrics) Unmarshal 

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

type DatabaseDetailsRequest 

type DatabaseDetailsRequest struct {
	// database is the name of the database we are querying.
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
}

DatabaseDetailsRequest requests detailed information about the specified database

func (*DatabaseDetailsRequest) Descriptor 

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

func (*DatabaseDetailsRequest) Marshal 

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

func (*DatabaseDetailsRequest) MarshalTo 

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

func (*DatabaseDetailsRequest) ProtoMessage 

func (*DatabaseDetailsRequest) ProtoMessage()

func (*DatabaseDetailsRequest) Reset 

func (m *DatabaseDetailsRequest) Reset()

func (*DatabaseDetailsRequest) Size 

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

func (*DatabaseDetailsRequest) String 

func (m *DatabaseDetailsRequest) String() string

func (*DatabaseDetailsRequest) Unmarshal 

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

type DatabaseDetailsResponse 

type DatabaseDetailsResponse struct {
	// grants are the results of SHOW GRANTS for this database.
	Grants []DatabaseDetailsResponse_Grant `protobuf:"bytes,1,rep,name=grants" json:"grants"`
	// table_names contains the names of all tables (SHOW TABLES) in this
	// database.
	TableNames []string `protobuf:"bytes,2,rep,name=table_names,json=tableNames" json:"table_names,omitempty"`
	// descriptor_id is an identifier used to uniquely identify this database.
	// It can be used to find events pertaining to this database by filtering on
	// the 'target_id' field of events.
	DescriptorID int64 `protobuf:"varint,3,opt,name=descriptor_id,json=descriptorId,proto3" json:"descriptor_id,omitempty"`
	// The zone configuration in effect for this database.
	ZoneConfig cockroach_config.ZoneConfig `protobuf:"bytes,4,opt,name=zone_config,json=zoneConfig" json:"zone_config"`
	// The level at which this object's zone configuration is set.
	ZoneConfigLevel ZoneConfigurationLevel `` /* 163-byte string literal not displayed */
}

DatabaseDetailsResponse contains grant information and table names for a database.

func (*DatabaseDetailsResponse) Descriptor 

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

func (*DatabaseDetailsResponse) Marshal 

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

func (*DatabaseDetailsResponse) MarshalTo 

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

func (*DatabaseDetailsResponse) ProtoMessage 

func (*DatabaseDetailsResponse) ProtoMessage()

func (*DatabaseDetailsResponse) Reset 

func (m *DatabaseDetailsResponse) Reset()

func (*DatabaseDetailsResponse) Size 

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

func (*DatabaseDetailsResponse) String 

func (m *DatabaseDetailsResponse) String() string

func (*DatabaseDetailsResponse) Unmarshal 

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

type DatabaseDetailsResponse_Grant 

type DatabaseDetailsResponse_Grant struct {
	// user is the user that this grant applies to.
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// privileges are the abilities this grant gives to the user.
	Privileges []string `protobuf:"bytes,2,rep,name=privileges" json:"privileges,omitempty"`
}

func (*DatabaseDetailsResponse_Grant) Descriptor 

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

func (*DatabaseDetailsResponse_Grant) Marshal 

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

func (*DatabaseDetailsResponse_Grant) MarshalTo 

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

func (*DatabaseDetailsResponse_Grant) ProtoMessage 

func (*DatabaseDetailsResponse_Grant) ProtoMessage()

func (*DatabaseDetailsResponse_Grant) Reset 

func (m *DatabaseDetailsResponse_Grant) Reset()

func (*DatabaseDetailsResponse_Grant) Size 

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

func (*DatabaseDetailsResponse_Grant) String 

func (m *DatabaseDetailsResponse_Grant) String() string

func (*DatabaseDetailsResponse_Grant) Unmarshal 

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

type DatabasesRequest 

type DatabasesRequest struct {
}

DatabasesRequest requests a list of databases.

func (*DatabasesRequest) Descriptor 

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

func (*DatabasesRequest) Marshal 

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

func (*DatabasesRequest) MarshalTo 

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

func (*DatabasesRequest) ProtoMessage 

func (*DatabasesRequest) ProtoMessage()

func (*DatabasesRequest) Reset 

func (m *DatabasesRequest) Reset()

func (*DatabasesRequest) Size 

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

func (*DatabasesRequest) String 

func (m *DatabasesRequest) String() string

func (*DatabasesRequest) Unmarshal 

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

type DatabasesResponse 

type DatabasesResponse struct {
	Databases []string `protobuf:"bytes,1,rep,name=databases" json:"databases,omitempty"`
}

DatabasesResponse contains a list of databases.

func (*DatabasesResponse) Descriptor 

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

func (*DatabasesResponse) Marshal 

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

func (*DatabasesResponse) MarshalTo 

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

func (*DatabasesResponse) ProtoMessage 

func (*DatabasesResponse) ProtoMessage()

func (*DatabasesResponse) Reset 

func (m *DatabasesResponse) Reset()

func (*DatabasesResponse) Size 

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

func (*DatabasesResponse) String 

func (m *DatabasesResponse) String() string

func (*DatabasesResponse) Unmarshal 

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

type DecommissionRequest 

type DecommissionRequest struct {
	NodeIDs         []github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 144-byte string literal not displayed */
	Decommissioning bool                                                  `protobuf:"varint,2,opt,name=decommissioning,proto3" json:"decommissioning,omitempty"`
}

DecommissionRequest requests the server to set the Decommissioning flag on all nodes specified by 'node_id' to the value of 'decommissioning'.

If no 'node_id' is given, targets the recipient node.

func (*DecommissionRequest) Descriptor 

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

func (*DecommissionRequest) Marshal 

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

func (*DecommissionRequest) MarshalTo 

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

func (*DecommissionRequest) ProtoMessage 

func (*DecommissionRequest) ProtoMessage()

func (*DecommissionRequest) Reset 

func (m *DecommissionRequest) Reset()

func (*DecommissionRequest) Size 

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

func (*DecommissionRequest) String 

func (m *DecommissionRequest) String() string

func (*DecommissionRequest) Unmarshal 

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

type DecommissionStatusRequest 

type DecommissionStatusRequest struct {
	NodeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 144-byte string literal not displayed */
}

DecommissionStatusRequest requests the decommissioning status for the specified or, if none are specified, all nodes.

func (*DecommissionStatusRequest) Descriptor 

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

func (*DecommissionStatusRequest) Marshal 

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

func (*DecommissionStatusRequest) MarshalTo 

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

func (*DecommissionStatusRequest) ProtoMessage 

func (*DecommissionStatusRequest) ProtoMessage()

func (*DecommissionStatusRequest) Reset 

func (m *DecommissionStatusRequest) Reset()

func (*DecommissionStatusRequest) Size 

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

func (*DecommissionStatusRequest) String 

func (m *DecommissionStatusRequest) String() string

func (*DecommissionStatusRequest) Unmarshal 

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

type DecommissionStatusResponse 

type DecommissionStatusResponse struct {
	// Status of all affected nodes.
	Status []DecommissionStatusResponse_Status `protobuf:"bytes,2,rep,name=status" json:"status"`
}

DecommissionStatusResponse lists decommissioning statuses for a number of NodeIDs.

func (*DecommissionStatusResponse) Descriptor 

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

func (*DecommissionStatusResponse) Marshal 

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

func (*DecommissionStatusResponse) MarshalTo 

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

func (*DecommissionStatusResponse) ProtoMessage 

func (*DecommissionStatusResponse) ProtoMessage()

func (*DecommissionStatusResponse) Reset 

func (m *DecommissionStatusResponse) Reset()

func (*DecommissionStatusResponse) Size 

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

func (*DecommissionStatusResponse) String 

func (m *DecommissionStatusResponse) String() string

func (*DecommissionStatusResponse) Unmarshal 

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

type DecommissionStatusResponse_Status 

type DecommissionStatusResponse_Status struct {
	NodeID          github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */
	IsLive          bool                                                `protobuf:"varint,2,opt,name=is_live,json=isLive,proto3" json:"is_live,omitempty"`
	ReplicaCount    int64                                               `protobuf:"varint,3,opt,name=replica_count,json=replicaCount,proto3" json:"replica_count,omitempty"`
	Decommissioning bool                                                `protobuf:"varint,4,opt,name=decommissioning,proto3" json:"decommissioning,omitempty"`
	Draining        bool                                                `protobuf:"varint,5,opt,name=draining,proto3" json:"draining,omitempty"`
}

func (*DecommissionStatusResponse_Status) Descriptor 

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

func (*DecommissionStatusResponse_Status) Marshal 

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

func (*DecommissionStatusResponse_Status) MarshalTo 

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

func (*DecommissionStatusResponse_Status) ProtoMessage 

func (*DecommissionStatusResponse_Status) ProtoMessage()

func (*DecommissionStatusResponse_Status) Reset 

func (m *DecommissionStatusResponse_Status) Reset()

func (*DecommissionStatusResponse_Status) Size 

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

func (*DecommissionStatusResponse_Status) String 

func (m *DecommissionStatusResponse_Status) String() string

func (*DecommissionStatusResponse_Status) Unmarshal 

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

type DetailsRequest 

type DetailsRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	//
	// node_id is a string so that "local" can be used to specify that no
	// forwarding is necessary.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

DetailsRequest requests a nodes details.

func (*DetailsRequest) Descriptor 

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

func (*DetailsRequest) Marshal 

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

func (*DetailsRequest) MarshalTo 

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

func (*DetailsRequest) ProtoMessage 

func (*DetailsRequest) ProtoMessage()

func (*DetailsRequest) Reset 

func (m *DetailsRequest) Reset()

func (*DetailsRequest) Size 

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

func (*DetailsRequest) String 

func (m *DetailsRequest) String() string

func (*DetailsRequest) Unmarshal 

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

type DetailsResponse 

type DetailsResponse struct {
	NodeID    github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */
	Address   cockroach_util.UnresolvedAddr                       `protobuf:"bytes,2,opt,name=address" json:"address"`
	BuildInfo cockroach_build.Info                                `protobuf:"bytes,3,opt,name=build_info,json=buildInfo" json:"build_info"`
}

func (*DetailsResponse) Descriptor 

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

func (*DetailsResponse) Marshal 

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

func (*DetailsResponse) MarshalTo 

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

func (*DetailsResponse) ProtoMessage 

func (*DetailsResponse) ProtoMessage()

func (*DetailsResponse) Reset 

func (m *DetailsResponse) Reset()

func (*DetailsResponse) Size 

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

func (*DetailsResponse) String 

func (m *DetailsResponse) String() string

func (*DetailsResponse) Unmarshal 

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

type DrainMode 

type DrainMode int32
const (
	// CLIENT instructs the server to refuse new SQL clients.
	// TODO(tschottdorf): also terminate existing clients in a graceful manner.
	DrainMode_CLIENT DrainMode = 0
	// LEADERSHIP instructs the server to gracefully let all its Replicas'
	// range leases expire.
	DrainMode_LEASES DrainMode = 1
)

func (DrainMode) EnumDescriptor 

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

func (DrainMode) String 

func (x DrainMode) String() string

type DrainRequest 

type DrainRequest struct {
	// These are actually of type DrainMode, but grpc-gateway does not support
	// proxying enum fields (yet:
	// https://github.com/grpc-ecosystem/grpc-gateway/issues/5) and it fails in
	// pretty dramatic ways (panics the server).
	On  []int32 `protobuf:"varint,1,rep,packed,name=on" json:"on,omitempty"`
	Off []int32 `protobuf:"varint,2,rep,packed,name=off" json:"off,omitempty"`
	// When true, terminates the process after the given drain modes have been
	// activated.
	Shutdown bool `protobuf:"varint,3,opt,name=shutdown,proto3" json:"shutdown,omitempty"`
}

DrainRequest requests the server to enter the specified draining mode. The server first deactivates all the modes specified in 'off' and then activates all those in 'on'.

func (*DrainRequest) Descriptor 

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

func (*DrainRequest) Marshal 

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

func (*DrainRequest) MarshalTo 

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

func (*DrainRequest) ProtoMessage 

func (*DrainRequest) ProtoMessage()

func (*DrainRequest) Reset 

func (m *DrainRequest) Reset()

func (*DrainRequest) Size 

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

func (*DrainRequest) String 

func (m *DrainRequest) String() string

func (*DrainRequest) Unmarshal 

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

type DrainResponse 

type DrainResponse struct {
	On []int32 `protobuf:"varint,1,rep,packed,name=on" json:"on,omitempty"`
}

DrainResponse is the response to a successful DrainRequest and lists the modes which are activated after having processing the request.

func (*DrainResponse) Descriptor 

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

func (*DrainResponse) Marshal 

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

func (*DrainResponse) MarshalTo 

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

func (*DrainResponse) ProtoMessage 

func (*DrainResponse) ProtoMessage()

func (*DrainResponse) Reset 

func (m *DrainResponse) Reset()

func (*DrainResponse) Size 

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

func (*DrainResponse) String 

func (m *DrainResponse) String() string

func (*DrainResponse) Unmarshal 

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

type EventsRequest 

type EventsRequest struct {
	Type     string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	TargetId int64  `protobuf:"varint,2,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	// limit is the total number of results that are retrieved by the query. If
	// this is omitted or set to 0, the default maximum number of results are
	// returned. When set to > 0, at most only that number of results are
	// returned. When set to < 0, an unlimited number of results are returned.
	Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
}

EventsRequest is a request for event log entries, optionally filtered by the specified event type and/or target_id.

func (*EventsRequest) Descriptor 

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

func (*EventsRequest) Marshal 

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

func (*EventsRequest) MarshalTo 

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

func (*EventsRequest) ProtoMessage 

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) Reset 

func (m *EventsRequest) Reset()

func (*EventsRequest) Size 

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

func (*EventsRequest) String 

func (m *EventsRequest) String() string

func (*EventsRequest) Unmarshal 

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

type EventsResponse 

type EventsResponse struct {
	Events []EventsResponse_Event `protobuf:"bytes,1,rep,name=events" json:"events"`
}

EventsResponse contains a set of event log entries. This is always limited to the latest N entries (N is enforced in the associated endpoint).

func (*EventsResponse) Descriptor 

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

func (*EventsResponse) Marshal 

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

func (*EventsResponse) MarshalTo 

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

func (*EventsResponse) ProtoMessage 

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) Reset 

func (m *EventsResponse) Reset()

func (*EventsResponse) Size 

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

func (*EventsResponse) String 

func (m *EventsResponse) String() string

func (*EventsResponse) Unmarshal 

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

type EventsResponse_Event 

type EventsResponse_Event struct {
	// timestamp is the time at which the event occurred.
	Timestamp time.Time `protobuf:"bytes,1,opt,name=timestamp,stdtime" json:"timestamp"`
	// event_type is the type of the event (e.g. "create_table", "drop_table".
	EventType string `protobuf:"bytes,2,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	// target_id is the target for this event.
	TargetID int64 `protobuf:"varint,3,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	// reporting_id is the reporting ID for this event.
	ReportingID int64 `protobuf:"varint,4,opt,name=reporting_id,json=reportingId,proto3" json:"reporting_id,omitempty"`
	// info has more detailed information for the event. The contents vary
	// depending on the event.
	Info string `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"`
	// unique_id is a unique identifier for this event.
	UniqueID []byte `protobuf:"bytes,6,opt,name=unique_id,json=uniqueId,proto3" json:"unique_id,omitempty"`
}

func (*EventsResponse_Event) Descriptor 

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

func (*EventsResponse_Event) Marshal 

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

func (*EventsResponse_Event) MarshalTo 

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

func (*EventsResponse_Event) ProtoMessage 

func (*EventsResponse_Event) ProtoMessage()

func (*EventsResponse_Event) Reset 

func (m *EventsResponse_Event) Reset()

func (*EventsResponse_Event) Size 

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

func (*EventsResponse_Event) String 

func (m *EventsResponse_Event) String() string

func (*EventsResponse_Event) Unmarshal 

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

type GetUIDataRequest 

type GetUIDataRequest struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
}

GETUIDataRequest requests the values for the given keys from the system.ui table.

func (*GetUIDataRequest) Descriptor 

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

func (*GetUIDataRequest) Marshal 

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

func (*GetUIDataRequest) MarshalTo 

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

func (*GetUIDataRequest) ProtoMessage 

func (*GetUIDataRequest) ProtoMessage()

func (*GetUIDataRequest) Reset 

func (m *GetUIDataRequest) Reset()

func (*GetUIDataRequest) Size 

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

func (*GetUIDataRequest) String 

func (m *GetUIDataRequest) String() string

func (*GetUIDataRequest) Unmarshal 

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

type GetUIDataResponse 

type GetUIDataResponse struct {
	// key_values maps keys to their retrieved values. If this doesn't contain a
	// a requested key, that key was not found.
	KeyValues map[string]GetUIDataResponse_Value `` /* 152-byte string literal not displayed */
}

GetUIDataResponse contains the requested values and the times at which the values were last updated.

func (*GetUIDataResponse) Descriptor 

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

func (*GetUIDataResponse) Marshal 

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

func (*GetUIDataResponse) MarshalTo 

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

func (*GetUIDataResponse) ProtoMessage 

func (*GetUIDataResponse) ProtoMessage()

func (*GetUIDataResponse) Reset 

func (m *GetUIDataResponse) Reset()

func (*GetUIDataResponse) Size 

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

func (*GetUIDataResponse) String 

func (m *GetUIDataResponse) String() string

func (*GetUIDataResponse) Unmarshal 

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

type GetUIDataResponse_Value 

type GetUIDataResponse_Value struct {
	// value is the value of the requested key.
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// last_updated is the time at which the value was last updated.
	LastUpdated time.Time `protobuf:"bytes,2,opt,name=last_updated,json=lastUpdated,stdtime" json:"last_updated"`
}

func (*GetUIDataResponse_Value) Descriptor 

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

func (*GetUIDataResponse_Value) Marshal 

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

func (*GetUIDataResponse_Value) MarshalTo 

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

func (*GetUIDataResponse_Value) ProtoMessage 

func (*GetUIDataResponse_Value) ProtoMessage()

func (*GetUIDataResponse_Value) Reset 

func (m *GetUIDataResponse_Value) Reset()

func (*GetUIDataResponse_Value) Size 

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

func (*GetUIDataResponse_Value) String 

func (m *GetUIDataResponse_Value) String() string

func (*GetUIDataResponse_Value) Unmarshal 

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

type GossipRequest 

type GossipRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	//
	// node_id is a string so that "local" can be used to specify that no
	// forwarding is necessary.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

func (*GossipRequest) Descriptor 

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

func (*GossipRequest) Marshal 

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

func (*GossipRequest) MarshalTo 

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

func (*GossipRequest) ProtoMessage 

func (*GossipRequest) ProtoMessage()

func (*GossipRequest) Reset 

func (m *GossipRequest) Reset()

func (*GossipRequest) Size 

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

func (*GossipRequest) String 

func (m *GossipRequest) String() string

func (*GossipRequest) Unmarshal 

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

type HealthRequest 

type HealthRequest struct {
}

HealthRequest inquires whether the addressed node is healthy.

func (*HealthRequest) Descriptor 

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

func (*HealthRequest) Marshal 

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

func (*HealthRequest) MarshalTo 

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

func (*HealthRequest) ProtoMessage 

func (*HealthRequest) ProtoMessage()

func (*HealthRequest) Reset 

func (m *HealthRequest) Reset()

func (*HealthRequest) Size 

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

func (*HealthRequest) String 

func (m *HealthRequest) String() string

func (*HealthRequest) Unmarshal 

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

type HealthResponse 

type HealthResponse struct {
}

HealthResponse is the response to HealthRequest. It currently does not contain any information. The request fails however if the node is not live. TODO(tschottdorf): Should it contain information, and if so, what?

func (*HealthResponse) Descriptor 

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

func (*HealthResponse) Marshal 

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

func (*HealthResponse) MarshalTo 

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

func (*HealthResponse) ProtoMessage 

func (*HealthResponse) ProtoMessage()

func (*HealthResponse) Reset 

func (m *HealthResponse) Reset()

func (*HealthResponse) Size 

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

func (*HealthResponse) String 

func (m *HealthResponse) String() string

func (*HealthResponse) Unmarshal 

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

type InitClient 

type InitClient interface {
	// Bootstrap an uninitialized cluster.
	Bootstrap(ctx context.Context, in *BootstrapRequest, opts ...grpc.CallOption) (*BootstrapResponse, error)
}

func NewInitClient 

func NewInitClient(cc *grpc.ClientConn) InitClient

type InitServer 

type InitServer interface {
	// Bootstrap an uninitialized cluster.
	Bootstrap(context.Context, *BootstrapRequest) (*BootstrapResponse, error)
}

type JSONResponse 

type JSONResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*JSONResponse) Descriptor 

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

func (*JSONResponse) Marshal 

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

func (*JSONResponse) MarshalTo 

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

func (*JSONResponse) ProtoMessage 

func (*JSONResponse) ProtoMessage()

func (*JSONResponse) Reset 

func (m *JSONResponse) Reset()

func (*JSONResponse) Size 

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

func (*JSONResponse) String 

func (m *JSONResponse) String() string

func (*JSONResponse) Unmarshal 

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

type JobsRequest 

type JobsRequest struct {
	Limit  int32                   `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Status string                  `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Type   cockroach_sql_jobs.Type `protobuf:"varint,3,opt,name=type,proto3,enum=cockroach.sql.jobs.Type" json:"type,omitempty"`
}

JobsRequest requests system job information of the given status and type.

func (*JobsRequest) Descriptor 

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

func (*JobsRequest) Marshal 

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

func (*JobsRequest) MarshalTo 

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

func (*JobsRequest) ProtoMessage 

func (*JobsRequest) ProtoMessage()

func (*JobsRequest) Reset 

func (m *JobsRequest) Reset()

func (*JobsRequest) Size 

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

func (*JobsRequest) String 

func (m *JobsRequest) String() string

func (*JobsRequest) Unmarshal 

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

type JobsResponse 

type JobsResponse struct {
	Jobs []JobsResponse_Job `protobuf:"bytes,1,rep,name=jobs" json:"jobs"`
}

JobsResponse contains the job record for each matching job.

func (*JobsResponse) Descriptor 

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

func (*JobsResponse) Marshal 

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

func (*JobsResponse) MarshalTo 

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

func (*JobsResponse) ProtoMessage 

func (*JobsResponse) ProtoMessage()

func (*JobsResponse) Reset 

func (m *JobsResponse) Reset()

func (*JobsResponse) Size 

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

func (*JobsResponse) String 

func (m *JobsResponse) String() string

func (*JobsResponse) Unmarshal 

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

type JobsResponse_Job 

type JobsResponse_Job struct {
	ID                int64                                                 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type              string                                                `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Description       string                                                `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Username          string                                                `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	DescriptorIDs     []github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID `` /* 162-byte string literal not displayed */
	Status            string                                                `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	Created           *time.Time                                            `protobuf:"bytes,7,opt,name=created,stdtime" json:"created,omitempty"`
	Started           *time.Time                                            `protobuf:"bytes,8,opt,name=started,stdtime" json:"started,omitempty"`
	Finished          *time.Time                                            `protobuf:"bytes,9,opt,name=finished,stdtime" json:"finished,omitempty"`
	Modified          *time.Time                                            `protobuf:"bytes,10,opt,name=modified,stdtime" json:"modified,omitempty"`
	FractionCompleted float32                                               `protobuf:"fixed32,11,opt,name=fraction_completed,json=fractionCompleted,proto3" json:"fraction_completed,omitempty"`
	Error             string                                                `protobuf:"bytes,12,opt,name=error,proto3" json:"error,omitempty"`
}

func (*JobsResponse_Job) Descriptor 

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

func (*JobsResponse_Job) Marshal 

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

func (*JobsResponse_Job) MarshalTo 

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

func (*JobsResponse_Job) ProtoMessage 

func (*JobsResponse_Job) ProtoMessage()

func (*JobsResponse_Job) Reset 

func (m *JobsResponse_Job) Reset()

func (*JobsResponse_Job) Size 

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

func (*JobsResponse_Job) String 

func (m *JobsResponse_Job) String() string

func (*JobsResponse_Job) Unmarshal 

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

type ListSessionsError 

type ListSessionsError struct {
	// ID of node that was being contacted when this error occurred
	NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */
	// Error message.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

An error wrapper object for ListSessionsResponse.

func (*ListSessionsError) Descriptor 

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

func (*ListSessionsError) Marshal 

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

func (*ListSessionsError) MarshalTo 

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

func (*ListSessionsError) ProtoMessage 

func (*ListSessionsError) ProtoMessage()

func (*ListSessionsError) Reset 

func (m *ListSessionsError) Reset()

func (*ListSessionsError) Size 

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

func (*ListSessionsError) String 

func (m *ListSessionsError) String() string

func (*ListSessionsError) Unmarshal 

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

type ListSessionsRequest 

type ListSessionsRequest struct {
	// Username of the user making this request.
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
}

Request object for ListSessions and ListLocalSessions.

func (*ListSessionsRequest) Descriptor 

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

func (*ListSessionsRequest) Marshal 

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

func (*ListSessionsRequest) MarshalTo 

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

func (*ListSessionsRequest) ProtoMessage 

func (*ListSessionsRequest) ProtoMessage()

func (*ListSessionsRequest) Reset 

func (m *ListSessionsRequest) Reset()

func (*ListSessionsRequest) Size 

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

func (*ListSessionsRequest) String 

func (m *ListSessionsRequest) String() string

func (*ListSessionsRequest) Unmarshal 

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

type ListSessionsResponse 

type ListSessionsResponse struct {
	// A list of sessions on this node or cluster.
	Sessions []Session `protobuf:"bytes,1,rep,name=sessions" json:"sessions"`
	// Any errors that occurred during fan-out calls to other nodes.
	Errors []ListSessionsError `protobuf:"bytes,2,rep,name=errors" json:"errors"`
}

Response object for ListSessions and ListLocalSessions.

func (*ListSessionsResponse) Descriptor 

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

func (*ListSessionsResponse) Marshal 

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

func (*ListSessionsResponse) MarshalTo 

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

func (*ListSessionsResponse) ProtoMessage 

func (*ListSessionsResponse) ProtoMessage()

func (*ListSessionsResponse) Reset 

func (m *ListSessionsResponse) Reset()

func (*ListSessionsResponse) Size 

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

func (*ListSessionsResponse) String 

func (m *ListSessionsResponse) String() string

func (*ListSessionsResponse) Unmarshal 

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

type LivenessRequest 

type LivenessRequest struct {
}

LivenessRequest requests liveness data for all nodes on the cluster.

func (*LivenessRequest) Descriptor 

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

func (*LivenessRequest) Marshal 

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

func (*LivenessRequest) MarshalTo 

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

func (*LivenessRequest) ProtoMessage 

func (*LivenessRequest) ProtoMessage()

func (*LivenessRequest) Reset 

func (m *LivenessRequest) Reset()

func (*LivenessRequest) Size 

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

func (*LivenessRequest) String 

func (m *LivenessRequest) String() string

func (*LivenessRequest) Unmarshal 

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

type LivenessResponse 

type LivenessResponse struct {
	Livenesses []cockroach_storage.Liveness `protobuf:"bytes,1,rep,name=livenesses" json:"livenesses"`
}

LivenessResponse contains the liveness status of each node on the cluster.

func (*LivenessResponse) Descriptor 

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

func (*LivenessResponse) Marshal 

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

func (*LivenessResponse) MarshalTo 

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

func (*LivenessResponse) ProtoMessage 

func (*LivenessResponse) ProtoMessage()

func (*LivenessResponse) Reset 

func (m *LivenessResponse) Reset()

func (*LivenessResponse) Size 

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

func (*LivenessResponse) String 

func (m *LivenessResponse) String() string

func (*LivenessResponse) Unmarshal 

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

type LogEntriesResponse 

type LogEntriesResponse struct {
	Entries []cockroach_util_log.Entry `protobuf:"bytes,1,rep,name=entries" json:"entries"`
}

func (*LogEntriesResponse) Descriptor 

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

func (*LogEntriesResponse) Marshal 

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

func (*LogEntriesResponse) MarshalTo 

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

func (*LogEntriesResponse) ProtoMessage 

func (*LogEntriesResponse) ProtoMessage()

func (*LogEntriesResponse) Reset 

func (m *LogEntriesResponse) Reset()

func (*LogEntriesResponse) Size 

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

func (*LogEntriesResponse) String 

func (m *LogEntriesResponse) String() string

func (*LogEntriesResponse) Unmarshal 

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

type LogFileRequest 

type LogFileRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	//
	// node_id is a string so that "local" can be used to specify that no
	// forwarding is necessary.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	File   string `protobuf:"bytes,2,opt,name=file,proto3" json:"file,omitempty"`
}

func (*LogFileRequest) Descriptor 

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

func (*LogFileRequest) Marshal 

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

func (*LogFileRequest) MarshalTo 

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

func (*LogFileRequest) ProtoMessage 

func (*LogFileRequest) ProtoMessage()

func (*LogFileRequest) Reset 

func (m *LogFileRequest) Reset()

func (*LogFileRequest) Size 

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

func (*LogFileRequest) String 

func (m *LogFileRequest) String() string

func (*LogFileRequest) Unmarshal 

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

type LogFilesListRequest 

type LogFilesListRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	//
	// node_id is a string so that "local" can be used to specify that no
	// forwarding is necessary.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

func (*LogFilesListRequest) Descriptor 

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

func (*LogFilesListRequest) Marshal 

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

func (*LogFilesListRequest) MarshalTo 

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

func (*LogFilesListRequest) ProtoMessage 

func (*LogFilesListRequest) ProtoMessage()

func (*LogFilesListRequest) Reset 

func (m *LogFilesListRequest) Reset()

func (*LogFilesListRequest) Size 

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

func (*LogFilesListRequest) String 

func (m *LogFilesListRequest) String() string

func (*LogFilesListRequest) Unmarshal 

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

type LogFilesListResponse 

type LogFilesListResponse struct {
	Files []cockroach_util_log.FileInfo `protobuf:"bytes,1,rep,name=files" json:"files"`
}

func (*LogFilesListResponse) Descriptor 

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

func (*LogFilesListResponse) Marshal 

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

func (*LogFilesListResponse) MarshalTo 

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

func (*LogFilesListResponse) ProtoMessage 

func (*LogFilesListResponse) ProtoMessage()

func (*LogFilesListResponse) Reset 

func (m *LogFilesListResponse) Reset()

func (*LogFilesListResponse) Size 

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

func (*LogFilesListResponse) String 

func (m *LogFilesListResponse) String() string

func (*LogFilesListResponse) Unmarshal 

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

type LogsRequest 

type LogsRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	//
	// node_id is a string so that "local" can be used to specify that no
	// forwarding is necessary.
	NodeId    string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Level     string `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty"`
	StartTime string `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   string `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Max       string `protobuf:"bytes,5,opt,name=max,proto3" json:"max,omitempty"`
	Pattern   string `protobuf:"bytes,6,opt,name=pattern,proto3" json:"pattern,omitempty"`
}

func (*LogsRequest) Descriptor 

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

func (*LogsRequest) Marshal 

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

func (*LogsRequest) MarshalTo 

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

func (*LogsRequest) ProtoMessage 

func (*LogsRequest) ProtoMessage()

func (*LogsRequest) Reset 

func (m *LogsRequest) Reset()

func (*LogsRequest) Size 

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

func (*LogsRequest) String 

func (m *LogsRequest) String() string

func (*LogsRequest) Unmarshal 

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

type MetricsRequest 

type MetricsRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	//
	// node_id is a string so that "local" can be used to specify that no
	// forwarding is necessary.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

func (*MetricsRequest) Descriptor 

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

func (*MetricsRequest) Marshal 

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

func (*MetricsRequest) MarshalTo 

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

func (*MetricsRequest) ProtoMessage 

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) Reset 

func (m *MetricsRequest) Reset()

func (*MetricsRequest) Size 

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

func (*MetricsRequest) String 

func (m *MetricsRequest) String() string

func (*MetricsRequest) Unmarshal 

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

type NodeRequest 

type NodeRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	//
	// node_id is a string so that "local" can be used to specify that no
	// forwarding is necessary.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

func (*NodeRequest) Descriptor 

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

func (*NodeRequest) Marshal 

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

func (*NodeRequest) MarshalTo 

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

func (*NodeRequest) ProtoMessage 

func (*NodeRequest) ProtoMessage()

func (*NodeRequest) Reset 

func (m *NodeRequest) Reset()

func (*NodeRequest) Size 

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

func (*NodeRequest) String 

func (m *NodeRequest) String() string

func (*NodeRequest) Unmarshal 

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

type NodesRequest 

type NodesRequest struct {
}

func (*NodesRequest) Descriptor 

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

func (*NodesRequest) Marshal 

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

func (*NodesRequest) MarshalTo 

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

func (*NodesRequest) ProtoMessage 

func (*NodesRequest) ProtoMessage()

func (*NodesRequest) Reset 

func (m *NodesRequest) Reset()

func (*NodesRequest) Size 

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

func (*NodesRequest) String 

func (m *NodesRequest) String() string

func (*NodesRequest) Unmarshal 

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

type NodesResponse 

type NodesResponse struct {
	Nodes []cockroach_server_status.NodeStatus `protobuf:"bytes,1,rep,name=nodes" json:"nodes"`
}

func (*NodesResponse) Descriptor 

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

func (*NodesResponse) Marshal 

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

func (*NodesResponse) MarshalTo 

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

func (*NodesResponse) ProtoMessage 

func (*NodesResponse) ProtoMessage()

func (*NodesResponse) Reset 

func (m *NodesResponse) Reset()

func (*NodesResponse) Size 

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

func (*NodesResponse) String 

func (m *NodesResponse) String() string

func (*NodesResponse) Unmarshal 

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

type PrettySpan 

type PrettySpan struct {
	StartKey string `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   string `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
}

func (*PrettySpan) Descriptor 

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

func (*PrettySpan) Equal 

func (this *PrettySpan) Equal(that interface{}) bool

func (*PrettySpan) Marshal 

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

func (*PrettySpan) MarshalTo 

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

func (*PrettySpan) ProtoMessage 

func (*PrettySpan) ProtoMessage()

func (*PrettySpan) Reset 

func (m *PrettySpan) Reset()

func (*PrettySpan) Size 

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

func (*PrettySpan) String 

func (m *PrettySpan) String() string

func (*PrettySpan) Unmarshal 

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

type ProblemRangesRequest 

type ProblemRangesRequest struct {
	NodeID string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

func (*ProblemRangesRequest) Descriptor 

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

func (*ProblemRangesRequest) Marshal 

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

func (*ProblemRangesRequest) MarshalTo 

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

func (*ProblemRangesRequest) ProtoMessage 

func (*ProblemRangesRequest) ProtoMessage()

func (*ProblemRangesRequest) Reset 

func (m *ProblemRangesRequest) Reset()

func (*ProblemRangesRequest) Size 

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

func (*ProblemRangesRequest) String 

func (m *ProblemRangesRequest) String() string

func (*ProblemRangesRequest) Unmarshal 

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

type ProblemRangesResponse 

type ProblemRangesResponse struct {
	// NodeID is the node that submitted all the requests.
	NodeID           github_com_cockroachdb_cockroach_pkg_roachpb.NodeID                                        `` /* 141-byte string literal not displayed */
	ProblemsByNodeID map[github_com_cockroachdb_cockroach_pkg_roachpb.NodeID]ProblemRangesResponse_NodeProblems `` /* 238-byte string literal not displayed */
}

func (*ProblemRangesResponse) Descriptor 

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

func (*ProblemRangesResponse) Marshal 

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

func (*ProblemRangesResponse) MarshalTo 

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

func (*ProblemRangesResponse) ProtoMessage 

func (*ProblemRangesResponse) ProtoMessage()

func (*ProblemRangesResponse) Reset 

func (m *ProblemRangesResponse) Reset()

func (*ProblemRangesResponse) Size 

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

func (*ProblemRangesResponse) String 

func (m *ProblemRangesResponse) String() string

func (*ProblemRangesResponse) Unmarshal 

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

type ProblemRangesResponse_NodeProblems 

type ProblemRangesResponse_NodeProblems struct {
	ErrorMessage                     string                                                 `protobuf:"bytes,1,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	UnavailableRangeIDs              []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 183-byte string literal not displayed */
	RaftLeaderNotLeaseHolderRangeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 230-byte string literal not displayed */
	NoRaftLeaderRangeIDs             []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 190-byte string literal not displayed */
	NoLeaseRangeIDs                  []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 173-byte string literal not displayed */
	UnderreplicatedRangeIDs          []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 195-byte string literal not displayed */
}

func (*ProblemRangesResponse_NodeProblems) Descriptor 

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

func (*ProblemRangesResponse_NodeProblems) Marshal 

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

func (*ProblemRangesResponse_NodeProblems) MarshalTo 

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

func (*ProblemRangesResponse_NodeProblems) ProtoMessage 

func (*ProblemRangesResponse_NodeProblems) ProtoMessage()

func (*ProblemRangesResponse_NodeProblems) Reset 

func (m *ProblemRangesResponse_NodeProblems) Reset()

func (*ProblemRangesResponse_NodeProblems) Size 

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

func (*ProblemRangesResponse_NodeProblems) String 

func (m *ProblemRangesResponse_NodeProblems) String() string

func (*ProblemRangesResponse_NodeProblems) Unmarshal 

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

type QueryPlanRequest 

type QueryPlanRequest struct {
	// query is the SQL query string.
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
}

QueryPlanRequest requests the query plans for a SQL string.

func (*QueryPlanRequest) Descriptor 

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

func (*QueryPlanRequest) Marshal 

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

func (*QueryPlanRequest) MarshalTo 

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

func (*QueryPlanRequest) ProtoMessage 

func (*QueryPlanRequest) ProtoMessage()

func (*QueryPlanRequest) Reset 

func (m *QueryPlanRequest) Reset()

func (*QueryPlanRequest) Size 

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

func (*QueryPlanRequest) String 

func (m *QueryPlanRequest) String() string

func (*QueryPlanRequest) Unmarshal 

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

type QueryPlanResponse 

type QueryPlanResponse struct {
	DistSQLPhysicalQueryPlan string `` /* 137-byte string literal not displayed */
}

QueryPlanResponse contains the query plans for a SQL string (currently only the distsql physical query plan).

func (*QueryPlanResponse) Descriptor 

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

func (*QueryPlanResponse) Marshal 

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

func (*QueryPlanResponse) MarshalTo 

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

func (*QueryPlanResponse) ProtoMessage 

func (*QueryPlanResponse) ProtoMessage()

func (*QueryPlanResponse) Reset 

func (m *QueryPlanResponse) Reset()

func (*QueryPlanResponse) Size 

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

func (*QueryPlanResponse) String 

func (m *QueryPlanResponse) String() string

func (*QueryPlanResponse) Unmarshal 

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

type RaftDebugRequest 

type RaftDebugRequest struct {
	RangeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 148-byte string literal not displayed */
}

func (*RaftDebugRequest) Descriptor 

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

func (*RaftDebugRequest) Marshal 

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

func (*RaftDebugRequest) MarshalTo 

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

func (*RaftDebugRequest) ProtoMessage 

func (*RaftDebugRequest) ProtoMessage()

func (*RaftDebugRequest) Reset 

func (m *RaftDebugRequest) Reset()

func (*RaftDebugRequest) Size 

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

func (*RaftDebugRequest) String 

func (m *RaftDebugRequest) String() string

func (*RaftDebugRequest) Unmarshal 

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

type RaftDebugResponse 

type RaftDebugResponse struct {
	Ranges map[github_com_cockroachdb_cockroach_pkg_roachpb.RangeID]RaftRangeStatus `` /* 191-byte string literal not displayed */
	Errors []RaftRangeError                                                         `protobuf:"bytes,2,rep,name=errors" json:"errors"`
}

func (*RaftDebugResponse) Descriptor 

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

func (*RaftDebugResponse) Marshal 

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

func (*RaftDebugResponse) MarshalTo 

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

func (*RaftDebugResponse) ProtoMessage 

func (*RaftDebugResponse) ProtoMessage()

func (*RaftDebugResponse) Reset 

func (m *RaftDebugResponse) Reset()

func (*RaftDebugResponse) Size 

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

func (*RaftDebugResponse) String 

func (m *RaftDebugResponse) String() string

func (*RaftDebugResponse) Unmarshal 

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

type RaftRangeError 

type RaftRangeError struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

func (*RaftRangeError) Descriptor 

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

func (*RaftRangeError) Marshal 

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

func (*RaftRangeError) MarshalTo 

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

func (*RaftRangeError) ProtoMessage 

func (*RaftRangeError) ProtoMessage()

func (*RaftRangeError) Reset 

func (m *RaftRangeError) Reset()

func (*RaftRangeError) Size 

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

func (*RaftRangeError) String 

func (m *RaftRangeError) String() string

func (*RaftRangeError) Unmarshal 

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

type RaftRangeNode 

type RaftRangeNode struct {
	NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */
	Range  RangeInfo                                           `protobuf:"bytes,2,opt,name=range" json:"range"`
}

func (*RaftRangeNode) Descriptor 

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

func (*RaftRangeNode) Marshal 

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

func (*RaftRangeNode) MarshalTo 

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

func (*RaftRangeNode) ProtoMessage 

func (*RaftRangeNode) ProtoMessage()

func (*RaftRangeNode) Reset 

func (m *RaftRangeNode) Reset()

func (*RaftRangeNode) Size 

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

func (*RaftRangeNode) String 

func (m *RaftRangeNode) String() string

func (*RaftRangeNode) Unmarshal 

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

type RaftRangeStatus 

type RaftRangeStatus struct {
	RangeID github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 145-byte string literal not displayed */
	Errors  []RaftRangeError                                     `protobuf:"bytes,2,rep,name=errors" json:"errors"`
	Nodes   []RaftRangeNode                                      `protobuf:"bytes,3,rep,name=nodes" json:"nodes"`
}

func (*RaftRangeStatus) Descriptor 

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

func (*RaftRangeStatus) Marshal 

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

func (*RaftRangeStatus) MarshalTo 

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

func (*RaftRangeStatus) ProtoMessage 

func (*RaftRangeStatus) ProtoMessage()

func (*RaftRangeStatus) Reset 

func (m *RaftRangeStatus) Reset()

func (*RaftRangeStatus) Size 

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

func (*RaftRangeStatus) String 

func (m *RaftRangeStatus) String() string

func (*RaftRangeStatus) Unmarshal 

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

type RaftState 

type RaftState struct {
	ReplicaID uint64           `protobuf:"varint,1,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"`
	HardState raftpb.HardState `protobuf:"bytes,2,opt,name=hard_state,json=hardState" json:"hard_state"`
	// Lead is part of Raft's SoftState.
	Lead uint64 `protobuf:"varint,3,opt,name=lead,proto3" json:"lead,omitempty"`
	// State is part of Raft's SoftState.
	// It's not an enum because this is primarily for ui consumption and there
	// are issues associated with them.
	State    string                        `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	Applied  uint64                        `protobuf:"varint,5,opt,name=applied,proto3" json:"applied,omitempty"`
	Progress map[uint64]RaftState_Progress `` /* 134-byte string literal not displayed */
}

RaftState gives internal details about a Raft group's state. Closely mirrors the upstream definitions in github.com/coreos/etcd/raft.

func (*RaftState) Descriptor 

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

func (*RaftState) Marshal 

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

func (*RaftState) MarshalTo 

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

func (*RaftState) ProtoMessage 

func (*RaftState) ProtoMessage()

func (*RaftState) Reset 

func (m *RaftState) Reset()

func (*RaftState) Size 

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

func (*RaftState) String 

func (m *RaftState) String() string

func (*RaftState) Unmarshal 

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

type RaftState_Progress 

type RaftState_Progress struct {
	Match           uint64 `protobuf:"varint,1,opt,name=match,proto3" json:"match,omitempty"`
	Next            uint64 `protobuf:"varint,2,opt,name=next,proto3" json:"next,omitempty"`
	State           string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	Paused          bool   `protobuf:"varint,4,opt,name=paused,proto3" json:"paused,omitempty"`
	PendingSnapshot uint64 `protobuf:"varint,5,opt,name=pending_snapshot,json=pendingSnapshot,proto3" json:"pending_snapshot,omitempty"`
}

func (*RaftState_Progress) Descriptor 

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

func (*RaftState_Progress) Marshal 

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

func (*RaftState_Progress) MarshalTo 

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

func (*RaftState_Progress) ProtoMessage 

func (*RaftState_Progress) ProtoMessage()

func (*RaftState_Progress) Reset 

func (m *RaftState_Progress) Reset()

func (*RaftState_Progress) Size 

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

func (*RaftState_Progress) String 

func (m *RaftState_Progress) String() string

func (*RaftState_Progress) Unmarshal 

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

type RangeInfo 

type RangeInfo struct {
	Span          PrettySpan                                           `protobuf:"bytes,1,opt,name=span" json:"span"`
	RaftState     RaftState                                            `protobuf:"bytes,2,opt,name=raft_state,json=raftState" json:"raft_state"`
	State         cockroach_storage_storagebase.RangeInfo              `protobuf:"bytes,4,opt,name=state" json:"state"`
	SourceNodeID  github_com_cockroachdb_cockroach_pkg_roachpb.NodeID  `` /* 161-byte string literal not displayed */
	SourceStoreID github_com_cockroachdb_cockroach_pkg_roachpb.StoreID `` /* 165-byte string literal not displayed */
	ErrorMessage  string                                               `protobuf:"bytes,7,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	LeaseHistory  []cockroach_roachpb1.Lease                           `protobuf:"bytes,8,rep,name=lease_history,json=leaseHistory" json:"lease_history"`
	Problems      RangeProblems                                        `protobuf:"bytes,9,opt,name=problems" json:"problems"`
	Stats         RangeStatistics                                      `protobuf:"bytes,10,opt,name=stats" json:"stats"`
	CmdQLocal     CommandQueueMetrics                                  `protobuf:"bytes,11,opt,name=cmd_q_local,json=cmdQLocal" json:"cmd_q_local"`
	CmdQGlobal    CommandQueueMetrics                                  `protobuf:"bytes,12,opt,name=cmd_q_global,json=cmdQGlobal" json:"cmd_q_global"`
	LeaseStatus   cockroach_storage2.LeaseStatus                       `protobuf:"bytes,13,opt,name=lease_status,json=leaseStatus" json:"lease_status"`
	Quiescent     bool                                                 `protobuf:"varint,14,opt,name=quiescent,proto3" json:"quiescent,omitempty"`
}

func (*RangeInfo) Descriptor 

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

func (*RangeInfo) Marshal 

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

func (*RangeInfo) MarshalTo 

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

func (*RangeInfo) ProtoMessage 

func (*RangeInfo) ProtoMessage()

func (*RangeInfo) Reset 

func (m *RangeInfo) Reset()

func (*RangeInfo) Size 

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

func (*RangeInfo) String 

func (m *RangeInfo) String() string

func (*RangeInfo) Unmarshal 

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

type RangeLogRequest 

type RangeLogRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	// If RangeID is 0, returns range log history without filtering by range.
	RangeId int64 `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	// limit is the total number of results that are retrieved by the query. If
	// this is omitted or set to 0, the default maximum number of results are
	// returned. When set to > 0, at most only that number of results are
	// returned. When set to < 0, an unlimited number of results are returned.
	Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
}

RangeLogRequest request the history of a range from the range log.

func (*RangeLogRequest) Descriptor 

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

func (*RangeLogRequest) Marshal 

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

func (*RangeLogRequest) MarshalTo 

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

func (*RangeLogRequest) ProtoMessage 

func (*RangeLogRequest) ProtoMessage()

func (*RangeLogRequest) Reset 

func (m *RangeLogRequest) Reset()

func (*RangeLogRequest) Size 

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

func (*RangeLogRequest) String 

func (m *RangeLogRequest) String() string

func (*RangeLogRequest) Unmarshal 

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

type RangeLogResponse 

type RangeLogResponse struct {
	Events []RangeLogResponse_Event `protobuf:"bytes,2,rep,name=events" json:"events"`
}

RangeLogResponse contains a list of entries from the range log table.

func (*RangeLogResponse) Descriptor 

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

func (*RangeLogResponse) Marshal 

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

func (*RangeLogResponse) MarshalTo 

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

func (*RangeLogResponse) ProtoMessage 

func (*RangeLogResponse) ProtoMessage()

func (*RangeLogResponse) Reset 

func (m *RangeLogResponse) Reset()

func (*RangeLogResponse) Size 

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

func (*RangeLogResponse) String 

func (m *RangeLogResponse) String() string

func (*RangeLogResponse) Unmarshal 

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

type RangeLogResponse_Event 

type RangeLogResponse_Event struct {
	Event      cockroach_storage1.RangeLogEvent `protobuf:"bytes,1,opt,name=event" json:"event"`
	PrettyInfo RangeLogResponse_PrettyInfo      `protobuf:"bytes,2,opt,name=pretty_info,json=prettyInfo" json:"pretty_info"`
}

func (*RangeLogResponse_Event) Descriptor 

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

func (*RangeLogResponse_Event) Marshal 

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

func (*RangeLogResponse_Event) MarshalTo 

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

func (*RangeLogResponse_Event) ProtoMessage 

func (*RangeLogResponse_Event) ProtoMessage()

func (*RangeLogResponse_Event) Reset 

func (m *RangeLogResponse_Event) Reset()

func (*RangeLogResponse_Event) Size 

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

func (*RangeLogResponse_Event) String 

func (m *RangeLogResponse_Event) String() string

func (*RangeLogResponse_Event) Unmarshal 

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

type RangeLogResponse_PrettyInfo 

type RangeLogResponse_PrettyInfo struct {
	UpdatedDesc    string `protobuf:"bytes,1,opt,name=updated_desc,json=updatedDesc,proto3" json:"updated_desc,omitempty"`
	NewDesc        string `protobuf:"bytes,2,opt,name=new_desc,json=newDesc,proto3" json:"new_desc,omitempty"`
	AddedReplica   string `protobuf:"bytes,3,opt,name=added_replica,json=addedReplica,proto3" json:"added_replica,omitempty"`
	RemovedReplica string `protobuf:"bytes,4,opt,name=removed_replica,json=removedReplica,proto3" json:"removed_replica,omitempty"`
	Reason         string `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	Details        string `protobuf:"bytes,6,opt,name=details,proto3" json:"details,omitempty"`
}

To avoid porting the pretty printing of keys and descriptors to javascript, they will be precomputed on the serverside.

func (*RangeLogResponse_PrettyInfo) Descriptor 

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

func (*RangeLogResponse_PrettyInfo) Marshal 

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

func (*RangeLogResponse_PrettyInfo) MarshalTo 

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

func (*RangeLogResponse_PrettyInfo) ProtoMessage 

func (*RangeLogResponse_PrettyInfo) ProtoMessage()

func (*RangeLogResponse_PrettyInfo) Reset 

func (m *RangeLogResponse_PrettyInfo) Reset()

func (*RangeLogResponse_PrettyInfo) Size 

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

func (*RangeLogResponse_PrettyInfo) String 

func (m *RangeLogResponse_PrettyInfo) String() string

func (*RangeLogResponse_PrettyInfo) Unmarshal 

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

type RangeProblems 

type RangeProblems struct {
	Unavailable          bool `protobuf:"varint,1,opt,name=unavailable,proto3" json:"unavailable,omitempty"`
	LeaderNotLeaseHolder bool `` /* 126-byte string literal not displayed */
	NoRaftLeader         bool `protobuf:"varint,3,opt,name=no_raft_leader,json=noRaftLeader,proto3" json:"no_raft_leader,omitempty"`
	Underreplicated      bool `protobuf:"varint,4,opt,name=underreplicated,proto3" json:"underreplicated,omitempty"`
	NoLease              bool `protobuf:"varint,5,opt,name=no_lease,json=noLease,proto3" json:"no_lease,omitempty"`
}

func (*RangeProblems) Descriptor 

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

func (*RangeProblems) Marshal 

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

func (*RangeProblems) MarshalTo 

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

func (*RangeProblems) ProtoMessage 

func (*RangeProblems) ProtoMessage()

func (*RangeProblems) Reset 

func (m *RangeProblems) Reset()

func (*RangeProblems) Size 

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

func (*RangeProblems) String 

func (m *RangeProblems) String() string

func (*RangeProblems) Unmarshal 

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

type RangeRequest 

type RangeRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	RangeId int64 `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
}

func (*RangeRequest) Descriptor 

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

func (*RangeRequest) Marshal 

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

func (*RangeRequest) MarshalTo 

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

func (*RangeRequest) ProtoMessage 

func (*RangeRequest) ProtoMessage()

func (*RangeRequest) Reset 

func (m *RangeRequest) Reset()

func (*RangeRequest) Size 

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

func (*RangeRequest) String 

func (m *RangeRequest) String() string

func (*RangeRequest) Unmarshal 

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

type RangeResponse 

type RangeResponse struct {
	// NodeID is the node that submitted all the requests.
	NodeID            github_com_cockroachdb_cockroach_pkg_roachpb.NodeID                                `` /* 141-byte string literal not displayed */
	RangeID           github_com_cockroachdb_cockroach_pkg_roachpb.RangeID                               `` /* 145-byte string literal not displayed */
	ResponsesByNodeID map[github_com_cockroachdb_cockroach_pkg_roachpb.NodeID]RangeResponse_NodeResponse `` /* 241-byte string literal not displayed */
}

func (*RangeResponse) Descriptor 

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

func (*RangeResponse) Marshal 

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

func (*RangeResponse) MarshalTo 

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

func (*RangeResponse) ProtoMessage 

func (*RangeResponse) ProtoMessage()

func (*RangeResponse) Reset 

func (m *RangeResponse) Reset()

func (*RangeResponse) Size 

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

func (*RangeResponse) String 

func (m *RangeResponse) String() string

func (*RangeResponse) Unmarshal 

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

type RangeResponse_NodeResponse 

type RangeResponse_NodeResponse struct {
	Response     bool        `protobuf:"varint,1,opt,name=response,proto3" json:"response,omitempty"`
	ErrorMessage string      `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Infos        []RangeInfo `protobuf:"bytes,3,rep,name=infos" json:"infos"`
}

func (*RangeResponse_NodeResponse) Descriptor 

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

func (*RangeResponse_NodeResponse) Marshal 

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

func (*RangeResponse_NodeResponse) MarshalTo 

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

func (*RangeResponse_NodeResponse) ProtoMessage 

func (*RangeResponse_NodeResponse) ProtoMessage()

func (*RangeResponse_NodeResponse) Reset 

func (m *RangeResponse_NodeResponse) Reset()

func (*RangeResponse_NodeResponse) Size 

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

func (*RangeResponse_NodeResponse) String 

func (m *RangeResponse_NodeResponse) String() string

func (*RangeResponse_NodeResponse) Unmarshal 

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

type RangeStatistics 

type RangeStatistics struct {
	// Note that queries per second will only be known by the leaseholder.
	// All other replicas will report it as 0.
	QueriesPerSecond float64 `protobuf:"fixed64,1,opt,name=queries_per_second,json=queriesPerSecond,proto3" json:"queries_per_second,omitempty"`
	WritesPerSecond  float64 `protobuf:"fixed64,2,opt,name=writes_per_second,json=writesPerSecond,proto3" json:"writes_per_second,omitempty"`
}

func (*RangeStatistics) Descriptor 

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

func (*RangeStatistics) Marshal 

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

func (*RangeStatistics) MarshalTo 

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

func (*RangeStatistics) ProtoMessage 

func (*RangeStatistics) ProtoMessage()

func (*RangeStatistics) Reset 

func (m *RangeStatistics) Reset()

func (*RangeStatistics) Size 

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

func (*RangeStatistics) String 

func (m *RangeStatistics) String() string

func (*RangeStatistics) Unmarshal 

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

type RangesRequest 

type RangesRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	//
	// node_id is a string so that "local" can be used to specify that no
	// forwarding is necessary.
	NodeId   string                                                 `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	RangeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 148-byte string literal not displayed */
}

func (*RangesRequest) Descriptor 

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

func (*RangesRequest) Marshal 

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

func (*RangesRequest) MarshalTo 

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

func (*RangesRequest) ProtoMessage 

func (*RangesRequest) ProtoMessage()

func (*RangesRequest) Reset 

func (m *RangesRequest) Reset()

func (*RangesRequest) Size 

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

func (*RangesRequest) String 

func (m *RangesRequest) String() string

func (*RangesRequest) Unmarshal 

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

type RangesResponse 

type RangesResponse struct {
	Ranges []RangeInfo `protobuf:"bytes,1,rep,name=ranges" json:"ranges"`
}

func (*RangesResponse) Descriptor 

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

func (*RangesResponse) Marshal 

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

func (*RangesResponse) MarshalTo 

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

func (*RangesResponse) ProtoMessage 

func (*RangesResponse) ProtoMessage()

func (*RangesResponse) Reset 

func (m *RangesResponse) Reset()

func (*RangesResponse) Size 

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

func (*RangesResponse) String 

func (m *RangesResponse) String() string

func (*RangesResponse) Unmarshal 

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

type Session 

type Session struct {
	// ID of node where this session exists.
	NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */
	// Username of the user for this session.
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// Connected client's IP address and port.
	ClientAddress string `protobuf:"bytes,3,opt,name=client_address,json=clientAddress,proto3" json:"client_address,omitempty"`
	// Application name specified by the client.
	ApplicationName string `protobuf:"bytes,4,opt,name=application_name,json=applicationName,proto3" json:"application_name,omitempty"`
	// Queries in progress on this session.
	ActiveQueries []ActiveQuery `protobuf:"bytes,5,rep,name=active_queries,json=activeQueries" json:"active_queries"`
	// Timestamp of session's start.
	Start time.Time `protobuf:"bytes,6,opt,name=start,stdtime" json:"start"`
	// ID of the current KV transaction for this session. Nil if the session
	// doesn't currently have a transaction.
	KvTxnID *github_com_cockroachdb_cockroach_pkg_util_uuid.UUID `` /* 147-byte string literal not displayed */
	// SQL string of the last query executed on this session.
	LastActiveQuery string `protobuf:"bytes,8,opt,name=last_active_query,json=lastActiveQuery,proto3" json:"last_active_query,omitempty"`
}

Session represents one SQL session.

func (*Session) Descriptor 

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

func (*Session) Marshal 

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

func (*Session) MarshalTo 

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

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) Size 

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

func (*Session) String 

func (m *Session) String() string

func (*Session) Unmarshal 

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

type SessionCookie 

type SessionCookie struct {
	// The unique ID of the session.
	ID int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The secret needed to verify ownership of a session.
	Secret []byte `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
}

SessionCookie is a message used to encode the authentication cookie returned from successful login requests.

func (*SessionCookie) Descriptor 

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

func (*SessionCookie) Marshal 

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

func (*SessionCookie) MarshalTo 

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

func (*SessionCookie) ProtoMessage 

func (*SessionCookie) ProtoMessage()

func (*SessionCookie) Reset 

func (m *SessionCookie) Reset()

func (*SessionCookie) Size 

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

func (*SessionCookie) String 

func (m *SessionCookie) String() string

func (*SessionCookie) Unmarshal 

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

type SetUIDataRequest 

type SetUIDataRequest struct {
	// key_values is a map of keys to bytes values. Each key will be stored
	// with its corresponding value as a separate row in system.ui.
	KeyValues map[string][]byte `` /* 169-byte string literal not displayed */
}

SetUIDataRequest stores the given key/value pairs in the system.ui table.

func (*SetUIDataRequest) Descriptor 

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

func (*SetUIDataRequest) Marshal 

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

func (*SetUIDataRequest) MarshalTo 

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

func (*SetUIDataRequest) ProtoMessage 

func (*SetUIDataRequest) ProtoMessage()

func (*SetUIDataRequest) Reset 

func (m *SetUIDataRequest) Reset()

func (*SetUIDataRequest) Size 

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

func (*SetUIDataRequest) String 

func (m *SetUIDataRequest) String() string

func (*SetUIDataRequest) Unmarshal 

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

type SetUIDataResponse 

type SetUIDataResponse struct {
}

SetUIDataResponse is currently an empty response.

func (*SetUIDataResponse) Descriptor 

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

func (*SetUIDataResponse) Marshal 

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

func (*SetUIDataResponse) MarshalTo 

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

func (*SetUIDataResponse) ProtoMessage 

func (*SetUIDataResponse) ProtoMessage()

func (*SetUIDataResponse) Reset 

func (m *SetUIDataResponse) Reset()

func (*SetUIDataResponse) Size 

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

func (*SetUIDataResponse) String 

func (m *SetUIDataResponse) String() string

func (*SetUIDataResponse) Unmarshal 

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

type SettingsRequest 

type SettingsRequest struct {
	// The array of setting names to retrieve.
	// An empty keys array means "all".
	Keys []string `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
}

SettingsRequest inquires what are the current settings in the cluster.

func (*SettingsRequest) Descriptor 

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

func (*SettingsRequest) Marshal 

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

func (*SettingsRequest) MarshalTo 

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

func (*SettingsRequest) ProtoMessage 

func (*SettingsRequest) ProtoMessage()

func (*SettingsRequest) Reset 

func (m *SettingsRequest) Reset()

func (*SettingsRequest) Size 

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

func (*SettingsRequest) String 

func (m *SettingsRequest) String() string

func (*SettingsRequest) Unmarshal 

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

type SettingsResponse 

type SettingsResponse struct {
	KeyValues map[string]SettingsResponse_Value `` /* 152-byte string literal not displayed */
}

SettingsResponse is the response to SettingsRequest.

func (*SettingsResponse) Descriptor 

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

func (*SettingsResponse) Marshal 

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

func (*SettingsResponse) MarshalTo 

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

func (*SettingsResponse) ProtoMessage 

func (*SettingsResponse) ProtoMessage()

func (*SettingsResponse) Reset 

func (m *SettingsResponse) Reset()

func (*SettingsResponse) Size 

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

func (*SettingsResponse) String 

func (m *SettingsResponse) String() string

func (*SettingsResponse) Unmarshal 

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

type SettingsResponse_Value 

type SettingsResponse_Value struct {
	Value       string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Type        string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
}

func (*SettingsResponse_Value) Descriptor 

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

func (*SettingsResponse_Value) Marshal 

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

func (*SettingsResponse_Value) MarshalTo 

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

func (*SettingsResponse_Value) ProtoMessage 

func (*SettingsResponse_Value) ProtoMessage()

func (*SettingsResponse_Value) Reset 

func (m *SettingsResponse_Value) Reset()

func (*SettingsResponse_Value) Size 

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

func (*SettingsResponse_Value) String 

func (m *SettingsResponse_Value) String() string

func (*SettingsResponse_Value) Unmarshal 

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

type SpanStatsRequest 

type SpanStatsRequest struct {
	NodeID   string                                            `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	StartKey github_com_cockroachdb_cockroach_pkg_roachpb.RKey `` /* 144-byte string literal not displayed */
	EndKey   github_com_cockroachdb_cockroach_pkg_roachpb.RKey `` /* 138-byte string literal not displayed */
}

func (*SpanStatsRequest) Descriptor 

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

func (*SpanStatsRequest) Marshal 

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

func (*SpanStatsRequest) MarshalTo 

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

func (*SpanStatsRequest) ProtoMessage 

func (*SpanStatsRequest) ProtoMessage()

func (*SpanStatsRequest) Reset 

func (m *SpanStatsRequest) Reset()

func (*SpanStatsRequest) Size 

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

func (*SpanStatsRequest) String 

func (m *SpanStatsRequest) String() string

func (*SpanStatsRequest) Unmarshal 

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

type SpanStatsResponse 

type SpanStatsResponse struct {
	RangeCount int32                                       `protobuf:"varint,2,opt,name=range_count,json=rangeCount,proto3" json:"range_count,omitempty"`
	TotalStats cockroach_storage_engine_enginepb.MVCCStats `protobuf:"bytes,1,opt,name=total_stats,json=totalStats" json:"total_stats"`
}

func (*SpanStatsResponse) Descriptor 

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

func (*SpanStatsResponse) Marshal 

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

func (*SpanStatsResponse) MarshalTo 

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

func (*SpanStatsResponse) ProtoMessage 

func (*SpanStatsResponse) ProtoMessage()

func (*SpanStatsResponse) Reset 

func (m *SpanStatsResponse) Reset()

func (*SpanStatsResponse) Size 

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

func (*SpanStatsResponse) String 

func (m *SpanStatsResponse) String() string

func (*SpanStatsResponse) Unmarshal 

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

type StacksRequest 

type StacksRequest struct {
	// figure out how to teach grpc-gateway about custom names.
	//
	// node_id is a string so that "local" can be used to specify that no
	// forwarding is necessary.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

func (*StacksRequest) Descriptor 

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

func (*StacksRequest) Marshal 

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

func (*StacksRequest) MarshalTo 

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

func (*StacksRequest) ProtoMessage 

func (*StacksRequest) ProtoMessage()

func (*StacksRequest) Reset 

func (m *StacksRequest) Reset()

func (*StacksRequest) Size 

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

func (*StacksRequest) String 

func (m *StacksRequest) String() string

func (*StacksRequest) Unmarshal 

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

type StatusClient 

type StatusClient interface {
	Certificates(ctx context.Context, in *CertificatesRequest, opts ...grpc.CallOption) (*CertificatesResponse, error)
	Details(ctx context.Context, in *DetailsRequest, opts ...grpc.CallOption) (*DetailsResponse, error)
	Nodes(ctx context.Context, in *NodesRequest, opts ...grpc.CallOption) (*NodesResponse, error)
	Node(ctx context.Context, in *NodeRequest, opts ...grpc.CallOption) (*cockroach_server_status.NodeStatus, error)
	RaftDebug(ctx context.Context, in *RaftDebugRequest, opts ...grpc.CallOption) (*RaftDebugResponse, error)
	Ranges(ctx context.Context, in *RangesRequest, opts ...grpc.CallOption) (*RangesResponse, error)
	Gossip(ctx context.Context, in *GossipRequest, opts ...grpc.CallOption) (*cockroach_gossip.InfoStatus, error)
	Allocator(ctx context.Context, in *AllocatorRequest, opts ...grpc.CallOption) (*AllocatorResponse, error)
	AllocatorRange(ctx context.Context, in *AllocatorRangeRequest, opts ...grpc.CallOption) (*AllocatorRangeResponse, error)
	ListSessions(ctx context.Context, in *ListSessionsRequest, opts ...grpc.CallOption) (*ListSessionsResponse, error)
	ListLocalSessions(ctx context.Context, in *ListSessionsRequest, opts ...grpc.CallOption) (*ListSessionsResponse, error)
	CancelQuery(ctx context.Context, in *CancelQueryRequest, opts ...grpc.CallOption) (*CancelQueryResponse, error)
	// SpanStats accepts a key span and node ID, and returns a set of stats
	// summed from all ranges on the stores on that node which contain keys
	// in that span. This is designed to compute stats specific to a SQL table:
	// it will be called with the highest/lowest key for a SQL table, and return
	// information about the resources on a node used by that table.
	SpanStats(ctx context.Context, in *SpanStatsRequest, opts ...grpc.CallOption) (*SpanStatsResponse, error)
	Stacks(ctx context.Context, in *StacksRequest, opts ...grpc.CallOption) (*JSONResponse, error)
	Metrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*JSONResponse, error)
	LogFilesList(ctx context.Context, in *LogFilesListRequest, opts ...grpc.CallOption) (*LogFilesListResponse, error)
	LogFile(ctx context.Context, in *LogFileRequest, opts ...grpc.CallOption) (*LogEntriesResponse, error)
	Logs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (*LogEntriesResponse, error)
	ProblemRanges(ctx context.Context, in *ProblemRangesRequest, opts ...grpc.CallOption) (*ProblemRangesResponse, error)
	Range(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error)
}

func NewStatusClient 

func NewStatusClient(cc *grpc.ClientConn) StatusClient

type StatusServer 

type StatusServer interface {
	Certificates(context.Context, *CertificatesRequest) (*CertificatesResponse, error)
	Details(context.Context, *DetailsRequest) (*DetailsResponse, error)
	Nodes(context.Context, *NodesRequest) (*NodesResponse, error)
	Node(context.Context, *NodeRequest) (*cockroach_server_status.NodeStatus, error)
	RaftDebug(context.Context, *RaftDebugRequest) (*RaftDebugResponse, error)
	Ranges(context.Context, *RangesRequest) (*RangesResponse, error)
	Gossip(context.Context, *GossipRequest) (*cockroach_gossip.InfoStatus, error)
	Allocator(context.Context, *AllocatorRequest) (*AllocatorResponse, error)
	AllocatorRange(context.Context, *AllocatorRangeRequest) (*AllocatorRangeResponse, error)
	ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error)
	ListLocalSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error)
	CancelQuery(context.Context, *CancelQueryRequest) (*CancelQueryResponse, error)
	// SpanStats accepts a key span and node ID, and returns a set of stats
	// summed from all ranges on the stores on that node which contain keys
	// in that span. This is designed to compute stats specific to a SQL table:
	// it will be called with the highest/lowest key for a SQL table, and return
	// information about the resources on a node used by that table.
	SpanStats(context.Context, *SpanStatsRequest) (*SpanStatsResponse, error)
	Stacks(context.Context, *StacksRequest) (*JSONResponse, error)
	Metrics(context.Context, *MetricsRequest) (*JSONResponse, error)
	LogFilesList(context.Context, *LogFilesListRequest) (*LogFilesListResponse, error)
	LogFile(context.Context, *LogFileRequest) (*LogEntriesResponse, error)
	Logs(context.Context, *LogsRequest) (*LogEntriesResponse, error)
	ProblemRanges(context.Context, *ProblemRangesRequest) (*ProblemRangesResponse, error)
	Range(context.Context, *RangeRequest) (*RangeResponse, error)
}

type TableDetailsRequest 

type TableDetailsRequest struct {
	// database is the database that contains the table we're interested in.
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// table is the name of the table that we're querying.
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
}

TableDetailsRequest is a request for detailed information about a table.

func (*TableDetailsRequest) Descriptor 

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

func (*TableDetailsRequest) Marshal 

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

func (*TableDetailsRequest) MarshalTo 

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

func (*TableDetailsRequest) ProtoMessage 

func (*TableDetailsRequest) ProtoMessage()

func (*TableDetailsRequest) Reset 

func (m *TableDetailsRequest) Reset()

func (*TableDetailsRequest) Size 

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

func (*TableDetailsRequest) String 

func (m *TableDetailsRequest) String() string

func (*TableDetailsRequest) Unmarshal 

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

type TableDetailsResponse 

type TableDetailsResponse struct {
	Grants  []TableDetailsResponse_Grant  `protobuf:"bytes,1,rep,name=grants" json:"grants"`
	Columns []TableDetailsResponse_Column `protobuf:"bytes,2,rep,name=columns" json:"columns"`
	Indexes []TableDetailsResponse_Index  `protobuf:"bytes,3,rep,name=indexes" json:"indexes"`
	// range_count is the size of the table in ranges. This provides a rough
	// estimate of the storage requirements for the table.
	// TODO(mrtracy): The TableStats method also returns a range_count field which
	// is more accurate than this one; TableDetails calculates this number using
	// a potentially faster method that is subject to cache staleness. We should
	// consider removing or renaming this field to reflect that difference. See
	// Github issue #5435 for more information.
	RangeCount int64 `protobuf:"varint,4,opt,name=range_count,json=rangeCount,proto3" json:"range_count,omitempty"`
	// create_table_statement is the output of "SHOW CREATE TABLE" for this table;
	// it is a SQL statement that would re-create the table's current schema if
	// executed.
	CreateTableStatement string `protobuf:"bytes,5,opt,name=create_table_statement,json=createTableStatement,proto3" json:"create_table_statement,omitempty"`
	// The zone configuration in effect for this table.
	ZoneConfig cockroach_config.ZoneConfig `protobuf:"bytes,6,opt,name=zone_config,json=zoneConfig" json:"zone_config"`
	// The level at which this object's zone configuration is set.
	ZoneConfigLevel ZoneConfigurationLevel `` /* 163-byte string literal not displayed */
	// descriptor_id is an identifier used to uniquely identify this table.
	// It can be used to find events pertaining to this table by filtering on
	// the 'target_id' field of events.
	DescriptorID int64 `protobuf:"varint,8,opt,name=descriptor_id,json=descriptorId,proto3" json:"descriptor_id,omitempty"`
}

TableDetailsResponse contains grants, column names, and indexes for a table.

func (*TableDetailsResponse) Descriptor 

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

func (*TableDetailsResponse) Marshal 

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

func (*TableDetailsResponse) MarshalTo 

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

func (*TableDetailsResponse) ProtoMessage 

func (*TableDetailsResponse) ProtoMessage()

func (*TableDetailsResponse) Reset 

func (m *TableDetailsResponse) Reset()

func (*TableDetailsResponse) Size 

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

func (*TableDetailsResponse) String 

func (m *TableDetailsResponse) String() string

func (*TableDetailsResponse) Unmarshal 

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

type TableDetailsResponse_Column 

type TableDetailsResponse_Column struct {
	// name is the name of the column.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// type is the SQL type (INT, STRING, etc.) of this column.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// nullable is whether this column can contain NULL.
	Nullable bool `protobuf:"varint,3,opt,name=nullable,proto3" json:"nullable,omitempty"`
	// default_value is the default value of this column.
	DefaultValue string `protobuf:"bytes,4,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
}

func (*TableDetailsResponse_Column) Descriptor 

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

func (*TableDetailsResponse_Column) Marshal 

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

func (*TableDetailsResponse_Column) MarshalTo 

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

func (*TableDetailsResponse_Column) ProtoMessage 

func (*TableDetailsResponse_Column) ProtoMessage()

func (*TableDetailsResponse_Column) Reset 

func (m *TableDetailsResponse_Column) Reset()

func (*TableDetailsResponse_Column) Size 

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

func (*TableDetailsResponse_Column) String 

func (m *TableDetailsResponse_Column) String() string

func (*TableDetailsResponse_Column) Unmarshal 

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

type TableDetailsResponse_Grant 

type TableDetailsResponse_Grant struct {
	// user is the user that this grant applies to.
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// privileges are the abilities this grant gives to the user.
	Privileges []string `protobuf:"bytes,2,rep,name=privileges" json:"privileges,omitempty"`
}

Grant is an entry from SHOW GRANTS.

func (*TableDetailsResponse_Grant) Descriptor 

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

func (*TableDetailsResponse_Grant) Marshal 

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

func (*TableDetailsResponse_Grant) MarshalTo 

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

func (*TableDetailsResponse_Grant) ProtoMessage 

func (*TableDetailsResponse_Grant) ProtoMessage()

func (*TableDetailsResponse_Grant) Reset 

func (m *TableDetailsResponse_Grant) Reset()

func (*TableDetailsResponse_Grant) Size 

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

func (*TableDetailsResponse_Grant) String 

func (m *TableDetailsResponse_Grant) String() string

func (*TableDetailsResponse_Grant) Unmarshal 

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

type TableDetailsResponse_Index 

type TableDetailsResponse_Index struct {
	// name is the name of this index.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// unique is whether this a unique index (i.e. CREATE UNIQUE INDEX).
	Unique bool `protobuf:"varint,2,opt,name=unique,proto3" json:"unique,omitempty"`
	// seq is an internal variable that's passed along.
	Seq int64 `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	// column is the column that this index indexes.
	Column string `protobuf:"bytes,4,opt,name=column,proto3" json:"column,omitempty"`
	// direction is either "ASC" (ascending) or "DESC" (descending).
	Direction string `protobuf:"bytes,5,opt,name=direction,proto3" json:"direction,omitempty"`
	// storing is an internal variable that's passed along.
	Storing bool `protobuf:"varint,6,opt,name=storing,proto3" json:"storing,omitempty"`
	// implicit is an internal variable that's passed along.
	Implicit bool `protobuf:"varint,7,opt,name=implicit,proto3" json:"implicit,omitempty"`
}

func (*TableDetailsResponse_Index) Descriptor 

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

func (*TableDetailsResponse_Index) Marshal 

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

func (*TableDetailsResponse_Index) MarshalTo 

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

func (*TableDetailsResponse_Index) ProtoMessage 

func (*TableDetailsResponse_Index) ProtoMessage()

func (*TableDetailsResponse_Index) Reset 

func (m *TableDetailsResponse_Index) Reset()

func (*TableDetailsResponse_Index) Size 

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

func (*TableDetailsResponse_Index) String 

func (m *TableDetailsResponse_Index) String() string

func (*TableDetailsResponse_Index) Unmarshal 

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

type TableStatsRequest 

type TableStatsRequest struct {
	// database is the database that contains the table we're interested in.
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// table is the name of the table that we're querying.
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
}

TableStatsRequest is a request for detailed, computationally expensive information about a table.

func (*TableStatsRequest) Descriptor 

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

func (*TableStatsRequest) Marshal 

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

func (*TableStatsRequest) MarshalTo 

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

func (*TableStatsRequest) ProtoMessage 

func (*TableStatsRequest) ProtoMessage()

func (*TableStatsRequest) Reset 

func (m *TableStatsRequest) Reset()

func (*TableStatsRequest) Size 

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

func (*TableStatsRequest) String 

func (m *TableStatsRequest) String() string

func (*TableStatsRequest) Unmarshal 

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

type TableStatsResponse 

type TableStatsResponse struct {
	// range_count is the number of ranges, as determined from a query of range
	// meta keys.
	RangeCount int64 `protobuf:"varint,1,opt,name=range_count,json=rangeCount,proto3" json:"range_count,omitempty"`
	// replica_count is the number of replicas of any range of this table, as
	// found by querying nodes which are known to have replicas. When compared
	// with range_count, this can be used to estimate the current replication
	// factor of the table.
	ReplicaCount int64 `protobuf:"varint,2,opt,name=replica_count,json=replicaCount,proto3" json:"replica_count,omitempty"`
	// node_count is the number of nodes which contain data for this table,
	// according to a query of range meta keys.
	NodeCount int64 `protobuf:"varint,3,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"`
	// stats is the summation of MVCCStats for all replicas of this table
	// across the cluster.
	Stats cockroach_storage_engine_enginepb.MVCCStats `protobuf:"bytes,4,opt,name=stats" json:"stats"`
	// A list of nodes which should contain data for this table (according to
	// cluster metadata), but could not be contacted during this request.
	MissingNodes []TableStatsResponse_MissingNode `protobuf:"bytes,5,rep,name=missing_nodes,json=missingNodes" json:"missing_nodes"`
}

TableStatsResponse contains detailed, computationally expensive information about a table.

func (*TableStatsResponse) Descriptor 

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

func (*TableStatsResponse) Marshal 

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

func (*TableStatsResponse) MarshalTo 

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

func (*TableStatsResponse) ProtoMessage 

func (*TableStatsResponse) ProtoMessage()

func (*TableStatsResponse) Reset 

func (m *TableStatsResponse) Reset()

func (*TableStatsResponse) Size 

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

func (*TableStatsResponse) String 

func (m *TableStatsResponse) String() string

func (*TableStatsResponse) Unmarshal 

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

type TableStatsResponse_MissingNode 

type TableStatsResponse_MissingNode struct {
	// The ID of the missing node.
	NodeID string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// The error message that resulted when the query sent to this node failed.
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
}

MissingNode represents information on a node which should contain data for this table, but could not be contacted during this request.

func (*TableStatsResponse_MissingNode) Descriptor 

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

func (*TableStatsResponse_MissingNode) Marshal 

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

func (*TableStatsResponse_MissingNode) MarshalTo 

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

func (*TableStatsResponse_MissingNode) ProtoMessage 

func (*TableStatsResponse_MissingNode) ProtoMessage()

func (*TableStatsResponse_MissingNode) Reset 

func (m *TableStatsResponse_MissingNode) Reset()

func (*TableStatsResponse_MissingNode) Size 

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

func (*TableStatsResponse_MissingNode) String 

func (m *TableStatsResponse_MissingNode) String() string

func (*TableStatsResponse_MissingNode) Unmarshal 

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

type UserLoginRequest 

type UserLoginRequest struct {
	// A username which must correspond to a database user on the cluster.
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// A password for the provided username.
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
}

UserLoginRequest contains credentials a user must provide to log in.

func (*UserLoginRequest) Descriptor 

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

func (*UserLoginRequest) Marshal 

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

func (*UserLoginRequest) MarshalTo 

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

func (*UserLoginRequest) ProtoMessage 

func (*UserLoginRequest) ProtoMessage()

func (*UserLoginRequest) Reset 

func (m *UserLoginRequest) Reset()

func (*UserLoginRequest) Size 

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

func (*UserLoginRequest) String 

func (m *UserLoginRequest) String() string

func (*UserLoginRequest) Unmarshal 

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

type UserLoginResponse 

type UserLoginResponse struct {
}

UserLoginResponse is currently empty. If a login is successful, an HTTP Set-Cookie header will be added to the response with a session cookie identifying the created session.

func (*UserLoginResponse) Descriptor 

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

func (*UserLoginResponse) Marshal 

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

func (*UserLoginResponse) MarshalTo 

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

func (*UserLoginResponse) ProtoMessage 

func (*UserLoginResponse) ProtoMessage()

func (*UserLoginResponse) Reset 

func (m *UserLoginResponse) Reset()

func (*UserLoginResponse) Size 

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

func (*UserLoginResponse) String 

func (m *UserLoginResponse) String() string

func (*UserLoginResponse) Unmarshal 

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

type UserLogoutRequest 

type UserLogoutRequest struct {
}

UserLogoutRequest will terminate the current session in use. The request is empty because the current session is identified by an HTTP cookie on the incoming request.

func (*UserLogoutRequest) Descriptor 

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

func (*UserLogoutRequest) Marshal 

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

func (*UserLogoutRequest) MarshalTo 

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

func (*UserLogoutRequest) ProtoMessage 

func (*UserLogoutRequest) ProtoMessage()

func (*UserLogoutRequest) Reset 

func (m *UserLogoutRequest) Reset()

func (*UserLogoutRequest) Size 

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

func (*UserLogoutRequest) String 

func (m *UserLogoutRequest) String() string

func (*UserLogoutRequest) Unmarshal 

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

type UserLogoutResponse 

type UserLogoutResponse struct {
}

func (*UserLogoutResponse) Descriptor 

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

func (*UserLogoutResponse) Marshal 

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

func (*UserLogoutResponse) MarshalTo 

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

func (*UserLogoutResponse) ProtoMessage 

func (*UserLogoutResponse) ProtoMessage()

func (*UserLogoutResponse) Reset 

func (m *UserLogoutResponse) Reset()

func (*UserLogoutResponse) Size 

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

func (*UserLogoutResponse) String 

func (m *UserLogoutResponse) String() string

func (*UserLogoutResponse) Unmarshal 

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

type UsersRequest 

type UsersRequest struct {
}

UsersRequest requests a list of users.

func (*UsersRequest) Descriptor 

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

func (*UsersRequest) Marshal 

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

func (*UsersRequest) MarshalTo 

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

func (*UsersRequest) ProtoMessage 

func (*UsersRequest) ProtoMessage()

func (*UsersRequest) Reset 

func (m *UsersRequest) Reset()

func (*UsersRequest) Size 

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

func (*UsersRequest) String 

func (m *UsersRequest) String() string

func (*UsersRequest) Unmarshal 

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

type UsersResponse 

type UsersResponse struct {
	// usernames is a list of users for the CockroachDB cluster.
	Users []UsersResponse_User `protobuf:"bytes,1,rep,name=users" json:"users"`
}

UsersResponse returns a list of users.

func (*UsersResponse) Descriptor 

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

func (*UsersResponse) Marshal 

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

func (*UsersResponse) MarshalTo 

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

func (*UsersResponse) ProtoMessage 

func (*UsersResponse) ProtoMessage()

func (*UsersResponse) Reset 

func (m *UsersResponse) Reset()

func (*UsersResponse) Size 

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

func (*UsersResponse) String 

func (m *UsersResponse) String() string

func (*UsersResponse) Unmarshal 

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

type UsersResponse_User 

type UsersResponse_User struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
}

User is a CockroachDB user.

func (*UsersResponse_User) Descriptor 

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

func (*UsersResponse_User) Marshal 

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

func (*UsersResponse_User) MarshalTo 

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

func (*UsersResponse_User) ProtoMessage 

func (*UsersResponse_User) ProtoMessage()

func (*UsersResponse_User) Reset 

func (m *UsersResponse_User) Reset()

func (*UsersResponse_User) Size 

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

func (*UsersResponse_User) String 

func (m *UsersResponse_User) String() string

func (*UsersResponse_User) Unmarshal 

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

type ZoneConfigurationLevel 

type ZoneConfigurationLevel int32

ZoneConfigurationLevel indicates, for objects with a Zone Configuration, the object level at which the configuration is defined. This is needed because objects without a specifically indicated Zone Configuration will inherit the configuration of their "parent". 

const (
	ZoneConfigurationLevel_UNKNOWN ZoneConfigurationLevel = 0
	// CLUSTER indicates that this object uses the cluster default Zone Configuration.
	ZoneConfigurationLevel_CLUSTER ZoneConfigurationLevel = 1
	// DATABASE indicates that this object uses a database-level Zone Configuration.
	ZoneConfigurationLevel_DATABASE ZoneConfigurationLevel = 2
	// TABLE indicates that this object uses a table-level Zone Configuration.
	ZoneConfigurationLevel_TABLE ZoneConfigurationLevel = 3
)

func (ZoneConfigurationLevel) EnumDescriptor 

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

func (ZoneConfigurationLevel) String 

func (x ZoneConfigurationLevel) String() string

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.