Documentation ¶
Index ¶
- Variables
- func Asset(name string) ([]byte, error)
- func AssetDir(name string) ([]string, error)
- func AssetInfo(name string) (os.FileInfo, error)
- func AssetNames() []string
- func DashName(name string) string
- func MustAsset(name string) []byte
- func RestoreAsset(dir, name string) error
- func RestoreAssets(dir, name string) error
- func UpperName(name string) string
- type AWSProvider
- func (p *AWSProvider) AppGet(name string) (*structs.App, error)
- func (p *AWSProvider) BuildCopy(srcApp, id, destApp string) (*structs.Build, error)
- func (p *AWSProvider) BuildCreateIndex(app string, index structs.Index, manifest, description string, cache bool) (*structs.Build, error)
- func (p *AWSProvider) BuildCreateRepo(app, url, manifest, description string, cache bool) (*structs.Build, error)
- func (p *AWSProvider) BuildCreateTar(app string, src io.Reader, manifest, description string, cache bool) (*structs.Build, error)
- func (p *AWSProvider) BuildDelete(app, id string) (*structs.Build, error)
- func (p *AWSProvider) BuildGet(app, id string) (*structs.Build, error)
- func (p *AWSProvider) BuildList(app string) (structs.Builds, error)
- func (p *AWSProvider) BuildRelease(b *structs.Build) (*structs.Release, error)
- func (p *AWSProvider) BuildSave(b *structs.Build) error
- func (p *AWSProvider) CapacityGet() (*structs.Capacity, error)
- func (p *AWSProvider) CertificateCreate(pub, key, chain string) (*structs.Certificate, error)
- func (p *AWSProvider) CertificateDelete(id string) error
- func (p *AWSProvider) CertificateGenerate(domains []string) (*structs.Certificate, error)
- func (p *AWSProvider) CertificateList() (structs.Certificates, error)
- func (p *AWSProvider) EventSend(e *structs.Event, err error) error
- func (p *AWSProvider) IndexDiff(index *structs.Index) ([]string, error)
- func (p *AWSProvider) IndexDownload(index *structs.Index, dir string) error
- func (p *AWSProvider) IndexUpload(hash string, data []byte) error
- func (p *AWSProvider) InstanceList() (structs.Instances, error)
- func (p *AWSProvider) LogStream(app string, w io.Writer, opts structs.LogStreamOptions) error
- func (p *AWSProvider) ReleaseDelete(app, id string) (*structs.Release, error)
- func (p *AWSProvider) ReleaseGet(app, id string) (*structs.Release, error)
- func (p *AWSProvider) ReleaseList(app string) (structs.Releases, error)
- func (p *AWSProvider) ReleasePromote(app, id string) (*structs.Release, error)
- func (p *AWSProvider) ReleaseSave(r *structs.Release, bucket, key string) error
- func (p *AWSProvider) ServiceCreate(name, kind string, params map[string]string) (*structs.Service, error)
- func (p *AWSProvider) ServiceDelete(name string) (*structs.Service, error)
- func (p *AWSProvider) ServiceGet(name string) (*structs.Service, error)
- func (p *AWSProvider) ServiceLink(name, app, process string) (*structs.Service, error)
- func (p *AWSProvider) ServiceLinkReplace(a *structs.App, s *structs.Service) error
- func (p *AWSProvider) ServiceLinkSet(a *structs.App, s *structs.Service) error
- func (p *AWSProvider) ServiceLinkSubscribe(a *structs.App, s *structs.Service) error
- func (p *AWSProvider) ServiceUnlink(name, app, process string) (*structs.Service, error)
- func (p *AWSProvider) ServiceUnlinkReplace(a *structs.App, s *structs.Service) error
- func (p *AWSProvider) ServiceUnlinkSet(a *structs.App, s *structs.Service) error
- func (p *AWSProvider) ServiceUnlinkSubscribe(a *structs.App, s *structs.Service) error
- func (p *AWSProvider) SystemGet() (*structs.System, error)
- func (p *AWSProvider) SystemSave(system structs.System) error
- type CfsslCertificateBundle
- type CfsslError
- type ECSServices
- type Template
- type TemplateParameter
Constants ¶
This section is empty.
Variables ¶
var ( CustomTopic = os.Getenv("CUSTOM_TOPIC") SortableTime = "20060102.150405.000000000" ValidAppName = regexp.MustCompile(`\A[a-zA-Z][-a-zA-Z0-9]{3,29}\z`) )
var (
IndexOperationConcurrency = 128
)
Functions ¶
func Asset ¶
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 ¶
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 ¶
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 MustAsset ¶
MustAsset is like Asset but panics when Asset would return an error. It simplifies safe initialization of global variables.
func RestoreAsset ¶
RestoreAsset restores an asset under the given directory
func RestoreAssets ¶
RestoreAssets restores an asset under the given directory recursively
Types ¶
type AWSProvider ¶
func NewProvider ¶
func NewProvider(region, access, secret, endpoint string) (*AWSProvider, error)
func (*AWSProvider) BuildCopy ¶
func (p *AWSProvider) BuildCopy(srcApp, id, destApp string) (*structs.Build, error)
func (*AWSProvider) BuildCreateIndex ¶
func (*AWSProvider) BuildCreateRepo ¶
func (*AWSProvider) BuildCreateTar ¶
func (*AWSProvider) BuildDelete ¶
func (p *AWSProvider) BuildDelete(app, id string) (*structs.Build, error)
func (*AWSProvider) BuildGet ¶
func (p *AWSProvider) BuildGet(app, id string) (*structs.Build, error)
func (*AWSProvider) BuildRelease ¶
func (*AWSProvider) BuildSave ¶
func (p *AWSProvider) BuildSave(b *structs.Build) error
BuildSave creates or updates a build item in DynamoDB. It takes an optional bucket argument, which if set indicates to PUT Log data into S3
func (*AWSProvider) CapacityGet ¶
func (p *AWSProvider) CapacityGet() (*structs.Capacity, error)
returns individual server memory, total rack memory
func (*AWSProvider) CertificateCreate ¶
func (p *AWSProvider) CertificateCreate(pub, key, chain string) (*structs.Certificate, error)
func (*AWSProvider) CertificateDelete ¶
func (p *AWSProvider) CertificateDelete(id string) error
func (*AWSProvider) CertificateGenerate ¶
func (p *AWSProvider) CertificateGenerate(domains []string) (*structs.Certificate, error)
func (*AWSProvider) CertificateList ¶
func (p *AWSProvider) CertificateList() (structs.Certificates, error)
func (*AWSProvider) EventSend ¶
func (p *AWSProvider) EventSend(e *structs.Event, err error) error
EventSend publishes an important message out to the world.
On AWS messages are published to SNS. The Rack has an HTTP endpoint that is an SNS subscription, and when a message is delivered forwards them to all configured webhook services.
Often the Rack has a Console webhook which facilitates forwarding events to Slack with additional formatting and filtering.
Because these are important system events, they are also published to Segment for operational metrics.
func (*AWSProvider) IndexDiff ¶
func (p *AWSProvider) IndexDiff(index *structs.Index) ([]string, error)
func (*AWSProvider) IndexDownload ¶
func (p *AWSProvider) IndexDownload(index *structs.Index, dir string) error
func (*AWSProvider) IndexUpload ¶
func (p *AWSProvider) IndexUpload(hash string, data []byte) error
func (*AWSProvider) InstanceList ¶
func (p *AWSProvider) InstanceList() (structs.Instances, error)
func (*AWSProvider) LogStream ¶
func (p *AWSProvider) LogStream(app string, w io.Writer, opts structs.LogStreamOptions) error
func (*AWSProvider) ReleaseDelete ¶
func (p *AWSProvider) ReleaseDelete(app, id string) (*structs.Release, error)
func (*AWSProvider) ReleaseGet ¶
func (p *AWSProvider) ReleaseGet(app, id string) (*structs.Release, error)
func (*AWSProvider) ReleaseList ¶
func (p *AWSProvider) ReleaseList(app string) (structs.Releases, error)
func (*AWSProvider) ReleasePromote ¶
func (p *AWSProvider) ReleasePromote(app, id string) (*structs.Release, error)
func (*AWSProvider) ReleaseSave ¶
func (p *AWSProvider) ReleaseSave(r *structs.Release, bucket, key string) error
func (*AWSProvider) ServiceCreate ¶
func (*AWSProvider) ServiceDelete ¶
func (p *AWSProvider) ServiceDelete(name string) (*structs.Service, error)
func (*AWSProvider) ServiceGet ¶
func (p *AWSProvider) ServiceGet(name string) (*structs.Service, error)
func (*AWSProvider) ServiceLink ¶
func (p *AWSProvider) ServiceLink(name, app, process string) (*structs.Service, error)
func (*AWSProvider) ServiceLinkReplace ¶
func (*AWSProvider) ServiceLinkSet ¶
func (*AWSProvider) ServiceLinkSubscribe ¶
func (*AWSProvider) ServiceUnlink ¶
func (p *AWSProvider) ServiceUnlink(name, app, process string) (*structs.Service, error)
func (*AWSProvider) ServiceUnlinkReplace ¶
func (*AWSProvider) ServiceUnlinkSet ¶
func (*AWSProvider) ServiceUnlinkSubscribe ¶
func (*AWSProvider) SystemSave ¶
func (p *AWSProvider) SystemSave(system structs.System) error
type CfsslCertificateBundle ¶
type CfsslCertificateBundle struct {
Bundle string `json:"bundle"`
}
type CfsslError ¶
func (CfsslError) Error ¶
func (e CfsslError) Error() string
type ECSServices ¶
type Template ¶
type Template struct {
Parameters map[string]TemplateParameter
}