brokerpak

package
v5.1.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 27, 2020 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Examples

Constants

View Source 
const (
	// BuiltinPakLocation is the file-system location to load brokerpaks from to
	// make them look builtin.
	BuiltinPakLocation = "/usr/share/gcp-service-broker/builtin-brokerpaks"
)
View Source 
const HashicorpUrlTemplate = "https://releases.hashicorp.com/${name}/${version}/${name}_${version}_${os}_${arch}.zip"

HashicorpUrlTemplate holds the default template for Hashicorp's terraform binary archive downloads.

Variables

This section is empty.

Functions

func Docs 

func Docs(pack string) error

Docs generates the markdown usage docs for the given pack and writes them to stdout.

func Info 

func Info(pack string) error

Info writes out human-readable information about the brokerpak.

func Init 

func Init(directory string) error

Init initializes a new brokerpak in the given directory with an example manifest and service definition.

func ListBrokerpaks 

func ListBrokerpaks(directory string) ([]string, error)

ListBrokerpaks gets all brokerpaks in a given directory.

func Pack 

func Pack(directory string) (string, error)

Pack creates a new brokerpak from the given directory which MUST contain a manifest.yml file. If the pack was successful, the returned string will be the path to the created brokerpak.

func RegisterAll 

func RegisterAll(registry broker.BrokerRegistry) error

RegisterAll fetches all brokerpaks from the settings file and registers them with the given registry.

func RunExamples 

func RunExamples(pack string) error

RunExamples executes the examples from a brokerpak.

func Validate 

func Validate(pack string) error

Validate checks the brokerpak for syntactic and limited semantic errors.

Example 
pk, err := fakeBrokerpak()
defer os.Remove(pk)

if err != nil {
	panic(err)
}

if err := Validate(pk); err != nil {
	panic(err)
} else {
	fmt.Println("ok!")
}

Output:

ok!

Types

type BrokerPakReader 

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

BrokerPakReader reads bundled together Terraform and service definitions.

func DownloadAndOpenBrokerpak 

func DownloadAndOpenBrokerpak(pakUri string) (*BrokerPakReader, error)

DownloadAndOpenBrokerpak downloads a (potentially remote) brokerpak to the local filesystem and opens it.

func OpenBrokerPak 

func OpenBrokerPak(pakPath string) (*BrokerPakReader, error)

Opens the file at the given path as a BrokerPakReader.

func (*BrokerPakReader) Close 

func (pak *BrokerPakReader) Close() error

Close closes the underlying reader for the BrokerPakReader.

func (*BrokerPakReader) ExtractPlatformBins 

func (pak *BrokerPakReader) ExtractPlatformBins(destination string) error

ExtractPlatformBins extracts the binaries for the current platform to the given destination.

func (*BrokerPakReader) Manifest 

func (pak *BrokerPakReader) Manifest() (*Manifest, error)

Manifest fetches the manifest out of the package.

func (*BrokerPakReader) Services 

func (pak *BrokerPakReader) Services() ([]tf.TfServiceDefinitionV1, error)

Services gets the list of services included in the pack.

func (*BrokerPakReader) Validate 

func (pak *BrokerPakReader) Validate() error

Validate checks the manifest and service definitions for syntactic and limited semantic errors.

type BrokerpakSourceConfig 

type BrokerpakSourceConfig struct {
	// BrokerpakUri holds the URI for loading the Brokerpak.
	BrokerpakUri string `json:"uri"`
	// ServicePrefix holds an optional prefix that will be prepended to every service name.
	ServicePrefix string `json:"service_prefix"`
	// ExcludedServices holds a newline delimited list of service UUIDs that will be excluded at registration time.
	ExcludedServices string `json:"excluded_services"`
	// Config holds the configuration options for the Brokerpak as a JSON object.
	Config string `json:"config"`
	// Notes holds user-defined notes about the Brokerpak and shouldn't be used programatically.
	Notes string `json:"notes"`
}

BrokerpakSourceConfig represents a single configuration of a brokerpak.

func NewBrokerpakSourceConfigFromPath 

func NewBrokerpakSourceConfigFromPath(path string) BrokerpakSourceConfig

NewBrokerpakSourceConfigFromPath creates a new BrokerpakSourceConfig from a path.

func (*BrokerpakSourceConfig) ExcludedServicesSlice 

func (b *BrokerpakSourceConfig) ExcludedServicesSlice() []string

ExcludedServicesSlice gets the ExcludedServices as a slice of UUIDs.

Example 
cfg := BrokerpakSourceConfig{ExcludedServices: "FOO\nBAR"}

fmt.Println(cfg.ExcludedServicesSlice())

Output:

[FOO BAR]

func (*BrokerpakSourceConfig) SetExcludedServices 

func (b *BrokerpakSourceConfig) SetExcludedServices(services []string)

SetExcludedServices sets the ExcludedServices from a slice of UUIDs.

Example 
cfg := BrokerpakSourceConfig{}
cfg.SetExcludedServices([]string{"plan1", "plan2"})

fmt.Println("slice:", cfg.ExcludedServicesSlice())
fmt.Println("text:", cfg.ExcludedServices)

Output:

slice: [plan1 plan2]
text: plan1
plan2

func (*BrokerpakSourceConfig) Validate 

func (b *BrokerpakSourceConfig) Validate() (errs *validation.FieldError)

Validate implements validation.Validatable.

type Manifest 

type Manifest struct {
	// Package metadata
	PackVersion int `yaml:"packversion"`

	// User modifiable values
	Name               string              `yaml:"name"`
	Version            string              `yaml:"version"`
	Metadata           map[string]string   `yaml:"metadata"`
	Platforms          []Platform          `yaml:"platforms"`
	TerraformResources []TerraformResource `yaml:"terraform_binaries"`
	ServiceDefinitions []string            `yaml:"service_definitions"`
	Parameters         []ManifestParameter `yaml:"parameters"`
}

func NewExampleManifest 

func NewExampleManifest() Manifest

NewExampleManifest creates a new manifest with sample values for the service broker suitable for giving a user a template to manually edit.

func (*Manifest) AppliesToCurrentPlatform 

func (m *Manifest) AppliesToCurrentPlatform() bool

AppliesToCurrentPlatform returns true if the one of the platforms in the manifest match the current GOOS and GOARCH.

func (*Manifest) Pack 

func (m *Manifest) Pack(base, dest string) error

Pack creates a brokerpak from the manifest and definitions.

func (*Manifest) Validate 

func (m *Manifest) Validate() (errs *validation.FieldError)

Validate will run struct validation on the fields of this manifest.

type ManifestParameter 

type ManifestParameter struct {
	// NOTE: Future fields should take inspiration from the CNAB spec because they
	// solve a similar problem. https://github.com/deislabs/cnab-spec
	Name        string `yaml:"name"`
	Description string `yaml:"description"`
}

ManifestParameter holds environment variables that will be looked up and passed to the executed Terraform instance.

func (*ManifestParameter) Validate 

func (param *ManifestParameter) Validate() (errs *validation.FieldError)

Validate implements validation.Validatable.

type Platform 

type Platform struct {
	Os   string `yaml:"os"`
	Arch string `yaml:"arch"`
}

Platform holds an os/architecture pair.

func CurrentPlatform 

func CurrentPlatform() Platform

CurrentPlatform returns the platform defined by GOOS and GOARCH.

func (Platform) Equals 

func (p Platform) Equals(other Platform) bool

Equals is an equality test between this platform and the other.

Example 
p := Platform{Os: "beos", Arch: "webasm"}
fmt.Println(p.Equals(p))
fmt.Println(p.Equals(CurrentPlatform()))

Output:

true
false

func (Platform) MatchesCurrent 

func (p Platform) MatchesCurrent() bool

MatchesCurrent returns true if the platform matches this binary's GOOS/GOARCH combination.

Example 
fmt.Println(CurrentPlatform().MatchesCurrent())

Output:

true

func (Platform) String 

func (p Platform) String() string

String formats the platform as an os/arch pair.

Example 
p := Platform{Os: "bsd", Arch: "amd64"}
fmt.Println(p.String())

Output:

bsd/amd64

func (Platform) Validate 

func (p Platform) Validate() (errs *validation.FieldError)

Validate implements validation.Validatable.

type Registrar 

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

Registrar is responsible for registering brokerpaks with BrokerRegistries subject to the settings provided by a ServerConfig like injecting environment variables and skipping certain services.

func NewRegistrar 

func NewRegistrar(sc *ServerConfig) *Registrar

NewRegistrar constructs a new registrar with the given configuration. Registrar expects to become the owner of the configuration afterwards.

func (*Registrar) Register 

func (r *Registrar) Register(registry broker.BrokerRegistry) error

Register fetches the brokerpaks and registers them with the given registry.

type ServerConfig 

type ServerConfig struct {
	// Config holds global configuration options for the Brokerpak as a JSON object.
	Config string

	// Brokerpaks holds list of brokerpaks to load.
	Brokerpaks map[string]BrokerpakSourceConfig
}

ServerConfig holds the Brokerpak configuration for the server.

func NewServerConfigFromEnv 

func NewServerConfigFromEnv() (*ServerConfig, error)

NewServerConfigFromEnv loads the global Brokerpak config from Viper.

Example 
viper.Set("brokerpak.sources", `{"good-key":{"uri":"file://path/to/brokerpak", "config":"{}"}}`)
viper.Set("brokerpak.config", `{}`)
defer viper.Reset() // cleanup

cfg, err := NewServerConfigFromEnv()
if err != nil {
	panic(err)
}

fmt.Println("global config:", cfg.Config)
fmt.Println("num services:", len(cfg.Brokerpaks))

Output:

global config: {}
num services: 1
Example (CustomBuiltin) 
viper.Set("brokerpak.sources", `{}`)
viper.Set("brokerpak.config", `{}`)
viper.Set(brokerpakBuiltinPathKey, "testdata/dummy-brokerpaks")
viper.Set("compatibility.enable-builtin-brokerpaks", "true")
defer viper.Reset() // cleanup

cfg, err := NewServerConfigFromEnv()
if err != nil {
	panic(err)
}

fmt.Println("num services:", len(cfg.Brokerpaks))

Output:

num services: 2

func (*ServerConfig) Validate 

func (cfg *ServerConfig) Validate() (errs *validation.FieldError)

Validate returns an error if the configuration is invalid.

type TerraformResource 

type TerraformResource struct {
	// Name holds the name of this resource. e.g. terraform-provider-google-beta
	Name string `yaml:"name"`

	// Version holds the version of the resource e.g. 1.19.0
	Version string `yaml:"version"`

	// Source holds the URI of an archive that contains the source code for this release.
	Source string `yaml:"source"`

	// UrlTemplate holds a custom URL template to get the release of the given tool.
	// Paramaters available are ${name}, ${version}, ${os}, and ${arch}.
	// If non is specified HashicorpUrlTemplate is used.
	UrlTemplate string `yaml:"url_template,omitempty"`
}

TerraformResource represents a downloadable binary dependency (Terraform version or Provider).

func (*TerraformResource) Url 

func (tr *TerraformResource) Url(platform Platform) string

Url constructs a download URL based on a platform.

func (*TerraformResource) Validate 

func (tr *TerraformResource) Validate() (errs *validation.FieldError)

Validate implements validation.Validatable.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.