cockroach: github.com/cockroachdb/cockroach/pkg/server/serverpb Index | Files

package serverpb

import "github.com/cockroachdb/cockroach/pkg/server/serverpb"

Package serverpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package serverpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package serverpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Package Files

admin.go admin.pb.go admin.pb.gw.go authentication.pb.go authentication.pb.gw.go init.pb.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 (
    ErrInvalidLengthAuthentication = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowAuthentication   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthInit = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowInit   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthStatus = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowStatus   = fmt.Errorf("proto: integer overflow")
)
var ActiveQuery_Phase_name = map[int32]string{
    0:  "PREPARING",
    1:  "EXECUTING",
}
var ActiveQuery_Phase_value = map[string]int32{
    "PREPARING": 0,
    "EXECUTING": 1,
}
var CertificateDetails_CertificateType_name = map[int32]string{
    0:  "CA",
    1:  "NODE",
    2:  "CLIENT_CA",
    3:  "CLIENT",
    4:  "UI_CA",
    5:  "UI",
}
var CertificateDetails_CertificateType_value = map[string]int32{
    "CA":        0,
    "NODE":      1,
    "CLIENT_CA": 2,
    "CLIENT":    3,
    "UI_CA":     4,
    "UI":        5,
}
var DrainMode_name = map[int32]string{
    0:  "CLIENT",
    1:  "LEASES",
}
var DrainMode_value = map[string]int32{
    "CLIENT": 0,
    "LEASES": 1,
}
var FileType_name = map[int32]string{
    0:  "HEAP",
    1:  "GOROUTINES",
}
var FileType_value = map[string]int32{
    "HEAP":       0,
    "GOROUTINES": 1,
}
var ProfileRequest_Type_name = map[int32]string{
    0: "HEAP",
}
var ProfileRequest_Type_value = map[string]int32{
    "HEAP": 0,
}
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 RegisterAdminHandlerClient Uses

func RegisterAdminHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AdminClient) error

RegisterAdminHandlerClient registers the http handlers for service Admin to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AdminClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AdminClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AdminClient" to call the correct interceptors.

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

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

func RegisterLogInHandler Uses

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

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

func RegisterLogInHandlerClient Uses

func RegisterLogInHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LogInClient) error

RegisterLogInHandlerClient registers the http handlers for service LogIn to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "LogInClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "LogInClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "LogInClient" to call the correct interceptors.

func RegisterLogInHandlerFromEndpoint Uses

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

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

func RegisterLogInServer Uses

func RegisterLogInServer(s *grpc.Server, srv LogInServer)

func RegisterLogOutHandler Uses

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

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

func RegisterLogOutHandlerClient Uses

func RegisterLogOutHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LogOutClient) error

RegisterLogOutHandlerClient registers the http handlers for service LogOut to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "LogOutClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "LogOutClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "LogOutClient" to call the correct interceptors.

func RegisterLogOutHandlerFromEndpoint Uses

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

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

func RegisterLogOutServer Uses

func RegisterLogOutServer(s *grpc.Server, srv LogOutServer)

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

func RegisterStatusHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StatusClient) error

RegisterStatusHandlerClient registers the http handlers for service Status to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "StatusClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "StatusClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "StatusClient" to call the correct interceptors.

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

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

ActiveQuery represents a query in flight on some Session.

func (*ActiveQuery) Descriptor Uses

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

func (*ActiveQuery) Marshal Uses

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

func (*ActiveQuery) MarshalTo Uses

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

func (*ActiveQuery) ProtoMessage Uses

func (*ActiveQuery) ProtoMessage()

func (*ActiveQuery) Reset Uses

func (m *ActiveQuery) Reset()

func (*ActiveQuery) Size Uses

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

func (*ActiveQuery) String Uses

func (m *ActiveQuery) String() string

func (*ActiveQuery) Unmarshal Uses

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

func (*ActiveQuery) XXX_DiscardUnknown Uses

func (m *ActiveQuery) XXX_DiscardUnknown()

func (*ActiveQuery) XXX_Marshal Uses

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

func (*ActiveQuery) XXX_Merge Uses

func (dst *ActiveQuery) XXX_Merge(src proto.Message)

func (*ActiveQuery) XXX_Size Uses

func (m *ActiveQuery) XXX_Size() int

func (*ActiveQuery) XXX_Unmarshal Uses

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

type ActiveQuery_Phase Uses

type ActiveQuery_Phase int32

Enum for phase of execution.

const (
    ActiveQuery_PREPARING ActiveQuery_Phase = 0
    ActiveQuery_EXECUTING ActiveQuery_Phase = 1
)

func (ActiveQuery_Phase) EnumDescriptor Uses

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

func (ActiveQuery_Phase) String Uses

func (x ActiveQuery_Phase) String() string

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 URL: /_admin/v1/nontablestats
    NonTableStats(ctx context.Context, in *NonTableStatsRequest, opts ...grpc.CallOption) (*NonTableStatsResponse, error)
    // Example URLs:
    // Example URLs:
    // - /_admin/v1/events
    // - /_admin/v1/events?limit=100
    // - /_admin/v1/events?type=create_table
    // - /_admin/v1/events?type=create_table&limit=100
    // - /_admin/v1/events?type=drop_table&target_id=4
    // - /_admin/v1/events?type=drop_table&target_id=4&limit=100
    Events(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (*EventsResponse, error)
    // This requires a POST. Because of the libraries we're using, the POST body
    // must be in the following format:
    //
    // {"key_values":
    //   { "key1": "base64_encoded_value1"},
    //   ...
    //   { "keyN": "base64_encoded_valueN"},
    // }
    //
    // Note that all keys are quoted strings and that all values are base64-
    // encoded.
    //
    // Together, SetUIData and GetUIData provide access to a "cookie jar" for the
    // admin UI. The structure of the underlying data is meant to be opaque to the
    // server.
    SetUIData(ctx context.Context, in *SetUIDataRequest, opts ...grpc.CallOption) (*SetUIDataResponse, error)
    // Example URLs:
    // - /_admin/v1/uidata?keys=MYKEY
    // - /_admin/v1/uidata?keys=MYKEY1&keys=MYKEY2
    //
    // Yes, it's a little odd that the query parameter is named "keys" instead of
    // "key". I would've preferred that the URL parameter be named "key". However,
    // it's clearer for the protobuf field to be named "keys," which makes the URL
    // parameter "keys" as well.
    GetUIData(ctx context.Context, in *GetUIDataRequest, opts ...grpc.CallOption) (*GetUIDataResponse, error)
    // Cluster returns metadata for the cluster.
    Cluster(ctx context.Context, in *ClusterRequest, opts ...grpc.CallOption) (*ClusterResponse, error)
    // Settings returns the cluster-wide settings for the cluster.
    Settings(ctx context.Context, in *SettingsRequest, opts ...grpc.CallOption) (*SettingsResponse, error)
    // Health returns liveness for the node target of the request.
    Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
    // Liveness returns the liveness state of all nodes on the cluster.
    Liveness(ctx context.Context, in *LivenessRequest, opts ...grpc.CallOption) (*LivenessResponse, error)
    // Jobs returns the job records for all jobs of the given status and type.
    Jobs(ctx context.Context, in *JobsRequest, opts ...grpc.CallOption) (*JobsResponse, error)
    // Locations returns the locality location records.
    Locations(ctx context.Context, in *LocationsRequest, opts ...grpc.CallOption) (*LocationsResponse, error)
    // QueryPlan returns the query plans for a SQL string.
    QueryPlan(ctx context.Context, in *QueryPlanRequest, opts ...grpc.CallOption) (*QueryPlanResponse, error)
    // Drain puts the node into the specified drain mode(s) and optionally
    // instructs the process to terminate.
    Drain(ctx context.Context, in *DrainRequest, opts ...grpc.CallOption) (Admin_DrainClient, error)
    // Decommission puts the node(s) into the specified decommissioning state.
    Decommission(ctx context.Context, in *DecommissionRequest, opts ...grpc.CallOption) (*DecommissionStatusResponse, error)
    // DecommissionStatus retrieves the decommissioning status of the specified nodes.
    DecommissionStatus(ctx context.Context, in *DecommissionStatusRequest, opts ...grpc.CallOption) (*DecommissionStatusResponse, error)
    // URL: /_admin/v1/rangelog
    // URL: /_admin/v1/rangelog?limit=100
    // URL: /_admin/v1/rangelog/1
    // URL: /_admin/v1/rangelog/1?limit=100
    RangeLog(ctx context.Context, in *RangeLogRequest, opts ...grpc.CallOption) (*RangeLogResponse, error)
    DataDistribution(ctx context.Context, in *DataDistributionRequest, opts ...grpc.CallOption) (*DataDistributionResponse, error)
    // URL: /_admin/v1/metricmetadata
    AllMetricMetadata(ctx context.Context, in *MetricMetadataRequest, opts ...grpc.CallOption) (*MetricMetadataResponse, error)
    // URL: /_admin/v1/chartcatalog
    ChartCatalog(ctx context.Context, in *ChartCatalogRequest, opts ...grpc.CallOption) (*ChartCatalogResponse, error)
    // EnqueueRange runs the specified range through the specified queue on the
    // range's leaseholder store, returning the detailed trace and error
    // information from doing so. Parameters must be provided in the body of the
    // POST request.
    // For example:
    //
    // {
    //   "queue": "raftlog",
    //   "rangeId": 10
    // }
    EnqueueRange(ctx context.Context, in *EnqueueRangeRequest, opts ...grpc.CallOption) (*EnqueueRangeResponse, error)
}

AdminClient is the client API for Admin service.

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

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 URL: /_admin/v1/nontablestats
    NonTableStats(context.Context, *NonTableStatsRequest) (*NonTableStatsResponse, error)
    // Example URLs:
    // Example URLs:
    // - /_admin/v1/events
    // - /_admin/v1/events?limit=100
    // - /_admin/v1/events?type=create_table
    // - /_admin/v1/events?type=create_table&limit=100
    // - /_admin/v1/events?type=drop_table&target_id=4
    // - /_admin/v1/events?type=drop_table&target_id=4&limit=100
    Events(context.Context, *EventsRequest) (*EventsResponse, error)
    // This requires a POST. Because of the libraries we're using, the POST body
    // must be in the following format:
    //
    // {"key_values":
    //   { "key1": "base64_encoded_value1"},
    //   ...
    //   { "keyN": "base64_encoded_valueN"},
    // }
    //
    // Note that all keys are quoted strings and that all values are base64-
    // encoded.
    //
    // Together, SetUIData and GetUIData provide access to a "cookie jar" for the
    // admin UI. The structure of the underlying data is meant to be opaque to the
    // server.
    SetUIData(context.Context, *SetUIDataRequest) (*SetUIDataResponse, error)
    // Example URLs:
    // - /_admin/v1/uidata?keys=MYKEY
    // - /_admin/v1/uidata?keys=MYKEY1&keys=MYKEY2
    //
    // Yes, it's a little odd that the query parameter is named "keys" instead of
    // "key". I would've preferred that the URL parameter be named "key". However,
    // it's clearer for the protobuf field to be named "keys," which makes the URL
    // parameter "keys" as well.
    GetUIData(context.Context, *GetUIDataRequest) (*GetUIDataResponse, error)
    // Cluster returns metadata for the cluster.
    Cluster(context.Context, *ClusterRequest) (*ClusterResponse, error)
    // Settings returns the cluster-wide settings for the cluster.
    Settings(context.Context, *SettingsRequest) (*SettingsResponse, error)
    // Health returns liveness for the node target of the request.
    Health(context.Context, *HealthRequest) (*HealthResponse, error)
    // Liveness returns the liveness state of all nodes on the cluster.
    Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error)
    // Jobs returns the job records for all jobs of the given status and type.
    Jobs(context.Context, *JobsRequest) (*JobsResponse, error)
    // Locations returns the locality location records.
    Locations(context.Context, *LocationsRequest) (*LocationsResponse, error)
    // QueryPlan returns the query plans for a SQL string.
    QueryPlan(context.Context, *QueryPlanRequest) (*QueryPlanResponse, error)
    // Drain puts the node into the specified drain mode(s) and optionally
    // instructs the process to terminate.
    Drain(*DrainRequest, Admin_DrainServer) error
    // Decommission puts the node(s) into the specified decommissioning state.
    Decommission(context.Context, *DecommissionRequest) (*DecommissionStatusResponse, error)
    // DecommissionStatus retrieves the decommissioning status of the specified nodes.
    DecommissionStatus(context.Context, *DecommissionStatusRequest) (*DecommissionStatusResponse, error)
    // URL: /_admin/v1/rangelog
    // URL: /_admin/v1/rangelog?limit=100
    // URL: /_admin/v1/rangelog/1
    // URL: /_admin/v1/rangelog/1?limit=100
    RangeLog(context.Context, *RangeLogRequest) (*RangeLogResponse, error)
    DataDistribution(context.Context, *DataDistributionRequest) (*DataDistributionResponse, error)
    // URL: /_admin/v1/metricmetadata
    AllMetricMetadata(context.Context, *MetricMetadataRequest) (*MetricMetadataResponse, error)
    // URL: /_admin/v1/chartcatalog
    ChartCatalog(context.Context, *ChartCatalogRequest) (*ChartCatalogResponse, error)
    // EnqueueRange runs the specified range through the specified queue on the
    // range's leaseholder store, returning the detailed trace and error
    // information from doing so. Parameters must be provided in the body of the
    // POST request.
    // For example:
    //
    // {
    //   "queue": "raftlog",
    //   "rangeId": 10
    // }
    EnqueueRange(context.Context, *EnqueueRangeRequest) (*EnqueueRangeResponse, error)
}

AdminServer is the server API for Admin service.

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

type AllocatorDryRun struct {
    RangeID github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/roachpb.RangeID" json:"range_id,omitempty"`
    Events  []*TraceEvent                                        `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
}

func (*AllocatorDryRun) Descriptor Uses

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

func (*AllocatorDryRun) Marshal Uses

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

func (*AllocatorDryRun) MarshalTo Uses

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

func (*AllocatorDryRun) ProtoMessage Uses

func (*AllocatorDryRun) ProtoMessage()

func (*AllocatorDryRun) Reset Uses

func (m *AllocatorDryRun) Reset()

func (*AllocatorDryRun) Size Uses

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

func (*AllocatorDryRun) String Uses

func (m *AllocatorDryRun) String() string

func (*AllocatorDryRun) Unmarshal Uses

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

func (*AllocatorDryRun) XXX_DiscardUnknown Uses

func (m *AllocatorDryRun) XXX_DiscardUnknown()

func (*AllocatorDryRun) XXX_Marshal Uses

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

func (*AllocatorDryRun) XXX_Merge Uses

func (dst *AllocatorDryRun) XXX_Merge(src proto.Message)

func (*AllocatorDryRun) XXX_Size Uses

func (m *AllocatorDryRun) XXX_Size() int

func (*AllocatorDryRun) XXX_Unmarshal Uses

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

type AllocatorRangeRequest Uses

type AllocatorRangeRequest struct {
    RangeId int64 `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
}

func (*AllocatorRangeRequest) Descriptor Uses

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

func (*AllocatorRangeRequest) Marshal Uses

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

func (*AllocatorRangeRequest) MarshalTo Uses

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

func (*AllocatorRangeRequest) ProtoMessage Uses

func (*AllocatorRangeRequest) ProtoMessage()

func (*AllocatorRangeRequest) Reset Uses

func (m *AllocatorRangeRequest) Reset()

func (*AllocatorRangeRequest) Size Uses

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

func (*AllocatorRangeRequest) String Uses

func (m *AllocatorRangeRequest) String() string

func (*AllocatorRangeRequest) Unmarshal Uses

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

func (*AllocatorRangeRequest) XXX_DiscardUnknown Uses

func (m *AllocatorRangeRequest) XXX_DiscardUnknown()

func (*AllocatorRangeRequest) XXX_Marshal Uses

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

func (*AllocatorRangeRequest) XXX_Merge Uses

func (dst *AllocatorRangeRequest) XXX_Merge(src proto.Message)

func (*AllocatorRangeRequest) XXX_Size Uses

func (m *AllocatorRangeRequest) XXX_Size() int

func (*AllocatorRangeRequest) XXX_Unmarshal Uses

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

type AllocatorRangeResponse Uses

type AllocatorRangeResponse struct {
    // The NodeID of the store whose dry run is returned. Only the leaseholder
    // for a given range will do an allocator dry run for it.
    NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/roachpb.NodeID" json:"node_id,omitempty"`
    DryRun *AllocatorDryRun                                    `protobuf:"bytes,2,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
}

func (*AllocatorRangeResponse) Descriptor Uses

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

func (*AllocatorRangeResponse) Marshal Uses

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

func (*AllocatorRangeResponse) MarshalTo Uses

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

func (*AllocatorRangeResponse) ProtoMessage Uses

func (*AllocatorRangeResponse) ProtoMessage()

func (*AllocatorRangeResponse) Reset Uses

func (m *AllocatorRangeResponse) Reset()

func (*AllocatorRangeResponse) Size Uses

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

func (*AllocatorRangeResponse) String Uses

func (m *AllocatorRangeResponse) String() string

func (*AllocatorRangeResponse) Unmarshal Uses

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

func (*AllocatorRangeResponse) XXX_DiscardUnknown Uses

func (m *AllocatorRangeResponse) XXX_DiscardUnknown()

func (*AllocatorRangeResponse) XXX_Marshal Uses

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

func (*AllocatorRangeResponse) XXX_Merge Uses

func (dst *AllocatorRangeResponse) XXX_Merge(src proto.Message)

func (*AllocatorRangeResponse) XXX_Size Uses

func (m *AllocatorRangeResponse) XXX_Size() int

func (*AllocatorRangeResponse) XXX_Unmarshal Uses

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

type AllocatorRequest Uses

type AllocatorRequest struct {
    NodeId   string                                                 `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
    RangeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `protobuf:"varint,2,rep,packed,name=range_ids,json=rangeIds,proto3,casttype=github.com/cockroachdb/cockroach/pkg/roachpb.RangeID" json:"range_ids,omitempty"`
}

func (*AllocatorRequest) Descriptor Uses

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

func (*AllocatorRequest) Marshal Uses

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

func (*AllocatorRequest) MarshalTo Uses

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

func (*AllocatorRequest) ProtoMessage Uses

func (*AllocatorRequest) ProtoMessage()

func (*AllocatorRequest) Reset Uses

func (m *AllocatorRequest) Reset()

func (*AllocatorRequest) Size Uses

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

func (*AllocatorRequest) String Uses

func (m *AllocatorRequest) String() string

func (*AllocatorRequest) Unmarshal Uses

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

func (*AllocatorRequest) XXX_DiscardUnknown Uses

func (m *AllocatorRequest) XXX_DiscardUnknown()

func (*AllocatorRequest) XXX_Marshal Uses

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

func (*AllocatorRequest) XXX_Merge Uses

func (dst *AllocatorRequest) XXX_Merge(src proto.Message)

func (*AllocatorRequest) XXX_Size Uses

func (m *AllocatorRequest) XXX_Size() int

func (*AllocatorRequest) XXX_Unmarshal Uses

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

type AllocatorResponse Uses

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

func (*AllocatorResponse) Descriptor Uses

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

func (*AllocatorResponse) Marshal Uses

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

func (*AllocatorResponse) MarshalTo Uses

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

func (*AllocatorResponse) ProtoMessage Uses

func (*AllocatorResponse) ProtoMessage()

func (*AllocatorResponse) Reset Uses

func (m *AllocatorResponse) Reset()

func (*AllocatorResponse) Size Uses

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

func (*AllocatorResponse) String Uses

func (m *AllocatorResponse) String() string

func (*AllocatorResponse) Unmarshal Uses

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

func (*AllocatorResponse) XXX_DiscardUnknown Uses

func (m *AllocatorResponse) XXX_DiscardUnknown()

func (*AllocatorResponse) XXX_Marshal Uses

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

func (*AllocatorResponse) XXX_Merge Uses

func (dst *AllocatorResponse) XXX_Merge(src proto.Message)

func (*AllocatorResponse) XXX_Size Uses

func (m *AllocatorResponse) XXX_Size() int

func (*AllocatorResponse) XXX_Unmarshal Uses

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

type BootstrapRequest Uses

type BootstrapRequest struct {
}

func (*BootstrapRequest) Descriptor Uses

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

func (*BootstrapRequest) Marshal Uses

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

func (*BootstrapRequest) MarshalTo Uses

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

func (*BootstrapRequest) ProtoMessage Uses

func (*BootstrapRequest) ProtoMessage()

func (*BootstrapRequest) Reset Uses

func (m *BootstrapRequest) Reset()

func (*BootstrapRequest) Size Uses

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

func (*BootstrapRequest) String Uses

func (m *BootstrapRequest) String() string

func (*BootstrapRequest) Unmarshal Uses

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

func (*BootstrapRequest) XXX_DiscardUnknown Uses

func (m *BootstrapRequest) XXX_DiscardUnknown()

func (*BootstrapRequest) XXX_Marshal Uses

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

func (*BootstrapRequest) XXX_Merge Uses

func (dst *BootstrapRequest) XXX_Merge(src proto.Message)

func (*BootstrapRequest) XXX_Size Uses

func (m *BootstrapRequest) XXX_Size() int

func (*BootstrapRequest) XXX_Unmarshal Uses

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

type BootstrapResponse Uses

type BootstrapResponse struct {
}

func (*BootstrapResponse) Descriptor Uses

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

func (*BootstrapResponse) Marshal Uses

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

func (*BootstrapResponse) MarshalTo Uses

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

func (*BootstrapResponse) ProtoMessage Uses

func (*BootstrapResponse) ProtoMessage()

func (*BootstrapResponse) Reset Uses

func (m *BootstrapResponse) Reset()

func (*BootstrapResponse) Size Uses

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

func (*BootstrapResponse) String Uses

func (m *BootstrapResponse) String() string

func (*BootstrapResponse) Unmarshal Uses

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

func (*BootstrapResponse) XXX_DiscardUnknown Uses

func (m *BootstrapResponse) XXX_DiscardUnknown()

func (*BootstrapResponse) XXX_Marshal Uses

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

func (*BootstrapResponse) XXX_Merge Uses

func (dst *BootstrapResponse) XXX_Merge(src proto.Message)

func (*BootstrapResponse) XXX_Size Uses

func (m *BootstrapResponse) XXX_Size() int

func (*BootstrapResponse) XXX_Unmarshal Uses

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

type CancelQueryRequest Uses

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

Request object for issing a query cancel request.

func (*CancelQueryRequest) Descriptor Uses

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

func (*CancelQueryRequest) Marshal Uses

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

func (*CancelQueryRequest) MarshalTo Uses

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

func (*CancelQueryRequest) ProtoMessage Uses

func (*CancelQueryRequest) ProtoMessage()

func (*CancelQueryRequest) Reset Uses

func (m *CancelQueryRequest) Reset()

func (*CancelQueryRequest) Size Uses

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

func (*CancelQueryRequest) String Uses

func (m *CancelQueryRequest) String() string

func (*CancelQueryRequest) Unmarshal Uses

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

func (*CancelQueryRequest) XXX_DiscardUnknown Uses

func (m *CancelQueryRequest) XXX_DiscardUnknown()

func (*CancelQueryRequest) XXX_Marshal Uses

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

func (*CancelQueryRequest) XXX_Merge Uses

func (dst *CancelQueryRequest) XXX_Merge(src proto.Message)

func (*CancelQueryRequest) XXX_Size Uses

func (m *CancelQueryRequest) XXX_Size() int

func (*CancelQueryRequest) XXX_Unmarshal Uses

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

type CancelQueryResponse Uses

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

Response returned by target query's gateway node.

func (*CancelQueryResponse) Descriptor Uses

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

func (*CancelQueryResponse) Marshal Uses

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

func (*CancelQueryResponse) MarshalTo Uses

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

func (*CancelQueryResponse) ProtoMessage Uses

func (*CancelQueryResponse) ProtoMessage()

func (*CancelQueryResponse) Reset Uses

func (m *CancelQueryResponse) Reset()

func (*CancelQueryResponse) Size Uses

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

func (*CancelQueryResponse) String Uses

func (m *CancelQueryResponse) String() string

func (*CancelQueryResponse) Unmarshal Uses

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

func (*CancelQueryResponse) XXX_DiscardUnknown Uses

func (m *CancelQueryResponse) XXX_DiscardUnknown()

func (*CancelQueryResponse) XXX_Marshal Uses

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

func (*CancelQueryResponse) XXX_Merge Uses

func (dst *CancelQueryResponse) XXX_Merge(src proto.Message)

func (*CancelQueryResponse) XXX_Size Uses

func (m *CancelQueryResponse) XXX_Size() int

func (*CancelQueryResponse) XXX_Unmarshal Uses

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

type CancelSessionRequest Uses

type CancelSessionRequest struct {
    // TODO(abhimadan): use [(gogoproto.customname) = "NodeID"] below. Need to
    // 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"`
    SessionID []byte `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
    Username  string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
}

func (*CancelSessionRequest) Descriptor Uses

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

func (*CancelSessionRequest) Marshal Uses

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

func (*CancelSessionRequest) MarshalTo Uses

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

func (*CancelSessionRequest) ProtoMessage Uses

func (*CancelSessionRequest) ProtoMessage()

func (*CancelSessionRequest) Reset Uses

func (m *CancelSessionRequest) Reset()

func (*CancelSessionRequest) Size Uses

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

func (*CancelSessionRequest) String Uses

func (m *CancelSessionRequest) String() string

func (*CancelSessionRequest) Unmarshal Uses

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

func (*CancelSessionRequest) XXX_DiscardUnknown Uses

func (m *CancelSessionRequest) XXX_DiscardUnknown()

func (*CancelSessionRequest) XXX_Marshal Uses

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

func (*CancelSessionRequest) XXX_Merge Uses

func (dst *CancelSessionRequest) XXX_Merge(src proto.Message)

func (*CancelSessionRequest) XXX_Size Uses

func (m *CancelSessionRequest) XXX_Size() int

func (*CancelSessionRequest) XXX_Unmarshal Uses

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

type CancelSessionResponse Uses

type CancelSessionResponse struct {
    Canceled bool   `protobuf:"varint,1,opt,name=canceled,proto3" json:"canceled,omitempty"`
    Error    string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*CancelSessionResponse) Descriptor Uses

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

func (*CancelSessionResponse) Marshal Uses

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

func (*CancelSessionResponse) MarshalTo Uses

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

func (*CancelSessionResponse) ProtoMessage Uses

func (*CancelSessionResponse) ProtoMessage()

func (*CancelSessionResponse) Reset Uses

func (m *CancelSessionResponse) Reset()

func (*CancelSessionResponse) Size Uses

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

func (*CancelSessionResponse) String Uses

func (m *CancelSessionResponse) String() string

func (*CancelSessionResponse) Unmarshal Uses

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

func (*CancelSessionResponse) XXX_DiscardUnknown Uses

func (m *CancelSessionResponse) XXX_DiscardUnknown()

func (*CancelSessionResponse) XXX_Marshal Uses

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

func (*CancelSessionResponse) XXX_Merge Uses

func (dst *CancelSessionResponse) XXX_Merge(src proto.Message)

func (*CancelSessionResponse) XXX_Size Uses

func (m *CancelSessionResponse) XXX_Size() int

func (*CancelSessionResponse) XXX_Unmarshal Uses

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

type CertificateDetails Uses

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

func (*CertificateDetails) Descriptor Uses

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

func (*CertificateDetails) Marshal Uses

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

func (*CertificateDetails) MarshalTo Uses

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

func (*CertificateDetails) ProtoMessage Uses

func (*CertificateDetails) ProtoMessage()

func (*CertificateDetails) Reset Uses

func (m *CertificateDetails) Reset()

func (*CertificateDetails) Size Uses

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

func (*CertificateDetails) String Uses

func (m *CertificateDetails) String() string

func (*CertificateDetails) Unmarshal Uses

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

func (*CertificateDetails) XXX_DiscardUnknown Uses

func (m *CertificateDetails) XXX_DiscardUnknown()

func (*CertificateDetails) XXX_Marshal Uses

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

func (*CertificateDetails) XXX_Merge Uses

func (dst *CertificateDetails) XXX_Merge(src proto.Message)

func (*CertificateDetails) XXX_Size Uses

func (m *CertificateDetails) XXX_Size() int

func (*CertificateDetails) XXX_Unmarshal Uses

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

type CertificateDetails_CertificateType Uses

type CertificateDetails_CertificateType int32

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

const (
    CertificateDetails_CA        CertificateDetails_CertificateType = 0
    CertificateDetails_NODE      CertificateDetails_CertificateType = 1
    CertificateDetails_CLIENT_CA CertificateDetails_CertificateType = 2
    CertificateDetails_CLIENT    CertificateDetails_CertificateType = 3
    CertificateDetails_UI_CA     CertificateDetails_CertificateType = 4
    CertificateDetails_UI        CertificateDetails_CertificateType = 5
)

func (CertificateDetails_CertificateType) EnumDescriptor Uses

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

func (CertificateDetails_CertificateType) String Uses

func (x CertificateDetails_CertificateType) String() string

type CertificateDetails_Fields Uses

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

func (*CertificateDetails_Fields) Descriptor Uses

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

func (*CertificateDetails_Fields) Marshal Uses

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

func (*CertificateDetails_Fields) MarshalTo Uses

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

func (*CertificateDetails_Fields) ProtoMessage Uses

func (*CertificateDetails_Fields) ProtoMessage()

func (*CertificateDetails_Fields) Reset Uses

func (m *CertificateDetails_Fields) Reset()

func (*CertificateDetails_Fields) Size Uses

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

func (*CertificateDetails_Fields) String Uses

func (m *CertificateDetails_Fields) String() string

func (*CertificateDetails_Fields) Unmarshal Uses

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

func (*CertificateDetails_Fields) XXX_DiscardUnknown Uses

func (m *CertificateDetails_Fields) XXX_DiscardUnknown()

func (*CertificateDetails_Fields) XXX_Marshal Uses

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

func (*CertificateDetails_Fields) XXX_Merge Uses

func (dst *CertificateDetails_Fields) XXX_Merge(src proto.Message)

func (*CertificateDetails_Fields) XXX_Size Uses

func (m *CertificateDetails_Fields) XXX_Size() int

func (*CertificateDetails_Fields) XXX_Unmarshal Uses

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

type CertificatesRequest Uses

type CertificatesRequest struct {
    // node_id is a string so that "local" can be used to specify that no
    // forwarding is necessary.
    NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

func (*CertificatesRequest) Descriptor Uses

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

func (*CertificatesRequest) Marshal Uses

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

func (*CertificatesRequest) MarshalTo Uses

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

func (*CertificatesRequest) ProtoMessage Uses

func (*CertificatesRequest) ProtoMessage()

func (*CertificatesRequest) Reset Uses

func (m *CertificatesRequest) Reset()

func (*CertificatesRequest) Size Uses

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

func (*CertificatesRequest) String Uses

func (m *CertificatesRequest) String() string

func (*CertificatesRequest) Unmarshal Uses

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

func (*CertificatesRequest) XXX_DiscardUnknown Uses

func (m *CertificatesRequest) XXX_DiscardUnknown()

func (*CertificatesRequest) XXX_Marshal Uses

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

func (*CertificatesRequest) XXX_Merge Uses

func (dst *CertificatesRequest) XXX_Merge(src proto.Message)

func (*CertificatesRequest) XXX_Size Uses

func (m *CertificatesRequest) XXX_Size() int

func (*CertificatesRequest) XXX_Unmarshal Uses

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

type CertificatesResponse Uses

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

func (*CertificatesResponse) Descriptor Uses

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

func (*CertificatesResponse) Marshal Uses

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

func (*CertificatesResponse) MarshalTo Uses

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

func (*CertificatesResponse) ProtoMessage Uses

func (*CertificatesResponse) ProtoMessage()

func (*CertificatesResponse) Reset Uses

func (m *CertificatesResponse) Reset()

func (*CertificatesResponse) Size Uses

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

func (*CertificatesResponse) String Uses

func (m *CertificatesResponse) String() string

func (*CertificatesResponse) Unmarshal Uses

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

func (*CertificatesResponse) XXX_DiscardUnknown Uses

func (m *CertificatesResponse) XXX_DiscardUnknown()

func (*CertificatesResponse) XXX_Marshal Uses

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

func (*CertificatesResponse) XXX_Merge Uses

func (dst *CertificatesResponse) XXX_Merge(src proto.Message)

func (*CertificatesResponse) XXX_Size Uses

func (m *CertificatesResponse) XXX_Size() int

func (*CertificatesResponse) XXX_Unmarshal Uses

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

type ChartCatalogRequest Uses

type ChartCatalogRequest struct {
}

ChartCatalogRequest requests returns a catalog of Admin UI charts.

func (*ChartCatalogRequest) Descriptor Uses

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

func (*ChartCatalogRequest) Marshal Uses

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

func (*ChartCatalogRequest) MarshalTo Uses

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

func (*ChartCatalogRequest) ProtoMessage Uses

func (*ChartCatalogRequest) ProtoMessage()

func (*ChartCatalogRequest) Reset Uses

func (m *ChartCatalogRequest) Reset()

func (*ChartCatalogRequest) Size Uses

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

func (*ChartCatalogRequest) String Uses

func (m *ChartCatalogRequest) String() string

func (*ChartCatalogRequest) Unmarshal Uses

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

func (*ChartCatalogRequest) XXX_DiscardUnknown Uses

func (m *ChartCatalogRequest) XXX_DiscardUnknown()

func (*ChartCatalogRequest) XXX_Marshal Uses

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

func (*ChartCatalogRequest) XXX_Merge Uses

func (dst *ChartCatalogRequest) XXX_Merge(src proto.Message)

func (*ChartCatalogRequest) XXX_Size Uses

func (m *ChartCatalogRequest) XXX_Size() int

func (*ChartCatalogRequest) XXX_Unmarshal Uses

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

type ChartCatalogResponse Uses

type ChartCatalogResponse struct {
    Catalog []catalog.ChartSection `protobuf:"bytes,1,rep,name=catalog,proto3" json:"catalog"`
}

ChartCatalogResponse returns a catalog of Admin UI charts useful for debugging.

func (*ChartCatalogResponse) Descriptor Uses

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

func (*ChartCatalogResponse) Marshal Uses

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

func (*ChartCatalogResponse) MarshalTo Uses

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

func (*ChartCatalogResponse) ProtoMessage Uses

func (*ChartCatalogResponse) ProtoMessage()

func (*ChartCatalogResponse) Reset Uses

func (m *ChartCatalogResponse) Reset()

func (*ChartCatalogResponse) Size Uses

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

func (*ChartCatalogResponse) String Uses

func (m *ChartCatalogResponse) String() string

func (*ChartCatalogResponse) Unmarshal Uses

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

func (*ChartCatalogResponse) XXX_DiscardUnknown Uses

func (m *ChartCatalogResponse) XXX_DiscardUnknown()

func (*ChartCatalogResponse) XXX_Marshal Uses

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

func (*ChartCatalogResponse) XXX_Merge Uses

func (dst *ChartCatalogResponse) XXX_Merge(src proto.Message)

func (*ChartCatalogResponse) XXX_Size Uses

func (m *ChartCatalogResponse) XXX_Size() int

func (*ChartCatalogResponse) XXX_Unmarshal Uses

func (m *ChartCatalogResponse) XXX_Unmarshal(b []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

func (*ClusterRequest) XXX_DiscardUnknown Uses

func (m *ClusterRequest) XXX_DiscardUnknown()

func (*ClusterRequest) XXX_Marshal Uses

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

func (*ClusterRequest) XXX_Merge Uses

func (dst *ClusterRequest) XXX_Merge(src proto.Message)

func (*ClusterRequest) XXX_Size Uses

func (m *ClusterRequest) XXX_Size() int

func (*ClusterRequest) XXX_Unmarshal Uses

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

type ClusterResponse Uses

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

ClusterResponse contains metadata for the cluster.

func (*ClusterResponse) Descriptor 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

func (*ClusterResponse) XXX_DiscardUnknown Uses

func (m *ClusterResponse) XXX_DiscardUnknown()

func (*ClusterResponse) XXX_Marshal Uses

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

func (*ClusterResponse) XXX_Merge Uses

func (dst *ClusterResponse) XXX_Merge(src proto.Message)

func (*ClusterResponse) XXX_Size Uses

func (m *ClusterResponse) XXX_Size() int

func (*ClusterResponse) XXX_Unmarshal Uses

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

type DataDistributionRequest Uses

type DataDistributionRequest struct {
}

func (*DataDistributionRequest) Descriptor Uses

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

func (*DataDistributionRequest) Marshal Uses

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

func (*DataDistributionRequest) MarshalTo Uses

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

func (*DataDistributionRequest) ProtoMessage Uses

func (*DataDistributionRequest) ProtoMessage()

func (*DataDistributionRequest) Reset Uses

func (m *DataDistributionRequest) Reset()

func (*DataDistributionRequest) Size Uses

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

func (*DataDistributionRequest) String Uses

func (m *DataDistributionRequest) String() string

func (*DataDistributionRequest) Unmarshal Uses

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

func (*DataDistributionRequest) XXX_DiscardUnknown Uses

func (m *DataDistributionRequest) XXX_DiscardUnknown()

func (*DataDistributionRequest) XXX_Marshal Uses

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

func (*DataDistributionRequest) XXX_Merge Uses

func (dst *DataDistributionRequest) XXX_Merge(src proto.Message)

func (*DataDistributionRequest) XXX_Size Uses

func (m *DataDistributionRequest) XXX_Size() int

func (*DataDistributionRequest) XXX_Unmarshal Uses

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

type DataDistributionResponse Uses

type DataDistributionResponse struct {
    // By database name.
    DatabaseInfo map[string]DataDistributionResponse_DatabaseInfo `protobuf:"bytes,1,rep,name=database_info,json=databaseInfo,proto3" json:"database_info" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // By zone name.
    ZoneConfigs map[string]DataDistributionResponse_ZoneConfig `protobuf:"bytes,3,rep,name=zone_configs,json=zoneConfigs,proto3" json:"zone_configs" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}

func (*DataDistributionResponse) Descriptor Uses

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

func (*DataDistributionResponse) Marshal Uses

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

func (*DataDistributionResponse) MarshalTo Uses

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

func (*DataDistributionResponse) ProtoMessage Uses

func (*DataDistributionResponse) ProtoMessage()

func (*DataDistributionResponse) Reset Uses

func (m *DataDistributionResponse) Reset()

func (*DataDistributionResponse) Size Uses

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

func (*DataDistributionResponse) String Uses

func (m *DataDistributionResponse) String() string

func (*DataDistributionResponse) Unmarshal Uses

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

func (*DataDistributionResponse) XXX_DiscardUnknown Uses

func (m *DataDistributionResponse) XXX_DiscardUnknown()

func (*DataDistributionResponse) XXX_Marshal Uses

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

func (*DataDistributionResponse) XXX_Merge Uses

func (dst *DataDistributionResponse) XXX_Merge(src proto.Message)

func (*DataDistributionResponse) XXX_Size Uses

func (m *DataDistributionResponse) XXX_Size() int

func (*DataDistributionResponse) XXX_Unmarshal Uses

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

type DataDistributionResponse_DatabaseInfo Uses

type DataDistributionResponse_DatabaseInfo struct {
    // By table name.
    TableInfo map[string]DataDistributionResponse_TableInfo `protobuf:"bytes,1,rep,name=table_info,json=tableInfo,proto3" json:"table_info" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}

func (*DataDistributionResponse_DatabaseInfo) Descriptor Uses

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

func (*DataDistributionResponse_DatabaseInfo) Marshal Uses

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

func (*DataDistributionResponse_DatabaseInfo) MarshalTo Uses

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

func (*DataDistributionResponse_DatabaseInfo) ProtoMessage Uses

func (*DataDistributionResponse_DatabaseInfo) ProtoMessage()

func (*DataDistributionResponse_DatabaseInfo) Reset Uses

func (m *DataDistributionResponse_DatabaseInfo) Reset()

func (*DataDistributionResponse_DatabaseInfo) Size Uses

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

func (*DataDistributionResponse_DatabaseInfo) String Uses

func (m *DataDistributionResponse_DatabaseInfo) String() string

func (*DataDistributionResponse_DatabaseInfo) Unmarshal Uses

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

func (*DataDistributionResponse_DatabaseInfo) XXX_DiscardUnknown Uses

func (m *DataDistributionResponse_DatabaseInfo) XXX_DiscardUnknown()

func (*DataDistributionResponse_DatabaseInfo) XXX_Marshal Uses

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

func (*DataDistributionResponse_DatabaseInfo) XXX_Merge Uses

func (dst *DataDistributionResponse_DatabaseInfo) XXX_Merge(src proto.Message)

func (*DataDistributionResponse_DatabaseInfo) XXX_Size Uses

func (m *DataDistributionResponse_DatabaseInfo) XXX_Size() int

func (*DataDistributionResponse_DatabaseInfo) XXX_Unmarshal Uses

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

type DataDistributionResponse_TableInfo Uses

type DataDistributionResponse_TableInfo struct {
    ReplicaCountByNodeId map[github_com_cockroachdb_cockroach_pkg_roachpb.NodeID]int64 `protobuf:"bytes,1,rep,name=replica_count_by_node_id,json=replicaCountByNodeId,proto3,castkey=github.com/cockroachdb/cockroach/pkg/roachpb.NodeID" json:"replica_count_by_node_id,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    ZoneConfigId         int64                                                         `protobuf:"varint,2,opt,name=zone_config_id,json=zoneConfigId,proto3" json:"zone_config_id,omitempty"`
    DroppedAt            *time.Time                                                    `protobuf:"bytes,3,opt,name=dropped_at,json=droppedAt,proto3,stdtime" json:"dropped_at,omitempty"`
}

func (*DataDistributionResponse_TableInfo) Descriptor Uses

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

func (*DataDistributionResponse_TableInfo) Marshal Uses

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

func (*DataDistributionResponse_TableInfo) MarshalTo Uses

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

func (*DataDistributionResponse_TableInfo) ProtoMessage Uses

func (*DataDistributionResponse_TableInfo) ProtoMessage()

func (*DataDistributionResponse_TableInfo) Reset Uses

func (m *DataDistributionResponse_TableInfo) Reset()

func (*DataDistributionResponse_TableInfo) Size Uses

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

func (*DataDistributionResponse_TableInfo) String Uses

func (m *DataDistributionResponse_TableInfo) String() string

func (*DataDistributionResponse_TableInfo) Unmarshal Uses

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

func (*DataDistributionResponse_TableInfo) XXX_DiscardUnknown Uses

func (m *DataDistributionResponse_TableInfo) XXX_DiscardUnknown()

func (*DataDistributionResponse_TableInfo) XXX_Marshal Uses

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

func (*DataDistributionResponse_TableInfo) XXX_Merge Uses

func (dst *DataDistributionResponse_TableInfo) XXX_Merge(src proto.Message)

func (*DataDistributionResponse_TableInfo) XXX_Size Uses

func (m *DataDistributionResponse_TableInfo) XXX_Size() int

func (*DataDistributionResponse_TableInfo) XXX_Unmarshal Uses

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

type DataDistributionResponse_ZoneConfig Uses

type DataDistributionResponse_ZoneConfig struct {
    // target is the object the zone config applies to, e.g. "DATABASE db" or
    // "PARTITION north_america OF TABLE users".
    Target string            `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
    Config config.ZoneConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config"`
    // config_sql is the SQL representation of config.
    ConfigSQL string `protobuf:"bytes,4,opt,name=config_sql,json=configSql,proto3" json:"config_sql,omitempty"`
}

func (*DataDistributionResponse_ZoneConfig) Descriptor Uses

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

func (*DataDistributionResponse_ZoneConfig) Marshal Uses

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

func (*DataDistributionResponse_ZoneConfig) MarshalTo Uses

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

func (*DataDistributionResponse_ZoneConfig) ProtoMessage Uses

func (*DataDistributionResponse_ZoneConfig) ProtoMessage()

func (*DataDistributionResponse_ZoneConfig) Reset Uses

func (m *DataDistributionResponse_ZoneConfig) Reset()

func (*DataDistributionResponse_ZoneConfig) Size Uses

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

func (*DataDistributionResponse_ZoneConfig) String Uses

func (m *DataDistributionResponse_ZoneConfig) String() string

func (*DataDistributionResponse_ZoneConfig) Unmarshal Uses

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

func (*DataDistributionResponse_ZoneConfig) XXX_DiscardUnknown Uses

func (m *DataDistributionResponse_ZoneConfig) XXX_DiscardUnknown()

func (*DataDistributionResponse_ZoneConfig) XXX_Marshal Uses

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

func (*DataDistributionResponse_ZoneConfig) XXX_Merge Uses

func (dst *DataDistributionResponse_ZoneConfig) XXX_Merge(src proto.Message)

func (*DataDistributionResponse_ZoneConfig) XXX_Size Uses

func (m *DataDistributionResponse_ZoneConfig) XXX_Size() int

func (*DataDistributionResponse_ZoneConfig) XXX_Unmarshal Uses

func (m *DataDistributionResponse_ZoneConfig) XXX_Unmarshal(b []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

func (*DatabaseDetailsRequest) XXX_DiscardUnknown Uses

func (m *DatabaseDetailsRequest) XXX_DiscardUnknown()

func (*DatabaseDetailsRequest) XXX_Marshal Uses

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

func (*DatabaseDetailsRequest) XXX_Merge Uses

func (dst *DatabaseDetailsRequest) XXX_Merge(src proto.Message)

func (*DatabaseDetailsRequest) XXX_Size Uses

func (m *DatabaseDetailsRequest) XXX_Size() int

func (*DatabaseDetailsRequest) XXX_Unmarshal Uses

func (m *DatabaseDetailsRequest) XXX_Unmarshal(b []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,proto3" 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,proto3" 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 config.ZoneConfig `protobuf:"bytes,4,opt,name=zone_config,json=zoneConfig,proto3" 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

func (*DatabaseDetailsResponse) XXX_DiscardUnknown Uses

func (m *DatabaseDetailsResponse) XXX_DiscardUnknown()

func (*DatabaseDetailsResponse) XXX_Marshal Uses

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

func (*DatabaseDetailsResponse) XXX_Merge Uses

func (dst *DatabaseDetailsResponse) XXX_Merge(src proto.Message)

func (*DatabaseDetailsResponse) XXX_Size Uses

func (m *DatabaseDetailsResponse) XXX_Size() int

func (*DatabaseDetailsResponse) XXX_Unmarshal Uses

func (m *DatabaseDetailsResponse) XXX_Unmarshal(b []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,proto3" 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

func (*DatabaseDetailsResponse_Grant) XXX_DiscardUnknown Uses

func (m *DatabaseDetailsResponse_Grant) XXX_DiscardUnknown()

func (*DatabaseDetailsResponse_Grant) XXX_Marshal Uses

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

func (*DatabaseDetailsResponse_Grant) XXX_Merge Uses

func (dst *DatabaseDetailsResponse_Grant) XXX_Merge(src proto.Message)

func (*DatabaseDetailsResponse_Grant) XXX_Size Uses

func (m *DatabaseDetailsResponse_Grant) XXX_Size() int

func (*DatabaseDetailsResponse_Grant) XXX_Unmarshal Uses

func (m *DatabaseDetailsResponse_Grant) XXX_Unmarshal(b []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

func (*DatabasesRequest) XXX_DiscardUnknown Uses

func (m *DatabasesRequest) XXX_DiscardUnknown()

func (*DatabasesRequest) XXX_Marshal Uses

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

func (*DatabasesRequest) XXX_Merge Uses

func (dst *DatabasesRequest) XXX_Merge(src proto.Message)

func (*DatabasesRequest) XXX_Size Uses

func (m *DatabasesRequest) XXX_Size() int

func (*DatabasesRequest) XXX_Unmarshal Uses

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

type DatabasesResponse Uses

type DatabasesResponse struct {
    Databases []string `protobuf:"bytes,1,rep,name=databases,proto3" 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

func (*DatabasesResponse) XXX_DiscardUnknown Uses

func (m *DatabasesResponse) XXX_DiscardUnknown()

func (*DatabasesResponse) XXX_Marshal Uses

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

func (*DatabasesResponse) XXX_Merge Uses

func (dst *DatabasesResponse) XXX_Merge(src proto.Message)

func (*DatabasesResponse) XXX_Size Uses

func (m *DatabasesResponse) XXX_Size() int

func (*DatabasesResponse) XXX_Unmarshal Uses

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

type DecommissionRequest Uses

type DecommissionRequest struct {
    NodeIDs         []github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `protobuf:"varint,1,rep,packed,name=node_ids,json=nodeIds,proto3,casttype=github.com/cockroachdb/cockroach/pkg/roachpb.NodeID" json:"node_ids,omitempty"`
    Decommissioning bool                                                  `protobuf:"varint,2,opt,name=decommissioning,proto3" json:"decommissioning,omitempty"`
}

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

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

func (*DecommissionRequest) Descriptor Uses

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

func (*DecommissionRequest) Marshal Uses

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

func (*DecommissionRequest) MarshalTo Uses

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

func (*DecommissionRequest) ProtoMessage Uses

func (*DecommissionRequest) ProtoMessage()

func (*DecommissionRequest) Reset Uses

func (m *DecommissionRequest) Reset()

func (*DecommissionRequest) Size Uses

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

func (*DecommissionRequest) String Uses

func (m *DecommissionRequest) String() string

func (*DecommissionRequest) Unmarshal Uses

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

func (*DecommissionRequest) XXX_DiscardUnknown Uses

func (m *DecommissionRequest) XXX_DiscardUnknown()

func (*DecommissionRequest) XXX_Marshal Uses

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

func (*DecommissionRequest) XXX_Merge Uses

func (dst *DecommissionRequest) XXX_Merge(src proto.Message)

func (*DecommissionRequest) XXX_Size Uses

func (m *DecommissionRequest) XXX_Size() int

func (*DecommissionRequest) XXX_Unmarshal Uses

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

type DecommissionStatusRequest Uses

type DecommissionStatusRequest struct {
    NodeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `protobuf:"varint,1,rep,packed,name=node_ids,json=nodeIds,proto3,casttype=github.com/cockroachdb/cockroach/pkg/roachpb.NodeID" json:"node_ids,omitempty"`
}

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

func (*DecommissionStatusRequest) Descriptor Uses

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

func (*DecommissionStatusRequest) Marshal Uses

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

func (*DecommissionStatusRequest) MarshalTo Uses

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

func (*DecommissionStatusRequest) ProtoMessage Uses

func (*DecommissionStatusRequest) ProtoMessage()

func (*DecommissionStatusRequest) Reset Uses

func (m *DecommissionStatusRequest) Reset()

func (*DecommissionStatusRequest) Size Uses

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

func (*DecommissionStatusRequest) String Uses

func (m *DecommissionStatusRequest) String() string

func (*DecommissionStatusRequest) Unmarshal Uses

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

func (*DecommissionStatusRequest) XXX_DiscardUnknown Uses

func (m *DecommissionStatusRequest) XXX_DiscardUnknown()

func (*DecommissionStatusRequest) XXX_Marshal Uses

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

func (*DecommissionStatusRequest) XXX_Merge Uses

func (dst *DecommissionStatusRequest) XXX_Merge(src proto.Message)

func (*DecommissionStatusRequest) XXX_Size Uses

func (m *DecommissionStatusRequest) XXX_Size() int

func (*DecommissionStatusRequest) XXX_Unmarshal Uses

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

type DecommissionStatusResponse Uses

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

DecommissionStatusResponse lists decommissioning statuses for a number of NodeIDs.

func (*DecommissionStatusResponse) Descriptor Uses

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

func (*DecommissionStatusResponse) Marshal Uses

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

func (*DecommissionStatusResponse) MarshalTo Uses

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

func (*DecommissionStatusResponse) ProtoMessage Uses

func (*DecommissionStatusResponse) ProtoMessage()

func (*DecommissionStatusResponse) Reset Uses

func (m *DecommissionStatusResponse) Reset()

func (*DecommissionStatusResponse) Size Uses

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

func (*DecommissionStatusResponse) String Uses

func (m *DecommissionStatusResponse) String() string

func (*DecommissionStatusResponse) Unmarshal Uses

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

func (*DecommissionStatusResponse) XXX_DiscardUnknown Uses

func (m *DecommissionStatusResponse) XXX_DiscardUnknown()

func (*DecommissionStatusResponse) XXX_Marshal Uses

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

func (*DecommissionStatusResponse) XXX_Merge Uses

func (dst *DecommissionStatusResponse) XXX_Merge(src proto.Message)

func (*DecommissionStatusResponse) XXX_Size Uses

func (m *DecommissionStatusResponse) XXX_Size() int

func (*DecommissionStatusResponse) XXX_Unmarshal Uses

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

type DecommissionStatusResponse_Status Uses

type DecommissionStatusResponse_Status struct {
    NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/roachpb.NodeID" json:"node_id,omitempty"`
    IsLive bool                                                `protobuf:"varint,2,opt,name=is_live,json=isLive,proto3" json:"is_live,omitempty"`
    // The number of replicas on the node, computed by scanning meta2 ranges.
    ReplicaCount    int64 `protobuf:"varint,3,opt,name=replica_count,json=replicaCount,proto3" json:"replica_count,omitempty"`
    Decommissioning bool  `protobuf:"varint,4,opt,name=decommissioning,proto3" json:"decommissioning,omitempty"`
    Draining        bool  `protobuf:"varint,5,opt,name=draining,proto3" json:"draining,omitempty"`
}

func (*DecommissionStatusResponse_Status) Descriptor Uses

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

func (*DecommissionStatusResponse_Status) Marshal Uses

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

func (*DecommissionStatusResponse_Status) MarshalTo Uses

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

func (*DecommissionStatusResponse_Status) ProtoMessage Uses

func (*DecommissionStatusResponse_Status) ProtoMessage()

func (*DecommissionStatusResponse_Status) Reset Uses

func (m *DecommissionStatusResponse_Status) Reset()

func (*DecommissionStatusResponse_Status) Size Uses

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

func (*DecommissionStatusResponse_Status) String Uses

func (m *DecommissionStatusResponse_Status) String() string

func (*DecommissionStatusResponse_Status) Unmarshal Uses

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

func (*DecommissionStatusResponse_Status) XXX_DiscardUnknown Uses

func (m *DecommissionStatusResponse_Status) XXX_DiscardUnknown()

func (*DecommissionStatusResponse_Status) XXX_Marshal Uses

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

func (*DecommissionStatusResponse_Status) XXX_Merge Uses

func (dst *DecommissionStatusResponse_Status) XXX_Merge(src proto.Message)

func (*DecommissionStatusResponse_Status) XXX_Size Uses

func (m *DecommissionStatusResponse_Status) XXX_Size() int

func (*DecommissionStatusResponse_Status) XXX_Unmarshal Uses

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

type DetailsRequest Uses

type DetailsRequest struct {
    // 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"`
    // ready specifies whether the client wants to know whether a node is ready to
    // receive traffic. If a node is unready, an error will be returned.
    Ready bool `protobuf:"varint,2,opt,name=ready,proto3" json:"ready,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

func (*DetailsRequest) XXX_DiscardUnknown Uses

func (m *DetailsRequest) XXX_DiscardUnknown()

func (*DetailsRequest) XXX_Marshal Uses

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

func (*DetailsRequest) XXX_Merge Uses

func (dst *DetailsRequest) XXX_Merge(src proto.Message)

func (*DetailsRequest) XXX_Size Uses

func (m *DetailsRequest) XXX_Size() int

func (*DetailsRequest) XXX_Unmarshal Uses

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

type DetailsResponse Uses

type DetailsResponse struct {
    NodeID     github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/roachpb.NodeID" json:"node_id,omitempty"`
    Address    util.UnresolvedAddr                                 `protobuf:"bytes,2,opt,name=address,proto3" json:"address"`
    BuildInfo  build.Info                                          `protobuf:"bytes,3,opt,name=build_info,json=buildInfo,proto3" json:"build_info"`
    SystemInfo SystemInfo                                          `protobuf:"bytes,4,opt,name=system_info,json=systemInfo,proto3" json:"system_info"`
    SQLAddress util.UnresolvedAddr                                 `protobuf:"bytes,5,opt,name=sql_address,json=sqlAddress,proto3" json:"sql_address"`
}

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

func (*DetailsResponse) XXX_DiscardUnknown Uses

func (m *DetailsResponse) XXX_DiscardUnknown()

func (*DetailsResponse) XXX_Marshal Uses

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

func (*DetailsResponse) XXX_Merge Uses

func (dst *DetailsResponse) XXX_Merge(src proto.Message)

func (*DetailsResponse) XXX_Size Uses

func (m *DetailsResponse) XXX_Size() int

func (*DetailsResponse) XXX_Unmarshal Uses

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

type DiagnosticsRequest Uses

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

DiagnosticsRequest requests a diagnostics report.

func (*DiagnosticsRequest) Descriptor Uses

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

func (*DiagnosticsRequest) Marshal Uses

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

func (*DiagnosticsRequest) MarshalTo Uses

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

func (*DiagnosticsRequest) ProtoMessage Uses

func (*DiagnosticsRequest) ProtoMessage()

func (*DiagnosticsRequest) Reset Uses

func (m *DiagnosticsRequest) Reset()

func (*DiagnosticsRequest) Size Uses

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

func (*DiagnosticsRequest) String Uses

func (m *DiagnosticsRequest) String() string

func (*DiagnosticsRequest) Unmarshal Uses

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

func (*DiagnosticsRequest) XXX_DiscardUnknown Uses

func (m *DiagnosticsRequest) XXX_DiscardUnknown()

func (*DiagnosticsRequest) XXX_Marshal Uses

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

func (*DiagnosticsRequest) XXX_Merge Uses

func (dst *DiagnosticsRequest) XXX_Merge(src proto.Message)

func (*DiagnosticsRequest) XXX_Size Uses

func (m *DiagnosticsRequest) XXX_Size() int

func (*DiagnosticsRequest) XXX_Unmarshal Uses

func (m *DiagnosticsRequest) XXX_Unmarshal(b []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,packed,name=on,proto3" json:"on,omitempty"`
    Off []int32 `protobuf:"varint,2,rep,packed,name=off,proto3" 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

func (*DrainRequest) XXX_DiscardUnknown Uses

func (m *DrainRequest) XXX_DiscardUnknown()

func (*DrainRequest) XXX_Marshal Uses

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

func (*DrainRequest) XXX_Merge Uses

func (dst *DrainRequest) XXX_Merge(src proto.Message)

func (*DrainRequest) XXX_Size Uses

func (m *DrainRequest) XXX_Size() int

func (*DrainRequest) XXX_Unmarshal Uses

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

type DrainResponse Uses

type DrainResponse struct {
    On []int32 `protobuf:"varint,1,rep,packed,name=on,proto3" 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

func (*DrainResponse) XXX_DiscardUnknown Uses

func (m *DrainResponse) XXX_DiscardUnknown()

func (*DrainResponse) XXX_Marshal Uses

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

func (*DrainResponse) XXX_Merge Uses

func (dst *DrainResponse) XXX_Merge(src proto.Message)

func (*DrainResponse) XXX_Size Uses

func (m *DrainResponse) XXX_Size() int

func (*DrainResponse) XXX_Unmarshal Uses

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

type EngineStatsInfo Uses

type EngineStatsInfo struct {
    StoreID              github_com_cockroachdb_cockroach_pkg_roachpb.StoreID `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/roachpb.StoreID" json:"store_id,omitempty"`
    TickersAndHistograms *enginepb.TickersAndHistograms                       `protobuf:"bytes,2,opt,name=tickers_and_histograms,json=tickersAndHistograms,proto3" json:"tickers_and_histograms,omitempty"`
}

func (*EngineStatsInfo) Descriptor Uses

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

func (*EngineStatsInfo) Marshal Uses

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

func (*EngineStatsInfo) MarshalTo Uses

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

func (*EngineStatsInfo) ProtoMessage Uses

func (*EngineStatsInfo) ProtoMessage()

func (*EngineStatsInfo) Reset Uses

func (m *EngineStatsInfo) Reset()

func (*EngineStatsInfo) Size Uses

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

func (*EngineStatsInfo) String Uses

func (m *EngineStatsInfo) String() string

func (*EngineStatsInfo) Unmarshal Uses

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

func (*EngineStatsInfo) XXX_DiscardUnknown Uses

func (m *EngineStatsInfo) XXX_DiscardUnknown()

func (*EngineStatsInfo) XXX_Marshal Uses

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

func (*EngineStatsInfo) XXX_Merge Uses

func (dst *EngineStatsInfo) XXX_Merge(src proto.Message)

func (*EngineStatsInfo) XXX_Size Uses

func (m *EngineStatsInfo) XXX_Size() int

func (*EngineStatsInfo) XXX_Unmarshal Uses

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

type EngineStatsRequest Uses

type EngineStatsRequest struct {
    // 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 (*EngineStatsRequest) Descriptor Uses

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

func (*EngineStatsRequest) Marshal Uses

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

func (*EngineStatsRequest) MarshalTo Uses

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

func (*EngineStatsRequest) ProtoMessage Uses

func (*EngineStatsRequest) ProtoMessage()

func (*EngineStatsRequest) Reset Uses

func (m *EngineStatsRequest) Reset()

func (*EngineStatsRequest) Size Uses

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

func (*EngineStatsRequest) String Uses

func (m *EngineStatsRequest) String() string

func (*EngineStatsRequest) Unmarshal Uses

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

func (*EngineStatsRequest) XXX_DiscardUnknown Uses

func (m *EngineStatsRequest) XXX_DiscardUnknown()

func (*EngineStatsRequest) XXX_Marshal Uses

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

func (*EngineStatsRequest) XXX_Merge Uses

func (dst *EngineStatsRequest) XXX_Merge(src proto.Message)

func (*EngineStatsRequest) XXX_Size Uses

func (m *EngineStatsRequest) XXX_Size() int

func (*EngineStatsRequest) XXX_Unmarshal Uses

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

type EngineStatsResponse Uses

type EngineStatsResponse struct {
    Stats []EngineStatsInfo `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats"`
}

func (*EngineStatsResponse) Descriptor Uses

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

func (*EngineStatsResponse) Marshal Uses

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

func (*EngineStatsResponse) MarshalTo Uses

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

func (*EngineStatsResponse) ProtoMessage Uses

func (*EngineStatsResponse) ProtoMessage()

func (*EngineStatsResponse) Reset Uses

func (m *EngineStatsResponse) Reset()

func (*EngineStatsResponse) Size Uses

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

func (*EngineStatsResponse) String Uses

func (m *EngineStatsResponse) String() string

func (*EngineStatsResponse) Unmarshal Uses

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

func (*EngineStatsResponse) XXX_DiscardUnknown Uses

func (m *EngineStatsResponse) XXX_DiscardUnknown()

func (*EngineStatsResponse) XXX_Marshal Uses

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

func (*EngineStatsResponse) XXX_Merge Uses

func (dst *EngineStatsResponse) XXX_Merge(src proto.Message)

func (*EngineStatsResponse) XXX_Size Uses

func (m *EngineStatsResponse) XXX_Size() int

func (*EngineStatsResponse) XXX_Unmarshal Uses

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

type EnqueueRangeRequest Uses

type EnqueueRangeRequest struct {
    // The node on which the queue should process the range. If node_id is 0,
    // the request will be forwarded to all other nodes.
    NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/roachpb.NodeID" json:"node_id,omitempty"`
    // The name of the replica queue to run the range through. Matched against
    // each queue's name field. See the implementation of baseQueue for details.
    Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
    // The ID of the range to run through the queue.
    RangeID github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `protobuf:"varint,3,opt,name=range_id,json=rangeId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/roachpb.RangeID" json:"range_id,omitempty"`
    // If set, run the queue's process method without first checking whether the
    // replica should be processed by calling shouldQueue.
    SkipShouldQueue bool `protobuf:"varint,4,opt,name=skip_should_queue,json=skipShouldQueue,proto3" json:"skip_should_queue,omitempty"`
}

func (*EnqueueRangeRequest) Descriptor Uses

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

func (*EnqueueRangeRequest) Marshal Uses

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

func (*EnqueueRangeRequest) MarshalTo Uses

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

func (*EnqueueRangeRequest) ProtoMessage Uses

func (*EnqueueRangeRequest) ProtoMessage()

func (*EnqueueRangeRequest) Reset Uses

func (m *EnqueueRangeRequest) Reset()

func (*EnqueueRangeRequest) Size Uses

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

func (*EnqueueRangeRequest) String Uses

func (m *EnqueueRangeRequest) String() string

func (*EnqueueRangeRequest) Unmarshal Uses

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

func (*EnqueueRangeRequest) XXX_DiscardUnknown Uses

func (m *EnqueueRangeRequest) XXX_DiscardUnknown()

func (*EnqueueRangeRequest) XXX_Marshal Uses

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

func (*EnqueueRangeRequest) XXX_Merge Uses

func (dst *EnqueueRangeRequest) XXX_Merge(src proto.Message)

func (*EnqueueRangeRequest) XXX_Size Uses

func (m *EnqueueRangeRequest) XXX_Size() int

func (*EnqueueRangeRequest) XXX_Unmarshal Uses

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

type EnqueueRangeResponse Uses

type EnqueueRangeResponse struct {
    Details []*EnqueueRangeResponse_Details `protobuf:"bytes,1,rep,name=details,proto3" json:"details,omitempty"`
}

func (*EnqueueRangeResponse) Descriptor Uses

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

func (*EnqueueRangeResponse) Marshal Uses

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

func (*EnqueueRangeResponse) MarshalTo Uses

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

func (*EnqueueRangeResponse) ProtoMessage Uses

func (*EnqueueRangeResponse) ProtoMessage()

func (*EnqueueRangeResponse) Reset Uses

func (m *EnqueueRangeResponse) Reset()

func (*EnqueueRangeResponse) Size Uses

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

func (*EnqueueRangeResponse) String Uses

func (m *EnqueueRangeResponse) String() string

func (*EnqueueRangeResponse) Unmarshal Uses

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

func (*EnqueueRangeResponse) XXX_DiscardUnknown Uses

func (m *EnqueueRangeResponse) XXX_DiscardUnknown()

func (*EnqueueRangeResponse) XXX_Marshal Uses

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

func (*EnqueueRangeResponse) XXX_Merge Uses

func (dst *EnqueueRangeResponse) XXX_Merge(src proto.Message)

func (*EnqueueRangeResponse) XXX_Size Uses

func (m *EnqueueRangeResponse) XXX_Size() int

func (*EnqueueRangeResponse) XXX_Unmarshal Uses

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

type EnqueueRangeResponse_Details Uses

type EnqueueRangeResponse_Details struct {
    NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/roachpb.NodeID" json:"node_id,omitempty"`
    // All trace events collected while processing the range in the queue.
    Events []*TraceEvent `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
    // The error message from the queue's processing, if any.
    Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
}

func (*EnqueueRangeResponse_Details) Descriptor Uses

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

func (*EnqueueRangeResponse_Details) Marshal Uses

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

func (*EnqueueRangeResponse_Details) MarshalTo Uses

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

func (*EnqueueRangeResponse_Details) ProtoMessage Uses

func (*EnqueueRangeResponse_Details) ProtoMessage()

func (*EnqueueRangeResponse_Details) Reset Uses

func (m *EnqueueRangeResponse_Details) Reset()

func (*EnqueueRangeResponse_Details) Size Uses

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

func (*EnqueueRangeResponse_Details) String Uses

func (m *EnqueueRangeResponse_Details) String() string

func (*EnqueueRangeResponse_Details) Unmarshal Uses

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

func (*EnqueueRangeResponse_Details) XXX_DiscardUnknown Uses

func (m *EnqueueRangeResponse_Details) XXX_DiscardUnknown()

func (*EnqueueRangeResponse_Details) XXX_Marshal Uses

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

func (*EnqueueRangeResponse_Details) XXX_Merge Uses

func (dst *EnqueueRangeResponse_Details) XXX_Merge(src proto.Message)

func (*EnqueueRangeResponse_Details) XXX_Size Uses

func (m *EnqueueRangeResponse_Details) XXX_Size() int

func (*EnqueueRangeResponse_Details) XXX_Unmarshal Uses

func (m *EnqueueRangeResponse_Details) XXX_Unmarshal(b []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"`
    // limit is the total number of results that are retrieved by the query. If
    // this is omitted or set to 0, the default maximum number of results are
    // returned. When set to > 0, at most only that number of results are
    // returned. When set to < 0, an unlimited number of results are returned.
    Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
}

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

func (*EventsRequest) Descriptor 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

func (*EventsRequest) XXX_DiscardUnknown Uses

func (m *EventsRequest) XXX_DiscardUnknown()

func (*EventsRequest) XXX_Marshal Uses

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

func (*EventsRequest) XXX_Merge Uses

func (dst *EventsRequest) XXX_Merge(src proto.Message)

func (*EventsRequest) XXX_Size Uses

func (m *EventsRequest) XXX_Size() int

func (*EventsRequest) XXX_Unmarshal Uses

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

type EventsResponse Uses

type EventsResponse struct {
    Events []EventsResponse_Event `protobuf:"bytes,1,rep,name=events,proto3" 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

func (*EventsResponse) XXX_DiscardUnknown Uses

func (m *EventsResponse) XXX_DiscardUnknown()

func (*EventsResponse) XXX_Marshal Uses

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

func (*EventsResponse) XXX_Merge Uses

func (dst *EventsResponse) XXX_Merge(src proto.Message)

func (*EventsResponse) XXX_Size Uses

func (m *EventsResponse) XXX_Size() int

func (*EventsResponse) XXX_Unmarshal Uses

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

type EventsResponse_Event Uses

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

func (*EventsResponse_Event) Descriptor 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

func (*EventsResponse_Event) XXX_DiscardUnknown Uses

func (m *EventsResponse_Event) XXX_DiscardUnknown()

func (*EventsResponse_Event) XXX_Marshal Uses

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

func (*EventsResponse_Event) XXX_Merge Uses

func (dst *EventsResponse_Event) XXX_Merge(src proto.Message)

func (*EventsResponse_Event) XXX_Size Uses

func (m *EventsResponse_Event) XXX_Size() int

func (*EventsResponse_Event) XXX_Unmarshal Uses

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

type File Uses

type File struct {
    Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    FileSize int64  `protobuf:"varint,2,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
    // Contents may not be populated if only a list of Files are requested.
    Contents []byte `protobuf:"bytes,3,opt,name=contents,proto3" json:"contents,omitempty"`
}

func (*File) Descriptor Uses

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

func (*File) Marshal Uses

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

func (*File) MarshalTo Uses

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

func (*File) ProtoMessage Uses

func (*File) ProtoMessage()

func (*File) Reset Uses

func (m *File) Reset()

func (*File) Size Uses

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

func (*File) String Uses

func (m *File) String() string

func (*File) Unmarshal Uses

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

func (*File) XXX_DiscardUnknown Uses

func (m *File) XXX_DiscardUnknown()

func (*File) XXX_Marshal Uses

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

func (*File) XXX_Merge Uses

func (dst *File) XXX_Merge(src proto.Message)

func (*File) XXX_Size Uses

func (m *File) XXX_Size() int

func (*File) XXX_Unmarshal Uses

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

type FileType Uses

type FileType int32

Represents the type of file. TODO(ridwanmsharif): Add support for log files. They're currently served by an endpoint that parses the log messages, which is not what the debug zip client wants.

const (
    FileType_HEAP       FileType = 0
    FileType_GOROUTINES FileType = 1
)

func (FileType) EnumDescriptor Uses

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

func (FileType) String Uses

func (x FileType) String() string

type GetFilesRequest Uses

type GetFilesRequest struct {
    // 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"`
    // If list_only is true then the contents of the files will not be populated
    // in the response. Only filenames and sizes will be returned.
    ListOnly bool     `protobuf:"varint,2,opt,name=list_only,json=listOnly,proto3" json:"list_only,omitempty"`
    Type     FileType `protobuf:"varint,5,opt,name=type,proto3,enum=cockroach.server.serverpb.FileType" json:"type,omitempty"`
    // Each pattern given is matched with Files of the above type in the node
    // using filepath.Glob(). The patterns only match to filenames and so path
    // separators cannot be used.
    // Example: * will match all files of requested type.
    Patterns []string `protobuf:"bytes,6,rep,name=patterns,proto3" json:"patterns,omitempty"`
}

func (*GetFilesRequest) Descriptor Uses

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

func (*GetFilesRequest) Marshal Uses

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

func (*GetFilesRequest) MarshalTo Uses

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

func (*GetFilesRequest) ProtoMessage Uses

func (*GetFilesRequest) ProtoMessage()

func (*GetFilesRequest) Reset Uses

func (m *GetFilesRequest) Reset()

func (*GetFilesRequest) Size Uses

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

func (*GetFilesRequest) String Uses

func (m *GetFilesRequest) String() string

func (*GetFilesRequest) Unmarshal Uses

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

func (*GetFilesRequest) XXX_DiscardUnknown Uses

func (m *GetFilesRequest) XXX_DiscardUnknown()

func (*GetFilesRequest) XXX_Marshal Uses

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

func (*GetFilesRequest) XXX_Merge Uses

func (dst *GetFilesRequest) XXX_Merge(src proto.Message)

func (*GetFilesRequest) XXX_Size Uses

func (m *GetFilesRequest) XXX_Size() int

func (*GetFilesRequest) XXX_Unmarshal Uses

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

type GetFilesResponse Uses

type GetFilesResponse struct {
    Files []*File `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
}

func (*GetFilesResponse) Descriptor Uses

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

func (*GetFilesResponse) Marshal Uses

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

func (*GetFilesResponse) MarshalTo Uses

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

func (*GetFilesResponse) ProtoMessage Uses

func (*GetFilesResponse) ProtoMessage()

func (*GetFilesResponse) Reset Uses

func (m *GetFilesResponse) Reset()

func (*GetFilesResponse) Size Uses

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

func (*GetFilesResponse) String Uses

func (m *GetFilesResponse) String() string

func (*GetFilesResponse) Unmarshal Uses

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

func (*GetFilesResponse) XXX_DiscardUnknown Uses

func (m *GetFilesResponse) XXX_DiscardUnknown()

func (*GetFilesResponse) XXX_Marshal Uses

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

func (*GetFilesResponse) XXX_Merge Uses

func (dst *GetFilesResponse) XXX_Merge(src proto.Message)

func (*GetFilesResponse) XXX_Size Uses

func (m *GetFilesResponse) XXX_Size() int

func (*GetFilesResponse) XXX_Unmarshal Uses

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

type GetUIDataRequest Uses

type GetUIDataRequest struct {
    Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" 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

func (*GetUIDataRequest) XXX_DiscardUnknown Uses

func (m *GetUIDataRequest) XXX_DiscardUnknown()

func (*GetUIDataRequest) XXX_Marshal Uses

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

func (*GetUIDataRequest) XXX_Merge Uses

func (dst *GetUIDataRequest) XXX_Merge(src proto.Message)

func (*GetUIDataRequest) XXX_Size Uses

func (m *GetUIDataRequest) XXX_Size() int

func (*GetUIDataRequest) XXX_Unmarshal Uses

func (m *GetUIDataRequest) XXX_Unmarshal(b []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,proto3" json:"key_values" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}

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

func (*GetUIDataResponse) XXX_DiscardUnknown Uses

func (m *GetUIDataResponse) XXX_DiscardUnknown()

func (*GetUIDataResponse) XXX_Marshal Uses

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

func (*GetUIDataResponse) XXX_Merge Uses

func (dst *GetUIDataResponse) XXX_Merge(src proto.Message)

func (*GetUIDataResponse) XXX_Size Uses

func (m *GetUIDataResponse) XXX_Size() int

func (*GetUIDataResponse) XXX_Unmarshal Uses

func (m *GetUIDataResponse) XXX_Unmarshal(b []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 time.Time `protobuf:"bytes,2,opt,name=last_updated,json=lastUpdated,proto3,stdtime" 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

func (*GetUIDataResponse_Value) XXX_DiscardUnknown Uses

func (m *GetUIDataResponse_Value) XXX_DiscardUnknown()

func (*GetUIDataResponse_Value) XXX_Marshal Uses

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

func (*GetUIDataResponse_Value) XXX_Merge Uses

func (dst *GetUIDataResponse_Value) XXX_Merge(src proto.Message)

func (*GetUIDataResponse_Value) XXX_Size Uses

func (m *GetUIDataResponse_Value) XXX_Size() int

func (*GetUIDataResponse_Value) XXX_Unmarshal Uses

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

type GossipRequest Uses

type GossipRequest struct {
    // 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

func (*GossipRequest) XXX_DiscardUnknown Uses

func (m *GossipRequest) XXX_DiscardUnknown()

func (*GossipRequest) XXX_Marshal Uses

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

func (*GossipRequest) XXX_Merge Uses

func (dst *GossipRequest) XXX_Merge(src proto.Message)

func (*GossipRequest) XXX_Size Uses

func (m *GossipRequest) XXX_Size() int

func (*GossipRequest) XXX_Unmarshal Uses

func (m *GossipRequest) XXX_Unmarshal(b []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

func (*HealthRequest) XXX_DiscardUnknown Uses

func (m *HealthRequest) XXX_DiscardUnknown()

func (*HealthRequest) XXX_Marshal Uses

func (m *HealthRequest) XXX_Marshal(b []