-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
remote relations worker polls offer model
- Loading branch information
1 parent
3c332bc
commit 836dfb5
Showing
26 changed files
with
1,331 additions
and
830 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,184 @@ | ||
| // Copyright 2017 Canonical Ltd. | ||
| // Licensed under the AGPLv3, see LICENCE file for details. | ||
|
|
||
| package crossmodel | ||
|
|
||
| import ( | ||
| "fmt" | ||
|
|
||
| "github.com/juju/errors" | ||
| "github.com/juju/loggo" | ||
| "gopkg.in/juju/names.v2" | ||
|
|
||
| "github.com/juju/juju/apiserver/params" | ||
| "github.com/juju/juju/state" | ||
| ) | ||
|
|
||
| var logger = loggo.GetLogger("juju.apiserver.common.crossmodel") | ||
|
|
||
| // PublishRelationChange applies the relation change event to the specified backend. | ||
| func PublishRelationChange(backend Backend, change params.RemoteRelationChangeEvent) error { | ||
| logger.Debugf("publish into model %v change: %+v", backend.ModelUUID(), change) | ||
|
|
||
| relationTag, err := getRemoteEntityTag(backend, change.RelationId) | ||
| if err != nil { | ||
| if errors.IsNotFound(err) { | ||
| logger.Debugf("not found relation tag %+v in model %v, exit early", change.RelationId, backend.ModelUUID()) | ||
| return nil | ||
| } | ||
| return errors.Trace(err) | ||
| } | ||
| logger.Debugf("relation tag for remote id %+v is %v", change.RelationId, relationTag) | ||
|
|
||
| // Ensure the relation exists. | ||
| rel, err := backend.KeyRelation(relationTag.Id()) | ||
| if errors.IsNotFound(err) { | ||
| if change.Life != params.Alive { | ||
| return nil | ||
| } | ||
| } | ||
| if err != nil { | ||
| return errors.Trace(err) | ||
| } | ||
|
|
||
| // Look up the application on the remote side of this relation | ||
| // ie from the model which published this change. | ||
| applicationTag, err := getRemoteEntityTag(backend, change.ApplicationId) | ||
| if err != nil { | ||
| return errors.Trace(err) | ||
| } | ||
| logger.Debugf("application tag for remote id %+v is %v", change.ApplicationId, applicationTag) | ||
|
|
||
| // If the remote model has destroyed the relation, do it here also. | ||
| if change.Life != params.Alive { | ||
| logger.Debugf("remote side of %v died", relationTag) | ||
| if err := rel.Destroy(); err != nil { | ||
| return errors.Trace(err) | ||
| } | ||
| // See if we need to remove the remote application proxy - we do this | ||
| // on the offering side as there is 1:1 between proxy and consuming app. | ||
| if applicationTag != nil { | ||
| remoteApp, err := backend.RemoteApplication(applicationTag.Id()) | ||
| if err != nil && !errors.IsNotFound(err) { | ||
| return errors.Trace(err) | ||
| } | ||
| if err == nil && remoteApp.IsConsumerProxy() { | ||
| logger.Debugf("destroy consuming app proxy for %v", applicationTag.Id()) | ||
| if err := remoteApp.Destroy(); err != nil { | ||
| return errors.Trace(err) | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| // TODO(wallyworld) - deal with remote application being removed | ||
| if applicationTag == nil { | ||
| logger.Infof("no remote application found for %v", relationTag.Id()) | ||
| return nil | ||
| } | ||
| logger.Debugf("remote applocation for changed relation %v is %v", relationTag.Id(), applicationTag.Id()) | ||
|
|
||
| for _, id := range change.DepartedUnits { | ||
| unitTag := names.NewUnitTag(fmt.Sprintf("%s/%v", applicationTag.Id(), id)) | ||
| logger.Debugf("unit %v has departed relation %v", unitTag.Id(), relationTag.Id()) | ||
| ru, err := rel.RemoteUnit(unitTag.Id()) | ||
| if err != nil { | ||
| return errors.Trace(err) | ||
| } | ||
| logger.Debugf("%s leaving scope", unitTag.Id()) | ||
| if err := ru.LeaveScope(); err != nil { | ||
| return errors.Trace(err) | ||
| } | ||
| } | ||
|
|
||
| for _, change := range change.ChangedUnits { | ||
| unitTag := names.NewUnitTag(fmt.Sprintf("%s/%v", applicationTag.Id(), change.UnitId)) | ||
| logger.Debugf("changed unit tag for remote id %v is %v", change.UnitId, unitTag) | ||
| ru, err := rel.RemoteUnit(unitTag.Id()) | ||
| if err != nil { | ||
| return errors.Trace(err) | ||
| } | ||
| inScope, err := ru.InScope() | ||
| if err != nil { | ||
| return errors.Trace(err) | ||
| } | ||
| settings := make(map[string]interface{}) | ||
| for k, v := range change.Settings { | ||
| settings[k] = v | ||
| } | ||
| if !inScope { | ||
| logger.Debugf("%s entering scope (%v)", unitTag.Id(), settings) | ||
| err = ru.EnterScope(settings) | ||
| } else { | ||
| logger.Debugf("%s updated settings (%v)", unitTag.Id(), settings) | ||
| err = ru.ReplaceSettings(settings) | ||
| } | ||
| if err != nil { | ||
| return errors.Trace(err) | ||
| } | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| func getRemoteEntityTag(backend Backend, id params.RemoteEntityId) (names.Tag, error) { | ||
| modelTag := names.NewModelTag(id.ModelUUID) | ||
| return backend.GetRemoteEntity(modelTag, id.Token) | ||
| } | ||
|
|
||
| // WatchRelationUnits returns a watcher for changes to the units on the specified relation. | ||
| func WatchRelationUnits(backend Backend, tag names.RelationTag) (state.RelationUnitsWatcher, error) { | ||
| relation, err := backend.KeyRelation(tag.Id()) | ||
| if err != nil { | ||
| return nil, errors.Trace(err) | ||
| } | ||
| for _, ep := range relation.Endpoints() { | ||
| _, err := backend.Application(ep.ApplicationName) | ||
| if errors.IsNotFound(err) { | ||
| // Not found, so it's the remote application. Try the next endpoint. | ||
| continue | ||
| } else if err != nil { | ||
| return nil, errors.Trace(err) | ||
| } | ||
| w, err := relation.WatchUnits(ep.ApplicationName) | ||
| if err != nil { | ||
| return nil, errors.Trace(err) | ||
| } | ||
| return w, nil | ||
| } | ||
| return nil, errors.NotFoundf("local application for %s", names.ReadableString(tag)) | ||
| } | ||
|
|
||
| // RelationUnitSettings returns the unit settings for the specified relation unit. | ||
| func RelationUnitSettings(backend Backend, ru params.RelationUnit) (params.Settings, error) { | ||
| relationTag, err := names.ParseRelationTag(ru.Relation) | ||
| if err != nil { | ||
| return nil, errors.Trace(err) | ||
| } | ||
| rel, err := backend.KeyRelation(relationTag.Id()) | ||
| if err != nil { | ||
| return nil, errors.Trace(err) | ||
| } | ||
| unitTag, err := names.ParseUnitTag(ru.Unit) | ||
| if err != nil { | ||
| return nil, errors.Trace(err) | ||
| } | ||
| unit, err := rel.Unit(unitTag.Id()) | ||
| if err != nil { | ||
| return nil, errors.Trace(err) | ||
| } | ||
| settings, err := unit.Settings() | ||
| if err != nil { | ||
| return nil, errors.Trace(err) | ||
| } | ||
| paramsSettings := make(params.Settings) | ||
| for k, v := range settings { | ||
| vString, ok := v.(string) | ||
| if !ok { | ||
| return nil, errors.Errorf( | ||
| "invalid relation setting %q: expected string, got %T", k, v, | ||
| ) | ||
| } | ||
| paramsSettings[k] = vString | ||
| } | ||
| return paramsSettings, nil | ||
| } |
Oops, something went wrong.