This commit is contained in:
Kasper Juul Hermansen 2022-09-10 13:08:16 +02:00
parent 33ac911f9c
commit 78c0c309d7
Signed by: kjuulh
GPG Key ID: 57B6E1465221F912
5 changed files with 28 additions and 5 deletions

23
builder.go Normal file
View File

@ -0,0 +1,23 @@
package curre
import "context"
type FunctionalComponent struct {
init func(ctx context.Context) error
start func(ctx context.Context) error
stop func(ctx context.Context) error
}
func NewFunctionalComponent(
init func(ctx context.Context) error,
start func(ctx context.Context) error,
stop func(ctx context.Context) error,
) Component {
return &FunctionalComponent{
init, start, stop,
}
}
func (fc *FunctionalComponent) Init(ctx context.Context) error { return fc.init(ctx) }
func (fc *FunctionalComponent) Start(ctx context.Context) error { return fc.start(ctx) }
func (fc *FunctionalComponent) Stop(ctx context.Context) error { return fc.stop(ctx) }

View File

@ -2,6 +2,6 @@ package curre
import "context" import "context"
type Closer interface { type Stopper interface {
Close(ctx context.Context) error Stop(ctx context.Context) error
} }

View File

@ -3,5 +3,5 @@ package curre
type Component interface { type Component interface {
Initer Initer
Starter Starter
Closer Stopper
} }

View File

@ -28,6 +28,6 @@ func (hs *httpServer) Start(ctx context.Context) error {
return nil return nil
} }
func (hs *httpServer) Close(ctx context.Context) error { func (hs *httpServer) Stop(ctx context.Context) error {
return nil return nil
} }

View File

@ -139,7 +139,7 @@ func (m *Manager) shutdown(ctx context.Context) error {
go func(ctx context.Context) { go func(ctx context.Context) {
for _, c := range closers { for _, c := range closers {
c.Close(ctx) c.Stop(ctx)
} }
shutdownChan <- struct{}{} shutdownChan <- struct{}{}