reconcile

Documentation

Index

• type ReconciliationTask
  • func NewTask(ctx context.Context, options *Settings, group *sync.WaitGroup, ...) *ReconciliationTask
  • func (r *ReconciliationTask) Run()
• type Settings
  • func DefaultSettings() *Settings
  • func (c *Settings) Validate() error

Types

type ReconciliationTask

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

ReconciliationTask type represents a registration task that takes care of propagating broker and visibility creations and deletions to the platform. It reconciles the state of the proxy brokers and visibilities in the platform to match the desired state provided by the Service Manager. TODO if the reg credentials are changed (the ones under cf.reg) we need to update the already registered brokers

func NewTask

func NewTask(ctx context.Context,
	options *Settings,
	group *sync.WaitGroup,
	platformClient platform.Client,
	smClient sm.Client,
	proxyPath string,
	c *cache.Cache) *ReconciliationTask

NewTask builds a new ReconciliationTask

func (*ReconciliationTask) Run

func (r *ReconciliationTask) Run()

Run executes the registration task that is responsible for reconciling the state of the proxy brokers and visibilities at the platform with the brokers provided by the Service Manager

type Settings

type Settings struct {
	URL      string `mapstructure:"url"`
	Username string `mapstructure:"username"`
	Password string `mapstructure:"password"`

	BrokerPrefix string `mapstructure:"broker_prefix"`

	VisibilityCache bool          `mapstructure:"visibility_cache"`
	CacheExpiration time.Duration `mapstructure:"cache_expiration"`
}

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