Compare commits
No commits in common. "main" and "v1.2.2" 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'
|
|
51
manager.go
51
manager.go
@ -4,7 +4,6 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"os"
|
"os"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
@ -31,37 +30,10 @@ func NewManager() *Manager {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
type ComponentsAreReady struct {
|
func (m *Manager) RunNonBlocking(ctx context.Context) error {
|
||||||
}
|
go m.Run(ctx)
|
||||||
|
|
||||||
type CleanupFunc func(ctx context.Context) error
|
return nil
|
||||||
|
|
||||||
func (m *Manager) RunNonBlocking(ctx context.Context, readyChan chan ComponentsAreReady) (CleanupFunc, error) {
|
|
||||||
go func() error {
|
|
||||||
m.initLifetime()
|
|
||||||
err := m.init(ctx)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
err = m.startBlocking(ctx)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
readyChan <- ComponentsAreReady{}
|
|
||||||
|
|
||||||
err = m.wait(ctx)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
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 {
|
||||||
@ -126,14 +98,6 @@ func (m *Manager) start(ctx context.Context) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *Manager) startBlocking(ctx context.Context) error {
|
|
||||||
for _, c := range m.components {
|
|
||||||
m.startComponent(ctx, c)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *Manager) startComponent(ctx context.Context, component Component) {
|
func (m *Manager) startComponent(ctx context.Context, component Component) {
|
||||||
defer func() {
|
defer func() {
|
||||||
err := recover()
|
err := recover()
|
||||||
@ -164,13 +128,8 @@ func (m *Manager) initLifetime() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (m *Manager) wait(ctx context.Context) error {
|
func (m *Manager) wait(ctx context.Context) error {
|
||||||
select {
|
exitCode := <-m.exitChan
|
||||||
case exitCode := <-m.exitChan:
|
m.exitCode = exitCode
|
||||||
m.exitCode = exitCode
|
|
||||||
return nil
|
|
||||||
case <-ctx.Done():
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1,3 +0,0 @@
|
|||||||
{
|
|
||||||
"$schema": "https://docs.renovatebot.com/renovate-schema.json"
|
|
||||||
}
|
|
Loading…
x
Reference in New Issue
Block a user