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

package serverpb

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

Package serverpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package serverpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package serverpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Package Files

admin.go admin.pb.go admin.pb.gw.go authentication.pb.go authentication.pb.gw.go init.pb.go status.go status.pb.go status.pb.gw.go

Variables

var (
    ErrInvalidLengthAdmin = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowAdmin   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthAuthentication = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowAuthentication   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthInit = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowInit   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthStatus = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowStatus   = fmt.Errorf("proto: integer overflow")
)
var ActiveQuery_Phase_name = map[int32]string{
    0:  "PREPARING",
    1:  "EXECUTING",
}
var ActiveQuery_Phase_value = map[string]int32{
    "PREPARING": 0,
    "EXECUTING": 1,
}
var CertificateDetails_CertificateType_name = map[int32]string{
    0:  "CA",
    1:  "NODE",
    2:  "CLIENT_CA",
    3:  "CLIENT",
    4:  "UI_CA",
    5:  "UI",
}
var CertificateDetails_CertificateType_value = map[string]int32{
    "CA":        0,
    "NODE":      1,
    "CLIENT_CA": 2,
    "CLIENT":    3,
    "UI_CA":     4,
    "UI":        5,
}
var FileType_name = map[int32]string{
    0:  "HEAP",
    1:  "GOROUTINES",
}
var FileType_value = map[string]int32{
    "HEAP":       0,
    "GOROUTINES": 1,
}
var ProfileRequest_Type_name = map[int32]string{
    0:  "HEAP",
    1:  "CPU",
}
var ProfileRequest_Type_value = map[string]int32{
    "HEAP": 0,
    "CPU":  1,
}
var StacksType_name = map[int32]string{
    0:  "GOROUTINE_STACKS",
    1:  "THREAD_STACKS",
}
var StacksType_value = map[string]int32{
    "GOROUTINE_STACKS": 0,
    "THREAD_STACKS":    1,
}
var ZoneConfigurationLevel_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "CLUSTER",
    2:  "DATABASE",
    3:  "TABLE",
}
var ZoneConfigurationLevel_value = map[string]int32{
    "UNKNOWN":  0,
    "CLUSTER":  1,
    "DATABASE": 2,
    "TABLE":    3,
}

func RegisterAdminHandler Uses

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

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

func RegisterAdminHandlerClient Uses

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

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

func RegisterAdminHandlerFromEndpoint Uses

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

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

func RegisterAdminHandlerServer Uses

func RegisterAdminHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AdminServer) error

RegisterAdminHandlerServer registers the http handlers for service Admin to "mux". UnaryRPC :call AdminServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterAdminServer Uses

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

func RegisterInitServer Uses

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

func RegisterLogInHandler Uses

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

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

func RegisterLogInHandlerClient Uses

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

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

func RegisterLogInHandlerFromEndpoint Uses

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

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

func RegisterLogInHandlerServer Uses

func RegisterLogInHandlerServer(ctx context.Context, mux *runtime.ServeMux, server LogInServer) error

RegisterLogInHandlerServer registers the http handlers for service LogIn to "mux". UnaryRPC :call LogInServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterLogInServer Uses

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

func RegisterLogOutHandler Uses

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

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

func RegisterLogOutHandlerClient Uses

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

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

func RegisterLogOutHandlerFromEndpoint Uses

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

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

func RegisterLogOutHandlerServer Uses

func RegisterLogOutHandlerServer(ctx context.Context, mux *runtime.ServeMux, server LogOutServer) error

RegisterLogOutHandlerServer registers the http handlers for service LogOut to "mux". UnaryRPC :call LogOutServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterLogOutServer Uses

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

func RegisterStatusHandler Uses

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

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

func RegisterStatusHandlerClient Uses

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

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

func RegisterStatusHandlerFromEndpoint Uses

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

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

func RegisterStatusHandlerServer Uses

func RegisterStatusHandlerServer(ctx context.Context, mux *runtime.ServeMux, server StatusServer) error

RegisterStatusHandlerServer registers the http handlers for service Status to "mux". UnaryRPC :call StatusServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterStatusServer Uses

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

type ActiveQuery Uses

type ActiveQuery struct {
    // ID of the query (uint128 presented as a hexadecimal string).
    ID  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
    // The UUID of the transaction this query is running in.
    TxnID github_com_cockroachdb_cockroach_pkg_util_uuid.UUID `protobuf:"bytes,7,opt,name=txn_id,json=txnId,proto3,customtype=github.com/cockroachdb/cockroach/pkg/util/uuid.UUID" json:"txn_id"`
    // SQL query string specified by the user.
    Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
    // Start timestamp of this query.
    Start time.Time `protobuf:"bytes,3,opt,name=start,proto3,stdtime" json:"start"`
    // True if this query is distributed.
    IsDistributed bool `protobuf:"varint,4,opt,name=is_distributed,json=isDistributed,proto3" json:"is_distributed,omitempty"`
    // phase stores the current phase of execution for this query.
    Phase    ActiveQuery_Phase `protobuf:"varint,5,opt,name=phase,proto3,enum=cockroach.server.serverpb.ActiveQuery_Phase" json:"phase,omitempty"`
    Progress float32           `protobuf:"fixed32,6,opt,name=progress,proto3" json:"progress,omitempty"`
}

ActiveQuery represents a query in flight on some Session.

func (*ActiveQuery) Descriptor Uses

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

func (*ActiveQuery) Marshal Uses

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

func (*ActiveQuery) MarshalTo Uses

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

func (*ActiveQuery) ProtoMessage Uses

func (*ActiveQuery) ProtoMessage()

func (*ActiveQuery) Reset Uses

func (m *ActiveQuery) Reset()

func (*ActiveQuery) Size Uses

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

func (*ActiveQuery) String Uses

func (m *ActiveQuery) String() string

func (*ActiveQuery) Unmarshal Uses

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

func (*ActiveQuery) XXX_DiscardUnknown Uses

func (m *ActiveQuery) XXX_DiscardUnknown()

func (*ActiveQuery) XXX_Marshal Uses

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

func (*ActiveQuery) XXX_Merge Uses

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

func (*ActiveQuery) XXX_Size Uses

func (m *ActiveQuery) XXX_Size() int

func (*ActiveQuery) XXX_Unmarshal Uses

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

type ActiveQuery_Phase Uses

type ActiveQuery_Phase int32

Enum for phase of execution.

const (
    ActiveQuery_PREPARING ActiveQuery_Phase = 0
    ActiveQuery_EXECUTING ActiveQuery_Phase = 1
)

func (ActiveQuery_Phase) EnumDescriptor Uses

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

func (ActiveQuery_Phase) String Uses

func (x ActiveQuery_Phase) String() string

type AdminClient Uses

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

AdminClient is the client API for Admin service.

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

func NewAdminClient Uses

func NewAdminClient(cc *grpc.ClientConn) AdminClient

type AdminServer Uses

type AdminServer interface {
    // URL: /_admin/v1/users
    Users(context.Context, *UsersRequest) (*UsersResponse, error)
    // URL: /_admin/v1/databases
    Databases(context.Context, *DatabasesRequest) (*DatabasesResponse, error)
    // Example URL: /_admin/v1/databases/system
    DatabaseDetails(context.Context, *DatabaseDetailsRequest) (*DatabaseDetailsResponse, error)
    // Example URL: /_admin/v1/databases/system/tables/ui
    TableDetails(context.Context, *TableDetailsRequest) (*TableDetailsResponse, error)
    // Example URL: /_admin/v1/databases/system/tables/ui/stats
    TableStats(context.Context, *TableStatsRequest) (*TableStatsResponse, error)
    // Example URL: /_admin/v1/nontablestats
    NonTableStats(context.Context, *NonTableStatsRequest) (*NonTableStatsResponse, error)
    // Example URLs:
    // Example URLs:
    // - /_admin/v1/events
    // - /_admin/v1/events?limit=100
    // - /_admin/v1/events?type=create_table
    // - /_admin/v1/events?type=create_table&limit=100
    // - /_admin/v1/events?type=drop_table&target_id=4
    // - /_admin/v1/events?type=drop_table&target_id=4&limit=100
    Events(context.Context, *EventsRequest) (*EventsResponse, error)
    // This requires a POST. Because of the libraries we're using, the POST body
    // must be in the following format:
    //
    // {"key_values":
    //   { "key1": "base64_encoded_value1"},
    //   ...
    //   { "keyN": "base64_encoded_valueN"},
    // }
    //
    // Note that all keys are quoted strings and that all values are base64-
    // encoded.
    //
    // Together, SetUIData and GetUIData provide access to a "cookie jar" for the
    // admin UI. The structure of the underlying data is meant to be opaque to the
    // server.
    SetUIData(context.Context, *SetUIDataRequest) (*SetUIDataResponse, error)
    // Example URLs:
    // - /_admin/v1/uidata?keys=MYKEY
    // - /_admin/v1/uidata?keys=MYKEY1&keys=MYKEY2
    //
    // Yes, it's a little odd that the query parameter is named "keys" instead of
    // "key". I would've preferred that the URL parameter be named "key". However,
    // it's clearer for the protobuf field to be named "keys," which makes the URL
    // parameter "keys" as well.
    GetUIData(context.Context, *GetUIDataRequest) (*GetUIDataResponse, error)
    // Cluster returns metadata for the cluster.
    Cluster(context.Context, *ClusterRequest) (*ClusterResponse, error)
    // Settings returns the cluster-wide settings for the cluster.
    Settings(context.Context, *SettingsRequest) (*SettingsResponse, error)
    // Health returns liveness for the node target of the request.
    Health(context.Context, *HealthRequest) (*HealthResponse, error)
    // Liveness returns the liveness state of all nodes on the cluster.
    Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error)
    // Jobs returns the job records for all jobs of the given status and type.
    Jobs(context.Context, *JobsRequest) (*JobsResponse, error)
    // Locations returns the locality location records.
    Locations(context.Context, *LocationsRequest) (*LocationsResponse, error)
    // QueryPlan returns the query plans for a SQL string.
    QueryPlan(context.Context, *QueryPlanRequest) (*QueryPlanResponse, error)
    // Drain puts the node into the specified drain mode(s) and optionally
    // instructs the process to terminate.
    // We do not expose this via HTTP unless we have a way to authenticate
    // + authorize streaming RPC connections. See #42567.
    Drain(*DrainRequest, Admin_DrainServer) error
    // Decommission puts the node(s) into the specified decommissioning state.
    // If this ever becomes exposed via HTTP, ensure that it performs
    // authorization. See #42567.
    Decommission(context.Context, *DecommissionRequest) (*DecommissionStatusResponse, error)
    // DecommissionStatus retrieves the decommissioning status of the specified nodes.
    // If this ever becomes exposed via HTTP, ensure that it performs
    // authorization. See #42567.
    DecommissionStatus(context.Context, *DecommissionStatusRequest) (*DecommissionStatusResponse, error)
    // URL: /_admin/v1/rangelog
    // URL: /_admin/v1/rangelog?limit=100
    // URL: /_admin/v1/rangelog/1
    // URL: /_admin/v1/rangelog/1?limit=100
    RangeLog(context.Context, *RangeLogRequest) (*RangeLogResponse, error)
    DataDistribution(context.Context, *DataDistributionRequest) (*DataDistributionResponse, error)
    // URL: /_admin/v1/metricmetadata
    AllMetricMetadata(context.Context, *MetricMetadataRequest) (*MetricMetadataResponse, error)
    // URL: /_admin/v1/chartcatalog
    ChartCatalog(context.Context, *ChartCatalogRequest) (*ChartCatalogResponse, error)
    // EnqueueRange runs the specified range through the specified queue on the
    // range's leaseholder store, returning the detailed trace and error
    // information from doing so. Parameters must be provided in the body of the
    // POST request.
    // For example:
    //
    // {
    //   "queue": "raftlog",
    //   "rangeId": 10
    // }
    EnqueueRange(context.Context, *EnqueueRangeRequest) (*EnqueueRangeResponse, error)
}

AdminServer is the server API for Admin service.

type Admin_DrainClient Uses

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

type Admin_DrainServer Uses

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

type AllocatorDryRun Uses

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

func (*AllocatorDryRun) Descriptor Uses

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

func (*AllocatorDryRun) Marshal Uses

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

func (*AllocatorDryRun) MarshalTo Uses

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

func (*AllocatorDryRun) ProtoMessage Uses

func (*AllocatorDryRun) ProtoMessage()

func (*AllocatorDryRun) Reset Uses

func (m *AllocatorDryRun) Reset()

func (*AllocatorDryRun) Size Uses

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

func (*AllocatorDryRun) String Uses

func (m *AllocatorDryRun) String() string

func (*AllocatorDryRun) Unmarshal Uses

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

func (*AllocatorDryRun) XXX_DiscardUnknown Uses

func (m *AllocatorDryRun) XXX_DiscardUnknown()

func (*AllocatorDryRun) XXX_Marshal Uses

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

func (*AllocatorDryRun) XXX_Merge Uses

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

func (*AllocatorDryRun) XXX_Size Uses

func (m *AllocatorDryRun) XXX_Size() int

func (*AllocatorDryRun) XXX_Unmarshal Uses

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

type AllocatorRangeRequest Uses

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

func (*AllocatorRangeRequest) Descriptor Uses

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

func (*AllocatorRangeRequest) Marshal Uses

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

func (*AllocatorRangeRequest) MarshalTo Uses

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

func (*AllocatorRangeRequest) ProtoMessage Uses

func (*AllocatorRangeRequest) ProtoMessage()

func (*AllocatorRangeRequest) Reset Uses

func (m *AllocatorRangeRequest) Reset()

func (*AllocatorRangeRequest) Size Uses

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

func (*AllocatorRangeRequest) String Uses

func (m *AllocatorRangeRequest) String() string

func (*AllocatorRangeRequest) Unmarshal Uses

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

func (*AllocatorRangeRequest) XXX_DiscardUnknown Uses

func (m *AllocatorRangeRequest) XXX_DiscardUnknown()

func (*AllocatorRangeRequest) XXX_Marshal Uses

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

func (*AllocatorRangeRequest) XXX_Merge Uses

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

func (*AllocatorRangeRequest) XXX_Size Uses

func (m *AllocatorRangeRequest) XXX_Size() int

func (*AllocatorRangeRequest) XXX_Unmarshal Uses

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

type AllocatorRangeResponse Uses

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

func (*AllocatorRangeResponse) Descriptor Uses

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

func (*AllocatorRangeResponse) Marshal Uses

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

func (*AllocatorRangeResponse) MarshalTo Uses

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

func (*AllocatorRangeResponse) ProtoMessage Uses

func (*AllocatorRangeResponse) ProtoMessage()

func (*AllocatorRangeResponse) Reset Uses

func (m *AllocatorRangeResponse) Reset()

func (*AllocatorRangeResponse) Size Uses

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

func (*AllocatorRangeResponse) String Uses

func (m *AllocatorRangeResponse) String() string

func (*AllocatorRangeResponse) Unmarshal Uses

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

func (*AllocatorRangeResponse) XXX_DiscardUnknown Uses

func (m *AllocatorRangeResponse) XXX_DiscardUnknown()

func (*AllocatorRangeResponse) XXX_Marshal Uses

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

func (*AllocatorRangeResponse) XXX_Merge Uses

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

func (*AllocatorRangeResponse) XXX_Size Uses

func (m *AllocatorRangeResponse) XXX_Size() int

func (*AllocatorRangeResponse) XXX_Unmarshal Uses

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

type AllocatorRequest Uses

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

func (*AllocatorRequest) Descriptor Uses

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

func (*AllocatorRequest) Marshal Uses

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

func (*AllocatorRequest) MarshalTo Uses

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

func (*AllocatorRequest) ProtoMessage Uses

func (*AllocatorRequest) ProtoMessage()

func (*AllocatorRequest) Reset Uses

func (m *AllocatorRequest) Reset()

func (*AllocatorRequest) Size Uses

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

func (*AllocatorRequest) String Uses

func (m *AllocatorRequest) String() string

func (*AllocatorRequest) Unmarshal Uses

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

func (*AllocatorRequest) XXX_DiscardUnknown Uses

func (m *AllocatorRequest) XXX_DiscardUnknown()

func (*AllocatorRequest) XXX_Marshal Uses

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

func (*AllocatorRequest) XXX_Merge Uses

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

func (*AllocatorRequest) XXX_Size Uses

func (m *AllocatorRequest) XXX_Size() int

func (*AllocatorRequest) XXX_Unmarshal Uses

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

type AllocatorResponse Uses

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

func (*AllocatorResponse) Descriptor Uses

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

func (*AllocatorResponse) Marshal Uses

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

func (*AllocatorResponse) MarshalTo Uses

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

func (*AllocatorResponse) ProtoMessage Uses

func (*AllocatorResponse) ProtoMessage()

func (*AllocatorResponse) Reset Uses

func (m *AllocatorResponse) Reset()

func (*AllocatorResponse) Size Uses

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

func (*AllocatorResponse) String Uses

func (m *AllocatorResponse) String() string

func (*AllocatorResponse) Unmarshal Uses

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

func (*AllocatorResponse) XXX_DiscardUnknown Uses

func (m *AllocatorResponse) XXX_DiscardUnknown()

func (*AllocatorResponse) XXX_Marshal Uses

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

func (*AllocatorResponse) XXX_Merge Uses

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

func (*AllocatorResponse) XXX_Size Uses

func (m *AllocatorResponse) XXX_Size() int

func (*AllocatorResponse) XXX_Unmarshal Uses

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

type BootstrapRequest Uses

type BootstrapRequest struct {
}

func (*BootstrapRequest) Descriptor Uses

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

func (*BootstrapRequest) Marshal Uses

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

func (*BootstrapRequest) MarshalTo Uses

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

func (*BootstrapRequest) ProtoMessage Uses

func (*BootstrapRequest) ProtoMessage()

func (*BootstrapRequest) Reset Uses

func (m *BootstrapRequest) Reset()

func (*BootstrapRequest) Size Uses

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

func (*BootstrapRequest) String Uses

func (m *BootstrapRequest) String() string

func (*BootstrapRequest) Unmarshal Uses

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

func (*BootstrapRequest) XXX_DiscardUnknown Uses

func (m *BootstrapRequest) XXX_DiscardUnknown()

func (*BootstrapRequest) XXX_Marshal Uses

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

func (*BootstrapRequest) XXX_Merge Uses

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

func (*BootstrapRequest) XXX_Size Uses

func (m *BootstrapRequest) XXX_Size() int

func (*BootstrapRequest) XXX_Unmarshal Uses

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

type BootstrapResponse Uses

type BootstrapResponse struct {
}

func (*BootstrapResponse) Descriptor Uses

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

func (*BootstrapResponse) Marshal Uses

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

func (*BootstrapResponse) MarshalTo Uses

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

func (*BootstrapResponse) ProtoMessage Uses

func (*BootstrapResponse) ProtoMessage()

func (*BootstrapResponse) Reset Uses

func (m *BootstrapResponse) Reset()

func (*BootstrapResponse) Size Uses

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

func (*BootstrapResponse) String Uses

func (m *BootstrapResponse) String() string

func (*BootstrapResponse) Unmarshal Uses

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

func (*BootstrapResponse) XXX_DiscardUnknown Uses

func (m *BootstrapResponse) XXX_DiscardUnknown()

func (*BootstrapResponse) XXX_Marshal Uses

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

func (*BootstrapResponse) XXX_Merge Uses

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

func (*BootstrapResponse) XXX_Size Uses

func (m *BootstrapResponse) XXX_Size() int

func (*BootstrapResponse) XXX_Unmarshal Uses

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

type CancelQueryRequest Uses

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

Request object for issing a query cancel request.

func (*CancelQueryRequest) Descriptor Uses

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

func (*CancelQueryRequest) Marshal Uses

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

func (*CancelQueryRequest) MarshalTo Uses

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

func (*CancelQueryRequest) ProtoMessage Uses

func (*CancelQueryRequest) ProtoMessage()

func (*CancelQueryRequest) Reset Uses

func (m *CancelQueryRequest) Reset()

func (*CancelQueryRequest) Size Uses

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

func (*CancelQueryRequest) String Uses

func (m *CancelQueryRequest) String() string

func (*CancelQueryRequest) Unmarshal Uses

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

func (*CancelQueryRequest) XXX_DiscardUnknown Uses

func (m *CancelQueryRequest) XXX_DiscardUnknown()

func (*CancelQueryRequest) XXX_Marshal Uses

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

func (*CancelQueryRequest) XXX_Merge Uses

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

func (*CancelQueryRequest) XXX_Size Uses

func (m *CancelQueryRequest) XXX_Size() int

func (*CancelQueryRequest) XXX_Unmarshal Uses

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

type CancelQueryResponse Uses

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

Response returned by target query's gateway node.

func (*CancelQueryResponse) Descriptor Uses

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

func (*CancelQueryResponse) Marshal Uses

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

func (*CancelQueryResponse) MarshalTo Uses

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

func (*CancelQueryResponse) ProtoMessage Uses

func (*CancelQueryResponse) ProtoMessage()

func (*CancelQueryResponse) Reset Uses

func (m *CancelQueryResponse) Reset()

func (*CancelQueryResponse) Size Uses

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

func (*CancelQueryResponse) String Uses

func (m *CancelQueryResponse) String() string

func (*CancelQueryResponse) Unmarshal Uses

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

func (*CancelQueryResponse) XXX_DiscardUnknown Uses

func (m *CancelQueryResponse) XXX_DiscardUnknown()

func (*CancelQueryResponse) XXX_Marshal Uses

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

func (*CancelQueryResponse) XXX_Merge Uses

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

func (*CancelQueryResponse) XXX_Size Uses

func (m *CancelQueryResponse) XXX_Size() int

func (*CancelQueryResponse) XXX_Unmarshal Uses

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

type CancelSessionRequest Uses

type CancelSessionRequest struct {
    // TODO(abhimadan): use [(gogoproto.customname) = "NodeID"] below. Need to
    // figure out how to teach grpc-gateway about custom names.
    //
    // node_id is a string so that "local" can be used to specify that no
    // forwarding is necessary.
    NodeId    string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
    SessionID []byte `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
    Username  string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
}

func (*CancelSessionRequest) Descriptor Uses

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

func (*CancelSessionRequest) Marshal Uses

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

func (*CancelSessionRequest) MarshalTo Uses

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

func (*CancelSessionRequest) ProtoMessage Uses

func (*CancelSessionRequest) ProtoMessage()

func (*CancelSessionRequest) Reset Uses

func (m *CancelSessionRequest) Reset()

func (*CancelSessionRequest) Size Uses

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

func (*CancelSessionRequest) String Uses

func (m *CancelSessionRequest) String() string

func (*CancelSessionRequest) Unmarshal Uses

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

func (*CancelSessionRequest) XXX_DiscardUnknown Uses

func (m *CancelSessionRequest) XXX_DiscardUnknown()

func (*CancelSessionRequest) XXX_Marshal Uses

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

func (*CancelSessionRequest) XXX_Merge Uses

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

func (*CancelSessionRequest) XXX_Size Uses

func (m *CancelSessionRequest) XXX_Size() int

func (*CancelSessionRequest) XXX_Unmarshal Uses

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

type CancelSessionResponse Uses

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

func (*CancelSessionResponse) Descriptor Uses

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

func (*CancelSessionResponse) Marshal Uses

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

func (*CancelSessionResponse) MarshalTo Uses

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

func (*CancelSessionResponse) ProtoMessage Uses

func (*CancelSessionResponse) ProtoMessage()

func (*CancelSessionResponse) Reset Uses

func (m *CancelSessionResponse) Reset()

func (*CancelSessionResponse) Size Uses

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

func (*CancelSessionResponse) String Uses

func (m *CancelSessionResponse) String() string

func (*CancelSessionResponse) Unmarshal Uses

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

func (*CancelSessionResponse) XXX_DiscardUnknown Uses

func (m *CancelSessionResponse) XXX_DiscardUnknown()

func (*CancelSessionResponse) XXX_Marshal Uses

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

func (*CancelSessionResponse) XXX_Merge Uses

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

func (*CancelSessionResponse) XXX_Size Uses

func (m *CancelSessionResponse) XXX_Size() int

func (*CancelSessionResponse) XXX_Unmarshal Uses

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

type CertificateDetails Uses

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

func (*CertificateDetails) Descriptor Uses

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

func (*CertificateDetails) Marshal Uses

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

func (*CertificateDetails) MarshalTo Uses

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

func (*CertificateDetails) ProtoMessage Uses

func (*CertificateDetails) ProtoMessage()

func (*CertificateDetails) Reset Uses

func (m *CertificateDetails) Reset()

func (*CertificateDetails) Size Uses

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

func (*CertificateDetails) String Uses

func (m *CertificateDetails) String() string

func (*CertificateDetails) Unmarshal Uses

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

func (*CertificateDetails) XXX_DiscardUnknown Uses

func (m *CertificateDetails) XXX_DiscardUnknown()

func (*CertificateDetails) XXX_Marshal Uses

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

func (*CertificateDetails) XXX_Merge Uses

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

func (*CertificateDetails) XXX_Size Uses

func (m *CertificateDetails) XXX_Size() int

func (*CertificateDetails) XXX_Unmarshal Uses

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

type CertificateDetails_CertificateType Uses

type CertificateDetails_CertificateType int32

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

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

func (CertificateDetails_CertificateType) EnumDescriptor Uses

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

func (CertificateDetails_CertificateType) String Uses

func (x CertificateDetails_CertificateType) String() string

type CertificateDetails_Fields Uses

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

func (*CertificateDetails_Fields) Descriptor Uses

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

func (*CertificateDetails_Fields) Marshal Uses

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

func (*CertificateDetails_Fields) MarshalTo Uses

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

func (*CertificateDetails_Fields) ProtoMessage Uses

func (*CertificateDetails_Fields) ProtoMessage()

func (*CertificateDetails_Fields) Reset Uses

func (m *CertificateDetails_Fields) Reset()

func (*CertificateDetails_Fields) Size Uses

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

func (*CertificateDetails_Fields) String Uses

func (m *CertificateDetails_Fields) String() string

func (*CertificateDetails_Fields) Unmarshal Uses

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

func (*CertificateDetails_Fields) XXX_DiscardUnknown Uses

func (m *CertificateDetails_Fields) XXX_DiscardUnknown()

func (*CertificateDetails_Fields) XXX_Marshal Uses

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

func (*CertificateDetails_Fields) XXX_Merge Uses

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

func (*CertificateDetails_Fields) XXX_Size Uses

func (m *CertificateDetails_Fields) XXX_Size() int

func (*CertificateDetails_Fields) XXX_Unmarshal Uses

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

type CertificatesRequest Uses

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

func (*CertificatesRequest) Descriptor Uses

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

func (*CertificatesRequest) Marshal Uses

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

func (*CertificatesRequest) MarshalTo Uses

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

func (*CertificatesRequest) ProtoMessage Uses

func (*CertificatesRequest) ProtoMessage()

func (*CertificatesRequest) Reset Uses

func (m *CertificatesRequest) Reset()

func (*CertificatesRequest) Size Uses

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

func (*CertificatesRequest) String Uses

func (m *CertificatesRequest) String() string

func (*CertificatesRequest) Unmarshal Uses

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

func (*CertificatesRequest) XXX_DiscardUnknown Uses

func (m *CertificatesRequest) XXX_DiscardUnknown()

func (*CertificatesRequest) XXX_Marshal Uses

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

func (*CertificatesRequest) XXX_Merge Uses

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

func (*CertificatesRequest) XXX_Size Uses

func (m *CertificatesRequest) XXX_Size() int

func (*CertificatesRequest) XXX_Unmarshal Uses

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

type CertificatesResponse Uses

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

func (*CertificatesResponse) Descriptor Uses

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

func (*CertificatesResponse) Marshal Uses

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

func (*CertificatesResponse) MarshalTo Uses

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

func (*CertificatesResponse) ProtoMessage Uses

func (*CertificatesResponse) ProtoMessage()

func (*CertificatesResponse) Reset Uses

func (m *CertificatesResponse) Reset()

func (*CertificatesResponse) Size Uses

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

func (*CertificatesResponse) String Uses

func (m *CertificatesResponse) String() string

func (*CertificatesResponse) Unmarshal Uses

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

func (*CertificatesResponse) XXX_DiscardUnknown Uses

func (m *CertificatesResponse) XXX_DiscardUnknown()

func (*CertificatesResponse) XXX_Marshal Uses

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

func (*CertificatesResponse) XXX_Merge Uses

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

func (*CertificatesResponse) XXX_Size Uses

func (m *CertificatesResponse) XXX_Size() int

func (*CertificatesResponse) XXX_Unmarshal Uses

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

type ChartCatalogRequest Uses

type ChartCatalogRequest struct {
}

ChartCatalogRequest requests returns a catalog of Admin UI charts.

func (*ChartCatalogRequest) Descriptor Uses

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

func (*ChartCatalogRequest) Marshal Uses

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

func (*ChartCatalogRequest) MarshalTo Uses

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

func (*ChartCatalogRequest) ProtoMessage Uses

func (*ChartCatalogRequest) ProtoMessage()

func (*ChartCatalogRequest) Reset Uses

func (m *ChartCatalogRequest) Reset()

func (*ChartCatalogRequest) Size Uses

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

func (*ChartCatalogRequest) String Uses

func (m *ChartCatalogRequest) String() string

func (*ChartCatalogRequest) Unmarshal Uses

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

func (*ChartCatalogRequest) XXX_DiscardUnknown Uses

func (m *ChartCatalogRequest) XXX_DiscardUnknown()

func (*ChartCatalogRequest) XXX_Marshal Uses

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

func (*ChartCatalogRequest) XXX_Merge Uses

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

func (*ChartCatalogRequest) XXX_Size Uses

func (m *ChartCatalogRequest) XXX_Size() int

func (*ChartCatalogRequest) XXX_Unmarshal Uses

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

type ChartCatalogResponse Uses

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

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

func (*ChartCatalogResponse) Descriptor Uses

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

func (*ChartCatalogResponse) Marshal Uses

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

func (*ChartCatalogResponse) MarshalTo Uses

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

func (*ChartCatalogResponse) ProtoMessage Uses

func (*ChartCatalogResponse) ProtoMessage()

func (*ChartCatalogResponse) Reset Uses

func (m *ChartCatalogResponse) Reset()

func (*ChartCatalogResponse) Size Uses

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

func (*ChartCatalogResponse) String Uses

func (m *ChartCatalogResponse) String() string

func (*ChartCatalogResponse) Unmarshal Uses

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

func (*ChartCatalogResponse) XXX_DiscardUnknown Uses

func (m *ChartCatalogResponse) XXX_DiscardUnknown()

func (*ChartCatalogResponse) XXX_Marshal Uses

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

func (*ChartCatalogResponse) XXX_Merge Uses

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

func (*ChartCatalogResponse) XXX_Size Uses

func (m *ChartCatalogResponse) XXX_Size() int

func (*ChartCatalogResponse) XXX_Unmarshal Uses

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

type ClusterRequest Uses

type ClusterRequest struct {
}

ClusterRequest requests metadata for the cluster.

func (*ClusterRequest) Descriptor Uses

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

func (*ClusterRequest) Marshal Uses

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

func (*ClusterRequest) MarshalTo Uses

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

func (*ClusterRequest) ProtoMessage Uses

func (*ClusterRequest) ProtoMessage()

func (*ClusterRequest) Reset Uses

func (m *ClusterRequest) Reset()

func (*ClusterRequest) Size Uses

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

func (*ClusterRequest) String Uses

func (m *ClusterRequest) String() string

func (*ClusterRequest) Unmarshal Uses

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

func (*ClusterRequest) XXX_DiscardUnknown Uses

func (m *ClusterRequest) XXX_DiscardUnknown()

func (*ClusterRequest) XXX_Marshal Uses

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

func (*ClusterRequest) XXX_Merge Uses

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

func (*ClusterRequest) XXX_Size Uses

func (m *ClusterRequest) XXX_Size() int

func (*ClusterRequest) XXX_Unmarshal Uses

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

type ClusterResponse Uses

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

ClusterResponse contains metadata for the cluster.

func (*ClusterResponse) Descriptor Uses

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

func (*ClusterResponse) Marshal Uses

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

func (*ClusterResponse) MarshalTo Uses

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

func (*ClusterResponse) ProtoMessage Uses

func (*ClusterResponse) ProtoMessage()

func (*ClusterResponse) Reset Uses

func (m *ClusterResponse) Reset()

func (*ClusterResponse) Size Uses

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

func (*ClusterResponse) String Uses

func (m *ClusterResponse) String() string

func (*ClusterResponse) Unmarshal Uses

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

func (*ClusterResponse) XXX_DiscardUnknown Uses

func (m *ClusterResponse) XXX_DiscardUnknown()

func (*ClusterResponse) XXX_Marshal Uses

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

func (*ClusterResponse) XXX_Merge Uses

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

func (*ClusterResponse) XXX_Size Uses

func (m *ClusterResponse) XXX_Size() int

func (*ClusterResponse) XXX_Unmarshal Uses

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

type CreateStatementDiagnosticsReportRequest Uses

type CreateStatementDiagnosticsReportRequest struct {
    StatementFingerprint string `protobuf:"bytes,1,opt,name=statement_fingerprint,json=statementFingerprint,proto3" json:"statement_fingerprint,omitempty"`
}

func (*CreateStatementDiagnosticsReportRequest) Descriptor Uses

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

func (*CreateStatementDiagnosticsReportRequest) Marshal Uses

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

func (*CreateStatementDiagnosticsReportRequest) MarshalTo Uses

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

func (*CreateStatementDiagnosticsReportRequest) ProtoMessage Uses

func (*CreateStatementDiagnosticsReportRequest) ProtoMessage()

func (*CreateStatementDiagnosticsReportRequest) Reset Uses

func (m *CreateStatementDiagnosticsReportRequest) Reset()

func (*CreateStatementDiagnosticsReportRequest) Size Uses

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

func (*CreateStatementDiagnosticsReportRequest) String Uses

func (m *CreateStatementDiagnosticsReportRequest) String() string

func (*CreateStatementDiagnosticsReportRequest) Unmarshal Uses

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

func (*CreateStatementDiagnosticsReportRequest) XXX_DiscardUnknown Uses

func (m *CreateStatementDiagnosticsReportRequest) XXX_DiscardUnknown()

func (*CreateStatementDiagnosticsReportRequest) XXX_Marshal Uses

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

func (*CreateStatementDiagnosticsReportRequest) XXX_Merge Uses

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

func (*CreateStatementDiagnosticsReportRequest) XXX_Size Uses

func (m *CreateStatementDiagnosticsReportRequest) XXX_Size() int

func (*CreateStatementDiagnosticsReportRequest) XXX_Unmarshal Uses

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

type CreateStatementDiagnosticsReportResponse Uses

type CreateStatementDiagnosticsReportResponse struct {
    Report *StatementDiagnosticsReport `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
}

func (*CreateStatementDiagnosticsReportResponse) Descriptor Uses

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

func (*CreateStatementDiagnosticsReportResponse) Marshal Uses

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

func (*CreateStatementDiagnosticsReportResponse) MarshalTo Uses

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

func (*CreateStatementDiagnosticsReportResponse) ProtoMessage Uses

func (*CreateStatementDiagnosticsReportResponse) ProtoMessage()

func (*CreateStatementDiagnosticsReportResponse) Reset Uses

func (m *CreateStatementDiagnosticsReportResponse) Reset()

func (*CreateStatementDiagnosticsReportResponse) Size Uses

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

func (*CreateStatementDiagnosticsReportResponse) String Uses

func (m *CreateStatementDiagnosticsReportResponse) String() string

func (*CreateStatementDiagnosticsReportResponse) Unmarshal Uses

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

func (*CreateStatementDiagnosticsReportResponse) XXX_DiscardUnknown Uses

func (m *CreateStatementDiagnosticsReportResponse) XXX_DiscardUnknown()

func (*CreateStatementDiagnosticsReportResponse) XXX_Marshal Uses

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

func (*CreateStatementDiagnosticsReportResponse) XXX_Merge Uses

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

func (*CreateStatementDiagnosticsReportResponse) XXX_Size Uses

func (m *CreateStatementDiagnosticsReportResponse) XXX_Size() int

func (*CreateStatementDiagnosticsReportResponse) XXX_Unmarshal Uses

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

type DataDistributionRequest Uses

type DataDistributionRequest struct {
}

func (*DataDistributionRequest) Descriptor Uses

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

func (*DataDistributionRequest) Marshal Uses

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

func (*DataDistributionRequest) MarshalTo Uses

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

func (*DataDistributionRequest) ProtoMessage Uses

func (*DataDistributionRequest) ProtoMessage()

func (*DataDistributionRequest) Reset Uses

func (m *DataDistributionRequest) Reset()

func (*DataDistributionRequest) Size Uses

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

func (*DataDistributionRequest) String Uses

func (m *DataDistributionRequest) String() string

func (*DataDistributionRequest) Unmarshal Uses

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

func (*DataDistributionRequest) XXX_DiscardUnknown Uses

func (m *DataDistributionRequest) XXX_DiscardUnknown()

func (*DataDistributionRequest) XXX_Marshal Uses

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

func (*DataDistributionRequest) XXX_Merge Uses

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

func (*DataDistributionRequest) XXX_Size Uses

func (m *DataDistributionRequest) XXX_Size() int

func (*DataDistributionRequest) XXX_Unmarshal Uses

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

type DataDistributionResponse Uses

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

func (*DataDistributionResponse) Descriptor Uses

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

func (*DataDistributionResponse) Marshal Uses

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

func (*DataDistributionResponse) MarshalTo Uses

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

func (*DataDistributionResponse) ProtoMessage Uses

func (*DataDistributionResponse) ProtoMessage()

func (*DataDistributionResponse) Reset Uses

func (m *DataDistributionResponse) Reset()

func (*DataDistributionResponse) Size Uses

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

func (*DataDistributionResponse) String Uses

func (m *DataDistributionResponse) String() string

func (*DataDistributionResponse) Unmarshal Uses

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

func (*DataDistributionResponse) XXX_DiscardUnknown Uses

func (m *DataDistributionResponse) XXX_DiscardUnknown()

func (*DataDistributionResponse) XXX_Marshal Uses

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

func (*DataDistributionResponse) XXX_Merge Uses

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

func (*DataDistributionResponse) XXX_Size Uses

func (m *DataDistributionResponse) XXX_Size() int

func (*DataDistributionResponse) XXX_Unmarshal Uses

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

type DataDistributionResponse_DatabaseInfo Uses

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

func (*DataDistributionResponse_DatabaseInfo) Descriptor Uses

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

func (*DataDistributionResponse_DatabaseInfo) Marshal Uses

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

func (*DataDistributionResponse_DatabaseInfo) MarshalTo Uses

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

func (*DataDistributionResponse_DatabaseInfo) ProtoMessage Uses

func (*DataDistributionResponse_DatabaseInfo) ProtoMessage()

func (*DataDistributionResponse_DatabaseInfo) Reset Uses

func (m *DataDistributionResponse_DatabaseInfo) Reset()

func (*DataDistributionResponse_DatabaseInfo) Size Uses

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

func (*DataDistributionResponse_DatabaseInfo) String Uses

func (m *DataDistributionResponse_DatabaseInfo) String() string

func (*DataDistributionResponse_DatabaseInfo) Unmarshal Uses

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

func (*DataDistributionResponse_DatabaseInfo) XXX_DiscardUnknown Uses

func (m *DataDistributionResponse_DatabaseInfo) XXX_DiscardUnknown()

func (*DataDistributionResponse_DatabaseInfo) XXX_Marshal Uses

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

func (*DataDistributionResponse_DatabaseInfo) XXX_Merge Uses

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

func (*DataDistributionResponse_DatabaseInfo) XXX_Size Uses

func (m *DataDistributionResponse_DatabaseInfo) XXX_Size() int

func (*DataDistributionResponse_DatabaseInfo) XXX_Unmarshal Uses

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

type DataDistributionResponse_TableInfo Uses

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

func (*DataDistributionResponse_TableInfo) Descriptor Uses

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

func (*DataDistributionResponse_TableInfo) Marshal Uses

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

func (*DataDistributionResponse_TableInfo) MarshalTo Uses

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

func (*DataDistributionResponse_TableInfo) ProtoMessage Uses

func (*DataDistributionResponse_TableInfo) ProtoMessage()

func (*DataDistributionResponse_TableInfo) Reset Uses

func (m *DataDistributionResponse_TableInfo) Reset()

func (*DataDistributionResponse_TableInfo) Size Uses

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

func (*DataDistributionResponse_TableInfo) String Uses

func (m *DataDistributionResponse_TableInfo) String() string

func (*DataDistributionResponse_TableInfo) Unmarshal Uses

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

func (*DataDistributionResponse_TableInfo) XXX_DiscardUnknown Uses

func (m *DataDistributionResponse_TableInfo) XXX_DiscardUnknown()

func (*DataDistributionResponse_TableInfo) XXX_Marshal Uses

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

func (*DataDistributionResponse_TableInfo) XXX_Merge Uses

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

func (*DataDistributionResponse_TableInfo) XXX_Size Uses

func (m *DataDistributionResponse_TableInfo) XXX_Size() int

func (*DataDistributionResponse_TableInfo) XXX_Unmarshal Uses

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

type DataDistributionResponse_ZoneConfig Uses

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

func (*DataDistributionResponse_ZoneConfig) Descriptor Uses

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

func (*DataDistributionResponse_ZoneConfig) Marshal Uses

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

func (*DataDistributionResponse_ZoneConfig) MarshalTo Uses

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

func (*DataDistributionResponse_ZoneConfig) ProtoMessage Uses

func (*DataDistributionResponse_ZoneConfig) ProtoMessage()

func (*DataDistributionResponse_ZoneConfig) Reset Uses

func (m *DataDistributionResponse_ZoneConfig) Reset()

func (*DataDistributionResponse_ZoneConfig) Size Uses

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

func (*DataDistributionResponse_ZoneConfig) String Uses

func (m *DataDistributionResponse_ZoneConfig) String() string

func (*DataDistributionResponse_ZoneConfig) Unmarshal Uses

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

func (*DataDistributionResponse_ZoneConfig) XXX_DiscardUnknown Uses

func (m *DataDistributionResponse_ZoneConfig) XXX_DiscardUnknown()

func (*DataDistributionResponse_ZoneConfig) XXX_Marshal Uses

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

func (*DataDistributionResponse_ZoneConfig) XXX_Merge Uses

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

func (*DataDistributionResponse_ZoneConfig) XXX_Size Uses

func (m *DataDistributionResponse_ZoneConfig) XXX_Size() int

func (*DataDistributionResponse_ZoneConfig) XXX_Unmarshal Uses

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

type DatabaseDetailsRequest Uses

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

DatabaseDetailsRequest requests detailed information about the specified database

func (*DatabaseDetailsRequest) Descriptor Uses

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

func (*DatabaseDetailsRequest) Marshal Uses

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

func (*DatabaseDetailsRequest) MarshalTo Uses

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

func (*DatabaseDetailsRequest) ProtoMessage Uses

func (*DatabaseDetailsRequest) ProtoMessage()

func (*DatabaseDetailsRequest) Reset Uses

func (m *DatabaseDetailsRequest) Reset()

func (*DatabaseDetailsRequest) Size Uses

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

func (*DatabaseDetailsRequest) String Uses

func (m *DatabaseDetailsRequest) String() string

func (*DatabaseDetailsRequest) Unmarshal Uses

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

func (*DatabaseDetailsRequest) XXX_DiscardUnknown Uses

func (m *DatabaseDetailsRequest) XXX_DiscardUnknown()

func (*DatabaseDetailsRequest) XXX_Marshal Uses

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

func (*DatabaseDetailsRequest) XXX_Merge Uses

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

func (*DatabaseDetailsRequest) XXX_Size Uses

func (m *DatabaseDetailsRequest) XXX_Size() int

func (*DatabaseDetailsRequest) XXX_Unmarshal Uses

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

type DatabaseDetailsResponse Uses

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

DatabaseDetailsResponse contains grant information and table names for a database.

func (*DatabaseDetailsResponse) Descriptor Uses

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

func (*DatabaseDetailsResponse) Marshal Uses

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

func (*DatabaseDetailsResponse) MarshalTo Uses

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

func (*DatabaseDetailsResponse) ProtoMessage Uses

func (*DatabaseDetailsResponse) ProtoMessage()

func (*DatabaseDetailsResponse) Reset Uses

func (m *DatabaseDetailsResponse) Reset()

func (*DatabaseDetailsResponse) Size Uses

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

func (*DatabaseDetailsResponse) String Uses

func (m *DatabaseDetailsResponse) String() string

func (*DatabaseDetailsResponse) Unmarshal Uses

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

func (*DatabaseDetailsResponse) XXX_DiscardUnknown Uses

func (m *DatabaseDetailsResponse) XXX_DiscardUnknown()

func (*DatabaseDetailsResponse) XXX_Marshal Uses

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

func (*DatabaseDetailsResponse) XXX_Merge Uses

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

func (*DatabaseDetailsResponse) XXX_Size Uses

func (m *DatabaseDetailsResponse) XXX_Size() int

func (*DatabaseDetailsResponse) XXX_Unmarshal Uses

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

type DatabaseDetailsResponse_Grant Uses

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

func (*DatabaseDetailsResponse_Grant) Descriptor Uses

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

func (*DatabaseDetailsResponse_Grant) Marshal Uses

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

func (*DatabaseDetailsResponse_Grant) MarshalTo Uses

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

func (*DatabaseDetailsResponse_Grant) ProtoMessage Uses

func (*DatabaseDetailsResponse_Grant) ProtoMessage()

func (*DatabaseDetailsResponse_Grant) Reset Uses

func (m *DatabaseDetailsResponse_Grant) Reset()

func (*DatabaseDetailsResponse_Grant) Size Uses

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

func (*DatabaseDetailsResponse_Grant) String Uses

func (m *DatabaseDetailsResponse_Grant) String() string

func (*DatabaseDetailsResponse_Grant) Unmarshal Uses

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

func (*DatabaseDetailsResponse_Grant) XXX_DiscardUnknown Uses

func (m *DatabaseDetailsResponse_Grant) XXX_DiscardUnknown()

func (*DatabaseDetailsResponse_Grant) XXX_Marshal Uses

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

func (*DatabaseDetailsResponse_Grant) XXX_Merge Uses

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

func (*DatabaseDetailsResponse_Grant) XXX_Size Uses

func (m *DatabaseDetailsResponse_Grant) XXX_Size() int

func (*DatabaseDetailsResponse_Grant) XXX_Unmarshal Uses

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

type DatabasesRequest Uses

type DatabasesRequest struct {
}

DatabasesRequest requests a list of databases.

func (*DatabasesRequest) Descriptor Uses

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

func (*DatabasesRequest) Marshal Uses

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

func (*DatabasesRequest) MarshalTo Uses

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

func (*DatabasesRequest) ProtoMessage Uses

func (*DatabasesRequest) ProtoMessage()

func (*DatabasesRequest) Reset Uses

func (m *DatabasesRequest) Reset()

func (*DatabasesRequest) Size Uses

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

func (*DatabasesRequest) String Uses

func (m *DatabasesRequest) String() string

func (*DatabasesRequest) Unmarshal Uses

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

func (*DatabasesRequest) XXX_DiscardUnknown Uses

func (m *DatabasesRequest) XXX_DiscardUnknown()

func (*DatabasesRequest) XXX_Marshal Uses

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

func (*DatabasesRequest) XXX_Merge Uses

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

func (*DatabasesRequest) XXX_Size Uses

func (m *DatabasesRequest) XXX_Size() int

func (*DatabasesRequest) XXX_Unmarshal Uses

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

type DatabasesResponse Uses

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

DatabasesResponse contains a list of databases.

func (*DatabasesResponse) Descriptor Uses

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

func (*DatabasesResponse) Marshal Uses

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

func (*DatabasesResponse) MarshalTo Uses

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

func (*DatabasesResponse) ProtoMessage Uses

func (*DatabasesResponse) ProtoMessage()

func (*DatabasesResponse) Reset Uses

func (m *DatabasesResponse) Reset()

func (*DatabasesResponse) Size Uses

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

func (*DatabasesResponse) String Uses

func (m *DatabasesResponse) String() string

func (*DatabasesResponse) Unmarshal Uses

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

func (*DatabasesResponse) XXX_DiscardUnknown Uses

func (m *DatabasesResponse) XXX_DiscardUnknown()

func (*DatabasesResponse) XXX_Marshal Uses

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

func (*DatabasesResponse) XXX_Merge Uses

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

func (*DatabasesResponse) XXX_Size Uses

func (m *DatabasesResponse) XXX_Size() int

func (*DatabasesResponse) XXX_Unmarshal Uses

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

type DecommissionRequest Uses

type DecommissionRequest struct {
    NodeIDs          []github_com_cockroachdb_cockroach_pkg_roachpb.NodeID `protobuf:"varint,1,rep,packed,name=node_ids,json=nodeIds,proto3,casttype=github.com/cockroachdb/cockroach/pkg/roachpb.NodeID" json:"node_ids,omitempty"`
    TargetMembership kvserverpb.MembershipStatus                           `protobuf:"varint,2,opt,name=target_membership,json=targetMembership,proto3,enum=cockroach.kv.kvserver.storagepb.MembershipStatus" json:"target_membership,omitempty"`
}

DecommissionRequest requests the server to set the membership status on all nodes specified by NodeIDs to the value of TargetMembership.

If no NodeIDs are given, it targets the recipient node.

func (*DecommissionRequest) Descriptor Uses

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

func (*DecommissionRequest) Marshal Uses

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

func (*DecommissionRequest) MarshalTo Uses

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

func (*DecommissionRequest) ProtoMessage Uses

func (*DecommissionRequest) ProtoMessage()

func (*DecommissionRequest) Reset Uses

func (m *DecommissionRequest) Reset()

func (*DecommissionRequest) Size Uses

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

func (*DecommissionRequest) String Uses

func (m *DecommissionRequest) String() string

func (*DecommissionRequest) Unmarshal Uses

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

func (*DecommissionRequest) XXX_DiscardUnknown Uses

func (m *DecommissionRequest) XXX_DiscardUnknown()

func (*DecommissionRequest) XXX_Marshal Uses

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

func (*DecommissionRequest) XXX_Merge Uses

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

func (*DecommissionRequest) XXX_Size Uses

func (m *DecommissionRequest) XXX_Size() int

func (*DecommissionRequest) XXX_Unmarshal Uses

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

type DecommissionStatusRequest Uses

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

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

func (*DecommissionStatusRequest) Descriptor Uses

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

func (*DecommissionStatusRequest) Marshal Uses

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

func (*DecommissionStatusRequest) MarshalTo Uses

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

func (*DecommissionStatusRequest) ProtoMessage Uses

func (*DecommissionStatusRequest) ProtoMessage()

func (*DecommissionStatusRequest) Reset Uses

func (m *DecommissionStatusRequest) Reset()

func (*DecommissionStatusRequest) Size Uses

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

func (*DecommissionStatusRequest) String Uses

func (m *DecommissionStatusRequest) String() string

func (*DecommissionStatusRequest) Unmarshal Uses

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

func (*DecommissionStatusRequest) XXX_DiscardUnknown Uses

func (m *DecommissionStatusRequest) XXX_DiscardUnknown()

func (*DecommissionStatusRequest) XXX_Marshal Uses

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

func (*DecommissionStatusRequest) XXX_Merge Uses

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

func (*DecommissionStatusRequest) XXX_Size Uses

func (m *DecommissionStatusRequest) XXX_Size() int

func (*DecommissionStatusRequest) XXX_Unmarshal Uses

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

type DecommissionStatusResponse Uses

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

DecommissionStatusResponse lists decommissioning statuses for a number of NodeIDs.

func (*DecommissionStatusResponse) Descriptor Uses

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

func (*DecommissionStatusResponse) Marshal Uses

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

func (*DecommissionStatusResponse) MarshalTo Uses

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

func (*DecommissionStatusResponse) ProtoMessage Uses

func (*DecommissionStatusResponse) ProtoMessage()

func (*DecommissionStatusResponse) Reset Uses

func (m *DecommissionStatusResponse) Reset()

func (*DecommissionStatusResponse) Size Uses

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

func (*DecommissionStatusResponse) String Uses

func (m *DecommissionStatusResponse) String() string

func (*DecommissionStatusResponse) Unmarshal Uses

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

func (*DecommissionStatusResponse) XXX_DiscardUnknown Uses

func (m *DecommissionStatusResponse) XXX_DiscardUnknown()

func (*DecommissionStatusResponse) XXX_Marshal Uses

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

func (*DecommissionStatusResponse) XXX_Merge Uses

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

func (*DecommissionStatusResponse) XXX_Size Uses

func (m *DecommissionStatusResponse) XXX_Size() int

func (*DecommissionStatusResponse) XXX_Unmarshal Uses

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

type DecommissionStatusResponse_Status Uses

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

func (*DecommissionStatusResponse_Status) Descriptor Uses

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

func (*DecommissionStatusResponse_Status) Marshal Uses

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

func (*DecommissionStatusResponse_Status) MarshalTo Uses

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

func (*DecommissionStatusResponse_Status) ProtoMessage Uses

func (*DecommissionStatusResponse_Status) ProtoMessage()

func (*DecommissionStatusResponse_Status) Reset Uses

func (m *DecommissionStatusResponse_Status) Reset()

func (*DecommissionStatusResponse_Status) Size Uses

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

func (*DecommissionStatusResponse_Status) String Uses

func (m *DecommissionStatusResponse_Status) String() string

func (*DecommissionStatusResponse_Status) Unmarshal Uses

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

func (*DecommissionStatusResponse_Status) XXX_DiscardUnknown Uses

func (m *DecommissionStatusResponse_Status) XXX_DiscardUnknown()

func (*DecommissionStatusResponse_Status) XXX_Marshal Uses

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

func (*DecommissionStatusResponse_Status) XXX_Merge Uses

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

func (*DecommissionStatusResponse_Status) XXX_Size Uses

func (m *DecommissionStatusResponse_Status) XXX_Size() int

func (*DecommissionStatusResponse_Status) XXX_Unmarshal Uses

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

type DetailsRequest Uses

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

DetailsRequest requests a nodes details. Note: this does *not* check readiness. Use the Health RPC for that purpose.

func (*DetailsRequest) Descriptor Uses

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

func (*DetailsRequest) Marshal Uses

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

func (*DetailsRequest) MarshalTo Uses

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

func (*DetailsRequest) ProtoMessage Uses

func (*DetailsRequest) ProtoMessage()

func (*DetailsRequest) Reset Uses

func (m *DetailsRequest) Reset()

func (*DetailsRequest) Size Uses

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

func (*DetailsRequest) String Uses

func (m *DetailsRequest) String() string

func (*DetailsRequest) Unmarshal Uses

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

func (*DetailsRequest) XXX_DiscardUnknown Uses

func (m *DetailsRequest) XXX_DiscardUnknown()

func (*DetailsRequest) XXX_Marshal Uses

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

func (*DetailsRequest) XXX_Merge Uses

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

func (*DetailsRequest) XXX_Size Uses

func (m *DetailsRequest) XXX_Size() int

func (*DetailsRequest) XXX_Unmarshal Uses

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

type DetailsResponse Uses

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

func (*DetailsResponse) Descriptor Uses

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

func (*DetailsResponse) Marshal Uses

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

func (*DetailsResponse) MarshalTo Uses

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

func (*DetailsResponse) ProtoMessage Uses

func (*DetailsResponse) ProtoMessage()

func (*DetailsResponse) Reset Uses

func (m *DetailsResponse) Reset()

func (*DetailsResponse) Size Uses

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

func (*DetailsResponse) String Uses

func (m *DetailsResponse) String() string

func (*DetailsResponse) Unmarshal Uses

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

func (*DetailsResponse) XXX_DiscardUnknown Uses

func (m *DetailsResponse) XXX_DiscardUnknown()

func (*DetailsResponse) XXX_Marshal Uses

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

func (*DetailsResponse) XXX_Merge Uses

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

func (*DetailsResponse) XXX_Size Uses

func (m *DetailsResponse) XXX_Size() int

func (*DetailsResponse) XXX_Unmarshal Uses

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

type DiagnosticsRequest Uses

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

DiagnosticsRequest requests a diagnostics report.

func (*DiagnosticsRequest) Descriptor Uses

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

func (*DiagnosticsRequest) Marshal Uses

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

func (*DiagnosticsRequest) MarshalTo Uses

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

func (*DiagnosticsRequest) ProtoMessage Uses

func (*DiagnosticsRequest) ProtoMessage()

func (*DiagnosticsRequest) Reset Uses

func (m *DiagnosticsRequest) Reset()

func (*DiagnosticsRequest) Size Uses

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

func (*DiagnosticsRequest) String Uses

func (m *DiagnosticsRequest) String() string

func (*DiagnosticsRequest) Unmarshal Uses

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

func (*DiagnosticsRequest) XXX_DiscardUnknown Uses

func (m *DiagnosticsRequest) XXX_DiscardUnknown()

func (*DiagnosticsRequest) XXX_Marshal Uses

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

func (*DiagnosticsRequest) XXX_Merge Uses

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

func (*DiagnosticsRequest) XXX_Size Uses

func (m *DiagnosticsRequest) XXX_Size() int

func (*DiagnosticsRequest) XXX_Unmarshal Uses

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

type DrainRequest Uses

type DrainRequest struct {
    // deprecated_probe_indicator works as follows:
    // - if nil, it indicates that the request is a probe only and
    //   the server should not actually drain. This indicator
    //   is supported for pre-20.1 RPC clients which do not know
    //   about the skip_drain field below.
    // - if non-nil, it must be exactly equal to the slice [0, 1].
    //   Other values result in an error. When non-nil,
    //   it implies do_drain = true regardless of the value of the
    //   other field (pre-20.1 clients don't populate the other field).
    //
    // This field will be removed in 20.2 in favor of
    // do_drain below.
    DeprecatedProbeIndicator []int32 `protobuf:"varint,1,rep,packed,name=deprecated_probe_indicator,json=deprecatedProbeIndicator,proto3" json:"deprecated_probe_indicator,omitempty"`
    // When true, terminates the process after the server has started draining.
    // Setting both shutdown and do_drain to false causes
    // the request to only operate as a probe.
    // Setting do_drain to false and shutdown to true causes
    // the server to shut down immediately without
    // first draining.
    Shutdown bool `protobuf:"varint,3,opt,name=shutdown,proto3" json:"shutdown,omitempty"`
    // When true, perform the drain phase. See the comment above on
    // shutdown for an explanation of the interaction between the two.
    // do_drain is also implied by a non-nil deprecated_probe_indicator.
    DoDrain bool `protobuf:"varint,4,opt,name=do_drain,json=doDrain,proto3" json:"do_drain,omitempty"`
}

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

func (*DrainRequest) Descriptor Uses

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

func (*DrainRequest) Marshal Uses

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

func (*DrainRequest) MarshalTo Uses

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

func (*DrainRequest) ProtoMessage Uses

func (*DrainRequest) ProtoMessage()

func (*DrainRequest) Reset Uses

func (m *DrainRequest) Reset()

func (*DrainRequest) Size Uses

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

func (*DrainRequest) String Uses

func (m *DrainRequest) String() string

func (*DrainRequest) Unmarshal Uses

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

func (*DrainRequest) XXX_DiscardUnknown Uses

func (m *DrainRequest) XXX_DiscardUnknown()

func (*DrainRequest) XXX_Marshal Uses

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

func (*DrainRequest) XXX_Merge Uses

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

func (*DrainRequest) XXX_Size Uses

func (m *DrainRequest) XXX_Size() int

func (*DrainRequest) XXX_Unmarshal Uses

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

type DrainResponse Uses

type DrainResponse struct {
    // deprecated_drain_status works as follows:
    // - if the server is NOT currently draining,
    //   it will be set to an empty or nil slice.
    // - a non-nil slice indicates the server is currently
    //   draining.
    //
    // This field exists for the benefit of 19.x clients
    // and will be removed in 20.2.
    DeprecatedDrainStatus []int32 `protobuf:"varint,1,rep,packed,name=deprecated_drain_status,json=deprecatedDrainStatus,proto3" json:"deprecated_drain_status,omitempty"`
    // is_draining is set to true iff the server is currently draining.
    // This is set to true in response to a request where skip_drain
    // is false; but it can also be set to true in response
    // to a probe request (!shutdown && skip_drain) if another
    // drain request has been issued prior or asynchronously.
    IsDraining bool `protobuf:"varint,2,opt,name=is_draining,json=isDraining,proto3" json:"is_draining,omitempty"`
    // drain_remaining_indicator measures, at the time of starting to
    // process the corresponding drain request, how many actions to
    // fully drain the node were deemed to be necessary. Some, but not
    // all, of these actions may already have been carried out by the
    // time this indicator is received by the client. The client should
    // issue requests until this indicator first reaches zero, which
    // indicates that the node is fully drained.
    //
    // The API contract is the following:
    //
    // - upon a first Drain call with do_drain set, the remaining
    //   indicator will have some value >=0. If >0, it indicates that
    //   drain is pushing state away from the node. (What this state
    //   precisely means is left unspecified for this field. See below
    //   for details.)
    //
    // - upon a subsequent Drain call with do_drain set, the remaining
    //   indicator should have reduced in value. The drain process does best
    //   effort at shedding state away from the node; hopefully, all the
    //   state is shed away upon the first call and the progress
    //   indicator can be zero as early as the second call. However,
    //   if there was a lot of state to shed, it is possible for
    //   timeout to be encountered upon the first call. In that case, the
    //   second call will do some more work and return a non-zero value
    //   as well.
    //
    // - eventually, in an iterated sequence of DrainRequests with
    //   do_drain set, the remaining indicator should reduce to zero. At
    //   that point the client can conclude that no state is left to
    //   shed, and it should be safe to shut down the node with a
    //   DrainRequest with shutdown = true.
    //
    // Note that this field is left unpopulated (and thus remains at
    // zero) for pre-20.1 nodes. A client can recognize this by
    // observing is_draining to be false after a request with do_drain =
    // true: the is_draining field is also left unpopulated by pre-20.1
    // nodes.
    DrainRemainingIndicator uint64 `protobuf:"varint,3,opt,name=drain_remaining_indicator,json=drainRemainingIndicator,proto3" json:"drain_remaining_indicator,omitempty"`
    // drain_remaining_description is an informal (= not
    // machine-parsable) string that explains the progress of the drain
    // process to human eyes. This is intended for use mainly for
    // troubleshooting.
    //
    // The field is only populated if do_drain is true in the
    // request.
    DrainRemainingDescription string `protobuf:"bytes,4,opt,name=drain_remaining_description,json=drainRemainingDescription,proto3" json:"drain_remaining_description,omitempty"`
}

DrainResponse is the response to a successful DrainRequest.

func (*DrainResponse) Descriptor Uses

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

func (*DrainResponse) Marshal Uses

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

func (*DrainResponse) MarshalTo Uses

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

func (*DrainResponse) ProtoMessage Uses

func (*DrainResponse) ProtoMessage()

func (*DrainResponse) Reset Uses

func (m *DrainResponse) Reset()

func (*DrainResponse) Size Uses

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

func (*DrainResponse) String Uses

func (m *DrainResponse) String() string

func (*DrainResponse) Unmarshal Uses

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

func (*DrainResponse) XXX_DiscardUnknown Uses

func (m *DrainResponse) XXX_DiscardUnknown()

func (*DrainResponse) XXX_Marshal Uses

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

func (*DrainResponse) XXX_Merge Uses

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

func (*DrainResponse) XXX_Size Uses

func (m *DrainResponse) XXX_Size() int

func (*DrainResponse) XXX_Unmarshal Uses

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

type EngineStatsInfo Uses

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

func (*EngineStatsInfo) Descriptor Uses

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

func (*EngineStatsInfo) Marshal Uses

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

func (*EngineStatsInfo) MarshalTo Uses

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

func (*EngineStatsInfo) ProtoMessage Uses

func (*EngineStatsInfo) ProtoMessage()

func (*EngineStatsInfo) Reset Uses

func (m *EngineStatsInfo) Reset()

func (*EngineStatsInfo) Size Uses

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

func (*EngineStatsInfo) String Uses

func (m *EngineStatsInfo) String() string

func (*EngineStatsInfo) Unmarshal Uses

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

func (*EngineStatsInfo) XXX_DiscardUnknown Uses

func (m *EngineStatsInfo) XXX_DiscardUnknown()

func (*EngineStatsInfo) XXX_Marshal Uses

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

func (*EngineStatsInfo) XXX_Merge Uses

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

func (*EngineStatsInfo) XXX_Size Uses

func (m *EngineStatsInfo) XXX_Size() int

func (*EngineStatsInfo) XXX_Unmarshal Uses

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

type EngineStatsRequest Uses

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

func (*EngineStatsRequest) Descriptor Uses

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

func (*EngineStatsRequest) Marshal Uses

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

func (*EngineStatsRequest) MarshalTo Uses

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

func (*EngineStatsRequest) ProtoMessage Uses

func (*EngineStatsRequest) ProtoMessage()

func (*EngineStatsRequest) Reset Uses

func (m *EngineStatsRequest) Reset()

func (*EngineStatsRequest) Size Uses

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

func (*EngineStatsRequest) String Uses

func (m *EngineStatsRequest) String() string

func (*EngineStatsRequest) Unmarshal Uses

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

func (*EngineStatsRequest) XXX_DiscardUnknown Uses

func (m *EngineStatsRequest) XXX_DiscardUnknown()

func (*EngineStatsRequest) XXX_Marshal Uses

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

func (*EngineStatsRequest) XXX_Merge Uses

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

func (*EngineStatsRequest) XXX_Size Uses

func (m *EngineStatsRequest) XXX_Size() int

func (*EngineStatsRequest) XXX_Unmarshal Uses

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

type EngineStatsResponse Uses

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

func (*EngineStatsResponse) Descriptor Uses

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

func (*EngineStatsResponse) Marshal Uses

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

func (*EngineStatsResponse) MarshalTo Uses

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

func (*EngineStatsResponse) ProtoMessage Uses

func (*EngineStatsResponse) ProtoMessage()

func (*EngineStatsResponse) Reset Uses

func (m *EngineStatsResponse) Reset()

func (*EngineStatsResponse) Size Uses

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

func (*EngineStatsResponse) String Uses

func (m *EngineStatsResponse) String() string

func (*EngineStatsResponse) Unmarshal Uses

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

func (*EngineStatsResponse) XXX_DiscardUnknown Uses

func (m *EngineStatsResponse) XXX_DiscardUnknown()

func (*EngineStatsResponse) XXX_Marshal Uses

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

func (*EngineStatsResponse) XXX_Merge Uses

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

func (*EngineStatsResponse) XXX_Size Uses

func (m *EngineStatsResponse) XXX_Size() int

func (*EngineStatsResponse) XXX_Unmarshal Uses

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

type EnqueueRangeRequest Uses

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

func (*EnqueueRangeRequest) Descriptor Uses

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

func (*EnqueueRangeRequest) Marshal Uses

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

func (*EnqueueRangeRequest) MarshalTo Uses

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

func (*EnqueueRangeRequest) ProtoMessage Uses

func (*EnqueueRangeRequest) ProtoMessage()

func (*EnqueueRangeRequest) Reset Uses

func (m *EnqueueRangeRequest) Reset()

func (*EnqueueRangeRequest) Size Uses

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

func (*EnqueueRangeRequest) String Uses

func (m *EnqueueRangeRequest) String() string

func (*EnqueueRangeRequest) Unmarshal Uses

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

func (*EnqueueRangeRequest) XXX_DiscardUnknown Uses

func (m *EnqueueRangeRequest) XXX_DiscardUnknown()

func (*EnqueueRangeRequest) XXX_Marshal Uses

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

func (*EnqueueRangeRequest) XXX_Merge Uses

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

func (*EnqueueRangeRequest) XXX_Size Uses

func (m *EnqueueRangeRequest) XXX_Size() int

func (*EnqueueRangeRequest) XXX_Unmarshal Uses

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

type EnqueueRangeResponse Uses

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

func (*EnqueueRangeResponse) Descriptor Uses

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

func (*EnqueueRangeResponse) Marshal Uses

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

func (*EnqueueRangeResponse) MarshalTo Uses

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

func (*EnqueueRangeResponse) ProtoMessage Uses

func (*EnqueueRangeResponse) ProtoMessage()

func (*EnqueueRangeResponse) Reset Uses

func (m *EnqueueRangeResponse) Reset()

func (*EnqueueRangeResponse) Size Uses

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

func (*EnqueueRangeResponse) String Uses

func (m *EnqueueRangeResponse) String() string

func (*EnqueueRangeResponse) Unmarshal Uses

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

func (*EnqueueRangeResponse) XXX_DiscardUnknown Uses

func (m *EnqueueRangeResponse) XXX_DiscardUnknown()

func (*EnqueueRangeResponse) XXX_Marshal Uses

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

func (*EnqueueRangeResponse) XXX_Merge Uses

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

func (*EnqueueRangeResponse) XXX_Size Uses

func (m *EnqueueRangeResponse) XXX_Size() int

func (*EnqueueRangeResponse) XXX_Unmarshal Uses

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

type EnqueueRangeResponse_Details Uses

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

func (*EnqueueRangeResponse_Details) Descriptor Uses

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

func (*EnqueueRangeResponse_Details) Marshal Uses

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

func (*EnqueueRangeResponse_Details) MarshalTo Uses

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

func (*EnqueueRangeResponse_Details) ProtoMessage Uses

func (*EnqueueRangeResponse_Details) ProtoMessage()

func (*EnqueueRangeResponse_Details) Reset Uses

func (m *EnqueueRangeResponse_Details) Reset()

func (*EnqueueRangeResponse_Details) Size Uses

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

func (*EnqueueRangeResponse_Details) String Uses

func (m *EnqueueRangeResponse_Details) String() string

func (*EnqueueRangeResponse_Details) Unmarshal Uses

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

func (*EnqueueRangeResponse_Details) XXX_DiscardUnknown Uses

func (m *EnqueueRangeResponse_Details) XXX_DiscardUnknown()

func (*EnqueueRangeResponse_Details) XXX_Marshal Uses

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

func (*EnqueueRangeResponse_Details) XXX_Merge Uses

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

func (*EnqueueRangeResponse_Details) XXX_Size Uses

func (m *EnqueueRangeResponse_Details) XXX_Size() int

func (*EnqueueRangeResponse_Details) XXX_Unmarshal Uses

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

type EventsRequest Uses

type EventsRequest struct {
    Type     string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
    TargetId int64  `protobuf:"varint,2,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
    // limit is the total number of results that are retrieved by the query. If
    // this is omitted or set to 0, the default maximum number of results are
    // returned. When set to > 0, at most only that number of results are
    // returned. When set to < 0, an unlimited number of results are returned.
    Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
    // unredacted_events indicates that the values in the events should
    // not be redacted. The default is to redact, so that older versions
    // of `cockroach zip` do not see un-redacted values by default.
    // For good security, this field is only obeyed by the server after
    // checking that the client of the RPC is an admin user.
    UnredactedEvents bool `protobuf:"varint,4,opt,name=unredacted_events,json=unredactedEvents,proto3" json:"unredacted_events,omitempty"`
}

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

func (*EventsRequest) Descriptor Uses

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

func (*EventsRequest) Marshal Uses

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

func (*EventsRequest) MarshalTo Uses

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

func (*EventsRequest) ProtoMessage Uses

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) Reset Uses

func (m *EventsRequest) Reset()

func (*EventsRequest) Size Uses

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

func (*EventsRequest) String Uses

func (m *EventsRequest) String() string

func (*EventsRequest) Unmarshal Uses

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

func (*EventsRequest) XXX_DiscardUnknown Uses

func (m *EventsRequest) XXX_DiscardUnknown()

func (*EventsRequest) XXX_Marshal Uses

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

func (*EventsRequest) XXX_Merge Uses

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

func (*EventsRequest) XXX_Size Uses

func (m *EventsRequest) XXX_Size() int

func (*EventsRequest) XXX_Unmarshal Uses

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

type EventsResponse Uses

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

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

func (*EventsResponse) Descriptor Uses

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

func (*EventsResponse) Marshal Uses

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

func (*EventsResponse) MarshalTo Uses

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

func (*EventsResponse) ProtoMessage Uses

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) Reset Uses

func (m *EventsResponse) Reset()

func (*EventsResponse) Size Uses

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

func (*EventsResponse) String Uses

func (m *EventsResponse) String() string

func (*EventsResponse) Unmarshal Uses

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

func (*EventsResponse) XXX_DiscardUnknown Uses

func (m *EventsResponse) XXX_DiscardUnknown()

func (*EventsResponse) XXX_Marshal Uses

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

func (*EventsResponse) XXX_Merge Uses

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

func (*EventsResponse) XXX_Size Uses

func (m *EventsResponse) XXX_Size() int

func (*EventsResponse) XXX_Unmarshal Uses

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

type EventsResponse_Event Uses

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

func (*EventsResponse_Event) Descriptor Uses

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

func (*EventsResponse_Event) Marshal Uses

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

func (*EventsResponse_Event) MarshalTo Uses

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

func (*EventsResponse_Event) ProtoMessage Uses

func (*EventsResponse_Event) ProtoMessage()

func (*EventsResponse_Event) Reset Uses

func (m *EventsResponse_Event) Reset()

func (*EventsResponse_Event) Size Uses

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

func (*EventsResponse_Event) String Uses

func (m *EventsResponse_Event) String() string

func (*EventsResponse_Event) Unmarshal Uses

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

func (*EventsResponse_Event) XXX_DiscardUnknown Uses

func (m *EventsResponse_Event) XXX_DiscardUnknown()

func (*EventsResponse_Event) XXX_Marshal Uses

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

func (*EventsResponse_Event) XXX_Merge Uses

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

func (*EventsResponse_Event) XXX_Size Uses

func (m *EventsResponse_Event) XXX_Size() int

func (*EventsResponse_Event) XXX_Unmarshal Uses

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

type File Uses

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

func (*File) Descriptor Uses

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

func (*File) Marshal Uses

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

func (*File) MarshalTo Uses

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

func (*File) ProtoMessage Uses

func (*File) ProtoMessage()

func (*File) Reset Uses

func (m *File) Reset()

func (*File) Size Uses

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

func (*File) String Uses

func (m *File) String() string

func (*File) Unmarshal Uses

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

func (*File) XXX_DiscardUnknown Uses

func (m *File) XXX_DiscardUnknown()

func (*File) XXX_Marshal Uses

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

func (*File) XXX_Merge Uses

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

func (*File) XXX_Size Uses

func (m *File) XXX_Size() int

func (*File) XXX_Unmarshal Uses

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

type FileType Uses

type FileType int32

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

const (
    FileType_HEAP       FileType = 0
    FileType_GOROUTINES FileType = 1
)

func (FileType) EnumDescriptor Uses

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

func (FileType) String Uses

func (x FileType) String() string

type GetFilesRequest Uses

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

func (*GetFilesRequest) Descriptor Uses

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

func (*GetFilesRequest) Marshal Uses

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

func (*GetFilesRequest) MarshalTo Uses

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

func (*GetFilesRequest) ProtoMessage Uses

func (*GetFilesRequest) ProtoMessage()

func (*GetFilesRequest) Reset Uses

func (m *GetFilesRequest) Reset()

func (*GetFilesRequest) Size Uses

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

func (*GetFilesRequest) String Uses

func (m *GetFilesRequest) String() string

func (*GetFilesRequest) Unmarshal Uses

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

func (*GetFilesRequest) XXX_DiscardUnknown Uses

func (m *GetFilesRequest) XXX_DiscardUnknown()

func (*GetFilesRequest) XXX_Marshal Uses

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

func (*GetFilesRequest) XXX_Merge Uses

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

func (*GetFilesRequest) XXX_Size Uses

func (m *GetFilesRequest) XXX_Size() int

func (*GetFilesRequest) XXX_Unmarshal Uses

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

type GetFilesResponse Uses

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

func (*GetFilesResponse) Descriptor Uses

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

func (*GetFilesResponse) Marshal Uses

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

func (*GetFilesResponse) MarshalTo Uses

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

func (*GetFilesResponse) ProtoMessage Uses

func (*GetFilesResponse) ProtoMessage()

func (*GetFilesResponse) Reset Uses

func (m *GetFilesResponse) Reset()

func (*GetFilesResponse) Size Uses