Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

jobs

package

Go to main page

Versions in this module

v1

v1.1.9

Oct 1, 2018

v1.1.9-rc.1

Sep 24, 2018

v1.1.8

Apr 19, 2018

v1.1.7

Mar 20, 2018

v1.1.6

Mar 2, 2018

v1.1.5

Jan 29, 2018

v1.1.4

Jan 1, 2018

v1.1.3

Nov 21, 2017

Changes in this version

+ var RestoreFailHook func(context.Context, *client.Txn, *RestoreDetails) error

v1.1.2

Oct 26, 2017

v1.1.1

Oct 16, 2017

v1.1.0

Oct 4, 2017

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

v1.1.0-rc.1

Oct 4, 2017

Incompatible versions in this module

v2.1.0-alpha.20180507+incompatible

Apr 30, 2018

v2.1.0-alpha.20180416+incompatible

Apr 10, 2018

v2.0.7+incompatible

Nov 28, 2018

v2.0.6+incompatible

Oct 1, 2018

v2.0.6-rc.1+incompatible

Sep 24, 2018

v2.0.5+incompatible

Aug 6, 2018

v2.0.4+incompatible

Jul 10, 2018

v2.0.3+incompatible

Jun 13, 2018

v2.0.2+incompatible

May 14, 2018

v2.0.1+incompatible

Apr 16, 2018

v2.0.0+incompatible

Apr 3, 2018