removed agent parameter

distribworks · Mar 12, 2020 · 361d13e · 361d13e
1 parent a261c8e
commit 361d13e
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 9 deletions.
diff --git a/dkron/agent.go b/dkron/agent.go
@@ -455,7 +455,7 @@ func (a *Agent) StartServer() {
 	}
 
 	if a.Store == nil {
-		s, err := NewStore(a)
+		s, err := NewStore()
 		if err != nil {
 			log.WithError(err).Fatal("dkron: Error initializing store")
 		}

diff --git a/dkron/job_test.go b/dkron/job_test.go
@@ -10,7 +10,7 @@ import (
 )
 
 func TestJobGetParent(t *testing.T) {
-	s, err := NewStore(nil)
+	s, err := NewStore()
 	defer s.Shutdown()
 	require.NoError(t, err)
 
@@ -99,7 +99,7 @@ func TestToProto(t *testing.T) {
 }
 
 func Test_isRunnable(t *testing.T) {
-	s, err := NewStore(nil)
+	s, err := NewStore()
 	a := &Agent{
 		Store: s,
 	}

diff --git a/dkron/store.go b/dkron/store.go
@@ -45,7 +45,7 @@ type kv struct {
 }
 
 // NewStore creates a new Storage instance.
-func NewStore(a *Agent) (*Store, error) {
+func NewStore() (*Store, error) {
 	db, err := buntdb.Open(":memory:")
 	if err != nil {
 		return nil, err

diff --git a/dkron/store_test.go b/dkron/store_test.go
@@ -10,8 +10,7 @@ import (
 )
 
 func TestStore(t *testing.T) {
-	a := NewAgent(nil)
-	s, err := NewStore(a)
+	s, err := NewStore()
 	require.NoError(t, err)
 	defer s.Shutdown()
 
@@ -459,10 +458,8 @@ func scaffoldJob() *Job {
 }
 
 func setupStore(t *testing.T) *Store {
-	a := NewAgent(nil)
-	s, err := NewStore(a)
+	s, err := NewStore()
 	require.NoError(t, err)
-	a.Store = s
 	return s
 }