cockroach: github.com/cockroachdb/cockroach/pkg/jobs/jobspb Index | Files

package jobspb

import "github.com/cockroachdb/cockroach/pkg/jobs/jobspb"

Index

Package Files

jobs.pb.go schedule.pb.go wrap.go

Variables

var (
    ErrInvalidLengthJobs = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowJobs   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthSchedule = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowSchedule   = fmt.Errorf("proto: integer overflow")
)
var ScheduleDetails_ErrorHandlingBehavior_name = map[int32]string{
    0:  "RETRY_SCHED",
    1:  "RETRY_SOON",
    2:  "PAUSE_SCHED",
}
var ScheduleDetails_ErrorHandlingBehavior_value = map[string]int32{
    "RETRY_SCHED": 0,
    "RETRY_SOON":  1,
    "PAUSE_SCHED": 2,
}
var ScheduleDetails_WaitBehavior_name = map[int32]string{
    0:  "WAIT",
    1:  "NO_WAIT",
    2:  "SKIP",
}
var ScheduleDetails_WaitBehavior_value = map[string]int32{
    "WAIT":    0,
    "NO_WAIT": 1,
    "SKIP":    2,
}
var SchemaChangeGCProgress_Status_name = map[int32]string{
    0:  "WAITING_FOR_GC",
    1:  "DELETING",
    2:  "DELETED",
}
var SchemaChangeGCProgress_Status_value = map[string]int32{
    "WAITING_FOR_GC": 0,
    "DELETING":       1,
    "DELETED":        2,
}
var Status_name = map[int32]string{
    0:  "DRAINING_NAMES",
    1:  "WAIT_FOR_GC_INTERVAL",
    2:  "ROCKSDB_COMPACTION",
    10: "DONE",
}
var Status_value = map[string]int32{
    "DRAINING_NAMES":       0,
    "WAIT_FOR_GC_INTERVAL": 1,
    "ROCKSDB_COMPACTION":   2,
    "DONE":                 10,
}
var Type_name = map[int32]string{
    0:  "UNSPECIFIED",
    1:  "BACKUP",
    2:  "RESTORE",
    3:  "SCHEMA_CHANGE",
    4:  "IMPORT",
    5:  "CHANGEFEED",
    6:  "CREATE_STATS",
    7:  "AUTO_CREATE_STATS",
    8:  "SCHEMA_CHANGE_GC",
}
var Type_value = map[string]int32{
    "UNSPECIFIED":       0,
    "BACKUP":            1,
    "RESTORE":           2,
    "SCHEMA_CHANGE":     3,
    "IMPORT":            4,
    "CHANGEFEED":        5,
    "CREATE_STATS":      6,
    "AUTO_CREATE_STATS": 7,
    "SCHEMA_CHANGE_GC":  8,
}

func WrapPayloadDetails Uses

func WrapPayloadDetails(details Details) interface {
    isPayload_Details
}

WrapPayloadDetails wraps a Details object in the protobuf wrapper struct necessary to make it usable as the Details field of a Payload.

Providing an unknown details type indicates programmer error and so causes a panic.

func WrapProgressDetails Uses

func WrapProgressDetails(details ProgressDetails) interface {
    isProgress_Details
}

WrapProgressDetails wraps a ProgressDetails object in the protobuf wrapper struct necessary to make it usable as the Details field of a Progress.

Providing an unknown details type indicates programmer error and so causes a panic.

type BackupDetails Uses

type BackupDetails struct {
    StartTime hlc.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time"`
    EndTime   hlc.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time"`
    // URI is the URI for the main backup destination. For partitioned backups,
    // the main BACKUP manifest and files with no other specified destination are
    // written to this location. For regular backups, all files are written to
    // this location.
    URI string `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`
    // URIsByLocalityKV is a map of locality KVs to store URIs, used for
    // partitioned backups.
    URIsByLocalityKV map[string]string              `protobuf:"bytes,5,rep,name=uris_by_locality_kv,json=urisByLocalityKv,proto3" json:"uris_by_locality_kv,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    BackupManifest   []byte                         `protobuf:"bytes,4,opt,name=backup_manifest,json=backupManifest,proto3" json:"backup_manifest,omitempty"`
    Encryption       *roachpb.FileEncryptionOptions `protobuf:"bytes,6,opt,name=encryption,proto3" json:"encryption,omitempty"`
    // ProtectedTimestampRecord is the ID of the protected timestamp record
    // corresponding to this job. While the job ought to clean up the record
    // when it enters a terminal state, there may be cases where it cannot or
    // does not run the code to do so. To deal with this there is a background
    // reconcilliation loop to ensure that protected timestamps are cleaned up.
    ProtectedTimestampRecord *github_com_cockroachdb_cockroach_pkg_util_uuid.UUID `protobuf:"bytes,7,opt,name=protected_timestamp_record,json=protectedTimestampRecord,proto3,customtype=github.com/cockroachdb/cockroach/pkg/util/uuid.UUID" json:"protected_timestamp_record,omitempty"`
}

func (*BackupDetails) Descriptor Uses

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

func (*BackupDetails) Marshal Uses

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

func (*BackupDetails) MarshalTo Uses

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

func (*BackupDetails) ProtoMessage Uses

func (*BackupDetails) ProtoMessage()

func (*BackupDetails) Reset Uses

func (m *BackupDetails) Reset()

func (*BackupDetails) Size Uses

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

func (*BackupDetails) String Uses

func (m *BackupDetails) String() string

func (*BackupDetails) Unmarshal Uses

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

func (*BackupDetails) XXX_DiscardUnknown Uses

func (m *BackupDetails) XXX_DiscardUnknown()

func (*BackupDetails) XXX_Marshal Uses

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

func (*BackupDetails) XXX_Merge Uses

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

func (*BackupDetails) XXX_Size Uses

func (m *BackupDetails) XXX_Size() int

func (*BackupDetails) XXX_Unmarshal Uses

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

type BackupProgress Uses

type BackupProgress struct {
}

func (*BackupProgress) Descriptor Uses

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

func (*BackupProgress) Marshal Uses

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

func (*BackupProgress) MarshalTo Uses

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

func (*BackupProgress) ProtoMessage Uses

func (*BackupProgress) ProtoMessage()

func (*BackupProgress) Reset Uses

func (m *BackupProgress) Reset()

func (*BackupProgress) Size Uses

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

func (*BackupProgress) String Uses

func (m *BackupProgress) String() string

func (*BackupProgress) Unmarshal Uses

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

func (*BackupProgress) XXX_DiscardUnknown Uses

func (m *BackupProgress) XXX_DiscardUnknown()

func (*BackupProgress) XXX_Marshal Uses

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

func (*BackupProgress) XXX_Merge Uses

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

func (*BackupProgress) XXX_Size Uses

func (m *BackupProgress) XXX_Size() int

func (*BackupProgress) XXX_Unmarshal Uses

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

type ChangefeedDetails Uses

type ChangefeedDetails struct {
    // Targets contains the user-specified tables and databases to watch, mapping
    // the descriptor id to the name at the time of changefeed creating. There is
    // a 1:1 correspondance between unique targets in the original sql query and
    // entries in this map.
    //
    // - A watched table is stored here under its table id
    // - TODO(dan): A watched database is stored here under its database id
    // - TODO(dan): A db.* expansion is treated identicially to watching the
    //   database
    //
    // Note that the TODOs mean this field currently is guaranteed to only hold
    // table ids and a cluster version check will be added when this changes.
    //
    // The names at resolution time are included so that table and database
    // renames can be detected. They are also used to construct an error message
    // if the descriptor id no longer exists when the jobs is unpaused (which can
    // happen if it was dropped or truncated).
    Targets       ChangefeedTargets `protobuf:"bytes,6,rep,name=targets,proto3,casttype=ChangefeedTargets,castkey=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"targets" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    SinkURI       string            `protobuf:"bytes,3,opt,name=sink_uri,json=sinkUri,proto3" json:"sink_uri,omitempty"`
    Opts          map[string]string `protobuf:"bytes,4,rep,name=opts,proto3" json:"opts,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    StatementTime hlc.Timestamp     `protobuf:"bytes,7,opt,name=statement_time,json=statementTime,proto3" json:"statement_time"`
}

func (*ChangefeedDetails) Descriptor Uses

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

func (*ChangefeedDetails) Marshal Uses

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

func (*ChangefeedDetails) MarshalTo Uses

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

func (*ChangefeedDetails) ProtoMessage Uses

func (*ChangefeedDetails) ProtoMessage()

func (*ChangefeedDetails) Reset Uses

func (m *ChangefeedDetails) Reset()

func (*ChangefeedDetails) Size Uses

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

func (*ChangefeedDetails) String Uses

func (m *ChangefeedDetails) String() string

func (*ChangefeedDetails) Unmarshal Uses

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

func (*ChangefeedDetails) XXX_DiscardUnknown Uses

func (m *ChangefeedDetails) XXX_DiscardUnknown()

func (*ChangefeedDetails) XXX_Marshal Uses

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

func (*ChangefeedDetails) XXX_Merge Uses

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

func (*ChangefeedDetails) XXX_Size Uses

func (m *ChangefeedDetails) XXX_Size() int

func (*ChangefeedDetails) XXX_Unmarshal Uses

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

type ChangefeedProgress Uses

type ChangefeedProgress struct {
    ResolvedSpans []ResolvedSpan `protobuf:"bytes,2,rep,name=resolved_spans,json=resolvedSpans,proto3" json:"resolved_spans"`
    // ProtectedTimestampRecord is the ID of the protected timestamp record
    // corresponding to this job. While the job ought to clean up the record
    // when it enters a terminal state, there may be cases where it cannot or
    // does not run the code to do so. To deal with this there is a background
    // reconcilliation loop to ensure that protected timestamps are cleaned up.
    //
    // A record is created with the job if the job requires an initial backfill.
    // Furthermore, once subsequent backfills begin, record will be created and
    // released accordingly.
    ProtectedTimestampRecord github_com_cockroachdb_cockroach_pkg_util_uuid.UUID `protobuf:"bytes,3,opt,name=protected_timestamp_record,json=protectedTimestampRecord,proto3,customtype=github.com/cockroachdb/cockroach/pkg/util/uuid.UUID" json:"protected_timestamp_record"`
}

func (*ChangefeedProgress) Descriptor Uses

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

func (*ChangefeedProgress) Marshal Uses

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

func (*ChangefeedProgress) MarshalTo Uses

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

func (*ChangefeedProgress) ProtoMessage Uses

func (*ChangefeedProgress) ProtoMessage()

func (*ChangefeedProgress) Reset Uses

func (m *ChangefeedProgress) Reset()

func (*ChangefeedProgress) Size Uses

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

func (*ChangefeedProgress) String Uses

func (m *ChangefeedProgress) String() string

func (*ChangefeedProgress) Unmarshal Uses

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

func (*ChangefeedProgress) XXX_DiscardUnknown Uses

func (m *ChangefeedProgress) XXX_DiscardUnknown()

func (*ChangefeedProgress) XXX_Marshal Uses

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

func (*ChangefeedProgress) XXX_Merge Uses

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

func (*ChangefeedProgress) XXX_Size Uses

func (m *ChangefeedProgress) XXX_Size() int

func (*ChangefeedProgress) XXX_Unmarshal Uses

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

type ChangefeedTarget Uses

type ChangefeedTarget struct {
    StatementTimeName string `protobuf:"bytes,1,opt,name=statement_time_name,json=statementTimeName,proto3" json:"statement_time_name,omitempty"`
}

func (*ChangefeedTarget) Descriptor Uses

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

func (*ChangefeedTarget) Marshal Uses

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

func (*ChangefeedTarget) MarshalTo Uses

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

func (*ChangefeedTarget) ProtoMessage Uses

func (*ChangefeedTarget) ProtoMessage()

func (*ChangefeedTarget) Reset Uses

func (m *ChangefeedTarget) Reset()

func (*ChangefeedTarget) Size Uses

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

func (*ChangefeedTarget) String Uses

func (m *ChangefeedTarget) String() string

func (*ChangefeedTarget) Unmarshal Uses

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

func (*ChangefeedTarget) XXX_DiscardUnknown Uses

func (m *ChangefeedTarget) XXX_DiscardUnknown()

func (*ChangefeedTarget) XXX_Marshal Uses

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

func (*ChangefeedTarget) XXX_Merge Uses

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

func (*ChangefeedTarget) XXX_Size Uses

func (m *ChangefeedTarget) XXX_Size() int

func (*ChangefeedTarget) XXX_Unmarshal Uses

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

type ChangefeedTargets Uses

type ChangefeedTargets map[sqlbase.ID]ChangefeedTarget

ChangefeedTargets is a set of id targets with metadata.

type CreateStatsDetails Uses

type CreateStatsDetails struct {
    Name            string                       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    Table           sqlbase.TableDescriptor      `protobuf:"bytes,2,opt,name=table,proto3" json:"table"`
    ColumnStats     []CreateStatsDetails_ColStat `protobuf:"bytes,3,rep,name=column_stats,json=columnStats,proto3" json:"column_stats"`
    Statement       string                       `protobuf:"bytes,4,opt,name=statement,proto3" json:"statement,omitempty"`
    AsOf            *hlc.Timestamp               `protobuf:"bytes,5,opt,name=as_of,json=asOf,proto3" json:"as_of,omitempty"`
    MaxFractionIdle float64                      `protobuf:"fixed64,7,opt,name=max_fraction_idle,json=maxFractionIdle,proto3" json:"max_fraction_idle,omitempty"`
    // Fully qualified table name.
    FQTableName string `protobuf:"bytes,6,opt,name=fq_table_name,json=fqTableName,proto3" json:"fq_table_name,omitempty"`
}

CreateStatsDetails are used for the CreateStats job, which is triggered whenever the `CREATE STATISTICS` SQL statement is run. The CreateStats job collects table statistics, which contain info such as the number of rows in the table or the number of distinct values in a column.

func (*CreateStatsDetails) Descriptor Uses

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

func (*CreateStatsDetails) Marshal Uses

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

func (*CreateStatsDetails) MarshalTo Uses

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

func (*CreateStatsDetails) ProtoMessage Uses

func (*CreateStatsDetails) ProtoMessage()

func (*CreateStatsDetails) Reset Uses

func (m *CreateStatsDetails) Reset()

func (*CreateStatsDetails) Size Uses

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

func (*CreateStatsDetails) String Uses

func (m *CreateStatsDetails) String() string

func (*CreateStatsDetails) Unmarshal Uses

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

func (*CreateStatsDetails) XXX_DiscardUnknown Uses

func (m *CreateStatsDetails) XXX_DiscardUnknown()

func (*CreateStatsDetails) XXX_Marshal Uses

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

func (*CreateStatsDetails) XXX_Merge Uses

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

func (*CreateStatsDetails) XXX_Size Uses

func (m *CreateStatsDetails) XXX_Size() int

func (*CreateStatsDetails) XXX_Unmarshal Uses

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

type CreateStatsDetails_ColStat Uses

type CreateStatsDetails_ColStat struct {
    ColumnIDs []github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ColumnID `protobuf:"varint,1,rep,packed,name=column_ids,json=columnIds,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ColumnID" json:"column_ids,omitempty"`
    // Indicates whether this column stat should include a histogram.
    HasHistogram bool `protobuf:"varint,2,opt,name=has_histogram,json=hasHistogram,proto3" json:"has_histogram,omitempty"`
    // Indicates whether this column stat is over an inverted index.
    Inverted bool `protobuf:"varint,3,opt,name=inverted,proto3" json:"inverted,omitempty"`
}

func (*CreateStatsDetails_ColStat) Descriptor Uses

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

func (*CreateStatsDetails_ColStat) Marshal Uses

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

func (*CreateStatsDetails_ColStat) MarshalTo Uses

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

func (*CreateStatsDetails_ColStat) ProtoMessage Uses

func (*CreateStatsDetails_ColStat) ProtoMessage()

func (*CreateStatsDetails_ColStat) Reset Uses

func (m *CreateStatsDetails_ColStat) Reset()

func (*CreateStatsDetails_ColStat) Size Uses

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

func (*CreateStatsDetails_ColStat) String Uses

func (m *CreateStatsDetails_ColStat) String() string

func (*CreateStatsDetails_ColStat) Unmarshal Uses

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

func (*CreateStatsDetails_ColStat) XXX_DiscardUnknown Uses

func (m *CreateStatsDetails_ColStat) XXX_DiscardUnknown()

func (*CreateStatsDetails_ColStat) XXX_Marshal Uses

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

func (*CreateStatsDetails_ColStat) XXX_Merge Uses

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

func (*CreateStatsDetails_ColStat) XXX_Size Uses

func (m *CreateStatsDetails_ColStat) XXX_Size() int

func (*CreateStatsDetails_ColStat) XXX_Unmarshal Uses

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

type CreateStatsProgress Uses

type CreateStatsProgress struct {
}

func (*CreateStatsProgress) Descriptor Uses

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

func (*CreateStatsProgress) Marshal Uses

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

func (*CreateStatsProgress) MarshalTo Uses

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

func (*CreateStatsProgress) ProtoMessage Uses

func (*CreateStatsProgress) ProtoMessage()

func (*CreateStatsProgress) Reset Uses

func (m *CreateStatsProgress) Reset()

func (*CreateStatsProgress) Size Uses

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

func (*CreateStatsProgress) String Uses

func (m *CreateStatsProgress) String() string

func (*CreateStatsProgress) Unmarshal Uses

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

func (*CreateStatsProgress) XXX_DiscardUnknown Uses

func (m *CreateStatsProgress) XXX_DiscardUnknown()

func (*CreateStatsProgress) XXX_Marshal Uses

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

func (*CreateStatsProgress) XXX_Merge Uses

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

func (*CreateStatsProgress) XXX_Size Uses

func (m *CreateStatsProgress) XXX_Size() int

func (*CreateStatsProgress) XXX_Unmarshal Uses

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

type Details Uses

type Details interface{}

Details is a marker interface for job details proto structs.

type DroppedTableDetails Uses

type DroppedTableDetails struct {
    Name   string                                              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    ID     github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID `protobuf:"varint,2,opt,name=ID,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"ID,omitempty"`
    Status Status                                              `protobuf:"varint,3,opt,name=status,proto3,enum=cockroach.sql.jobs.jobspb.Status" json:"status,omitempty"`
}

func (*DroppedTableDetails) Descriptor Uses

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

func (*DroppedTableDetails) Marshal Uses

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

func (*DroppedTableDetails) MarshalTo Uses

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

func (*DroppedTableDetails) ProtoMessage Uses

func (*DroppedTableDetails) ProtoMessage()

func (*DroppedTableDetails) Reset Uses

func (m *DroppedTableDetails) Reset()

func (*DroppedTableDetails) Size Uses

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

func (*DroppedTableDetails) String Uses

func (m *DroppedTableDetails) String() string

func (*DroppedTableDetails) Unmarshal Uses

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

func (*DroppedTableDetails) XXX_DiscardUnknown Uses

func (m *DroppedTableDetails) XXX_DiscardUnknown()

func (*DroppedTableDetails) XXX_Marshal Uses

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

func (*DroppedTableDetails) XXX_Merge Uses

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

func (*DroppedTableDetails) XXX_Size Uses

func (m *DroppedTableDetails) XXX_Size() int

func (*DroppedTableDetails) XXX_Unmarshal Uses

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

type ExecutionArguments Uses

type ExecutionArguments struct {
    Args *types.Any `protobuf:"bytes,1,opt,name=args,proto3" json:"args,omitempty"`
}

ExecutionArguments describes data needed to execute scheduled jobs.

func (*ExecutionArguments) Descriptor Uses

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

func (*ExecutionArguments) Marshal Uses

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

func (*ExecutionArguments) MarshalTo Uses

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

func (*ExecutionArguments) ProtoMessage Uses

func (*ExecutionArguments) ProtoMessage()

func (*ExecutionArguments) Reset Uses

func (m *ExecutionArguments) Reset()

func (*ExecutionArguments) Size Uses

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

func (*ExecutionArguments) String Uses

func (m *ExecutionArguments) String() string

func (*ExecutionArguments) Unmarshal Uses

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

func (*ExecutionArguments) XXX_DiscardUnknown Uses

func (m *ExecutionArguments) XXX_DiscardUnknown()

func (*ExecutionArguments) XXX_Marshal Uses

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

func (*ExecutionArguments) XXX_Merge Uses

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

func (*ExecutionArguments) XXX_Size Uses

func (m *ExecutionArguments) XXX_Size() int

func (*ExecutionArguments) XXX_Unmarshal Uses

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

type ImportDetails Uses

type ImportDetails struct {
    Tables     []ImportDetails_Table                               `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables"`
    URIs       []string                                            `protobuf:"bytes,2,rep,name=uris,proto3" json:"uris,omitempty"`
    Format     roachpb.IOFileFormat                                `protobuf:"bytes,3,opt,name=format,proto3" json:"format"`
    SSTSize    int64                                               `protobuf:"varint,4,opt,name=sst_size,json=sstSize,proto3" json:"sst_size,omitempty"`
    Oversample int64                                               `protobuf:"varint,9,opt,name=oversample,proto3" json:"oversample,omitempty"`
    SkipFKs    bool                                                `protobuf:"varint,10,opt,name=skip_fks,json=skipFks,proto3" json:"skip_fks,omitempty"`
    Walltime   int64                                               `protobuf:"varint,5,opt,name=walltime,proto3" json:"walltime,omitempty"`
    ParentID   github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID `protobuf:"varint,6,opt,name=parent_id,json=parentId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"parent_id,omitempty"`
    BackupPath string                                              `protobuf:"bytes,7,opt,name=backup_path,json=backupPath,proto3" json:"backup_path,omitempty"`
    // samples is a sampling of cockroach KV keys generated from the input data.
    // It is populated with the sampling phase's results. These must be
    // used if a job is resumed to guarantee that AddSSTable will not attempt
    // to add ranges with an old split point within them.
    Samples [][]byte `protobuf:"bytes,8,rep,name=samples,proto3" json:"samples,omitempty"`
    // ingest_directly means the Import job directly ingests the data as readers
    // produce it instead of sampling it and then setting up a distsql shuffle and
    // sort that produced sorted, non-overlapping data to ingest. When ingesting
    // directly, many other fields like samples, oversample, sst_size are ignored.
    IngestDirectly  bool `protobuf:"varint,11,opt,name=ingest_directly,json=ingestDirectly,proto3" json:"ingest_directly,omitempty"`
    PrepareComplete bool `protobuf:"varint,12,opt,name=prepare_complete,json=prepareComplete,proto3" json:"prepare_complete,omitempty"`
    TablesPublished bool `protobuf:"varint,13,opt,name=tables_published,json=tablesPublished,proto3" json:"tables_published,omitempty"`
    // ProtectedTimestampRecord is the ID of the protected timestamp record
    // corresponding to this job. While the job ought to clean up the record
    // when it enters a terminal state, there may be cases where it cannot or
    // does not run the code to do so. To deal with this there is a background
    // reconcilliation loop to ensure that protected timestamps are cleaned up.
    ProtectedTimestampRecord *github_com_cockroachdb_cockroach_pkg_util_uuid.UUID `protobuf:"bytes,22,opt,name=protected_timestamp_record,json=protectedTimestampRecord,proto3,customtype=github.com/cockroachdb/cockroach/pkg/util/uuid.UUID" json:"protected_timestamp_record,omitempty"`
}

func (*ImportDetails) Descriptor Uses

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

func (*ImportDetails) Marshal Uses

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

func (*ImportDetails) MarshalTo Uses

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

func (*ImportDetails) ProtoMessage Uses

func (*ImportDetails) ProtoMessage()

func (*ImportDetails) Reset Uses

func (m *ImportDetails) Reset()

func (*ImportDetails) Size Uses

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

func (*ImportDetails) String Uses

func (m *ImportDetails) String() string

func (*ImportDetails) Unmarshal Uses

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

func (*ImportDetails) XXX_DiscardUnknown Uses

func (m *ImportDetails) XXX_DiscardUnknown()

func (*ImportDetails) XXX_Marshal Uses

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

func (*ImportDetails) XXX_Merge Uses

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

func (*ImportDetails) XXX_Size Uses

func (m *ImportDetails) XXX_Size() int

func (*ImportDetails) XXX_Unmarshal Uses

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

type ImportDetails_Table Uses

type ImportDetails_Table struct {
    Desc       *sqlbase.TableDescriptor `protobuf:"bytes,1,opt,name=desc,proto3" json:"desc,omitempty"`
    Name       string                   `protobuf:"bytes,18,opt,name=name,proto3" json:"name,omitempty"`
    SeqVal     int64                    `protobuf:"varint,19,opt,name=seq_val,json=seqVal,proto3" json:"seq_val,omitempty"`
    IsNew      bool                     `protobuf:"varint,20,opt,name=is_new,json=isNew,proto3" json:"is_new,omitempty"`
    TargetCols []string                 `protobuf:"bytes,21,rep,name=target_cols,json=targetCols,proto3" json:"target_cols,omitempty"`
}

func (*ImportDetails_Table) Descriptor Uses

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

func (*ImportDetails_Table) Marshal Uses

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

func (*ImportDetails_Table) MarshalTo Uses

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

func (*ImportDetails_Table) ProtoMessage Uses

func (*ImportDetails_Table) ProtoMessage()

func (*ImportDetails_Table) Reset Uses

func (m *ImportDetails_Table) Reset()

func (*ImportDetails_Table) Size Uses

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

func (*ImportDetails_Table) String Uses

func (m *ImportDetails_Table) String() string

func (*ImportDetails_Table) Unmarshal Uses

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

func (*ImportDetails_Table) XXX_DiscardUnknown Uses

func (m *ImportDetails_Table) XXX_DiscardUnknown()

func (*ImportDetails_Table) XXX_Marshal Uses

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

func (*ImportDetails_Table) XXX_Merge Uses

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

func (*ImportDetails_Table) XXX_Size Uses

func (m *ImportDetails_Table) XXX_Size() int

func (*ImportDetails_Table) XXX_Unmarshal Uses

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

type ImportProgress Uses

type ImportProgress struct {
    SamplingProgress []float32 `protobuf:"fixed32,1,rep,packed,name=sampling_progress,json=samplingProgress,proto3" json:"sampling_progress,omitempty"`
    ReadProgress     []float32 `protobuf:"fixed32,2,rep,packed,name=read_progress,json=readProgress,proto3" json:"read_progress,omitempty"`
    WriteProgress    []float32 `protobuf:"fixed32,3,rep,packed,name=write_progress,json=writeProgress,proto3" json:"write_progress,omitempty"`
    // The spans of split keys which have had their SSTable's generated.
    // This allows us to skip the shuffle stage for already-completed
    // spans when resuming an import job.
    SpanProgress []roachpb.Span `protobuf:"bytes,4,rep,name=span_progress,json=spanProgress,proto3" json:"span_progress"`
    // In direct-ingest import, once the KVs for i'th row of an input file have
    // been flushed, we can advance the count here and then on resume skip over
    // that many rows without needing to convert/process them at all.
    ResumePos []int64 `protobuf:"varint,5,rep,packed,name=resume_pos,json=resumePos,proto3" json:"resume_pos,omitempty"`
}

func (*ImportProgress) Descriptor Uses

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

func (*ImportProgress) Marshal Uses

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

func (*ImportProgress) MarshalTo Uses

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

func (*ImportProgress) ProtoMessage Uses

func (*ImportProgress) ProtoMessage()

func (*ImportProgress) Reset Uses

func (m *ImportProgress) Reset()

func (*ImportProgress) Size Uses

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

func (*ImportProgress) String Uses

func (m *ImportProgress) String() string

func (*ImportProgress) Unmarshal Uses

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

func (*ImportProgress) XXX_DiscardUnknown Uses

func (m *ImportProgress) XXX_DiscardUnknown()

func (*ImportProgress) XXX_Marshal Uses

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

func (*ImportProgress) XXX_Merge Uses

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

func (*ImportProgress) XXX_Size Uses

func (m *ImportProgress) XXX_Size() int

func (*ImportProgress) XXX_Unmarshal Uses

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

type Job Uses

type Job struct {
    Id  int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
    // Keep progress first as it may bre more relevant to see when looking at a
    // running job.
    Progress *Progress `protobuf:"bytes,2,opt,name=progress,proto3" json:"progress,omitempty"`
    Payload  *Payload  `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*Job) Descriptor Uses

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

func (*Job) Marshal Uses

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

func (*Job) MarshalTo Uses

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

func (*Job) ProtoMessage Uses

func (*Job) ProtoMessage()

func (*Job) Reset Uses

func (m *Job) Reset()

func (*Job) Size Uses

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

func (*Job) String Uses

func (m *Job) String() string

func (*Job) Unmarshal Uses

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

func (*Job) XXX_DiscardUnknown Uses

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal Uses

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

func (*Job) XXX_Merge Uses

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

func (*Job) XXX_Size Uses

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal Uses

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

type Lease Uses

type Lease struct {
    // The ID of the node that holds the lease.
    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 epoch of the lease holder's node liveness entry.
    Epoch int64 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
}

func (*Lease) Descriptor Uses

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

func (*Lease) Equal Uses

func (this *Lease) Equal(that interface{}) bool

func (*Lease) Marshal Uses

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

func (*Lease) MarshalTo Uses

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

func (*Lease) ProtoMessage Uses

func (*Lease) ProtoMessage()

func (*Lease) Reset Uses

func (m *Lease) Reset()

func (*Lease) Size Uses

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

func (*Lease) String Uses

func (m *Lease) String() string

func (*Lease) Unmarshal Uses

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

func (*Lease) XXX_DiscardUnknown Uses

func (m *Lease) XXX_DiscardUnknown()

func (*Lease) XXX_Marshal Uses

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

func (*Lease) XXX_Merge Uses

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

func (*Lease) XXX_Size Uses

func (m *Lease) XXX_Size() int

func (*Lease) XXX_Unmarshal Uses

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

type Payload Uses

type Payload struct {
    Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
    // If empty, the description is assumed to be the statement.
    Statement string `protobuf:"bytes,16,opt,name=statement,proto3" json:"statement,omitempty"`
    Username  string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
    // For consistency with the SQL timestamp type, which has microsecond
    // precision, we avoid the timestamp.Timestamp WKT, which has nanosecond
    // precision, and use microsecond integers directly.
    StartedMicros  int64                                                 `protobuf:"varint,3,opt,name=started_micros,json=startedMicros,proto3" json:"started_micros,omitempty"`
    FinishedMicros int64                                                 `protobuf:"varint,4,opt,name=finished_micros,json=finishedMicros,proto3" json:"finished_micros,omitempty"`
    DescriptorIDs  []github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID `protobuf:"varint,6,rep,packed,name=descriptor_ids,json=descriptorIds,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"descriptor_ids,omitempty"`
    // TODO (lucy): Deprecate the string error field and move to using the encoded
    // errors everywhere.
    Error         string                   `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
    ResumeErrors  []*errorspb.EncodedError `protobuf:"bytes,17,rep,name=resume_errors,json=resumeErrors,proto3" json:"resume_errors,omitempty"`
    CleanupErrors []*errorspb.EncodedError `protobuf:"bytes,18,rep,name=cleanup_errors,json=cleanupErrors,proto3" json:"cleanup_errors,omitempty"`
    // FinalResumeError is set when an error occurs that requires the job to be
    // reverted. The error is recorded so it can be handled while reverting, if
    // needed.
    FinalResumeError *errorspb.EncodedError `protobuf:"bytes,19,opt,name=final_resume_error,json=finalResumeError,proto3" json:"final_resume_error,omitempty"`
    Lease            *Lease                 `protobuf:"bytes,9,opt,name=lease,proto3" json:"lease,omitempty"`
    // Noncancelable is used to denote when a job cannot be canceled. This field
    // will not be respected in mixed version clusters where some nodes have
    // a version < 20.1, so it can only be used in cases where all nodes having
    // versions >= 20.1 is guaranteed.
    Noncancelable bool `protobuf:"varint,20,opt,name=noncancelable,proto3" json:"noncancelable,omitempty"`
    // Types that are valid to be assigned to Details:
    //	*Payload_Backup
    //	*Payload_Restore
    //	*Payload_SchemaChange
    //	*Payload_Import
    //	*Payload_Changefeed
    //	*Payload_CreateStats
    //	*Payload_SchemaChangeGC
    Details isPayload_Details `protobuf_oneof:"details"`
}

func (*Payload) Descriptor Uses

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

func (*Payload) GetBackup Uses

func (m *Payload) GetBackup() *BackupDetails

func (*Payload) GetChangefeed Uses

func (m *Payload) GetChangefeed() *ChangefeedDetails

func (*Payload) GetCreateStats Uses

func (m *Payload) GetCreateStats() *CreateStatsDetails

func (*Payload) GetDetails Uses

func (m *Payload) GetDetails() isPayload_Details

func (*Payload) GetImport Uses

func (m *Payload) GetImport() *ImportDetails

func (*Payload) GetRestore Uses

func (m *Payload) GetRestore() *RestoreDetails

func (*Payload) GetSchemaChange Uses

func (m *Payload) GetSchemaChange() *SchemaChangeDetails

func (*Payload) GetSchemaChangeGC Uses

func (m *Payload) GetSchemaChangeGC() *SchemaChangeGCDetails

func (*Payload) Marshal Uses

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

func (*Payload) MarshalTo Uses

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

func (*Payload) ProtoMessage Uses

func (*Payload) ProtoMessage()

func (*Payload) Reset Uses

func (m *Payload) Reset()

func (*Payload) Size Uses

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

func (*Payload) String Uses

func (m *Payload) String() string

func (*Payload) Type Uses

func (p *Payload) Type() Type

Type returns the payload's job type.

func (*Payload) Unmarshal Uses

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

func (*Payload) UnwrapDetails Uses

func (p *Payload) UnwrapDetails() Details

UnwrapDetails returns the details object stored within the payload's Details field, discarding the protobuf wrapper struct.

func (*Payload) XXX_DiscardUnknown Uses

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal Uses

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

func (*Payload) XXX_Merge Uses

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

func (*Payload) XXX_OneofFuncs Uses

func (*Payload) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Payload) XXX_Size Uses

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal Uses

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

type Payload_Backup Uses

type Payload_Backup struct {
    Backup *BackupDetails `protobuf:"bytes,10,opt,name=backup,proto3,oneof"`
}

func (*Payload_Backup) MarshalTo Uses

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

func (*Payload_Backup) Size Uses

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

type Payload_Changefeed Uses

type Payload_Changefeed struct {
    Changefeed *ChangefeedDetails `protobuf:"bytes,14,opt,name=changefeed,proto3,oneof"`
}

func (*Payload_Changefeed) MarshalTo Uses

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

func (*Payload_Changefeed) Size Uses

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

type Payload_CreateStats Uses

type Payload_CreateStats struct {
    CreateStats *CreateStatsDetails `protobuf:"bytes,15,opt,name=createStats,proto3,oneof"`
}

func (*Payload_CreateStats) MarshalTo Uses

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

func (*Payload_CreateStats) Size Uses

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

type Payload_Import Uses

type Payload_Import struct {
    Import *ImportDetails `protobuf:"bytes,13,opt,name=import,proto3,oneof"`
}

func (*Payload_Import) MarshalTo Uses

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

func (*Payload_Import) Size Uses

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

type Payload_Restore Uses

type Payload_Restore struct {
    Restore *RestoreDetails `protobuf:"bytes,11,opt,name=restore,proto3,oneof"`
}

func (*Payload_Restore) MarshalTo Uses

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

func (*Payload_Restore) Size Uses

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

type Payload_SchemaChange Uses

type Payload_SchemaChange struct {
    SchemaChange *SchemaChangeDetails `protobuf:"bytes,12,opt,name=schemaChange,proto3,oneof"`
}

func (*Payload_SchemaChange) MarshalTo Uses

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

func (*Payload_SchemaChange) Size Uses

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

type Payload_SchemaChangeGC Uses

type Payload_SchemaChangeGC struct {
    SchemaChangeGC *SchemaChangeGCDetails `protobuf:"bytes,21,opt,name=schemaChangeGC,proto3,oneof"`
}

func (*Payload_SchemaChangeGC) MarshalTo Uses

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

func (*Payload_SchemaChangeGC) Size Uses

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

type Progress Uses

type Progress struct {
    // Types that are valid to be assigned to Progress:
    //	*Progress_FractionCompleted
    //	*Progress_HighWater
    Progress       isProgress_Progress `protobuf_oneof:"progress"`
    ModifiedMicros int64               `protobuf:"varint,2,opt,name=modified_micros,json=modifiedMicros,proto3" json:"modified_micros,omitempty"`
    RunningStatus  string              `protobuf:"bytes,4,opt,name=running_status,json=runningStatus,proto3" json:"running_status,omitempty"`
    // Types that are valid to be assigned to Details:
    //	*Progress_Backup
    //	*Progress_Restore
    //	*Progress_SchemaChange
    //	*Progress_Import
    //	*Progress_Changefeed
    //	*Progress_CreateStats
    //	*Progress_SchemaChangeGC
    Details isProgress_Details `protobuf_oneof:"details"`
}

func (*Progress) Descriptor Uses

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

func (*Progress) GetBackup Uses

func (m *Progress) GetBackup() *BackupProgress

func (*Progress) GetChangefeed Uses

func (m *Progress) GetChangefeed() *ChangefeedProgress

func (*Progress) GetCreateStats Uses

func (m *Progress) GetCreateStats() *CreateStatsProgress

func (*Progress) GetDetails Uses

func (m *Progress) GetDetails() isProgress_Details

func (*Progress) GetFractionCompleted Uses

func (m *Progress) GetFractionCompleted() float32

func (*Progress) GetHighWater Uses

func (m *Progress) GetHighWater() *hlc.Timestamp

func (*Progress) GetImport Uses

func (m *Progress) GetImport() *ImportProgress

func (*Progress) GetProgress Uses

func (m *Progress) GetProgress() isProgress_Progress

func (*Progress) GetRestore Uses

func (m *Progress) GetRestore() *RestoreProgress

func (*Progress) GetSchemaChange Uses

func (m *Progress) GetSchemaChange() *SchemaChangeProgress

func (*Progress) GetSchemaChangeGC Uses

func (m *Progress) GetSchemaChangeGC() *SchemaChangeGCProgress

func (*Progress) Marshal Uses

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

func (*Progress) MarshalTo Uses

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

func (*Progress) ProtoMessage Uses

func (*Progress) ProtoMessage()

func (*Progress) Reset Uses

func (m *Progress) Reset()

func (*Progress) Size Uses

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

func (*Progress) String Uses

func (m *Progress) String() string

func (*Progress) Unmarshal Uses

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

func (*Progress) UnwrapDetails Uses

func (p *Progress) UnwrapDetails() ProgressDetails

UnwrapDetails returns the details object stored within the progress' Details field, discarding the protobuf wrapper struct.

func (*Progress) XXX_DiscardUnknown Uses

func (m *Progress) XXX_DiscardUnknown()

func (*Progress) XXX_Marshal Uses

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

func (*Progress) XXX_Merge Uses

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

func (*Progress) XXX_OneofFuncs Uses

func (*Progress) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Progress) XXX_Size Uses

func (m *Progress) XXX_Size() int

func (*Progress) XXX_Unmarshal Uses

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

type ProgressDetails Uses

type ProgressDetails interface{}

ProgressDetails is a marker interface for job progress details proto structs.

type Progress_Backup Uses

type Progress_Backup struct {
    Backup *BackupProgress `protobuf:"bytes,10,opt,name=backup,proto3,oneof"`
}

func (*Progress_Backup) MarshalTo Uses

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

func (*Progress_Backup) Size Uses

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

type Progress_Changefeed Uses

type Progress_Changefeed struct {
    Changefeed *ChangefeedProgress `protobuf:"bytes,14,opt,name=changefeed,proto3,oneof"`
}

func (*Progress_Changefeed) MarshalTo Uses

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

func (*Progress_Changefeed) Size Uses

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

type Progress_CreateStats Uses

type Progress_CreateStats struct {
    CreateStats *CreateStatsProgress `protobuf:"bytes,15,opt,name=createStats,proto3,oneof"`
}

func (*Progress_CreateStats) MarshalTo Uses

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

func (*Progress_CreateStats) Size Uses

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

type Progress_FractionCompleted Uses

type Progress_FractionCompleted struct {
    FractionCompleted float32 `protobuf:"fixed32,1,opt,name=fraction_completed,json=fractionCompleted,proto3,oneof"`
}

func (*Progress_FractionCompleted) MarshalTo Uses

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

func (*Progress_FractionCompleted) Size Uses

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

type Progress_HighWater Uses

type Progress_HighWater struct {
    HighWater *hlc.Timestamp `protobuf:"bytes,3,opt,name=high_water,json=highWater,proto3,oneof"`
}

func (*Progress_HighWater) MarshalTo Uses

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

func (*Progress_HighWater) Size Uses

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

type Progress_Import Uses

type Progress_Import struct {
    Import *ImportProgress `protobuf:"bytes,13,opt,name=import,proto3,oneof"`
}

func (*Progress_Import) MarshalTo Uses

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

func (*Progress_Import) Size Uses

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

type Progress_Restore Uses

type Progress_Restore struct {
    Restore *RestoreProgress `protobuf:"bytes,11,opt,name=restore,proto3,oneof"`
}

func (*Progress_Restore) MarshalTo Uses

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

func (*Progress_Restore) Size Uses

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

type Progress_SchemaChange Uses

type Progress_SchemaChange struct {
    SchemaChange *SchemaChangeProgress `protobuf:"bytes,12,opt,name=schemaChange,proto3,oneof"`
}

func (*Progress_SchemaChange) MarshalTo Uses

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

func (*Progress_SchemaChange) Size Uses

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

type Progress_SchemaChangeGC Uses

type Progress_SchemaChangeGC struct {
    SchemaChangeGC *SchemaChangeGCProgress `protobuf:"bytes,16,opt,name=schemaChangeGC,proto3,oneof"`
}

func (*Progress_SchemaChangeGC) MarshalTo Uses

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

func (*Progress_SchemaChangeGC) Size Uses

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

type ResolvedSpan Uses

type ResolvedSpan struct {
    Span            roachpb.Span  `protobuf:"bytes,1,opt,name=span,proto3" json:"span"`
    Timestamp       hlc.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp"`
    BoundaryReached bool          `protobuf:"varint,3,opt,name=boundary_reached,json=boundaryReached,proto3" json:"boundary_reached,omitempty"`
}

func (*ResolvedSpan) Descriptor Uses

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

func (*ResolvedSpan) Marshal Uses

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

func (*ResolvedSpan) MarshalTo Uses

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

func (*ResolvedSpan) ProtoMessage Uses

func (*ResolvedSpan) ProtoMessage()

func (*ResolvedSpan) Reset Uses

func (m *ResolvedSpan) Reset()

func (*ResolvedSpan) Size Uses

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

func (*ResolvedSpan) String Uses

func (m *ResolvedSpan) String() string

func (*ResolvedSpan) Unmarshal Uses

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

func (*ResolvedSpan) XXX_DiscardUnknown Uses

func (m *ResolvedSpan) XXX_DiscardUnknown()

func (*ResolvedSpan) XXX_Marshal Uses

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

func (*ResolvedSpan) XXX_Merge Uses

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

func (*ResolvedSpan) XXX_Size Uses

func (m *ResolvedSpan) XXX_Size() int

func (*ResolvedSpan) XXX_Unmarshal Uses

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

type RestoreDetails Uses

type RestoreDetails struct {
    EndTime            hlc.Timestamp                                                                             `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time"`
    DescriptorRewrites map[github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID]*RestoreDetails_DescriptorRewrite `protobuf:"bytes,2,rep,name=descriptor_rewrites,json=descriptorRewrites,proto3,castkey=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"descriptor_rewrites,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // URIs contains one URI for each backup (full or incremental) corresponding
    // to the location of the main BACKUP manifest. For partitioned backups, each
    // backup may also have files in other stores.
    URIs               []string                                                             `protobuf:"bytes,3,rep,name=uris,proto3" json:"uris,omitempty"`
    BackupLocalityInfo []RestoreDetails_BackupLocalityInfo                                  `protobuf:"bytes,7,rep,name=backup_locality_info,json=backupLocalityInfo,proto3" json:"backup_locality_info"`
    TableDescs         []*sqlbase.TableDescriptor                                           `protobuf:"bytes,5,rep,name=table_descs,json=tableDescs,proto3" json:"table_descs,omitempty"`
    OverrideDB         string                                                               `protobuf:"bytes,6,opt,name=override_db,json=overrideDb,proto3" json:"override_db,omitempty"`
    PrepareCompleted   bool                                                                 `protobuf:"varint,8,opt,name=prepare_completed,json=prepareCompleted,proto3" json:"prepare_completed,omitempty"`
    StatsInserted      bool                                                                 `protobuf:"varint,9,opt,name=stats_inserted,json=statsInserted,proto3" json:"stats_inserted,omitempty"`
    TablesPublished    bool                                                                 `protobuf:"varint,10,opt,name=tables_published,json=tablesPublished,proto3" json:"tables_published,omitempty"`
    DescriptorCoverage github_com_cockroachdb_cockroach_pkg_sql_sem_tree.DescriptorCoverage `protobuf:"varint,11,opt,name=descriptor_coverage,json=descriptorCoverage,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sem/tree.DescriptorCoverage" json:"descriptor_coverage,omitempty"`
    Encryption         *roachpb.FileEncryptionOptions                                       `protobuf:"bytes,12,opt,name=encryption,proto3" json:"encryption,omitempty"`
}

func (*RestoreDetails) Descriptor Uses

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

func (*RestoreDetails) Marshal Uses

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

func (*RestoreDetails) MarshalTo Uses

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

func (*RestoreDetails) ProtoMessage Uses

func (*RestoreDetails) ProtoMessage()

func (*RestoreDetails) Reset Uses

func (m *RestoreDetails) Reset()

func (*RestoreDetails) Size Uses

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

func (*RestoreDetails) String Uses

func (m *RestoreDetails) String() string

func (*RestoreDetails) Unmarshal Uses

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

func (*RestoreDetails) XXX_DiscardUnknown Uses

func (m *RestoreDetails) XXX_DiscardUnknown()

func (*RestoreDetails) XXX_Marshal Uses

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

func (*RestoreDetails) XXX_Merge Uses

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

func (*RestoreDetails) XXX_Size Uses

func (m *RestoreDetails) XXX_Size() int

func (*RestoreDetails) XXX_Unmarshal Uses

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

type RestoreDetails_BackupLocalityInfo Uses

type RestoreDetails_BackupLocalityInfo struct {
    URIsByOriginalLocalityKV map[string]string `protobuf:"bytes,1,rep,name=uris_by_original_locality_kv,json=urisByOriginalLocalityKv,proto3" json:"uris_by_original_locality_kv,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}

func (*RestoreDetails_BackupLocalityInfo) Descriptor Uses

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

func (*RestoreDetails_BackupLocalityInfo) Marshal Uses

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

func (*RestoreDetails_BackupLocalityInfo) MarshalTo Uses

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

func (*RestoreDetails_BackupLocalityInfo) ProtoMessage Uses

func (*RestoreDetails_BackupLocalityInfo) ProtoMessage()

func (*RestoreDetails_BackupLocalityInfo) Reset Uses

func (m *RestoreDetails_BackupLocalityInfo) Reset()

func (*RestoreDetails_BackupLocalityInfo) Size Uses

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

func (*RestoreDetails_BackupLocalityInfo) String Uses

func (m *RestoreDetails_BackupLocalityInfo) String() string

func (*RestoreDetails_BackupLocalityInfo) Unmarshal Uses

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

func (*RestoreDetails_BackupLocalityInfo) XXX_DiscardUnknown Uses

func (m *RestoreDetails_BackupLocalityInfo) XXX_DiscardUnknown()

func (*RestoreDetails_BackupLocalityInfo) XXX_Marshal Uses

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

func (*RestoreDetails_BackupLocalityInfo) XXX_Merge Uses

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

func (*RestoreDetails_BackupLocalityInfo) XXX_Size Uses

func (m *RestoreDetails_BackupLocalityInfo) XXX_Size() int

func (*RestoreDetails_BackupLocalityInfo) XXX_Unmarshal Uses

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

type RestoreDetails_DescriptorRewrite Uses

type RestoreDetails_DescriptorRewrite struct {
    ID       github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID `protobuf:"varint,1,opt,name=id,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"id,omitempty"`
    ParentID github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID `protobuf:"varint,2,opt,name=parent_id,json=parentId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"parent_id,omitempty"`
    // ToExisting represents whether this descriptor is being remapped to a
    // descriptor that already exists in the cluster.
    ToExisting bool `protobuf:"varint,3,opt,name=to_existing,json=toExisting,proto3" json:"to_existing,omitempty"`
}

func (*RestoreDetails_DescriptorRewrite) Descriptor Uses

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

func (*RestoreDetails_DescriptorRewrite) Marshal Uses

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

func (*RestoreDetails_DescriptorRewrite) MarshalTo Uses

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

func (*RestoreDetails_DescriptorRewrite) ProtoMessage Uses

func (*RestoreDetails_DescriptorRewrite) ProtoMessage()

func (*RestoreDetails_DescriptorRewrite) Reset Uses

func (m *RestoreDetails_DescriptorRewrite) Reset()

func (*RestoreDetails_DescriptorRewrite) Size Uses

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

func (*RestoreDetails_DescriptorRewrite) String Uses

func (m *RestoreDetails_DescriptorRewrite) String() string

func (*RestoreDetails_DescriptorRewrite) Unmarshal Uses

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

func (*RestoreDetails_DescriptorRewrite) XXX_DiscardUnknown Uses

func (m *RestoreDetails_DescriptorRewrite) XXX_DiscardUnknown()

func (*RestoreDetails_DescriptorRewrite) XXX_Marshal Uses

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

func (*RestoreDetails_DescriptorRewrite) XXX_Merge Uses

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

func (*RestoreDetails_DescriptorRewrite) XXX_Size Uses

func (m *RestoreDetails_DescriptorRewrite) XXX_Size() int

func (*RestoreDetails_DescriptorRewrite) XXX_Unmarshal Uses

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

type RestoreProgress Uses

type RestoreProgress struct {
    HighWater []byte `protobuf:"bytes,1,opt,name=high_water,json=highWater,proto3" json:"high_water,omitempty"`
}

func (*RestoreProgress) Descriptor Uses

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

func (*RestoreProgress) Marshal Uses

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

func (*RestoreProgress) MarshalTo Uses

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

func (*RestoreProgress) ProtoMessage Uses

func (*RestoreProgress) ProtoMessage()

func (*RestoreProgress) Reset Uses

func (m *RestoreProgress) Reset()

func (*RestoreProgress) Size Uses

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

func (*RestoreProgress) String Uses

func (m *RestoreProgress) String() string

func (*RestoreProgress) Unmarshal Uses

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

func (*RestoreProgress) XXX_DiscardUnknown Uses

func (m *RestoreProgress) XXX_DiscardUnknown()

func (*RestoreProgress) XXX_Marshal Uses

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

func (*RestoreProgress) XXX_Merge Uses

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

func (*RestoreProgress) XXX_Size Uses

func (m *RestoreProgress) XXX_Size() int

func (*RestoreProgress) XXX_Unmarshal Uses

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

type ResumeSpanList Uses

type ResumeSpanList struct {
    ResumeSpans []roachpb.Span `protobuf:"bytes,1,rep,name=resume_spans,json=resumeSpans,proto3" json:"resume_spans"`
}

func (*ResumeSpanList) Descriptor Uses

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

func (*ResumeSpanList) Marshal Uses

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

func (*ResumeSpanList) MarshalTo Uses

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

func (*ResumeSpanList) ProtoMessage Uses

func (*ResumeSpanList) ProtoMessage()

func (*ResumeSpanList) Reset Uses

func (m *ResumeSpanList) Reset()

func (*ResumeSpanList) Size Uses

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

func (*ResumeSpanList) String Uses

func (m *ResumeSpanList) String() string

func (*ResumeSpanList) Unmarshal Uses

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

func (*ResumeSpanList) XXX_DiscardUnknown Uses

func (m *ResumeSpanList) XXX_DiscardUnknown()

func (*ResumeSpanList) XXX_Marshal Uses

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

func (*ResumeSpanList) XXX_Merge Uses

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

func (*ResumeSpanList) XXX_Size Uses

func (m *ResumeSpanList) XXX_Size() int

func (*ResumeSpanList) XXX_Unmarshal Uses

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

type ScheduleChangeInfo Uses

type ScheduleChangeInfo struct {
    Changes []ScheduleChangeInfo_Change `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes"`
}

ScheduleChangeInfo describes the reasons for schedule changes.

func (*ScheduleChangeInfo) Descriptor Uses

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

func (*ScheduleChangeInfo) Marshal Uses

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

func (*ScheduleChangeInfo) MarshalTo Uses

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

func (*ScheduleChangeInfo) ProtoMessage Uses

func (*ScheduleChangeInfo) ProtoMessage()

func (*ScheduleChangeInfo) Reset Uses

func (m *ScheduleChangeInfo) Reset()

func (*ScheduleChangeInfo) Size Uses

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

func (*ScheduleChangeInfo) String Uses

func (m *ScheduleChangeInfo) String() string

func (*ScheduleChangeInfo) Unmarshal Uses

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

func (*ScheduleChangeInfo) XXX_DiscardUnknown Uses

func (m *ScheduleChangeInfo) XXX_DiscardUnknown()

func (*ScheduleChangeInfo) XXX_Marshal Uses

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

func (*ScheduleChangeInfo) XXX_Merge Uses

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

func (*ScheduleChangeInfo) XXX_Size Uses

func (m *ScheduleChangeInfo) XXX_Size() int

func (*ScheduleChangeInfo) XXX_Unmarshal Uses

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

type ScheduleChangeInfo_Change Uses

type ScheduleChangeInfo_Change struct {
    Time   int64  `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
    Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
}

func (*ScheduleChangeInfo_Change) Descriptor Uses

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

func (*ScheduleChangeInfo_Change) Marshal Uses

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

func (*ScheduleChangeInfo_Change) MarshalTo Uses

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

func (*ScheduleChangeInfo_Change) ProtoMessage Uses

func (*ScheduleChangeInfo_Change) ProtoMessage()

func (*ScheduleChangeInfo_Change) Reset Uses

func (m *ScheduleChangeInfo_Change) Reset()

func (*ScheduleChangeInfo_Change) Size Uses

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

func (*ScheduleChangeInfo_Change) String Uses

func (m *ScheduleChangeInfo_Change) String() string

func (*ScheduleChangeInfo_Change) Unmarshal Uses

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

func (*ScheduleChangeInfo_Change) XXX_DiscardUnknown Uses

func (m *ScheduleChangeInfo_Change) XXX_DiscardUnknown()

func (*ScheduleChangeInfo_Change) XXX_Marshal Uses

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

func (*ScheduleChangeInfo_Change) XXX_Merge Uses

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

func (*ScheduleChangeInfo_Change) XXX_Size Uses

func (m *ScheduleChangeInfo_Change) XXX_Size() int

func (*ScheduleChangeInfo_Change) XXX_Unmarshal Uses

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

type ScheduleDetails Uses

type ScheduleDetails struct {
    // How to handle running jobs.
    Wait ScheduleDetails_WaitBehavior `protobuf:"varint,1,opt,name=wait,proto3,enum=cockroach.jobs.jobspb.ScheduleDetails_WaitBehavior" json:"wait,omitempty"`
    // How to handle failed jobs.
    OnError ScheduleDetails_ErrorHandlingBehavior `protobuf:"varint,2,opt,name=on_error,json=onError,proto3,enum=cockroach.jobs.jobspb.ScheduleDetails_ErrorHandlingBehavior" json:"on_error,omitempty"`
}

ScheduleDetails describes how to schedule and execute the job.

func (*ScheduleDetails) Descriptor Uses

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

func (*ScheduleDetails) Marshal Uses

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

func (*ScheduleDetails) MarshalTo Uses

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

func (*ScheduleDetails) ProtoMessage Uses

func (*ScheduleDetails) ProtoMessage()

func (*ScheduleDetails) Reset Uses

func (m *ScheduleDetails) Reset()

func (*ScheduleDetails) Size Uses

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

func (*ScheduleDetails) String Uses

func (m *ScheduleDetails) String() string

func (*ScheduleDetails) Unmarshal Uses

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

func (*ScheduleDetails) XXX_DiscardUnknown Uses

func (m *ScheduleDetails) XXX_DiscardUnknown()

func (*ScheduleDetails) XXX_Marshal Uses

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

func (*ScheduleDetails) XXX_Merge Uses

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

func (*ScheduleDetails) XXX_Size Uses

func (m *ScheduleDetails) XXX_Size() int

func (*ScheduleDetails) XXX_Unmarshal Uses

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

type ScheduleDetails_ErrorHandlingBehavior Uses

type ScheduleDetails_ErrorHandlingBehavior int32

ErrorHandlingBehavior describes how to handle failed job runs.

const (
    // By default, failed jobs will run again, based on their schedule.
    ScheduleDetails_RETRY_SCHED ScheduleDetails_ErrorHandlingBehavior = 0
    // Retry failed jobs soon.
    ScheduleDetails_RETRY_SOON ScheduleDetails_ErrorHandlingBehavior = 1
    // Stop running this schedule
    ScheduleDetails_PAUSE_SCHED ScheduleDetails_ErrorHandlingBehavior = 2
)

func (ScheduleDetails_ErrorHandlingBehavior) EnumDescriptor Uses

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

func (ScheduleDetails_ErrorHandlingBehavior) String Uses

func (x ScheduleDetails_ErrorHandlingBehavior) String() string

type ScheduleDetails_WaitBehavior Uses

type ScheduleDetails_WaitBehavior int32

WaitBehavior describes how to handle previously started jobs that have not completed yet.

const (
    // Wait for the previous run to complete
    // before starting the next one.
    ScheduleDetails_WAIT ScheduleDetails_WaitBehavior = 0
    // Do not wait for the previous run to complete.
    ScheduleDetails_NO_WAIT ScheduleDetails_WaitBehavior = 1
    // If the previous run is still running, skip this run
    // and advance schedule to the next recurrence.
    ScheduleDetails_SKIP ScheduleDetails_WaitBehavior = 2
)

func (ScheduleDetails_WaitBehavior) EnumDescriptor Uses

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

func (ScheduleDetails_WaitBehavior) String Uses

func (x ScheduleDetails_WaitBehavior) String() string

type SchemaChangeDetails Uses

type SchemaChangeDetails struct {
    // A schema change can involve running multiple processors backfilling
    // or deleting data. They occasionally checkpoint Spans so that the
    // processing can resume in the event of a node failure. The spans are
    // non-overlapping contiguous areas of the KV space that still need to
    // be processed. The index represents the index of a mutation in a
    // mutation list containing mutations for the same mutationID.
    ResumeSpanList []ResumeSpanList      `protobuf:"bytes,2,rep,name=resume_span_list,json=resumeSpanList,proto3" json:"resume_span_list"`
    DroppedTables  []DroppedTableDetails `protobuf:"bytes,3,rep,name=dropped_tables,json=droppedTables,proto3" json:"dropped_tables"`
    // The descriptor ID of the dropped database which created this job.
    DroppedDatabaseID github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID         `protobuf:"varint,4,opt,name=dropped_database_id,json=droppedDatabaseId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"dropped_database_id,omitempty"`
    TableID           github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID         `protobuf:"varint,5,opt,name=table_id,json=tableId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"table_id,omitempty"`
    MutationID        github_com_cockroachdb_cockroach_pkg_sql_sqlbase.MutationID `protobuf:"varint,6,opt,name=mutation_id,json=mutationId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.MutationID" json:"mutation_id,omitempty"`
    // The format version of the schema change job details. This is used to
    // distinguish between jobs as they existed in 19.2 and earlier versions
    // (controlled and updated by a SchemaChanger) and jobs as they exist in 20.1
    // (scheduled and run by the job registry).
    FormatVersion SchemaChangeDetailsFormatVersion `protobuf:"varint,7,opt,name=format_version,json=formatVersion,proto3,casttype=SchemaChangeDetailsFormatVersion" json:"format_version,omitempty"`
}

func (*SchemaChangeDetails) Descriptor Uses

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

func (*SchemaChangeDetails) Marshal Uses

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

func (*SchemaChangeDetails) MarshalTo Uses

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

func (*SchemaChangeDetails) ProtoMessage Uses

func (*SchemaChangeDetails) ProtoMessage()

func (*SchemaChangeDetails) Reset Uses

func (m *SchemaChangeDetails) Reset()

func (*SchemaChangeDetails) Size Uses

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

func (*SchemaChangeDetails) String Uses

func (m *SchemaChangeDetails) String() string

func (*SchemaChangeDetails) Unmarshal Uses

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

func (*SchemaChangeDetails) XXX_DiscardUnknown Uses

func (m *SchemaChangeDetails) XXX_DiscardUnknown()

func (*SchemaChangeDetails) XXX_Marshal Uses

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

func (*SchemaChangeDetails) XXX_Merge Uses

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

func (*SchemaChangeDetails) XXX_Size Uses

func (m *SchemaChangeDetails) XXX_Size() int

func (*SchemaChangeDetails) XXX_Unmarshal Uses

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

type SchemaChangeDetailsFormatVersion Uses

type SchemaChangeDetailsFormatVersion uint32

SchemaChangeDetailsFormatVersion is the format version for SchemaChangeDetails.

const (
    // BaseFormatVersion corresponds to the initial version of
    // SchemaChangeDetails, intended for the original version of schema change
    // jobs which were meant to be updated by a SchemaChanger instead of being run
    // as jobs by the job registry.
    BaseFormatVersion SchemaChangeDetailsFormatVersion = iota
    // JobResumerFormatVersion corresponds to the introduction of the schema
    // change job resumer. This version introduces the TableID and MutationID
    // fields, and, more generally, flags the job as being suitable for the job
    // registry to adopt.
    JobResumerFormatVersion
)

type SchemaChangeGCDetails Uses

type SchemaChangeGCDetails struct {
    // Indexes to GC.
    Indexes []SchemaChangeGCDetails_DroppedIndex `protobuf:"bytes,1,rep,name=indexes,proto3" json:"indexes"`
    // Entire tables to GC.
    Tables []SchemaChangeGCDetails_DroppedID `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables"`
    // If dropping indexes, the table ID which has those indexes. If dropping a
    // database, the database ID.
    ParentID github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID `protobuf:"varint,3,opt,name=parent_id,json=parentId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"parent_id,omitempty"`
}

SchemaChangeGCDetails should resemble one of the following:

1. Index (non-interleaved) deletions: One or more deletions of an index on a table.

details.Indexes -> the indexes to GC. These indexes must be
non-interleaved.
details.ParentID -> the table with the indexes.

2. Table deletions: The deletion of a single table.

details.Tables -> the tables to be deleted.

3. Database deletions: The deletion of a database and therefore all its tables.

details.Tables -> the IDs of the tables to GC.
details.ParentID -> the ID of the database to drop.

func (*SchemaChangeGCDetails) Descriptor Uses

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

func (*SchemaChangeGCDetails) Marshal Uses

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

func (*SchemaChangeGCDetails) MarshalTo Uses

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

func (*SchemaChangeGCDetails) ProtoMessage Uses

func (*SchemaChangeGCDetails) ProtoMessage()

func (*SchemaChangeGCDetails) Reset Uses

func (m *SchemaChangeGCDetails) Reset()

func (*SchemaChangeGCDetails) Size Uses

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

func (*SchemaChangeGCDetails) String Uses

func (m *SchemaChangeGCDetails) String() string

func (*SchemaChangeGCDetails) Unmarshal Uses

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

func (*SchemaChangeGCDetails) XXX_DiscardUnknown Uses

func (m *SchemaChangeGCDetails) XXX_DiscardUnknown()

func (*SchemaChangeGCDetails) XXX_Marshal Uses

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

func (*SchemaChangeGCDetails) XXX_Merge Uses

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

func (*SchemaChangeGCDetails) XXX_Size Uses

func (m *SchemaChangeGCDetails) XXX_Size() int

func (*SchemaChangeGCDetails) XXX_Unmarshal Uses

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

type SchemaChangeGCDetails_DroppedID Uses

type SchemaChangeGCDetails_DroppedID struct {
    ID       github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID `protobuf:"varint,1,opt,name=id,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"id,omitempty"`
    DropTime int64                                               `protobuf:"varint,2,opt,name=drop_time,json=dropTime,proto3" json:"drop_time,omitempty"`
}

func (*SchemaChangeGCDetails_DroppedID) Descriptor Uses

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

func (*SchemaChangeGCDetails_DroppedID) Marshal Uses

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

func (*SchemaChangeGCDetails_DroppedID) MarshalTo Uses

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

func (*SchemaChangeGCDetails_DroppedID) ProtoMessage Uses

func (*SchemaChangeGCDetails_DroppedID) ProtoMessage()

func (*SchemaChangeGCDetails_DroppedID) Reset Uses

func (m *SchemaChangeGCDetails_DroppedID) Reset()

func (*SchemaChangeGCDetails_DroppedID) Size Uses

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

func (*SchemaChangeGCDetails_DroppedID) String Uses

func (m *SchemaChangeGCDetails_DroppedID) String() string

func (*SchemaChangeGCDetails_DroppedID) Unmarshal Uses

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

func (*SchemaChangeGCDetails_DroppedID) XXX_DiscardUnknown Uses

func (m *SchemaChangeGCDetails_DroppedID) XXX_DiscardUnknown()

func (*SchemaChangeGCDetails_DroppedID) XXX_Marshal Uses

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

func (*SchemaChangeGCDetails_DroppedID) XXX_Merge Uses

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

func (*SchemaChangeGCDetails_DroppedID) XXX_Size Uses

func (m *SchemaChangeGCDetails_DroppedID) XXX_Size() int

func (*SchemaChangeGCDetails_DroppedID) XXX_Unmarshal Uses

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

type SchemaChangeGCDetails_DroppedIndex Uses

type SchemaChangeGCDetails_DroppedIndex struct {
    IndexID  github_com_cockroachdb_cockroach_pkg_sql_sqlbase.IndexID `protobuf:"varint,1,opt,name=index_id,json=indexId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.IndexID" json:"index_id,omitempty"`
    DropTime int64                                                    `protobuf:"varint,2,opt,name=drop_time,json=dropTime,proto3" json:"drop_time,omitempty"`
}

func (*SchemaChangeGCDetails_DroppedIndex) Descriptor Uses

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

func (*SchemaChangeGCDetails_DroppedIndex) Marshal Uses

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

func (*SchemaChangeGCDetails_DroppedIndex) MarshalTo Uses

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

func (*SchemaChangeGCDetails_DroppedIndex) ProtoMessage Uses

func (*SchemaChangeGCDetails_DroppedIndex) ProtoMessage()

func (*SchemaChangeGCDetails_DroppedIndex) Reset Uses

func (m *SchemaChangeGCDetails_DroppedIndex) Reset()

func (*SchemaChangeGCDetails_DroppedIndex) Size Uses

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

func (*SchemaChangeGCDetails_DroppedIndex) String Uses

func (m *SchemaChangeGCDetails_DroppedIndex) String() string

func (*SchemaChangeGCDetails_DroppedIndex) Unmarshal Uses

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

func (*SchemaChangeGCDetails_DroppedIndex) XXX_DiscardUnknown Uses

func (m *SchemaChangeGCDetails_DroppedIndex) XXX_DiscardUnknown()

func (*SchemaChangeGCDetails_DroppedIndex) XXX_Marshal Uses

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

func (*SchemaChangeGCDetails_DroppedIndex) XXX_Merge Uses

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

func (*SchemaChangeGCDetails_DroppedIndex) XXX_Size Uses

func (m *SchemaChangeGCDetails_DroppedIndex) XXX_Size() int

func (*SchemaChangeGCDetails_DroppedIndex) XXX_Unmarshal Uses

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

type SchemaChangeGCProgress Uses

type SchemaChangeGCProgress struct {
    // Indexes to GC.
    Indexes []SchemaChangeGCProgress_IndexProgress `protobuf:"bytes,1,rep,name=indexes,proto3" json:"indexes"`
    // Entire tables to GC.
    Tables []SchemaChangeGCProgress_TableProgress `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables"`
}

func (*SchemaChangeGCProgress) Descriptor Uses

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

func (*SchemaChangeGCProgress) Marshal Uses

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

func (*SchemaChangeGCProgress) MarshalTo Uses

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

func (*SchemaChangeGCProgress) ProtoMessage Uses

func (*SchemaChangeGCProgress) ProtoMessage()

func (*SchemaChangeGCProgress) Reset Uses

func (m *SchemaChangeGCProgress) Reset()

func (*SchemaChangeGCProgress) Size Uses

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

func (*SchemaChangeGCProgress) String Uses

func (m *SchemaChangeGCProgress) String() string

func (*SchemaChangeGCProgress) Unmarshal Uses

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

func (*SchemaChangeGCProgress) XXX_DiscardUnknown Uses

func (m *SchemaChangeGCProgress) XXX_DiscardUnknown()

func (*SchemaChangeGCProgress) XXX_Marshal Uses

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

func (*SchemaChangeGCProgress) XXX_Merge Uses

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

func (*SchemaChangeGCProgress) XXX_Size Uses

func (m *SchemaChangeGCProgress) XXX_Size() int

func (*SchemaChangeGCProgress) XXX_Unmarshal Uses

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

type SchemaChangeGCProgress_IndexProgress Uses

type SchemaChangeGCProgress_IndexProgress struct {
    IndexID github_com_cockroachdb_cockroach_pkg_sql_sqlbase.IndexID `protobuf:"varint,1,opt,name=index_id,json=indexId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.IndexID" json:"index_id,omitempty"`
    Status  SchemaChangeGCProgress_Status                            `protobuf:"varint,2,opt,name=status,proto3,enum=cockroach.sql.jobs.jobspb.SchemaChangeGCProgress_Status" json:"status,omitempty"`
}

func (*SchemaChangeGCProgress_IndexProgress) Descriptor Uses

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

func (*SchemaChangeGCProgress_IndexProgress) Marshal Uses

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

func (*SchemaChangeGCProgress_IndexProgress) MarshalTo Uses

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

func (*SchemaChangeGCProgress_IndexProgress) ProtoMessage Uses

func (*SchemaChangeGCProgress_IndexProgress) ProtoMessage()

func (*SchemaChangeGCProgress_IndexProgress) Reset Uses

func (m *SchemaChangeGCProgress_IndexProgress) Reset()

func (*SchemaChangeGCProgress_IndexProgress) Size Uses

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

func (*SchemaChangeGCProgress_IndexProgress) String Uses

func (m *SchemaChangeGCProgress_IndexProgress) String() string

func (*SchemaChangeGCProgress_IndexProgress) Unmarshal Uses

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

func (*SchemaChangeGCProgress_IndexProgress) XXX_DiscardUnknown Uses

func (m *SchemaChangeGCProgress_IndexProgress) XXX_DiscardUnknown()

func (*SchemaChangeGCProgress_IndexProgress) XXX_Marshal Uses

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

func (*SchemaChangeGCProgress_IndexProgress) XXX_Merge Uses

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

func (*SchemaChangeGCProgress_IndexProgress) XXX_Size Uses

func (m *SchemaChangeGCProgress_IndexProgress) XXX_Size() int

func (*SchemaChangeGCProgress_IndexProgress) XXX_Unmarshal Uses

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

type SchemaChangeGCProgress_Status Uses

type SchemaChangeGCProgress_Status int32
const (
    // Waiting for the index/table to expire.
    SchemaChangeGCProgress_WAITING_FOR_GC SchemaChangeGCProgress_Status = 0
    // The GC TTL has expired. This element is marked for imminent deletion
    SchemaChangeGCProgress_DELETING SchemaChangeGCProgress_Status = 1
    // This element has been deleted. The job is done when all elements are in
    // this state.
    SchemaChangeGCProgress_DELETED SchemaChangeGCProgress_Status = 2
)

func (SchemaChangeGCProgress_Status) EnumDescriptor Uses

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

func (SchemaChangeGCProgress_Status) String Uses

func (x SchemaChangeGCProgress_Status) String() string

type SchemaChangeGCProgress_TableProgress Uses

type SchemaChangeGCProgress_TableProgress struct {
    ID     github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID `protobuf:"varint,1,opt,name=id,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"id,omitempty"`
    Status SchemaChangeGCProgress_Status                       `protobuf:"varint,2,opt,name=status,proto3,enum=cockroach.sql.jobs.jobspb.SchemaChangeGCProgress_Status" json:"status,omitempty"`
}

func (*SchemaChangeGCProgress_TableProgress) Descriptor Uses

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

func (*SchemaChangeGCProgress_TableProgress) Marshal Uses

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

func (*SchemaChangeGCProgress_TableProgress) MarshalTo Uses

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

func (*SchemaChangeGCProgress_TableProgress) ProtoMessage Uses

func (*SchemaChangeGCProgress_TableProgress) ProtoMessage()

func (*SchemaChangeGCProgress_TableProgress) Reset Uses

func (m *SchemaChangeGCProgress_TableProgress) Reset()

func (*SchemaChangeGCProgress_TableProgress) Size Uses

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

func (*SchemaChangeGCProgress_TableProgress) String Uses

func (m *SchemaChangeGCProgress_TableProgress) String() string

func (*SchemaChangeGCProgress_TableProgress) Unmarshal Uses

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

func (*SchemaChangeGCProgress_TableProgress) XXX_DiscardUnknown Uses

func (m *SchemaChangeGCProgress_TableProgress) XXX_DiscardUnknown()

func (*SchemaChangeGCProgress_TableProgress) XXX_Marshal Uses

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

func (*SchemaChangeGCProgress_TableProgress) XXX_Merge Uses

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

func (*SchemaChangeGCProgress_TableProgress) XXX_Size Uses

func (m *SchemaChangeGCProgress_TableProgress) XXX_Size() int

func (*SchemaChangeGCProgress_TableProgress) XXX_Unmarshal Uses

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

type SchemaChangeProgress Uses

type SchemaChangeProgress struct {
}

func (*SchemaChangeProgress) Descriptor Uses

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

func (*SchemaChangeProgress) Marshal Uses

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

func (*SchemaChangeProgress) MarshalTo Uses

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

func (*SchemaChangeProgress) ProtoMessage Uses

func (*SchemaChangeProgress) ProtoMessage()

func (*SchemaChangeProgress) Reset Uses

func (m *SchemaChangeProgress) Reset()

func (*SchemaChangeProgress) Size Uses

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

func (*SchemaChangeProgress) String Uses

func (m *SchemaChangeProgress) String() string

func (*SchemaChangeProgress) Unmarshal Uses

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

func (*SchemaChangeProgress) XXX_DiscardUnknown Uses

func (m *SchemaChangeProgress) XXX_DiscardUnknown()

func (*SchemaChangeProgress) XXX_Marshal Uses

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

func (*SchemaChangeProgress) XXX_Merge Uses

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

func (*SchemaChangeProgress) XXX_Size Uses

func (m *SchemaChangeProgress) XXX_Size() int

func (*SchemaChangeProgress) XXX_Unmarshal Uses

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

type SqlStatementExecutionArg Uses

type SqlStatementExecutionArg struct {
    Statement string `protobuf:"bytes,1,opt,name=statement,proto3" json:"statement,omitempty"`
}

Message representing sql statement to execute.

func (*SqlStatementExecutionArg) Descriptor Uses

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

func (*SqlStatementExecutionArg) Marshal Uses

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

func (*SqlStatementExecutionArg) MarshalTo Uses

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

func (*SqlStatementExecutionArg) ProtoMessage Uses

func (*SqlStatementExecutionArg) ProtoMessage()

func (*SqlStatementExecutionArg) Reset Uses

func (m *SqlStatementExecutionArg) Reset()

func (*SqlStatementExecutionArg) Size Uses

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

func (*SqlStatementExecutionArg) String Uses

func (m *SqlStatementExecutionArg) String() string

func (*SqlStatementExecutionArg) Unmarshal Uses

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

func (*SqlStatementExecutionArg) XXX_DiscardUnknown Uses

func (m *SqlStatementExecutionArg) XXX_DiscardUnknown()

func (*SqlStatementExecutionArg) XXX_Marshal Uses

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

func (*SqlStatementExecutionArg) XXX_Merge Uses

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

func (*SqlStatementExecutionArg) XXX_Size Uses

func (m *SqlStatementExecutionArg) XXX_Size() int

func (*SqlStatementExecutionArg) XXX_Unmarshal Uses

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

type Status Uses

type Status int32
const (
    Status_DRAINING_NAMES       Status = 0
    Status_WAIT_FOR_GC_INTERVAL Status = 1
    Status_ROCKSDB_COMPACTION   Status = 2
    Status_DONE                 Status = 10
)

func (Status) EnumDescriptor Uses

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

func (Status) String Uses

func (x Status) String() string

type Type Uses

type Type int32
const (
    TypeUnspecified     Type = 0
    TypeBackup          Type = 1
    TypeRestore         Type = 2
    TypeSchemaChange    Type = 3
    TypeImport          Type = 4
    TypeChangefeed      Type = 5
    TypeCreateStats     Type = 6
    TypeAutoCreateStats Type = 7
    TypeSchemaChangeGC  Type = 8
)

func DetailsType Uses

func DetailsType(d isPayload_Details) Type

DetailsType returns the type for a payload detail.

func (Type) EnumDescriptor Uses

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

func (Type) String Uses

func (t Type) String() string

Package jobspb imports 15 packages (graph) and is imported by 67 packages. Updated 2020-07-10. Refresh now. Tools for package owners.