mbus

Documentation

Index

• type RegistryMessage
  • func (rm *RegistryMessage) ValidateMessage() bool
• type Subscriber
  • func NewSubscriber(logger logger.Logger, natsClient *nats.Conn, routeRegistry registry.Registry, ...) *Subscriber
  • func (s *Subscriber) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type SubscriberOpts

Types

type RegistryMessage

type RegistryMessage struct {
	Host                    string            `json:"host"`
	Port                    uint16            `json:"port"`
	Uris                    []route.Uri       `json:"uris"`
	Tags                    map[string]string `json:"tags"`
	App                     string            `json:"app"`
	StaleThresholdInSeconds int               `json:"stale_threshold_in_seconds"`
	RouteServiceURL         string            `json:"route_service_url"`
	PrivateInstanceID       string            `json:"private_instance_id"`
	PrivateInstanceIndex    string            `json:"private_instance_index"`
	RouterGroupGuid         string            `json:"router_group_guid"`
}

RegistryMessage defines the format of a route registration/unregistration

func (*RegistryMessage) ValidateMessage

func (rm *RegistryMessage) ValidateMessage() bool

ValidateMessage checks to ensure the registry message is valid

type Subscriber

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

Subscriber subscribes to NATS for all router.* messages and handles them

func NewSubscriber

func NewSubscriber(
	logger logger.Logger,
	natsClient *nats.Conn,
	routeRegistry registry.Registry,
	startMsgChan <-chan struct{},
	opts *SubscriberOpts,
	routerGroupGuid string,
) *Subscriber

NewSubscriber returns a new Subscriber

func (*Subscriber) Run

func (s *Subscriber) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Run manages the lifecycle of the subscriber process

type SubscriberOpts

type SubscriberOpts struct {
	ID                               string
	MinimumRegisterIntervalInSeconds int
	PruneThresholdInSeconds          int
}

SubscriberOpts contains configuration for Subscriber struct