@@ -24,20 +24,20 @@ func ProviderQueue(mctx helpers.MetricsCtx, lc fx.Lifecycle, repo repo.Repo) (*q
24
24
return q .NewQueue (helpers .LifecycleCtx (mctx , lc ), "provider-v1" , repo .Datastore ())
25
25
}
26
26
27
- // SimpleProviderCtor creates new record provider
28
- func SimpleProviderCtor (mctx helpers.MetricsCtx , lc fx.Lifecycle , queue * q.Queue , rt routing.IpfsRouting ) provider.Provider {
27
+ // SimpleProvider creates new record provider
28
+ func SimpleProvider (mctx helpers.MetricsCtx , lc fx.Lifecycle , queue * q.Queue , rt routing.IpfsRouting ) provider.Provider {
29
29
return simple .NewProvider (helpers .LifecycleCtx (mctx , lc ), queue , rt )
30
30
}
31
31
32
- // SimpleReproviderCtor creates new reprovider
33
- func SimpleReproviderCtor (reproviderInterval time.Duration ) func (helpers.MetricsCtx , fx.Lifecycle , routing.IpfsRouting , simple.KeyChanFunc ) (provider.Reprovider , error ) {
32
+ // SimpleReprovider creates new reprovider
33
+ func SimpleReprovider (reproviderInterval time.Duration ) func (helpers.MetricsCtx , fx.Lifecycle , routing.IpfsRouting , simple.KeyChanFunc ) (provider.Reprovider , error ) {
34
34
return func (mctx helpers.MetricsCtx , lc fx.Lifecycle , rt routing.IpfsRouting , keyProvider simple.KeyChanFunc ) (provider.Reprovider , error ) {
35
35
return simple .NewReprovider (helpers .LifecycleCtx (mctx , lc ), reproviderInterval , rt , keyProvider ), nil
36
36
}
37
37
}
38
38
39
- // SimpleProviderSysCtor creates new provider system
40
- func SimpleProviderSysCtor (lc fx.Lifecycle , p provider.Provider , r provider.Reprovider ) provider.System {
39
+ // SimpleProviderSys creates new provider system
40
+ func SimpleProviderSys (lc fx.Lifecycle , p provider.Provider , r provider.Reprovider ) provider.System {
41
41
sys := provider .NewSystem (p , r )
42
42
lc .Append (fx.Hook {
43
43
OnStart : func (ctx context.Context ) error {
@@ -51,20 +51,20 @@ func SimpleProviderSysCtor(lc fx.Lifecycle, p provider.Provider, r provider.Repr
51
51
return sys
52
52
}
53
53
54
- // SimpleOfflineProviderSysCtor creates a new offline provider system
55
- func SimpleOfflineProviderSysCtor (p provider.Provider , r provider.Reprovider ) provider.System {
54
+ // SimpleOfflineProviderSys creates a new offline provider system
55
+ func SimpleOfflineProviderSys (p provider.Provider , r provider.Reprovider ) provider.System {
56
56
return provider .NewSystem (p , r )
57
57
}
58
58
59
59
// STRATEGIC
60
60
61
- // StrategicProviderSysCtor creates new provider system
62
- func StrategicProviderSysCtor () provider.System {
61
+ // StrategicProviderSys creates new provider system
62
+ func StrategicProviderSys () provider.System {
63
63
return provider .NewOfflineProvider ()
64
64
}
65
65
66
- // StrategicOfflineProviderSysCtor creates a new offline provider system
67
- func StrategicOfflineProviderSysCtor () provider.System {
66
+ // StrategicOfflineProviderSys creates a new offline provider system
67
+ func StrategicOfflineProviderSys () provider.System {
68
68
return provider .NewOfflineProvider ()
69
69
}
70
70
@@ -73,24 +73,24 @@ func StrategicOfflineProviderSysCtor() provider.System {
73
73
// OnlineProviders groups units managing provider routing records online
74
74
func OnlineProviders (useStrategicProviding bool , reprovideStrategy string , reprovideInterval string ) fx.Option {
75
75
if useStrategicProviding {
76
- return fx .Provide (StrategicProviderSysCtor )
76
+ return fx .Provide (StrategicProviderSys )
77
77
}
78
78
79
79
return fx .Options (
80
80
SimpleProviders (reprovideStrategy , reprovideInterval ),
81
- fx .Provide (SimpleProviderSysCtor ),
81
+ fx .Provide (SimpleProviderSys ),
82
82
)
83
83
}
84
84
85
85
// OfflineProviders groups units managing provider routing records offline
86
86
func OfflineProviders (useStrategicProviding bool , reprovideStrategy string , reprovideInterval string ) fx.Option {
87
87
if useStrategicProviding {
88
- return fx .Provide (StrategicOfflineProviderSysCtor )
88
+ return fx .Provide (StrategicOfflineProviderSys )
89
89
}
90
90
91
91
return fx .Options (
92
92
SimpleProviders (reprovideStrategy , reprovideInterval ),
93
- fx .Provide (SimpleOfflineProviderSysCtor ),
93
+ fx .Provide (SimpleOfflineProviderSys ),
94
94
)
95
95
}
96
96
@@ -122,8 +122,8 @@ func SimpleProviders(reprovideStrategy string, reprovideInterval string) fx.Opti
122
122
123
123
return fx .Options (
124
124
fx .Provide (ProviderQueue ),
125
- fx .Provide (SimpleProviderCtor ),
125
+ fx .Provide (SimpleProvider ),
126
126
keyProvider ,
127
- fx .Provide (SimpleReproviderCtor (reproviderInterval )),
127
+ fx .Provide (SimpleReprovider (reproviderInterval )),
128
128
)
129
129
}
0 commit comments