Compare commits
6 Commits
Author | SHA1 | Date | |
---|---|---|---|
b055a7de1c | |||
f857d22142 | |||
b81d5a8988 | |||
db85184dca | |||
a59a278140 | |||
4774158f24 |
9
.drone.yml
Executable file
9
.drone.yml
Executable file
@ -0,0 +1,9 @@
|
|||||||
|
|
||||||
|
kind: pipeline
|
||||||
|
type: docker
|
||||||
|
name: "test"
|
||||||
|
steps:
|
||||||
|
- name: test
|
||||||
|
image: harbor.front.kjuulh.io/docker-proxy/library/bash:latest
|
||||||
|
commands:
|
||||||
|
- echo 'Run tests'
|
25
manager.go
25
manager.go
@ -4,6 +4,7 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"os"
|
"os"
|
||||||
"sync"
|
"sync"
|
||||||
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
@ -33,14 +34,10 @@ func NewManager() *Manager {
|
|||||||
type ComponentsAreReady struct {
|
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 {
|
go func() error {
|
||||||
defer func(ctx context.Context) {
|
|
||||||
err := m.shutdown(ctx)
|
|
||||||
if err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
}(ctx)
|
|
||||||
m.initLifetime()
|
m.initLifetime()
|
||||||
err := m.init(ctx)
|
err := m.init(ctx)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -61,7 +58,10 @@ func (m *Manager) RunNonBlocking(ctx context.Context, readyChan chan ComponentsA
|
|||||||
|
|
||||||
return nil
|
return nil
|
||||||
}()
|
}()
|
||||||
return nil
|
|
||||||
|
return func(ctx context.Context) error {
|
||||||
|
return m.shutdown(ctx)
|
||||||
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *Manager) Run(ctx context.Context) error {
|
func (m *Manager) Run(ctx context.Context) error {
|
||||||
@ -164,8 +164,13 @@ func (m *Manager) initLifetime() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (m *Manager) wait(ctx context.Context) error {
|
func (m *Manager) wait(ctx context.Context) error {
|
||||||
exitCode := <-m.exitChan
|
select {
|
||||||
m.exitCode = exitCode
|
case exitCode := <-m.exitChan:
|
||||||
|
m.exitCode = exitCode
|
||||||
|
return nil
|
||||||
|
case <-ctx.Done():
|
||||||
|
return nil
|
||||||
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
3
renovate.json
Normal file
3
renovate.json
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
{
|
||||||
|
"$schema": "https://docs.renovatebot.com/renovate-schema.json"
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user