persistencetest

Documentation

Index

• func EnqueueMessage(ctx context.Context, queue persistence.QueueV2, ...) (*persistence.InternalEnqueueMessageResponse, error)
• func EnqueueMessagesForDelete(t *testing.T, q persistence.QueueV2, queueName string, ...)
• func GetQueueKey(t *testing.T, opts ...func(p *getQueueKeyParams)) persistence.QueueKey
• func WithCategory(category tasks.Category) func(p *getQueueKeyParams)
• func WithQueueType(queueType persistence.QueueV2Type) func(p *getQueueKeyParams)
• type EnqueueParams

Functions

func EnqueueMessage

func EnqueueMessage(
	ctx context.Context,
	queue persistence.QueueV2,
	queueType persistence.QueueV2Type,
	queueName string,
	opts ...func(p *EnqueueParams),
) (*persistence.InternalEnqueueMessageResponse, error)

func EnqueueMessagesForDelete

func EnqueueMessagesForDelete(t *testing.T, q persistence.QueueV2, queueName string, queueType persistence.QueueV2Type)

func GetQueueKey

func GetQueueKey(t *testing.T, opts ...func(p *getQueueKeyParams)) persistence.QueueKey

func WithCategory

func WithCategory(category tasks.Category) func(p *getQueueKeyParams)

func WithQueueType

func WithQueueType(queueType persistence.QueueV2Type) func(p *getQueueKeyParams)

Types

type EnqueueParams

type EnqueueParams struct {
	Data         []byte
	EncodingType int
}