replication

Documentation

Index

• func GenerateTask(ctx context.Context, ...) (_ *historyservice.GenerateLastHistoryReplicationTasksResponse, retError error)
• func GetDLQTasks(ctx context.Context, shard shard.Context, ...) ([]*replicationspb.ReplicationTask, error)
• func GetStatus(ctx context.Context, request *historyservice.GetReplicationStatusRequest, ...) (_ *historyservice.ShardReplicationStatus, retError error)
• func GetTasks(ctx context.Context, shardContext shard.Context, ...) (*replicationspb.ReplicationMessages, error)
• func SyncWorkflowState(ctx context.Context, request *historyservice.SyncWorkflowStateRequest, ...) (_ *historyservice.SyncWorkflowStateResponse, retError error)

Functions

func GenerateTask

func GenerateTask(
	ctx context.Context,
	request *historyservice.GenerateLastHistoryReplicationTasksRequest,
	shard shard.Context,
	workflowConsistencyChecker api.WorkflowConsistencyChecker,
) (_ *historyservice.GenerateLastHistoryReplicationTasksResponse, retError error)

func GetDLQTasks

func GetDLQTasks(
	ctx context.Context,
	shard shard.Context,
	replicationAckMgr replication.AckManager,
	taskInfos []*replicationspb.ReplicationTaskInfo,
) ([]*replicationspb.ReplicationTask, error)

func GetStatus

func GetStatus(
	ctx context.Context,
	request *historyservice.GetReplicationStatusRequest,
	shard shard.Context,
	replicationAckMgr replication.AckManager,
) (_ *historyservice.ShardReplicationStatus, retError error)

func GetTasks

func GetTasks(
	ctx context.Context,
	shardContext shard.Context,
	replicationAckMgr replication.AckManager,
	pollingCluster string,
	ackMessageID int64,
	ackTimestamp time.Time,
	queryMessageID int64,
) (*replicationspb.ReplicationMessages, error)

func SyncWorkflowState

func SyncWorkflowState(
	ctx context.Context,
	request *historyservice.SyncWorkflowStateRequest,
	replicationProgressCache replication.ProgressCache,
	syncStateRetriever replication.SyncStateRetriever,
	logger log.Logger,
) (_ *historyservice.SyncWorkflowStateResponse, retError error)