install

Documentation

Index

• Constants
• func NewPackageCatalog(kv *consul.KV, repositoryRoot string) (*packageCatalog, error)
• type Install
  • func NewInstall(consulClient *consul.Client, marathon *marathon.Marathon, mesos *mesos.Mesos, ...) (*Install, error)
  • func (install *Install) FindInstalled(pkgReq *PackageRequest) *marathon.App
  • func (install *Install) GetPackageDefinition(name string, version string, userConfig map[string]interface{}, ...) (*packageDefinition, error)
  • func (install *Install) InstallPackage(pkgReq *PackageRequest) (string, error)
  • func (install *Install) Package(name string) (*Package, error)
  • func (install *Install) Packages() (PackageCollection, error)
  • func (install *Install) Repositories() (RepositoryCollection, error)
  • func (install *Install) SyncSources(sources []*Source, force bool) error
  • func (install *Install) UninstallPackage(app *marathon.App) error
• type Package
  • func NewPackage(name string) *Package
  • func (p Package) ContainerId() string
  • func (p Package) FindLatestPackageVersion() *PackageVersion
  • func (p Package) FindLatestSupportedPackageVersion() *PackageVersion
  • func (p Package) FindPackageVersion(version string) *PackageVersion
  • func (p Package) GetPackageVersion(version string) *PackageVersion
  • func (p Package) HasSupportedVersion() bool
  • func (p Package) PackageKey() string
  • func (p Package) PackageVersionKey(index string) string
  • func (p Package) PackageVersions() []*PackageVersion
  • func (p Package) SupportedVersions() []*PackageVersion
• type PackageCollection
• type PackageRequest
  • func NewPackageRequest(data []byte) (request *PackageRequest, err error)
• type PackageVersion
• type Repository
  • func (r Repository) PackagesKey() string
• type RepositoryCollection
• type Source
  • func (s Source) IsValid() bool
• type SourceType

Constants

const (
	FileSystem = iota
	Git
)

const RepositoryRoot = "mantl-install/repository"

Functions

func NewPackageCatalog

func NewPackageCatalog(kv *consul.KV, repositoryRoot string) (*packageCatalog, error)

Types

type Install

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

func NewInstall

func NewInstall(consulClient *consul.Client, marathon *marathon.Marathon, mesos *mesos.Mesos, zookeeper *zookeeper.Zookeeper) (*Install, error)

func (*Install) FindInstalled

func (install *Install) FindInstalled(pkgReq *PackageRequest) *marathon.App

func (*Install) GetPackageDefinition

func (install *Install) GetPackageDefinition(name string, version string, userConfig map[string]interface{}, apiConfig map[string]interface{}) (*packageDefinition, error)

func (*Install) InstallPackage

func (install *Install) InstallPackage(pkgReq *PackageRequest) (string, error)

func (*Install) Package

func (install *Install) Package(name string) (*Package, error)

func (*Install) Packages

func (install *Install) Packages() (PackageCollection, error)

func (*Install) Repositories

func (install *Install) Repositories() (RepositoryCollection, error)

func (*Install) SyncSources

func (install *Install) SyncSources(sources []*Source, force bool) error

func (*Install) UninstallPackage

func (install *Install) UninstallPackage(app *marathon.App) error

type Package

type Package struct {
	Name           string                     `json:"name"`
	Description    string                     `json:"description"`
	Framework      bool                       `json:"framework"`
	CurrentVersion string                     `json:"currentVersion"`
	Supported      bool                       `json:"supported"`
	Tags           []string                   `json:"tags"`
	Versions       map[string]*PackageVersion `json:"versions"`
}

func NewPackage

func NewPackage(name string) *Package

func (Package) ContainerId

func (p Package) ContainerId() string

func (Package) FindLatestPackageVersion

func (p Package) FindLatestPackageVersion() *PackageVersion

func (Package) FindLatestSupportedPackageVersion

func (p Package) FindLatestSupportedPackageVersion() *PackageVersion

func (Package) FindPackageVersion

func (p Package) FindPackageVersion(version string) *PackageVersion

func (Package) GetPackageVersion

func (p Package) GetPackageVersion(version string) *PackageVersion

func (Package) HasSupportedVersion

func (p Package) HasSupportedVersion() bool

func (Package) PackageKey

func (p Package) PackageKey() string

func (Package) PackageVersionKey

func (p Package) PackageVersionKey(index string) string

func (Package) PackageVersions

func (p Package) PackageVersions() []*PackageVersion

func (Package) SupportedVersions

func (p Package) SupportedVersions() []*PackageVersion

type PackageCollection

type PackageCollection []*Package

type PackageRequest

type PackageRequest struct {
	Name             string                 `json:"name"`
	Version          string                 `json:"version"`
	Config           map[string]interface{} `json:"config"`
	UninstallOptions map[string]interface{} `json:"uninstallOptions"`
}

func NewPackageRequest

func NewPackageRequest(data []byte) (request *PackageRequest, err error)

type PackageVersion

type PackageVersion struct {
	Version   string `json:"version"`
	Index     string `json:"index"`
	Supported bool   `json:"supported"`
}

type Repository

type Repository struct {
	Name  string
	Index int
}

func (Repository) PackagesKey

func (r Repository) PackagesKey() string

type RepositoryCollection

type RepositoryCollection []*Repository

type Source

type Source struct {
	Name       string
	Path       string
	SourceType SourceType
	Branch     string
	Index      int
}

func (Source) IsValid

func (s Source) IsValid() bool

type SourceType

type SourceType uint8