empire

package module

Go to main page

Versions in this module

v0

v0.13.0

Sep 19, 2017

Changes in this version

+ const DBDriver

+ const DefaultInstancePortPoolEnd

+ const DefaultInstancePortPoolStart

+ const GenericProcessName

+ var DefaultSchema = &Schema

type App

+ Maintenance bool

type DB

+ Schema *Schema

+ func NewDB(conn *sql.DB) (*DB, error)

type Empire

+ ImageRegistry ImageRegistry

+ func (e *Empire) SetMaintenanceMode(ctx context.Context, opts SetMaintenanceModeOpts) error

+ type FakeScheduler struct

+ func NewFakeScheduler() *FakeScheduler

+ func (m *FakeScheduler) Remove(ctx context.Context, appID string) error

+ func (m *FakeScheduler) Restart(ctx context.Context, appID string, ss twelvefactor.StatusStream) error

+ func (m *FakeScheduler) Run(ctx context.Context, app *twelvefactor.Manifest) error

+ func (m *FakeScheduler) Stop(ctx context.Context, instanceID string) error

+ func (m *FakeScheduler) Submit(ctx context.Context, app *twelvefactor.Manifest, ss twelvefactor.StatusStream) error

+ func (m *FakeScheduler) Tasks(ctx context.Context, appID string) ([]*twelvefactor.Task, error)

+ type ImageRegistry interface

+ Resolve func(context.Context, image.Image, *jsonmessage.Stream) (image.Image, error)

+ type InstancePortPool struct

+ End uint

+ Start uint

+ type MaintenanceEvent struct

+ App string

+ Maintenance bool

+ Message string

+ User string

+ func (e MaintenanceEvent) Event() string

+ func (e MaintenanceEvent) GetApp() *App

+ func (e MaintenanceEvent) String() string

type Process

+ ECS *procfile.ECS

type ProcfileExtractor

+ ExtractProcfile func(context.Context, image.Image, *jsonmessage.Stream) ([]byte, error)

type ProcfileExtractorFunc

+ func (fn ProcfileExtractorFunc) ExtractProcfile(ctx context.Context, image image.Image, w *jsonmessage.Stream) ([]byte, error)

type RunOpts

+ Stderr io.Writer

+ Stdin io.Reader

+ Stdout io.Writer

+ type Scheduler twelvefactor.Scheduler

+ type Schema struct

+ InstancePortPool *InstancePortPool

+ type SetMaintenanceModeOpts struct

+ App *App

+ Maintenance bool

+ Message string

+ User *User

+ func (opts SetMaintenanceModeOpts) Event() MaintenanceEvent

+ func (opts SetMaintenanceModeOpts) Validate(e *Empire) error

v0.13.0-clearcare-2

Jul 24, 2019

v0.13.0-clearcare-1

Jul 17, 2019

v0.13.0-clearcare

Jul 17, 2019

v0.12.0

Mar 13, 2017

Changes in this version

type App

+ Certs Certs

+ type Certs map[string]string

+ func (c *Certs) Scan(src interface{}) error

+ func (c Certs) Value() (driver.Value, error)

+ type CertsAttachOpts struct

+ App *App

+ Cert string

+ Process string

+ type Host struct

+ ID string

+ type NoCertError struct

+ Process string

+ func (e *NoCertError) Error() string

type Port

+ Container int

+ Host int

+ Protocol string

type Process

+ Environment map[string]string

+ Ports []Port

type Release

+ func (r *Release) Procfile() (procfile.Procfile, error)

type Slug

+ func (s *Slug) ParsedProcfile() (procfile.Procfile, error)

type Task

+ Host Host

+ ID string

v0.11.1

Mar 13, 2017

v0.11.0

Aug 23, 2016

Changes in this version

+ type AllowedCommands int

+ const AllowCommandAny

+ const AllowCommandProcfile

+ type CommandNotAllowedError struct

+ Command Command

+ func (c *CommandNotAllowedError) Error() string

type DB

+ func (db *DB) CheckSchemaVersion() error

+ func (db *DB) SchemaVersion() (int, error)

+ type DeployOpts struct

+ App *App

+ Environment string

+ Image image.Image

+ Message string

+ Output *DeploymentStream

+ Stream bool

+ User *User

+ func (opts DeployOpts) Event() DeployEvent

+ func (opts DeployOpts) Validate(e *Empire) error

+ type DeploymentStream struct

+ func NewDeploymentStream(w io.Writer) *DeploymentStream

+ func (w *DeploymentStream) Error(err error) error

+ func (w *DeploymentStream) Publish(status scheduler.Status) error

+ func (w *DeploymentStream) Status(message string) error

+ func (w *DeploymentStream) Write(b []byte) (int, error)

type Empire

+ AllowedCommands AllowedCommands

+ Secret []byte

type Formation

+ func (f Formation) IsValid() error

+ type IncompatibleSchemaError struct

+ ExpectedSchemaVersion int

+ SchemaVersion int

+ func (e *IncompatibleSchemaError) Error() string

type Process

+ Cron *string

+ NoService bool

+ func (p *Process) IsValid() error

+ type ProcessUpdate struct

+ Constraints *Constraints

+ Process string

+ Quantity int

type RunEvent

+ Finished bool

+ func (e *RunEvent) Finish()

type ScaleEvent

+ Updates []*ScaleEventUpdate

+ type ScaleEventUpdate struct

+ Constraints Constraints

+ PreviousConstraints Constraints

+ PreviousQuantity int

+ Process string

+ Quantity int

type ScaleOpts

+ Updates []*ProcessUpdate

v0.10.2

Aug 10, 2016

v0.10.1

Jun 14, 2016

Changes in this version

+ var ErrUserName = errors.New("Name is required")

+ var Migrations = []migrate.Migration

+ var ProcfileName = "Procfile"

type AccessToken

+ func (t *AccessToken) IsValid() error

+ type AppEvent interface

+ GetApp func() *App

+ type CMDExtractor struct

+ func NewCMDExtractor(c *docker.Client) *CMDExtractor

+ func (e *CMDExtractor) Extract(_ context.Context, img image.Image, _ io.Writer) ([]byte, error)

type Command

+ func MustParseCommand(command string) Command

+ func ParseCommand(command string) (Command, error)

+ func (c Command) String() string

type CreateEvent

+ Message string

type CreateOpts

+ Message string

+ func (opts CreateOpts) Validate(e *Empire) error

type DeployEvent

+ Environment string

+ Message string

+ Release int

+ func (e DeployEvent) GetApp() *App

type DeploymentsCreateOpts

+ Environment string

+ Message string

+ func (opts DeploymentsCreateOpts) Validate(e *Empire) error

type DestroyEvent

+ Message string

type DestroyOpts

+ Message string

+ func (opts DestroyOpts) Validate(e *Empire) error

type Empire

+ Environment string

+ MessagesRequired bool

+ ProcfileExtractor ProcfileExtractor

+ RunRecorder RunRecorder

+ func (e *Empire) ListScale(ctx context.Context, app *App) (Formation, error)

+ type FileExtractor struct

+ func NewFileExtractor(c *docker.Client) *FileExtractor

+ func (e *FileExtractor) Extract(_ context.Context, img image.Image, w io.Writer) ([]byte, error)

type Formation

+ func (f *Formation) Scan(src interface{}) error

+ func (f Formation) Merge(other Formation) Formation

+ func (f Formation) Value() (driver.Value, error)

+ type MessageRequiredError struct

+ func (e *MessageRequiredError) Error() string

+ type MultiEventStream []EventStream

+ func (streams MultiEventStream) PublishEvent(e Event) error

type Process

+ CPUShare constraints.CPUShare

+ Memory constraints.Memory

+ Nproc constraints.Nproc

+ func (p *Process) Constraints() Constraints

+ func (p *Process) SetConstraints(c Constraints)

type ProcfileExtractor

+ func MultiExtractor(extractors ...ProcfileExtractor) ProcfileExtractor

+ Extract func(context.Context, image.Image, io.Writer) ([]byte, error)

+ type ProcfileExtractorFunc func(context.Context, image.Image, io.Writer) ([]byte, error)

+ func (fn ProcfileExtractorFunc) Extract(ctx context.Context, image image.Image, w io.Writer) ([]byte, error)

type RestartEvent

+ Message string

+ func (e RestartEvent) GetApp() *App

type RestartOpts

+ Message string

+ func (opts RestartOpts) Validate(e *Empire) error

type RollbackEvent

+ Message string

+ func (e RollbackEvent) GetApp() *App

type RollbackOpts

+ Message string

+ func (opts RollbackOpts) Validate(e *Empire) error

type RunEvent

+ Message string

+ URL string

+ func (e RunEvent) GetApp() *App

type RunOpts

+ Constraints *Constraints

+ Message string

+ func (opts RunOpts) Validate(e *Empire) error

+ type RunRecorder func() (io.Writer, error)

+ func RecordTo(w io.Writer) RunRecorder

+ func RecordToCloudWatch(group string, config client.ConfigProvider) RunRecorder

type ScaleEvent

+ Constraints Constraints

+ Message string

+ PreviousConstraints Constraints

+ func (e ScaleEvent) GetApp() *App

type ScaleOpts

+ Message string

+ func (opts ScaleOpts) Validate(e *Empire) error

type SetEvent

+ Message string

+ func (e SetEvent) GetApp() *App

type SetOpts

+ Message string

+ func (opts SetOpts) Validate(e *Empire) error

type Slug

+ Procfile []byte

+ func (s *Slug) Formation() (Formation, error)

type User

+ func (u *User) IsValid() error

v0.10.1-clearcare

Dec 6, 2018

v0.10.0

Jan 14, 2016

Changes in this version

+ const Version

+ var ErrNoReleases = errors.New("no releases")

+ var NullEventStream = EventStreamFunc(func(event Event) error { ... })

type App

+ Cert string

+ type AsyncEventStream struct

+ func AsyncEvents(e EventStream) *AsyncEventStream

+ func (e *AsyncEventStream) PublishEvent(event Event) error

+ type CreateEvent struct

+ Name string

+ User string

+ func (e CreateEvent) Event() string

+ func (e CreateEvent) String() string

+ type CreateOpts struct

+ Name string

+ User *User

+ func (opts CreateOpts) Event() CreateEvent

+ type DB struct

+ func OpenDB(uri string) (*DB, error)

+ func (db *DB) Debug()

+ func (db *DB) IsHealthy() bool

+ func (db *DB) MigrateUp(path string) ([]error, bool)

+ func (db *DB) Reset() error

+ type DeployEvent struct

+ App string

+ Image string

+ User string

+ func (e DeployEvent) Event() string

+ func (e DeployEvent) String() string

type DeploymentsCreateOpts

+ func (opts DeploymentsCreateOpts) Event() DeployEvent

+ type DestroyEvent struct

+ App string

+ User string

+ func (e DestroyEvent) Event() string

+ func (e DestroyEvent) String() string

+ type DestroyOpts struct

+ App *App

+ User *User

+ func (opts DestroyOpts) Event() DestroyEvent

type Empire

+ DB *DB

+ ExtractProcfile ProcfileExtractor

+ LogsStreamer LogsStreamer

+ Scheduler scheduler.Scheduler

+ func (e *Empire) AppsFind(q AppsQuery) (*App, error)

+ func (e *Empire) CertsAttach(ctx context.Context, app *App, cert string) error

+ func (e *Empire) Config(app *App) (*Config, error)

+ func (e *Empire) Create(ctx context.Context, opts CreateOpts) (*App, error)

+ func (e *Empire) Destroy(ctx context.Context, opts DestroyOpts) error

+ func (e *Empire) DomainsFind(q DomainsQuery) (*Domain, error)

+ func (e *Empire) ReleasesFind(q ReleasesQuery) (*Release, error)

+ func (e *Empire) Restart(ctx context.Context, opts RestartOpts) error

+ func (e *Empire) Rollback(ctx context.Context, opts RollbackOpts) (*Release, error)

+ func (e *Empire) Run(ctx context.Context, opts RunOpts) error

+ func (e *Empire) Scale(ctx context.Context, opts ScaleOpts) (*Process, error)

+ func (e *Empire) Set(ctx context.Context, opts SetOpts) (*Config, error)

+ func (e *Empire) Tasks(ctx context.Context, app *App) ([]*Task, error)

+ type Event interface

+ Event func() string

+ String func() string

+ type EventStream interface

+ PublishEvent func(Event) error

+ type EventStreamFunc func(Event) error

+ func (fn EventStreamFunc) PublishEvent(event Event) error

+ type KinesisLogsStreamer struct

+ func NewKinesisLogsStreamer() *KinesisLogsStreamer

+ func (s *KinesisLogsStreamer) StreamLogs(app *App, w io.Writer) error

+ type ProcfileExtractor func(context.Context, image.Image, io.Writer) (procfile.Procfile, error)

+ func PullAndExtract(c *dockerutil.Client) ProcfileExtractor

type Release

+ func (r *Release) Process(t ProcessType) *Process

+ type RestartEvent struct

+ App string

+ PID string

+ User string

+ func (e RestartEvent) Event() string

+ func (e RestartEvent) String() string

+ type RestartOpts struct

+ App *App

+ PID string

+ User *User

+ func (opts RestartOpts) Event() RestartEvent

+ type RollbackEvent struct

+ App string

+ User string

+ Version int

+ func (e RollbackEvent) Event() string

+ func (e RollbackEvent) String() string

+ type RollbackOpts struct

+ App *App

+ User *User

+ Version int

+ func (opts RollbackOpts) Event() RollbackEvent

+ type RunEvent struct

+ App string

+ Attached bool

+ Command string

+ User string

+ func (e RunEvent) Event() string

+ func (e RunEvent) String() string

+ type RunOpts struct

+ App *App

+ Command string

+ Env map[string]string

+ Input io.Reader

+ Output io.Writer

+ User *User

+ func (opts RunOpts) Event() RunEvent

+ type ScaleEvent struct

+ App string

+ PreviousQuantity int

+ Process string

+ Quantity int

+ User string

+ func (e ScaleEvent) Event() string

+ func (e ScaleEvent) String() string

+ type ScaleOpts struct

+ App *App

+ Constraints *Constraints

+ Process ProcessType

+ Quantity int

+ User *User

+ func (opts ScaleOpts) Event() ScaleEvent

+ type SetEvent struct

+ App string

+ Changed []string

+ User string

+ func (e SetEvent) Event() string

+ func (e SetEvent) String() string

+ type SetOpts struct

+ App *App

+ User *User

+ Vars Vars

+ func (opts SetOpts) Event() SetEvent

+ type Task struct

+ Command string

+ Constraints Constraints

+ Name string

+ State string

+ Type string

+ UpdatedAt time.Time

v0.9.2

Oct 27, 2015

Changes in this version

type Empire

+ func (e *Empire) StreamLogs(app *App, w io.Writer) error

+ type LogsStreamer interface

+ StreamLogs func(*App, io.Writer) error

type Options

+ LogsStreamer string

type ProcessState

+ Type string

v0.9.1

Jul 31, 2015

Changes in this version

+ const ExposePrivate

+ const ExposePublic

+ const StatusFailed

+ const StatusPending

+ const StatusSuccess

+ const UserKey

+ const WebPort

+ const WebProcessType

+ var All = ScopeFunc(func(db *gorm.DB) *gorm.DB { ... })

+ var Constraints1X = Constraints

+ var Constraints2X = Constraints

+ var ConstraintsPX = Constraints

+ var DefaultConstraints = Constraints1X

+ var DefaultOptions = Options

+ var DefaultQuantities = ProcessQuantityMap

+ var DefaultReporter = reporter.NewLogReporter()

+ var ErrDomainAlreadyAdded = errors.New("Domain already added to this app.")

+ var ErrDomainInUse = errors.New("Domain currently in use by another app.")

+ var ErrDomainNotFound = errors.New("Domain could not be found.")

+ var ErrInvalidName = &ValidationError

+ var ErrNoPorts = errors.New("no ports avaiable")

+ var NamePattern = regexp.MustCompile(`^[a-z][a-z0-9-]{2,30}$`)

+ var NamedConstraints = map[string]Constraints

+ var Procfile = "Procfile"

+ func AppID(id string) func(*gorm.DB) *gorm.DB

+ func AppNameFromRepo(repo string) string

+ func FakeDockerPull(img image.Image, w io.Writer) error

+ func Migrate(db, path string) ([]error, bool)

+ func SignToken(secret []byte, token *AccessToken) (string, error)

+ func WithUser(ctx context.Context, u *User) context.Context

+ type AccessToken struct

+ Token string

+ User *User

+ func ParseToken(secret []byte, token string) (*AccessToken, error)

+ type App struct

+ Certificates []*Certificate

+ CreatedAt *time.Time

+ Exposure string

+ ID string

+ Name string

+ Repo *string

+ func (a *App) BeforeCreate() error

+ func (a *App) IsValid() error

+ type AppsQuery struct

+ ID *string

+ Name *string

+ Repo *string

+ func (q AppsQuery) Scope(db *gorm.DB) *gorm.DB

+ type Certificate struct

+ App *App

+ AppID string

+ CertificateChain string

+ CreatedAt *time.Time

+ ID string

+ Name string

+ PrivateKey string

+ UpdatedAt *time.Time

+ func (c *Certificate) BeforeCreate() error

+ func (c *Certificate) BeforeUpdate() error

+ type CertificatesQuery struct

+ App *App

+ ID *string

+ func (q CertificatesQuery) Scope(db *gorm.DB) *gorm.DB

+ type Command string

+ func (c *Command) Scan(src interface{}) error

+ func (c Command) Value() (driver.Value, error)

+ type CommandMap map[ProcessType]Command

+ func ParseProcfile(b []byte) (CommandMap, error)

+ func (cm *CommandMap) Scan(src interface{}) error

+ func (cm CommandMap) Value() (driver.Value, error)

+ type ComposedScope []Scope

+ func (s ComposedScope) Scope(db *gorm.DB) *gorm.DB

+ type Config struct

+ App *App

+ AppID string

+ ID string

+ Vars Vars

+ func NewConfig(old *Config, vars Vars) *Config

+ type ConfigsQuery struct

+ App *App

+ ID *string

+ func (q ConfigsQuery) Scope(db *gorm.DB) *gorm.DB

+ type Constraints constraints.Constraints

+ func (c *Constraints) UnmarshalJSON(b []byte) error

+ func (c Constraints) String() string

+ type DeploymentsCreateOpts struct

+ App *App

+ Image image.Image

+ Output io.Writer

+ User *User

+ type DockerOptions struct

+ Auth *docker.AuthConfigurations

+ CertPath string

+ Socket string

+ type Domain struct

+ App *App

+ AppID string

+ CreatedAt *time.Time

+ Hostname string

+ ID string

+ func (d *Domain) BeforeCreate() error

+ type DomainsQuery struct

+ App *App

+ Hostname *string

+ func (q DomainsQuery) Scope(db *gorm.DB) *gorm.DB

+ type ECSOptions struct

+ Cluster string

+ ServiceRole string

+ type ELBOptions struct

+ ExternalSecurityGroupID string

+ ExternalSubnetIDs []string

+ InternalSecurityGroupID string

+ InternalSubnetIDs []string

+ InternalZoneID string

+ type Empire struct

+ Logger log15.Logger

+ func New(options Options) (*Empire, error)

+ func (e *Empire) AccessTokensCreate(accessToken *AccessToken) (*AccessToken, error)

+ func (e *Empire) AccessTokensFind(token string) (*AccessToken, error)

+ func (e *Empire) Apps(q AppsQuery) ([]*App, error)

+ func (e *Empire) AppsCreate(app *App) (*App, error)

+ func (e *Empire) AppsDestroy(ctx context.Context, app *App) error

+ func (e *Empire) AppsFirst(q AppsQuery) (*App, error)

+ func (e *Empire) AppsScale(ctx context.Context, app *App, t ProcessType, quantity int, c *Constraints) (*Process, error)

+ func (e *Empire) CertificatesCreate(ctx context.Context, cert *Certificate) (*Certificate, error)

+ func (e *Empire) CertificatesDestroy(ctx context.Context, cert *Certificate) error

+ func (e *Empire) CertificatesFirst(ctx context.Context, q CertificatesQuery) (*Certificate, error)

+ func (e *Empire) CertificatesUpdate(ctx context.Context, cert *Certificate) (*Certificate, error)

+ func (e *Empire) ConfigsApply(ctx context.Context, app *App, vars Vars) (*Config, error)

+ func (e *Empire) ConfigsCurrent(app *App) (*Config, error)

+ func (e *Empire) Deploy(ctx context.Context, opts DeploymentsCreateOpts) (*Release, error)

+ func (e *Empire) Domains(q DomainsQuery) ([]*Domain, error)

+ func (e *Empire) DomainsCreate(domain *Domain) (*Domain, error)

+ func (e *Empire) DomainsDestroy(domain *Domain) error

+ func (e *Empire) DomainsFirst(q DomainsQuery) (*Domain, error)

+ func (e *Empire) IsHealthy() bool

+ func (e *Empire) JobStatesByApp(ctx context.Context, app *App) ([]*ProcessState, error)

+ func (e *Empire) ProcessesRestart(ctx context.Context, app *App, id string) error

+ func (e *Empire) ProcessesRun(ctx context.Context, app *App, opts ProcessRunOpts) error

+ func (e *Empire) Releases(q ReleasesQuery) ([]*Release, error)

+ func (e *Empire) ReleasesFirst(q ReleasesQuery) (*Release, error)

+ func (e *Empire) ReleasesLast(app *App) (*Release, error)

+ func (e *Empire) ReleasesRollback(ctx context.Context, app *App, version int) (*Release, error)

+ func (e *Empire) Reset() error

+ type Extractor interface

+ Extract func(image.Image) (CommandMap, error)

+ type Formation map[ProcessType]*Process

+ func NewFormation(f Formation, cm CommandMap) Formation

+ func (f Formation) Processes() []*Process

+ type Options struct

+ AWSConfig *aws.Config

+ DB string

+ Docker DockerOptions

+ ECS ECSOptions

+ ELB ELBOptions

+ Secret string

+ type Port struct

+ AppID *string

+ ID string

+ Port int

+ type Process struct

+ Command Command

+ ID string

+ Port int

+ Quantity int

+ Release *Release

+ ReleaseID string

+ Type ProcessType

+ func NewProcess(t ProcessType, cmd Command) *Process

+ type ProcessQuantityMap map[ProcessType]int

+ type ProcessRunOpts struct

+ Command string

+ Env map[string]string

+ Input io.Reader

+ Output io.Writer

+ type ProcessState struct

+ Command string

+ Constraints Constraints

+ Name string

+ State string

+ UpdatedAt time.Time

+ type ProcessType string

+ func (p *ProcessType) Scan(src interface{}) error

+ func (p ProcessType) Value() (driver.Value, error)

+ type ProcessesQuery struct

+ Release *Release

+ func (q ProcessesQuery) Scope(db *gorm.DB) *gorm.DB

+ type ProcfileError struct

+ Err error

+ func (e *ProcfileError) Error() string

+ type Release struct

+ App *App

+ AppID string

+ Config *Config

+ ConfigID string

+ CreatedAt *time.Time

+ Description string

+ ID string

+ Processes []*Process

+ Slug *Slug

+ SlugID string

+ Version int

+ func (r *Release) BeforeCreate() error

+ func (r *Release) Formation() Formation

+ type ReleasesQuery struct

+ App *App

+ Range headerutil.Range

+ Version *int

+ func (q ReleasesQuery) DefaultRange() headerutil.Range

+ func (q ReleasesQuery) Scope(db *gorm.DB) *gorm.DB

+ type Resolver interface

+ Resolve func(context.Context, image.Image, io.Writer) (image.Image, error)

+ type Scope interface

+ Scope func(*gorm.DB) *gorm.DB

+ func FieldEquals(field string, v interface{}) Scope

+ func ForApp(app *App) Scope

+ func ID(id string) Scope

+ func Limit(limit int) Scope

+ func Order(order string) Scope

+ func Preload(associations ...string) Scope

+ func Range(r headerutil.Range) Scope

+ type ScopeFunc func(*gorm.DB) *gorm.DB

+ func (f ScopeFunc) Scope(db *gorm.DB) *gorm.DB

+ type Slug struct

+ ID string

+ Image image.Image

+ ProcessTypes CommandMap

+ type User struct

+ GitHubToken string

+ Name string

+ func UserFromContext(ctx context.Context) (*User, bool)

+ func (u *User) GitHubClient() *http.Client

+ type ValidationError struct

+ Err error

+ func (e *ValidationError) Error() string

+ type Variable string

+ type Vars map[Variable]*string

+ func (v *Vars) Scan(src interface{}) error

+ func (v Vars) Value() (driver.Value, error)

v0.9.0

Jun 15, 2015

v0.0.1

Feb 11, 2015

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL