Versions in this module Expand all Collapse all v1 v1.1.4 Jan 1, 2018 Changes in this version + const DefaultCancelInterval + var DefaultAdoptInterval = 30 * time.Second + var ErrIntOverflowJobs = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthJobs = fmt.Errorf("proto: negative length found during unmarshaling") + var RestoreFailHook func(context.Context, *client.Txn, *RestoreDetails) error + var Type_name = map[int32]string + var Type_value = map[string]int32 + var WithoutCancel func() + func AddResumeHook(fn resumeHookFn) + func WrapPayloadDetails(details Details) interface + type BackupDetails struct + EndTime cockroach_util_hlc.Timestamp + StartTime cockroach_util_hlc.Timestamp + URI string + func (*BackupDetails) Descriptor() ([]byte, []int) + func (*BackupDetails) ProtoMessage() + func (m *BackupDetails) Marshal() (dAtA []byte, err error) + func (m *BackupDetails) MarshalTo(dAtA []byte) (int, error) + func (m *BackupDetails) Reset() + func (m *BackupDetails) Size() (n int) + func (m *BackupDetails) String() string + func (m *BackupDetails) Unmarshal(dAtA []byte) error + type Details interface + type ImportDetails struct + Tables []ImportDetails_Table + func (*ImportDetails) Descriptor() ([]byte, []int) + func (*ImportDetails) ProtoMessage() + func (m *ImportDetails) Marshal() (dAtA []byte, err error) + func (m *ImportDetails) MarshalTo(dAtA []byte) (int, error) + func (m *ImportDetails) Reset() + func (m *ImportDetails) Size() (n int) + func (m *ImportDetails) String() string + func (m *ImportDetails) Unmarshal(dAtA []byte) error + type ImportDetails_Table struct + BackupPath string + Desc *cockroach_sql_sqlbase1.TableDescriptor + Options *cockroach_roachpb1.CSVOptions + URIs []string + func (*ImportDetails_Table) Descriptor() ([]byte, []int) + func (*ImportDetails_Table) ProtoMessage() + func (m *ImportDetails_Table) Marshal() (dAtA []byte, err error) + func (m *ImportDetails_Table) MarshalTo(dAtA []byte) (int, error) + func (m *ImportDetails_Table) Reset() + func (m *ImportDetails_Table) Size() (n int) + func (m *ImportDetails_Table) String() string + func (m *ImportDetails_Table) Unmarshal(dAtA []byte) error + type InvalidStatusError struct + func (e *InvalidStatusError) Error() string + type Job struct + Record Record + func (j *Job) Canceled(ctx context.Context) error + func (j *Job) ClusterID() uuid.UUID + func (j *Job) Created(ctx context.Context, cancelFn func()) error + func (j *Job) DB() *client.DB + func (j *Job) Failed(ctx context.Context, err error) + func (j *Job) FinishedWith(ctx context.Context, err error) error + func (j *Job) Gossip() *gossip.Gossip + func (j *Job) ID() *int64 + func (j *Job) NodeID() roachpb.NodeID + func (j *Job) Paused(ctx context.Context) error + func (j *Job) Payload() Payload + func (j *Job) Progressed(ctx context.Context, fractionCompleted float32, progressedFn ProgressedFn) error + func (j *Job) Resumed(ctx context.Context) error + func (j *Job) SetDetails(ctx context.Context, details interface{}) error + func (j *Job) Started(ctx context.Context) error + func (j *Job) Succeeded(ctx context.Context) error + func (j *Job) WithTxn(txn *client.Txn) *Job + type Lease struct + Epoch int64 + NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID + func (*Lease) Descriptor() ([]byte, []int) + func (*Lease) ProtoMessage() + func (m *Lease) Marshal() (dAtA []byte, err error) + func (m *Lease) MarshalTo(dAtA []byte) (int, error) + func (m *Lease) Reset() + func (m *Lease) Size() (n int) + func (m *Lease) String() string + func (m *Lease) Unmarshal(dAtA []byte) error + func (this *Lease) Equal(that interface{}) bool + type Payload struct + Description string + DescriptorIDs []github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID + Details isPayload_Details + Error string + FinishedMicros int64 + FractionCompleted float32 + Lease *Lease + ModifiedMicros int64 + StartedMicros int64 + Username string + func UnmarshalPayload(datum parser.Datum) (*Payload, error) + func (*Payload) Descriptor() ([]byte, []int) + func (*Payload) ProtoMessage() + func (*Payload) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *Payload) GetBackup() *BackupDetails + func (m *Payload) GetDetails() isPayload_Details + func (m *Payload) GetImport() *ImportDetails + func (m *Payload) GetRestore() *RestoreDetails + func (m *Payload) GetSchemaChange() *SchemaChangeDetails + func (m *Payload) Marshal() (dAtA []byte, err error) + func (m *Payload) MarshalTo(dAtA []byte) (int, error) + func (m *Payload) Reset() + func (m *Payload) Size() (n int) + func (m *Payload) String() string + func (m *Payload) Unmarshal(dAtA []byte) error + func (p *Payload) Type() Type + func (p *Payload) UnwrapDetails() (Details, error) + type Payload_Backup struct + Backup *BackupDetails + func (m *Payload_Backup) MarshalTo(dAtA []byte) (int, error) + func (m *Payload_Backup) Size() (n int) + type Payload_Import struct + Import *ImportDetails + func (m *Payload_Import) MarshalTo(dAtA []byte) (int, error) + func (m *Payload_Import) Size() (n int) + type Payload_Restore struct + Restore *RestoreDetails + func (m *Payload_Restore) MarshalTo(dAtA []byte) (int, error) + func (m *Payload_Restore) Size() (n int) + type Payload_SchemaChange struct + SchemaChange *SchemaChangeDetails + func (m *Payload_SchemaChange) MarshalTo(dAtA []byte) (int, error) + func (m *Payload_SchemaChange) Size() (n int) + type ProgressedFn func(ctx context.Context, details interface{}) + var Noop ProgressedFn + type Record struct + Description string + DescriptorIDs sqlbase.IDs + Details Details + Username string + type Registry struct + func MakeRegistry(clock *hlc.Clock, db *client.DB, ex sqlutil.InternalExecutor, ...) *Registry + func (r *Registry) LoadJob(ctx context.Context, jobID int64) (*Job, error) + func (r *Registry) LoadJobWithTxn(ctx context.Context, jobID int64, txn *client.Txn) (*Job, error) + func (r *Registry) NewJob(record Record) *Job + func (r *Registry) Start(ctx context.Context, stopper *stop.Stopper, nl nodeLiveness, ...) error + type RestoreDetails struct + LowWaterMark []byte + TableRewrites map[github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID]*RestoreDetails_TableRewrite + URIs []string + func (*RestoreDetails) Descriptor() ([]byte, []int) + func (*RestoreDetails) ProtoMessage() + func (m *RestoreDetails) Marshal() (dAtA []byte, err error) + func (m *RestoreDetails) MarshalTo(dAtA []byte) (int, error) + func (m *RestoreDetails) Reset() + func (m *RestoreDetails) Size() (n int) + func (m *RestoreDetails) String() string + func (m *RestoreDetails) Unmarshal(dAtA []byte) error + type RestoreDetails_TableRewrite struct + ParentID github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID + TableID github_com_cockroachdb_cockroach_pkg_sql_sqlbase.ID + func (*RestoreDetails_TableRewrite) Descriptor() ([]byte, []int) + func (*RestoreDetails_TableRewrite) ProtoMessage() + func (m *RestoreDetails_TableRewrite) Marshal() (dAtA []byte, err error) + func (m *RestoreDetails_TableRewrite) MarshalTo(dAtA []byte) (int, error) + func (m *RestoreDetails_TableRewrite) Reset() + func (m *RestoreDetails_TableRewrite) Size() (n int) + func (m *RestoreDetails_TableRewrite) String() string + func (m *RestoreDetails_TableRewrite) Unmarshal(dAtA []byte) error + type ResumeSpanList struct + ResumeSpans []cockroach_roachpb1.Span + func (*ResumeSpanList) Descriptor() ([]byte, []int) + func (*ResumeSpanList) ProtoMessage() + func (m *ResumeSpanList) Marshal() (dAtA []byte, err error) + func (m *ResumeSpanList) MarshalTo(dAtA []byte) (int, error) + func (m *ResumeSpanList) Reset() + func (m *ResumeSpanList) Size() (n int) + func (m *ResumeSpanList) String() string + func (m *ResumeSpanList) Unmarshal(dAtA []byte) error + type SchemaChangeDetails struct + ReadAsOf cockroach_util_hlc.Timestamp + ResumeSpanList []ResumeSpanList + func (*SchemaChangeDetails) Descriptor() ([]byte, []int) + func (*SchemaChangeDetails) ProtoMessage() + func (m *SchemaChangeDetails) Marshal() (dAtA []byte, err error) + func (m *SchemaChangeDetails) MarshalTo(dAtA []byte) (int, error) + func (m *SchemaChangeDetails) Reset() + func (m *SchemaChangeDetails) Size() (n int) + func (m *SchemaChangeDetails) String() string + func (m *SchemaChangeDetails) Unmarshal(dAtA []byte) error + type Status string + const StatusCanceled + const StatusFailed + const StatusPaused + const StatusPending + const StatusRunning + const StatusSucceeded + func RunAndWaitForTerminalState(ctx context.Context, sqlDB *gosql.DB, execFn func(context.Context) error) (int64, Status, error) + func (s Status) Terminal() bool + type Type int32 + const TypeBackup + const TypeImport + const TypeRestore + const TypeSchemaChange + const TypeUnspecified + func (Type) EnumDescriptor() ([]byte, []int) + func (t Type) String() string