caasfirewaller

Documentation

Index

• func Manifold(cfg ManifoldConfig) dependency.Manifold
• func NewWorker(config Config) (worker.Worker, error)
• type ApplicationGetter
• type Client
• type Config
  • func (config Config) Validate() error
• type LifeGetter
• type ManifoldConfig
  • func (config ManifoldConfig) Validate() error
• type ServiceExposer

Functions

func Manifold

func Manifold(cfg ManifoldConfig) dependency.Manifold

Manifold returns a Manifold that encapsulates the firewaller worker.

func NewWorker

func NewWorker(config Config) (worker.Worker, error)

NewWorker starts and returns a new CAAS unit firewaller worker.

Types

type ApplicationGetter

type ApplicationGetter interface {
	WatchApplications() (watcher.StringsWatcher, error)
	WatchApplication(string) (watcher.NotifyWatcher, error)
	IsExposed(string) (bool, error)
	ApplicationConfig(string) (application.ConfigAttributes, error)
}

ApplicationGetter provides an interface for watching for the lifecycle state changes (including addition) of applications in the model, and fetching their details.

type Client

type Client interface {
	ApplicationGetter
	LifeGetter
}

Client provides an interface for interacting with the CAASFirewaller API. Subsets of this should be passed to the CAASFirewaller worker.

type Config

type Config struct {
	ControllerUUID    string
	ModelUUID         string
	ApplicationGetter ApplicationGetter
	LifeGetter        LifeGetter
	ServiceExposer    ServiceExposer
}

Config holds configuration for the CAAS unit firewaller worker.

func (Config) Validate

func (config Config) Validate() error

Validate validates the worker configuration.

type LifeGetter

type LifeGetter interface {
	Life(string) (life.Value, error)
}

LifeGetter provides an interface for getting the lifecycle state value for an application.

type ManifoldConfig

type ManifoldConfig struct {
	APICallerName string
	BrokerName    string

	ControllerUUID string
	ModelUUID      string

	NewClient func(base.APICaller) Client
	NewWorker func(Config) (worker.Worker, error)
}

ManifoldConfig describes the resources used by the firewaller worker.

func (ManifoldConfig) Validate

func (config ManifoldConfig) Validate() error

Validate is called by start to check for bad configuration.

type ServiceExposer

type ServiceExposer interface {
	ExposeService(appName string, resourceTags map[string]string, config application.ConfigAttributes) error
	UnexposeService(appName string) error
}