mgmt

Documentation

Index

• type Mgmt
  • func Start(ctx context.Context, uris []string, cleanupQueues bool) *Mgmt
  • func (m *Mgmt) DeclareAndBind(cfg config.Config, queueName string, id int) rmq.IQueueInfo
  • func (m *Mgmt) DeclareQueues(cfg config.Config)
  • func (m *Mgmt) DeleteDeclaredQueues()
  • func (m *Mgmt) DeleteQueue(ctx context.Context, name string) error
  • func (m *Mgmt) Stop()

Types

type Mgmt

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

func Start

func Start(ctx context.Context, uris []string, cleanupQueues bool) *Mgmt

func (*Mgmt) DeclareAndBind

func (m *Mgmt) DeclareAndBind(cfg config.Config, queueName string, id int) rmq.IQueueInfo

func (*Mgmt) DeclareQueues

func (m *Mgmt) DeclareQueues(cfg config.Config)

func (*Mgmt) DeleteDeclaredQueues

func (m *Mgmt) DeleteDeclaredQueues()

func (*Mgmt) DeleteQueue

func (m *Mgmt) DeleteQueue(ctx context.Context, name string) error

func (*Mgmt) Stop

func (m *Mgmt) Stop()