with public func
This commit is contained in:
parent
3b3c0e6118
commit
a2c53271e4
18
builder.go
18
builder.go
@ -3,9 +3,9 @@ package curre
|
|||||||
import "context"
|
import "context"
|
||||||
|
|
||||||
type FunctionalComponent struct {
|
type FunctionalComponent struct {
|
||||||
init func(ctx context.Context) error
|
InitFunc func(ctx context.Context) error
|
||||||
start func(ctx context.Context) error
|
StartFunc func(ctx context.Context) error
|
||||||
stop func(ctx context.Context) error
|
StopFunc func(ctx context.Context) error
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewFunctionalComponent(
|
func NewFunctionalComponent(
|
||||||
@ -15,20 +15,20 @@ func NewFunctionalComponent(
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (fc *FunctionalComponent) Init(ctx context.Context) error {
|
func (fc *FunctionalComponent) Init(ctx context.Context) error {
|
||||||
if fc.init != nil {
|
if fc.InitFunc != nil {
|
||||||
return fc.init(ctx)
|
return fc.InitFunc(ctx)
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
func (fc *FunctionalComponent) Start(ctx context.Context) error {
|
func (fc *FunctionalComponent) Start(ctx context.Context) error {
|
||||||
if fc.start != nil {
|
if fc.StartFunc != nil {
|
||||||
return fc.start(ctx)
|
return fc.StartFunc(ctx)
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
func (fc *FunctionalComponent) Stop(ctx context.Context) error {
|
func (fc *FunctionalComponent) Stop(ctx context.Context) error {
|
||||||
if fc.stop != nil {
|
if fc.StopFunc != nil {
|
||||||
return fc.stop(ctx)
|
return fc.StopFunc(ctx)
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user