queue

Documentation

Index

• Variables
• type MockQueue
  • func (q *MockQueue) PullMessage(ctx context.Context, wait int) (res []byte, err error)
  • func (q *MockQueue) Purge(ctx context.Context) error
  • func (q *MockQueue) PushMessage(ctx context.Context, i any) error
• type PullPoll
• type Queue
  • func NewQueue(queueUri string) *Queue
  • func (q *Queue) PullMessage(ctx context.Context, wait int) ([]byte, error)
  • func (q *Queue) Purge(ctx context.Context) error
  • func (q *Queue) PushMessage(ctx context.Context, i any) error

Variables

var EmptyMessageErr = fmt.Errorf("no messages found")

Types

type MockQueue

type MockQueue struct {
	mock.Mock
}

func (*MockQueue) PullMessage

func (q *MockQueue) PullMessage(ctx context.Context, wait int) (res []byte, err error)

func (*MockQueue) Purge

func (q *MockQueue) Purge(ctx context.Context) error

func (*MockQueue) PushMessage

func (q *MockQueue) PushMessage(ctx context.Context, i any) error

type PullPoll

type PullPoll interface {
	Purge(context.Context) error
	PullMessage(context.Context, int) ([]byte, error)
	PushMessage(context.Context, any) error
}

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(queueUri string) *Queue

func (*Queue) PullMessage

func (q *Queue) PullMessage(ctx context.Context, wait int) ([]byte, error)

func (*Queue) Purge

func (q *Queue) Purge(ctx context.Context) error

func (*Queue) PushMessage

func (q *Queue) PushMessage(ctx context.Context, i any) error