broker

Documentation

Index

• type Broker
  • func New(options Options, logger common.Logger) *Broker
  • func (b *Broker) GetClient(clientId string) (*client, bool)
  • func (b *Broker) GetClientsJSON() []api.ClientJSON
  • func (b *Broker) GetEventsJSON() []api.EventInfoJSON
  • func (b *Broker) GetLogsByPattern(pattern string) (api.GetLogsResponse, error)
  • func (b *Broker) GetRequestSender(req *cellaserv.Request) (*client, error)
  • func (b *Broker) GetService(name string, identification string) (srvc *service, err error)
  • func (b *Broker) GetServicesJSON() []api.ServiceJSON
  • func (b *Broker) Quit() chan struct{}
  • func (b *Broker) RenameClientFromRequest(req *cellaserv.Request, name string)
  • func (b *Broker) Run(ctx context.Context) error
  • func (b *Broker) SpyService(c *client, srvc *service)
  • func (b *Broker) Started() chan struct{}
  • func (b *Broker) StartedWithCellaserv() chan struct{}
• type Monitoring
• type Options

Types

type Broker

type Broker struct {
	Monitoring *Monitoring

	Options *Options
	// contains filtered or unexported fields
}

func New

func New(options Options, logger common.Logger) *Broker

func (*Broker) GetClient

func (b *Broker) GetClient(clientId string) (*client, bool)

GetClient returns the client struct associated with the client id.

func (*Broker) GetClientsJSON

func (b *Broker) GetClientsJSON() []api.ClientJSON

func (*Broker) GetEventsJSON

func (b *Broker) GetEventsJSON() []api.EventInfoJSON

func (*Broker) GetLogsByPattern

func (b *Broker) GetLogsByPattern(pattern string) (api.GetLogsResponse, error)

func (*Broker) GetRequestSender

func (b *Broker) GetRequestSender(req *cellaserv.Request) (*client, error)

func (*Broker) GetService

func (b *Broker) GetService(name string, identification string) (srvc *service, err error)

GetService returns the service identified by the name and identification in argument, or an error if not found.

func (*Broker) GetServicesJSON

func (b *Broker) GetServicesJSON() []api.ServiceJSON

func (*Broker) Quit

func (b *Broker) Quit() chan struct{}

Quit returns the quit broker channel

func (*Broker) RenameClientFromRequest

func (b *Broker) RenameClientFromRequest(req *cellaserv.Request, name string)

func (*Broker) Run

func (b *Broker) Run(ctx context.Context) error

func (*Broker) SpyService

func (b *Broker) SpyService(c *client, srvc *service)

spyByRequest finds the sender of the request and add it to the

func (*Broker) Started

func (b *Broker) Started() chan struct{}

Started returns the started broker channel

func (*Broker) StartedWithCellaserv

func (b *Broker) StartedWithCellaserv() chan struct{}

type Monitoring

type Monitoring struct {
	Registry *prometheus.Registry
	// contains filtered or unexported fields
}

type Options

type Options struct {
	ListenAddress         string
	RequestTimeoutSec     time.Duration
	LogsDir               string
	PublishLoggingEnabled bool
}