controller

Documentation

Index

• Variables
• type Client
  • func NewClient(uri, key string) (*Client, error)
  • func NewClientWithPin(uri, key string, pin []byte) (*Client, error)
  • func (c *Client) AppList() ([]*ct.App, error)
  • func (c *Client) Close() error
  • func (c *Client) CreateApp(app *ct.App) error
  • func (c *Client) CreateArtifact(artifact *ct.Artifact) error
  • func (c *Client) CreateKey(pubKey string) (*ct.Key, error)
  • func (c *Client) CreateProvider(provider *ct.Provider) error
  • func (c *Client) CreateRelease(release *ct.Release) error
  • func (c *Client) CreateRoute(appID string, route *strowger.Route) error
  • func (c *Client) DeleteJob(appID, jobID string) error
  • func (c *Client) DeleteKey(id string) error
  • func (c *Client) DeleteRoute(appID string, routeID string) error
  • func (c *Client) GetApp(appID string) (*ct.App, error)
  • func (c *Client) GetAppRelease(appID string) (*ct.Release, error)
  • func (c *Client) GetArtifact(artifactID string) (*ct.Artifact, error)
  • func (c *Client) GetFormation(appID, releaseID string) (*ct.Formation, error)
  • func (c *Client) GetJobLog(appID, jobID string) (io.ReadCloser, error)
  • func (c *Client) GetRelease(releaseID string) (*ct.Release, error)
  • func (c *Client) JobList(appID string) ([]*ct.Job, error)
  • func (c *Client) KeyList() ([]*ct.Key, error)
  • func (c *Client) ProviderList() ([]*ct.Provider, error)
  • func (c *Client) ProvisionResource(req *ct.ResourceReq) (*ct.Resource, error)
  • func (c *Client) PutFormation(formation *ct.Formation) error
  • func (c *Client) PutJob(job *ct.Job) error
  • func (c *Client) PutResource(resource *ct.Resource) error
  • func (c *Client) RouteList(appID string) ([]*strowger.Route, error)
  • func (c *Client) RunJobAttached(appID string, job *ct.NewJob) (utils.ReadWriteCloser, error)
  • func (c *Client) RunJobDetached(appID string, req *ct.NewJob) (*ct.Job, error)
  • func (c *Client) SetAppRelease(appID, releaseID string) error
  • func (c *Client) StreamFormations(since *time.Time) (*FormationUpdates, *error)
• type FormationUpdates
  • func (u *FormationUpdates) Close() error

Variables

var ErrNotFound = errors.New("controller: not found")

Types

type Client

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

func NewClient

func NewClient(uri, key string) (*Client, error)

func NewClientWithPin

func NewClientWithPin(uri, key string, pin []byte) (*Client, error)

func (*Client) AppList

func (c *Client) AppList() ([]*ct.App, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) CreateApp

func (c *Client) CreateApp(app *ct.App) error

func (*Client) CreateArtifact

func (c *Client) CreateArtifact(artifact *ct.Artifact) error

func (*Client) CreateKey

func (c *Client) CreateKey(pubKey string) (*ct.Key, error)

func (*Client) CreateProvider

func (c *Client) CreateProvider(provider *ct.Provider) error

func (*Client) CreateRelease

func (c *Client) CreateRelease(release *ct.Release) error

func (*Client) CreateRoute

func (c *Client) CreateRoute(appID string, route *strowger.Route) error

func (*Client) DeleteJob

func (c *Client) DeleteJob(appID, jobID string) error

func (*Client) DeleteKey

func (c *Client) DeleteKey(id string) error

func (*Client) DeleteRoute

func (c *Client) DeleteRoute(appID string, routeID string) error

func (*Client) GetApp

func (c *Client) GetApp(appID string) (*ct.App, error)

func (*Client) GetAppRelease

func (c *Client) GetAppRelease(appID string) (*ct.Release, error)

func (*Client) GetArtifact

func (c *Client) GetArtifact(artifactID string) (*ct.Artifact, error)

func (*Client) GetFormation

func (c *Client) GetFormation(appID, releaseID string) (*ct.Formation, error)

func (*Client) GetJobLog

func (c *Client) GetJobLog(appID, jobID string) (io.ReadCloser, error)

func (*Client) GetRelease

func (c *Client) GetRelease(releaseID string) (*ct.Release, error)

func (*Client) JobList

func (c *Client) JobList(appID string) ([]*ct.Job, error)

func (*Client) KeyList

func (c *Client) KeyList() ([]*ct.Key, error)

func (*Client) ProviderList

func (c *Client) ProviderList() ([]*ct.Provider, error)

func (*Client) ProvisionResource

func (c *Client) ProvisionResource(req *ct.ResourceReq) (*ct.Resource, error)

func (*Client) PutFormation

func (c *Client) PutFormation(formation *ct.Formation) error

func (*Client) PutJob

func (c *Client) PutJob(job *ct.Job) error

func (*Client) PutResource

func (c *Client) PutResource(resource *ct.Resource) error

func (*Client) RouteList

func (c *Client) RouteList(appID string) ([]*strowger.Route, error)

func (*Client) RunJobAttached

func (c *Client) RunJobAttached(appID string, job *ct.NewJob) (utils.ReadWriteCloser, error)

func (*Client) RunJobDetached

func (c *Client) RunJobDetached(appID string, req *ct.NewJob) (*ct.Job, error)

func (*Client) SetAppRelease

func (c *Client) SetAppRelease(appID, releaseID string) error

func (*Client) StreamFormations

func (c *Client) StreamFormations(since *time.Time) (*FormationUpdates, *error)

type FormationUpdates

type FormationUpdates struct {
	Chan <-chan *ct.ExpandedFormation
	// contains filtered or unexported fields
}

func (*FormationUpdates) Close

func (u *FormationUpdates) Close() error