summaryrefslogtreecommitdiff
path: root/service
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2018-06-10 13:10:11 +0300
committerWolfy-J <[email protected]>2018-06-10 13:10:11 +0300
commitd4c007859c002e6af540ec516929de81d03ff82d (patch)
treed7115bded0ae58a08dfe84d8a2cfcdb32c347132 /service
parent2f4e1d950339076574edc50044d6f1ebc3a83a01 (diff)
no immutable services
Diffstat (limited to 'service')
-rw-r--r--service/container.go (renamed from service/registry.go)28
-rw-r--r--service/container_test.go (renamed from service/registry_test.go)0
2 files changed, 14 insertions, 14 deletions
diff --git a/service/registry.go b/service/container.go
index f94d4171..fb1d6874 100644
--- a/service/registry.go
+++ b/service/container.go
@@ -17,8 +17,8 @@ type Config interface {
Unmarshal(out interface{}) error
}
-// Registry controls all internal RR services and provides plugin based system.
-type Registry interface {
+// Container controls all internal RR services and provides plugin based system.
+type Container interface {
// Register add new service to the registry under given name.
Register(name string, service Service)
@@ -40,9 +40,9 @@ type Registry interface {
// Service provides high level functionality for road runner Service.
type Service interface {
- // WithConfig must return Service instance configured with the given environment. Must return error in case of
- // misconfiguration, might return nil as Service if Service is not enabled.
- WithConfig(cfg Config, reg Registry) (Service, error)
+ // Configure must return configure service and return true if service is enabled. Must return error in case of
+ // misconfiguration. Services must not be used without proper configuration pushed first.
+ Configure(cfg Config, reg Container) (enabled bool, err error)
// Serve serves Service.
Serve() error
@@ -96,7 +96,7 @@ func (e *entry) setStopped() {
}
// NewRegistry creates new registry.
-func NewRegistry(log logrus.FieldLogger) Registry {
+func NewRegistry(log logrus.FieldLogger) Container {
return &registry{
log: log,
candidates: make([]*entry, 0),
@@ -131,18 +131,18 @@ func (r *registry) Configure(cfg Config) error {
continue
}
- s, err := e.Service.WithConfig(segment, r)
+ _, err := e.Service.Configure(segment, r)
if err != nil {
return errors.Wrap(err, fmt.Sprintf("%s.service", e.Name))
}
- if s != nil {
- r.configured = append(r.configured, &entry{
- Name: e.Name,
- Service: s,
- serving: false,
- })
- }
+ //if s != nil {
+ // r.configured = append(r.configured, &entry{
+ // Name: e.Name,
+ // Service: s,
+ // serving: false,
+ // })
+ //}
}
return nil
diff --git a/service/registry_test.go b/service/container_test.go
index 6d43c336..6d43c336 100644
--- a/service/registry_test.go
+++ b/service/container_test.go