serverpb

package
v0.0.0-...-6d60fb6 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 2016 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview 

Package serverpb is a generated protocol buffer package.

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

It has these top-level messages:
	DatabasesRequest
	DatabasesResponse
	DatabaseDetailsRequest
	DatabaseDetailsResponse
	TableDetailsRequest
	TableDetailsResponse
	UsersRequest
	UsersResponse
	EventsRequest
	EventsResponse
	SetUIDataRequest
	SetUIDataResponse
	GetUIDataRequest
	GetUIDataResponse
	ClusterRequest
	ClusterResponse
	DrainRequest
	DrainResponse
	HealthRequest
	HealthResponse
	ClusterFreezeRequest
	ClusterFreezeResponse
	DetailsRequest
	DetailsResponse
	NodesRequest
	NodesResponse
	NodeRequest
	RangeInfo
	RangesRequest
	RangesResponse
	GossipRequest
	JSONResponse
	LogsRequest
	LogFilesListRequest
	LogFileRequest
	StacksRequest
	MetricsRequest
	RaftRangeNode
	RaftRangeError
	RaftRangeStatus
	RaftDebugRequest
	RaftDebugResponse
	PrettySpan

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 (
	ErrInvalidLengthStatus = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStatus   = fmt.Errorf("proto: integer overflow")
)
View Source 
var DrainMode_name = map[int32]string{
	0: "CLIENT",
	1: "LEADERSHIP",
}
View Source 
var DrainMode_value = map[string]int32{
	"CLIENT":     0,
	"LEADERSHIP": 1,
}

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 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 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 URLs:
	// - /_admin/v1/events?type=create_table
	// - /_admin/v1/events?type=drop_table&target_id=4
	// - /_admin/v1/events
	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)
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, 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) (*DrainResponse, error)
	// ClusterFreeze freezes/unfreezes the cluster.
	ClusterFreeze(ctx context.Context, in *ClusterFreezeRequest, opts ...grpc.CallOption) (Admin_ClusterFreezeClient, 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 URLs:
	// - /_admin/v1/events?type=create_table
	// - /_admin/v1/events?type=drop_table&target_id=4
	// - /_admin/v1/events
	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)
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	// Drain puts the node into the specified drain mode(s) and optionally
	// instructs the process to terminate.
	Drain(context.Context, *DrainRequest) (*DrainResponse, error)
	// ClusterFreeze freezes/unfreezes the cluster.
	ClusterFreeze(*ClusterFreezeRequest, Admin_ClusterFreezeServer) error
}

type Admin_ClusterFreezeClient 

type Admin_ClusterFreezeClient interface {
	Recv() (*ClusterFreezeResponse, error)
	grpc.ClientStream
}

type Admin_ClusterFreezeServer 

type Admin_ClusterFreezeServer interface {
	Send(*ClusterFreezeResponse) error
	grpc.ServerStream
}

type ClusterFreezeRequest 

type ClusterFreezeRequest struct {
	// When set, attempt to freeze the cluster in preparation for a
	// stop-the-world upgrade. When unset, attempt to unfreeze any
	// frozen Ranges.
	Freeze bool `protobuf:"varint,1,opt,name=freeze,proto3" json:"freeze,omitempty"`
}

ClusterFreezeRequest lets the receiving node go through all Ranges in the cluster, freezing them in preparation for an upgrade.

func (*ClusterFreezeRequest) Descriptor 

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

func (*ClusterFreezeRequest) Marshal 

func (m *ClusterFreezeRequest) Marshal() (data []byte, err error)

func (*ClusterFreezeRequest) MarshalTo 

func (m *ClusterFreezeRequest) MarshalTo(data []byte) (int, error)

func (*ClusterFreezeRequest) ProtoMessage 

func (*ClusterFreezeRequest) ProtoMessage()

func (*ClusterFreezeRequest) Reset 

func (m *ClusterFreezeRequest) Reset()

func (*ClusterFreezeRequest) Size 

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

func (*ClusterFreezeRequest) String 

func (m *ClusterFreezeRequest) String() string

func (*ClusterFreezeRequest) Unmarshal 

func (m *ClusterFreezeRequest) Unmarshal(data []byte) error

type ClusterFreezeResponse 

type ClusterFreezeResponse struct {
	RangesAffected int64  `protobuf:"varint,1,opt,name=ranges_affected,json=rangesAffected,proto3" json:"ranges_affected,omitempty"`
	Message        string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

ClusterFreezeResponse is the streaming response to a ClusterFreezeRequest. It contains a message intended for human consumption, and, for some updates, the number of ranges whose state changed as a result of the request.

func (*ClusterFreezeResponse) Descriptor 

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

func (*ClusterFreezeResponse) Marshal 

func (m *ClusterFreezeResponse) Marshal() (data []byte, err error)

func (*ClusterFreezeResponse) MarshalTo 

func (m *ClusterFreezeResponse) MarshalTo(data []byte) (int, error)

func (*ClusterFreezeResponse) ProtoMessage 

func (*ClusterFreezeResponse) ProtoMessage()

func (*ClusterFreezeResponse) Reset 

func (m *ClusterFreezeResponse) Reset()

func (*ClusterFreezeResponse) Size 

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

func (*ClusterFreezeResponse) String 

func (m *ClusterFreezeResponse) String() string

func (*ClusterFreezeResponse) Unmarshal 

func (m *ClusterFreezeResponse) 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 {
	ClusterID string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,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 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"`
}

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 DetailsRequest 

type DetailsRequest struct {
	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_roachpb.NodeID `` /* 137-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'
	// leader leases expire.
	DrainMode_LEADERSHIP 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/gengo/grpc-gateway/issues/5)
	// and it fails in pretty dramatic ways (panics the server).
	On  []int32 `protobuf:"varint,1,rep,name=on" json:"on,omitempty"`
	Off []int32 `protobuf:"varint,2,rep,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,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"`
}

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 EventsResponse_Event_Timestamp `protobuf:"bytes,1,opt,name=timestamp" 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 vent.
	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 EventsResponse_Event_Timestamp 

type EventsResponse_Event_Timestamp struct {
	// The time in seconds since, January 1, 1970 UTC (Unix time).
	Sec int64 `protobuf:"varint,1,opt,name=sec,proto3" json:"sec,omitempty"`
	// nsec specifies a non-negative nanosecond offset within sec.
	// It must be in the range [0, 999999999].
	Nsec uint32 `protobuf:"varint,2,opt,name=nsec,proto3" json:"nsec,omitempty"`
}

Timestamp is embedded in each place it's used, because proto3 defines a built-in Timestamp message that we can't use, because gogoprotobuf doesn't support all proto3 protobuf types yet. See https://github.com/gogo/protobuf/issues/155.

func (*EventsResponse_Event_Timestamp) Descriptor 

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

func (*EventsResponse_Event_Timestamp) Marshal 

func (m *EventsResponse_Event_Timestamp) Marshal() (data []byte, err error)

func (*EventsResponse_Event_Timestamp) MarshalTo 

func (m *EventsResponse_Event_Timestamp) MarshalTo(data []byte) (int, error)

func (*EventsResponse_Event_Timestamp) ProtoMessage 

func (*EventsResponse_Event_Timestamp) ProtoMessage()

func (*EventsResponse_Event_Timestamp) Reset 

func (m *EventsResponse_Event_Timestamp) Reset()

func (*EventsResponse_Event_Timestamp) Size 

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

func (*EventsResponse_Event_Timestamp) String 

func (m *EventsResponse_Event_Timestamp) String() string

func (*EventsResponse_Event_Timestamp) Unmarshal 

func (m *EventsResponse_Event_Timestamp) 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_Timestamp 

type GetUIDataResponse_Timestamp struct {
	// The time in seconds since, January 1, 1970 UTC (Unix time).
	Sec int64 `protobuf:"varint,1,opt,name=sec,proto3" json:"sec,omitempty"`
	// nsec specifies a non-negative nanosecond offset within sec.
	// It must be in the range [0, 999999999].
	Nsec uint32 `protobuf:"varint,2,opt,name=nsec,proto3" json:"nsec,omitempty"`
}

Timestamp is embedded in each place it's used, because proto3 defines a built-in Timestamp message that we can't use, because gogoprotobuf doesn't support all proto3 protobuf types yet. See gogoprotobuf issue #113.

func (*GetUIDataResponse_Timestamp) Descriptor 

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

func (*GetUIDataResponse_Timestamp) Marshal 

func (m *GetUIDataResponse_Timestamp) Marshal() (data []byte, err error)

func (*GetUIDataResponse_Timestamp) MarshalTo 

func (m *GetUIDataResponse_Timestamp) MarshalTo(data []byte) (int, error)

func (*GetUIDataResponse_Timestamp) ProtoMessage 

func (*GetUIDataResponse_Timestamp) ProtoMessage()

func (*GetUIDataResponse_Timestamp) Reset 

func (m *GetUIDataResponse_Timestamp) Reset()

func (*GetUIDataResponse_Timestamp) Size 

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

func (*GetUIDataResponse_Timestamp) String 

func (m *GetUIDataResponse_Timestamp) String() string

func (*GetUIDataResponse_Timestamp) Unmarshal 

func (m *GetUIDataResponse_Timestamp) 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 GetUIDataResponse_Timestamp `protobuf:"bytes,2,opt,name=last_updated,json=lastUpdated" 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 {
	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. 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 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 LogFileRequest 

type LogFileRequest struct {
	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 {
	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 LogsRequest 

type LogsRequest struct {
	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 {
	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 {
	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"`
}

PrettySpan holds a pretty-printed key range.

func (*PrettySpan) Descriptor 

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

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 RaftDebugRequest 

type RaftDebugRequest struct {
}

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_roachpb.RangeID]RaftRangeStatus `` /* 187-byte string literal not displayed */
}

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_roachpb.NodeID `` /* 137-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_roachpb.RangeID `` /* 141-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 RangeInfo 

type RangeInfo struct {
	Span      PrettySpan                              `protobuf:"bytes,1,opt,name=span" json:"span"`
	RaftState string                                  `protobuf:"bytes,2,opt,name=raft_state,json=raftState,proto3" json:"raft_state,omitempty"`
	State     cockroach_storage_storagebase.RangeInfo `protobuf:"bytes,4,opt,name=state" json:"state"`
}

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 RangesRequest 

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

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 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 StacksRequest 

type StacksRequest struct {
	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 {
	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)
	Stacks(ctx context.Context, in *StacksRequest, opts ...grpc.CallOption) (*JSONResponse, error)
	Metrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*JSONResponse, error)
	Logs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (*JSONResponse, error)
	LogFilesList(ctx context.Context, in *LogFilesListRequest, opts ...grpc.CallOption) (*JSONResponse, error)
	LogFile(ctx context.Context, in *LogFileRequest, opts ...grpc.CallOption) (*JSONResponse, error)
}

func NewStatusClient 

func NewStatusClient(cc *grpc.ClientConn) StatusClient

type StatusServer 

type StatusServer interface {
	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)
	Stacks(context.Context, *StacksRequest) (*JSONResponse, error)
	Metrics(context.Context, *MetricsRequest) (*JSONResponse, error)
	Logs(context.Context, *LogsRequest) (*JSONResponse, error)
	LogFilesList(context.Context, *LogFilesListRequest) (*JSONResponse, error)
	LogFile(context.Context, *LogFileRequest) (*JSONResponse, 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.
	RangeCount int64 `protobuf:"varint,4,opt,name=range_count,json=rangeCount,proto3" json:"range_count,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"`
}

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 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

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.