dlq

Mar 22, 2024

Changes in this version

+ const DefaultMergeBatchSize

+ const MaxMergeBatchSize

+ const QueryTypeProgress

+ const WorkflowName

+ const WorkflowTypeDelete

+ const WorkflowTypeMerge

+ var ErrMergeBatchSizeTooLarge = errors.New("BatchSize too large")

+ var ErrNegativeBatchSize = errors.New("BatchSize must be positive or 0 to use the default")

+ var Module = workercommon.AnnotateWorkerComponentProvider(newComponent)

+ type AddTasksFn func(ctx context.Context, req *adminservice.AddTasksRequest) (*adminservice.AddTasksResponse, error)

+ func (f AddTasksFn) AddTasks(ctx context.Context, in *adminservice.AddTasksRequest) (*adminservice.AddTasksResponse, error)

+ type CurrentClusterName string

+ type DeleteParams struct

+ MaxMessageID int64

+ type HistoryClient interface

+ DeleteDLQTasks func(ctx context.Context, in *historyservice.DeleteDLQTasksRequest, ...) (*historyservice.DeleteDLQTasksResponse, error)

+ GetDLQTasks func(ctx context.Context, in *historyservice.GetDLQTasksRequest, ...) (*historyservice.GetDLQTasksResponse, error)

+ type Key struct

+ SourceCluster string

+ TargetCluster string

+ TaskCategoryID int

+ type MergeParams struct

+ BatchSize int

+ MaxMessageID int64

+ type ProgressQueryResponse struct

+ DlqKey Key

+ LastProcessedMessageID int64

+ MaxMessageIDToProcess int64

+ NumberOfMessagesProcessed int64

+ WorkflowType string

+ type TaskClient interface

+ AddTasks func(ctx context.Context, in *adminservice.AddTasksRequest) (*adminservice.AddTasksResponse, error)

+ type TaskClientDialer interface

+ Dial func(ctx context.Context, cluster string) (TaskClient, error)

+ type TaskClientDialerFn func(ctx context.Context, address string) (TaskClient, error)

+ func (f TaskClientDialerFn) Dial(ctx context.Context, cluster string) (TaskClient, error)

+ type WorkflowParams struct

+ DeleteParams DeleteParams

+ MergeParams MergeParams

+ WorkflowType string