sqsstub

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 31, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddPermissionFuture 

type AddPermissionFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*AddPermissionFuture) Get 

func (r *AddPermissionFuture) Get(ctx workflow.Context) (*sqs.AddPermissionOutput, error)

type ChangeMessageVisibilityBatchFuture 

type ChangeMessageVisibilityBatchFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ChangeMessageVisibilityBatchFuture) Get 

func (r *ChangeMessageVisibilityBatchFuture) Get(ctx workflow.Context) (*sqs.ChangeMessageVisibilityBatchOutput, error)

type ChangeMessageVisibilityFuture 

type ChangeMessageVisibilityFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ChangeMessageVisibilityFuture) Get 

func (r *ChangeMessageVisibilityFuture) Get(ctx workflow.Context) (*sqs.ChangeMessageVisibilityOutput, error)

type Client 

type Client interface {
	AddPermission(ctx workflow.Context, input *sqs.AddPermissionInput) (*sqs.AddPermissionOutput, error)
	AddPermissionAsync(ctx workflow.Context, input *sqs.AddPermissionInput) *AddPermissionFuture

	ChangeMessageVisibility(ctx workflow.Context, input *sqs.ChangeMessageVisibilityInput) (*sqs.ChangeMessageVisibilityOutput, error)
	ChangeMessageVisibilityAsync(ctx workflow.Context, input *sqs.ChangeMessageVisibilityInput) *ChangeMessageVisibilityFuture

	ChangeMessageVisibilityBatch(ctx workflow.Context, input *sqs.ChangeMessageVisibilityBatchInput) (*sqs.ChangeMessageVisibilityBatchOutput, error)
	ChangeMessageVisibilityBatchAsync(ctx workflow.Context, input *sqs.ChangeMessageVisibilityBatchInput) *ChangeMessageVisibilityBatchFuture

	CreateQueue(ctx workflow.Context, input *sqs.CreateQueueInput) (*sqs.CreateQueueOutput, error)
	CreateQueueAsync(ctx workflow.Context, input *sqs.CreateQueueInput) *CreateQueueFuture

	DeleteMessage(ctx workflow.Context, input *sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)
	DeleteMessageAsync(ctx workflow.Context, input *sqs.DeleteMessageInput) *DeleteMessageFuture

	DeleteMessageBatch(ctx workflow.Context, input *sqs.DeleteMessageBatchInput) (*sqs.DeleteMessageBatchOutput, error)
	DeleteMessageBatchAsync(ctx workflow.Context, input *sqs.DeleteMessageBatchInput) *DeleteMessageBatchFuture

	DeleteQueue(ctx workflow.Context, input *sqs.DeleteQueueInput) (*sqs.DeleteQueueOutput, error)
	DeleteQueueAsync(ctx workflow.Context, input *sqs.DeleteQueueInput) *DeleteQueueFuture

	GetQueueAttributes(ctx workflow.Context, input *sqs.GetQueueAttributesInput) (*sqs.GetQueueAttributesOutput, error)
	GetQueueAttributesAsync(ctx workflow.Context, input *sqs.GetQueueAttributesInput) *GetQueueAttributesFuture

	GetQueueUrl(ctx workflow.Context, input *sqs.GetQueueUrlInput) (*sqs.GetQueueUrlOutput, error)
	GetQueueUrlAsync(ctx workflow.Context, input *sqs.GetQueueUrlInput) *GetQueueUrlFuture

	ListDeadLetterSourceQueues(ctx workflow.Context, input *sqs.ListDeadLetterSourceQueuesInput) (*sqs.ListDeadLetterSourceQueuesOutput, error)
	ListDeadLetterSourceQueuesAsync(ctx workflow.Context, input *sqs.ListDeadLetterSourceQueuesInput) *ListDeadLetterSourceQueuesFuture

	ListQueueTags(ctx workflow.Context, input *sqs.ListQueueTagsInput) (*sqs.ListQueueTagsOutput, error)
	ListQueueTagsAsync(ctx workflow.Context, input *sqs.ListQueueTagsInput) *ListQueueTagsFuture

	ListQueues(ctx workflow.Context, input *sqs.ListQueuesInput) (*sqs.ListQueuesOutput, error)
	ListQueuesAsync(ctx workflow.Context, input *sqs.ListQueuesInput) *ListQueuesFuture

	PurgeQueue(ctx workflow.Context, input *sqs.PurgeQueueInput) (*sqs.PurgeQueueOutput, error)
	PurgeQueueAsync(ctx workflow.Context, input *sqs.PurgeQueueInput) *PurgeQueueFuture

	ReceiveMessage(ctx workflow.Context, input *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)
	ReceiveMessageAsync(ctx workflow.Context, input *sqs.ReceiveMessageInput) *ReceiveMessageFuture

	RemovePermission(ctx workflow.Context, input *sqs.RemovePermissionInput) (*sqs.RemovePermissionOutput, error)
	RemovePermissionAsync(ctx workflow.Context, input *sqs.RemovePermissionInput) *RemovePermissionFuture

	SendMessage(ctx workflow.Context, input *sqs.SendMessageInput) (*sqs.SendMessageOutput, error)
	SendMessageAsync(ctx workflow.Context, input *sqs.SendMessageInput) *SendMessageFuture

	SendMessageBatch(ctx workflow.Context, input *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)
	SendMessageBatchAsync(ctx workflow.Context, input *sqs.SendMessageBatchInput) *SendMessageBatchFuture

	SetQueueAttributes(ctx workflow.Context, input *sqs.SetQueueAttributesInput) (*sqs.SetQueueAttributesOutput, error)
	SetQueueAttributesAsync(ctx workflow.Context, input *sqs.SetQueueAttributesInput) *SetQueueAttributesFuture

	TagQueue(ctx workflow.Context, input *sqs.TagQueueInput) (*sqs.TagQueueOutput, error)
	TagQueueAsync(ctx workflow.Context, input *sqs.TagQueueInput) *TagQueueFuture

	UntagQueue(ctx workflow.Context, input *sqs.UntagQueueInput) (*sqs.UntagQueueOutput, error)
	UntagQueueAsync(ctx workflow.Context, input *sqs.UntagQueueInput) *UntagQueueFuture
}

func NewClient 

func NewClient() Client

type CreateQueueFuture 

type CreateQueueFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*CreateQueueFuture) Get 

func (r *CreateQueueFuture) Get(ctx workflow.Context) (*sqs.CreateQueueOutput, error)

type DeleteMessageBatchFuture 

type DeleteMessageBatchFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DeleteMessageBatchFuture) Get 

func (r *DeleteMessageBatchFuture) Get(ctx workflow.Context) (*sqs.DeleteMessageBatchOutput, error)

type DeleteMessageFuture 

type DeleteMessageFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DeleteMessageFuture) Get 

func (r *DeleteMessageFuture) Get(ctx workflow.Context) (*sqs.DeleteMessageOutput, error)

type DeleteQueueFuture 

type DeleteQueueFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DeleteQueueFuture) Get 

func (r *DeleteQueueFuture) Get(ctx workflow.Context) (*sqs.DeleteQueueOutput, error)

type GetQueueAttributesFuture 

type GetQueueAttributesFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*GetQueueAttributesFuture) Get 

func (r *GetQueueAttributesFuture) Get(ctx workflow.Context) (*sqs.GetQueueAttributesOutput, error)

type GetQueueUrlFuture 

type GetQueueUrlFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*GetQueueUrlFuture) Get 

func (r *GetQueueUrlFuture) Get(ctx workflow.Context) (*sqs.GetQueueUrlOutput, error)

type ListDeadLetterSourceQueuesFuture 

type ListDeadLetterSourceQueuesFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListDeadLetterSourceQueuesFuture) Get 

func (r *ListDeadLetterSourceQueuesFuture) Get(ctx workflow.Context) (*sqs.ListDeadLetterSourceQueuesOutput, error)

type ListQueueTagsFuture 

type ListQueueTagsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListQueueTagsFuture) Get 

func (r *ListQueueTagsFuture) Get(ctx workflow.Context) (*sqs.ListQueueTagsOutput, error)

type ListQueuesFuture 

type ListQueuesFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListQueuesFuture) Get 

func (r *ListQueuesFuture) Get(ctx workflow.Context) (*sqs.ListQueuesOutput, error)

type PurgeQueueFuture 

type PurgeQueueFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*PurgeQueueFuture) Get 

func (r *PurgeQueueFuture) Get(ctx workflow.Context) (*sqs.PurgeQueueOutput, error)

type ReceiveMessageFuture 

type ReceiveMessageFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ReceiveMessageFuture) Get 

func (r *ReceiveMessageFuture) Get(ctx workflow.Context) (*sqs.ReceiveMessageOutput, error)

type RemovePermissionFuture 

type RemovePermissionFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*RemovePermissionFuture) Get 

func (r *RemovePermissionFuture) Get(ctx workflow.Context) (*sqs.RemovePermissionOutput, error)

type SendMessageBatchFuture 

type SendMessageBatchFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*SendMessageBatchFuture) Get 

func (r *SendMessageBatchFuture) Get(ctx workflow.Context) (*sqs.SendMessageBatchOutput, error)

type SendMessageFuture 

type SendMessageFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*SendMessageFuture) Get 

func (r *SendMessageFuture) Get(ctx workflow.Context) (*sqs.SendMessageOutput, error)

type SetQueueAttributesFuture 

type SetQueueAttributesFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*SetQueueAttributesFuture) Get 

func (r *SetQueueAttributesFuture) Get(ctx workflow.Context) (*sqs.SetQueueAttributesOutput, error)

type TagQueueFuture 

type TagQueueFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*TagQueueFuture) Get 

func (r *TagQueueFuture) Get(ctx workflow.Context) (*sqs.TagQueueOutput, error)

type UntagQueueFuture 

type UntagQueueFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UntagQueueFuture) Get 

func (r *UntagQueueFuture) Get(ctx workflow.Context) (*sqs.UntagQueueOutput, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.