Lines Matching defs:controller
34 type controller struct { struct
35 task *api.Task
36 adapter *containerAdapter
37 closed chan struct{}
38 err error
39 pulled chan struct{} // closed after pull
40 cancelPull func() // cancels pull context if not nil
41 pullErr error // pull error, only read after pulled closed
60 func (r *controller) Task() (*api.Task, error) {
65 func (r *controller) ContainerStatus(ctx context.Context) (*api.ContainerStatus, error) {
76 func (r *controller) PortStatus(ctx context.Context) (*api.PortStatus, error) {
90 func (r *controller) Update(ctx context.Context, t *api.Task) error {
100 func (r *controller) Prepare(ctx context.Context) error {
188 func (r *controller) Start(ctx context.Context) error {
284 func (r *controller) Wait(pctx context.Context) error {
330 func (r *controller) hasServiceBinding() bool {
349 func (r *controller) Shutdown(ctx context.Context) error {
390 func (r *controller) Terminate(ctx context.Context) error {
411 func (r *controller) Remove(ctx context.Context) error {
441 func (r *controller) waitReady(pctx context.Context) error {
482 … Logs(ctx context.Context, publisher exec.LogPublisher, options api.LogSubscriptionOptions) error {
571 func (r *controller) Close() error {
586 func (r *controller) matchevent(event events.Message) bool {
594 func (r *controller) checkClosed() error {
695 func (r *controller) checkHealth(ctx context.Context) error {