queues

type CreateOps struct {
	// Indicates the unique name of a queue.
	// A string of 1 to 64 characters that contain
	// a-z, A-Z, 0-9, hyphens (-), and underscores (_).
	// The name cannot be modified once specified.
	Name string `json:"name" required:"true"`

	// Indicates the queue type. Default value: NORMAL. Options:
	// NORMAL: Standard queue. Best-effort ordering.
	// FIFO: First-ln-First-out (FIFO) queue. FIFO delivery.
	// KAFKA_HA: High-availability Kafka queue.
	// KAFKA_HT: High-throughput Kafka queue.
	// AMQP: Advanced Message Queuing Protocol (AMQP) queue.
	QueueMode string `json:"queue_mode,omitempty"`

	// Indicates the basic information about a queue.
	// The queue description must be 0 to 160 characters in length,
	// and does not contain angle brackets (<) and (>).
	Description string `json:"description,omitempty"`

	// This parameter is mandatory only when queue_mode is NORMAL or FIFO.
	// Indicates whether to enable dead letter messages.
	// Default value: disable. Options: enable, disable.
	RedrivePolicy string `json:"redrive_policy,omitempty"`

	// This parameter is mandatory only when
	// redrive_policy is set to enable.
	// This parameter indicates the maximum number
	// of allowed message consumption failures.
	// Value range: 1-100.
	MaxConsumeCount int `json:"max_consume_count,omitempty"`

	// This parameter is mandatory only when
	// queue_mode is set to KAFKA_HA or KAFKA_HT.
	// This parameter indicates the retention time
	// of messages in Kafka queues.
	// Value range: 1 to 72 hours.
	RetentionHours int `json:"retention_hours,omitempty"`
}

type CreateOpsBuilder interface {
	ToQueueCreateMap() (map[string]interface{}, error)
}

type CreateResult struct {
	golangsdk.Result
}

type DeleteResult struct {
	golangsdk.ErrResult
}

type GetResult struct {
	golangsdk.Result
}

type Queue struct {
	ID               string  `json:"id"`
	Name             string  `json:"name"`
	Created          float64 `json:"created"`
	Description      string  `json:"description"`
	QueueMode        string  `json:"queue_mode"`
	Reservation      int     `json:"reservation"`
	MaxMsgSizeByte   int     `json:"max_msg_size_byte"`
	ProducedMessages int     `json:"produced_messages"`
	RedrivePolicy    string  `json:"redrive_policy"`
	MaxConsumeCount  int     `json:"max_consume_count"`
	GroupCount       int     `json:"group_count"`
}

type QueueCreate struct {
	ID         string `json:"id"`
	Name       string `json:"name"`
	KafkaTopic string `json:"kafka_topic"`
}

type QueuePage struct {
	pagination.SinglePageBase
}