sqs

Documentation

Index

• type Client
  • func NewSQSClient(queueUrl string) *Client
  • func (s *Client) SendUsageMessage(ctx context.Context, messageBody string, ...) error
• type UsageMessageAttributes
  • func NewUsageMessageAttributes(tenantID, productID, memoryMB, startTimestamp, endTimestamp, workflow string) UsageMessageAttributes

Types

type Client

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

func NewSQSClient

func NewSQSClient(queueUrl string) *Client

func (*Client) SendUsageMessage

func (s *Client) SendUsageMessage(ctx context.Context, messageBody string, messageAttributes UsageMessageAttributes) error

type UsageMessageAttributes

type UsageMessageAttributes struct {
	TenantID       types.MessageAttributeValue
	ProductID      types.MessageAttributeValue
	MemoryMB       types.MessageAttributeValue
	StartTimestamp types.MessageAttributeValue
	EndTimestamp   types.MessageAttributeValue
	Workflow       types.MessageAttributeValue
}

func NewUsageMessageAttributes

func NewUsageMessageAttributes(tenantID, productID, memoryMB, startTimestamp, endTimestamp, workflow string) UsageMessageAttributes