cockroach: github.com/kardianos/cockroach/server/serverpb Index | Files

package serverpb

import "github.com/kardianos/cockroach/server/serverpb"

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
	TableStatsRequest
	TableStatsResponse
	UsersRequest
	UsersResponse
	EventsRequest
	EventsResponse
	SetUIDataRequest
	SetUIDataResponse
	GetUIDataRequest
	GetUIDataResponse
	ClusterRequest
	ClusterResponse
	DrainRequest
	DrainResponse
	HealthRequest
	HealthResponse
	ClusterFreezeRequest
	ClusterFreezeResponse
	DetailsRequest
	DetailsResponse
	NodesRequest
	NodesResponse
	NodeRequest
	RaftState
	RangeInfo
	RangesRequest
	RangesResponse
	GossipRequest
	JSONResponse
	LogsRequest
	LogEntriesResponse
	LogFilesListRequest
	LogFilesListResponse
	LogFileRequest
	StacksRequest
	MetricsRequest
	RaftRangeNode
	RaftRangeError
	RaftRangeStatus
	RaftDebugRequest
	RaftDebugResponse
	SpanStatsRequest
	SpanStatsResponse
	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

Package Files

admin.pb.go admin.pb.gw.go status.pb.go status.pb.gw.go

Variables

var (
    ErrInvalidLengthAdmin = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowAdmin   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthStatus = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowStatus   = fmt.Errorf("proto: integer overflow")
)
var DrainMode_name = map[int32]string{
    0:  "CLIENT",
    1:  "LEASES",
}
var DrainMode_value = map[string]int32{
    "CLIENT": 0,
    "LEASES": 1,
}
var ZoneConfigurationLevel_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "CLUSTER",
    2:  "DATABASE",
    3:  "TABLE",
}
var ZoneConfigurationLevel_value = map[string]int32{
    "UNKNOWN":  0,
    "CLUSTER":  1,
    "DATABASE": 2,
    "TABLE":    3,
}

func RegisterAdminHandler Uses

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 Uses

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 Uses

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

func RegisterStatusHandler Uses

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 Uses

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 Uses

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

type AdminClient Uses

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:
    // - /_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) (Admin_DrainClient, error)
    // ClusterFreeze freezes/unfreezes the cluster.
    ClusterFreeze(ctx context.Context, in *ClusterFreezeRequest, opts ...grpc.CallOption) (Admin_ClusterFreezeClient, error)
}

func NewAdminClient Uses

func NewAdminClient(cc *grpc.ClientConn) AdminClient

type AdminServer Uses

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:
    // - /_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(*DrainRequest, Admin_DrainServer) error
    // ClusterFreeze freezes/unfreezes the cluster.
    ClusterFreeze(*ClusterFreezeRequest, Admin_ClusterFreezeServer) error
}

type Admin_ClusterFreezeClient Uses

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

type Admin_ClusterFreezeServer Uses

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

type Admin_DrainClient Uses

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

type Admin_DrainServer Uses

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

type ClusterFreezeRequest Uses

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 Uses

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

func (*ClusterFreezeRequest) Marshal Uses

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

func (*ClusterFreezeRequest) MarshalTo Uses

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

func (*ClusterFreezeRequest) ProtoMessage Uses

func (*ClusterFreezeRequest) ProtoMessage()

func (*ClusterFreezeRequest) Reset Uses

func (m *ClusterFreezeRequest) Reset()

func (*ClusterFreezeRequest) Size Uses

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

func (*ClusterFreezeRequest) String Uses

func (m *ClusterFreezeRequest) String() string

func (*ClusterFreezeRequest) Unmarshal Uses

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

type ClusterFreezeResponse Uses

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 Uses

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

func (*ClusterFreezeResponse) Marshal Uses

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

func (*ClusterFreezeResponse) MarshalTo Uses

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

func (*ClusterFreezeResponse) ProtoMessage Uses

func (*ClusterFreezeResponse) ProtoMessage()

func (*ClusterFreezeResponse) Reset Uses

func (m *ClusterFreezeResponse) Reset()

func (*ClusterFreezeResponse) Size Uses

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

func (*ClusterFreezeResponse) String Uses

func (m *ClusterFreezeResponse) String() string

func (*ClusterFreezeResponse) Unmarshal Uses

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

type ClusterRequest Uses

type ClusterRequest struct {
}

ClusterRequest requests metadata for the cluster.

func (*ClusterRequest) Descriptor Uses

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

func (*ClusterRequest) Marshal Uses

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

func (*ClusterRequest) MarshalTo Uses

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

func (*ClusterRequest) ProtoMessage Uses

func (*ClusterRequest) ProtoMessage()

func (*ClusterRequest) Reset Uses

func (m *ClusterRequest) Reset()

func (*ClusterRequest) Size Uses

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

func (*ClusterRequest) String Uses

func (m *ClusterRequest) String() string

func (*ClusterRequest) Unmarshal Uses

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

type ClusterResponse Uses

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 Uses

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

func (*ClusterResponse) Marshal Uses

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

func (*ClusterResponse) MarshalTo Uses

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

func (*ClusterResponse) ProtoMessage Uses

func (*ClusterResponse) ProtoMessage()

func (*ClusterResponse) Reset Uses

func (m *ClusterResponse) Reset()

func (*ClusterResponse) Size Uses

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

func (*ClusterResponse) String Uses

func (m *ClusterResponse) String() string

func (*ClusterResponse) Unmarshal Uses

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

type DatabaseDetailsRequest Uses

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 Uses

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

func (*DatabaseDetailsRequest) Marshal Uses

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

func (*DatabaseDetailsRequest) MarshalTo Uses

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

func (*DatabaseDetailsRequest) ProtoMessage Uses

func (*DatabaseDetailsRequest) ProtoMessage()

func (*DatabaseDetailsRequest) Reset Uses

func (m *DatabaseDetailsRequest) Reset()

func (*DatabaseDetailsRequest) Size Uses

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

func (*DatabaseDetailsRequest) String Uses

func (m *DatabaseDetailsRequest) String() string

func (*DatabaseDetailsRequest) Unmarshal Uses

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

type DatabaseDetailsResponse Uses

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 `protobuf:"varint,5,opt,name=zone_config_level,json=zoneConfigLevel,proto3,enum=cockroach.server.serverpb.ZoneConfigurationLevel" json:"zone_config_level,omitempty"`
}

DatabaseDetailsResponse contains grant information and table names for a database.

func (*DatabaseDetailsResponse) Descriptor Uses

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

func (*DatabaseDetailsResponse) Marshal Uses

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

func (*DatabaseDetailsResponse) MarshalTo Uses

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

func (*DatabaseDetailsResponse) ProtoMessage Uses

func (*DatabaseDetailsResponse) ProtoMessage()

func (*DatabaseDetailsResponse) Reset Uses

func (m *DatabaseDetailsResponse) Reset()

func (*DatabaseDetailsResponse) Size Uses

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

func (*DatabaseDetailsResponse) String Uses

func (m *DatabaseDetailsResponse) String() string

func (*DatabaseDetailsResponse) Unmarshal Uses

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

type DatabaseDetailsResponse_Grant Uses

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 Uses

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

func (*DatabaseDetailsResponse_Grant) Marshal Uses

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

func (*DatabaseDetailsResponse_Grant) MarshalTo Uses

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

func (*DatabaseDetailsResponse_Grant) ProtoMessage Uses

func (*DatabaseDetailsResponse_Grant) ProtoMessage()

func (*DatabaseDetailsResponse_Grant) Reset Uses

func (m *DatabaseDetailsResponse_Grant) Reset()

func (*DatabaseDetailsResponse_Grant) Size Uses

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

func (*DatabaseDetailsResponse_Grant) String Uses

func (m *DatabaseDetailsResponse_Grant) String() string

func (*DatabaseDetailsResponse_Grant) Unmarshal Uses

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

type DatabasesRequest Uses

type DatabasesRequest struct {
}

DatabasesRequest requests a list of databases.

func (*DatabasesRequest) Descriptor Uses

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

func (*DatabasesRequest) Marshal Uses

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

func (*DatabasesRequest) MarshalTo Uses

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

func (*DatabasesRequest) ProtoMessage Uses

func (*DatabasesRequest) ProtoMessage()

func (*DatabasesRequest) Reset Uses

func (m *DatabasesRequest) Reset()

func (*DatabasesRequest) Size Uses

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

func (*DatabasesRequest) String Uses

func (m *DatabasesRequest) String() string

func (*DatabasesRequest) Unmarshal Uses

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

type DatabasesResponse Uses

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

DatabasesResponse contains a list of databases.

func (*DatabasesResponse) Descriptor Uses

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

func (*DatabasesResponse) Marshal Uses

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

func (*DatabasesResponse) MarshalTo Uses

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

func (*DatabasesResponse) ProtoMessage Uses

func (*DatabasesResponse) ProtoMessage()

func (*DatabasesResponse) Reset Uses

func (m *DatabasesResponse) Reset()

func (*DatabasesResponse) Size Uses

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

func (*DatabasesResponse) String Uses

func (m *DatabasesResponse) String() string

func (*DatabasesResponse) Unmarshal Uses

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

type DetailsRequest Uses

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 Uses

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

func (*DetailsRequest) Marshal Uses

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

func (*DetailsRequest) MarshalTo Uses

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

func (*DetailsRequest) ProtoMessage Uses

func (*DetailsRequest) ProtoMessage()

func (*DetailsRequest) Reset Uses

func (m *DetailsRequest) Reset()

func (*DetailsRequest) Size Uses

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

func (*DetailsRequest) String Uses

func (m *DetailsRequest) String() string

func (*DetailsRequest) Unmarshal Uses

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

type DetailsResponse Uses

type DetailsResponse struct {
    NodeID    github_com_cockroachdb_cockroach_roachpb.NodeID `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3,casttype=github.com/cockroachdb/cockroach/roachpb.NodeID" json:"node_id,omitempty"`
    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 Uses

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

func (*DetailsResponse) Marshal Uses

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

func (*DetailsResponse) MarshalTo Uses

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

func (*DetailsResponse) ProtoMessage Uses

func (*DetailsResponse) ProtoMessage()

func (*DetailsResponse) Reset Uses

func (m *DetailsResponse) Reset()

func (*DetailsResponse) Size Uses

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

func (*DetailsResponse) String Uses

func (m *DetailsResponse) String() string

func (*DetailsResponse) Unmarshal Uses

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

type DrainMode Uses

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 Uses

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

func (DrainMode) String Uses

func (x DrainMode) String() string

type DrainRequest Uses

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

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

func (*DrainRequest) Marshal Uses

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

func (*DrainRequest) MarshalTo Uses

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

func (*DrainRequest) ProtoMessage Uses

func (*DrainRequest) ProtoMessage()

func (*DrainRequest) Reset Uses

func (m *DrainRequest) Reset()

func (*DrainRequest) Size Uses

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

func (*DrainRequest) String Uses

func (m *DrainRequest) String() string

func (*DrainRequest) Unmarshal Uses

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

type DrainResponse Uses

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 Uses

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

func (*DrainResponse) Marshal Uses

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

func (*DrainResponse) MarshalTo Uses

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

func (*DrainResponse) ProtoMessage Uses

func (*DrainResponse) ProtoMessage()

func (*DrainResponse) Reset Uses

func (m *DrainResponse) Reset()

func (*DrainResponse) Size Uses

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

func (*DrainResponse) String Uses

func (m *DrainResponse) String() string

func (*DrainResponse) Unmarshal Uses

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

type EventsRequest Uses

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 Uses

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

func (*EventsRequest) Marshal Uses

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

func (*EventsRequest) MarshalTo Uses

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

func (*EventsRequest) ProtoMessage Uses

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) Reset Uses

func (m *EventsRequest) Reset()

func (*EventsRequest) Size Uses

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

func (*EventsRequest) String Uses

func (m *EventsRequest) String() string

func (*EventsRequest) Unmarshal Uses

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

type EventsResponse Uses

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 Uses

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

func (*EventsResponse) Marshal Uses

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

func (*EventsResponse) MarshalTo Uses

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

func (*EventsResponse) ProtoMessage Uses

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) Reset Uses

func (m *EventsResponse) Reset()

func (*EventsResponse) Size Uses

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

func (*EventsResponse) String Uses

func (m *EventsResponse) String() string

func (*EventsResponse) Unmarshal Uses

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

type EventsResponse_Event Uses

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 Uses

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

func (*EventsResponse_Event) Marshal Uses

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

func (*EventsResponse_Event) MarshalTo Uses

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

func (*EventsResponse_Event) ProtoMessage Uses

func (*EventsResponse_Event) ProtoMessage()

func (*EventsResponse_Event) Reset Uses

func (m *EventsResponse_Event) Reset()

func (*EventsResponse_Event) Size Uses

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

func (*EventsResponse_Event) String Uses

func (m *EventsResponse_Event) String() string

func (*EventsResponse_Event) Unmarshal Uses

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

type EventsResponse_Event_Timestamp Uses

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 doesn't support all proto3 protobuf types yet. See https://github.com/gogo/protobuf/issues/155.

func (*EventsResponse_Event_Timestamp) Descriptor Uses

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

func (*EventsResponse_Event_Timestamp) Marshal Uses

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

func (*EventsResponse_Event_Timestamp) MarshalTo Uses

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

func (*EventsResponse_Event_Timestamp) ProtoMessage Uses

func (*EventsResponse_Event_Timestamp) ProtoMessage()

func (*EventsResponse_Event_Timestamp) Reset Uses

func (m *EventsResponse_Event_Timestamp) Reset()

func (*EventsResponse_Event_Timestamp) Size Uses

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

func (*EventsResponse_Event_Timestamp) String Uses

func (m *EventsResponse_Event_Timestamp) String() string

func (*EventsResponse_Event_Timestamp) Unmarshal Uses

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

type GetUIDataRequest Uses

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 Uses

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

func (*GetUIDataRequest) Marshal Uses

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

func (*GetUIDataRequest) MarshalTo Uses

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

func (*GetUIDataRequest) ProtoMessage Uses

func (*GetUIDataRequest) ProtoMessage()

func (*GetUIDataRequest) Reset Uses

func (m *GetUIDataRequest) Reset()

func (*GetUIDataRequest) Size Uses

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

func (*GetUIDataRequest) String Uses

func (m *GetUIDataRequest) String() string

func (*GetUIDataRequest) Unmarshal Uses

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

type GetUIDataResponse Uses

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 `protobuf:"bytes,1,rep,name=key_values,json=keyValues" json:"key_values" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value"`
}

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

func (*GetUIDataResponse) Descriptor Uses

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

func (*GetUIDataResponse) Marshal Uses

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

func (*GetUIDataResponse) MarshalTo Uses

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

func (*GetUIDataResponse) ProtoMessage Uses

func (*GetUIDataResponse) ProtoMessage()

func (*GetUIDataResponse) Reset Uses

func (m *GetUIDataResponse) Reset()

func (*GetUIDataResponse) Size Uses

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

func (*GetUIDataResponse) String Uses

func (m *GetUIDataResponse) String() string

func (*GetUIDataResponse) Unmarshal Uses

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

type GetUIDataResponse_Timestamp Uses

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

func (*GetUIDataResponse_Timestamp) Descriptor Uses

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

func (*GetUIDataResponse_Timestamp) Marshal Uses

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

func (*GetUIDataResponse_Timestamp) MarshalTo Uses

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

func (*GetUIDataResponse_Timestamp) ProtoMessage Uses

func (*GetUIDataResponse_Timestamp) ProtoMessage()

func (*GetUIDataResponse_Timestamp) Reset Uses

func (m *GetUIDataResponse_Timestamp) Reset()

func (*GetUIDataResponse_Timestamp) Size Uses

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

func (*GetUIDataResponse_Timestamp) String Uses

func (m *GetUIDataResponse_Timestamp) String() string

func (*GetUIDataResponse_Timestamp) Unmarshal Uses

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

type GetUIDataResponse_Value Uses

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 Uses

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

func (*GetUIDataResponse_Value) Marshal Uses

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

func (*GetUIDataResponse_Value) MarshalTo Uses

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

func (*GetUIDataResponse_Value) ProtoMessage Uses

func (*GetUIDataResponse_Value) ProtoMessage()

func (*GetUIDataResponse_Value) Reset Uses

func (m *GetUIDataResponse_Value) Reset()

func (*GetUIDataResponse_Value) Size Uses

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

func (*GetUIDataResponse_Value) String Uses

func (m *GetUIDataResponse_Value) String() string

func (*GetUIDataResponse_Value) Unmarshal Uses

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

type GossipRequest Uses

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 Uses

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

func (*GossipRequest) Marshal Uses

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

func (*GossipRequest) MarshalTo Uses

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

func (*GossipRequest) ProtoMessage Uses

func (*GossipRequest) ProtoMessage()

func (*GossipRequest) Reset Uses

func (m *GossipRequest) Reset()

func (*GossipRequest) Size Uses

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

func (*GossipRequest) String Uses

func (m *GossipRequest) String() string

func (*GossipRequest) Unmarshal Uses

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

type HealthRequest Uses

type HealthRequest struct {
}

HealthRequest inquires whether the addressed node is healthy.

func (*HealthRequest) Descriptor Uses

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

func (*HealthRequest) Marshal Uses

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

func (*HealthRequest) MarshalTo Uses

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

func (*HealthRequest) ProtoMessage Uses

func (*HealthRequest) ProtoMessage()

func (*HealthRequest) Reset Uses

func (m *HealthRequest) Reset()

func (*HealthRequest) Size Uses

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

func (*HealthRequest) String Uses

func (m *HealthRequest) String() string

func (*HealthRequest) Unmarshal Uses

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

type HealthResponse Uses

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 Uses

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

func (*HealthResponse) Marshal Uses

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

func (*HealthResponse) MarshalTo Uses

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

func (*HealthResponse) ProtoMessage Uses

func (*HealthResponse) ProtoMessage()

func (*HealthResponse) Reset Uses

func (m *HealthResponse) Reset()

func (*HealthResponse) Size Uses

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

func (*HealthResponse) String Uses

func (m *HealthResponse) String() string

func (*HealthResponse) Unmarshal Uses

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

type JSONResponse Uses

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

func (*JSONResponse) Descriptor Uses

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

func (*JSONResponse) Marshal Uses

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

func (*JSONResponse) MarshalTo Uses

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

func (*JSONResponse) ProtoMessage Uses

func (*JSONResponse) ProtoMessage()

func (*JSONResponse) Reset Uses

func (m *JSONResponse) Reset()

func (*JSONResponse) Size Uses

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

func (*JSONResponse) String Uses

func (m *JSONResponse) String() string

func (*JSONResponse) Unmarshal Uses

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

type LogEntriesResponse Uses

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

func (*LogEntriesResponse) Descriptor Uses

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

func (*LogEntriesResponse) Marshal Uses

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

func (*LogEntriesResponse) MarshalTo Uses

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

func (*LogEntriesResponse) ProtoMessage Uses

func (*LogEntriesResponse) ProtoMessage()

func (*LogEntriesResponse) Reset Uses

func (m *LogEntriesResponse) Reset()

func (*LogEntriesResponse) Size Uses

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

func (*LogEntriesResponse) String Uses

func (m *LogEntriesResponse) String() string

func (*LogEntriesResponse) Unmarshal Uses

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

type LogFileRequest Uses

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 Uses

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

func (*LogFileRequest) Marshal Uses

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

func (*LogFileRequest) MarshalTo Uses

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

func (*LogFileRequest) ProtoMessage Uses

func (*LogFileRequest) ProtoMessage()

func (*LogFileRequest) Reset Uses

func (m *LogFileRequest) Reset()

func (*LogFileRequest) Size Uses

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

func (*LogFileRequest) String Uses

func (m *LogFileRequest) String() string

func (*LogFileRequest) Unmarshal Uses

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

type LogFilesListRequest Uses

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 Uses

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

func (*LogFilesListRequest) Marshal Uses

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

func (*LogFilesListRequest) MarshalTo Uses

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

func (*LogFilesListRequest) ProtoMessage Uses

func (*LogFilesListRequest) ProtoMessage()

func (*LogFilesListRequest) Reset Uses

func (m *LogFilesListRequest) Reset()

func (*LogFilesListRequest) Size Uses

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

func (*LogFilesListRequest) String Uses

func (m *LogFilesListRequest) String() string

func (*LogFilesListRequest) Unmarshal Uses

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

type LogFilesListResponse Uses

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

func (*LogFilesListResponse) Descriptor Uses

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

func (*LogFilesListResponse) Marshal Uses

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

func (*LogFilesListResponse) MarshalTo Uses

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

func (*LogFilesListResponse) ProtoMessage Uses

func (*LogFilesListResponse) ProtoMessage()

func (*LogFilesListResponse) Reset Uses

func (m *LogFilesListResponse) Reset()

func (*LogFilesListResponse) Size Uses

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

func (*LogFilesListResponse) String Uses

func (m *LogFilesListResponse) String() string

func (*LogFilesListResponse) Unmarshal Uses

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

type LogsRequest Uses

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 Uses

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

func (*LogsRequest) Marshal Uses

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

func (*LogsRequest) MarshalTo Uses

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

func (*LogsRequest) ProtoMessage Uses

func (*LogsRequest) ProtoMessage()

func (*LogsRequest) Reset Uses

func (m *LogsRequest) Reset()

func (*LogsRequest) Size Uses

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

func (*LogsRequest) String Uses

func (m *LogsRequest) String() string

func (*LogsRequest) Unmarshal Uses

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

type MetricsRequest Uses

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 Uses

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

func (*MetricsRequest) Marshal Uses

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

func (*MetricsRequest) MarshalTo Uses

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

func (*MetricsRequest) ProtoMessage Uses

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) Reset Uses

func (m *MetricsRequest) Reset()

func (*MetricsRequest) Size Uses

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

func (*MetricsRequest) String Uses

func (m *MetricsRequest) String() string

func (*MetricsRequest) Unmarshal Uses

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

type NodeRequest Uses

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 Uses

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

func (*NodeRequest) Marshal Uses

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

func (*NodeRequest) MarshalTo Uses

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

func (*NodeRequest) ProtoMessage Uses

func (*NodeRequest) ProtoMessage()

func (*NodeRequest) Reset Uses

func (m *NodeRequest) Reset()

func (*NodeRequest) Size Uses

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

func (*NodeRequest) String Uses

func (m *NodeRequest) String() string

func (*NodeRequest) Unmarshal Uses

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

type NodesRequest Uses

type NodesRequest struct {
}

func (*NodesRequest) Descriptor Uses

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

func (*NodesRequest) Marshal Uses

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

func (*NodesRequest) MarshalTo Uses

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

func (*NodesRequest) ProtoMessage Uses

func (*NodesRequest) ProtoMessage()

func (*NodesRequest) Reset Uses

func (m *NodesRequest) Reset()

func (*NodesRequest) Size Uses

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

func (*NodesRequest) String Uses

func (m *NodesRequest) String() string

func (*NodesRequest) Unmarshal Uses

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

type NodesResponse Uses

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

func (*NodesResponse) Descriptor Uses

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

func (*NodesResponse) Marshal Uses

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

func (*NodesResponse) MarshalTo Uses

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

func (*NodesResponse) ProtoMessage Uses

func (*NodesResponse) ProtoMessage()

func (*NodesResponse) Reset Uses

func (m *NodesResponse) Reset()

func (*NodesResponse) Size Uses

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

func (*NodesResponse) String Uses

func (m *NodesResponse) String() string

func (*NodesResponse) Unmarshal Uses

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

type PrettySpan Uses

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 Uses

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

func (*PrettySpan) Marshal Uses

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

func (*PrettySpan) MarshalTo Uses

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

func (*PrettySpan) ProtoMessage Uses

func (*PrettySpan) ProtoMessage()

func (*PrettySpan) Reset Uses

func (m *PrettySpan) Reset()

func (*PrettySpan) Size Uses

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

func (*PrettySpan) String Uses

func (m *PrettySpan) String() string

func (*PrettySpan) Unmarshal Uses

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

type RaftDebugRequest Uses

type RaftDebugRequest struct {
}

func (*RaftDebugRequest) Descriptor Uses

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

func (*RaftDebugRequest) Marshal Uses

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

func (*RaftDebugRequest) MarshalTo Uses

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

func (*RaftDebugRequest) ProtoMessage Uses

func (*RaftDebugRequest) ProtoMessage()

func (*RaftDebugRequest) Reset Uses

func (m *RaftDebugRequest) Reset()

func (*RaftDebugRequest) Size Uses

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

func (*RaftDebugRequest) String Uses

func (m *RaftDebugRequest) String() string

func (*RaftDebugRequest) Unmarshal Uses

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

type RaftDebugResponse Uses

type RaftDebugResponse struct {
    Ranges map[github_com_cockroachdb_cockroach_roachpb.RangeID]RaftRangeStatus `protobuf:"bytes,1,rep,name=ranges,castkey=github.com/cockroachdb/cockroach/roachpb.RangeID" json:"ranges" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value"`
    Errors []RaftRangeError                                                     `protobuf:"bytes,2,rep,name=errors" json:"errors"`
}

func (*RaftDebugResponse) Descriptor Uses

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

func (*RaftDebugResponse) Marshal Uses

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

func (*RaftDebugResponse) MarshalTo Uses

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

func (*RaftDebugResponse) ProtoMessage Uses

func (*RaftDebugResponse) ProtoMessage()

func (*RaftDebugResponse) Reset Uses

func (m *RaftDebugResponse) Reset()

func (*RaftDebugResponse) Size Uses

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

func (*RaftDebugResponse) String Uses

func (m *RaftDebugResponse) String() string

func (*RaftDebugResponse) Unmarshal Uses

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

type RaftRangeError Uses

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

func (*RaftRangeError) Descriptor Uses

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

func (*RaftRangeError) Marshal Uses

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

func (*RaftRangeError) MarshalTo Uses

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

func (*RaftRangeError) ProtoMessage Uses

func (*RaftRangeError) ProtoMessage()

func (*RaftRangeError) Reset Uses

func (m *RaftRangeError) Reset()

func (*RaftRangeError) Size Uses

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

func (*RaftRangeError) String Uses

func (m *RaftRangeError) String() string

func (*RaftRangeError) Unmarshal Uses

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

type RaftRangeNode Uses

type RaftRangeNode struct {
    NodeID github_com_cockroachdb_cockroach_roachpb.NodeID `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3,casttype=github.com/cockroachdb/cockroach/roachpb.NodeID" json:"node_id,omitempty"`
    Range  RangeInfo                                       `protobuf:"bytes,2,opt,name=range" json:"range"`
}

func (*RaftRangeNode) Descriptor Uses

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

func (*RaftRangeNode) Marshal Uses

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

func (*RaftRangeNode) MarshalTo Uses

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

func (*RaftRangeNode) ProtoMessage Uses

func (*RaftRangeNode) ProtoMessage()

func (*RaftRangeNode) Reset Uses

func (m *RaftRangeNode) Reset()

func (*RaftRangeNode) Size Uses

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

func (*RaftRangeNode) String Uses

func (m *RaftRangeNode) String() string

func (*RaftRangeNode) Unmarshal Uses

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

type RaftRangeStatus Uses

type RaftRangeStatus struct {
    RangeID github_com_cockroachdb_cockroach_roachpb.RangeID `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3,casttype=github.com/cockroachdb/cockroach/roachpb.RangeID" json:"range_id,omitempty"`
    Errors  []RaftRangeError                                 `protobuf:"bytes,2,rep,name=errors" json:"errors"`
    Nodes   []RaftRangeNode                                  `protobuf:"bytes,3,rep,name=nodes" json:"nodes"`
}

func (*RaftRangeStatus) Descriptor Uses

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

func (*RaftRangeStatus) Marshal Uses

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

func (*RaftRangeStatus) MarshalTo Uses

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

func (*RaftRangeStatus) ProtoMessage Uses

func (*RaftRangeStatus) ProtoMessage()

func (*RaftRangeStatus) Reset Uses

func (m *RaftRangeStatus) Reset()

func (*RaftRangeStatus) Size Uses

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

func (*RaftRangeStatus) String Uses

func (m *RaftRangeStatus) String() string

func (*RaftRangeStatus) Unmarshal Uses

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

type RaftState Uses

type RaftState struct {
    ReplicaID uint64 `protobuf:"varint,1,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"`
    // TODO(tamird): use raftpb's HardState. This leads to complications for
    // the ui protos which are currently unsolved.
    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 `protobuf:"bytes,6,rep,name=progress" json:"progress" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value"`
}

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

func (*RaftState) Descriptor Uses

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

func (*RaftState) Marshal Uses

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

func (*RaftState) MarshalTo Uses

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

func (*RaftState) ProtoMessage Uses

func (*RaftState) ProtoMessage()

func (*RaftState) Reset Uses

func (m *RaftState) Reset()

func (*RaftState) Size Uses

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

func (*RaftState) String Uses

func (m *RaftState) String() string

func (*RaftState) Unmarshal Uses

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

type RaftState_Progress Uses

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 Uses

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

func (*RaftState_Progress) Marshal Uses

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

func (*RaftState_Progress) MarshalTo Uses

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

func (*RaftState_Progress) ProtoMessage Uses

func (*RaftState_Progress) ProtoMessage()

func (*RaftState_Progress) Reset Uses

func (m *RaftState_Progress) Reset()

func (*RaftState_Progress) Size Uses

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

func (*RaftState_Progress) String Uses

func (m *RaftState_Progress) String() string

func (*RaftState_Progress) Unmarshal Uses

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

type RangeInfo Uses

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"`
}

func (*RangeInfo) Descriptor Uses

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

func (*RangeInfo) Marshal Uses

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

func (*RangeInfo) MarshalTo Uses

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

func (*RangeInfo) ProtoMessage Uses

func (*RangeInfo) ProtoMessage()

func (*RangeInfo) Reset Uses

func (m *RangeInfo) Reset()

func (*RangeInfo) Size Uses

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

func (*RangeInfo) String Uses

func (m *RangeInfo) String() string

func (*RangeInfo) Unmarshal Uses

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

type RangesRequest Uses

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"`
}

func (*RangesRequest) Descriptor Uses

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

func (*RangesRequest) Marshal Uses

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

func (*RangesRequest) MarshalTo Uses

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

func (*RangesRequest) ProtoMessage Uses

func (*RangesRequest) ProtoMessage()

func (*RangesRequest) Reset Uses

func (m *RangesRequest) Reset()

func (*RangesRequest) Size Uses

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

func (*RangesRequest) String Uses

func (m *RangesRequest) String() string

func (*RangesRequest) Unmarshal Uses

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

type RangesResponse Uses

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

func (*RangesResponse) Descriptor Uses

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

func (*RangesResponse) Marshal Uses

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

func (*RangesResponse) MarshalTo Uses

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

func (*RangesResponse) ProtoMessage Uses

func (*RangesResponse) ProtoMessage()

func (*RangesResponse) Reset Uses

func (m *RangesResponse) Reset()

func (*RangesResponse) Size Uses

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

func (*RangesResponse) String Uses

func (m *RangesResponse) String() string

func (*RangesResponse) Unmarshal Uses

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

type SetUIDataRequest Uses

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 `protobuf:"bytes,1,rep,name=key_values,json=keyValues" json:"key_values,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}

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

func (*SetUIDataRequest) Descriptor Uses

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

func (*SetUIDataRequest) Marshal Uses

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

func (*SetUIDataRequest) MarshalTo Uses

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

func (*SetUIDataRequest) ProtoMessage Uses

func (*SetUIDataRequest) ProtoMessage()

func (*SetUIDataRequest) Reset Uses

func (m *SetUIDataRequest) Reset()

func (*SetUIDataRequest) Size Uses

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

func (*SetUIDataRequest) String Uses

func (m *SetUIDataRequest) String() string

func (*SetUIDataRequest) Unmarshal Uses

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

type SetUIDataResponse Uses

type SetUIDataResponse struct {
}

SetUIDataResponse is currently an empty response.

func (*SetUIDataResponse) Descriptor Uses

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

func (*SetUIDataResponse) Marshal Uses

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

func (*SetUIDataResponse) MarshalTo Uses

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

func (*SetUIDataResponse) ProtoMessage Uses

func (*SetUIDataResponse) ProtoMessage()

func (*SetUIDataResponse) Reset Uses

func (m *SetUIDataResponse) Reset()

func (*SetUIDataResponse) Size Uses

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

func (*SetUIDataResponse) String Uses

func (m *SetUIDataResponse) String() string

func (*SetUIDataResponse) Unmarshal Uses

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

type SpanStatsRequest Uses

type SpanStatsRequest struct {
    NodeID   string                                        `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
    StartKey github_com_cockroachdb_cockroach_roachpb.RKey `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3,casttype=github.com/cockroachdb/cockroach/roachpb.RKey" json:"start_key,omitempty"`
    EndKey   github_com_cockroachdb_cockroach_roachpb.RKey `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3,casttype=github.com/cockroachdb/cockroach/roachpb.RKey" json:"end_key,omitempty"`
}

func (*SpanStatsRequest) Descriptor Uses

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

func (*SpanStatsRequest) Marshal Uses

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

func (*SpanStatsRequest) MarshalTo Uses

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

func (*SpanStatsRequest) ProtoMessage Uses

func (*SpanStatsRequest) ProtoMessage()

func (*SpanStatsRequest) Reset Uses

func (m *SpanStatsRequest) Reset()

func (*SpanStatsRequest) Size Uses

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

func (*SpanStatsRequest) String Uses

func (m *SpanStatsRequest) String() string

func (*SpanStatsRequest) Unmarshal Uses

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

type SpanStatsResponse Uses

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 Uses

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

func (*SpanStatsResponse) Marshal Uses

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

func (*SpanStatsResponse) MarshalTo Uses

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

func (*SpanStatsResponse) ProtoMessage Uses

func (*SpanStatsResponse) ProtoMessage()

func (*SpanStatsResponse) Reset Uses

func (m *SpanStatsResponse) Reset()

func (*SpanStatsResponse) Size Uses

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

func (*SpanStatsResponse) String Uses

func (m *SpanStatsResponse) String() string

func (*SpanStatsResponse) Unmarshal Uses

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

type StacksRequest Uses

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 Uses

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

func (*StacksRequest) Marshal Uses

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

func (*StacksRequest) MarshalTo Uses

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

func (*StacksRequest) ProtoMessage Uses

func (*StacksRequest) ProtoMessage()

func (*StacksRequest) Reset Uses

func (m *StacksRequest) Reset()

func (*StacksRequest) Size Uses

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

func (*StacksRequest) String Uses

func (m *StacksRequest) String() string

func (*StacksRequest) Unmarshal Uses

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

type StatusClient Uses

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)
    // 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)
}

func NewStatusClient Uses

func NewStatusClient(cc *grpc.ClientConn) StatusClient

type StatusServer Uses

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)
    // 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)
}

type TableDetailsRequest Uses

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 Uses

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

func (*TableDetailsRequest) Marshal Uses

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

func (*TableDetailsRequest) MarshalTo Uses

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

func (*TableDetailsRequest) ProtoMessage Uses

func (*TableDetailsRequest) ProtoMessage()

func (*TableDetailsRequest) Reset Uses

func (m *TableDetailsRequest) Reset()

func (*TableDetailsRequest) Size Uses

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

func (*TableDetailsRequest) String Uses

func (m *TableDetailsRequest) String() string

func (*TableDetailsRequest) Unmarshal Uses

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

type TableDetailsResponse Uses

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"`
    // 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 `protobuf:"varint,7,opt,name=zone_config_level,json=zoneConfigLevel,proto3,enum=cockroach.server.serverpb.ZoneConfigurationLevel" json:"zone_config_level,omitempty"`
    // 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 Uses

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

func (*TableDetailsResponse) Marshal Uses

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

func (*TableDetailsResponse) MarshalTo Uses

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

func (*TableDetailsResponse) ProtoMessage Uses

func (*TableDetailsResponse) ProtoMessage()

func (*TableDetailsResponse) Reset Uses

func (m *TableDetailsResponse) Reset()

func (*TableDetailsResponse) Size Uses

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

func (*TableDetailsResponse) String Uses

func (m *TableDetailsResponse) String() string

func (*TableDetailsResponse) Unmarshal Uses

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

type TableDetailsResponse_Column Uses

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 Uses

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

func (*TableDetailsResponse_Column) Marshal Uses

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

func (*TableDetailsResponse_Column) MarshalTo Uses

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

func (*TableDetailsResponse_Column) ProtoMessage Uses

func (*TableDetailsResponse_Column) ProtoMessage()

func (*TableDetailsResponse_Column) Reset Uses

func (m *TableDetailsResponse_Column) Reset()

func (*TableDetailsResponse_Column) Size Uses

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

func (*TableDetailsResponse_Column) String Uses

func (m *TableDetailsResponse_Column) String() string

func (*TableDetailsResponse_Column) Unmarshal Uses

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

type TableDetailsResponse_Grant Uses

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 Uses

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

func (*TableDetailsResponse_Grant) Marshal Uses

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

func (*TableDetailsResponse_Grant) MarshalTo Uses

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

func (*TableDetailsResponse_Grant) ProtoMessage Uses

func (*TableDetailsResponse_Grant) ProtoMessage()

func (*TableDetailsResponse_Grant) Reset Uses

func (m *TableDetailsResponse_Grant) Reset()

func (*TableDetailsResponse_Grant) Size Uses

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

func (*TableDetailsResponse_Grant) String Uses

func (m *TableDetailsResponse_Grant) String() string

func (*TableDetailsResponse_Grant) Unmarshal Uses

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

type TableDetailsResponse_Index Uses

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 Uses

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

func (*TableDetailsResponse_Index) Marshal Uses

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

func (*TableDetailsResponse_Index) MarshalTo Uses

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

func (*TableDetailsResponse_Index) ProtoMessage Uses

func (*TableDetailsResponse_Index) ProtoMessage()

func (*TableDetailsResponse_Index) Reset Uses

func (m *TableDetailsResponse_Index) Reset()

func (*TableDetailsResponse_Index) Size Uses

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

func (*TableDetailsResponse_Index) String Uses

func (m *TableDetailsResponse_Index) String() string

func (*TableDetailsResponse_Index) Unmarshal Uses

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

type TableStatsRequest Uses

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 Uses

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

func (*TableStatsRequest) Marshal Uses

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

func (*TableStatsRequest) MarshalTo Uses

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

func (*TableStatsRequest) ProtoMessage Uses

func (*TableStatsRequest) ProtoMessage()

func (*TableStatsRequest) Reset Uses

func (m *TableStatsRequest) Reset()

func (*TableStatsRequest) Size Uses

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

func (*TableStatsRequest) String Uses

func (m *TableStatsRequest) String() string

func (*TableStatsRequest) Unmarshal Uses

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

type TableStatsResponse Uses

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 Uses

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

func (*TableStatsResponse) Marshal Uses

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

func (*TableStatsResponse) MarshalTo Uses

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

func (*TableStatsResponse) ProtoMessage Uses

func (*TableStatsResponse) ProtoMessage()

func (*TableStatsResponse) Reset Uses

func (m *TableStatsResponse) Reset()

func (*TableStatsResponse) Size Uses

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

func (*TableStatsResponse) String Uses

func (m *TableStatsResponse) String() string

func (*TableStatsResponse) Unmarshal Uses

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

type TableStatsResponse_MissingNode Uses

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 Uses

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

func (*TableStatsResponse_MissingNode) Marshal Uses

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

func (*TableStatsResponse_MissingNode) MarshalTo Uses

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

func (*TableStatsResponse_MissingNode) ProtoMessage Uses

func (*TableStatsResponse_MissingNode) ProtoMessage()

func (*TableStatsResponse_MissingNode) Reset Uses

func (m *TableStatsResponse_MissingNode) Reset()

func (*TableStatsResponse_MissingNode) Size Uses

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

func (*TableStatsResponse_MissingNode) String Uses

func (m *TableStatsResponse_MissingNode) String() string

func (*TableStatsResponse_MissingNode) Unmarshal Uses

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

type UsersRequest Uses

type UsersRequest struct {
}

UsersRequest requests a list of users.

func (*UsersRequest) Descriptor Uses

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

func (*UsersRequest) Marshal Uses

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

func (*UsersRequest) MarshalTo Uses

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

func (*UsersRequest) ProtoMessage Uses

func (*UsersRequest) ProtoMessage()

func (*UsersRequest) Reset Uses

func (m *UsersRequest) Reset()

func (*UsersRequest) Size Uses

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

func (*UsersRequest) String Uses

func (m *UsersRequest) String() string

func (*UsersRequest) Unmarshal Uses

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

type UsersResponse Uses

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 Uses

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

func (*UsersResponse) Marshal Uses

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

func (*UsersResponse) MarshalTo Uses

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

func (*UsersResponse) ProtoMessage Uses

func (*UsersResponse) ProtoMessage()

func (*UsersResponse) Reset Uses

func (m *UsersResponse) Reset()

func (*UsersResponse) Size Uses

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

func (*UsersResponse) String Uses

func (m *UsersResponse) String() string

func (*UsersResponse) Unmarshal Uses

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

type UsersResponse_User Uses

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 Uses

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

func (*UsersResponse_User) Marshal Uses

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

func (*UsersResponse_User) MarshalTo Uses

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

func (*UsersResponse_User) ProtoMessage Uses

func (*UsersResponse_User) ProtoMessage()

func (*UsersResponse_User) Reset Uses

func (m *UsersResponse_User) Reset()

func (*UsersResponse_User) Size Uses

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

func (*UsersResponse_User) String Uses

func (m *UsersResponse_User) String() string

func (*UsersResponse_User) Unmarshal Uses

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

type ZoneConfigurationLevel Uses

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 Uses

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

func (ZoneConfigurationLevel) String Uses

func (x ZoneConfigurationLevel) String() string

Package serverpb imports 24 packages (graph). Updated 2016-09-23. Refresh now. Tools for package owners. This is a quick bug-fix fork (has fewer than three commits, and only during the week it was created).