Compare commits
2 Commits
v1.3.3
...
db85184dca
Author | SHA1 | Date | |
---|---|---|---|
db85184dca
|
|||
a59a278140
|
9
.drone.yml
Executable file
9
.drone.yml
Executable file
@@ -0,0 +1,9 @@
|
||||
|
||||
kind: pipeline
|
||||
type: docker
|
||||
name: "test"
|
||||
steps:
|
||||
- name: test
|
||||
image: bash
|
||||
commands:
|
||||
- echo 'Run tests'
|
16
manager.go
16
manager.go
@@ -34,15 +34,10 @@ func NewManager() *Manager {
|
||||
type ComponentsAreReady struct {
|
||||
}
|
||||
|
||||
func (m *Manager) RunNonBlocking(ctx context.Context, readyChan chan ComponentsAreReady) error {
|
||||
type CleanupFunc func(ctx context.Context) error
|
||||
|
||||
func (m *Manager) RunNonBlocking(ctx context.Context, readyChan chan ComponentsAreReady) (CleanupFunc, error) {
|
||||
go func() error {
|
||||
defer func() {
|
||||
ctx, _ := context.WithTimeout(context.Background(), time.Second*5)
|
||||
err := m.shutdown(ctx)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
}()
|
||||
m.initLifetime()
|
||||
err := m.init(ctx)
|
||||
if err != nil {
|
||||
@@ -63,7 +58,10 @@ func (m *Manager) RunNonBlocking(ctx context.Context, readyChan chan ComponentsA
|
||||
|
||||
return nil
|
||||
}()
|
||||
return nil
|
||||
|
||||
return func(ctx context.Context) error {
|
||||
return m.shutdown(ctx)
|
||||
}, nil
|
||||
}
|
||||
|
||||
func (m *Manager) Run(ctx context.Context) error {
|
||||
|
Reference in New Issue
Block a user