-
Notifications
You must be signed in to change notification settings - Fork 1
/
main.go
74 lines (64 loc) · 2.26 KB
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
/**
* Copyright (c) 2015 Intel Corporation
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
// Package main application-broker API
//
// The purpose of this application is to easily expose Cloud Foundry applications to marketplace as service offerings
// without implementing separate brokers for each of them.
//
// Version: 0.7.3
//
// swagger:meta
package main
import (
log "github.com/cihub/seelog"
"github.com/cloudfoundry-community/go-cfenv"
"github.com/trustedanalytics/application-broker/broker"
"github.com/trustedanalytics/application-broker/cloud"
"github.com/trustedanalytics/application-broker/dao"
"github.com/trustedanalytics/application-broker/logging"
"github.com/trustedanalytics/application-broker/messagebus"
"github.com/trustedanalytics/application-broker/service"
)
func main() {
var mbus messagebus.MessageBus
var err error
logging.Initialize()
cfEnv, err := cfenv.Current()
if err != nil {
log.Warnf("CF Env vars gathering failed with error [%v]. Running locally, probably.", err)
}
natsConfig := messagebus.Config{}
natsAvailable := natsConfig.TryInitialize(cfEnv)
if natsAvailable {
if mbus, err = messagebus.NewNatsMessageBus(natsConfig); err != nil {
log.Warnf("Failed to initialize NATS. Events information publishing will be skipped. [%v]", err)
mbus = &messagebus.DevNullBus{}
}
} else {
log.Warn("NATS not available. Events information publishing will be skipped.")
mbus = &messagebus.DevNullBus{}
}
db := dao.MongoFactory(cfEnv)
cloud := cloud.NewCloudAPI(cfEnv)
s := service.New(db, cloud, mbus, service.CreationStatusFactory{})
b, err := broker.New(s)
if err != nil {
log.Criticalf("failed to initialize broker: [%v]", err)
}
brokerCfg := broker.Config{}
brokerCfg.Initialize(cfEnv)
b.Start(brokerCfg)
}