Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
44218ec4ac
|
|||
a2c53271e4
|
|||
3b3c0e6118
|
|||
78c0c309d7
|
34
builder.go
Normal file
34
builder.go
Normal file
@@ -0,0 +1,34 @@
|
|||||||
|
package curre
|
||||||
|
|
||||||
|
import "context"
|
||||||
|
|
||||||
|
type FunctionalComponent struct {
|
||||||
|
InitFunc func(fc *FunctionalComponent, ctx context.Context) error
|
||||||
|
StartFunc func(fc *FunctionalComponent, ctx context.Context) error
|
||||||
|
StopFunc func(fc *FunctionalComponent, ctx context.Context) error
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewFunctionalComponent(
|
||||||
|
fc *FunctionalComponent,
|
||||||
|
) Component {
|
||||||
|
return fc
|
||||||
|
}
|
||||||
|
|
||||||
|
func (fc *FunctionalComponent) Init(ctx context.Context) error {
|
||||||
|
if fc.InitFunc != nil {
|
||||||
|
return fc.InitFunc(fc, ctx)
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
func (fc *FunctionalComponent) Start(ctx context.Context) error {
|
||||||
|
if fc.StartFunc != nil {
|
||||||
|
return fc.StartFunc(fc, ctx)
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
func (fc *FunctionalComponent) Stop(ctx context.Context) error {
|
||||||
|
if fc.StopFunc != nil {
|
||||||
|
return fc.StopFunc(fc, ctx)
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
@@ -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
|
||||||
}
|
}
|
||||||
|
@@ -3,5 +3,5 @@ package curre
|
|||||||
type Component interface {
|
type Component interface {
|
||||||
Initer
|
Initer
|
||||||
Starter
|
Starter
|
||||||
Closer
|
Stopper
|
||||||
}
|
}
|
||||||
|
@@ -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
|
||||||
}
|
}
|
||||||
|
@@ -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{}{}
|
||||||
|
Reference in New Issue
Block a user