Compare commits
No commits in common. "main" and "v1.3.1" have entirely different histories.
@ -1,9 +0,0 @@
|
||||
|
||||
kind: pipeline
|
||||
type: docker
|
||||
name: "test"
|
||||
steps:
|
||||
- name: test
|
||||
image: harbor.front.kjuulh.io/docker-proxy/library/bash:latest
|
||||
commands:
|
||||
- echo 'Run tests'
|
21
manager.go
21
manager.go
@ -4,7 +4,6 @@ import (
|
||||
"context"
|
||||
"os"
|
||||
"sync"
|
||||
"time"
|
||||
)
|
||||
|
||||
const (
|
||||
@ -34,9 +33,7 @@ func NewManager() *Manager {
|
||||
type ComponentsAreReady struct {
|
||||
}
|
||||
|
||||
type CleanupFunc func(ctx context.Context) error
|
||||
|
||||
func (m *Manager) RunNonBlocking(ctx context.Context, readyChan chan ComponentsAreReady) (CleanupFunc, error) {
|
||||
func (m *Manager) RunNonBlocking(ctx context.Context, readyChan chan ComponentsAreReady) error {
|
||||
go func() error {
|
||||
m.initLifetime()
|
||||
err := m.init(ctx)
|
||||
@ -56,12 +53,13 @@ func (m *Manager) RunNonBlocking(ctx context.Context, readyChan chan ComponentsA
|
||||
return err
|
||||
}
|
||||
|
||||
err = m.shutdown(ctx)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}()
|
||||
|
||||
return func(ctx context.Context) error {
|
||||
return m.shutdown(ctx)
|
||||
}, nil
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *Manager) Run(ctx context.Context) error {
|
||||
@ -164,14 +162,9 @@ func (m *Manager) initLifetime() {
|
||||
}
|
||||
|
||||
func (m *Manager) wait(ctx context.Context) error {
|
||||
select {
|
||||
case exitCode := <-m.exitChan:
|
||||
exitCode := <-m.exitChan
|
||||
m.exitCode = exitCode
|
||||
return nil
|
||||
case <-ctx.Done():
|
||||
return nil
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *Manager) shutdown(ctx context.Context) error {
|
||||
|
@ -1,3 +0,0 @@
|
||||
{
|
||||
"$schema": "https://docs.renovatebot.com/renovate-schema.json"
|
||||
}
|
Loading…
x
Reference in New Issue
Block a user