Documentation ¶
Index ¶
- func NewProcedure(params ProcedureParams) (procedure.Procedure, error)
- type Procedure
- func (p *Procedure) Cancel(_ context.Context) error
- func (p *Procedure) ID() uint64
- func (p *Procedure) Priority() procedure.Priority
- func (p *Procedure) RelatedVersionInfo() procedure.RelatedVersionInfo
- func (p *Procedure) Start(ctx context.Context) error
- func (p *Procedure) State() procedure.State
- func (p *Procedure) Typ() procedure.Typ
- type ProcedureParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewProcedure ¶
func NewProcedure(params ProcedureParams) (procedure.Procedure, error)
Types ¶
type Procedure ¶
type Procedure struct {
// contains filtered or unexported fields
}
func (*Procedure) RelatedVersionInfo ¶
func (p *Procedure) RelatedVersionInfo() procedure.RelatedVersionInfo
type ProcedureParams ¶
type ProcedureParams struct { Dispatch eventdispatch.Dispatch ClusterMetadata *metadata.ClusterMetadata ClusterSnapshot metadata.Snapshot ID uint64 ShardID storage.ShardID SourceReq *metaservicepb.CreateTableRequest OnSucceeded func(metadata.CreateTableResult) error OnFailed func(error) error }
Click to show internal directories.
Click to hide internal directories.