Documentation ¶
Overview ¶
Package serverpb is a generated protocol buffer package. It is generated from these files: cockroach/pkg/server/serverpb/admin.proto cockroach/pkg/server/serverpb/authentication.proto cockroach/pkg/server/serverpb/init.proto cockroach/pkg/server/serverpb/status.proto It has these top-level messages: DatabasesRequest DatabasesResponse DatabaseDetailsRequest DatabaseDetailsResponse TableDetailsRequest TableDetailsResponse TableStatsRequest TableStatsResponse UsersRequest UsersResponse EventsRequest EventsResponse SetUIDataRequest SetUIDataResponse GetUIDataRequest GetUIDataResponse ClusterRequest ClusterResponse DrainRequest DrainResponse DecommissionStatusRequest DecommissionRequest DecommissionStatusResponse SettingsRequest SettingsResponse HealthRequest HealthResponse LivenessRequest LivenessResponse JobsRequest JobsResponse RangeLogRequest RangeLogResponse QueryPlanRequest QueryPlanResponse UserLoginRequest UserLoginResponse UserLogoutRequest UserLogoutResponse SessionCookie BootstrapRequest BootstrapResponse CertificatesRequest CertificateDetails CertificatesResponse DetailsRequest DetailsResponse NodesRequest NodesResponse NodeRequest RaftState RangeProblems RangeStatistics PrettySpan CommandQueueMetrics RangeInfo RangesRequest RangesResponse GossipRequest AllocatorDryRun AllocatorRangeRequest AllocatorRangeResponse AllocatorRequest AllocatorResponse JSONResponse LogsRequest LogEntriesResponse LogFilesListRequest LogFilesListResponse LogFileRequest StacksRequest MetricsRequest RaftRangeNode RaftRangeError RaftRangeStatus RaftDebugRequest RaftDebugResponse ActiveQuery ListSessionsRequest Session ListSessionsError ListSessionsResponse CancelQueryRequest CancelQueryResponse SpanStatsRequest SpanStatsResponse ProblemRangesRequest ProblemRangesResponse RangeRequest RangeResponse
Package serverpb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package serverpb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package serverpb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterAdminHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterAdminHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterAdminServer(s *grpc.Server, srv AdminServer)
- func RegisterAuthenticationHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterAuthenticationHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterAuthenticationServer(s *grpc.Server, srv AuthenticationServer)
- func RegisterInitServer(s *grpc.Server, srv InitServer)
- func RegisterStatusHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterStatusHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterStatusServer(s *grpc.Server, srv StatusServer)
- type ActiveQuery
- func (*ActiveQuery) Descriptor() ([]byte, []int)
- func (m *ActiveQuery) Marshal() (dAtA []byte, err error)
- func (m *ActiveQuery) MarshalTo(dAtA []byte) (int, error)
- func (*ActiveQuery) ProtoMessage()
- func (m *ActiveQuery) Reset()
- func (m *ActiveQuery) Size() (n int)
- func (m *ActiveQuery) String() string
- func (m *ActiveQuery) Unmarshal(dAtA []byte) error
- type ActiveQuery_Phase
- type AdminClient
- type AdminServer
- type Admin_DrainClient
- type Admin_DrainServer
- type AllocatorDryRun
- func (*AllocatorDryRun) Descriptor() ([]byte, []int)
- func (m *AllocatorDryRun) Marshal() (dAtA []byte, err error)
- func (m *AllocatorDryRun) MarshalTo(dAtA []byte) (int, error)
- func (*AllocatorDryRun) ProtoMessage()
- func (m *AllocatorDryRun) Reset()
- func (m *AllocatorDryRun) Size() (n int)
- func (m *AllocatorDryRun) String() string
- func (m *AllocatorDryRun) Unmarshal(dAtA []byte) error
- type AllocatorDryRun_Event
- func (*AllocatorDryRun_Event) Descriptor() ([]byte, []int)
- func (m *AllocatorDryRun_Event) Marshal() (dAtA []byte, err error)
- func (m *AllocatorDryRun_Event) MarshalTo(dAtA []byte) (int, error)
- func (*AllocatorDryRun_Event) ProtoMessage()
- func (m *AllocatorDryRun_Event) Reset()
- func (m *AllocatorDryRun_Event) Size() (n int)
- func (m *AllocatorDryRun_Event) String() string
- func (m *AllocatorDryRun_Event) Unmarshal(dAtA []byte) error
- type AllocatorRangeRequest
- func (*AllocatorRangeRequest) Descriptor() ([]byte, []int)
- func (m *AllocatorRangeRequest) Marshal() (dAtA []byte, err error)
- func (m *AllocatorRangeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*AllocatorRangeRequest) ProtoMessage()
- func (m *AllocatorRangeRequest) Reset()
- func (m *AllocatorRangeRequest) Size() (n int)
- func (m *AllocatorRangeRequest) String() string
- func (m *AllocatorRangeRequest) Unmarshal(dAtA []byte) error
- type AllocatorRangeResponse
- func (*AllocatorRangeResponse) Descriptor() ([]byte, []int)
- func (m *AllocatorRangeResponse) Marshal() (dAtA []byte, err error)
- func (m *AllocatorRangeResponse) MarshalTo(dAtA []byte) (int, error)
- func (*AllocatorRangeResponse) ProtoMessage()
- func (m *AllocatorRangeResponse) Reset()
- func (m *AllocatorRangeResponse) Size() (n int)
- func (m *AllocatorRangeResponse) String() string
- func (m *AllocatorRangeResponse) Unmarshal(dAtA []byte) error
- type AllocatorRequest
- func (*AllocatorRequest) Descriptor() ([]byte, []int)
- func (m *AllocatorRequest) Marshal() (dAtA []byte, err error)
- func (m *AllocatorRequest) MarshalTo(dAtA []byte) (int, error)
- func (*AllocatorRequest) ProtoMessage()
- func (m *AllocatorRequest) Reset()
- func (m *AllocatorRequest) Size() (n int)
- func (m *AllocatorRequest) String() string
- func (m *AllocatorRequest) Unmarshal(dAtA []byte) error
- type AllocatorResponse
- func (*AllocatorResponse) Descriptor() ([]byte, []int)
- func (m *AllocatorResponse) Marshal() (dAtA []byte, err error)
- func (m *AllocatorResponse) MarshalTo(dAtA []byte) (int, error)
- func (*AllocatorResponse) ProtoMessage()
- func (m *AllocatorResponse) Reset()
- func (m *AllocatorResponse) Size() (n int)
- func (m *AllocatorResponse) String() string
- func (m *AllocatorResponse) Unmarshal(dAtA []byte) error
- type AuthenticationClient
- type AuthenticationServer
- type BootstrapRequest
- func (*BootstrapRequest) Descriptor() ([]byte, []int)
- func (m *BootstrapRequest) Marshal() (dAtA []byte, err error)
- func (m *BootstrapRequest) MarshalTo(dAtA []byte) (int, error)
- func (*BootstrapRequest) ProtoMessage()
- func (m *BootstrapRequest) Reset()
- func (m *BootstrapRequest) Size() (n int)
- func (m *BootstrapRequest) String() string
- func (m *BootstrapRequest) Unmarshal(dAtA []byte) error
- type BootstrapResponse
- func (*BootstrapResponse) Descriptor() ([]byte, []int)
- func (m *BootstrapResponse) Marshal() (dAtA []byte, err error)
- func (m *BootstrapResponse) MarshalTo(dAtA []byte) (int, error)
- func (*BootstrapResponse) ProtoMessage()
- func (m *BootstrapResponse) Reset()
- func (m *BootstrapResponse) Size() (n int)
- func (m *BootstrapResponse) String() string
- func (m *BootstrapResponse) Unmarshal(dAtA []byte) error
- type CancelQueryRequest
- func (*CancelQueryRequest) Descriptor() ([]byte, []int)
- func (m *CancelQueryRequest) Marshal() (dAtA []byte, err error)
- func (m *CancelQueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CancelQueryRequest) ProtoMessage()
- func (m *CancelQueryRequest) Reset()
- func (m *CancelQueryRequest) Size() (n int)
- func (m *CancelQueryRequest) String() string
- func (m *CancelQueryRequest) Unmarshal(dAtA []byte) error
- type CancelQueryResponse
- func (*CancelQueryResponse) Descriptor() ([]byte, []int)
- func (m *CancelQueryResponse) Marshal() (dAtA []byte, err error)
- func (m *CancelQueryResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CancelQueryResponse) ProtoMessage()
- func (m *CancelQueryResponse) Reset()
- func (m *CancelQueryResponse) Size() (n int)
- func (m *CancelQueryResponse) String() string
- func (m *CancelQueryResponse) Unmarshal(dAtA []byte) error
- type CertificateDetails
- func (*CertificateDetails) Descriptor() ([]byte, []int)
- func (m *CertificateDetails) Marshal() (dAtA []byte, err error)
- func (m *CertificateDetails) MarshalTo(dAtA []byte) (int, error)
- func (*CertificateDetails) ProtoMessage()
- func (m *CertificateDetails) Reset()
- func (m *CertificateDetails) Size() (n int)
- func (m *CertificateDetails) String() string
- func (m *CertificateDetails) Unmarshal(dAtA []byte) error
- type CertificateDetails_CertificateType
- type CertificateDetails_Fields
- func (*CertificateDetails_Fields) Descriptor() ([]byte, []int)
- func (m *CertificateDetails_Fields) Marshal() (dAtA []byte, err error)
- func (m *CertificateDetails_Fields) MarshalTo(dAtA []byte) (int, error)
- func (*CertificateDetails_Fields) ProtoMessage()
- func (m *CertificateDetails_Fields) Reset()
- func (m *CertificateDetails_Fields) Size() (n int)
- func (m *CertificateDetails_Fields) String() string
- func (m *CertificateDetails_Fields) Unmarshal(dAtA []byte) error
- type CertificatesRequest
- func (*CertificatesRequest) Descriptor() ([]byte, []int)
- func (m *CertificatesRequest) Marshal() (dAtA []byte, err error)
- func (m *CertificatesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CertificatesRequest) ProtoMessage()
- func (m *CertificatesRequest) Reset()
- func (m *CertificatesRequest) Size() (n int)
- func (m *CertificatesRequest) String() string
- func (m *CertificatesRequest) Unmarshal(dAtA []byte) error
- type CertificatesResponse
- func (*CertificatesResponse) Descriptor() ([]byte, []int)
- func (m *CertificatesResponse) Marshal() (dAtA []byte, err error)
- func (m *CertificatesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CertificatesResponse) ProtoMessage()
- func (m *CertificatesResponse) Reset()
- func (m *CertificatesResponse) Size() (n int)
- func (m *CertificatesResponse) String() string
- func (m *CertificatesResponse) Unmarshal(dAtA []byte) error
- type ClusterRequest
- func (*ClusterRequest) Descriptor() ([]byte, []int)
- func (m *ClusterRequest) Marshal() (dAtA []byte, err error)
- func (m *ClusterRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterRequest) ProtoMessage()
- func (m *ClusterRequest) Reset()
- func (m *ClusterRequest) Size() (n int)
- func (m *ClusterRequest) String() string
- func (m *ClusterRequest) Unmarshal(dAtA []byte) error
- type ClusterResponse
- func (*ClusterResponse) Descriptor() ([]byte, []int)
- func (m *ClusterResponse) Marshal() (dAtA []byte, err error)
- func (m *ClusterResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterResponse) ProtoMessage()
- func (m *ClusterResponse) Reset()
- func (m *ClusterResponse) Size() (n int)
- func (m *ClusterResponse) String() string
- func (m *ClusterResponse) Unmarshal(dAtA []byte) error
- type CommandQueueMetrics
- func (*CommandQueueMetrics) Descriptor() ([]byte, []int)
- func (m *CommandQueueMetrics) Marshal() (dAtA []byte, err error)
- func (m *CommandQueueMetrics) MarshalTo(dAtA []byte) (int, error)
- func (*CommandQueueMetrics) ProtoMessage()
- func (m *CommandQueueMetrics) Reset()
- func (m *CommandQueueMetrics) Size() (n int)
- func (m *CommandQueueMetrics) String() string
- func (m *CommandQueueMetrics) Unmarshal(dAtA []byte) error
- type DatabaseDetailsRequest
- func (*DatabaseDetailsRequest) Descriptor() ([]byte, []int)
- func (m *DatabaseDetailsRequest) Marshal() (dAtA []byte, err error)
- func (m *DatabaseDetailsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DatabaseDetailsRequest) ProtoMessage()
- func (m *DatabaseDetailsRequest) Reset()
- func (m *DatabaseDetailsRequest) Size() (n int)
- func (m *DatabaseDetailsRequest) String() string
- func (m *DatabaseDetailsRequest) Unmarshal(dAtA []byte) error
- type DatabaseDetailsResponse
- func (*DatabaseDetailsResponse) Descriptor() ([]byte, []int)
- func (m *DatabaseDetailsResponse) Marshal() (dAtA []byte, err error)
- func (m *DatabaseDetailsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DatabaseDetailsResponse) ProtoMessage()
- func (m *DatabaseDetailsResponse) Reset()
- func (m *DatabaseDetailsResponse) Size() (n int)
- func (m *DatabaseDetailsResponse) String() string
- func (m *DatabaseDetailsResponse) Unmarshal(dAtA []byte) error
- type DatabaseDetailsResponse_Grant
- func (*DatabaseDetailsResponse_Grant) Descriptor() ([]byte, []int)
- func (m *DatabaseDetailsResponse_Grant) Marshal() (dAtA []byte, err error)
- func (m *DatabaseDetailsResponse_Grant) MarshalTo(dAtA []byte) (int, error)
- func (*DatabaseDetailsResponse_Grant) ProtoMessage()
- func (m *DatabaseDetailsResponse_Grant) Reset()
- func (m *DatabaseDetailsResponse_Grant) Size() (n int)
- func (m *DatabaseDetailsResponse_Grant) String() string
- func (m *DatabaseDetailsResponse_Grant) Unmarshal(dAtA []byte) error
- type DatabasesRequest
- func (*DatabasesRequest) Descriptor() ([]byte, []int)
- func (m *DatabasesRequest) Marshal() (dAtA []byte, err error)
- func (m *DatabasesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DatabasesRequest) ProtoMessage()
- func (m *DatabasesRequest) Reset()
- func (m *DatabasesRequest) Size() (n int)
- func (m *DatabasesRequest) String() string
- func (m *DatabasesRequest) Unmarshal(dAtA []byte) error
- type DatabasesResponse
- func (*DatabasesResponse) Descriptor() ([]byte, []int)
- func (m *DatabasesResponse) Marshal() (dAtA []byte, err error)
- func (m *DatabasesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DatabasesResponse) ProtoMessage()
- func (m *DatabasesResponse) Reset()
- func (m *DatabasesResponse) Size() (n int)
- func (m *DatabasesResponse) String() string
- func (m *DatabasesResponse) Unmarshal(dAtA []byte) error
- type DecommissionRequest
- func (*DecommissionRequest) Descriptor() ([]byte, []int)
- func (m *DecommissionRequest) Marshal() (dAtA []byte, err error)
- func (m *DecommissionRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DecommissionRequest) ProtoMessage()
- func (m *DecommissionRequest) Reset()
- func (m *DecommissionRequest) Size() (n int)
- func (m *DecommissionRequest) String() string
- func (m *DecommissionRequest) Unmarshal(dAtA []byte) error
- type DecommissionStatusRequest
- func (*DecommissionStatusRequest) Descriptor() ([]byte, []int)
- func (m *DecommissionStatusRequest) Marshal() (dAtA []byte, err error)
- func (m *DecommissionStatusRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DecommissionStatusRequest) ProtoMessage()
- func (m *DecommissionStatusRequest) Reset()
- func (m *DecommissionStatusRequest) Size() (n int)
- func (m *DecommissionStatusRequest) String() string
- func (m *DecommissionStatusRequest) Unmarshal(dAtA []byte) error
- type DecommissionStatusResponse
- func (*DecommissionStatusResponse) Descriptor() ([]byte, []int)
- func (m *DecommissionStatusResponse) Marshal() (dAtA []byte, err error)
- func (m *DecommissionStatusResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DecommissionStatusResponse) ProtoMessage()
- func (m *DecommissionStatusResponse) Reset()
- func (m *DecommissionStatusResponse) Size() (n int)
- func (m *DecommissionStatusResponse) String() string
- func (m *DecommissionStatusResponse) Unmarshal(dAtA []byte) error
- type DecommissionStatusResponse_Status
- func (*DecommissionStatusResponse_Status) Descriptor() ([]byte, []int)
- func (m *DecommissionStatusResponse_Status) Marshal() (dAtA []byte, err error)
- func (m *DecommissionStatusResponse_Status) MarshalTo(dAtA []byte) (int, error)
- func (*DecommissionStatusResponse_Status) ProtoMessage()
- func (m *DecommissionStatusResponse_Status) Reset()
- func (m *DecommissionStatusResponse_Status) Size() (n int)
- func (m *DecommissionStatusResponse_Status) String() string
- func (m *DecommissionStatusResponse_Status) Unmarshal(dAtA []byte) error
- type DetailsRequest
- func (*DetailsRequest) Descriptor() ([]byte, []int)
- func (m *DetailsRequest) Marshal() (dAtA []byte, err error)
- func (m *DetailsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DetailsRequest) ProtoMessage()
- func (m *DetailsRequest) Reset()
- func (m *DetailsRequest) Size() (n int)
- func (m *DetailsRequest) String() string
- func (m *DetailsRequest) Unmarshal(dAtA []byte) error
- type DetailsResponse
- func (*DetailsResponse) Descriptor() ([]byte, []int)
- func (m *DetailsResponse) Marshal() (dAtA []byte, err error)
- func (m *DetailsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DetailsResponse) ProtoMessage()
- func (m *DetailsResponse) Reset()
- func (m *DetailsResponse) Size() (n int)
- func (m *DetailsResponse) String() string
- func (m *DetailsResponse) Unmarshal(dAtA []byte) error
- type DrainMode
- type DrainRequest
- func (*DrainRequest) Descriptor() ([]byte, []int)
- func (m *DrainRequest) Marshal() (dAtA []byte, err error)
- func (m *DrainRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DrainRequest) ProtoMessage()
- func (m *DrainRequest) Reset()
- func (m *DrainRequest) Size() (n int)
- func (m *DrainRequest) String() string
- func (m *DrainRequest) Unmarshal(dAtA []byte) error
- type DrainResponse
- func (*DrainResponse) Descriptor() ([]byte, []int)
- func (m *DrainResponse) Marshal() (dAtA []byte, err error)
- func (m *DrainResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DrainResponse) ProtoMessage()
- func (m *DrainResponse) Reset()
- func (m *DrainResponse) Size() (n int)
- func (m *DrainResponse) String() string
- func (m *DrainResponse) Unmarshal(dAtA []byte) error
- type EventsRequest
- func (*EventsRequest) Descriptor() ([]byte, []int)
- func (m *EventsRequest) Marshal() (dAtA []byte, err error)
- func (m *EventsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*EventsRequest) ProtoMessage()
- func (m *EventsRequest) Reset()
- func (m *EventsRequest) Size() (n int)
- func (m *EventsRequest) String() string
- func (m *EventsRequest) Unmarshal(dAtA []byte) error
- type EventsResponse
- func (*EventsResponse) Descriptor() ([]byte, []int)
- func (m *EventsResponse) Marshal() (dAtA []byte, err error)
- func (m *EventsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*EventsResponse) ProtoMessage()
- func (m *EventsResponse) Reset()
- func (m *EventsResponse) Size() (n int)
- func (m *EventsResponse) String() string
- func (m *EventsResponse) Unmarshal(dAtA []byte) error
- type EventsResponse_Event
- func (*EventsResponse_Event) Descriptor() ([]byte, []int)
- func (m *EventsResponse_Event) Marshal() (dAtA []byte, err error)
- func (m *EventsResponse_Event) MarshalTo(dAtA []byte) (int, error)
- func (*EventsResponse_Event) ProtoMessage()
- func (m *EventsResponse_Event) Reset()
- func (m *EventsResponse_Event) Size() (n int)
- func (m *EventsResponse_Event) String() string
- func (m *EventsResponse_Event) Unmarshal(dAtA []byte) error
- type GetUIDataRequest
- func (*GetUIDataRequest) Descriptor() ([]byte, []int)
- func (m *GetUIDataRequest) Marshal() (dAtA []byte, err error)
- func (m *GetUIDataRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetUIDataRequest) ProtoMessage()
- func (m *GetUIDataRequest) Reset()
- func (m *GetUIDataRequest) Size() (n int)
- func (m *GetUIDataRequest) String() string
- func (m *GetUIDataRequest) Unmarshal(dAtA []byte) error
- type GetUIDataResponse
- func (*GetUIDataResponse) Descriptor() ([]byte, []int)
- func (m *GetUIDataResponse) Marshal() (dAtA []byte, err error)
- func (m *GetUIDataResponse) MarshalTo(dAtA []byte) (int, error)
- func (*GetUIDataResponse) ProtoMessage()
- func (m *GetUIDataResponse) Reset()
- func (m *GetUIDataResponse) Size() (n int)
- func (m *GetUIDataResponse) String() string
- func (m *GetUIDataResponse) Unmarshal(dAtA []byte) error
- type GetUIDataResponse_Value
- func (*GetUIDataResponse_Value) Descriptor() ([]byte, []int)
- func (m *GetUIDataResponse_Value) Marshal() (dAtA []byte, err error)
- func (m *GetUIDataResponse_Value) MarshalTo(dAtA []byte) (int, error)
- func (*GetUIDataResponse_Value) ProtoMessage()
- func (m *GetUIDataResponse_Value) Reset()
- func (m *GetUIDataResponse_Value) Size() (n int)
- func (m *GetUIDataResponse_Value) String() string
- func (m *GetUIDataResponse_Value) Unmarshal(dAtA []byte) error
- type GossipRequest
- func (*GossipRequest) Descriptor() ([]byte, []int)
- func (m *GossipRequest) Marshal() (dAtA []byte, err error)
- func (m *GossipRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GossipRequest) ProtoMessage()
- func (m *GossipRequest) Reset()
- func (m *GossipRequest) Size() (n int)
- func (m *GossipRequest) String() string
- func (m *GossipRequest) Unmarshal(dAtA []byte) error
- type HealthRequest
- func (*HealthRequest) Descriptor() ([]byte, []int)
- func (m *HealthRequest) Marshal() (dAtA []byte, err error)
- func (m *HealthRequest) MarshalTo(dAtA []byte) (int, error)
- func (*HealthRequest) ProtoMessage()
- func (m *HealthRequest) Reset()
- func (m *HealthRequest) Size() (n int)
- func (m *HealthRequest) String() string
- func (m *HealthRequest) Unmarshal(dAtA []byte) error
- type HealthResponse
- func (*HealthResponse) Descriptor() ([]byte, []int)
- func (m *HealthResponse) Marshal() (dAtA []byte, err error)
- func (m *HealthResponse) MarshalTo(dAtA []byte) (int, error)
- func (*HealthResponse) ProtoMessage()
- func (m *HealthResponse) Reset()
- func (m *HealthResponse) Size() (n int)
- func (m *HealthResponse) String() string
- func (m *HealthResponse) Unmarshal(dAtA []byte) error
- type InitClient
- type InitServer
- type JSONResponse
- func (*JSONResponse) Descriptor() ([]byte, []int)
- func (m *JSONResponse) Marshal() (dAtA []byte, err error)
- func (m *JSONResponse) MarshalTo(dAtA []byte) (int, error)
- func (*JSONResponse) ProtoMessage()
- func (m *JSONResponse) Reset()
- func (m *JSONResponse) Size() (n int)
- func (m *JSONResponse) String() string
- func (m *JSONResponse) Unmarshal(dAtA []byte) error
- type JobsRequest
- func (*JobsRequest) Descriptor() ([]byte, []int)
- func (m *JobsRequest) Marshal() (dAtA []byte, err error)
- func (m *JobsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*JobsRequest) ProtoMessage()
- func (m *JobsRequest) Reset()
- func (m *JobsRequest) Size() (n int)
- func (m *JobsRequest) String() string
- func (m *JobsRequest) Unmarshal(dAtA []byte) error
- type JobsResponse
- func (*JobsResponse) Descriptor() ([]byte, []int)
- func (m *JobsResponse) Marshal() (dAtA []byte, err error)
- func (m *JobsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*JobsResponse) ProtoMessage()
- func (m *JobsResponse) Reset()
- func (m *JobsResponse) Size() (n int)
- func (m *JobsResponse) String() string
- func (m *JobsResponse) Unmarshal(dAtA []byte) error
- type JobsResponse_Job
- func (*JobsResponse_Job) Descriptor() ([]byte, []int)
- func (m *JobsResponse_Job) Marshal() (dAtA []byte, err error)
- func (m *JobsResponse_Job) MarshalTo(dAtA []byte) (int, error)
- func (*JobsResponse_Job) ProtoMessage()
- func (m *JobsResponse_Job) Reset()
- func (m *JobsResponse_Job) Size() (n int)
- func (m *JobsResponse_Job) String() string
- func (m *JobsResponse_Job) Unmarshal(dAtA []byte) error
- type ListSessionsError
- func (*ListSessionsError) Descriptor() ([]byte, []int)
- func (m *ListSessionsError) Marshal() (dAtA []byte, err error)
- func (m *ListSessionsError) MarshalTo(dAtA []byte) (int, error)
- func (*ListSessionsError) ProtoMessage()
- func (m *ListSessionsError) Reset()
- func (m *ListSessionsError) Size() (n int)
- func (m *ListSessionsError) String() string
- func (m *ListSessionsError) Unmarshal(dAtA []byte) error
- type ListSessionsRequest
- func (*ListSessionsRequest) Descriptor() ([]byte, []int)
- func (m *ListSessionsRequest) Marshal() (dAtA []byte, err error)
- func (m *ListSessionsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ListSessionsRequest) ProtoMessage()
- func (m *ListSessionsRequest) Reset()
- func (m *ListSessionsRequest) Size() (n int)
- func (m *ListSessionsRequest) String() string
- func (m *ListSessionsRequest) Unmarshal(dAtA []byte) error
- type ListSessionsResponse
- func (*ListSessionsResponse) Descriptor() ([]byte, []int)
- func (m *ListSessionsResponse) Marshal() (dAtA []byte, err error)
- func (m *ListSessionsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ListSessionsResponse) ProtoMessage()
- func (m *ListSessionsResponse) Reset()
- func (m *ListSessionsResponse) Size() (n int)
- func (m *ListSessionsResponse) String() string
- func (m *ListSessionsResponse) Unmarshal(dAtA []byte) error
- type LivenessRequest
- func (*LivenessRequest) Descriptor() ([]byte, []int)
- func (m *LivenessRequest) Marshal() (dAtA []byte, err error)
- func (m *LivenessRequest) MarshalTo(dAtA []byte) (int, error)
- func (*LivenessRequest) ProtoMessage()
- func (m *LivenessRequest) Reset()
- func (m *LivenessRequest) Size() (n int)
- func (m *LivenessRequest) String() string
- func (m *LivenessRequest) Unmarshal(dAtA []byte) error
- type LivenessResponse
- func (*LivenessResponse) Descriptor() ([]byte, []int)
- func (m *LivenessResponse) Marshal() (dAtA []byte, err error)
- func (m *LivenessResponse) MarshalTo(dAtA []byte) (int, error)
- func (*LivenessResponse) ProtoMessage()
- func (m *LivenessResponse) Reset()
- func (m *LivenessResponse) Size() (n int)
- func (m *LivenessResponse) String() string
- func (m *LivenessResponse) Unmarshal(dAtA []byte) error
- type LogEntriesResponse
- func (*LogEntriesResponse) Descriptor() ([]byte, []int)
- func (m *LogEntriesResponse) Marshal() (dAtA []byte, err error)
- func (m *LogEntriesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*LogEntriesResponse) ProtoMessage()
- func (m *LogEntriesResponse) Reset()
- func (m *LogEntriesResponse) Size() (n int)
- func (m *LogEntriesResponse) String() string
- func (m *LogEntriesResponse) Unmarshal(dAtA []byte) error
- type LogFileRequest
- func (*LogFileRequest) Descriptor() ([]byte, []int)
- func (m *LogFileRequest) Marshal() (dAtA []byte, err error)
- func (m *LogFileRequest) MarshalTo(dAtA []byte) (int, error)
- func (*LogFileRequest) ProtoMessage()
- func (m *LogFileRequest) Reset()
- func (m *LogFileRequest) Size() (n int)
- func (m *LogFileRequest) String() string
- func (m *LogFileRequest) Unmarshal(dAtA []byte) error
- type LogFilesListRequest
- func (*LogFilesListRequest) Descriptor() ([]byte, []int)
- func (m *LogFilesListRequest) Marshal() (dAtA []byte, err error)
- func (m *LogFilesListRequest) MarshalTo(dAtA []byte) (int, error)
- func (*LogFilesListRequest) ProtoMessage()
- func (m *LogFilesListRequest) Reset()
- func (m *LogFilesListRequest) Size() (n int)
- func (m *LogFilesListRequest) String() string
- func (m *LogFilesListRequest) Unmarshal(dAtA []byte) error
- type LogFilesListResponse
- func (*LogFilesListResponse) Descriptor() ([]byte, []int)
- func (m *LogFilesListResponse) Marshal() (dAtA []byte, err error)
- func (m *LogFilesListResponse) MarshalTo(dAtA []byte) (int, error)
- func (*LogFilesListResponse) ProtoMessage()
- func (m *LogFilesListResponse) Reset()
- func (m *LogFilesListResponse) Size() (n int)
- func (m *LogFilesListResponse) String() string
- func (m *LogFilesListResponse) Unmarshal(dAtA []byte) error
- type LogsRequest
- func (*LogsRequest) Descriptor() ([]byte, []int)
- func (m *LogsRequest) Marshal() (dAtA []byte, err error)
- func (m *LogsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*LogsRequest) ProtoMessage()
- func (m *LogsRequest) Reset()
- func (m *LogsRequest) Size() (n int)
- func (m *LogsRequest) String() string
- func (m *LogsRequest) Unmarshal(dAtA []byte) error
- type MetricsRequest
- func (*MetricsRequest) Descriptor() ([]byte, []int)
- func (m *MetricsRequest) Marshal() (dAtA []byte, err error)
- func (m *MetricsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*MetricsRequest) ProtoMessage()
- func (m *MetricsRequest) Reset()
- func (m *MetricsRequest) Size() (n int)
- func (m *MetricsRequest) String() string
- func (m *MetricsRequest) Unmarshal(dAtA []byte) error
- type NodeRequest
- func (*NodeRequest) Descriptor() ([]byte, []int)
- func (m *NodeRequest) Marshal() (dAtA []byte, err error)
- func (m *NodeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*NodeRequest) ProtoMessage()
- func (m *NodeRequest) Reset()
- func (m *NodeRequest) Size() (n int)
- func (m *NodeRequest) String() string
- func (m *NodeRequest) Unmarshal(dAtA []byte) error
- type NodesRequest
- func (*NodesRequest) Descriptor() ([]byte, []int)
- func (m *NodesRequest) Marshal() (dAtA []byte, err error)
- func (m *NodesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*NodesRequest) ProtoMessage()
- func (m *NodesRequest) Reset()
- func (m *NodesRequest) Size() (n int)
- func (m *NodesRequest) String() string
- func (m *NodesRequest) Unmarshal(dAtA []byte) error
- type NodesResponse
- func (*NodesResponse) Descriptor() ([]byte, []int)
- func (m *NodesResponse) Marshal() (dAtA []byte, err error)
- func (m *NodesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*NodesResponse) ProtoMessage()
- func (m *NodesResponse) Reset()
- func (m *NodesResponse) Size() (n int)
- func (m *NodesResponse) String() string
- func (m *NodesResponse) Unmarshal(dAtA []byte) error
- type PrettySpan
- func (*PrettySpan) Descriptor() ([]byte, []int)
- func (this *PrettySpan) Equal(that interface{}) bool
- func (m *PrettySpan) Marshal() (dAtA []byte, err error)
- func (m *PrettySpan) MarshalTo(dAtA []byte) (int, error)
- func (*PrettySpan) ProtoMessage()
- func (m *PrettySpan) Reset()
- func (m *PrettySpan) Size() (n int)
- func (m *PrettySpan) String() string
- func (m *PrettySpan) Unmarshal(dAtA []byte) error
- type ProblemRangesRequest
- func (*ProblemRangesRequest) Descriptor() ([]byte, []int)
- func (m *ProblemRangesRequest) Marshal() (dAtA []byte, err error)
- func (m *ProblemRangesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ProblemRangesRequest) ProtoMessage()
- func (m *ProblemRangesRequest) Reset()
- func (m *ProblemRangesRequest) Size() (n int)
- func (m *ProblemRangesRequest) String() string
- func (m *ProblemRangesRequest) Unmarshal(dAtA []byte) error
- type ProblemRangesResponse
- func (*ProblemRangesResponse) Descriptor() ([]byte, []int)
- func (m *ProblemRangesResponse) Marshal() (dAtA []byte, err error)
- func (m *ProblemRangesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ProblemRangesResponse) ProtoMessage()
- func (m *ProblemRangesResponse) Reset()
- func (m *ProblemRangesResponse) Size() (n int)
- func (m *ProblemRangesResponse) String() string
- func (m *ProblemRangesResponse) Unmarshal(dAtA []byte) error
- type ProblemRangesResponse_NodeProblems
- func (*ProblemRangesResponse_NodeProblems) Descriptor() ([]byte, []int)
- func (m *ProblemRangesResponse_NodeProblems) Marshal() (dAtA []byte, err error)
- func (m *ProblemRangesResponse_NodeProblems) MarshalTo(dAtA []byte) (int, error)
- func (*ProblemRangesResponse_NodeProblems) ProtoMessage()
- func (m *ProblemRangesResponse_NodeProblems) Reset()
- func (m *ProblemRangesResponse_NodeProblems) Size() (n int)
- func (m *ProblemRangesResponse_NodeProblems) String() string
- func (m *ProblemRangesResponse_NodeProblems) Unmarshal(dAtA []byte) error
- type QueryPlanRequest
- func (*QueryPlanRequest) Descriptor() ([]byte, []int)
- func (m *QueryPlanRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPlanRequest) MarshalTo(dAtA []byte) (int, error)
- func (*QueryPlanRequest) ProtoMessage()
- func (m *QueryPlanRequest) Reset()
- func (m *QueryPlanRequest) Size() (n int)
- func (m *QueryPlanRequest) String() string
- func (m *QueryPlanRequest) Unmarshal(dAtA []byte) error
- type QueryPlanResponse
- func (*QueryPlanResponse) Descriptor() ([]byte, []int)
- func (m *QueryPlanResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPlanResponse) MarshalTo(dAtA []byte) (int, error)
- func (*QueryPlanResponse) ProtoMessage()
- func (m *QueryPlanResponse) Reset()
- func (m *QueryPlanResponse) Size() (n int)
- func (m *QueryPlanResponse) String() string
- func (m *QueryPlanResponse) Unmarshal(dAtA []byte) error
- type RaftDebugRequest
- func (*RaftDebugRequest) Descriptor() ([]byte, []int)
- func (m *RaftDebugRequest) Marshal() (dAtA []byte, err error)
- func (m *RaftDebugRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RaftDebugRequest) ProtoMessage()
- func (m *RaftDebugRequest) Reset()
- func (m *RaftDebugRequest) Size() (n int)
- func (m *RaftDebugRequest) String() string
- func (m *RaftDebugRequest) Unmarshal(dAtA []byte) error
- type RaftDebugResponse
- func (*RaftDebugResponse) Descriptor() ([]byte, []int)
- func (m *RaftDebugResponse) Marshal() (dAtA []byte, err error)
- func (m *RaftDebugResponse) MarshalTo(dAtA []byte) (int, error)
- func (*RaftDebugResponse) ProtoMessage()
- func (m *RaftDebugResponse) Reset()
- func (m *RaftDebugResponse) Size() (n int)
- func (m *RaftDebugResponse) String() string
- func (m *RaftDebugResponse) Unmarshal(dAtA []byte) error
- type RaftRangeError
- func (*RaftRangeError) Descriptor() ([]byte, []int)
- func (m *RaftRangeError) Marshal() (dAtA []byte, err error)
- func (m *RaftRangeError) MarshalTo(dAtA []byte) (int, error)
- func (*RaftRangeError) ProtoMessage()
- func (m *RaftRangeError) Reset()
- func (m *RaftRangeError) Size() (n int)
- func (m *RaftRangeError) String() string
- func (m *RaftRangeError) Unmarshal(dAtA []byte) error
- type RaftRangeNode
- func (*RaftRangeNode) Descriptor() ([]byte, []int)
- func (m *RaftRangeNode) Marshal() (dAtA []byte, err error)
- func (m *RaftRangeNode) MarshalTo(dAtA []byte) (int, error)
- func (*RaftRangeNode) ProtoMessage()
- func (m *RaftRangeNode) Reset()
- func (m *RaftRangeNode) Size() (n int)
- func (m *RaftRangeNode) String() string
- func (m *RaftRangeNode) Unmarshal(dAtA []byte) error
- type RaftRangeStatus
- func (*RaftRangeStatus) Descriptor() ([]byte, []int)
- func (m *RaftRangeStatus) Marshal() (dAtA []byte, err error)
- func (m *RaftRangeStatus) MarshalTo(dAtA []byte) (int, error)
- func (*RaftRangeStatus) ProtoMessage()
- func (m *RaftRangeStatus) Reset()
- func (m *RaftRangeStatus) Size() (n int)
- func (m *RaftRangeStatus) String() string
- func (m *RaftRangeStatus) Unmarshal(dAtA []byte) error
- type RaftState
- func (*RaftState) Descriptor() ([]byte, []int)
- func (m *RaftState) Marshal() (dAtA []byte, err error)
- func (m *RaftState) MarshalTo(dAtA []byte) (int, error)
- func (*RaftState) ProtoMessage()
- func (m *RaftState) Reset()
- func (m *RaftState) Size() (n int)
- func (m *RaftState) String() string
- func (m *RaftState) Unmarshal(dAtA []byte) error
- type RaftState_Progress
- func (*RaftState_Progress) Descriptor() ([]byte, []int)
- func (m *RaftState_Progress) Marshal() (dAtA []byte, err error)
- func (m *RaftState_Progress) MarshalTo(dAtA []byte) (int, error)
- func (*RaftState_Progress) ProtoMessage()
- func (m *RaftState_Progress) Reset()
- func (m *RaftState_Progress) Size() (n int)
- func (m *RaftState_Progress) String() string
- func (m *RaftState_Progress) Unmarshal(dAtA []byte) error
- type RangeInfo
- func (*RangeInfo) Descriptor() ([]byte, []int)
- func (m *RangeInfo) Marshal() (dAtA []byte, err error)
- func (m *RangeInfo) MarshalTo(dAtA []byte) (int, error)
- func (*RangeInfo) ProtoMessage()
- func (m *RangeInfo) Reset()
- func (m *RangeInfo) Size() (n int)
- func (m *RangeInfo) String() string
- func (m *RangeInfo) Unmarshal(dAtA []byte) error
- type RangeLogRequest
- func (*RangeLogRequest) Descriptor() ([]byte, []int)
- func (m *RangeLogRequest) Marshal() (dAtA []byte, err error)
- func (m *RangeLogRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RangeLogRequest) ProtoMessage()
- func (m *RangeLogRequest) Reset()
- func (m *RangeLogRequest) Size() (n int)
- func (m *RangeLogRequest) String() string
- func (m *RangeLogRequest) Unmarshal(dAtA []byte) error
- type RangeLogResponse
- func (*RangeLogResponse) Descriptor() ([]byte, []int)
- func (m *RangeLogResponse) Marshal() (dAtA []byte, err error)
- func (m *RangeLogResponse) MarshalTo(dAtA []byte) (int, error)
- func (*RangeLogResponse) ProtoMessage()
- func (m *RangeLogResponse) Reset()
- func (m *RangeLogResponse) Size() (n int)
- func (m *RangeLogResponse) String() string
- func (m *RangeLogResponse) Unmarshal(dAtA []byte) error
- type RangeLogResponse_Event
- func (*RangeLogResponse_Event) Descriptor() ([]byte, []int)
- func (m *RangeLogResponse_Event) Marshal() (dAtA []byte, err error)
- func (m *RangeLogResponse_Event) MarshalTo(dAtA []byte) (int, error)
- func (*RangeLogResponse_Event) ProtoMessage()
- func (m *RangeLogResponse_Event) Reset()
- func (m *RangeLogResponse_Event) Size() (n int)
- func (m *RangeLogResponse_Event) String() string
- func (m *RangeLogResponse_Event) Unmarshal(dAtA []byte) error
- type RangeLogResponse_PrettyInfo
- func (*RangeLogResponse_PrettyInfo) Descriptor() ([]byte, []int)
- func (m *RangeLogResponse_PrettyInfo) Marshal() (dAtA []byte, err error)
- func (m *RangeLogResponse_PrettyInfo) MarshalTo(dAtA []byte) (int, error)
- func (*RangeLogResponse_PrettyInfo) ProtoMessage()
- func (m *RangeLogResponse_PrettyInfo) Reset()
- func (m *RangeLogResponse_PrettyInfo) Size() (n int)
- func (m *RangeLogResponse_PrettyInfo) String() string
- func (m *RangeLogResponse_PrettyInfo) Unmarshal(dAtA []byte) error
- type RangeProblems
- func (*RangeProblems) Descriptor() ([]byte, []int)
- func (m *RangeProblems) Marshal() (dAtA []byte, err error)
- func (m *RangeProblems) MarshalTo(dAtA []byte) (int, error)
- func (*RangeProblems) ProtoMessage()
- func (m *RangeProblems) Reset()
- func (m *RangeProblems) Size() (n int)
- func (m *RangeProblems) String() string
- func (m *RangeProblems) Unmarshal(dAtA []byte) error
- type RangeRequest
- func (*RangeRequest) Descriptor() ([]byte, []int)
- func (m *RangeRequest) Marshal() (dAtA []byte, err error)
- func (m *RangeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RangeRequest) ProtoMessage()
- func (m *RangeRequest) Reset()
- func (m *RangeRequest) Size() (n int)
- func (m *RangeRequest) String() string
- func (m *RangeRequest) Unmarshal(dAtA []byte) error
- type RangeResponse
- func (*RangeResponse) Descriptor() ([]byte, []int)
- func (m *RangeResponse) Marshal() (dAtA []byte, err error)
- func (m *RangeResponse) MarshalTo(dAtA []byte) (int, error)
- func (*RangeResponse) ProtoMessage()
- func (m *RangeResponse) Reset()
- func (m *RangeResponse) Size() (n int)
- func (m *RangeResponse) String() string
- func (m *RangeResponse) Unmarshal(dAtA []byte) error
- type RangeResponse_NodeResponse
- func (*RangeResponse_NodeResponse) Descriptor() ([]byte, []int)
- func (m *RangeResponse_NodeResponse) Marshal() (dAtA []byte, err error)
- func (m *RangeResponse_NodeResponse) MarshalTo(dAtA []byte) (int, error)
- func (*RangeResponse_NodeResponse) ProtoMessage()
- func (m *RangeResponse_NodeResponse) Reset()
- func (m *RangeResponse_NodeResponse) Size() (n int)
- func (m *RangeResponse_NodeResponse) String() string
- func (m *RangeResponse_NodeResponse) Unmarshal(dAtA []byte) error
- type RangeStatistics
- func (*RangeStatistics) Descriptor() ([]byte, []int)
- func (m *RangeStatistics) Marshal() (dAtA []byte, err error)
- func (m *RangeStatistics) MarshalTo(dAtA []byte) (int, error)
- func (*RangeStatistics) ProtoMessage()
- func (m *RangeStatistics) Reset()
- func (m *RangeStatistics) Size() (n int)
- func (m *RangeStatistics) String() string
- func (m *RangeStatistics) Unmarshal(dAtA []byte) error
- type RangesRequest
- func (*RangesRequest) Descriptor() ([]byte, []int)
- func (m *RangesRequest) Marshal() (dAtA []byte, err error)
- func (m *RangesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RangesRequest) ProtoMessage()
- func (m *RangesRequest) Reset()
- func (m *RangesRequest) Size() (n int)
- func (m *RangesRequest) String() string
- func (m *RangesRequest) Unmarshal(dAtA []byte) error
- type RangesResponse
- func (*RangesResponse) Descriptor() ([]byte, []int)
- func (m *RangesResponse) Marshal() (dAtA []byte, err error)
- func (m *RangesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*RangesResponse) ProtoMessage()
- func (m *RangesResponse) Reset()
- func (m *RangesResponse) Size() (n int)
- func (m *RangesResponse) String() string
- func (m *RangesResponse) Unmarshal(dAtA []byte) error
- type Session
- func (*Session) Descriptor() ([]byte, []int)
- func (m *Session) Marshal() (dAtA []byte, err error)
- func (m *Session) MarshalTo(dAtA []byte) (int, error)
- func (*Session) ProtoMessage()
- func (m *Session) Reset()
- func (m *Session) Size() (n int)
- func (m *Session) String() string
- func (m *Session) Unmarshal(dAtA []byte) error
- type SessionCookie
- func (*SessionCookie) Descriptor() ([]byte, []int)
- func (m *SessionCookie) Marshal() (dAtA []byte, err error)
- func (m *SessionCookie) MarshalTo(dAtA []byte) (int, error)
- func (*SessionCookie) ProtoMessage()
- func (m *SessionCookie) Reset()
- func (m *SessionCookie) Size() (n int)
- func (m *SessionCookie) String() string
- func (m *SessionCookie) Unmarshal(dAtA []byte) error
- type SetUIDataRequest
- func (*SetUIDataRequest) Descriptor() ([]byte, []int)
- func (m *SetUIDataRequest) Marshal() (dAtA []byte, err error)
- func (m *SetUIDataRequest) MarshalTo(dAtA []byte) (int, error)
- func (*SetUIDataRequest) ProtoMessage()
- func (m *SetUIDataRequest) Reset()
- func (m *SetUIDataRequest) Size() (n int)
- func (m *SetUIDataRequest) String() string
- func (m *SetUIDataRequest) Unmarshal(dAtA []byte) error
- type SetUIDataResponse
- func (*SetUIDataResponse) Descriptor() ([]byte, []int)
- func (m *SetUIDataResponse) Marshal() (dAtA []byte, err error)
- func (m *SetUIDataResponse) MarshalTo(dAtA []byte) (int, error)
- func (*SetUIDataResponse) ProtoMessage()
- func (m *SetUIDataResponse) Reset()
- func (m *SetUIDataResponse) Size() (n int)
- func (m *SetUIDataResponse) String() string
- func (m *SetUIDataResponse) Unmarshal(dAtA []byte) error
- type SettingsRequest
- func (*SettingsRequest) Descriptor() ([]byte, []int)
- func (m *SettingsRequest) Marshal() (dAtA []byte, err error)
- func (m *SettingsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*SettingsRequest) ProtoMessage()
- func (m *SettingsRequest) Reset()
- func (m *SettingsRequest) Size() (n int)
- func (m *SettingsRequest) String() string
- func (m *SettingsRequest) Unmarshal(dAtA []byte) error
- type SettingsResponse
- func (*SettingsResponse) Descriptor() ([]byte, []int)
- func (m *SettingsResponse) Marshal() (dAtA []byte, err error)
- func (m *SettingsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*SettingsResponse) ProtoMessage()
- func (m *SettingsResponse) Reset()
- func (m *SettingsResponse) Size() (n int)
- func (m *SettingsResponse) String() string
- func (m *SettingsResponse) Unmarshal(dAtA []byte) error
- type SettingsResponse_Value
- func (*SettingsResponse_Value) Descriptor() ([]byte, []int)
- func (m *SettingsResponse_Value) Marshal() (dAtA []byte, err error)
- func (m *SettingsResponse_Value) MarshalTo(dAtA []byte) (int, error)
- func (*SettingsResponse_Value) ProtoMessage()
- func (m *SettingsResponse_Value) Reset()
- func (m *SettingsResponse_Value) Size() (n int)
- func (m *SettingsResponse_Value) String() string
- func (m *SettingsResponse_Value) Unmarshal(dAtA []byte) error
- type SpanStatsRequest
- func (*SpanStatsRequest) Descriptor() ([]byte, []int)
- func (m *SpanStatsRequest) Marshal() (dAtA []byte, err error)
- func (m *SpanStatsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*SpanStatsRequest) ProtoMessage()
- func (m *SpanStatsRequest) Reset()
- func (m *SpanStatsRequest) Size() (n int)
- func (m *SpanStatsRequest) String() string
- func (m *SpanStatsRequest) Unmarshal(dAtA []byte) error
- type SpanStatsResponse
- func (*SpanStatsResponse) Descriptor() ([]byte, []int)
- func (m *SpanStatsResponse) Marshal() (dAtA []byte, err error)
- func (m *SpanStatsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*SpanStatsResponse) ProtoMessage()
- func (m *SpanStatsResponse) Reset()
- func (m *SpanStatsResponse) Size() (n int)
- func (m *SpanStatsResponse) String() string
- func (m *SpanStatsResponse) Unmarshal(dAtA []byte) error
- type StacksRequest
- func (*StacksRequest) Descriptor() ([]byte, []int)
- func (m *StacksRequest) Marshal() (dAtA []byte, err error)
- func (m *StacksRequest) MarshalTo(dAtA []byte) (int, error)
- func (*StacksRequest) ProtoMessage()
- func (m *StacksRequest) Reset()
- func (m *StacksRequest) Size() (n int)
- func (m *StacksRequest) String() string
- func (m *StacksRequest) Unmarshal(dAtA []byte) error
- type StatusClient
- type StatusServer
- type TableDetailsRequest
- func (*TableDetailsRequest) Descriptor() ([]byte, []int)
- func (m *TableDetailsRequest) Marshal() (dAtA []byte, err error)
- func (m *TableDetailsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TableDetailsRequest) ProtoMessage()
- func (m *TableDetailsRequest) Reset()
- func (m *TableDetailsRequest) Size() (n int)
- func (m *TableDetailsRequest) String() string
- func (m *TableDetailsRequest) Unmarshal(dAtA []byte) error
- type TableDetailsResponse
- func (*TableDetailsResponse) Descriptor() ([]byte, []int)
- func (m *TableDetailsResponse) Marshal() (dAtA []byte, err error)
- func (m *TableDetailsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*TableDetailsResponse) ProtoMessage()
- func (m *TableDetailsResponse) Reset()
- func (m *TableDetailsResponse) Size() (n int)
- func (m *TableDetailsResponse) String() string
- func (m *TableDetailsResponse) Unmarshal(dAtA []byte) error
- type TableDetailsResponse_Column
- func (*TableDetailsResponse_Column) Descriptor() ([]byte, []int)
- func (m *TableDetailsResponse_Column) Marshal() (dAtA []byte, err error)
- func (m *TableDetailsResponse_Column) MarshalTo(dAtA []byte) (int, error)
- func (*TableDetailsResponse_Column) ProtoMessage()
- func (m *TableDetailsResponse_Column) Reset()
- func (m *TableDetailsResponse_Column) Size() (n int)
- func (m *TableDetailsResponse_Column) String() string
- func (m *TableDetailsResponse_Column) Unmarshal(dAtA []byte) error
- type TableDetailsResponse_Grant
- func (*TableDetailsResponse_Grant) Descriptor() ([]byte, []int)
- func (m *TableDetailsResponse_Grant) Marshal() (dAtA []byte, err error)
- func (m *TableDetailsResponse_Grant) MarshalTo(dAtA []byte) (int, error)
- func (*TableDetailsResponse_Grant) ProtoMessage()
- func (m *TableDetailsResponse_Grant) Reset()
- func (m *TableDetailsResponse_Grant) Size() (n int)
- func (m *TableDetailsResponse_Grant) String() string
- func (m *TableDetailsResponse_Grant) Unmarshal(dAtA []byte) error
- type TableDetailsResponse_Index
- func (*TableDetailsResponse_Index) Descriptor() ([]byte, []int)
- func (m *TableDetailsResponse_Index) Marshal() (dAtA []byte, err error)
- func (m *TableDetailsResponse_Index) MarshalTo(dAtA []byte) (int, error)
- func (*TableDetailsResponse_Index) ProtoMessage()
- func (m *TableDetailsResponse_Index) Reset()
- func (m *TableDetailsResponse_Index) Size() (n int)
- func (m *TableDetailsResponse_Index) String() string
- func (m *TableDetailsResponse_Index) Unmarshal(dAtA []byte) error
- type TableStatsRequest
- func (*TableStatsRequest) Descriptor() ([]byte, []int)
- func (m *TableStatsRequest) Marshal() (dAtA []byte, err error)
- func (m *TableStatsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TableStatsRequest) ProtoMessage()
- func (m *TableStatsRequest) Reset()
- func (m *TableStatsRequest) Size() (n int)
- func (m *TableStatsRequest) String() string
- func (m *TableStatsRequest) Unmarshal(dAtA []byte) error
- type TableStatsResponse
- func (*TableStatsResponse) Descriptor() ([]byte, []int)
- func (m *TableStatsResponse) Marshal() (dAtA []byte, err error)
- func (m *TableStatsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*TableStatsResponse) ProtoMessage()
- func (m *TableStatsResponse) Reset()
- func (m *TableStatsResponse) Size() (n int)
- func (m *TableStatsResponse) String() string
- func (m *TableStatsResponse) Unmarshal(dAtA []byte) error
- type TableStatsResponse_MissingNode
- func (*TableStatsResponse_MissingNode) Descriptor() ([]byte, []int)
- func (m *TableStatsResponse_MissingNode) Marshal() (dAtA []byte, err error)
- func (m *TableStatsResponse_MissingNode) MarshalTo(dAtA []byte) (int, error)
- func (*TableStatsResponse_MissingNode) ProtoMessage()
- func (m *TableStatsResponse_MissingNode) Reset()
- func (m *TableStatsResponse_MissingNode) Size() (n int)
- func (m *TableStatsResponse_MissingNode) String() string
- func (m *TableStatsResponse_MissingNode) Unmarshal(dAtA []byte) error
- type UserLoginRequest
- func (*UserLoginRequest) Descriptor() ([]byte, []int)
- func (m *UserLoginRequest) Marshal() (dAtA []byte, err error)
- func (m *UserLoginRequest) MarshalTo(dAtA []byte) (int, error)
- func (*UserLoginRequest) ProtoMessage()
- func (m *UserLoginRequest) Reset()
- func (m *UserLoginRequest) Size() (n int)
- func (m *UserLoginRequest) String() string
- func (m *UserLoginRequest) Unmarshal(dAtA []byte) error
- type UserLoginResponse
- func (*UserLoginResponse) Descriptor() ([]byte, []int)
- func (m *UserLoginResponse) Marshal() (dAtA []byte, err error)
- func (m *UserLoginResponse) MarshalTo(dAtA []byte) (int, error)
- func (*UserLoginResponse) ProtoMessage()
- func (m *UserLoginResponse) Reset()
- func (m *UserLoginResponse) Size() (n int)
- func (m *UserLoginResponse) String() string
- func (m *UserLoginResponse) Unmarshal(dAtA []byte) error
- type UserLogoutRequest
- func (*UserLogoutRequest) Descriptor() ([]byte, []int)
- func (m *UserLogoutRequest) Marshal() (dAtA []byte, err error)
- func (m *UserLogoutRequest) MarshalTo(dAtA []byte) (int, error)
- func (*UserLogoutRequest) ProtoMessage()
- func (m *UserLogoutRequest) Reset()
- func (m *UserLogoutRequest) Size() (n int)
- func (m *UserLogoutRequest) String() string
- func (m *UserLogoutRequest) Unmarshal(dAtA []byte) error
- type UserLogoutResponse
- func (*UserLogoutResponse) Descriptor() ([]byte, []int)
- func (m *UserLogoutResponse) Marshal() (dAtA []byte, err error)
- func (m *UserLogoutResponse) MarshalTo(dAtA []byte) (int, error)
- func (*UserLogoutResponse) ProtoMessage()
- func (m *UserLogoutResponse) Reset()
- func (m *UserLogoutResponse) Size() (n int)
- func (m *UserLogoutResponse) String() string
- func (m *UserLogoutResponse) Unmarshal(dAtA []byte) error
- type UsersRequest
- func (*UsersRequest) Descriptor() ([]byte, []int)
- func (m *UsersRequest) Marshal() (dAtA []byte, err error)
- func (m *UsersRequest) MarshalTo(dAtA []byte) (int, error)
- func (*UsersRequest) ProtoMessage()
- func (m *UsersRequest) Reset()
- func (m *UsersRequest) Size() (n int)
- func (m *UsersRequest) String() string
- func (m *UsersRequest) Unmarshal(dAtA []byte) error
- type UsersResponse
- func (*UsersResponse) Descriptor() ([]byte, []int)
- func (m *UsersResponse) Marshal() (dAtA []byte, err error)
- func (m *UsersResponse) MarshalTo(dAtA []byte) (int, error)
- func (*UsersResponse) ProtoMessage()
- func (m *UsersResponse) Reset()
- func (m *UsersResponse) Size() (n int)
- func (m *UsersResponse) String() string
- func (m *UsersResponse) Unmarshal(dAtA []byte) error
- type UsersResponse_User
- func (*UsersResponse_User) Descriptor() ([]byte, []int)
- func (m *UsersResponse_User) Marshal() (dAtA []byte, err error)
- func (m *UsersResponse_User) MarshalTo(dAtA []byte) (int, error)
- func (*UsersResponse_User) ProtoMessage()
- func (m *UsersResponse_User) Reset()
- func (m *UsersResponse_User) Size() (n int)
- func (m *UsersResponse_User) String() string
- func (m *UsersResponse_User) Unmarshal(dAtA []byte) error
- type ZoneConfigurationLevel
Constants ¶
This section is empty.
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",
}
var CertificateDetails_CertificateType_value = map[string]int32{
"CA": 0,
"NODE": 1,
}
var DrainMode_name = map[int32]string{
0: "CLIENT",
1: "LEASES",
}
var DrainMode_value = map[string]int32{
"CLIENT": 0,
"LEASES": 1,
}
var ZoneConfigurationLevel_name = map[int32]string{
0: "UNKNOWN",
1: "CLUSTER",
2: "DATABASE",
3: "TABLE",
}
var ZoneConfigurationLevel_value = map[string]int32{
"UNKNOWN": 0,
"CLUSTER": 1,
"DATABASE": 2,
"TABLE": 3,
}
Functions ¶
func RegisterAdminHandler ¶
RegisterAdminHandler registers the http handlers for service Admin to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterAdminHandlerFromEndpoint ¶
func RegisterAdminHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterAdminHandlerFromEndpoint is same as RegisterAdminHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterAdminServer ¶
func RegisterAdminServer(s *grpc.Server, srv AdminServer)
func RegisterAuthenticationHandler ¶ added in v1.1.0
func RegisterAuthenticationHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterAuthenticationHandler registers the http handlers for service Authentication to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterAuthenticationHandlerFromEndpoint ¶ added in v1.1.0
func RegisterAuthenticationHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterAuthenticationHandlerFromEndpoint is same as RegisterAuthenticationHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterAuthenticationServer ¶ added in v1.1.0
func RegisterAuthenticationServer(s *grpc.Server, srv AuthenticationServer)
func RegisterInitServer ¶ added in v1.1.0
func RegisterInitServer(s *grpc.Server, srv InitServer)
func RegisterStatusHandler ¶
RegisterStatusHandler registers the http handlers for service Status to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterStatusHandlerFromEndpoint ¶
func RegisterStatusHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterStatusHandlerFromEndpoint is same as RegisterStatusHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterStatusServer ¶
func RegisterStatusServer(s *grpc.Server, srv StatusServer)
Types ¶
type ActiveQuery ¶ added in v1.1.0
type ActiveQuery struct { // ID of the query (uint128 presented as a hexadecimal string). ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // SQL query string specified by the user. Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"` // Start timestamp of this query. Start time.Time `protobuf:"bytes,3,opt,name=start,stdtime" json:"start"` // True if this query is distributed. IsDistributed bool `protobuf:"varint,4,opt,name=is_distributed,json=isDistributed,proto3" json:"is_distributed,omitempty"` // phase stores the current phase of execution for this query. Phase ActiveQuery_Phase `protobuf:"varint,5,opt,name=phase,proto3,enum=cockroach.server.serverpb.ActiveQuery_Phase" json:"phase,omitempty"` }
ActiveQuery represents a query in flight on some Session.
func (*ActiveQuery) Descriptor ¶ added in v1.1.0
func (*ActiveQuery) Descriptor() ([]byte, []int)
func (*ActiveQuery) Marshal ¶ added in v1.1.0
func (m *ActiveQuery) Marshal() (dAtA []byte, err error)
func (*ActiveQuery) MarshalTo ¶ added in v1.1.0
func (m *ActiveQuery) MarshalTo(dAtA []byte) (int, error)
func (*ActiveQuery) ProtoMessage ¶ added in v1.1.0
func (*ActiveQuery) ProtoMessage()
func (*ActiveQuery) Reset ¶ added in v1.1.0
func (m *ActiveQuery) Reset()
func (*ActiveQuery) Size ¶ added in v1.1.0
func (m *ActiveQuery) Size() (n int)
func (*ActiveQuery) String ¶ added in v1.1.0
func (m *ActiveQuery) String() string
func (*ActiveQuery) Unmarshal ¶ added in v1.1.0
func (m *ActiveQuery) Unmarshal(dAtA []byte) error
type ActiveQuery_Phase ¶ added in v1.1.0
type ActiveQuery_Phase int32
Enum for phase of execution.
const ( ActiveQuery_PREPARING ActiveQuery_Phase = 0 ActiveQuery_EXECUTING ActiveQuery_Phase = 1 )
func (ActiveQuery_Phase) EnumDescriptor ¶ added in v1.1.0
func (ActiveQuery_Phase) EnumDescriptor() ([]byte, []int)
func (ActiveQuery_Phase) String ¶ added in v1.1.0
func (x ActiveQuery_Phase) String() string
type AdminClient ¶
type AdminClient interface { // URL: /_admin/v1/users Users(ctx context.Context, in *UsersRequest, opts ...grpc.CallOption) (*UsersResponse, error) // URL: /_admin/v1/databases Databases(ctx context.Context, in *DatabasesRequest, opts ...grpc.CallOption) (*DatabasesResponse, error) // Example URL: /_admin/v1/databases/system DatabaseDetails(ctx context.Context, in *DatabaseDetailsRequest, opts ...grpc.CallOption) (*DatabaseDetailsResponse, error) // Example URL: /_admin/v1/databases/system/tables/ui TableDetails(ctx context.Context, in *TableDetailsRequest, opts ...grpc.CallOption) (*TableDetailsResponse, error) // Example URL: /_admin/v1/databases/system/tables/ui/stats TableStats(ctx context.Context, in *TableStatsRequest, opts ...grpc.CallOption) (*TableStatsResponse, error) // Example URLs: // Example URLs: // - /_admin/v1/events // - /_admin/v1/events?limit=100 // - /_admin/v1/events?type=create_table // - /_admin/v1/events?type=create_table&limit=100 // - /_admin/v1/events?type=drop_table&target_id=4 // - /_admin/v1/events?type=drop_table&target_id=4&limit=100 Events(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (*EventsResponse, error) // This requires a POST. Because of the libraries we're using, the POST body // must be in the following format: // // {"key_values": // { "key1": "base64_encoded_value1"}, // ... // { "keyN": "base64_encoded_valueN"}, // } // // Note that all keys are quoted strings and that all values are base64- // encoded. // // Together, SetUIData and GetUIData provide access to a "cookie jar" for the // admin UI. The structure of the underlying data is meant to be opaque to the // server. SetUIData(ctx context.Context, in *SetUIDataRequest, opts ...grpc.CallOption) (*SetUIDataResponse, error) // Example URLs: // - /_admin/v1/uidata?keys=MYKEY // - /_admin/v1/uidata?keys=MYKEY1&keys=MYKEY2 // // Yes, it's a little odd that the query parameter is named "keys" instead of // "key". I would've preferred that the URL parameter be named "key". However, // it's clearer for the protobuf field to be named "keys," which makes the URL // parameter "keys" as well. GetUIData(ctx context.Context, in *GetUIDataRequest, opts ...grpc.CallOption) (*GetUIDataResponse, error) // Cluster returns metadata for the cluster. Cluster(ctx context.Context, in *ClusterRequest, opts ...grpc.CallOption) (*ClusterResponse, error) // Settings returns the cluster-wide settings for the cluster. Settings(ctx context.Context, in *SettingsRequest, opts ...grpc.CallOption) (*SettingsResponse, error) // Health returns liveness for the node target of the request. Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error) // Liveness returns the liveness state of all nodes on the cluster. Liveness(ctx context.Context, in *LivenessRequest, opts ...grpc.CallOption) (*LivenessResponse, error) // Jobs returns the job records for all jobs of the given status and type. Jobs(ctx context.Context, in *JobsRequest, opts ...grpc.CallOption) (*JobsResponse, error) // QueryPlan returns the query plans for a SQL string. QueryPlan(ctx context.Context, in *QueryPlanRequest, opts ...grpc.CallOption) (*QueryPlanResponse, error) // Drain puts the node into the specified drain mode(s) and optionally // instructs the process to terminate. Drain(ctx context.Context, in *DrainRequest, opts ...grpc.CallOption) (Admin_DrainClient, error) // Decommission puts the node(s) into the specified decommissioning state. Decommission(ctx context.Context, in *DecommissionRequest, opts ...grpc.CallOption) (*DecommissionStatusResponse, error) // DecommissionStatus retrieves the decommissioning status of the specified nodes. DecommissionStatus(ctx context.Context, in *DecommissionStatusRequest, opts ...grpc.CallOption) (*DecommissionStatusResponse, error) // URL: /_admin/v1/rangelog // URL: /_admin/v1/rangelog?limit=100 // URL: /_admin/v1/rangelog/1 // URL: /_admin/v1/rangelog/1?limit=100 RangeLog(ctx context.Context, in *RangeLogRequest, opts ...grpc.CallOption) (*RangeLogResponse, error) }
func NewAdminClient ¶
func NewAdminClient(cc *grpc.ClientConn) AdminClient
type AdminServer ¶
type AdminServer interface { // URL: /_admin/v1/users Users(context.Context, *UsersRequest) (*UsersResponse, error) // URL: /_admin/v1/databases Databases(context.Context, *DatabasesRequest) (*DatabasesResponse, error) // Example URL: /_admin/v1/databases/system DatabaseDetails(context.Context, *DatabaseDetailsRequest) (*DatabaseDetailsResponse, error) // Example URL: /_admin/v1/databases/system/tables/ui TableDetails(context.Context, *TableDetailsRequest) (*TableDetailsResponse, error) // Example URL: /_admin/v1/databases/system/tables/ui/stats TableStats(context.Context, *TableStatsRequest) (*TableStatsResponse, error) // Example URLs: // Example URLs: // - /_admin/v1/events // - /_admin/v1/events?limit=100 // - /_admin/v1/events?type=create_table // - /_admin/v1/events?type=create_table&limit=100 // - /_admin/v1/events?type=drop_table&target_id=4 // - /_admin/v1/events?type=drop_table&target_id=4&limit=100 Events(context.Context, *EventsRequest) (*EventsResponse, error) // This requires a POST. Because of the libraries we're using, the POST body // must be in the following format: // // {"key_values": // { "key1": "base64_encoded_value1"}, // ... // { "keyN": "base64_encoded_valueN"}, // } // // Note that all keys are quoted strings and that all values are base64- // encoded. // // Together, SetUIData and GetUIData provide access to a "cookie jar" for the // admin UI. The structure of the underlying data is meant to be opaque to the // server. SetUIData(context.Context, *SetUIDataRequest) (*SetUIDataResponse, error) // Example URLs: // - /_admin/v1/uidata?keys=MYKEY // - /_admin/v1/uidata?keys=MYKEY1&keys=MYKEY2 // // Yes, it's a little odd that the query parameter is named "keys" instead of // "key". I would've preferred that the URL parameter be named "key". However, // it's clearer for the protobuf field to be named "keys," which makes the URL // parameter "keys" as well. GetUIData(context.Context, *GetUIDataRequest) (*GetUIDataResponse, error) // Cluster returns metadata for the cluster. Cluster(context.Context, *ClusterRequest) (*ClusterResponse, error) // Settings returns the cluster-wide settings for the cluster. Settings(context.Context, *SettingsRequest) (*SettingsResponse, error) // Health returns liveness for the node target of the request. Health(context.Context, *HealthRequest) (*HealthResponse, error) // Liveness returns the liveness state of all nodes on the cluster. Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error) // Jobs returns the job records for all jobs of the given status and type. Jobs(context.Context, *JobsRequest) (*JobsResponse, error) // QueryPlan returns the query plans for a SQL string. QueryPlan(context.Context, *QueryPlanRequest) (*QueryPlanResponse, error) // Drain puts the node into the specified drain mode(s) and optionally // instructs the process to terminate. Drain(*DrainRequest, Admin_DrainServer) error // Decommission puts the node(s) into the specified decommissioning state. Decommission(context.Context, *DecommissionRequest) (*DecommissionStatusResponse, error) // DecommissionStatus retrieves the decommissioning status of the specified nodes. DecommissionStatus(context.Context, *DecommissionStatusRequest) (*DecommissionStatusResponse, error) // URL: /_admin/v1/rangelog // URL: /_admin/v1/rangelog?limit=100 // URL: /_admin/v1/rangelog/1 // URL: /_admin/v1/rangelog/1?limit=100 RangeLog(context.Context, *RangeLogRequest) (*RangeLogResponse, error) }
type Admin_DrainClient ¶
type Admin_DrainClient interface { Recv() (*DrainResponse, error) grpc.ClientStream }
type Admin_DrainServer ¶
type Admin_DrainServer interface { Send(*DrainResponse) error grpc.ServerStream }
type AllocatorDryRun ¶ added in v1.1.0
type AllocatorDryRun struct { RangeID github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 145-byte string literal not displayed */ Events []*AllocatorDryRun_Event `protobuf:"bytes,2,rep,name=events" json:"events,omitempty"` }
func (*AllocatorDryRun) Descriptor ¶ added in v1.1.0
func (*AllocatorDryRun) Descriptor() ([]byte, []int)
func (*AllocatorDryRun) Marshal ¶ added in v1.1.0
func (m *AllocatorDryRun) Marshal() (dAtA []byte, err error)
func (*AllocatorDryRun) MarshalTo ¶ added in v1.1.0
func (m *AllocatorDryRun) MarshalTo(dAtA []byte) (int, error)
func (*AllocatorDryRun) ProtoMessage ¶ added in v1.1.0
func (*AllocatorDryRun) ProtoMessage()
func (*AllocatorDryRun) Reset ¶ added in v1.1.0
func (m *AllocatorDryRun) Reset()
func (*AllocatorDryRun) Size ¶ added in v1.1.0
func (m *AllocatorDryRun) Size() (n int)
func (*AllocatorDryRun) String ¶ added in v1.1.0
func (m *AllocatorDryRun) String() string
func (*AllocatorDryRun) Unmarshal ¶ added in v1.1.0
func (m *AllocatorDryRun) Unmarshal(dAtA []byte) error
type AllocatorDryRun_Event ¶ added in v1.1.0
type AllocatorDryRun_Event struct { Time time.Time `protobuf:"bytes,1,opt,name=time,stdtime" json:"time"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` }
func (*AllocatorDryRun_Event) Descriptor ¶ added in v1.1.0
func (*AllocatorDryRun_Event) Descriptor() ([]byte, []int)
func (*AllocatorDryRun_Event) Marshal ¶ added in v1.1.0
func (m *AllocatorDryRun_Event) Marshal() (dAtA []byte, err error)
func (*AllocatorDryRun_Event) MarshalTo ¶ added in v1.1.0
func (m *AllocatorDryRun_Event) MarshalTo(dAtA []byte) (int, error)
func (*AllocatorDryRun_Event) ProtoMessage ¶ added in v1.1.0
func (*AllocatorDryRun_Event) ProtoMessage()
func (*AllocatorDryRun_Event) Reset ¶ added in v1.1.0
func (m *AllocatorDryRun_Event) Reset()
func (*AllocatorDryRun_Event) Size ¶ added in v1.1.0
func (m *AllocatorDryRun_Event) Size() (n int)
func (*AllocatorDryRun_Event) String ¶ added in v1.1.0
func (m *AllocatorDryRun_Event) String() string
func (*AllocatorDryRun_Event) Unmarshal ¶ added in v1.1.0
func (m *AllocatorDryRun_Event) Unmarshal(dAtA []byte) error
type AllocatorRangeRequest ¶ added in v1.1.0
type AllocatorRangeRequest struct { // figure out how to teach grpc-gateway about custom names. RangeId int64 `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"` }
func (*AllocatorRangeRequest) Descriptor ¶ added in v1.1.0
func (*AllocatorRangeRequest) Descriptor() ([]byte, []int)
func (*AllocatorRangeRequest) Marshal ¶ added in v1.1.0
func (m *AllocatorRangeRequest) Marshal() (dAtA []byte, err error)
func (*AllocatorRangeRequest) MarshalTo ¶ added in v1.1.0
func (m *AllocatorRangeRequest) MarshalTo(dAtA []byte) (int, error)
func (*AllocatorRangeRequest) ProtoMessage ¶ added in v1.1.0
func (*AllocatorRangeRequest) ProtoMessage()
func (*AllocatorRangeRequest) Reset ¶ added in v1.1.0
func (m *AllocatorRangeRequest) Reset()
func (*AllocatorRangeRequest) Size ¶ added in v1.1.0
func (m *AllocatorRangeRequest) Size() (n int)
func (*AllocatorRangeRequest) String ¶ added in v1.1.0
func (m *AllocatorRangeRequest) String() string
func (*AllocatorRangeRequest) Unmarshal ¶ added in v1.1.0
func (m *AllocatorRangeRequest) Unmarshal(dAtA []byte) error
type AllocatorRangeResponse ¶ added in v1.1.0
type AllocatorRangeResponse struct { // The NodeID of the store whose dry run is returned. Only the leaseholder // for a given range will do an allocator dry run for it. NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */ DryRun *AllocatorDryRun `protobuf:"bytes,2,opt,name=dry_run,json=dryRun" json:"dry_run,omitempty"` }
func (*AllocatorRangeResponse) Descriptor ¶ added in v1.1.0
func (*AllocatorRangeResponse) Descriptor() ([]byte, []int)
func (*AllocatorRangeResponse) Marshal ¶ added in v1.1.0
func (m *AllocatorRangeResponse) Marshal() (dAtA []byte, err error)
func (*AllocatorRangeResponse) MarshalTo ¶ added in v1.1.0
func (m *AllocatorRangeResponse) MarshalTo(dAtA []byte) (int, error)
func (*AllocatorRangeResponse) ProtoMessage ¶ added in v1.1.0
func (*AllocatorRangeResponse) ProtoMessage()
func (*AllocatorRangeResponse) Reset ¶ added in v1.1.0
func (m *AllocatorRangeResponse) Reset()
func (*AllocatorRangeResponse) Size ¶ added in v1.1.0
func (m *AllocatorRangeResponse) Size() (n int)
func (*AllocatorRangeResponse) String ¶ added in v1.1.0
func (m *AllocatorRangeResponse) String() string
func (*AllocatorRangeResponse) Unmarshal ¶ added in v1.1.0
func (m *AllocatorRangeResponse) Unmarshal(dAtA []byte) error
type AllocatorRequest ¶ added in v1.1.0
type AllocatorRequest struct { // figure out how to teach grpc-gateway about custom names. NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` RangeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 148-byte string literal not displayed */ }
func (*AllocatorRequest) Descriptor ¶ added in v1.1.0
func (*AllocatorRequest) Descriptor() ([]byte, []int)
func (*AllocatorRequest) Marshal ¶ added in v1.1.0
func (m *AllocatorRequest) Marshal() (dAtA []byte, err error)
func (*AllocatorRequest) MarshalTo ¶ added in v1.1.0
func (m *AllocatorRequest) MarshalTo(dAtA []byte) (int, error)
func (*AllocatorRequest) ProtoMessage ¶ added in v1.1.0
func (*AllocatorRequest) ProtoMessage()
func (*AllocatorRequest) Reset ¶ added in v1.1.0
func (m *AllocatorRequest) Reset()
func (*AllocatorRequest) Size ¶ added in v1.1.0
func (m *AllocatorRequest) Size() (n int)
func (*AllocatorRequest) String ¶ added in v1.1.0
func (m *AllocatorRequest) String() string
func (*AllocatorRequest) Unmarshal ¶ added in v1.1.0
func (m *AllocatorRequest) Unmarshal(dAtA []byte) error
type AllocatorResponse ¶ added in v1.1.0
type AllocatorResponse struct {
DryRuns []*AllocatorDryRun `protobuf:"bytes,1,rep,name=dry_runs,json=dryRuns" json:"dry_runs,omitempty"`
}
func (*AllocatorResponse) Descriptor ¶ added in v1.1.0
func (*AllocatorResponse) Descriptor() ([]byte, []int)
func (*AllocatorResponse) Marshal ¶ added in v1.1.0
func (m *AllocatorResponse) Marshal() (dAtA []byte, err error)
func (*AllocatorResponse) MarshalTo ¶ added in v1.1.0
func (m *AllocatorResponse) MarshalTo(dAtA []byte) (int, error)
func (*AllocatorResponse) ProtoMessage ¶ added in v1.1.0
func (*AllocatorResponse) ProtoMessage()
func (*AllocatorResponse) Reset ¶ added in v1.1.0
func (m *AllocatorResponse) Reset()
func (*AllocatorResponse) Size ¶ added in v1.1.0
func (m *AllocatorResponse) Size() (n int)
func (*AllocatorResponse) String ¶ added in v1.1.0
func (m *AllocatorResponse) String() string
func (*AllocatorResponse) Unmarshal ¶ added in v1.1.0
func (m *AllocatorResponse) Unmarshal(dAtA []byte) error
type AuthenticationClient ¶ added in v1.1.0
type AuthenticationClient interface { // UserLogin is used to create a web authentication session. UserLogin(ctx context.Context, in *UserLoginRequest, opts ...grpc.CallOption) (*UserLoginResponse, error) // UserLogout terminates an active authentication session. UserLogout(ctx context.Context, in *UserLogoutRequest, opts ...grpc.CallOption) (*UserLogoutResponse, error) }
func NewAuthenticationClient ¶ added in v1.1.0
func NewAuthenticationClient(cc *grpc.ClientConn) AuthenticationClient
type AuthenticationServer ¶ added in v1.1.0
type AuthenticationServer interface { // UserLogin is used to create a web authentication session. UserLogin(context.Context, *UserLoginRequest) (*UserLoginResponse, error) // UserLogout terminates an active authentication session. UserLogout(context.Context, *UserLogoutRequest) (*UserLogoutResponse, error) }
type BootstrapRequest ¶ added in v1.1.0
type BootstrapRequest struct { }
func (*BootstrapRequest) Descriptor ¶ added in v1.1.0
func (*BootstrapRequest) Descriptor() ([]byte, []int)
func (*BootstrapRequest) Marshal ¶ added in v1.1.0
func (m *BootstrapRequest) Marshal() (dAtA []byte, err error)
func (*BootstrapRequest) MarshalTo ¶ added in v1.1.0
func (m *BootstrapRequest) MarshalTo(dAtA []byte) (int, error)
func (*BootstrapRequest) ProtoMessage ¶ added in v1.1.0
func (*BootstrapRequest) ProtoMessage()
func (*BootstrapRequest) Reset ¶ added in v1.1.0
func (m *BootstrapRequest) Reset()
func (*BootstrapRequest) Size ¶ added in v1.1.0
func (m *BootstrapRequest) Size() (n int)
func (*BootstrapRequest) String ¶ added in v1.1.0
func (m *BootstrapRequest) String() string
func (*BootstrapRequest) Unmarshal ¶ added in v1.1.0
func (m *BootstrapRequest) Unmarshal(dAtA []byte) error
type BootstrapResponse ¶ added in v1.1.0
type BootstrapResponse struct { }
func (*BootstrapResponse) Descriptor ¶ added in v1.1.0
func (*BootstrapResponse) Descriptor() ([]byte, []int)
func (*BootstrapResponse) Marshal ¶ added in v1.1.0
func (m *BootstrapResponse) Marshal() (dAtA []byte, err error)
func (*BootstrapResponse) MarshalTo ¶ added in v1.1.0
func (m *BootstrapResponse) MarshalTo(dAtA []byte) (int, error)
func (*BootstrapResponse) ProtoMessage ¶ added in v1.1.0
func (*BootstrapResponse) ProtoMessage()
func (*BootstrapResponse) Reset ¶ added in v1.1.0
func (m *BootstrapResponse) Reset()
func (*BootstrapResponse) Size ¶ added in v1.1.0
func (m *BootstrapResponse) Size() (n int)
func (*BootstrapResponse) String ¶ added in v1.1.0
func (m *BootstrapResponse) String() string
func (*BootstrapResponse) Unmarshal ¶ added in v1.1.0
func (m *BootstrapResponse) Unmarshal(dAtA []byte) error
type CancelQueryRequest ¶ added in v1.1.0
type CancelQueryRequest struct { // ID of gateway node for the query to be cancelled. // // figure out how to teach grpc-gateway about custom names. // // node_id is a string so that "local" can be used to specify that no // forwarding is necessary. NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // ID of query to be cancelled (converted to string). QueryID string `protobuf:"bytes,2,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"` // Username of the user making this cancellation request. Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"` }
Request object for issing a query cancel request.
func (*CancelQueryRequest) Descriptor ¶ added in v1.1.0
func (*CancelQueryRequest) Descriptor() ([]byte, []int)
func (*CancelQueryRequest) Marshal ¶ added in v1.1.0
func (m *CancelQueryRequest) Marshal() (dAtA []byte, err error)
func (*CancelQueryRequest) MarshalTo ¶ added in v1.1.0
func (m *CancelQueryRequest) MarshalTo(dAtA []byte) (int, error)
func (*CancelQueryRequest) ProtoMessage ¶ added in v1.1.0
func (*CancelQueryRequest) ProtoMessage()
func (*CancelQueryRequest) Reset ¶ added in v1.1.0
func (m *CancelQueryRequest) Reset()
func (*CancelQueryRequest) Size ¶ added in v1.1.0
func (m *CancelQueryRequest) Size() (n int)
func (*CancelQueryRequest) String ¶ added in v1.1.0
func (m *CancelQueryRequest) String() string
func (*CancelQueryRequest) Unmarshal ¶ added in v1.1.0
func (m *CancelQueryRequest) Unmarshal(dAtA []byte) error
type CancelQueryResponse ¶ added in v1.1.0
type CancelQueryResponse struct { // Whether the cancellation request succeeded and the query was cancelled. Cancelled bool `protobuf:"varint,1,opt,name=cancelled,proto3" json:"cancelled,omitempty"` // Error message (accompanied with cancelled = false). Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` }
Response returned by target query's gateway node.
func (*CancelQueryResponse) Descriptor ¶ added in v1.1.0
func (*CancelQueryResponse) Descriptor() ([]byte, []int)
func (*CancelQueryResponse) Marshal ¶ added in v1.1.0
func (m *CancelQueryResponse) Marshal() (dAtA []byte, err error)
func (*CancelQueryResponse) MarshalTo ¶ added in v1.1.0
func (m *CancelQueryResponse) MarshalTo(dAtA []byte) (int, error)
func (*CancelQueryResponse) ProtoMessage ¶ added in v1.1.0
func (*CancelQueryResponse) ProtoMessage()
func (*CancelQueryResponse) Reset ¶ added in v1.1.0
func (m *CancelQueryResponse) Reset()
func (*CancelQueryResponse) Size ¶ added in v1.1.0
func (m *CancelQueryResponse) Size() (n int)
func (*CancelQueryResponse) String ¶ added in v1.1.0
func (m *CancelQueryResponse) String() string
func (*CancelQueryResponse) Unmarshal ¶ added in v1.1.0
func (m *CancelQueryResponse) Unmarshal(dAtA []byte) error
type CertificateDetails ¶ added in v1.1.0
type CertificateDetails struct { Type CertificateDetails_CertificateType `` /* 128-byte string literal not displayed */ // "error_message" and "data" are mutually exclusive. ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` // data is the raw file contents of the certificate. This means PEM-encoded DER data. Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` Fields []CertificateDetails_Fields `protobuf:"bytes,4,rep,name=fields" json:"fields"` }
func (*CertificateDetails) Descriptor ¶ added in v1.1.0
func (*CertificateDetails) Descriptor() ([]byte, []int)
func (*CertificateDetails) Marshal ¶ added in v1.1.0
func (m *CertificateDetails) Marshal() (dAtA []byte, err error)
func (*CertificateDetails) MarshalTo ¶ added in v1.1.0
func (m *CertificateDetails) MarshalTo(dAtA []byte) (int, error)
func (*CertificateDetails) ProtoMessage ¶ added in v1.1.0
func (*CertificateDetails) ProtoMessage()
func (*CertificateDetails) Reset ¶ added in v1.1.0
func (m *CertificateDetails) Reset()
func (*CertificateDetails) Size ¶ added in v1.1.0
func (m *CertificateDetails) Size() (n int)
func (*CertificateDetails) String ¶ added in v1.1.0
func (m *CertificateDetails) String() string
func (*CertificateDetails) Unmarshal ¶ added in v1.1.0
func (m *CertificateDetails) Unmarshal(dAtA []byte) error
type CertificateDetails_CertificateType ¶ added in v1.1.0
type CertificateDetails_CertificateType int32
We use an enum to allow reporting of client certs and potential others (eg: UI).
const ( CertificateDetails_CA CertificateDetails_CertificateType = 0 CertificateDetails_NODE CertificateDetails_CertificateType = 1 )
func (CertificateDetails_CertificateType) EnumDescriptor ¶ added in v1.1.0
func (CertificateDetails_CertificateType) EnumDescriptor() ([]byte, []int)
func (CertificateDetails_CertificateType) String ¶ added in v1.1.0
func (x CertificateDetails_CertificateType) String() string
type CertificateDetails_Fields ¶ added in v1.1.0
type CertificateDetails_Fields struct { Issuer string `protobuf:"bytes,1,opt,name=issuer,proto3" json:"issuer,omitempty"` Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"` ValidFrom int64 `protobuf:"varint,3,opt,name=valid_from,json=validFrom,proto3" json:"valid_from,omitempty"` ValidUntil int64 `protobuf:"varint,4,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` Addresses []string `protobuf:"bytes,5,rep,name=addresses" json:"addresses,omitempty"` SignatureAlgorithm string `protobuf:"bytes,6,opt,name=signature_algorithm,json=signatureAlgorithm,proto3" json:"signature_algorithm,omitempty"` PublicKey string `protobuf:"bytes,7,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` KeyUsage []string `protobuf:"bytes,8,rep,name=key_usage,json=keyUsage" json:"key_usage,omitempty"` ExtendedKeyUsage []string `protobuf:"bytes,9,rep,name=extended_key_usage,json=extendedKeyUsage" json:"extended_key_usage,omitempty"` }
func (*CertificateDetails_Fields) Descriptor ¶ added in v1.1.0
func (*CertificateDetails_Fields) Descriptor() ([]byte, []int)
func (*CertificateDetails_Fields) Marshal ¶ added in v1.1.0
func (m *CertificateDetails_Fields) Marshal() (dAtA []byte, err error)
func (*CertificateDetails_Fields) MarshalTo ¶ added in v1.1.0
func (m *CertificateDetails_Fields) MarshalTo(dAtA []byte) (int, error)
func (*CertificateDetails_Fields) ProtoMessage ¶ added in v1.1.0
func (*CertificateDetails_Fields) ProtoMessage()
func (*CertificateDetails_Fields) Reset ¶ added in v1.1.0
func (m *CertificateDetails_Fields) Reset()
func (*CertificateDetails_Fields) Size ¶ added in v1.1.0
func (m *CertificateDetails_Fields) Size() (n int)
func (*CertificateDetails_Fields) String ¶ added in v1.1.0
func (m *CertificateDetails_Fields) String() string
func (*CertificateDetails_Fields) Unmarshal ¶ added in v1.1.0
func (m *CertificateDetails_Fields) Unmarshal(dAtA []byte) error
type CertificatesRequest ¶ added in v1.1.0
type CertificatesRequest struct { // figure out how to teach grpc-gateway about custom names. // // node_id is a string so that "local" can be used to specify that no // forwarding is necessary. NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` }
func (*CertificatesRequest) Descriptor ¶ added in v1.1.0
func (*CertificatesRequest) Descriptor() ([]byte, []int)
func (*CertificatesRequest) Marshal ¶ added in v1.1.0
func (m *CertificatesRequest) Marshal() (dAtA []byte, err error)
func (*CertificatesRequest) MarshalTo ¶ added in v1.1.0
func (m *CertificatesRequest) MarshalTo(dAtA []byte) (int, error)
func (*CertificatesRequest) ProtoMessage ¶ added in v1.1.0
func (*CertificatesRequest) ProtoMessage()
func (*CertificatesRequest) Reset ¶ added in v1.1.0
func (m *CertificatesRequest) Reset()
func (*CertificatesRequest) Size ¶ added in v1.1.0
func (m *CertificatesRequest) Size() (n int)
func (*CertificatesRequest) String ¶ added in v1.1.0
func (m *CertificatesRequest) String() string
func (*CertificatesRequest) Unmarshal ¶ added in v1.1.0
func (m *CertificatesRequest) Unmarshal(dAtA []byte) error
type CertificatesResponse ¶ added in v1.1.0
type CertificatesResponse struct {
Certificates []CertificateDetails `protobuf:"bytes,1,rep,name=certificates" json:"certificates"`
}
func (*CertificatesResponse) Descriptor ¶ added in v1.1.0
func (*CertificatesResponse) Descriptor() ([]byte, []int)
func (*CertificatesResponse) Marshal ¶ added in v1.1.0
func (m *CertificatesResponse) Marshal() (dAtA []byte, err error)
func (*CertificatesResponse) MarshalTo ¶ added in v1.1.0
func (m *CertificatesResponse) MarshalTo(dAtA []byte) (int, error)
func (*CertificatesResponse) ProtoMessage ¶ added in v1.1.0
func (*CertificatesResponse) ProtoMessage()
func (*CertificatesResponse) Reset ¶ added in v1.1.0
func (m *CertificatesResponse) Reset()
func (*CertificatesResponse) Size ¶ added in v1.1.0
func (m *CertificatesResponse) Size() (n int)
func (*CertificatesResponse) String ¶ added in v1.1.0
func (m *CertificatesResponse) String() string
func (*CertificatesResponse) Unmarshal ¶ added in v1.1.0
func (m *CertificatesResponse) Unmarshal(dAtA []byte) error
type ClusterRequest ¶
type ClusterRequest struct { }
ClusterRequest requests metadata for the cluster.
func (*ClusterRequest) Descriptor ¶
func (*ClusterRequest) Descriptor() ([]byte, []int)
func (*ClusterRequest) Marshal ¶
func (m *ClusterRequest) Marshal() (dAtA []byte, err error)
func (*ClusterRequest) ProtoMessage ¶
func (*ClusterRequest) ProtoMessage()
func (*ClusterRequest) Reset ¶
func (m *ClusterRequest) Reset()
func (*ClusterRequest) Size ¶
func (m *ClusterRequest) Size() (n int)
func (*ClusterRequest) String ¶
func (m *ClusterRequest) String() string
func (*ClusterRequest) Unmarshal ¶
func (m *ClusterRequest) Unmarshal(dAtA []byte) error
type ClusterResponse ¶
type ClusterResponse struct { // The unique ID used to identify this cluster. ClusterID string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // True if diagnostics reporting is enabled for the cluster. ReportingEnabled bool `protobuf:"varint,2,opt,name=reporting_enabled,json=reportingEnabled,proto3" json:"reporting_enabled,omitempty"` // True if enterprise features are enabled for the cluster. EnterpriseEnabled bool `protobuf:"varint,3,opt,name=enterprise_enabled,json=enterpriseEnabled,proto3" json:"enterprise_enabled,omitempty"` }
ClusterResponse contains metadata for the cluster.
func (*ClusterResponse) Descriptor ¶
func (*ClusterResponse) Descriptor() ([]byte, []int)
func (*ClusterResponse) Marshal ¶
func (m *ClusterResponse) Marshal() (dAtA []byte, err error)
func (*ClusterResponse) ProtoMessage ¶
func (*ClusterResponse) ProtoMessage()
func (*ClusterResponse) Reset ¶
func (m *ClusterResponse) Reset()
func (*ClusterResponse) Size ¶
func (m *ClusterResponse) Size() (n int)
func (*ClusterResponse) String ¶
func (m *ClusterResponse) String() string
func (*ClusterResponse) Unmarshal ¶
func (m *ClusterResponse) Unmarshal(dAtA []byte) error
type CommandQueueMetrics ¶ added in v1.1.0
type CommandQueueMetrics struct { WriteCommands int64 `protobuf:"varint,1,opt,name=write_commands,json=writeCommands,proto3" json:"write_commands,omitempty"` ReadCommands int64 `protobuf:"varint,2,opt,name=read_commands,json=readCommands,proto3" json:"read_commands,omitempty"` MaxOverlapsSeen int64 `protobuf:"varint,3,opt,name=max_overlaps_seen,json=maxOverlapsSeen,proto3" json:"max_overlaps_seen,omitempty"` TreeSize int32 `protobuf:"varint,4,opt,name=tree_size,json=treeSize,proto3" json:"tree_size,omitempty"` }
func (*CommandQueueMetrics) Descriptor ¶ added in v1.1.0
func (*CommandQueueMetrics) Descriptor() ([]byte, []int)
func (*CommandQueueMetrics) Marshal ¶ added in v1.1.0
func (m *CommandQueueMetrics) Marshal() (dAtA []byte, err error)
func (*CommandQueueMetrics) MarshalTo ¶ added in v1.1.0
func (m *CommandQueueMetrics) MarshalTo(dAtA []byte) (int, error)
func (*CommandQueueMetrics) ProtoMessage ¶ added in v1.1.0
func (*CommandQueueMetrics) ProtoMessage()
func (*CommandQueueMetrics) Reset ¶ added in v1.1.0
func (m *CommandQueueMetrics) Reset()
func (*CommandQueueMetrics) Size ¶ added in v1.1.0
func (m *CommandQueueMetrics) Size() (n int)
func (*CommandQueueMetrics) String ¶ added in v1.1.0
func (m *CommandQueueMetrics) String() string
func (*CommandQueueMetrics) Unmarshal ¶ added in v1.1.0
func (m *CommandQueueMetrics) Unmarshal(dAtA []byte) error
type DatabaseDetailsRequest ¶
type DatabaseDetailsRequest struct { // database is the name of the database we are querying. Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` }
DatabaseDetailsRequest requests detailed information about the specified database
func (*DatabaseDetailsRequest) Descriptor ¶
func (*DatabaseDetailsRequest) Descriptor() ([]byte, []int)
func (*DatabaseDetailsRequest) Marshal ¶
func (m *DatabaseDetailsRequest) Marshal() (dAtA []byte, err error)
func (*DatabaseDetailsRequest) MarshalTo ¶
func (m *DatabaseDetailsRequest) MarshalTo(dAtA []byte) (int, error)
func (*DatabaseDetailsRequest) ProtoMessage ¶
func (*DatabaseDetailsRequest) ProtoMessage()
func (*DatabaseDetailsRequest) Reset ¶
func (m *DatabaseDetailsRequest) Reset()
func (*DatabaseDetailsRequest) Size ¶
func (m *DatabaseDetailsRequest) Size() (n int)
func (*DatabaseDetailsRequest) String ¶
func (m *DatabaseDetailsRequest) String() string
func (*DatabaseDetailsRequest) Unmarshal ¶
func (m *DatabaseDetailsRequest) Unmarshal(dAtA []byte) error
type DatabaseDetailsResponse ¶
type DatabaseDetailsResponse struct { // grants are the results of SHOW GRANTS for this database. Grants []DatabaseDetailsResponse_Grant `protobuf:"bytes,1,rep,name=grants" json:"grants"` // table_names contains the names of all tables (SHOW TABLES) in this // database. TableNames []string `protobuf:"bytes,2,rep,name=table_names,json=tableNames" json:"table_names,omitempty"` // descriptor_id is an identifier used to uniquely identify this database. // It can be used to find events pertaining to this database by filtering on // the 'target_id' field of events. DescriptorID int64 `protobuf:"varint,3,opt,name=descriptor_id,json=descriptorId,proto3" json:"descriptor_id,omitempty"` // The zone configuration in effect for this database. ZoneConfig cockroach_config.ZoneConfig `protobuf:"bytes,4,opt,name=zone_config,json=zoneConfig" json:"zone_config"` // The level at which this object's zone configuration is set. ZoneConfigLevel ZoneConfigurationLevel `` /* 163-byte string literal not displayed */ }
DatabaseDetailsResponse contains grant information and table names for a database.
func (*DatabaseDetailsResponse) Descriptor ¶
func (*DatabaseDetailsResponse) Descriptor() ([]byte, []int)
func (*DatabaseDetailsResponse) Marshal ¶
func (m *DatabaseDetailsResponse) Marshal() (dAtA []byte, err error)
func (*DatabaseDetailsResponse) MarshalTo ¶
func (m *DatabaseDetailsResponse) MarshalTo(dAtA []byte) (int, error)
func (*DatabaseDetailsResponse) ProtoMessage ¶
func (*DatabaseDetailsResponse) ProtoMessage()
func (*DatabaseDetailsResponse) Reset ¶
func (m *DatabaseDetailsResponse) Reset()
func (*DatabaseDetailsResponse) Size ¶
func (m *DatabaseDetailsResponse) Size() (n int)
func (*DatabaseDetailsResponse) String ¶
func (m *DatabaseDetailsResponse) String() string
func (*DatabaseDetailsResponse) Unmarshal ¶
func (m *DatabaseDetailsResponse) Unmarshal(dAtA []byte) error
type DatabaseDetailsResponse_Grant ¶
type DatabaseDetailsResponse_Grant struct { // user is the user that this grant applies to. User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // privileges are the abilities this grant gives to the user. Privileges []string `protobuf:"bytes,2,rep,name=privileges" json:"privileges,omitempty"` }
func (*DatabaseDetailsResponse_Grant) Descriptor ¶
func (*DatabaseDetailsResponse_Grant) Descriptor() ([]byte, []int)
func (*DatabaseDetailsResponse_Grant) Marshal ¶
func (m *DatabaseDetailsResponse_Grant) Marshal() (dAtA []byte, err error)
func (*DatabaseDetailsResponse_Grant) MarshalTo ¶
func (m *DatabaseDetailsResponse_Grant) MarshalTo(dAtA []byte) (int, error)
func (*DatabaseDetailsResponse_Grant) ProtoMessage ¶
func (*DatabaseDetailsResponse_Grant) ProtoMessage()
func (*DatabaseDetailsResponse_Grant) Reset ¶
func (m *DatabaseDetailsResponse_Grant) Reset()
func (*DatabaseDetailsResponse_Grant) Size ¶
func (m *DatabaseDetailsResponse_Grant) Size() (n int)
func (*DatabaseDetailsResponse_Grant) String ¶
func (m *DatabaseDetailsResponse_Grant) String() string
func (*DatabaseDetailsResponse_Grant) Unmarshal ¶
func (m *DatabaseDetailsResponse_Grant) Unmarshal(dAtA []byte) error
type DatabasesRequest ¶
type DatabasesRequest struct { }
DatabasesRequest requests a list of databases.
func (*DatabasesRequest) Descriptor ¶
func (*DatabasesRequest) Descriptor() ([]byte, []int)
func (*DatabasesRequest) Marshal ¶
func (m *DatabasesRequest) Marshal() (dAtA []byte, err error)
func (*DatabasesRequest) ProtoMessage ¶
func (*DatabasesRequest) ProtoMessage()
func (*DatabasesRequest) Reset ¶
func (m *DatabasesRequest) Reset()
func (*DatabasesRequest) Size ¶
func (m *DatabasesRequest) Size() (n int)
func (*DatabasesRequest) String ¶
func (m *DatabasesRequest) String() string
func (*DatabasesRequest) Unmarshal ¶
func (m *DatabasesRequest) Unmarshal(dAtA []byte) error
type DatabasesResponse ¶
type DatabasesResponse struct {
Databases []string `protobuf:"bytes,1,rep,name=databases" json:"databases,omitempty"`
}
DatabasesResponse contains a list of databases.
func (*DatabasesResponse) Descriptor ¶
func (*DatabasesResponse) Descriptor() ([]byte, []int)
func (*DatabasesResponse) Marshal ¶
func (m *DatabasesResponse) Marshal() (dAtA []byte, err error)
func (*DatabasesResponse) MarshalTo ¶
func (m *DatabasesResponse) MarshalTo(dAtA []byte) (int, error)
func (*DatabasesResponse) ProtoMessage ¶
func (*DatabasesResponse) ProtoMessage()
func (*DatabasesResponse) Reset ¶
func (m *DatabasesResponse) Reset()
func (*DatabasesResponse) Size ¶
func (m *DatabasesResponse) Size() (n int)
func (*DatabasesResponse) String ¶
func (m *DatabasesResponse) String() string
func (*DatabasesResponse) Unmarshal ¶
func (m *DatabasesResponse) Unmarshal(dAtA []byte) error
type DecommissionRequest ¶ added in v1.1.0
type DecommissionRequest struct { NodeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 144-byte string literal not displayed */ Decommissioning bool `protobuf:"varint,2,opt,name=decommissioning,proto3" json:"decommissioning,omitempty"` }
DecommissionRequest requests the server to set the Decommissioning flag on all nodes specified by 'node_id' to the value of 'decommissioning'.
If no 'node_id' is given, targets the recipient node.
func (*DecommissionRequest) Descriptor ¶ added in v1.1.0
func (*DecommissionRequest) Descriptor() ([]byte, []int)
func (*DecommissionRequest) Marshal ¶ added in v1.1.0
func (m *DecommissionRequest) Marshal() (dAtA []byte, err error)
func (*DecommissionRequest) MarshalTo ¶ added in v1.1.0
func (m *DecommissionRequest) MarshalTo(dAtA []byte) (int, error)
func (*DecommissionRequest) ProtoMessage ¶ added in v1.1.0
func (*DecommissionRequest) ProtoMessage()
func (*DecommissionRequest) Reset ¶ added in v1.1.0
func (m *DecommissionRequest) Reset()
func (*DecommissionRequest) Size ¶ added in v1.1.0
func (m *DecommissionRequest) Size() (n int)
func (*DecommissionRequest) String ¶ added in v1.1.0
func (m *DecommissionRequest) String() string
func (*DecommissionRequest) Unmarshal ¶ added in v1.1.0
func (m *DecommissionRequest) Unmarshal(dAtA []byte) error
type DecommissionStatusRequest ¶ added in v1.1.0
type DecommissionStatusRequest struct {
NodeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 144-byte string literal not displayed */
}
DecommissionStatusRequest requests the decommissioning status for the specified or, if none are specified, all nodes.
func (*DecommissionStatusRequest) Descriptor ¶ added in v1.1.0
func (*DecommissionStatusRequest) Descriptor() ([]byte, []int)
func (*DecommissionStatusRequest) Marshal ¶ added in v1.1.0
func (m *DecommissionStatusRequest) Marshal() (dAtA []byte, err error)
func (*DecommissionStatusRequest) MarshalTo ¶ added in v1.1.0
func (m *DecommissionStatusRequest) MarshalTo(dAtA []byte) (int, error)
func (*DecommissionStatusRequest) ProtoMessage ¶ added in v1.1.0
func (*DecommissionStatusRequest) ProtoMessage()
func (*DecommissionStatusRequest) Reset ¶ added in v1.1.0
func (m *DecommissionStatusRequest) Reset()
func (*DecommissionStatusRequest) Size ¶ added in v1.1.0
func (m *DecommissionStatusRequest) Size() (n int)
func (*DecommissionStatusRequest) String ¶ added in v1.1.0
func (m *DecommissionStatusRequest) String() string
func (*DecommissionStatusRequest) Unmarshal ¶ added in v1.1.0
func (m *DecommissionStatusRequest) Unmarshal(dAtA []byte) error
type DecommissionStatusResponse ¶ added in v1.1.0
type DecommissionStatusResponse struct { // Status of all affected nodes. Status []DecommissionStatusResponse_Status `protobuf:"bytes,2,rep,name=status" json:"status"` }
DecommissionStatusResponse lists decommissioning statuses for a number of NodeIDs.
func (*DecommissionStatusResponse) Descriptor ¶ added in v1.1.0
func (*DecommissionStatusResponse) Descriptor() ([]byte, []int)
func (*DecommissionStatusResponse) Marshal ¶ added in v1.1.0
func (m *DecommissionStatusResponse) Marshal() (dAtA []byte, err error)
func (*DecommissionStatusResponse) MarshalTo ¶ added in v1.1.0
func (m *DecommissionStatusResponse) MarshalTo(dAtA []byte) (int, error)
func (*DecommissionStatusResponse) ProtoMessage ¶ added in v1.1.0
func (*DecommissionStatusResponse) ProtoMessage()
func (*DecommissionStatusResponse) Reset ¶ added in v1.1.0
func (m *DecommissionStatusResponse) Reset()
func (*DecommissionStatusResponse) Size ¶ added in v1.1.0
func (m *DecommissionStatusResponse) Size() (n int)
func (*DecommissionStatusResponse) String ¶ added in v1.1.0
func (m *DecommissionStatusResponse) String() string
func (*DecommissionStatusResponse) Unmarshal ¶ added in v1.1.0
func (m *DecommissionStatusResponse) Unmarshal(dAtA []byte) error
type DecommissionStatusResponse_Status ¶ added in v1.1.0
type DecommissionStatusResponse_Status struct { NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */ IsLive bool `protobuf:"varint,2,opt,name=is_live,json=isLive,proto3" json:"is_live,omitempty"` ReplicaCount int64 `protobuf:"varint,3,opt,name=replica_count,json=replicaCount,proto3" json:"replica_count,omitempty"` Decommissioning bool `protobuf:"varint,4,opt,name=decommissioning,proto3" json:"decommissioning,omitempty"` Draining bool `protobuf:"varint,5,opt,name=draining,proto3" json:"draining,omitempty"` }
func (*DecommissionStatusResponse_Status) Descriptor ¶ added in v1.1.0
func (*DecommissionStatusResponse_Status) Descriptor() ([]byte, []int)
func (*DecommissionStatusResponse_Status) Marshal ¶ added in v1.1.0
func (m *DecommissionStatusResponse_Status) Marshal() (dAtA []byte, err error)
func (*DecommissionStatusResponse_Status) MarshalTo ¶ added in v1.1.0
func (m *DecommissionStatusResponse_Status) MarshalTo(dAtA []byte) (int, error)
func (*DecommissionStatusResponse_Status) ProtoMessage ¶ added in v1.1.0
func (*DecommissionStatusResponse_Status) ProtoMessage()
func (*DecommissionStatusResponse_Status) Reset ¶ added in v1.1.0
func (m *DecommissionStatusResponse_Status) Reset()
func (*DecommissionStatusResponse_Status) Size ¶ added in v1.1.0
func (m *DecommissionStatusResponse_Status) Size() (n int)
func (*DecommissionStatusResponse_Status) String ¶ added in v1.1.0
func (m *DecommissionStatusResponse_Status) String() string
func (*DecommissionStatusResponse_Status) Unmarshal ¶ added in v1.1.0
func (m *DecommissionStatusResponse_Status) Unmarshal(dAtA []byte) error
type DetailsRequest ¶
type DetailsRequest struct { // figure out how to teach grpc-gateway about custom names. // // node_id is a string so that "local" can be used to specify that no // forwarding is necessary. NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` }
DetailsRequest requests a nodes details.
func (*DetailsRequest) Descriptor ¶
func (*DetailsRequest) Descriptor() ([]byte, []int)
func (*DetailsRequest) Marshal ¶
func (m *DetailsRequest) Marshal() (dAtA []byte, err error)
func (*DetailsRequest) ProtoMessage ¶
func (*DetailsRequest) ProtoMessage()
func (*DetailsRequest) Reset ¶
func (m *DetailsRequest) Reset()
func (*DetailsRequest) Size ¶
func (m *DetailsRequest) Size() (n int)
func (*DetailsRequest) String ¶
func (m *DetailsRequest) String() string
func (*DetailsRequest) Unmarshal ¶
func (m *DetailsRequest) Unmarshal(dAtA []byte) error
type DetailsResponse ¶
type DetailsResponse struct { NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */ Address cockroach_util.UnresolvedAddr `protobuf:"bytes,2,opt,name=address" json:"address"` BuildInfo cockroach_build.Info `protobuf:"bytes,3,opt,name=build_info,json=buildInfo" json:"build_info"` }
func (*DetailsResponse) Descriptor ¶
func (*DetailsResponse) Descriptor() ([]byte, []int)
func (*DetailsResponse) Marshal ¶
func (m *DetailsResponse) Marshal() (dAtA []byte, err error)
func (*DetailsResponse) ProtoMessage ¶
func (*DetailsResponse) ProtoMessage()
func (*DetailsResponse) Reset ¶
func (m *DetailsResponse) Reset()
func (*DetailsResponse) Size ¶
func (m *DetailsResponse) Size() (n int)
func (*DetailsResponse) String ¶
func (m *DetailsResponse) String() string
func (*DetailsResponse) Unmarshal ¶
func (m *DetailsResponse) Unmarshal(dAtA []byte) error
type DrainMode ¶
type DrainMode int32
const ( // CLIENT instructs the server to refuse new SQL clients. // TODO(tschottdorf): also terminate existing clients in a graceful manner. DrainMode_CLIENT DrainMode = 0 // LEADERSHIP instructs the server to gracefully let all its Replicas' // range leases expire. DrainMode_LEASES DrainMode = 1 )
func (DrainMode) EnumDescriptor ¶
type DrainRequest ¶
type DrainRequest struct { // These are actually of type DrainMode, but grpc-gateway does not support // proxying enum fields (yet: // https://github.com/grpc-ecosystem/grpc-gateway/issues/5) and it fails in // pretty dramatic ways (panics the server). On []int32 `protobuf:"varint,1,rep,packed,name=on" json:"on,omitempty"` Off []int32 `protobuf:"varint,2,rep,packed,name=off" json:"off,omitempty"` // When true, terminates the process after the given drain modes have been // activated. Shutdown bool `protobuf:"varint,3,opt,name=shutdown,proto3" json:"shutdown,omitempty"` }
DrainRequest requests the server to enter the specified draining mode. The server first deactivates all the modes specified in 'off' and then activates all those in 'on'.
func (*DrainRequest) Descriptor ¶
func (*DrainRequest) Descriptor() ([]byte, []int)
func (*DrainRequest) Marshal ¶
func (m *DrainRequest) Marshal() (dAtA []byte, err error)
func (*DrainRequest) ProtoMessage ¶
func (*DrainRequest) ProtoMessage()
func (*DrainRequest) Reset ¶
func (m *DrainRequest) Reset()
func (*DrainRequest) Size ¶
func (m *DrainRequest) Size() (n int)
func (*DrainRequest) String ¶
func (m *DrainRequest) String() string
func (*DrainRequest) Unmarshal ¶
func (m *DrainRequest) Unmarshal(dAtA []byte) error
type DrainResponse ¶
type DrainResponse struct {
On []int32 `protobuf:"varint,1,rep,packed,name=on" json:"on,omitempty"`
}
DrainResponse is the response to a successful DrainRequest and lists the modes which are activated after having processing the request.
func (*DrainResponse) Descriptor ¶
func (*DrainResponse) Descriptor() ([]byte, []int)
func (*DrainResponse) Marshal ¶
func (m *DrainResponse) Marshal() (dAtA []byte, err error)
func (*DrainResponse) ProtoMessage ¶
func (*DrainResponse) ProtoMessage()
func (*DrainResponse) Reset ¶
func (m *DrainResponse) Reset()
func (*DrainResponse) Size ¶
func (m *DrainResponse) Size() (n int)
func (*DrainResponse) String ¶
func (m *DrainResponse) String() string
func (*DrainResponse) Unmarshal ¶
func (m *DrainResponse) Unmarshal(dAtA []byte) error
type EventsRequest ¶
type EventsRequest struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` TargetId int64 `protobuf:"varint,2,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"` // limit is the total number of results that are retrieved by the query. If // this is omitted or set to 0, the default maximum number of results are // returned. When set to > 0, at most only that number of results are // returned. When set to < 0, an unlimited number of results are returned. Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"` }
EventsRequest is a request for event log entries, optionally filtered by the specified event type and/or target_id.
func (*EventsRequest) Descriptor ¶
func (*EventsRequest) Descriptor() ([]byte, []int)
func (*EventsRequest) Marshal ¶
func (m *EventsRequest) Marshal() (dAtA []byte, err error)
func (*EventsRequest) ProtoMessage ¶
func (*EventsRequest) ProtoMessage()
func (*EventsRequest) Reset ¶
func (m *EventsRequest) Reset()
func (*EventsRequest) Size ¶
func (m *EventsRequest) Size() (n int)
func (*EventsRequest) String ¶
func (m *EventsRequest) String() string
func (*EventsRequest) Unmarshal ¶
func (m *EventsRequest) Unmarshal(dAtA []byte) error
type EventsResponse ¶
type EventsResponse struct {
Events []EventsResponse_Event `protobuf:"bytes,1,rep,name=events" json:"events"`
}
EventsResponse contains a set of event log entries. This is always limited to the latest N entries (N is enforced in the associated endpoint).
func (*EventsResponse) Descriptor ¶
func (*EventsResponse) Descriptor() ([]byte, []int)
func (*EventsResponse) Marshal ¶
func (m *EventsResponse) Marshal() (dAtA []byte, err error)
func (*EventsResponse) ProtoMessage ¶
func (*EventsResponse) ProtoMessage()
func (*EventsResponse) Reset ¶
func (m *EventsResponse) Reset()
func (*EventsResponse) Size ¶
func (m *EventsResponse) Size() (n int)
func (*EventsResponse) String ¶
func (m *EventsResponse) String() string
func (*EventsResponse) Unmarshal ¶
func (m *EventsResponse) Unmarshal(dAtA []byte) error
type EventsResponse_Event ¶
type EventsResponse_Event struct { // timestamp is the time at which the event occurred. Timestamp time.Time `protobuf:"bytes,1,opt,name=timestamp,stdtime" json:"timestamp"` // event_type is the type of the event (e.g. "create_table", "drop_table". EventType string `protobuf:"bytes,2,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"` // target_id is the target for this event. TargetID int64 `protobuf:"varint,3,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"` // reporting_id is the reporting ID for this event. ReportingID int64 `protobuf:"varint,4,opt,name=reporting_id,json=reportingId,proto3" json:"reporting_id,omitempty"` // info has more detailed information for the event. The contents vary // depending on the event. Info string `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"` // unique_id is a unique identifier for this event. UniqueID []byte `protobuf:"bytes,6,opt,name=unique_id,json=uniqueId,proto3" json:"unique_id,omitempty"` }
func (*EventsResponse_Event) Descriptor ¶
func (*EventsResponse_Event) Descriptor() ([]byte, []int)
func (*EventsResponse_Event) Marshal ¶
func (m *EventsResponse_Event) Marshal() (dAtA []byte, err error)
func (*EventsResponse_Event) MarshalTo ¶
func (m *EventsResponse_Event) MarshalTo(dAtA []byte) (int, error)
func (*EventsResponse_Event) ProtoMessage ¶
func (*EventsResponse_Event) ProtoMessage()
func (*EventsResponse_Event) Reset ¶
func (m *EventsResponse_Event) Reset()
func (*EventsResponse_Event) Size ¶
func (m *EventsResponse_Event) Size() (n int)
func (*EventsResponse_Event) String ¶
func (m *EventsResponse_Event) String() string
func (*EventsResponse_Event) Unmarshal ¶
func (m *EventsResponse_Event) Unmarshal(dAtA []byte) error
type GetUIDataRequest ¶
type GetUIDataRequest struct {
Keys []string `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
}
GETUIDataRequest requests the values for the given keys from the system.ui table.
func (*GetUIDataRequest) Descriptor ¶
func (*GetUIDataRequest) Descriptor() ([]byte, []int)
func (*GetUIDataRequest) Marshal ¶
func (m *GetUIDataRequest) Marshal() (dAtA []byte, err error)
func (*GetUIDataRequest) ProtoMessage ¶
func (*GetUIDataRequest) ProtoMessage()
func (*GetUIDataRequest) Reset ¶
func (m *GetUIDataRequest) Reset()
func (*GetUIDataRequest) Size ¶
func (m *GetUIDataRequest) Size() (n int)
func (*GetUIDataRequest) String ¶
func (m *GetUIDataRequest) String() string
func (*GetUIDataRequest) Unmarshal ¶
func (m *GetUIDataRequest) Unmarshal(dAtA []byte) error
type GetUIDataResponse ¶
type GetUIDataResponse struct { // key_values maps keys to their retrieved values. If this doesn't contain a // a requested key, that key was not found. KeyValues map[string]GetUIDataResponse_Value `` /* 152-byte string literal not displayed */ }
GetUIDataResponse contains the requested values and the times at which the values were last updated.
func (*GetUIDataResponse) Descriptor ¶
func (*GetUIDataResponse) Descriptor() ([]byte, []int)
func (*GetUIDataResponse) Marshal ¶
func (m *GetUIDataResponse) Marshal() (dAtA []byte, err error)
func (*GetUIDataResponse) MarshalTo ¶
func (m *GetUIDataResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetUIDataResponse) ProtoMessage ¶
func (*GetUIDataResponse) ProtoMessage()
func (*GetUIDataResponse) Reset ¶
func (m *GetUIDataResponse) Reset()
func (*GetUIDataResponse) Size ¶
func (m *GetUIDataResponse) Size() (n int)
func (*GetUIDataResponse) String ¶
func (m *GetUIDataResponse) String() string
func (*GetUIDataResponse) Unmarshal ¶
func (m *GetUIDataResponse) Unmarshal(dAtA []byte) error
type GetUIDataResponse_Value ¶
type GetUIDataResponse_Value struct { // value is the value of the requested key. Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // last_updated is the time at which the value was last updated. LastUpdated time.Time `protobuf:"bytes,2,opt,name=last_updated,json=lastUpdated,stdtime" json:"last_updated"` }
func (*GetUIDataResponse_Value) Descriptor ¶
func (*GetUIDataResponse_Value) Descriptor() ([]byte, []int)
func (*GetUIDataResponse_Value) Marshal ¶
func (m *GetUIDataResponse_Value) Marshal() (dAtA []byte, err error)
func (*GetUIDataResponse_Value) MarshalTo ¶
func (m *GetUIDataResponse_Value) MarshalTo(dAtA []byte) (int, error)
func (*GetUIDataResponse_Value) ProtoMessage ¶
func (*GetUIDataResponse_Value) ProtoMessage()
func (*GetUIDataResponse_Value) Reset ¶
func (m *GetUIDataResponse_Value) Reset()
func (*GetUIDataResponse_Value) Size ¶
func (m *GetUIDataResponse_Value) Size() (n int)
func (*GetUIDataResponse_Value) String ¶
func (m *GetUIDataResponse_Value) String() string
func (*GetUIDataResponse_Value) Unmarshal ¶
func (m *GetUIDataResponse_Value) Unmarshal(dAtA []byte) error
type GossipRequest ¶
type GossipRequest struct { // figure out how to teach grpc-gateway about custom names. // // node_id is a string so that "local" can be used to specify that no // forwarding is necessary. NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` }
func (*GossipRequest) Descriptor ¶
func (*GossipRequest) Descriptor() ([]byte, []int)
func (*GossipRequest) Marshal ¶
func (m *GossipRequest) Marshal() (dAtA []byte, err error)
func (*GossipRequest) ProtoMessage ¶
func (*GossipRequest) ProtoMessage()
func (*GossipRequest) Reset ¶
func (m *GossipRequest) Reset()
func (*GossipRequest) Size ¶
func (m *GossipRequest) Size() (n int)
func (*GossipRequest) String ¶
func (m *GossipRequest) String() string
func (*GossipRequest) Unmarshal ¶
func (m *GossipRequest) Unmarshal(dAtA []byte) error
type HealthRequest ¶
type HealthRequest struct { }
HealthRequest inquires whether the addressed node is healthy.
func (*HealthRequest) Descriptor ¶
func (*HealthRequest) Descriptor() ([]byte, []int)
func (*HealthRequest) Marshal ¶
func (m *HealthRequest) Marshal() (dAtA []byte, err error)
func (*HealthRequest) ProtoMessage ¶
func (*HealthRequest) ProtoMessage()
func (*HealthRequest) Reset ¶
func (m *HealthRequest) Reset()
func (*HealthRequest) Size ¶
func (m *HealthRequest) Size() (n int)
func (*HealthRequest) String ¶
func (m *HealthRequest) String() string
func (*HealthRequest) Unmarshal ¶
func (m *HealthRequest) Unmarshal(dAtA []byte) error
type HealthResponse ¶
type HealthResponse struct { }
HealthResponse is the response to HealthRequest. It currently does not contain any information. The request fails however if the node is not live. TODO(tschottdorf): Should it contain information, and if so, what?
func (*HealthResponse) Descriptor ¶
func (*HealthResponse) Descriptor() ([]byte, []int)
func (*HealthResponse) Marshal ¶
func (m *HealthResponse) Marshal() (dAtA []byte, err error)
func (*HealthResponse) ProtoMessage ¶
func (*HealthResponse) ProtoMessage()
func (*HealthResponse) Reset ¶
func (m *HealthResponse) Reset()
func (*HealthResponse) Size ¶
func (m *HealthResponse) Size() (n int)
func (*HealthResponse) String ¶
func (m *HealthResponse) String() string
func (*HealthResponse) Unmarshal ¶
func (m *HealthResponse) Unmarshal(dAtA []byte) error
type InitClient ¶ added in v1.1.0
type InitClient interface { // Bootstrap an uninitialized cluster. Bootstrap(ctx context.Context, in *BootstrapRequest, opts ...grpc.CallOption) (*BootstrapResponse, error) }
func NewInitClient ¶ added in v1.1.0
func NewInitClient(cc *grpc.ClientConn) InitClient
type InitServer ¶ added in v1.1.0
type InitServer interface { // Bootstrap an uninitialized cluster. Bootstrap(context.Context, *BootstrapRequest) (*BootstrapResponse, error) }
type JSONResponse ¶
type JSONResponse struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}
func (*JSONResponse) Descriptor ¶
func (*JSONResponse) Descriptor() ([]byte, []int)
func (*JSONResponse) Marshal ¶
func (m *JSONResponse) Marshal() (dAtA []byte, err error)
func (*JSONResponse) ProtoMessage ¶
func (*JSONResponse) ProtoMessage()
func (*JSONResponse) Reset ¶
func (m *JSONResponse) Reset()
func (*JSONResponse) Size ¶
func (m *JSONResponse) Size() (n int)
func (*JSONResponse) String ¶
func (m *JSONResponse) String() string
func (*JSONResponse) Unmarshal ¶
func (m *JSONResponse) Unmarshal(dAtA []byte) error
type JobsRequest ¶ added in v1.1.0
type JobsRequest struct { Limit int32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` Type cockroach_sql_jobs.Type `protobuf:"varint,3,opt,name=type,proto3,enum=cockroach.sql.jobs.Type" json:"type,omitempty"` }
JobsRequest requests system job information of the given status and type.
func (*JobsRequest) Descriptor ¶ added in v1.1.0
func (*JobsRequest) Descriptor() ([]byte, []int)
func (*JobsRequest) Marshal ¶ added in v1.1.0
func (m *JobsRequest) Marshal() (dAtA []byte, err error)
func (*JobsRequest) MarshalTo ¶ added in v1.1.0
func (m *JobsRequest) MarshalTo(dAtA []byte) (int, error)
func (*JobsRequest) ProtoMessage ¶ added in v1.1.0
func (*JobsRequest) ProtoMessage()
func (*JobsRequest) Reset ¶ added in v1.1.0
func (m *JobsRequest) Reset()
func (*JobsRequest) Size ¶ added in v1.1.0
func (m *JobsRequest) Size() (n int)
func (*JobsRequest) String ¶ added in v1.1.0
func (m *JobsRequest) String() string
func (*JobsRequest) Unmarshal ¶ added in v1.1.0
func (m *JobsRequest) Unmarshal(dAtA []byte) error
type JobsResponse ¶ added in v1.1.0
type JobsResponse struct {
Jobs []JobsResponse_Job `protobuf:"bytes,1,rep,name=jobs" json:"jobs"`
}
JobsResponse contains the job record for each matching job.
func (*JobsResponse) Descriptor ¶ added in v1.1.0
func (*JobsResponse) Descriptor() ([]byte, []int)
func (*JobsResponse) Marshal ¶ added in v1.1.0
func (m *JobsResponse) Marshal() (dAtA []byte, err error)
func (*JobsResponse) MarshalTo ¶ added in v1.1.0
func (m *JobsResponse) MarshalTo(dAtA []byte) (int, error)
func (*JobsResponse) ProtoMessage ¶ added in v1.1.0
func (*JobsResponse) ProtoMessage()
func (*JobsResponse) Reset ¶ added in v1.1.0
func (m *JobsResponse) Reset()
func (*JobsResponse) Size ¶ added in v1.1.0
func (m *JobsResponse) Size() (n int)
func (*JobsResponse) String ¶ added in v1.1.0
func (m *JobsResponse) String() string
func (*JobsResponse) Unmarshal ¶ added in v1.1.0
func (m *JobsResponse) Unmarshal(dAtA []byte) error
type JobsResponse_Job ¶ added in v1.1.0
type JobsResponse_Job struct { ID int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` Username string `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"` DescriptorIDs []github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID `` /* 162-byte string literal not displayed */ Status string `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"` Created *time.Time `protobuf:"bytes,7,opt,name=created,stdtime" json:"created,omitempty"` Started *time.Time `protobuf:"bytes,8,opt,name=started,stdtime" json:"started,omitempty"` Finished *time.Time `protobuf:"bytes,9,opt,name=finished,stdtime" json:"finished,omitempty"` Modified *time.Time `protobuf:"bytes,10,opt,name=modified,stdtime" json:"modified,omitempty"` FractionCompleted float32 `protobuf:"fixed32,11,opt,name=fraction_completed,json=fractionCompleted,proto3" json:"fraction_completed,omitempty"` Error string `protobuf:"bytes,12,opt,name=error,proto3" json:"error,omitempty"` }
func (*JobsResponse_Job) Descriptor ¶ added in v1.1.0
func (*JobsResponse_Job) Descriptor() ([]byte, []int)
func (*JobsResponse_Job) Marshal ¶ added in v1.1.0
func (m *JobsResponse_Job) Marshal() (dAtA []byte, err error)
func (*JobsResponse_Job) MarshalTo ¶ added in v1.1.0
func (m *JobsResponse_Job) MarshalTo(dAtA []byte) (int, error)
func (*JobsResponse_Job) ProtoMessage ¶ added in v1.1.0
func (*JobsResponse_Job) ProtoMessage()
func (*JobsResponse_Job) Reset ¶ added in v1.1.0
func (m *JobsResponse_Job) Reset()
func (*JobsResponse_Job) Size ¶ added in v1.1.0
func (m *JobsResponse_Job) Size() (n int)
func (*JobsResponse_Job) String ¶ added in v1.1.0
func (m *JobsResponse_Job) String() string
func (*JobsResponse_Job) Unmarshal ¶ added in v1.1.0
func (m *JobsResponse_Job) Unmarshal(dAtA []byte) error
type ListSessionsError ¶ added in v1.1.0
type ListSessionsError struct { // ID of node that was being contacted when this error occurred NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */ // Error message. Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` }
An error wrapper object for ListSessionsResponse.
func (*ListSessionsError) Descriptor ¶ added in v1.1.0
func (*ListSessionsError) Descriptor() ([]byte, []int)
func (*ListSessionsError) Marshal ¶ added in v1.1.0
func (m *ListSessionsError) Marshal() (dAtA []byte, err error)
func (*ListSessionsError) MarshalTo ¶ added in v1.1.0
func (m *ListSessionsError) MarshalTo(dAtA []byte) (int, error)
func (*ListSessionsError) ProtoMessage ¶ added in v1.1.0
func (*ListSessionsError) ProtoMessage()
func (*ListSessionsError) Reset ¶ added in v1.1.0
func (m *ListSessionsError) Reset()
func (*ListSessionsError) Size ¶ added in v1.1.0
func (m *ListSessionsError) Size() (n int)
func (*ListSessionsError) String ¶ added in v1.1.0
func (m *ListSessionsError) String() string
func (*ListSessionsError) Unmarshal ¶ added in v1.1.0
func (m *ListSessionsError) Unmarshal(dAtA []byte) error
type ListSessionsRequest ¶ added in v1.1.0
type ListSessionsRequest struct { // Username of the user making this request. Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` }
Request object for ListSessions and ListLocalSessions.
func (*ListSessionsRequest) Descriptor ¶ added in v1.1.0
func (*ListSessionsRequest) Descriptor() ([]byte, []int)
func (*ListSessionsRequest) Marshal ¶ added in v1.1.0
func (m *ListSessionsRequest) Marshal() (dAtA []byte, err error)
func (*ListSessionsRequest) MarshalTo ¶ added in v1.1.0
func (m *ListSessionsRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListSessionsRequest) ProtoMessage ¶ added in v1.1.0
func (*ListSessionsRequest) ProtoMessage()
func (*ListSessionsRequest) Reset ¶ added in v1.1.0
func (m *ListSessionsRequest) Reset()
func (*ListSessionsRequest) Size ¶ added in v1.1.0
func (m *ListSessionsRequest) Size() (n int)
func (*ListSessionsRequest) String ¶ added in v1.1.0
func (m *ListSessionsRequest) String() string
func (*ListSessionsRequest) Unmarshal ¶ added in v1.1.0
func (m *ListSessionsRequest) Unmarshal(dAtA []byte) error
type ListSessionsResponse ¶ added in v1.1.0
type ListSessionsResponse struct { // A list of sessions on this node or cluster. Sessions []Session `protobuf:"bytes,1,rep,name=sessions" json:"sessions"` // Any errors that occurred during fan-out calls to other nodes. Errors []ListSessionsError `protobuf:"bytes,2,rep,name=errors" json:"errors"` }
Response object for ListSessions and ListLocalSessions.
func (*ListSessionsResponse) Descriptor ¶ added in v1.1.0
func (*ListSessionsResponse) Descriptor() ([]byte, []int)
func (*ListSessionsResponse) Marshal ¶ added in v1.1.0
func (m *ListSessionsResponse) Marshal() (dAtA []byte, err error)
func (*ListSessionsResponse) MarshalTo ¶ added in v1.1.0
func (m *ListSessionsResponse) MarshalTo(dAtA []byte) (int, error)
func (*ListSessionsResponse) ProtoMessage ¶ added in v1.1.0
func (*ListSessionsResponse) ProtoMessage()
func (*ListSessionsResponse) Reset ¶ added in v1.1.0
func (m *ListSessionsResponse) Reset()
func (*ListSessionsResponse) Size ¶ added in v1.1.0
func (m *ListSessionsResponse) Size() (n int)
func (*ListSessionsResponse) String ¶ added in v1.1.0
func (m *ListSessionsResponse) String() string
func (*ListSessionsResponse) Unmarshal ¶ added in v1.1.0
func (m *ListSessionsResponse) Unmarshal(dAtA []byte) error
type LivenessRequest ¶
type LivenessRequest struct { }
LivenessRequest requests liveness data for all nodes on the cluster.
func (*LivenessRequest) Descriptor ¶
func (*LivenessRequest) Descriptor() ([]byte, []int)
func (*LivenessRequest) Marshal ¶
func (m *LivenessRequest) Marshal() (dAtA []byte, err error)
func (*LivenessRequest) ProtoMessage ¶
func (*LivenessRequest) ProtoMessage()
func (*LivenessRequest) Reset ¶
func (m *LivenessRequest) Reset()
func (*LivenessRequest) Size ¶
func (m *LivenessRequest) Size() (n int)
func (*LivenessRequest) String ¶
func (m *LivenessRequest) String() string
func (*LivenessRequest) Unmarshal ¶
func (m *LivenessRequest) Unmarshal(dAtA []byte) error
type LivenessResponse ¶
type LivenessResponse struct {
Livenesses []cockroach_storage.Liveness `protobuf:"bytes,1,rep,name=livenesses" json:"livenesses"`
}
LivenessResponse contains the liveness status of each node on the cluster.
func (*LivenessResponse) Descriptor ¶
func (*LivenessResponse) Descriptor() ([]byte, []int)
func (*LivenessResponse) Marshal ¶
func (m *LivenessResponse) Marshal() (dAtA []byte, err error)
func (*LivenessResponse) ProtoMessage ¶
func (*LivenessResponse) ProtoMessage()
func (*LivenessResponse) Reset ¶
func (m *LivenessResponse) Reset()
func (*LivenessResponse) Size ¶
func (m *LivenessResponse) Size() (n int)
func (*LivenessResponse) String ¶
func (m *LivenessResponse) String() string
func (*LivenessResponse) Unmarshal ¶
func (m *LivenessResponse) Unmarshal(dAtA []byte) error
type LogEntriesResponse ¶
type LogEntriesResponse struct {
Entries []cockroach_util_log.Entry `protobuf:"bytes,1,rep,name=entries" json:"entries"`
}
func (*LogEntriesResponse) Descriptor ¶
func (*LogEntriesResponse) Descriptor() ([]byte, []int)
func (*LogEntriesResponse) Marshal ¶
func (m *LogEntriesResponse) Marshal() (dAtA []byte, err error)
func (*LogEntriesResponse) MarshalTo ¶
func (m *LogEntriesResponse) MarshalTo(dAtA []byte) (int, error)
func (*LogEntriesResponse) ProtoMessage ¶
func (*LogEntriesResponse) ProtoMessage()
func (*LogEntriesResponse) Reset ¶
func (m *LogEntriesResponse) Reset()
func (*LogEntriesResponse) Size ¶
func (m *LogEntriesResponse) Size() (n int)
func (*LogEntriesResponse) String ¶
func (m *LogEntriesResponse) String() string
func (*LogEntriesResponse) Unmarshal ¶
func (m *LogEntriesResponse) Unmarshal(dAtA []byte) error
type LogFileRequest ¶
type LogFileRequest struct { // figure out how to teach grpc-gateway about custom names. // // node_id is a string so that "local" can be used to specify that no // forwarding is necessary. NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` File string `protobuf:"bytes,2,opt,name=file,proto3" json:"file,omitempty"` }
func (*LogFileRequest) Descriptor ¶
func (*LogFileRequest) Descriptor() ([]byte, []int)
func (*LogFileRequest) Marshal ¶
func (m *LogFileRequest) Marshal() (dAtA []byte, err error)
func (*LogFileRequest) ProtoMessage ¶
func (*LogFileRequest) ProtoMessage()
func (*LogFileRequest) Reset ¶
func (m *LogFileRequest) Reset()
func (*LogFileRequest) Size ¶
func (m *LogFileRequest) Size() (n int)
func (*LogFileRequest) String ¶
func (m *LogFileRequest) String() string
func (*LogFileRequest) Unmarshal ¶
func (m *LogFileRequest) Unmarshal(dAtA []byte) error
type LogFilesListRequest ¶
type LogFilesListRequest struct { // figure out how to teach grpc-gateway about custom names. // // node_id is a string so that "local" can be used to specify that no // forwarding is necessary. NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` }
func (*LogFilesListRequest) Descriptor ¶
func (*LogFilesListRequest) Descriptor() ([]byte, []int)
func (*LogFilesListRequest) Marshal ¶
func (m *LogFilesListRequest) Marshal() (dAtA []byte, err error)
func (*LogFilesListRequest) MarshalTo ¶
func (m *LogFilesListRequest) MarshalTo(dAtA []byte) (int, error)
func (*LogFilesListRequest) ProtoMessage ¶
func (*LogFilesListRequest) ProtoMessage()
func (*LogFilesListRequest) Reset ¶
func (m *LogFilesListRequest) Reset()
func (*LogFilesListRequest) Size ¶
func (m *LogFilesListRequest) Size() (n int)
func (*LogFilesListRequest) String ¶
func (m *LogFilesListRequest) String() string
func (*LogFilesListRequest) Unmarshal ¶
func (m *LogFilesListRequest) Unmarshal(dAtA []byte) error
type LogFilesListResponse ¶
type LogFilesListResponse struct {
Files []cockroach_util_log.FileInfo `protobuf:"bytes,1,rep,name=files" json:"files"`
}
func (*LogFilesListResponse) Descriptor ¶
func (*LogFilesListResponse) Descriptor() ([]byte, []int)
func (*LogFilesListResponse) Marshal ¶
func (m *LogFilesListResponse) Marshal() (dAtA []byte, err error)
func (*LogFilesListResponse) MarshalTo ¶
func (m *LogFilesListResponse) MarshalTo(dAtA []byte) (int, error)
func (*LogFilesListResponse) ProtoMessage ¶
func (*LogFilesListResponse) ProtoMessage()
func (*LogFilesListResponse) Reset ¶
func (m *LogFilesListResponse) Reset()
func (*LogFilesListResponse) Size ¶
func (m *LogFilesListResponse) Size() (n int)
func (*LogFilesListResponse) String ¶
func (m *LogFilesListResponse) String() string
func (*LogFilesListResponse) Unmarshal ¶
func (m *LogFilesListResponse) Unmarshal(dAtA []byte) error
type LogsRequest ¶
type LogsRequest struct { // figure out how to teach grpc-gateway about custom names. // // node_id is a string so that "local" can be used to specify that no // forwarding is necessary. NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` Level string `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty"` StartTime string `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` EndTime string `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` Max string `protobuf:"bytes,5,opt,name=max,proto3" json:"max,omitempty"` Pattern string `protobuf:"bytes,6,opt,name=pattern,proto3" json:"pattern,omitempty"` }
func (*LogsRequest) Descriptor ¶
func (*LogsRequest) Descriptor() ([]byte, []int)
func (*LogsRequest) Marshal ¶
func (m *LogsRequest) Marshal() (dAtA []byte, err error)
func (*LogsRequest) ProtoMessage ¶
func (*LogsRequest) ProtoMessage()
func (*LogsRequest) Reset ¶
func (m *LogsRequest) Reset()
func (*LogsRequest) Size ¶
func (m *LogsRequest) Size() (n int)
func (*LogsRequest) String ¶
func (m *LogsRequest) String() string
func (*LogsRequest) Unmarshal ¶
func (m *LogsRequest) Unmarshal(dAtA []byte) error
type MetricsRequest ¶
type MetricsRequest struct { // figure out how to teach grpc-gateway about custom names. // // node_id is a string so that "local" can be used to specify that no // forwarding is necessary. NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` }
func (*MetricsRequest) Descriptor ¶
func (*MetricsRequest) Descriptor() ([]byte, []int)
func (*MetricsRequest) Marshal ¶
func (m *MetricsRequest) Marshal() (dAtA []byte, err error)
func (*MetricsRequest) ProtoMessage ¶
func (*MetricsRequest) ProtoMessage()
func (*MetricsRequest) Reset ¶
func (m *MetricsRequest) Reset()
func (*MetricsRequest) Size ¶
func (m *MetricsRequest) Size() (n int)
func (*MetricsRequest) String ¶
func (m *MetricsRequest) String() string
func (*MetricsRequest) Unmarshal ¶
func (m *MetricsRequest) Unmarshal(dAtA []byte) error
type NodeRequest ¶
type NodeRequest struct { // figure out how to teach grpc-gateway about custom names. // // node_id is a string so that "local" can be used to specify that no // forwarding is necessary. NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` }
func (*NodeRequest) Descriptor ¶
func (*NodeRequest) Descriptor() ([]byte, []int)
func (*NodeRequest) Marshal ¶
func (m *NodeRequest) Marshal() (dAtA []byte, err error)
func (*NodeRequest) ProtoMessage ¶
func (*NodeRequest) ProtoMessage()
func (*NodeRequest) Reset ¶
func (m *NodeRequest) Reset()
func (*NodeRequest) Size ¶
func (m *NodeRequest) Size() (n int)
func (*NodeRequest) String ¶
func (m *NodeRequest) String() string
func (*NodeRequest) Unmarshal ¶
func (m *NodeRequest) Unmarshal(dAtA []byte) error
type NodesRequest ¶
type NodesRequest struct { }
func (*NodesRequest) Descriptor ¶
func (*NodesRequest) Descriptor() ([]byte, []int)
func (*NodesRequest) Marshal ¶
func (m *NodesRequest) Marshal() (dAtA []byte, err error)
func (*NodesRequest) ProtoMessage ¶
func (*NodesRequest) ProtoMessage()
func (*NodesRequest) Reset ¶
func (m *NodesRequest) Reset()
func (*NodesRequest) Size ¶
func (m *NodesRequest) Size() (n int)
func (*NodesRequest) String ¶
func (m *NodesRequest) String() string
func (*NodesRequest) Unmarshal ¶
func (m *NodesRequest) Unmarshal(dAtA []byte) error
type NodesResponse ¶
type NodesResponse struct {
Nodes []cockroach_server_status.NodeStatus `protobuf:"bytes,1,rep,name=nodes" json:"nodes"`
}
func (*NodesResponse) Descriptor ¶
func (*NodesResponse) Descriptor() ([]byte, []int)
func (*NodesResponse) Marshal ¶
func (m *NodesResponse) Marshal() (dAtA []byte, err error)
func (*NodesResponse) ProtoMessage ¶
func (*NodesResponse) ProtoMessage()
func (*NodesResponse) Reset ¶
func (m *NodesResponse) Reset()
func (*NodesResponse) Size ¶
func (m *NodesResponse) Size() (n int)
func (*NodesResponse) String ¶
func (m *NodesResponse) String() string
func (*NodesResponse) Unmarshal ¶
func (m *NodesResponse) Unmarshal(dAtA []byte) error
type PrettySpan ¶
type PrettySpan struct { StartKey string `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"` EndKey string `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"` }
func (*PrettySpan) Descriptor ¶
func (*PrettySpan) Descriptor() ([]byte, []int)
func (*PrettySpan) Equal ¶ added in v1.1.0
func (this *PrettySpan) Equal(that interface{}) bool
func (*PrettySpan) Marshal ¶
func (m *PrettySpan) Marshal() (dAtA []byte, err error)
func (*PrettySpan) ProtoMessage ¶
func (*PrettySpan) ProtoMessage()
func (*PrettySpan) Reset ¶
func (m *PrettySpan) Reset()
func (*PrettySpan) Size ¶
func (m *PrettySpan) Size() (n int)
func (*PrettySpan) String ¶
func (m *PrettySpan) String() string
func (*PrettySpan) Unmarshal ¶
func (m *PrettySpan) Unmarshal(dAtA []byte) error
type ProblemRangesRequest ¶ added in v1.1.0
type ProblemRangesRequest struct {
NodeID string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}
func (*ProblemRangesRequest) Descriptor ¶ added in v1.1.0
func (*ProblemRangesRequest) Descriptor() ([]byte, []int)
func (*ProblemRangesRequest) Marshal ¶ added in v1.1.0
func (m *ProblemRangesRequest) Marshal() (dAtA []byte, err error)
func (*ProblemRangesRequest) MarshalTo ¶ added in v1.1.0
func (m *ProblemRangesRequest) MarshalTo(dAtA []byte) (int, error)
func (*ProblemRangesRequest) ProtoMessage ¶ added in v1.1.0
func (*ProblemRangesRequest) ProtoMessage()
func (*ProblemRangesRequest) Reset ¶ added in v1.1.0
func (m *ProblemRangesRequest) Reset()
func (*ProblemRangesRequest) Size ¶ added in v1.1.0
func (m *ProblemRangesRequest) Size() (n int)
func (*ProblemRangesRequest) String ¶ added in v1.1.0
func (m *ProblemRangesRequest) String() string
func (*ProblemRangesRequest) Unmarshal ¶ added in v1.1.0
func (m *ProblemRangesRequest) Unmarshal(dAtA []byte) error
type ProblemRangesResponse ¶ added in v1.1.0
type ProblemRangesResponse struct { // NodeID is the node that submitted all the requests. NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */ ProblemsByNodeID map[github_com_cockroachdb_cockroach_pkg_roachpb.NodeID]ProblemRangesResponse_NodeProblems `` /* 238-byte string literal not displayed */ }
func (*ProblemRangesResponse) Descriptor ¶ added in v1.1.0
func (*ProblemRangesResponse) Descriptor() ([]byte, []int)
func (*ProblemRangesResponse) Marshal ¶ added in v1.1.0
func (m *ProblemRangesResponse) Marshal() (dAtA []byte, err error)
func (*ProblemRangesResponse) MarshalTo ¶ added in v1.1.0
func (m *ProblemRangesResponse) MarshalTo(dAtA []byte) (int, error)
func (*ProblemRangesResponse) ProtoMessage ¶ added in v1.1.0
func (*ProblemRangesResponse) ProtoMessage()
func (*ProblemRangesResponse) Reset ¶ added in v1.1.0
func (m *ProblemRangesResponse) Reset()
func (*ProblemRangesResponse) Size ¶ added in v1.1.0
func (m *ProblemRangesResponse) Size() (n int)
func (*ProblemRangesResponse) String ¶ added in v1.1.0
func (m *ProblemRangesResponse) String() string
func (*ProblemRangesResponse) Unmarshal ¶ added in v1.1.0
func (m *ProblemRangesResponse) Unmarshal(dAtA []byte) error
type ProblemRangesResponse_NodeProblems ¶ added in v1.1.0
type ProblemRangesResponse_NodeProblems struct { ErrorMessage string `protobuf:"bytes,1,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` RaftLeaderNotLeaseHolderRangeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 230-byte string literal not displayed */ NoRaftLeaderRangeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 190-byte string literal not displayed */ NoLeaseRangeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 173-byte string literal not displayed */ UnderreplicatedRangeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 195-byte string literal not displayed */ }
func (*ProblemRangesResponse_NodeProblems) Descriptor ¶ added in v1.1.0
func (*ProblemRangesResponse_NodeProblems) Descriptor() ([]byte, []int)
func (*ProblemRangesResponse_NodeProblems) Marshal ¶ added in v1.1.0
func (m *ProblemRangesResponse_NodeProblems) Marshal() (dAtA []byte, err error)
func (*ProblemRangesResponse_NodeProblems) MarshalTo ¶ added in v1.1.0
func (m *ProblemRangesResponse_NodeProblems) MarshalTo(dAtA []byte) (int, error)
func (*ProblemRangesResponse_NodeProblems) ProtoMessage ¶ added in v1.1.0
func (*ProblemRangesResponse_NodeProblems) ProtoMessage()
func (*ProblemRangesResponse_NodeProblems) Reset ¶ added in v1.1.0
func (m *ProblemRangesResponse_NodeProblems) Reset()
func (*ProblemRangesResponse_NodeProblems) Size ¶ added in v1.1.0
func (m *ProblemRangesResponse_NodeProblems) Size() (n int)
func (*ProblemRangesResponse_NodeProblems) String ¶ added in v1.1.0
func (m *ProblemRangesResponse_NodeProblems) String() string
func (*ProblemRangesResponse_NodeProblems) Unmarshal ¶ added in v1.1.0
func (m *ProblemRangesResponse_NodeProblems) Unmarshal(dAtA []byte) error
type QueryPlanRequest ¶ added in v1.1.0
type QueryPlanRequest struct { // query is the SQL query string. Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` }
QueryPlanRequest requests the query plans for a SQL string.
func (*QueryPlanRequest) Descriptor ¶ added in v1.1.0
func (*QueryPlanRequest) Descriptor() ([]byte, []int)
func (*QueryPlanRequest) Marshal ¶ added in v1.1.0
func (m *QueryPlanRequest) Marshal() (dAtA []byte, err error)
func (*QueryPlanRequest) MarshalTo ¶ added in v1.1.0
func (m *QueryPlanRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPlanRequest) ProtoMessage ¶ added in v1.1.0
func (*QueryPlanRequest) ProtoMessage()
func (*QueryPlanRequest) Reset ¶ added in v1.1.0
func (m *QueryPlanRequest) Reset()
func (*QueryPlanRequest) Size ¶ added in v1.1.0
func (m *QueryPlanRequest) Size() (n int)
func (*QueryPlanRequest) String ¶ added in v1.1.0
func (m *QueryPlanRequest) String() string
func (*QueryPlanRequest) Unmarshal ¶ added in v1.1.0
func (m *QueryPlanRequest) Unmarshal(dAtA []byte) error
type QueryPlanResponse ¶ added in v1.1.0
type QueryPlanResponse struct {
DistSQLPhysicalQueryPlan string `` /* 137-byte string literal not displayed */
}
QueryPlanResponse contains the query plans for a SQL string (currently only the distsql physical query plan).
func (*QueryPlanResponse) Descriptor ¶ added in v1.1.0
func (*QueryPlanResponse) Descriptor() ([]byte, []int)
func (*QueryPlanResponse) Marshal ¶ added in v1.1.0
func (m *QueryPlanResponse) Marshal() (dAtA []byte, err error)
func (*QueryPlanResponse) MarshalTo ¶ added in v1.1.0
func (m *QueryPlanResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPlanResponse) ProtoMessage ¶ added in v1.1.0
func (*QueryPlanResponse) ProtoMessage()
func (*QueryPlanResponse) Reset ¶ added in v1.1.0
func (m *QueryPlanResponse) Reset()
func (*QueryPlanResponse) Size ¶ added in v1.1.0
func (m *QueryPlanResponse) Size() (n int)
func (*QueryPlanResponse) String ¶ added in v1.1.0
func (m *QueryPlanResponse) String() string
func (*QueryPlanResponse) Unmarshal ¶ added in v1.1.0
func (m *QueryPlanResponse) Unmarshal(dAtA []byte) error
type RaftDebugRequest ¶
type RaftDebugRequest struct {
RangeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 148-byte string literal not displayed */
}
func (*RaftDebugRequest) Descriptor ¶
func (*RaftDebugRequest) Descriptor() ([]byte, []int)
func (*RaftDebugRequest) Marshal ¶
func (m *RaftDebugRequest) Marshal() (dAtA []byte, err error)
func (*RaftDebugRequest) ProtoMessage ¶
func (*RaftDebugRequest) ProtoMessage()
func (*RaftDebugRequest) Reset ¶
func (m *RaftDebugRequest) Reset()
func (*RaftDebugRequest) Size ¶
func (m *RaftDebugRequest) Size() (n int)
func (*RaftDebugRequest) String ¶
func (m *RaftDebugRequest) String() string
func (*RaftDebugRequest) Unmarshal ¶
func (m *RaftDebugRequest) Unmarshal(dAtA []byte) error
type RaftDebugResponse ¶
type RaftDebugResponse struct { Ranges map[github_com_cockroachdb_cockroach_pkg_roachpb.RangeID]RaftRangeStatus `` /* 191-byte string literal not displayed */ Errors []RaftRangeError `protobuf:"bytes,2,rep,name=errors" json:"errors"` }
func (*RaftDebugResponse) Descriptor ¶
func (*RaftDebugResponse) Descriptor() ([]byte, []int)
func (*RaftDebugResponse) Marshal ¶
func (m *RaftDebugResponse) Marshal() (dAtA []byte, err error)
func (*RaftDebugResponse) MarshalTo ¶
func (m *RaftDebugResponse) MarshalTo(dAtA []byte) (int, error)
func (*RaftDebugResponse) ProtoMessage ¶
func (*RaftDebugResponse) ProtoMessage()
func (*RaftDebugResponse) Reset ¶
func (m *RaftDebugResponse) Reset()
func (*RaftDebugResponse) Size ¶
func (m *RaftDebugResponse) Size() (n int)
func (*RaftDebugResponse) String ¶
func (m *RaftDebugResponse) String() string
func (*RaftDebugResponse) Unmarshal ¶
func (m *RaftDebugResponse) Unmarshal(dAtA []byte) error
type RaftRangeError ¶
type RaftRangeError struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}
func (*RaftRangeError) Descriptor ¶
func (*RaftRangeError) Descriptor() ([]byte, []int)
func (*RaftRangeError) Marshal ¶
func (m *RaftRangeError) Marshal() (dAtA []byte, err error)
func (*RaftRangeError) ProtoMessage ¶
func (*RaftRangeError) ProtoMessage()
func (*RaftRangeError) Reset ¶
func (m *RaftRangeError) Reset()
func (*RaftRangeError) Size ¶
func (m *RaftRangeError) Size() (n int)
func (*RaftRangeError) String ¶
func (m *RaftRangeError) String() string
func (*RaftRangeError) Unmarshal ¶
func (m *RaftRangeError) Unmarshal(dAtA []byte) error
type RaftRangeNode ¶
type RaftRangeNode struct { NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */ Range RangeInfo `protobuf:"bytes,2,opt,name=range" json:"range"` }
func (*RaftRangeNode) Descriptor ¶
func (*RaftRangeNode) Descriptor() ([]byte, []int)
func (*RaftRangeNode) Marshal ¶
func (m *RaftRangeNode) Marshal() (dAtA []byte, err error)
func (*RaftRangeNode) ProtoMessage ¶
func (*RaftRangeNode) ProtoMessage()
func (*RaftRangeNode) Reset ¶
func (m *RaftRangeNode) Reset()
func (*RaftRangeNode) Size ¶
func (m *RaftRangeNode) Size() (n int)
func (*RaftRangeNode) String ¶
func (m *RaftRangeNode) String() string
func (*RaftRangeNode) Unmarshal ¶
func (m *RaftRangeNode) Unmarshal(dAtA []byte) error
type RaftRangeStatus ¶
type RaftRangeStatus struct { RangeID github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 145-byte string literal not displayed */ Errors []RaftRangeError `protobuf:"bytes,2,rep,name=errors" json:"errors"` Nodes []RaftRangeNode `protobuf:"bytes,3,rep,name=nodes" json:"nodes"` }
func (*RaftRangeStatus) Descriptor ¶
func (*RaftRangeStatus) Descriptor() ([]byte, []int)
func (*RaftRangeStatus) Marshal ¶
func (m *RaftRangeStatus) Marshal() (dAtA []byte, err error)
func (*RaftRangeStatus) ProtoMessage ¶
func (*RaftRangeStatus) ProtoMessage()
func (*RaftRangeStatus) Reset ¶
func (m *RaftRangeStatus) Reset()
func (*RaftRangeStatus) Size ¶
func (m *RaftRangeStatus) Size() (n int)
func (*RaftRangeStatus) String ¶
func (m *RaftRangeStatus) String() string
func (*RaftRangeStatus) Unmarshal ¶
func (m *RaftRangeStatus) Unmarshal(dAtA []byte) error
type RaftState ¶
type RaftState struct { ReplicaID uint64 `protobuf:"varint,1,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"` HardState raftpb.HardState `protobuf:"bytes,2,opt,name=hard_state,json=hardState" json:"hard_state"` // Lead is part of Raft's SoftState. Lead uint64 `protobuf:"varint,3,opt,name=lead,proto3" json:"lead,omitempty"` // State is part of Raft's SoftState. // It's not an enum because this is primarily for ui consumption and there // are issues associated with them. State string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"` Applied uint64 `protobuf:"varint,5,opt,name=applied,proto3" json:"applied,omitempty"` Progress map[uint64]RaftState_Progress `` /* 134-byte string literal not displayed */ }
RaftState gives internal details about a Raft group's state. Closely mirrors the upstream definitions in github.com/coreos/etcd/raft.
func (*RaftState) Descriptor ¶
func (*RaftState) ProtoMessage ¶
func (*RaftState) ProtoMessage()
type RaftState_Progress ¶
type RaftState_Progress struct { Match uint64 `protobuf:"varint,1,opt,name=match,proto3" json:"match,omitempty"` Next uint64 `protobuf:"varint,2,opt,name=next,proto3" json:"next,omitempty"` State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"` Paused bool `protobuf:"varint,4,opt,name=paused,proto3" json:"paused,omitempty"` PendingSnapshot uint64 `protobuf:"varint,5,opt,name=pending_snapshot,json=pendingSnapshot,proto3" json:"pending_snapshot,omitempty"` }
func (*RaftState_Progress) Descriptor ¶
func (*RaftState_Progress) Descriptor() ([]byte, []int)
func (*RaftState_Progress) Marshal ¶
func (m *RaftState_Progress) Marshal() (dAtA []byte, err error)
func (*RaftState_Progress) MarshalTo ¶
func (m *RaftState_Progress) MarshalTo(dAtA []byte) (int, error)
func (*RaftState_Progress) ProtoMessage ¶
func (*RaftState_Progress) ProtoMessage()
func (*RaftState_Progress) Reset ¶
func (m *RaftState_Progress) Reset()
func (*RaftState_Progress) Size ¶
func (m *RaftState_Progress) Size() (n int)
func (*RaftState_Progress) String ¶
func (m *RaftState_Progress) String() string
func (*RaftState_Progress) Unmarshal ¶
func (m *RaftState_Progress) Unmarshal(dAtA []byte) error
type RangeInfo ¶
type RangeInfo struct { Span PrettySpan `protobuf:"bytes,1,opt,name=span" json:"span"` RaftState RaftState `protobuf:"bytes,2,opt,name=raft_state,json=raftState" json:"raft_state"` State cockroach_storage_storagebase.RangeInfo `protobuf:"bytes,4,opt,name=state" json:"state"` SourceNodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 161-byte string literal not displayed */ SourceStoreID github_com_cockroachdb_cockroach_pkg_roachpb.StoreID `` /* 165-byte string literal not displayed */ ErrorMessage string `protobuf:"bytes,7,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` LeaseHistory []cockroach_roachpb1.Lease `protobuf:"bytes,8,rep,name=lease_history,json=leaseHistory" json:"lease_history"` Problems RangeProblems `protobuf:"bytes,9,opt,name=problems" json:"problems"` Stats RangeStatistics `protobuf:"bytes,10,opt,name=stats" json:"stats"` CmdQLocal CommandQueueMetrics `protobuf:"bytes,11,opt,name=cmd_q_local,json=cmdQLocal" json:"cmd_q_local"` CmdQGlobal CommandQueueMetrics `protobuf:"bytes,12,opt,name=cmd_q_global,json=cmdQGlobal" json:"cmd_q_global"` LeaseStatus cockroach_storage2.LeaseStatus `protobuf:"bytes,13,opt,name=lease_status,json=leaseStatus" json:"lease_status"` }
func (*RangeInfo) Descriptor ¶
func (*RangeInfo) ProtoMessage ¶
func (*RangeInfo) ProtoMessage()
type RangeLogRequest ¶ added in v1.1.0
type RangeLogRequest struct { // figure out how to teach grpc-gateway about custom names. // If RangeID is 0, returns range log history without filtering by range. RangeId int64 `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"` // limit is the total number of results that are retrieved by the query. If // this is omitted or set to 0, the default maximum number of results are // returned. When set to > 0, at most only that number of results are // returned. When set to < 0, an unlimited number of results are returned. Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` }
RangeLogRequest request the history of a range from the range log.
func (*RangeLogRequest) Descriptor ¶ added in v1.1.0
func (*RangeLogRequest) Descriptor() ([]byte, []int)
func (*RangeLogRequest) Marshal ¶ added in v1.1.0
func (m *RangeLogRequest) Marshal() (dAtA []byte, err error)
func (*RangeLogRequest) MarshalTo ¶ added in v1.1.0
func (m *RangeLogRequest) MarshalTo(dAtA []byte) (int, error)
func (*RangeLogRequest) ProtoMessage ¶ added in v1.1.0
func (*RangeLogRequest) ProtoMessage()
func (*RangeLogRequest) Reset ¶ added in v1.1.0
func (m *RangeLogRequest) Reset()
func (*RangeLogRequest) Size ¶ added in v1.1.0
func (m *RangeLogRequest) Size() (n int)
func (*RangeLogRequest) String ¶ added in v1.1.0
func (m *RangeLogRequest) String() string
func (*RangeLogRequest) Unmarshal ¶ added in v1.1.0
func (m *RangeLogRequest) Unmarshal(dAtA []byte) error
type RangeLogResponse ¶ added in v1.1.0
type RangeLogResponse struct {
Events []RangeLogResponse_Event `protobuf:"bytes,2,rep,name=events" json:"events"`
}
RangeLogResponse contains a list of entries from the range log table.
func (*RangeLogResponse) Descriptor ¶ added in v1.1.0
func (*RangeLogResponse) Descriptor() ([]byte, []int)
func (*RangeLogResponse) Marshal ¶ added in v1.1.0
func (m *RangeLogResponse) Marshal() (dAtA []byte, err error)
func (*RangeLogResponse) MarshalTo ¶ added in v1.1.0
func (m *RangeLogResponse) MarshalTo(dAtA []byte) (int, error)
func (*RangeLogResponse) ProtoMessage ¶ added in v1.1.0
func (*RangeLogResponse) ProtoMessage()
func (*RangeLogResponse) Reset ¶ added in v1.1.0
func (m *RangeLogResponse) Reset()
func (*RangeLogResponse) Size ¶ added in v1.1.0
func (m *RangeLogResponse) Size() (n int)
func (*RangeLogResponse) String ¶ added in v1.1.0
func (m *RangeLogResponse) String() string
func (*RangeLogResponse) Unmarshal ¶ added in v1.1.0
func (m *RangeLogResponse) Unmarshal(dAtA []byte) error
type RangeLogResponse_Event ¶ added in v1.1.0
type RangeLogResponse_Event struct { Event cockroach_storage1.RangeLogEvent `protobuf:"bytes,1,opt,name=event" json:"event"` PrettyInfo RangeLogResponse_PrettyInfo `protobuf:"bytes,2,opt,name=pretty_info,json=prettyInfo" json:"pretty_info"` }
func (*RangeLogResponse_Event) Descriptor ¶ added in v1.1.0
func (*RangeLogResponse_Event) Descriptor() ([]byte, []int)
func (*RangeLogResponse_Event) Marshal ¶ added in v1.1.0
func (m *RangeLogResponse_Event) Marshal() (dAtA []byte, err error)
func (*RangeLogResponse_Event) MarshalTo ¶ added in v1.1.0
func (m *RangeLogResponse_Event) MarshalTo(dAtA []byte) (int, error)
func (*RangeLogResponse_Event) ProtoMessage ¶ added in v1.1.0
func (*RangeLogResponse_Event) ProtoMessage()
func (*RangeLogResponse_Event) Reset ¶ added in v1.1.0
func (m *RangeLogResponse_Event) Reset()
func (*RangeLogResponse_Event) Size ¶ added in v1.1.0
func (m *RangeLogResponse_Event) Size() (n int)
func (*RangeLogResponse_Event) String ¶ added in v1.1.0
func (m *RangeLogResponse_Event) String() string
func (*RangeLogResponse_Event) Unmarshal ¶ added in v1.1.0
func (m *RangeLogResponse_Event) Unmarshal(dAtA []byte) error
type RangeLogResponse_PrettyInfo ¶ added in v1.1.0
type RangeLogResponse_PrettyInfo struct { UpdatedDesc string `protobuf:"bytes,1,opt,name=updated_desc,json=updatedDesc,proto3" json:"updated_desc,omitempty"` NewDesc string `protobuf:"bytes,2,opt,name=new_desc,json=newDesc,proto3" json:"new_desc,omitempty"` AddedReplica string `protobuf:"bytes,3,opt,name=added_replica,json=addedReplica,proto3" json:"added_replica,omitempty"` RemovedReplica string `protobuf:"bytes,4,opt,name=removed_replica,json=removedReplica,proto3" json:"removed_replica,omitempty"` Reason string `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"` Details string `protobuf:"bytes,6,opt,name=details,proto3" json:"details,omitempty"` }
To avoid porting the pretty printing of keys and descriptors to javascript, they will be precomputed on the serverside.
func (*RangeLogResponse_PrettyInfo) Descriptor ¶ added in v1.1.0
func (*RangeLogResponse_PrettyInfo) Descriptor() ([]byte, []int)
func (*RangeLogResponse_PrettyInfo) Marshal ¶ added in v1.1.0
func (m *RangeLogResponse_PrettyInfo) Marshal() (dAtA []byte, err error)
func (*RangeLogResponse_PrettyInfo) MarshalTo ¶ added in v1.1.0
func (m *RangeLogResponse_PrettyInfo) MarshalTo(dAtA []byte) (int, error)
func (*RangeLogResponse_PrettyInfo) ProtoMessage ¶ added in v1.1.0
func (*RangeLogResponse_PrettyInfo) ProtoMessage()
func (*RangeLogResponse_PrettyInfo) Reset ¶ added in v1.1.0
func (m *RangeLogResponse_PrettyInfo) Reset()
func (*RangeLogResponse_PrettyInfo) Size ¶ added in v1.1.0
func (m *RangeLogResponse_PrettyInfo) Size() (n int)
func (*RangeLogResponse_PrettyInfo) String ¶ added in v1.1.0
func (m *RangeLogResponse_PrettyInfo) String() string
func (*RangeLogResponse_PrettyInfo) Unmarshal ¶ added in v1.1.0
func (m *RangeLogResponse_PrettyInfo) Unmarshal(dAtA []byte) error
type RangeProblems ¶
type RangeProblems struct { LeaderNotLeaseHolder bool `` /* 126-byte string literal not displayed */ NoRaftLeader bool `protobuf:"varint,3,opt,name=no_raft_leader,json=noRaftLeader,proto3" json:"no_raft_leader,omitempty"` Underreplicated bool `protobuf:"varint,4,opt,name=underreplicated,proto3" json:"underreplicated,omitempty"` NoLease bool `protobuf:"varint,5,opt,name=no_lease,json=noLease,proto3" json:"no_lease,omitempty"` }
func (*RangeProblems) Descriptor ¶
func (*RangeProblems) Descriptor() ([]byte, []int)
func (*RangeProblems) Marshal ¶
func (m *RangeProblems) Marshal() (dAtA []byte, err error)
func (*RangeProblems) ProtoMessage ¶
func (*RangeProblems) ProtoMessage()
func (*RangeProblems) Reset ¶
func (m *RangeProblems) Reset()
func (*RangeProblems) Size ¶
func (m *RangeProblems) Size() (n int)
func (*RangeProblems) String ¶
func (m *RangeProblems) String() string
func (*RangeProblems) Unmarshal ¶
func (m *RangeProblems) Unmarshal(dAtA []byte) error
type RangeRequest ¶ added in v1.1.0
type RangeRequest struct { // figure out how to teach grpc-gateway about custom names. RangeId int64 `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"` }
func (*RangeRequest) Descriptor ¶ added in v1.1.0
func (*RangeRequest) Descriptor() ([]byte, []int)
func (*RangeRequest) Marshal ¶ added in v1.1.0
func (m *RangeRequest) Marshal() (dAtA []byte, err error)
func (*RangeRequest) MarshalTo ¶ added in v1.1.0
func (m *RangeRequest) MarshalTo(dAtA []byte) (int, error)
func (*RangeRequest) ProtoMessage ¶ added in v1.1.0
func (*RangeRequest) ProtoMessage()
func (*RangeRequest) Reset ¶ added in v1.1.0
func (m *RangeRequest) Reset()
func (*RangeRequest) Size ¶ added in v1.1.0
func (m *RangeRequest) Size() (n int)
func (*RangeRequest) String ¶ added in v1.1.0
func (m *RangeRequest) String() string
func (*RangeRequest) Unmarshal ¶ added in v1.1.0
func (m *RangeRequest) Unmarshal(dAtA []byte) error
type RangeResponse ¶ added in v1.1.0
type RangeResponse struct { // NodeID is the node that submitted all the requests. NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */ RangeID github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 145-byte string literal not displayed */ ResponsesByNodeID map[github_com_cockroachdb_cockroach_pkg_roachpb.NodeID]RangeResponse_NodeResponse `` /* 241-byte string literal not displayed */ }
func (*RangeResponse) Descriptor ¶ added in v1.1.0
func (*RangeResponse) Descriptor() ([]byte, []int)
func (*RangeResponse) Marshal ¶ added in v1.1.0
func (m *RangeResponse) Marshal() (dAtA []byte, err error)
func (*RangeResponse) MarshalTo ¶ added in v1.1.0
func (m *RangeResponse) MarshalTo(dAtA []byte) (int, error)
func (*RangeResponse) ProtoMessage ¶ added in v1.1.0
func (*RangeResponse) ProtoMessage()
func (*RangeResponse) Reset ¶ added in v1.1.0
func (m *RangeResponse) Reset()
func (*RangeResponse) Size ¶ added in v1.1.0
func (m *RangeResponse) Size() (n int)
func (*RangeResponse) String ¶ added in v1.1.0
func (m *RangeResponse) String() string
func (*RangeResponse) Unmarshal ¶ added in v1.1.0
func (m *RangeResponse) Unmarshal(dAtA []byte) error
type RangeResponse_NodeResponse ¶ added in v1.1.0
type RangeResponse_NodeResponse struct { Response bool `protobuf:"varint,1,opt,name=response,proto3" json:"response,omitempty"` ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` Infos []RangeInfo `protobuf:"bytes,3,rep,name=infos" json:"infos"` }
func (*RangeResponse_NodeResponse) Descriptor ¶ added in v1.1.0
func (*RangeResponse_NodeResponse) Descriptor() ([]byte, []int)
func (*RangeResponse_NodeResponse) Marshal ¶ added in v1.1.0
func (m *RangeResponse_NodeResponse) Marshal() (dAtA []byte, err error)
func (*RangeResponse_NodeResponse) MarshalTo ¶ added in v1.1.0
func (m *RangeResponse_NodeResponse) MarshalTo(dAtA []byte) (int, error)
func (*RangeResponse_NodeResponse) ProtoMessage ¶ added in v1.1.0
func (*RangeResponse_NodeResponse) ProtoMessage()
func (*RangeResponse_NodeResponse) Reset ¶ added in v1.1.0
func (m *RangeResponse_NodeResponse) Reset()
func (*RangeResponse_NodeResponse) Size ¶ added in v1.1.0
func (m *RangeResponse_NodeResponse) Size() (n int)
func (*RangeResponse_NodeResponse) String ¶ added in v1.1.0
func (m *RangeResponse_NodeResponse) String() string
func (*RangeResponse_NodeResponse) Unmarshal ¶ added in v1.1.0
func (m *RangeResponse_NodeResponse) Unmarshal(dAtA []byte) error
type RangeStatistics ¶ added in v1.1.0
type RangeStatistics struct { // Note that queries per second will only be known by the leaseholder. // All other replicas will report it as 0. QueriesPerSecond float64 `protobuf:"fixed64,1,opt,name=queries_per_second,json=queriesPerSecond,proto3" json:"queries_per_second,omitempty"` WritesPerSecond float64 `protobuf:"fixed64,2,opt,name=writes_per_second,json=writesPerSecond,proto3" json:"writes_per_second,omitempty"` }
func (*RangeStatistics) Descriptor ¶ added in v1.1.0
func (*RangeStatistics) Descriptor() ([]byte, []int)
func (*RangeStatistics) Marshal ¶ added in v1.1.0
func (m *RangeStatistics) Marshal() (dAtA []byte, err error)
func (*RangeStatistics) MarshalTo ¶ added in v1.1.0
func (m *RangeStatistics) MarshalTo(dAtA []byte) (int, error)
func (*RangeStatistics) ProtoMessage ¶ added in v1.1.0
func (*RangeStatistics) ProtoMessage()
func (*RangeStatistics) Reset ¶ added in v1.1.0
func (m *RangeStatistics) Reset()
func (*RangeStatistics) Size ¶ added in v1.1.0
func (m *RangeStatistics) Size() (n int)
func (*RangeStatistics) String ¶ added in v1.1.0
func (m *RangeStatistics) String() string
func (*RangeStatistics) Unmarshal ¶ added in v1.1.0
func (m *RangeStatistics) Unmarshal(dAtA []byte) error
type RangesRequest ¶
type RangesRequest struct { // figure out how to teach grpc-gateway about custom names. // // node_id is a string so that "local" can be used to specify that no // forwarding is necessary. NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` RangeIDs []github_com_cockroachdb_cockroach_pkg_roachpb.RangeID `` /* 148-byte string literal not displayed */ }
func (*RangesRequest) Descriptor ¶
func (*RangesRequest) Descriptor() ([]byte, []int)
func (*RangesRequest) Marshal ¶
func (m *RangesRequest) Marshal() (dAtA []byte, err error)
func (*RangesRequest) ProtoMessage ¶
func (*RangesRequest) ProtoMessage()
func (*RangesRequest) Reset ¶
func (m *RangesRequest) Reset()
func (*RangesRequest) Size ¶
func (m *RangesRequest) Size() (n int)
func (*RangesRequest) String ¶
func (m *RangesRequest) String() string
func (*RangesRequest) Unmarshal ¶
func (m *RangesRequest) Unmarshal(dAtA []byte) error
type RangesResponse ¶
type RangesResponse struct {
Ranges []RangeInfo `protobuf:"bytes,1,rep,name=ranges" json:"ranges"`
}
func (*RangesResponse) Descriptor ¶
func (*RangesResponse) Descriptor() ([]byte, []int)
func (*RangesResponse) Marshal ¶
func (m *RangesResponse) Marshal() (dAtA []byte, err error)
func (*RangesResponse) ProtoMessage ¶
func (*RangesResponse) ProtoMessage()
func (*RangesResponse) Reset ¶
func (m *RangesResponse) Reset()
func (*RangesResponse) Size ¶
func (m *RangesResponse) Size() (n int)
func (*RangesResponse) String ¶
func (m *RangesResponse) String() string
func (*RangesResponse) Unmarshal ¶
func (m *RangesResponse) Unmarshal(dAtA []byte) error
type Session ¶ added in v1.1.0
type Session struct { // ID of node where this session exists. NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `` /* 141-byte string literal not displayed */ // Username of the user for this session. Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` // Connected client's IP address and port. ClientAddress string `protobuf:"bytes,3,opt,name=client_address,json=clientAddress,proto3" json:"client_address,omitempty"` // Application name specified by the client. ApplicationName string `protobuf:"bytes,4,opt,name=application_name,json=applicationName,proto3" json:"application_name,omitempty"` // Queries in progress on this session. ActiveQueries []ActiveQuery `protobuf:"bytes,5,rep,name=active_queries,json=activeQueries" json:"active_queries"` // Timestamp of session's start. Start time.Time `protobuf:"bytes,6,opt,name=start,stdtime" json:"start"` // ID of the current KV transaction for this session. Nil if the session // doesn't currently have a transaction. KvTxnID *github_com_cockroachdb_cockroach_pkg_util_uuid.UUID `` /* 147-byte string literal not displayed */ // SQL string of the last query executed on this session. LastActiveQuery string `protobuf:"bytes,8,opt,name=last_active_query,json=lastActiveQuery,proto3" json:"last_active_query,omitempty"` }
Session represents one SQL session.
func (*Session) Descriptor ¶ added in v1.1.0
func (*Session) ProtoMessage ¶ added in v1.1.0
func (*Session) ProtoMessage()
type SessionCookie ¶ added in v1.1.0
type SessionCookie struct { // The unique ID of the session. ID int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // The secret needed to verify ownership of a session. Secret []byte `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"` }
SessionCookie is a message used to encode the authentication cookie returned from successful login requests.
func (*SessionCookie) Descriptor ¶ added in v1.1.0
func (*SessionCookie) Descriptor() ([]byte, []int)
func (*SessionCookie) Marshal ¶ added in v1.1.0
func (m *SessionCookie) Marshal() (dAtA []byte, err error)
func (*SessionCookie) MarshalTo ¶ added in v1.1.0
func (m *SessionCookie) MarshalTo(dAtA []byte) (int, error)
func (*SessionCookie) ProtoMessage ¶ added in v1.1.0
func (*SessionCookie) ProtoMessage()
func (*SessionCookie) Reset ¶ added in v1.1.0
func (m *SessionCookie) Reset()
func (*SessionCookie) Size ¶ added in v1.1.0
func (m *SessionCookie) Size() (n int)
func (*SessionCookie) String ¶ added in v1.1.0
func (m *SessionCookie) String() string
func (*SessionCookie) Unmarshal ¶ added in v1.1.0
func (m *SessionCookie) Unmarshal(dAtA []byte) error
type SetUIDataRequest ¶
type SetUIDataRequest struct { // key_values is a map of keys to bytes values. Each key will be stored // with its corresponding value as a separate row in system.ui. KeyValues map[string][]byte `` /* 169-byte string literal not displayed */ }
SetUIDataRequest stores the given key/value pairs in the system.ui table.
func (*SetUIDataRequest) Descriptor ¶
func (*SetUIDataRequest) Descriptor() ([]byte, []int)
func (*SetUIDataRequest) Marshal ¶
func (m *SetUIDataRequest) Marshal() (dAtA []byte, err error)
func (*SetUIDataRequest) ProtoMessage ¶
func (*SetUIDataRequest) ProtoMessage()
func (*SetUIDataRequest) Reset ¶
func (m *SetUIDataRequest) Reset()
func (*SetUIDataRequest) Size ¶
func (m *SetUIDataRequest) Size() (n int)
func (*SetUIDataRequest) String ¶
func (m *SetUIDataRequest) String() string
func (*SetUIDataRequest) Unmarshal ¶
func (m *SetUIDataRequest) Unmarshal(dAtA []byte) error
type SetUIDataResponse ¶
type SetUIDataResponse struct { }
SetUIDataResponse is currently an empty response.
func (*SetUIDataResponse) Descriptor ¶
func (*SetUIDataResponse) Descriptor() ([]byte, []int)
func (*SetUIDataResponse) Marshal ¶
func (m *SetUIDataResponse) Marshal() (dAtA []byte, err error)
func (*SetUIDataResponse) MarshalTo ¶
func (m *SetUIDataResponse) MarshalTo(dAtA []byte) (int, error)
func (*SetUIDataResponse) ProtoMessage ¶
func (*SetUIDataResponse) ProtoMessage()
func (*SetUIDataResponse) Reset ¶
func (m *SetUIDataResponse) Reset()
func (*SetUIDataResponse) Size ¶
func (m *SetUIDataResponse) Size() (n int)
func (*SetUIDataResponse) String ¶
func (m *SetUIDataResponse) String() string
func (*SetUIDataResponse) Unmarshal ¶
func (m *SetUIDataResponse) Unmarshal(dAtA []byte) error
type SettingsRequest ¶
type SettingsRequest struct { // The array of setting names to retrieve. // An empty keys array means "all". Keys []string `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"` }
SettingsRequest inquires what are the current settings in the cluster.
func (*SettingsRequest) Descriptor ¶
func (*SettingsRequest) Descriptor() ([]byte, []int)
func (*SettingsRequest) Marshal ¶
func (m *SettingsRequest) Marshal() (dAtA []byte, err error)
func (*SettingsRequest) ProtoMessage ¶
func (*SettingsRequest) ProtoMessage()
func (*SettingsRequest) Reset ¶
func (m *SettingsRequest) Reset()
func (*SettingsRequest) Size ¶
func (m *SettingsRequest) Size() (n int)
func (*SettingsRequest) String ¶
func (m *SettingsRequest) String() string
func (*SettingsRequest) Unmarshal ¶
func (m *SettingsRequest) Unmarshal(dAtA []byte) error
type SettingsResponse ¶
type SettingsResponse struct {
KeyValues map[string]SettingsResponse_Value `` /* 152-byte string literal not displayed */
}
SettingsResponse is the response to SettingsRequest.
func (*SettingsResponse) Descriptor ¶
func (*SettingsResponse) Descriptor() ([]byte, []int)
func (*SettingsResponse) Marshal ¶
func (m *SettingsResponse) Marshal() (dAtA []byte, err error)
func (*SettingsResponse) ProtoMessage ¶
func (*SettingsResponse) ProtoMessage()
func (*SettingsResponse) Reset ¶
func (m *SettingsResponse) Reset()
func (*SettingsResponse) Size ¶
func (m *SettingsResponse) Size() (n int)
func (*SettingsResponse) String ¶
func (m *SettingsResponse) String() string
func (*SettingsResponse) Unmarshal ¶
func (m *SettingsResponse) Unmarshal(dAtA []byte) error
type SettingsResponse_Value ¶
type SettingsResponse_Value struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` }
func (*SettingsResponse_Value) Descriptor ¶
func (*SettingsResponse_Value) Descriptor() ([]byte, []int)
func (*SettingsResponse_Value) Marshal ¶
func (m *SettingsResponse_Value) Marshal() (dAtA []byte, err error)
func (*SettingsResponse_Value) MarshalTo ¶
func (m *SettingsResponse_Value) MarshalTo(dAtA []byte) (int, error)
func (*SettingsResponse_Value) ProtoMessage ¶
func (*SettingsResponse_Value) ProtoMessage()
func (*SettingsResponse_Value) Reset ¶
func (m *SettingsResponse_Value) Reset()
func (*SettingsResponse_Value) Size ¶
func (m *SettingsResponse_Value) Size() (n int)
func (*SettingsResponse_Value) String ¶
func (m *SettingsResponse_Value) String() string
func (*SettingsResponse_Value) Unmarshal ¶
func (m *SettingsResponse_Value) Unmarshal(dAtA []byte) error
type SpanStatsRequest ¶
type SpanStatsRequest struct { NodeID string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` StartKey github_com_cockroachdb_cockroach_pkg_roachpb.RKey `` /* 144-byte string literal not displayed */ EndKey github_com_cockroachdb_cockroach_pkg_roachpb.RKey `` /* 138-byte string literal not displayed */ }
func (*SpanStatsRequest) Descriptor ¶
func (*SpanStatsRequest) Descriptor() ([]byte, []int)
func (*SpanStatsRequest) Marshal ¶
func (m *SpanStatsRequest) Marshal() (dAtA []byte, err error)
func (*SpanStatsRequest) ProtoMessage ¶
func (*SpanStatsRequest) ProtoMessage()
func (*SpanStatsRequest) Reset ¶
func (m *SpanStatsRequest) Reset()
func (*SpanStatsRequest) Size ¶
func (m *SpanStatsRequest) Size() (n int)
func (*SpanStatsRequest) String ¶
func (m *SpanStatsRequest) String() string
func (*SpanStatsRequest) Unmarshal ¶
func (m *SpanStatsRequest) Unmarshal(dAtA []byte) error
type SpanStatsResponse ¶
type SpanStatsResponse struct { RangeCount int32 `protobuf:"varint,2,opt,name=range_count,json=rangeCount,proto3" json:"range_count,omitempty"` TotalStats cockroach_storage_engine_enginepb.MVCCStats `protobuf:"bytes,1,opt,name=total_stats,json=totalStats" json:"total_stats"` }
func (*SpanStatsResponse) Descriptor ¶
func (*SpanStatsResponse) Descriptor() ([]byte, []int)
func (*SpanStatsResponse) Marshal ¶
func (m *SpanStatsResponse) Marshal() (dAtA []byte, err error)
func (*SpanStatsResponse) MarshalTo ¶
func (m *SpanStatsResponse) MarshalTo(dAtA []byte) (int, error)
func (*SpanStatsResponse) ProtoMessage ¶
func (*SpanStatsResponse) ProtoMessage()
func (*SpanStatsResponse) Reset ¶
func (m *SpanStatsResponse) Reset()
func (*SpanStatsResponse) Size ¶
func (m *SpanStatsResponse) Size() (n int)
func (*SpanStatsResponse) String ¶
func (m *SpanStatsResponse) String() string
func (*SpanStatsResponse) Unmarshal ¶
func (m *SpanStatsResponse) Unmarshal(dAtA []byte) error
type StacksRequest ¶
type StacksRequest struct { // figure out how to teach grpc-gateway about custom names. // // node_id is a string so that "local" can be used to specify that no // forwarding is necessary. NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` }
func (*StacksRequest) Descriptor ¶
func (*StacksRequest) Descriptor() ([]byte, []int)
func (*StacksRequest) Marshal ¶
func (m *StacksRequest) Marshal() (dAtA []byte, err error)
func (*StacksRequest) ProtoMessage ¶
func (*StacksRequest) ProtoMessage()
func (*StacksRequest) Reset ¶
func (m *StacksRequest) Reset()
func (*StacksRequest) Size ¶
func (m *StacksRequest) Size() (n int)
func (*StacksRequest) String ¶
func (m *StacksRequest) String() string
func (*StacksRequest) Unmarshal ¶
func (m *StacksRequest) Unmarshal(dAtA []byte) error
type StatusClient ¶
type StatusClient interface { Certificates(ctx context.Context, in *CertificatesRequest, opts ...grpc.CallOption) (*CertificatesResponse, error) Details(ctx context.Context, in *DetailsRequest, opts ...grpc.CallOption) (*DetailsResponse, error) Nodes(ctx context.Context, in *NodesRequest, opts ...grpc.CallOption) (*NodesResponse, error) Node(ctx context.Context, in *NodeRequest, opts ...grpc.CallOption) (*cockroach_server_status.NodeStatus, error) RaftDebug(ctx context.Context, in *RaftDebugRequest, opts ...grpc.CallOption) (*RaftDebugResponse, error) Ranges(ctx context.Context, in *RangesRequest, opts ...grpc.CallOption) (*RangesResponse, error) Gossip(ctx context.Context, in *GossipRequest, opts ...grpc.CallOption) (*cockroach_gossip.InfoStatus, error) Allocator(ctx context.Context, in *AllocatorRequest, opts ...grpc.CallOption) (*AllocatorResponse, error) AllocatorRange(ctx context.Context, in *AllocatorRangeRequest, opts ...grpc.CallOption) (*AllocatorRangeResponse, error) ListSessions(ctx context.Context, in *ListSessionsRequest, opts ...grpc.CallOption) (*ListSessionsResponse, error) ListLocalSessions(ctx context.Context, in *ListSessionsRequest, opts ...grpc.CallOption) (*ListSessionsResponse, error) CancelQuery(ctx context.Context, in *CancelQueryRequest, opts ...grpc.CallOption) (*CancelQueryResponse, error) // SpanStats accepts a key span and node ID, and returns a set of stats // summed from all ranges on the stores on that node which contain keys // in that span. This is designed to compute stats specific to a SQL table: // it will be called with the highest/lowest key for a SQL table, and return // information about the resources on a node used by that table. SpanStats(ctx context.Context, in *SpanStatsRequest, opts ...grpc.CallOption) (*SpanStatsResponse, error) Stacks(ctx context.Context, in *StacksRequest, opts ...grpc.CallOption) (*JSONResponse, error) Metrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*JSONResponse, error) LogFilesList(ctx context.Context, in *LogFilesListRequest, opts ...grpc.CallOption) (*LogFilesListResponse, error) LogFile(ctx context.Context, in *LogFileRequest, opts ...grpc.CallOption) (*LogEntriesResponse, error) Logs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (*LogEntriesResponse, error) ProblemRanges(ctx context.Context, in *ProblemRangesRequest, opts ...grpc.CallOption) (*ProblemRangesResponse, error) Range(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error) }
func NewStatusClient ¶
func NewStatusClient(cc *grpc.ClientConn) StatusClient
type StatusServer ¶
type StatusServer interface { Certificates(context.Context, *CertificatesRequest) (*CertificatesResponse, error) Details(context.Context, *DetailsRequest) (*DetailsResponse, error) Nodes(context.Context, *NodesRequest) (*NodesResponse, error) Node(context.Context, *NodeRequest) (*cockroach_server_status.NodeStatus, error) RaftDebug(context.Context, *RaftDebugRequest) (*RaftDebugResponse, error) Ranges(context.Context, *RangesRequest) (*RangesResponse, error) Gossip(context.Context, *GossipRequest) (*cockroach_gossip.InfoStatus, error) Allocator(context.Context, *AllocatorRequest) (*AllocatorResponse, error) AllocatorRange(context.Context, *AllocatorRangeRequest) (*AllocatorRangeResponse, error) ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error) ListLocalSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error) CancelQuery(context.Context, *CancelQueryRequest) (*CancelQueryResponse, error) // SpanStats accepts a key span and node ID, and returns a set of stats // summed from all ranges on the stores on that node which contain keys // in that span. This is designed to compute stats specific to a SQL table: // it will be called with the highest/lowest key for a SQL table, and return // information about the resources on a node used by that table. SpanStats(context.Context, *SpanStatsRequest) (*SpanStatsResponse, error) Stacks(context.Context, *StacksRequest) (*JSONResponse, error) Metrics(context.Context, *MetricsRequest) (*JSONResponse, error) LogFilesList(context.Context, *LogFilesListRequest) (*LogFilesListResponse, error) LogFile(context.Context, *LogFileRequest) (*LogEntriesResponse, error) Logs(context.Context, *LogsRequest) (*LogEntriesResponse, error) ProblemRanges(context.Context, *ProblemRangesRequest) (*ProblemRangesResponse, error) Range(context.Context, *RangeRequest) (*RangeResponse, error) }
type TableDetailsRequest ¶
type TableDetailsRequest struct { // database is the database that contains the table we're interested in. Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` // table is the name of the table that we're querying. Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"` }
TableDetailsRequest is a request for detailed information about a table.
func (*TableDetailsRequest) Descriptor ¶
func (*TableDetailsRequest) Descriptor() ([]byte, []int)
func (*TableDetailsRequest) Marshal ¶
func (m *TableDetailsRequest) Marshal() (dAtA []byte, err error)
func (*TableDetailsRequest) MarshalTo ¶
func (m *TableDetailsRequest) MarshalTo(dAtA []byte) (int, error)
func (*TableDetailsRequest) ProtoMessage ¶
func (*TableDetailsRequest) ProtoMessage()
func (*TableDetailsRequest) Reset ¶
func (m *TableDetailsRequest) Reset()
func (*TableDetailsRequest) Size ¶
func (m *TableDetailsRequest) Size() (n int)
func (*TableDetailsRequest) String ¶
func (m *TableDetailsRequest) String() string
func (*TableDetailsRequest) Unmarshal ¶
func (m *TableDetailsRequest) Unmarshal(dAtA []byte) error
type TableDetailsResponse ¶
type TableDetailsResponse struct { Grants []TableDetailsResponse_Grant `protobuf:"bytes,1,rep,name=grants" json:"grants"` Columns []TableDetailsResponse_Column `protobuf:"bytes,2,rep,name=columns" json:"columns"` Indexes []TableDetailsResponse_Index `protobuf:"bytes,3,rep,name=indexes" json:"indexes"` // range_count is the size of the table in ranges. This provides a rough // estimate of the storage requirements for the table. // TODO(mrtracy): The TableStats method also returns a range_count field which // is more accurate than this one; TableDetails calculates this number using // a potentially faster method that is subject to cache staleness. We should // consider removing or renaming this field to reflect that difference. See // Github issue #5435 for more information. RangeCount int64 `protobuf:"varint,4,opt,name=range_count,json=rangeCount,proto3" json:"range_count,omitempty"` // create_table_statement is the output of "SHOW CREATE TABLE" for this table; // it is a SQL statement that would re-create the table's current schema if // executed. CreateTableStatement string `protobuf:"bytes,5,opt,name=create_table_statement,json=createTableStatement,proto3" json:"create_table_statement,omitempty"` // The zone configuration in effect for this table. ZoneConfig cockroach_config.ZoneConfig `protobuf:"bytes,6,opt,name=zone_config,json=zoneConfig" json:"zone_config"` // The level at which this object's zone configuration is set. ZoneConfigLevel ZoneConfigurationLevel `` /* 163-byte string literal not displayed */ // descriptor_id is an identifier used to uniquely identify this table. // It can be used to find events pertaining to this table by filtering on // the 'target_id' field of events. DescriptorID int64 `protobuf:"varint,8,opt,name=descriptor_id,json=descriptorId,proto3" json:"descriptor_id,omitempty"` }
TableDetailsResponse contains grants, column names, and indexes for a table.
func (*TableDetailsResponse) Descriptor ¶
func (*TableDetailsResponse) Descriptor() ([]byte, []int)
func (*TableDetailsResponse) Marshal ¶
func (m *TableDetailsResponse) Marshal() (dAtA []byte, err error)
func (*TableDetailsResponse) MarshalTo ¶
func (m *TableDetailsResponse) MarshalTo(dAtA []byte) (int, error)
func (*TableDetailsResponse) ProtoMessage ¶
func (*TableDetailsResponse) ProtoMessage()
func (*TableDetailsResponse) Reset ¶
func (m *TableDetailsResponse) Reset()
func (*TableDetailsResponse) Size ¶
func (m *TableDetailsResponse) Size() (n int)
func (*TableDetailsResponse) String ¶
func (m *TableDetailsResponse) String() string
func (*TableDetailsResponse) Unmarshal ¶
func (m *TableDetailsResponse) Unmarshal(dAtA []byte) error
type TableDetailsResponse_Column ¶
type TableDetailsResponse_Column struct { // name is the name of the column. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // type is the SQL type (INT, STRING, etc.) of this column. Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // nullable is whether this column can contain NULL. Nullable bool `protobuf:"varint,3,opt,name=nullable,proto3" json:"nullable,omitempty"` // default_value is the default value of this column. DefaultValue string `protobuf:"bytes,4,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"` }
func (*TableDetailsResponse_Column) Descriptor ¶
func (*TableDetailsResponse_Column) Descriptor() ([]byte, []int)
func (*TableDetailsResponse_Column) Marshal ¶
func (m *TableDetailsResponse_Column) Marshal() (dAtA []byte, err error)
func (*TableDetailsResponse_Column) MarshalTo ¶
func (m *TableDetailsResponse_Column) MarshalTo(dAtA []byte) (int, error)
func (*TableDetailsResponse_Column) ProtoMessage ¶
func (*TableDetailsResponse_Column) ProtoMessage()
func (*TableDetailsResponse_Column) Reset ¶
func (m *TableDetailsResponse_Column) Reset()
func (*TableDetailsResponse_Column) Size ¶
func (m *TableDetailsResponse_Column) Size() (n int)
func (*TableDetailsResponse_Column) String ¶
func (m *TableDetailsResponse_Column) String() string
func (*TableDetailsResponse_Column) Unmarshal ¶
func (m *TableDetailsResponse_Column) Unmarshal(dAtA []byte) error
type TableDetailsResponse_Grant ¶
type TableDetailsResponse_Grant struct { // user is the user that this grant applies to. User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // privileges are the abilities this grant gives to the user. Privileges []string `protobuf:"bytes,2,rep,name=privileges" json:"privileges,omitempty"` }
Grant is an entry from SHOW GRANTS.
func (*TableDetailsResponse_Grant) Descriptor ¶
func (*TableDetailsResponse_Grant) Descriptor() ([]byte, []int)
func (*TableDetailsResponse_Grant) Marshal ¶
func (m *TableDetailsResponse_Grant) Marshal() (dAtA []byte, err error)
func (*TableDetailsResponse_Grant) MarshalTo ¶
func (m *TableDetailsResponse_Grant) MarshalTo(dAtA []byte) (int, error)
func (*TableDetailsResponse_Grant) ProtoMessage ¶
func (*TableDetailsResponse_Grant) ProtoMessage()
func (*TableDetailsResponse_Grant) Reset ¶
func (m *TableDetailsResponse_Grant) Reset()
func (*TableDetailsResponse_Grant) Size ¶
func (m *TableDetailsResponse_Grant) Size() (n int)
func (*TableDetailsResponse_Grant) String ¶
func (m *TableDetailsResponse_Grant) String() string
func (*TableDetailsResponse_Grant) Unmarshal ¶
func (m *TableDetailsResponse_Grant) Unmarshal(dAtA []byte) error
type TableDetailsResponse_Index ¶
type TableDetailsResponse_Index struct { // name is the name of this index. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // unique is whether this a unique index (i.e. CREATE UNIQUE INDEX). Unique bool `protobuf:"varint,2,opt,name=unique,proto3" json:"unique,omitempty"` // seq is an internal variable that's passed along. Seq int64 `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"` // column is the column that this index indexes. Column string `protobuf:"bytes,4,opt,name=column,proto3" json:"column,omitempty"` // direction is either "ASC" (ascending) or "DESC" (descending). Direction string `protobuf:"bytes,5,opt,name=direction,proto3" json:"direction,omitempty"` // storing is an internal variable that's passed along. Storing bool `protobuf:"varint,6,opt,name=storing,proto3" json:"storing,omitempty"` // implicit is an internal variable that's passed along. Implicit bool `protobuf:"varint,7,opt,name=implicit,proto3" json:"implicit,omitempty"` }
func (*TableDetailsResponse_Index) Descriptor ¶
func (*TableDetailsResponse_Index) Descriptor() ([]byte, []int)
func (*TableDetailsResponse_Index) Marshal ¶
func (m *TableDetailsResponse_Index) Marshal() (dAtA []byte, err error)
func (*TableDetailsResponse_Index) MarshalTo ¶
func (m *TableDetailsResponse_Index) MarshalTo(dAtA []byte) (int, error)
func (*TableDetailsResponse_Index) ProtoMessage ¶
func (*TableDetailsResponse_Index) ProtoMessage()
func (*TableDetailsResponse_Index) Reset ¶
func (m *TableDetailsResponse_Index) Reset()
func (*TableDetailsResponse_Index) Size ¶
func (m *TableDetailsResponse_Index) Size() (n int)
func (*TableDetailsResponse_Index) String ¶
func (m *TableDetailsResponse_Index) String() string
func (*TableDetailsResponse_Index) Unmarshal ¶
func (m *TableDetailsResponse_Index) Unmarshal(dAtA []byte) error
type TableStatsRequest ¶
type TableStatsRequest struct { // database is the database that contains the table we're interested in. Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` // table is the name of the table that we're querying. Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"` }
TableStatsRequest is a request for detailed, computationally expensive information about a table.
func (*TableStatsRequest) Descriptor ¶
func (*TableStatsRequest) Descriptor() ([]byte, []int)
func (*TableStatsRequest) Marshal ¶
func (m *TableStatsRequest) Marshal() (dAtA []byte, err error)
func (*TableStatsRequest) MarshalTo ¶
func (m *TableStatsRequest) MarshalTo(dAtA []byte) (int, error)
func (*TableStatsRequest) ProtoMessage ¶
func (*TableStatsRequest) ProtoMessage()
func (*TableStatsRequest) Reset ¶
func (m *TableStatsRequest) Reset()
func (*TableStatsRequest) Size ¶
func (m *TableStatsRequest) Size() (n int)
func (*TableStatsRequest) String ¶
func (m *TableStatsRequest) String() string
func (*TableStatsRequest) Unmarshal ¶
func (m *TableStatsRequest) Unmarshal(dAtA []byte) error
type TableStatsResponse ¶
type TableStatsResponse struct { // range_count is the number of ranges, as determined from a query of range // meta keys. RangeCount int64 `protobuf:"varint,1,opt,name=range_count,json=rangeCount,proto3" json:"range_count,omitempty"` // replica_count is the number of replicas of any range of this table, as // found by querying nodes which are known to have replicas. When compared // with range_count, this can be used to estimate the current replication // factor of the table. ReplicaCount int64 `protobuf:"varint,2,opt,name=replica_count,json=replicaCount,proto3" json:"replica_count,omitempty"` // node_count is the number of nodes which contain data for this table, // according to a query of range meta keys. NodeCount int64 `protobuf:"varint,3,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"` // stats is the summation of MVCCStats for all replicas of this table // across the cluster. Stats cockroach_storage_engine_enginepb.MVCCStats `protobuf:"bytes,4,opt,name=stats" json:"stats"` // A list of nodes which should contain data for this table (according to // cluster metadata), but could not be contacted during this request. MissingNodes []TableStatsResponse_MissingNode `protobuf:"bytes,5,rep,name=missing_nodes,json=missingNodes" json:"missing_nodes"` }
TableStatsResponse contains detailed, computationally expensive information about a table.
func (*TableStatsResponse) Descriptor ¶
func (*TableStatsResponse) Descriptor() ([]byte, []int)
func (*TableStatsResponse) Marshal ¶
func (m *TableStatsResponse) Marshal() (dAtA []byte, err error)
func (*TableStatsResponse) MarshalTo ¶
func (m *TableStatsResponse) MarshalTo(dAtA []byte) (int, error)
func (*TableStatsResponse) ProtoMessage ¶
func (*TableStatsResponse) ProtoMessage()
func (*TableStatsResponse) Reset ¶
func (m *TableStatsResponse) Reset()
func (*TableStatsResponse) Size ¶
func (m *TableStatsResponse) Size() (n int)
func (*TableStatsResponse) String ¶
func (m *TableStatsResponse) String() string
func (*TableStatsResponse) Unmarshal ¶
func (m *TableStatsResponse) Unmarshal(dAtA []byte) error
type TableStatsResponse_MissingNode ¶
type TableStatsResponse_MissingNode struct { // The ID of the missing node. NodeID string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // The error message that resulted when the query sent to this node failed. ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` }
MissingNode represents information on a node which should contain data for this table, but could not be contacted during this request.
func (*TableStatsResponse_MissingNode) Descriptor ¶
func (*TableStatsResponse_MissingNode) Descriptor() ([]byte, []int)
func (*TableStatsResponse_MissingNode) Marshal ¶
func (m *TableStatsResponse_MissingNode) Marshal() (dAtA []byte, err error)
func (*TableStatsResponse_MissingNode) MarshalTo ¶
func (m *TableStatsResponse_MissingNode) MarshalTo(dAtA []byte) (int, error)
func (*TableStatsResponse_MissingNode) ProtoMessage ¶
func (*TableStatsResponse_MissingNode) ProtoMessage()
func (*TableStatsResponse_MissingNode) Reset ¶
func (m *TableStatsResponse_MissingNode) Reset()
func (*TableStatsResponse_MissingNode) Size ¶
func (m *TableStatsResponse_MissingNode) Size() (n int)
func (*TableStatsResponse_MissingNode) String ¶
func (m *TableStatsResponse_MissingNode) String() string
func (*TableStatsResponse_MissingNode) Unmarshal ¶
func (m *TableStatsResponse_MissingNode) Unmarshal(dAtA []byte) error
type UserLoginRequest ¶ added in v1.1.0
type UserLoginRequest struct { // A username which must correspond to a database user on the cluster. Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` // A password for the provided username. Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` }
UserLoginRequest contains credentials a user must provide to log in.
func (*UserLoginRequest) Descriptor ¶ added in v1.1.0
func (*UserLoginRequest) Descriptor() ([]byte, []int)
func (*UserLoginRequest) Marshal ¶ added in v1.1.0
func (m *UserLoginRequest) Marshal() (dAtA []byte, err error)
func (*UserLoginRequest) MarshalTo ¶ added in v1.1.0
func (m *UserLoginRequest) MarshalTo(dAtA []byte) (int, error)
func (*UserLoginRequest) ProtoMessage ¶ added in v1.1.0
func (*UserLoginRequest) ProtoMessage()
func (*UserLoginRequest) Reset ¶ added in v1.1.0
func (m *UserLoginRequest) Reset()
func (*UserLoginRequest) Size ¶ added in v1.1.0
func (m *UserLoginRequest) Size() (n int)
func (*UserLoginRequest) String ¶ added in v1.1.0
func (m *UserLoginRequest) String() string
func (*UserLoginRequest) Unmarshal ¶ added in v1.1.0
func (m *UserLoginRequest) Unmarshal(dAtA []byte) error
type UserLoginResponse ¶ added in v1.1.0
type UserLoginResponse struct { }
UserLoginResponse is currently empty. If a login is successful, an HTTP Set-Cookie header will be added to the response with a session cookie identifying the created session.
func (*UserLoginResponse) Descriptor ¶ added in v1.1.0
func (*UserLoginResponse) Descriptor() ([]byte, []int)
func (*UserLoginResponse) Marshal ¶ added in v1.1.0
func (m *UserLoginResponse) Marshal() (dAtA []byte, err error)
func (*UserLoginResponse) MarshalTo ¶ added in v1.1.0
func (m *UserLoginResponse) MarshalTo(dAtA []byte) (int, error)
func (*UserLoginResponse) ProtoMessage ¶ added in v1.1.0
func (*UserLoginResponse) ProtoMessage()
func (*UserLoginResponse) Reset ¶ added in v1.1.0
func (m *UserLoginResponse) Reset()
func (*UserLoginResponse) Size ¶ added in v1.1.0
func (m *UserLoginResponse) Size() (n int)
func (*UserLoginResponse) String ¶ added in v1.1.0
func (m *UserLoginResponse) String() string
func (*UserLoginResponse) Unmarshal ¶ added in v1.1.0
func (m *UserLoginResponse) Unmarshal(dAtA []byte) error
type UserLogoutRequest ¶ added in v1.1.0
type UserLogoutRequest struct { }
UserLogoutRequest will terminate the current session in use. The request is empty because the current session is identified by an HTTP cookie on the incoming request.
func (*UserLogoutRequest) Descriptor ¶ added in v1.1.0
func (*UserLogoutRequest) Descriptor() ([]byte, []int)
func (*UserLogoutRequest) Marshal ¶ added in v1.1.0
func (m *UserLogoutRequest) Marshal() (dAtA []byte, err error)
func (*UserLogoutRequest) MarshalTo ¶ added in v1.1.0
func (m *UserLogoutRequest) MarshalTo(dAtA []byte) (int, error)
func (*UserLogoutRequest) ProtoMessage ¶ added in v1.1.0
func (*UserLogoutRequest) ProtoMessage()
func (*UserLogoutRequest) Reset ¶ added in v1.1.0
func (m *UserLogoutRequest) Reset()
func (*UserLogoutRequest) Size ¶ added in v1.1.0
func (m *UserLogoutRequest) Size() (n int)
func (*UserLogoutRequest) String ¶ added in v1.1.0
func (m *UserLogoutRequest) String() string
func (*UserLogoutRequest) Unmarshal ¶ added in v1.1.0
func (m *UserLogoutRequest) Unmarshal(dAtA []byte) error
type UserLogoutResponse ¶ added in v1.1.0
type UserLogoutResponse struct { }
func (*UserLogoutResponse) Descriptor ¶ added in v1.1.0
func (*UserLogoutResponse) Descriptor() ([]byte, []int)
func (*UserLogoutResponse) Marshal ¶ added in v1.1.0
func (m *UserLogoutResponse) Marshal() (dAtA []byte, err error)
func (*UserLogoutResponse) MarshalTo ¶ added in v1.1.0
func (m *UserLogoutResponse) MarshalTo(dAtA []byte) (int, error)
func (*UserLogoutResponse) ProtoMessage ¶ added in v1.1.0
func (*UserLogoutResponse) ProtoMessage()
func (*UserLogoutResponse) Reset ¶ added in v1.1.0
func (m *UserLogoutResponse) Reset()
func (*UserLogoutResponse) Size ¶ added in v1.1.0
func (m *UserLogoutResponse) Size() (n int)
func (*UserLogoutResponse) String ¶ added in v1.1.0
func (m *UserLogoutResponse) String() string
func (*UserLogoutResponse) Unmarshal ¶ added in v1.1.0
func (m *UserLogoutResponse) Unmarshal(dAtA []byte) error
type UsersRequest ¶
type UsersRequest struct { }
UsersRequest requests a list of users.
func (*UsersRequest) Descriptor ¶
func (*UsersRequest) Descriptor() ([]byte, []int)
func (*UsersRequest) Marshal ¶
func (m *UsersRequest) Marshal() (dAtA []byte, err error)
func (*UsersRequest) ProtoMessage ¶
func (*UsersRequest) ProtoMessage()
func (*UsersRequest) Reset ¶
func (m *UsersRequest) Reset()
func (*UsersRequest) Size ¶
func (m *UsersRequest) Size() (n int)
func (*UsersRequest) String ¶
func (m *UsersRequest) String() string
func (*UsersRequest) Unmarshal ¶
func (m *UsersRequest) Unmarshal(dAtA []byte) error
type UsersResponse ¶
type UsersResponse struct { // usernames is a list of users for the CockroachDB cluster. Users []UsersResponse_User `protobuf:"bytes,1,rep,name=users" json:"users"` }
UsersResponse returns a list of users.
func (*UsersResponse) Descriptor ¶
func (*UsersResponse) Descriptor() ([]byte, []int)
func (*UsersResponse) Marshal ¶
func (m *UsersResponse) Marshal() (dAtA []byte, err error)
func (*UsersResponse) ProtoMessage ¶
func (*UsersResponse) ProtoMessage()
func (*UsersResponse) Reset ¶
func (m *UsersResponse) Reset()
func (*UsersResponse) Size ¶
func (m *UsersResponse) Size() (n int)
func (*UsersResponse) String ¶
func (m *UsersResponse) String() string
func (*UsersResponse) Unmarshal ¶
func (m *UsersResponse) Unmarshal(dAtA []byte) error
type UsersResponse_User ¶
type UsersResponse_User struct {
Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
}
User is a CockroachDB user.
func (*UsersResponse_User) Descriptor ¶
func (*UsersResponse_User) Descriptor() ([]byte, []int)
func (*UsersResponse_User) Marshal ¶
func (m *UsersResponse_User) Marshal() (dAtA []byte, err error)
func (*UsersResponse_User) MarshalTo ¶
func (m *UsersResponse_User) MarshalTo(dAtA []byte) (int, error)
func (*UsersResponse_User) ProtoMessage ¶
func (*UsersResponse_User) ProtoMessage()
func (*UsersResponse_User) Reset ¶
func (m *UsersResponse_User) Reset()
func (*UsersResponse_User) Size ¶
func (m *UsersResponse_User) Size() (n int)
func (*UsersResponse_User) String ¶
func (m *UsersResponse_User) String() string
func (*UsersResponse_User) Unmarshal ¶
func (m *UsersResponse_User) Unmarshal(dAtA []byte) error
type ZoneConfigurationLevel ¶
type ZoneConfigurationLevel int32
ZoneConfigurationLevel indicates, for objects with a Zone Configuration, the object level at which the configuration is defined. This is needed because objects without a specifically indicated Zone Configuration will inherit the configuration of their "parent".
const ( ZoneConfigurationLevel_UNKNOWN ZoneConfigurationLevel = 0 // CLUSTER indicates that this object uses the cluster default Zone Configuration. ZoneConfigurationLevel_CLUSTER ZoneConfigurationLevel = 1 // DATABASE indicates that this object uses a database-level Zone Configuration. ZoneConfigurationLevel_DATABASE ZoneConfigurationLevel = 2 // TABLE indicates that this object uses a table-level Zone Configuration. ZoneConfigurationLevel_TABLE ZoneConfigurationLevel = 3 )
func (ZoneConfigurationLevel) EnumDescriptor ¶
func (ZoneConfigurationLevel) EnumDescriptor() ([]byte, []int)
func (ZoneConfigurationLevel) String ¶
func (x ZoneConfigurationLevel) String() string