Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Config ¶
type Config struct {
SafetyCommitOffsetPaddingSize int64 `config:"safety_commit_offset_padding_size"` //offset between last and wal
SafetyCommitIntervalInSeconds int64 `config:"safety_commit_interval_in_seconds"` //time between last and wal
SafetyCommitRetryTimes int `config:"safety_commit_retry_times"` //retry times
PartitionSize int `config:"partition_size"` //retry times
}
type MessageRecord ¶
type ReplicationCorrectionGroup ¶
type ReplicationCorrectionGroup struct {
PreStageQueueName string `config:"pre_stage_queue"`
//FirstStageQueueName string `config:"first_stage_queue"`
FinalStageQueueName string `config:"final_stage_queue"`
// contains filtered or unexported fields
}
func (*ReplicationCorrectionGroup) Name ¶
func (processor *ReplicationCorrectionGroup) Name() string
type ReplicationCorrectionProcessor ¶
type ReplicationCorrectionProcessor struct {
// contains filtered or unexported fields
}
func (*ReplicationCorrectionProcessor) Name ¶
func (processor *ReplicationCorrectionProcessor) Name() string
func (*ReplicationCorrectionProcessor) Process ¶
func (processor *ReplicationCorrectionProcessor) Process(ctx *pipeline.Context) error
func (*ReplicationCorrectionProcessor) Stop ¶
func (processor *ReplicationCorrectionProcessor) Stop() error
Click to show internal directories.
Click to hide internal directories.