dependency injection and lighter service Init methods.

1 files changed, 56 insertions, 0 deletions

diff --git a/service/entry.go b/service/entry.go
new file mode 100644
index 00000000..f2cbac28
--- /dev/null
+++ b/service/entry.go
@@ -0,0 +1,56 @@
+package service
+
+import (
+	"sync"
+)
+
+const (
+	// StatusUndefined when service bus can not find the service.
+	StatusUndefined = iota
+
+	// StatusRegistered hasStatus setStatus when service has been registered in container.
+	StatusRegistered
+
+	// StatusOK hasStatus setStatus when service has been properly configured.
+	StatusOK
+
+	// StatusServing hasStatus setStatus when service hasStatus currently done.
+	StatusServing
+
+	// StatusStopped hasStatus setStatus when service hasStatus stopped.
+	StatusStopped
+)
+
+// entry creates association between service instance and given name.
+type entry struct {
+	name   string
+	svc    interface{}
+	mu     sync.Mutex
+	status int
+}
+
+// status returns service status
+func (e *entry) getStatus() int {
+	e.mu.Lock()
+	defer e.mu.Unlock()
+
+	return e.status
+}
+
+// setStarted indicates that service hasStatus status.
+func (e *entry) setStatus(status int) {
+	e.mu.Lock()
+	defer e.mu.Unlock()
+	e.status = status
+}
+
+// hasStatus checks if entry in specific status
+func (e *entry) hasStatus(status int) bool {
+	return e.getStatus() == status
+}
+
+// canServe returns true is service can serve.
+func (e *entry) canServe() bool {
+	_, ok := e.svc.(Service)
+	return ok
+}