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) 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-10-10. Refresh now. Tools for package owners.