Compare commits
3 Commits
4214259591
...
3b3c0e6118
Author | SHA1 | Date | |
---|---|---|---|
3b3c0e6118 | |||
78c0c309d7 | |||
33ac911f9c |
34
builder.go
Normal file
34
builder.go
Normal file
@ -0,0 +1,34 @@
|
||||
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(
|
||||
fc *FunctionalComponent,
|
||||
) Component {
|
||||
return fc
|
||||
}
|
||||
|
||||
func (fc *FunctionalComponent) Init(ctx context.Context) error {
|
||||
if fc.init != nil {
|
||||
return fc.init(ctx)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
func (fc *FunctionalComponent) Start(ctx context.Context) error {
|
||||
if fc.start != nil {
|
||||
return fc.start(ctx)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
func (fc *FunctionalComponent) Stop(ctx context.Context) error {
|
||||
if fc.stop != nil {
|
||||
return fc.stop(ctx)
|
||||
}
|
||||
return nil
|
||||
}
|
@ -2,6 +2,6 @@ package curre
|
||||
|
||||
import "context"
|
||||
|
||||
type Closer interface {
|
||||
Close(ctx context.Context) error
|
||||
type Stopper interface {
|
||||
Stop(ctx context.Context) error
|
||||
}
|
||||
|
@ -3,5 +3,5 @@ package curre
|
||||
type Component interface {
|
||||
Initer
|
||||
Starter
|
||||
Closer
|
||||
Stopper
|
||||
}
|
||||
|
@ -28,6 +28,6 @@ func (hs *httpServer) Start(ctx context.Context) error {
|
||||
|
||||
return nil
|
||||
}
|
||||
func (hs *httpServer) Close(ctx context.Context) error {
|
||||
func (hs *httpServer) Stop(ctx context.Context) error {
|
||||
return nil
|
||||
}
|
||||
|
2
go.sum
Normal file
2
go.sum
Normal file
@ -0,0 +1,2 @@
|
||||
git.front.kjuulh.io/kjuulh/curre v0.0.0-20220909233936-421425959197 h1:aOFriK+Ui/Kp0llmPXi3qTQkU6IPvsrRW4jl87TPArQ=
|
||||
git.front.kjuulh.io/kjuulh/curre v0.0.0-20220909233936-421425959197/go.mod h1:m7WpSehONLqPh/XF3F0BI0UOpLOfGuDmDEFI1XsM6fE=
|
@ -139,7 +139,7 @@ func (m *Manager) shutdown(ctx context.Context) error {
|
||||
|
||||
go func(ctx context.Context) {
|
||||
for _, c := range closers {
|
||||
c.Close(ctx)
|
||||
c.Stop(ctx)
|
||||
}
|
||||
|
||||
shutdownChan <- struct{}{}
|
||||
|
Loading…
Reference in New Issue
Block a user