broker

Documentation

Index

• type Broker
  • func New(config configuration.Configuration) (*Broker, error)
  • func (b *Broker) APIVersion(ctx *fiber.Ctx) error
  • func (b *Broker) CreateQuery(ctx *fiber.Ctx) error
  • func (b *Broker) GetHost() string
  • func (b *Broker) GetID() string
  • func (b *Broker) GetMetadata() map[string]string
  • func (b *Broker) GetName() string
  • func (b *Broker) GetPort() string
  • func (b *Broker) ShutdownServer() error
  • func (b *Broker) StartServer(address string) error

Types

type Broker

type Broker struct {
	Name     string
	ID       uuid.UUID
	Hostname string
	// contains filtered or unexported fields
}

func New

func New(config configuration.Configuration) (*Broker, error)

func (*Broker) APIVersion

func (b *Broker) APIVersion(ctx *fiber.Ctx) error

func (*Broker) CreateQuery

func (b *Broker) CreateQuery(ctx *fiber.Ctx) error

func (*Broker) GetHost

func (b *Broker) GetHost() string

func (*Broker) GetID

func (b *Broker) GetID() string

func (*Broker) GetMetadata

func (b *Broker) GetMetadata() map[string]string

func (*Broker) GetName

func (b *Broker) GetName() string

func (*Broker) GetPort

func (b *Broker) GetPort() string

func (*Broker) ShutdownServer

func (b *Broker) ShutdownServer() error

func (*Broker) StartServer

func (b *Broker) StartServer(address string) error