queue

package

v1.6.0 Latest Latest Go to latest Published: Jan 15, 2023 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

func NewSQSDriver(q *sqs.Client, config *types.QueueConfig) *SQSDriver

func (d *SQSDriver) ChangeMessageVisibility(msg types.ChangeVisibilityMessage, second int32) error

func (d *SQSDriver) DeleteMessage(msg types.DeletableMessage) error

func (d *SQSDriver) GetConfig() *types.QueueConfig

func (d *SQSDriver) GetMessage(num int) ([]types.Message, error)

func (d *SQSDriver) GetMessageLength() ([]string, error)

func (d *SQSDriver) PutMessage(raw []byte, delay int32) error

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

func (m *SQSMessage) GetBody() []byte

func (m *SQSMessage) GetChangeVisibilityID() string

func (m *SQSMessage) GetDeduplicationID() string

func (m *SQSMessage) GetDeleteID() string

func (m *SQSMessage) GetID() string

func (m *SQSMessage) IsDeleted() bool

func (m *SQSMessage) SetDeleted(deleted bool)

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

func NewSQSMockDriver(config *types.QueueConfig) *SQSMockDriver

func (d *SQSMockDriver) ChangeMessageVisibility(msg types.ChangeVisibilityMessage, second int32) error

func (d *SQSMockDriver) DeleteMessage(msg types.DeletableMessage) error

func (d *SQSMockDriver) GetConfig() *types.QueueConfig

func (d *SQSMockDriver) GetMessage(num int) ([]types.Message, error)

func (d *SQSMockDriver) GetMessageLength() ([]string, error)

func (d *SQSMockDriver) PutMessage(raw []byte, delay int32) error

func (d *SQSMockDriver) SetDummyMessage(m *SQSMessage)

func (d *SQSMockDriver) SetMessageLength(lens []string)