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, shard shard.Context, ...) (*replicationspb.ReplicationMessages, 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,
	shard shard.Context,
	replicationAckMgr replication.AckManager,
	pollingCluster string,
	ackMessageID int64,
	ackTimestamp time.Time,
	queryMessageID int64,
) (*replicationspb.ReplicationMessages, error)