rabbitmqqueues

Documentation

Overview

rabbitmqqueues contains the resource processor for rabbitMQ. See the processors package for more information.

Index

• Constants
• type Processor
  • func (p *Processor) Delete(ctx context.Context, resource *msg_dm.RabbitMQQueue, ...) error
  • func (p *Processor) Process(ctx context.Context, resource *msg_dm.RabbitMQQueue, ...) error

Constants

const (
	Queue = "queue"
	// RabbitMQSSLPort is the default port for RabbitMQ SSL connections.
	RabbitMQSSLPort = 5671
)

Types

type Processor

type Processor struct {
}

Processor is a processor for RabbitMQQueue resource.

func (*Processor) Delete

func (p *Processor) Delete(ctx context.Context, resource *msg_dm.RabbitMQQueue, options processors.Options) error

Delete implements the processors.Processor interface for RabbitMQQueue resources.

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, resource *msg_dm.RabbitMQQueue, options processors.Options) error

Process implements the processors.Processor interface for RabbitMQQueue resources. It validates the required fields and computed secret fields of the RabbitMQQueue resource and returns an error if validation fails.