| // Copyright 2022 CeresDB Project Authors. Licensed under Apache-2.0. |
| |
| package procedure |
| |
| import "github.com/CeresDB/ceresmeta/pkg/coderr" |
| |
| var ( |
| ErrShardLeaderNotFound = coderr.NewCodeError(coderr.Internal, "shard leader not found") |
| ErrProcedureNotFound = coderr.NewCodeError(coderr.Internal, "procedure not found") |
| ErrClusterConfigChanged = coderr.NewCodeError(coderr.Internal, "cluster config changed") |
| ErrTableNotExists = coderr.NewCodeError(coderr.Internal, "table not exists") |
| ErrTableAlreadyExists = coderr.NewCodeError(coderr.Internal, "table already exists") |
| ErrProcedureTypeNotMatch = coderr.NewCodeError(coderr.Internal, "procedure type not match") |
| ErrDecodeRawData = coderr.NewCodeError(coderr.Internal, "decode raw data") |
| ErrEncodeRawData = coderr.NewCodeError(coderr.Internal, "encode raw data") |
| ErrGetRequest = coderr.NewCodeError(coderr.Internal, "get request from event") |
| ErrNodeNumberNotEnough = coderr.NewCodeError(coderr.Internal, "node number not enough") |
| ErrEmptyPartitionNames = coderr.NewCodeError(coderr.Internal, "partition names is empty") |
| ErrDropTableResult = coderr.NewCodeError(coderr.Internal, "length of shard not correct") |
| ErrPickShard = coderr.NewCodeError(coderr.Internal, "pick shard failed") |
| ErrSubmitProcedure = coderr.NewCodeError(coderr.Internal, "submit new procedure") |
| ErrQueueFull = coderr.NewCodeError(coderr.Internal, "queue is full, unable to offer more data") |
| ErrPushDuplicatedProcedure = coderr.NewCodeError(coderr.Internal, "try to push duplicated procedure") |
| ErrShardNumberNotEnough = coderr.NewCodeError(coderr.Internal, "shard number not enough") |
| ErrEmptyBatchProcedure = coderr.NewCodeError(coderr.Internal, "procedure batch is empty") |
| ErrMergeBatchProcedure = coderr.NewCodeError(coderr.Internal, "failed to merge procedures batch") |
| ) |