Documentation ¶
Index ¶
- func GetDLQ(ctx context.Context, request *historyservice.GetDLQMessagesRequest, ...) (*historyservice.GetDLQMessagesResponse, error)
- func MergeDLQ(ctx context.Context, request *historyservice.MergeDLQMessagesRequest, ...) (*historyservice.MergeDLQMessagesResponse, error)
- func PurgeDLQ(ctx context.Context, request *historyservice.PurgeDLQMessagesRequest, ...) (*historyservice.PurgeDLQMessagesResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetDLQ ¶
func GetDLQ( ctx context.Context, request *historyservice.GetDLQMessagesRequest, shard shard.Context, replicationDLQHandler replication.DLQHandler, ) (*historyservice.GetDLQMessagesResponse, error)
func MergeDLQ ¶
func MergeDLQ( ctx context.Context, request *historyservice.MergeDLQMessagesRequest, shard shard.Context, replicationDLQHandler replication.DLQHandler, ) (*historyservice.MergeDLQMessagesResponse, error)
func PurgeDLQ ¶
func PurgeDLQ( ctx context.Context, request *historyservice.PurgeDLQMessagesRequest, shard shard.Context, replicationDLQHandler replication.DLQHandler, ) (*historyservice.PurgeDLQMessagesResponse, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.