mirror/opencloud
1
0
Fork 0
mirror of https://github.com/opencloud-eu/opencloud.git synced 2026-03-04 15:27:17 -05:00
Code Issues Packages Projects Releases Wiki Activity

provide name to anonymous type

Browse Source
This commit is contained in:
A.Unger
2021-06-30 10:37:47 +02:00
parent 4994d0b132
commit ed9359ddd4
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
ocis/pkg/runtime/service/service.go
View File

@@ -43,11 +43,13 @@ var (
runset []string
)
type serviceFuncMap map[string]func(*ociscfg.Config) suture.Service
// Service represents a RPC service.
type Service struct {
Supervisor *suture.Supervisor
ServicesRegistry map[string]func(*ociscfg.Config) suture.Service
Delayed map[string]func(*ociscfg.Config) suture.Service
ServicesRegistry serviceFuncMap
Delayed serviceFuncMap
Log log.Logger
serviceToken map[string][]suture.ServiceToken
@@ -77,8 +79,8 @@ func NewService(options ...Option) (*Service, error) {
globalCtx, cancelGlobal := context.WithCancel(context.Background())
s := &Service{
ServicesRegistry: make(map[string]func(*ociscfg.Config) suture.Service),
Delayed: make(map[string]func(*ociscfg.Config) suture.Service),
ServicesRegistry: make(serviceFuncMap),
Delayed: make(serviceFuncMap),
Log: l,
serviceToken: make(map[string][]suture.ServiceToken),
@@ -210,7 +212,7 @@ func Start(o ...Option) error {
}
// scheduleServiceTokens adds service tokens to the service supervisor.
func scheduleServiceTokens(s *Service, funcSet map[string]func(*ociscfg.Config) suture.Service) {
func scheduleServiceTokens(s *Service, funcSet serviceFuncMap) {
for _, name := range runset {
if _, ok := funcSet[name]; !ok {
continue