qdr

Documentation

Index

• Constants
• func IsNotFound(err error) bool
• type Connector
  • func (r Connector) GetType() string
• type LinkRoute
  • func (r LinkRoute) GetType() string
• type Manage
  • func NewManage() *Manage
  • func NewManageWithUrl(URL string) *Manage
  • func (m *Manage) Create(routerResource RouterResource, attributes map[string]string) (string, error)
  • func (m *Manage) Delete(routerResource RouterResource) error
  • func (m *Manage) Exists(routerResource RouterResource) (bool, error)
  • func (m *Manage) Manage(operation string, attributes map[string]string) (string, error)
  • func (m *Manage) Read(routerResource RouterResource) (string, error)
  • func (m *Manage) ReadAsObject(routerResource RouterResource, v interface{}) (bool, error)
• type NamedResource
  • func (r NamedResource) GetName() string
• type ResourceNotFoundError
  • func (e *ResourceNotFoundError) Error() string
• type RouterResource
  • func NamedConnector(Name string) RouterResource
  • func NamedLinkRoute(Name string) RouterResource
  • func NamedSslProfile(Name string) RouterResource
  • func TypeAndName(Type string, Name string) RouterResource
• type SslProfile
  • func (r SslProfile) GetType() string

Constants

const DefaultCommand = "/usr/bin/qdmanage"

const TypeNameConnector string = "org.apache.qpid.dispatch.connector"

const TypeNameLinkRoute string = "org.apache.qpid.dispatch.router.config.linkRoute"

const TypeNameSslProfile string = "org.apache.qpid.dispatch.sslProfile"

Functions

func IsNotFound

func IsNotFound(err error) bool

Types

type Connector

type Connector struct {
	NamedResource
	Host         string `json:"host"`
	Port         string `json:"port"` // yes, port is a string, as it could be a named port
	Role         string `json:"role"`
	SASLUsername string `json:"saslUsername,omitempty"`
	SASLPassword string `json:"saslPassword,omitempty"`
	SSLProfile   string `json:"sslProfile,omitempty"`
}

func (Connector) GetType

func (r Connector) GetType() string

type LinkRoute

type LinkRoute struct {
	NamedResource
	Connection string `json:"connection"`
	Direction  string `json:"direction"`
	Pattern    string `json:"pattern"`
}

func (LinkRoute) GetType

func (r LinkRoute) GetType() string

type Manage

type Manage struct {
	URL     string
	Command string
}

func NewManage

func NewManage() *Manage

func NewManageWithUrl

func NewManageWithUrl(URL string) *Manage

func (*Manage) Create

func (m *Manage) Create(routerResource RouterResource, attributes map[string]string) (string, error)

func (*Manage) Delete

func (m *Manage) Delete(routerResource RouterResource) error

func (*Manage) Exists

func (m *Manage) Exists(routerResource RouterResource) (bool, error)

func (*Manage) Manage

func (m *Manage) Manage(operation string, attributes map[string]string) (string, error)

Call a manage operation

func (*Manage) Read

func (m *Manage) Read(routerResource RouterResource) (string, error)

Get a resource, returns the JSON of the resource, or and empty string if the object does not exists

func (*Manage) ReadAsObject

func (m *Manage) ReadAsObject(routerResource RouterResource, v interface{}) (bool, error)

Read an object

Return `true` if the object was found, `false` otherwise

type NamedResource

type NamedResource struct {
	Name string `json:"name"`
}

func (NamedResource) GetName

func (r NamedResource) GetName() string

type ResourceNotFoundError

type ResourceNotFoundError struct {
}

func (*ResourceNotFoundError) Error

func (e *ResourceNotFoundError) Error() string

type RouterResource

type RouterResource interface {
	GetType() string
	GetName() string
}

func NamedConnector

func NamedConnector(Name string) RouterResource

func NamedLinkRoute

func NamedLinkRoute(Name string) RouterResource

func NamedSslProfile

func NamedSslProfile(Name string) RouterResource

func TypeAndName

func TypeAndName(Type string, Name string) RouterResource

type SslProfile

type SslProfile struct {
	NamedResource
	CertificatePath   string `json:"certFile,omitempty"`
	CACertificatePath string `json:"caCertFile,omitempty"`
}

func (SslProfile) GetType

func (r SslProfile) GetType() string