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 wrap.go

Variables

var (
    ErrInvalidLengthJobs = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowJobs   = fmt.Errorf("proto: integer overflow")
)
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",
}
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,
}

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"`
    BackupDescriptor []byte            `protobuf:"bytes,4,opt,name=backup_descriptor,json=backupDescriptor,proto3" json:"backup_descriptor,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"`
}

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

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 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"`
    PrepareComplete bool                                                `protobuf:"varint,12,opt,name=prepare_complete,json=prepareComplete,proto3" json:"prepare_complete,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"`
}

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.
    CompletedRow []uint64 `protobuf:"varint,5,rep,packed,name=completed_row,json=completedRow,proto3" json:"completed_row,omitempty"`
}

func (ImportProgress) Completed Uses

func (d ImportProgress) Completed() float32

Completed returns the total complete percent of processing this table. There are two phases: sampling, SST writing. The SST phase is divided into two stages: read CSV, write SST. Thus, the entire progress can be measured by (sampling + read csv + write sst) progress. Since there are multiple distSQL processors running these stages, we assign slots to each one, and they are in charge of updating their portion of the progress. Since we read over CSV files twice (once for sampling, once for SST writing), we must indicate which phase we are in. This is done using the SamplingProgress slice, which is empty if we are in the second stage (and can thus be implied as complete).

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 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"`
    Error          string                                                `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
    Lease          *Lease                                                `protobuf:"bytes,9,opt,name=lease,proto3" json:"lease,omitempty"`
    // Types that are valid to be assigned to Details:
    //	*Payload_Backup
    //	*Payload_Restore
    //	*Payload_SchemaChange
    //	*Payload_Import
    //	*Payload_Changefeed
    //	*Payload_CreateStats
    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) 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 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
    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) 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 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"`
}

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"`
    TableRewrites map[github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID]*RestoreDetails_TableRewrite `protobuf:"bytes,2,rep,name=table_rewrites,json=tableRewrites,proto3,castkey=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"table_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"`
}

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

type RestoreDetails_TableRewrite struct {
    TableID  github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID `protobuf:"varint,1,opt,name=table_id,json=tableId,proto3,casttype=github.com/cockroachdb/cockroach/pkg/sql/sqlbase.ID" json:"table_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"`
}

func (*RestoreDetails_TableRewrite) Descriptor Uses

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

func (*RestoreDetails_TableRewrite) Marshal Uses

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

func (*RestoreDetails_TableRewrite) MarshalTo Uses

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

func (*RestoreDetails_TableRewrite) ProtoMessage Uses

func (*RestoreDetails_TableRewrite) ProtoMessage()

func (*RestoreDetails_TableRewrite) Reset Uses

func (m *RestoreDetails_TableRewrite) Reset()

func (*RestoreDetails_TableRewrite) Size Uses

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

func (*RestoreDetails_TableRewrite) String Uses

func (m *RestoreDetails_TableRewrite) String() string

func (*RestoreDetails_TableRewrite) Unmarshal Uses

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

func (*RestoreDetails_TableRewrite) XXX_DiscardUnknown Uses

func (m *RestoreDetails_TableRewrite) XXX_DiscardUnknown()

func (*RestoreDetails_TableRewrite) XXX_Marshal Uses

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

func (*RestoreDetails_TableRewrite) XXX_Merge Uses

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

func (*RestoreDetails_TableRewrite) XXX_Size Uses

func (m *RestoreDetails_TableRewrite) XXX_Size() int

func (*RestoreDetails_TableRewrite) XXX_Unmarshal Uses

func (m *RestoreDetails_TableRewrite) 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 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"`
}

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

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 11 packages (graph) and is imported by 26 packages. Updated 2019-09-19. Refresh now. Tools for package owners.