replicationadmin

package

v1.26.2-125.0 Latest Latest Go to latest Published: Dec 2, 2024 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/temporalio/temporal

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.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL