mbus

Documentation

Index

• func Connect(c *config.Config, reconnected chan<- Signal, l logger.Logger) *nats.Conn
• type Client
• type RegistryMessage
  • func (v RegistryMessage) MarshalEasyJSON(w *jwriter.Writer)
  • func (v RegistryMessage) MarshalJSON() ([]byte, error)
  • func (v *RegistryMessage) UnmarshalEasyJSON(l *jlexer.Lexer)
  • func (v *RegistryMessage) UnmarshalJSON(data []byte) error
  • func (rm *RegistryMessage) ValidateMessage() bool
• type Signal
• type Subscriber
  • func NewSubscriber(mbusClient Client, routeRegistry registry.Registry, c *config.Config, ...) *Subscriber
  • func (s *Subscriber) Dropped() (int, error)
  • func (v Subscriber) MarshalEasyJSON(w *jwriter.Writer)
  • func (v Subscriber) MarshalJSON() ([]byte, error)
  • func (s *Subscriber) Pending() (int, error)
  • func (s *Subscriber) Run(signals <-chan os.Signal, ready chan<- struct{}) error
  • func (v *Subscriber) UnmarshalEasyJSON(l *jlexer.Lexer)
  • func (v *Subscriber) UnmarshalJSON(data []byte) error

Functions

func Connect

func Connect(c *config.Config, reconnected chan<- Signal, l logger.Logger) *nats.Conn

Types

type Client

type Client interface {
	Subscribe(subj string, cb nats.MsgHandler) (*nats.Subscription, error)
	Publish(subj string, data []byte) error
}

type RegistryMessage

type RegistryMessage struct {
	Host                    string            `json:"host"`
	Port                    uint16            `json:"port"`
	TLSPort                 uint16            `json:"tls_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"`
	ServerCertDomainSAN     string            `json:"server_cert_domain_san"`
	PrivateInstanceIndex    string            `json:"private_instance_index"`
	IsolationSegment        string            `json:"isolation_segment"`
	EndpointUpdatedAtNs     int64             `json:"endpoint_updated_at_ns"`
}

RegistryMessage defines the format of a route registration/unregistration easyjson:json

func (RegistryMessage) MarshalEasyJSON

func (v RegistryMessage) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (RegistryMessage) MarshalJSON

func (v RegistryMessage) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*RegistryMessage) UnmarshalEasyJSON

func (v *RegistryMessage) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*RegistryMessage) UnmarshalJSON

func (v *RegistryMessage) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

func (*RegistryMessage) ValidateMessage

func (rm *RegistryMessage) ValidateMessage() bool

ValidateMessage checks to ensure the registry message is valid

type Signal

type Signal struct{}

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(
	mbusClient Client,
	routeRegistry registry.Registry,
	c *config.Config,
	reconnected <-chan Signal,
	l logger.Logger,
) *Subscriber

NewSubscriber returns a new Subscriber

func (*Subscriber) Dropped

func (s *Subscriber) Dropped() (int, error)

func (Subscriber) MarshalEasyJSON

func (v Subscriber) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (Subscriber) MarshalJSON

func (v Subscriber) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*Subscriber) Pending

func (s *Subscriber) Pending() (int, error)

func (*Subscriber) Run

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

Run manages the lifecycle of the subscriber process

func (*Subscriber) UnmarshalEasyJSON

func (v *Subscriber) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Subscriber) UnmarshalJSON

func (v *Subscriber) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface