models

package
v0.0.0-...-c28a0c0 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2016 License: Apache-2.0, Apache-2.0 Imports: 56 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CustomTopic = os.Getenv("CUSTOM_TOPIC")
View Source 
var DEPLOYMENT_TIMEOUT = 10 * time.Minute
View Source 
var DescribeStacksCache = map[string]DescribeStacksResult{}
View Source 
var DescribeStacksCacheTTL = 5 * time.Second
View Source 
var DescribeStacksMutex = &sync.Mutex{}
View Source 
var ErrPending = errors.New("can not get docker client for non-running container")
View Source 
var (
	IndexOperationConcurrency = 128
)
View Source 
var ManifestRandomPorts = true

set to false when testing for deterministic ports

View Source 
var NotificationHost = os.Getenv("NOTIFICATION_HOST")
View Source 
var NotificationTopic = os.Getenv("NOTIFICATION_TOPIC")
View Source 
var PauseNotifications = false
View Source 
var SortableTime = "20060102.150405.000000000"
View Source 
var StatusCodePrefix = client.StatusCodePrefix

Functions

func AppDockerLogin 

func AppDockerLogin(app App) (string, error)

Log into the appropriate registry for the given app This could be the self-hosted v1 registry or an ECR registry

func Asset 

func Asset(name string) ([]byte, error)

Asset loads and returns the asset for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetDir 

func AssetDir(name string) ([]string, error)

AssetDir returns the file names below a certain directory embedded in the file by go-bindata. For example if you run go-bindata on data/... and data contains the following hierarchy: 

data/
  foo.txt
  img/
    a.png
    b.png

then AssetDir("data") would return []string{"foo.txt", "img"} AssetDir("data/img") would return []string{"a.png", "b.png"} AssetDir("foo.txt") and AssetDir("notexist") would return an error AssetDir("") will return []string{"data"}.

func AssetInfo 

func AssetInfo(name string) (os.FileInfo, error)

AssetInfo loads and returns the asset info for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetNames 

func AssetNames() []string

AssetNames returns the names of the assets.

func AutoScaling 

func AutoScaling() *autoscaling.AutoScaling

func AwsCamelize 

func AwsCamelize(dasherized string) string

func CFParams 

func CFParams(source map[string]string) map[string]string

turns a dasherized map of key/value CLI params to parameters that CloudFormation expects

func CloudFormation 

func CloudFormation() *cloudformation.CloudFormation

func CloudWatch 

func CloudWatch() *cloudwatch.CloudWatch

func CloudWatchLogs 

func CloudWatchLogs() *cloudwatchlogs.CloudWatchLogs

func DashName 

func DashName(name string) string

func DescribeStack 

func DescribeStack(name string) (*cloudformation.DescribeStacksOutput, error)

func DescribeStacks 

func DescribeStacks() (*cloudformation.DescribeStacksOutput, error)

func Docker 

func Docker(host string) (*docker.Client, error)

func DockerHost 

func DockerHost() (string, error)

func DockerLogin 

func DockerLogin(ac docker.AuthConfiguration) (string, error)

func DockerLogout 

func DockerLogout(ac docker.AuthConfiguration) error

func DynamoDB 

func DynamoDB() *dynamodb.DynamoDB

func EC2 

func EC2() *ec2.EC2

func ECR 

func ECR() *ecr.ECR

func ECS 

func ECS() *ecs.ECS

func ELB 

func ELB() *elb.ELB

func GetAppServices 

func GetAppServices(app string) ([]*ecs.Service, error)

func IAM 

func IAM() *iam.IAM

func IndexUpload 

func IndexUpload(hash string, data []byte) error

func InstanceKeyroll 

func InstanceKeyroll() error

func InstanceSSH 

func InstanceSSH(id, command, term string, height, width int, rw io.ReadWriter) error

func Kinesis 

func Kinesis() *kinesis.Kinesis

func LoginPrivateRegistries 

func LoginPrivateRegistries() error

func MustAsset 

func MustAsset(name string) []byte

MustAsset is like Asset but panics when Asset would return an error. It simplifies safe initialization of global variables.

func Notify 

func Notify(name, status string, data map[string]string) error

func NotifyError 

func NotifyError(action string, err error, data map[string]string) error

uniform error handling

func NotifySuccess 

func NotifySuccess(action string, data map[string]string) error

func PullAppImages 

func PullAppImages()

func PutEnvironment 

func PutEnvironment(app string, env Environment) (string, error)

func PutRackSettings 

func PutRackSettings(env Environment) error

func RDS 

func RDS() *rds.RDS

func RestoreAsset 

func RestoreAsset(dir, name string) error

RestoreAsset restores an asset under the given directory

func RestoreAssets 

func RestoreAssets(dir, name string) error

RestoreAssets restores an asset under the given directory recursively

func S3 

func S3() *s3.S3

func S3Put 

func S3Put(bucket, key string, data []byte, public bool) error

func S3PutFile 

func S3PutFile(bucket, key string, f io.ReadSeeker, public bool) error

func SNS 

func SNS() *sns.SNS

func SQS 

func SQS() *sqs.SQS

func SetFormation 

func SetFormation(app, process string, count, memory int64) error

Update Process Parameters for Count and Memory Expects -1 for count or memory to indicate no change, since count=0 is valid

func SettingGet 

func SettingGet(name string) (string, error)

func SettingSet 

func SettingSet(name, value string) error

func UpdateStack 

func UpdateStack(req *cloudformation.UpdateStackInput) (*cloudformation.UpdateStackOutput, error)

func UpperName 

func UpperName(name string) string

Types

type App 

type App struct {
	Name    string `json:"name"`
	Release string `json:"release"`
	Status  string `json:"status"`

	Outputs    map[string]string `json:"-"`
	Parameters map[string]string `json:"-"`
	Tags       map[string]string `json:"-"`
}

func GetApp 

func GetApp(name string) (*App, error)

func GetAppBound 

func GetAppBound(name string) (*App, error)

func GetAppUnbound 

func GetAppUnbound(name string) (*App, error)

func (*App) BalancerHost 

func (a *App) BalancerHost() string

func (*App) BalancerPorts 

func (a *App) BalancerPorts(ps string) map[string]string

func (*App) Cleanup 

func (a *App) Cleanup() error

func (*App) Create 

func (a *App) Create() error

func (*App) Delete 

func (a *App) Delete() error

func (*App) ExecAttached 

func (a *App) ExecAttached(pid, command string, height, width int, rw io.ReadWriter) error

func (*App) ForkRelease 

func (a *App) ForkRelease() (*Release, error)

func (*App) Formation 

func (a *App) Formation() (string, error)

func (*App) IsBound 

func (a *App) IsBound() bool

func (*App) LatestRelease 

func (a *App) LatestRelease() (*Release, error)

func (*App) ProcessPorts 

func (a *App) ProcessPorts(ps string) map[string]string

func (*App) Resources 

func (a *App) Resources() (Resources, error)

func (*App) RunAttached 

func (a *App) RunAttached(process, command string, height, width int, rw io.ReadWriter) error

func (*App) RunDetached 

func (a *App) RunDetached(process, command string) error

func (*App) StackName 

func (a *App) StackName() string

func (*App) SubscribeLogs 

func (a *App) SubscribeLogs(output chan []byte, quit chan bool) error

During the transition from Kinesis to CloudWatch Logs, apps might not have been re-deployed and provisioned a LogGroup. Conditionally fall back to reading from Kinesis in this case.

func (*App) TaskDefinitionFamily 

func (a *App) TaskDefinitionFamily() string

func (*App) UpdateParams 

func (a *App) UpdateParams(changes map[string]string) error

Shortcut for updating current parameters If template changed, more care about new or removed parameters must be taken (see Release.Promote or System.Save)

type Apps 

type Apps []App

func ListApps 

func ListApps() (Apps, error)

func (Apps) Len 

func (s Apps) Len() int

func (Apps) Less 

func (s Apps) Less(i, j int) bool

func (Apps) Swap 

func (s Apps) Swap(i, j int)

type Build 

type Build struct {
	Id       string `json:"id"`
	App      string `json:"app"`
	Logs     string `json:"logs"`
	Manifest string `json:"manifest"`
	Release  string `json:"release"`
	Status   string `json:"status"`

	Description string `json:"description"`

	Started time.Time `json:"started"`
	Ended   time.Time `json:"ended"`
	// contains filtered or unexported fields
}

func GetBuild 

func GetBuild(app, id string) (*Build, error)

func NewBuild 

func NewBuild(app string) Build

func (*Build) Cleanup 

func (b *Build) Cleanup() error

func (*Build) CopyTo 

func (srcBuild *Build) CopyTo(destApp App) (*Build, error)

func (*Build) ExecuteIndex 

func (b *Build) ExecuteIndex(index Index, cache bool, manifest string, ch chan error)

func (*Build) ExecuteLocal 

func (b *Build) ExecuteLocal(r io.Reader, cache bool, manifest string, ch chan error)

func (*Build) ExecuteRemote 

func (b *Build) ExecuteRemote(repo string, cache bool, manifest string, ch chan error)

func (*Build) Fail 

func (b *Build) Fail(err error)

func (*Build) IsRunning 

func (b *Build) IsRunning() bool

Test if another build container is running. This is a temporary workaround since the current Docker Registry does not handle pushing multiple images at the same time. Course grained locking will prevent subtle build errors until a better registry and/or Docker image subsystem is integrated

func (*Build) Save 

func (b *Build) Save() error

type Builds 

type Builds []Build

func ListBuilds 

func ListBuilds(app string) (Builds, error)

type CfsslCertificateBundle 

type CfsslCertificateBundle struct {
	Bundle string `json:"bundle"`
}

type Deployment 

type Deployment struct {
	Status  string
	Release string

	Desired int64
	Pending int64
	Running int64

	Created time.Time
}

type Deployments 

type Deployments []Deployment

func ListDeployments 

func ListDeployments(app string) (Deployments, error)

type DescribeStacksResult 

type DescribeStacksResult struct {
	Name        string
	Output      *cloudformation.DescribeStacksOutput
	RequestTime time.Time
}

type ECSEvents 

type ECSEvents []*ecs.ServiceEvent

func (ECSEvents) CapacityWarning 

func (events ECSEvents) CapacityWarning() string

func (ECSEvents) HasCapacityWarning 

func (events ECSEvents) HasCapacityWarning() bool

type ECSServices 

type ECSServices []*ecs.Service

func ClusterServices 

func ClusterServices() (ECSServices, error)

func (ECSServices) EventsSince 

func (services ECSServices) EventsSince(since time.Time) ECSEvents

func (ECSServices) IsConverged 

func (services ECSServices) IsConverged() bool

func (ECSServices) LastEvent 

func (services ECSServices) LastEvent() ecs.ServiceEvent

type Environment 

type Environment map[string]string

func GetEnvironment 

func GetEnvironment(app string) (Environment, error)

func GetPrivateRegistriesAuth 

func GetPrivateRegistriesAuth() (Environment, docker.AuthConfigurations119, error)

func GetRackSettings 

func GetRackSettings() (Environment, error)

Use the Rack Settings bucket and EncryptionKey KMS key to store and retrieve sensitive credentials, just like app env

func LoadEnvironment 

func LoadEnvironment(data []byte) Environment

func (Environment) Raw 

func (e Environment) Raw() string

func (Environment) SortedNames 

func (e Environment) SortedNames() []string

type Formation 

type Formation []FormationEntry

func ListFormation 

func ListFormation(app string) (Formation, error)

func (Formation) Entry 

func (f Formation) Entry(name string) *FormationEntry

func (Formation) Len 

func (f Formation) Len() int

func (Formation) Less 

func (f Formation) Less(a, b int) bool

func (Formation) Swap 

func (f Formation) Swap(a, b int)

type FormationEntry 

type FormationEntry struct {
	Balancer string `json:"balancer"`
	Name     string `json:"name"`
	Count    int    `json:"count"`
	Memory   int    `json:"memory"`
	Ports    []int  `json:"ports"`
}

type Index 

type Index map[string]IndexItem

func (Index) Diff 

func (index Index) Diff() ([]string, error)

func (Index) Download 

func (index Index) Download(dir string) error

type IndexItem 

type IndexItem struct {
	Name    string      `json:"name"`
	Mode    os.FileMode `json:"mode"`
	ModTime time.Time   `json:"mtime"`
}

type Manifest 

type Manifest []ManifestEntry

func LoadManifest 

func LoadManifest(data string, app *App) (Manifest, error)

func (Manifest) BalancerResourceName 

func (m Manifest) BalancerResourceName(process string) string

func (Manifest) Balancers 

func (m Manifest) Balancers() []ManifestBalancer

func (Manifest) Entry 

func (m Manifest) Entry(name string) *ManifestEntry

func (Manifest) EntryNames 

func (m Manifest) EntryNames() []string

func (Manifest) Formation 

func (m Manifest) Formation() (string, error)

func (Manifest) GetBalancer 

func (m Manifest) GetBalancer(name string) *ManifestBalancer

func (Manifest) HasExternalPorts 

func (m Manifest) HasExternalPorts() bool

func (Manifest) HasProcesses 

func (m Manifest) HasProcesses() bool

type ManifestBalancer 

type ManifestBalancer struct {
	Entry  ManifestEntry
	Public bool
}

func (ManifestBalancer) ExternalPorts 

func (mb ManifestBalancer) ExternalPorts() []string

func (ManifestBalancer) FirstPort 

func (mb ManifestBalancer) FirstPort() string

func (ManifestBalancer) InternalPorts 

func (mb ManifestBalancer) InternalPorts() []string

func (ManifestBalancer) LoadBalancerName 

func (mb ManifestBalancer) LoadBalancerName() template.HTML

func (ManifestBalancer) PortMappings 

func (mb ManifestBalancer) PortMappings() []ManifestPort

func (ManifestBalancer) Ports 

func (mb ManifestBalancer) Ports() []string

func (ManifestBalancer) ProcessName 

func (mb ManifestBalancer) ProcessName() string

func (ManifestBalancer) Randoms 

func (mb ManifestBalancer) Randoms() map[string]int

func (ManifestBalancer) ResourceName 

func (mb ManifestBalancer) ResourceName() string

func (ManifestBalancer) Scheme 

func (mb ManifestBalancer) Scheme() string

type ManifestEntries 

type ManifestEntries map[string]ManifestEntry

type ManifestEntry 

type ManifestEntry struct {
	Name string

	Build      string                   `yaml:"build"`
	Command    interface{}              `yaml:"command"`
	Env        []string                 `yaml:"environment"`
	Exports    map[string]string        `yaml:"-"`
	Image      string                   `yaml:"image"`
	Links      []string                 `yaml:"links"`
	LinkVars   map[string]template.HTML `yaml:"-"`
	Ports      []string                 `yaml:"ports"`
	Privileged bool                     `yaml:"privileged"`
	Volumes    []string                 `yaml:"volumes"`
	// contains filtered or unexported fields
}

func (*ManifestEntry) BalancerResourceName 

func (me *ManifestEntry) BalancerResourceName() string

func (*ManifestEntry) CommandString 

func (me *ManifestEntry) CommandString() string

func (ManifestEntry) ContainerPorts 

func (me ManifestEntry) ContainerPorts() []string

func (ManifestEntry) EnvMap 

func (me ManifestEntry) EnvMap() map[string]string

func (ManifestEntry) ExternalPorts 

func (me ManifestEntry) ExternalPorts() []string

func (ManifestEntry) HasBalancer 

func (me ManifestEntry) HasBalancer() bool

func (ManifestEntry) InternalPorts 

func (me ManifestEntry) InternalPorts() []string

func (ManifestEntry) MountableVolumes 

func (me ManifestEntry) MountableVolumes() []string

func (ManifestEntry) PortMappings 

func (me ManifestEntry) PortMappings() []ManifestPort

func (ManifestEntry) Randoms 

func (me ManifestEntry) Randoms() map[string]int

func (ManifestEntry) RegistryImage 

func (me ManifestEntry) RegistryImage(app *App, buildId string) string

type ManifestPort 

type ManifestPort struct {
	Balancer  string
	Container string
	Public    bool
}

type Metrics 

type Metrics struct {
	Cpu    float64
	Memory float64
	Disk   float64
}

func AppMetrics 

func AppMetrics(app string) (*Metrics, error)

func InstanceMetrics 

func InstanceMetrics(app, process, instance string) (*Metrics, error)

func ProcessMetrics 

func ProcessMetrics(app, process string) (*Metrics, error)

type Process 

type Process struct {
	Id      string    `json:"id"`
	App     string    `json:"app"`
	Command string    `json:"command"`
	Host    string    `json:"host"`
	Image   string    `json:"image"`
	Name    string    `json:"name"`
	Ports   []string  `json:"ports"`
	Release string    `json:"release"`
	Size    int64     `json:"size"`
	Cpu     float64   `json:"cpu"`
	Memory  float64   `json:"memory"`
	Started time.Time `json:"started"`
	// contains filtered or unexported fields
}

func GetProcess 

func GetProcess(app, id string) (*Process, error)

func ListPendingProcesses 

func ListPendingProcesses(app string) ([]*Process, error)

func ListProcesses 

func ListProcesses(app string) ([]*Process, error)

func (*Process) Docker 

func (p *Process) Docker() (*docker.Client, error)

func (*Process) FetchStats 

func (p *Process) FetchStats() error

func (*Process) Stop 

func (p *Process) Stop() error

type Processes 

type Processes []*Process

func ListOneoffProcesses 

func ListOneoffProcesses(app string) (Processes, error)

func (Processes) Len 

func (ps Processes) Len() int

func (Processes) Less 

func (ps Processes) Less(i, j int) bool

Sort processes by name and id Processes with a 'pending' id will naturally come last by design

func (Processes) Swap 

func (ps Processes) Swap(i, j int)

type Release 

type Release struct {
	Id       string    `json:"id"`
	App      string    `json:"app"`
	Build    string    `json:"build"`
	Env      string    `json:"env"`
	Manifest string    `json:"manifest"`
	Created  time.Time `json:"created"`
}

func GetRelease 

func GetRelease(app, id string) (*Release, error)

func NewRelease 

func NewRelease(app string) Release

func (*Release) Cleanup 

func (r *Release) Cleanup() error

func (*Release) EnvironmentUrl 

func (r *Release) EnvironmentUrl() string

func (*Release) Formation 

func (r *Release) Formation() (string, error)

func (*Release) Promote 

func (r *Release) Promote() error

func (*Release) Save 

func (r *Release) Save() error

type Releases 

type Releases []Release

func ListReleases 

func ListReleases(app string) (Releases, error)

type Resource 

type Resource struct {
	Id   string
	Name string

	Reason string
	Status string
	Type   string

	Time time.Time
}

type Resources 

type Resources map[string]Resource

func ListResources 

func ListResources(app string) (Resources, error)

type SSL 

type SSL struct {
	Expiration time.Time `json:"expiration"`
	Domain     string    `json:"domain"`
	Process    string    `json:"process"`
	Port       int       `json:"port"`
	Secure     bool      `json:"secure"`
}

func CreateSSL 

func CreateSSL(app, process string, port int, body, key string, chain string, secure bool) (*SSL, error)

func DeleteSSL 

func DeleteSSL(app, process string, port int) (*SSL, error)

func UpdateSSL 

func UpdateSSL(app, process string, port int, body, key string, chain string) (*SSL, error)

type SSLs 

type SSLs []SSL

func ListSSLs 

func ListSSLs(a string) (SSLs, error)

type Service 

type Service client.Service

func GetService 

func GetService(name string) (*Service, error)

func GetServiceBound 

func GetServiceBound(name string) (*Service, error)

func GetServiceUnbound 

func GetServiceUnbound(name string) (*Service, error)

func (*Service) Create 

func (s *Service) Create() error

func (*Service) CreateDatastore 

func (s *Service) CreateDatastore() (*cloudformation.CreateStackInput, error)

func (*Service) CreatePapertrail 

func (s *Service) CreatePapertrail() (*cloudformation.CreateStackInput, error)

func (*Service) CreateS3 

func (s *Service) CreateS3() (*cloudformation.CreateStackInput, error)

func (*Service) CreateSNS 

func (s *Service) CreateSNS() (*cloudformation.CreateStackInput, error)

func (*Service) CreateSQS 

func (s *Service) CreateSQS() (*cloudformation.CreateStackInput, error)

func (*Service) CreateWebhook 

func (s *Service) CreateWebhook() (*cloudformation.CreateStackInput, error)

func (*Service) Delete 

func (s *Service) Delete() error

func (*Service) Formation 

func (s *Service) Formation() (string, error)

func (*Service) IsBound 

func (s *Service) IsBound() bool

func (*Service) LinkPapertrail 

func (s *Service) LinkPapertrail(app App) error

func (*Service) StackName 

func (s *Service) StackName() string

func (*Service) SubscribeLogs 

func (s *Service) SubscribeLogs(output chan []byte, quit chan bool) error

func (*Service) UnlinkPapertrail 

func (s *Service) UnlinkPapertrail(app App) error

func (*Service) Update 

func (s *Service) Update(changes map[string]string) error

Service Update takes a map of CF Parameter changes and applies on top of the existing parameters and the newest template. The CLI / Client / Server delegates everything to CloudFormation, and makes no guarantees of service uptime during update. In fact, most datastore updates guarantee resource replacement which will cause database downtime.

func (*Service) UpdateDatastore 

func (s *Service) UpdateDatastore() (*cloudformation.UpdateStackInput, error)

func (*Service) UpdateIAMService 

func (s *Service) UpdateIAMService() (*cloudformation.UpdateStackInput, error)

S3, SNS, SQS create an IAM user, therefore require IAM capabilitites for updates

func (*Service) UpdatePapertrail 

func (s *Service) UpdatePapertrail(arns map[string]string) error

type Services 

type Services []Service

func ListServices 

func ListServices() (Services, error)

func (Services) Len 

func (ss Services) Len() int

func (Services) Less 

func (ss Services) Less(i, j int) bool

func (Services) Swap 

func (ss Services) Swap(i, j int)

type Template 

type Template struct {
	Parameters map[string]TemplateParameter
}

type TemplateParameter 

type TemplateParameter struct {
	Default     string
	Description string
	Type        string
}

type Transaction 

type Transaction struct {
	Name   string
	Type   string
	Status string
	Start  time.Time
	End    time.Time
}

A Transaction groups more than one event on a Name/Type resource

type Transactions 

type Transactions []Transaction

func (Transactions) Len 

func (slice Transactions) Len() int

func (Transactions) Less 

func (slice Transactions) Less(i, j int) bool

func (Transactions) Swap 

func (slice Transactions) Swap(i, j int)

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.