reconcile

Documentation

Index

• Constants
• type CompositeError
  • func (ce *CompositeError) Add(e error)
  • func (ce *CompositeError) Error() string
  • func (ce *CompositeError) Len() int
• type Consumer
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, messages <-chan *notifications.Message, ...)
• type Resyncer
  • func NewResyncer(settings *Settings, platformClient platform.Client, smClient sm.Client, ...) Resyncer
• type Settings
  • func DefaultSettings() *Settings
  • func (c *Settings) Validate() error
• type TimestampedError
  • func (te TimestampedError) Error() string

Constants

const DefaultProxyBrokerPrefix = "sm-"

DefaultProxyBrokerPrefix prefix for brokers registered by the proxy

Types

type CompositeError

type CompositeError []error

CompositeError consists of multiple errors and attaches timestamps to them

func (*CompositeError) Add

func (ce *CompositeError) Add(e error)

Add allows appending errors

func (*CompositeError) Error

func (ce *CompositeError) Error() string

Error implements the error interface and returns a string representation of the composite error

func (*CompositeError) Len

func (ce *CompositeError) Len() int

Len returns the number of errors present in the composite error. If the composite error is nil, Len returns 0.

type Consumer

type Consumer interface {
	Consume(ctx context.Context, notification *types.Notification)
}

Consumer provides functionality for consuming notifications

type Reconciler

type Reconciler struct {
	Consumer Consumer
	Resyncer Resyncer
}

Reconciler takes care of propagating broker and visibility changes to the platform. TODO if the reg credentials are changed (the ones under cf.reg) we need to update the already registered brokers

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, messages <-chan *notifications.Message, group *sync.WaitGroup)

Reconcile listens for notification messages and either consumes the notification or triggers a resync

type Resyncer

type Resyncer interface {
	Resync(ctx context.Context)
}

Resyncer provides functionality for triggering a resync on the platform

func NewResyncer

func NewResyncer(settings *Settings, platformClient platform.Client, smClient sm.Client, smPath, proxyPathPattern string) Resyncer

NewResyncer returns a resyncer that reconciles the state of the proxy brokers and visibilities in the platform to match the desired state provided by the Service Manager.

type Settings

type Settings struct {
	LegacyURL           string   `mapstructure:"legacy_url"`
	MaxParallelRequests int      `mapstructure:"max_parallel_requests"`
	URL                 string   `mapstructure:"url"`
	BrokerPrefix        string   `mapstructure:"broker_prefix"`
	BrokerBlacklist     []string `mapstructure:"broker_blacklist"`
	TakeoverEnabled     bool     `mapstructure:"takeover_enabled"`
}

Settings type represents the sbproxy settings

func DefaultSettings

func DefaultSettings() *Settings

DefaultSettings creates default proxy settings

func (*Settings) Validate

func (c *Settings) Validate() error

Validate validates that the configuration contains all mandatory properties

type TimestampedError

type TimestampedError struct {
	Cause     error
	Timestamp string
}

TimestampedError contains an error and a timestamp in time.RFC3339Nano format

func (TimestampedError) Error

func (te TimestampedError) Error() string