broker

Documentation

Index

• type BrokerServer
  • func NewServer() *BrokerServer
  • func (b *BrokerServer) ServedRequests() []*http.Request
  • func (b *BrokerServer) Start() *BrokerServer
  • func (b *BrokerServer) Stop()
  • func (b *BrokerServer) URL() string
  • func (b *BrokerServer) WithHandler(pattern string, handler http.Handler) *BrokerServer
  • func (b *BrokerServer) WithResponse(pattern string, response map[string]any, statusCode int) *BrokerServer
• type CatalogPurger
  • func NewCatalogPurger(rootNamespace string) *CatalogPurger
  • func (p *CatalogPurger) ForBrokerGUID(brokerGUID string) *CatalogPurger
  • func (p *CatalogPurger) ForBrokerName(brokerName string) *CatalogPurger
  • func (p *CatalogPurger) Purge()

Types

type BrokerServer

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

func NewServer

func NewServer() *BrokerServer

func (*BrokerServer) ServedRequests

func (b *BrokerServer) ServedRequests() []*http.Request

func (*BrokerServer) Start

func (b *BrokerServer) Start() *BrokerServer

func (*BrokerServer) Stop

func (b *BrokerServer) Stop()

func (*BrokerServer) URL

func (b *BrokerServer) URL() string

func (*BrokerServer) WithHandler

func (b *BrokerServer) WithHandler(pattern string, handler http.Handler) *BrokerServer

func (*BrokerServer) WithResponse

func (b *BrokerServer) WithResponse(pattern string, response map[string]any, statusCode int) *BrokerServer

type CatalogPurger

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

func NewCatalogPurger

func NewCatalogPurger(rootNamespace string) *CatalogPurger

func (*CatalogPurger) ForBrokerGUID

func (p *CatalogPurger) ForBrokerGUID(brokerGUID string) *CatalogPurger

func (*CatalogPurger) ForBrokerName

func (p *CatalogPurger) ForBrokerName(brokerName string) *CatalogPurger

func (*CatalogPurger) Purge

func (p *CatalogPurger) Purge()