本文整理汇总了Golang中github.com/concourse/atc/db.PipelineDBFactory类的典型用法代码示例。如果您正苦于以下问题:Golang PipelineDBFactory类的具体用法?Golang PipelineDBFactory怎么用?Golang PipelineDBFactory使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了PipelineDBFactory类的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: NewHandler
func NewHandler(
logger lager.Logger,
pipelineDBFactory db.PipelineDBFactory,
pipelineHandler func(db.PipelineDB) http.Handler,
template *template.Template,
) http.Handler {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
pipelineDB, err := pipelineDBFactory.BuildDefault()
if err != nil {
if err == db.ErrNoPipelines {
err = template.Execute(w, TemplateData{})
if err != nil {
log.Fatal("failed-to-task-template", err, lager.Data{})
}
return
}
logger.Error("failed-to-load-pipelinedb", err)
w.WriteHeader(http.StatusInternalServerError)
return
}
pipelineHandler(pipelineDB).ServeHTTP(w, r)
})
}
开发者ID:utako,项目名称:atc,代码行数:25,代码来源:handler.go
示例2: NewHandler
func NewHandler(
logger lager.Logger,
pipelineDBFactory db.PipelineDBFactory,
pipelineHandler http.Handler,
template *template.Template,
) http.Handler {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
log := logger.Session("index")
pipelineDB, found, err := pipelineDBFactory.BuildDefault()
if err != nil {
log.Error("failed-to-load-pipelinedb", err)
w.WriteHeader(http.StatusInternalServerError)
return
}
if !found {
err = template.Execute(w, TemplateData{})
if err != nil {
log.Fatal("failed-to-build-template", err, lager.Data{})
}
return
}
if r.Form == nil {
r.Form = url.Values{}
}
r.Form[":pipeline"] = []string{pipelineDB.GetPipelineName()}
pipelineHandler.ServeHTTP(w, r)
})
}
开发者ID:ACPK,项目名称:atc,代码行数:34,代码来源:handler.go
示例3:
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
. "github.com/sclevine/agouti/matchers"
"github.com/cloudfoundry/gunk/urljoiner"
"github.com/concourse/atc"
"github.com/concourse/atc/db"
"github.com/concourse/atc/event"
)
var _ = Describe("One-off Builds", func() {
var atcProcess ifrit.Process
var dbListener *pq.Listener
var atcPort uint16
var pipelineDBFactory db.PipelineDBFactory
BeforeEach(func() {
dbLogger := lagertest.NewTestLogger("test")
postgresRunner.Truncate()
dbConn = postgresRunner.Open()
dbListener = pq.NewListener(postgresRunner.DataSourceName(), time.Second, time.Minute, nil)
bus := db.NewNotificationsBus(dbListener, dbConn)
sqlDB = db.NewSQL(dbLogger, dbConn, bus)
pipelineDBFactory = db.NewPipelineDBFactory(dbLogger, dbConn, bus, sqlDB)
atcProcess, atcPort = startATC(atcBin, 1)
})
AfterEach(func() {
ginkgomon.Interrupt(atcProcess)
开发者ID:ACPK,项目名称:atc,代码行数:30,代码来源:builds_list_test.go
示例4:
"time"
"github.com/concourse/atc/db"
"github.com/concourse/atc/db/fakes"
"github.com/lib/pq"
"github.com/pivotal-golang/lager/lagertest"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
)
var _ = Describe("PipelineDBFactory", func() {
var dbConn db.Conn
var listener *pq.Listener
var pipelineDBFactory db.PipelineDBFactory
var pipelinesDB *fakes.FakePipelinesDB
BeforeEach(func() {
postgresRunner.Truncate()
dbConn = db.Wrap(postgresRunner.Open())
listener = pq.NewListener(postgresRunner.DataSourceName(), time.Second, time.Minute, nil)
Eventually(listener.Ping, 5*time.Second).ShouldNot(HaveOccurred())
bus := db.NewNotificationsBus(listener, dbConn)
pipelinesDB = new(fakes.FakePipelinesDB)
pipelineDBFactory = db.NewPipelineDBFactory(lagertest.NewTestLogger("test"), dbConn, bus, pipelinesDB)
开发者ID:pcfdev-forks,项目名称:atc,代码行数:31,代码来源:pipeline_db_factory_test.go
示例5:
"github.com/tedsuo/ifrit/ginkgomon"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
. "github.com/sclevine/agouti/matchers"
"github.com/cloudfoundry/gunk/urljoiner"
"github.com/concourse/atc"
"github.com/concourse/atc/db"
)
var _ = Describe("Pipeline Pausing", func() {
var atcProcess ifrit.Process
var dbListener *pq.Listener
var atcPort uint16
var pipelineDBFactory db.PipelineDBFactory
BeforeEach(func() {
dbLogger := lagertest.NewTestLogger("test")
postgresRunner.Truncate()
dbConn = db.Wrap(postgresRunner.Open())
dbListener = pq.NewListener(postgresRunner.DataSourceName(), time.Second, time.Minute, nil)
bus := db.NewNotificationsBus(dbListener, dbConn)
sqlDB = db.NewSQL(dbLogger, dbConn, bus)
pipelineDBFactory = db.NewPipelineDBFactory(dbLogger, dbConn, bus, sqlDB)
atcProcess, atcPort = startATC(atcBin, 1, true, BASIC_AUTH)
err := sqlDB.DeleteTeamByName(atc.DefaultTeamName)
Expect(err).NotTo(HaveOccurred())
})
AfterEach(func() {
开发者ID:pcfdev-forks,项目名称:atc,代码行数:31,代码来源:pipeline_pausing_test.go
示例6:
"time"
"github.com/concourse/atc"
"github.com/concourse/atc/db"
"github.com/lib/pq"
"github.com/pivotal-golang/lager/lagertest"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
)
var _ = Describe("Resource History", func() {
var dbConn *sql.DB
var listener *pq.Listener
var pipelineDBFactory db.PipelineDBFactory
var sqlDB *db.SQLDB
var pipelineDB db.PipelineDB
var otherPipelineDB db.PipelineDB
BeforeEach(func() {
postgresRunner.Truncate()
dbConn = postgresRunner.Open()
listener = pq.NewListener(postgresRunner.DataSourceName(), time.Second, time.Minute, nil)
Eventually(listener.Ping, 5*time.Second).ShouldNot(HaveOccurred())
bus := db.NewNotificationsBus(listener, dbConn)
sqlDB = db.NewSQL(lagertest.NewTestLogger("test"), dbConn, bus)
pipelineDBFactory = db.NewPipelineDBFactory(lagertest.NewTestLogger("test"), dbConn, bus, sqlDB)
开发者ID:ACPK,项目名称:atc,代码行数:31,代码来源:pipeline_db_resource_versions_test.go
示例7:
"github.com/lib/pq"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
"github.com/pivotal-golang/lager/lagertest"
"github.com/concourse/atc"
"github.com/concourse/atc/db"
)
var _ = Describe("SQL DB", func() {
var dbConn *sql.DB
var listener *pq.Listener
var sqlDB *db.SQLDB
var pipelineDB db.PipelineDB
var pipelineDBFactory db.PipelineDBFactory
var dbSharedBehaviorInput = dbSharedBehaviorInput{}
BeforeEach(func() {
var err error
postgresRunner.Truncate()
dbConn = postgresRunner.Open()
listener = pq.NewListener(postgresRunner.DataSourceName(), time.Second, time.Minute, nil)
Eventually(listener.Ping, 5*time.Second).ShouldNot(HaveOccurred())
bus := db.NewNotificationsBus(listener, dbConn)
sqlDB = db.NewSQL(lagertest.NewTestLogger("test"), dbConn, bus)
开发者ID:ACPK,项目名称:atc,代码行数:30,代码来源:sqldb_test.go
示例8:
"time"
"github.com/concourse/atc"
"github.com/concourse/atc/db"
"github.com/lib/pq"
"github.com/pivotal-golang/lager/lagertest"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
)
var _ = Describe("Resource History", func() {
var dbConn db.Conn
var listener *pq.Listener
var pipelineDBFactory db.PipelineDBFactory
var sqlDB *db.SQLDB
var pipelineDB db.PipelineDB
BeforeEach(func() {
postgresRunner.Truncate()
dbConn = db.Wrap(postgresRunner.Open())
listener = pq.NewListener(postgresRunner.DataSourceName(), time.Second, time.Minute, nil)
Eventually(listener.Ping, 5*time.Second).ShouldNot(HaveOccurred())
bus := db.NewNotificationsBus(listener, dbConn)
sqlDB = db.NewSQL(lagertest.NewTestLogger("test"), dbConn, bus)
pipelineDBFactory = db.NewPipelineDBFactory(lagertest.NewTestLogger("test"), dbConn, bus, sqlDB)
开发者ID:pcfdev-forks,项目名称:atc,代码行数:30,代码来源:pipeline_db_resource_versions_test.go
示例9:
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
. "github.com/sclevine/agouti/matchers"
"github.com/cloudfoundry/gunk/urljoiner"
"github.com/concourse/atc"
"github.com/concourse/atc/db"
"github.com/concourse/atc/event"
)
var _ = Describe("Job Pausing", func() {
var atcProcess ifrit.Process
var dbListener *pq.Listener
var atcPort uint16
var pipelineDBFactory db.PipelineDBFactory
var pipelineDB db.PipelineDB
BeforeEach(func() {
dbLogger := lagertest.NewTestLogger("test")
postgresRunner.Truncate()
dbConn = db.Wrap(postgresRunner.Open())
dbListener = pq.NewListener(postgresRunner.DataSourceName(), time.Second, time.Minute, nil)
bus := db.NewNotificationsBus(dbListener, dbConn)
sqlDB = db.NewSQL(dbLogger, dbConn, bus)
pipelineDBFactory = db.NewPipelineDBFactory(dbLogger, dbConn, bus, sqlDB)
atcProcess, atcPort = startATC(atcBin, 1, true, BASIC_AUTH)
_, err := dbConn.Query(`DELETE FROM teams WHERE name = 'main'`)
Expect(err).NotTo(HaveOccurred())
})
开发者ID:pcfdev-forks,项目名称:atc,代码行数:29,代码来源:job_pausing_test.go
示例10:
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
"github.com/onsi/gomega/gexec"
. "github.com/sclevine/agouti/matchers"
"github.com/cloudfoundry/gunk/urljoiner"
"github.com/concourse/atc"
"github.com/concourse/atc/db"
"github.com/concourse/atc/event"
)
var _ = Describe("Resource Pausing", func() {
var atcProcess ifrit.Process
var dbListener *pq.Listener
var atcPort uint16
var pipelineDBFactory db.PipelineDBFactory
BeforeEach(func() {
atcBin, err := gexec.Build("github.com/concourse/atc/cmd/atc")
Ω(err).ShouldNot(HaveOccurred())
dbLogger := lagertest.NewTestLogger("test")
postgresRunner.CreateTestDB()
dbConn = postgresRunner.Open()
dbListener = pq.NewListener(postgresRunner.DataSourceName(), time.Second, time.Minute, nil)
bus := db.NewNotificationsBus(dbListener)
sqlDB = db.NewSQL(dbLogger, dbConn, bus)
pipelineDBFactory = db.NewPipelineDBFactory(dbLogger, dbConn, bus, sqlDB)
atcProcess, atcPort = startATC(atcBin, 1)
})
开发者ID:utako,项目名称:atc,代码行数:31,代码来源:build_abort_test.go
示例11:
"github.com/concourse/atc"
"github.com/concourse/atc/db"
"github.com/lib/pq"
"github.com/pivotal-golang/lager/lagertest"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
)
var _ = Describe("Leases", func() {
var (
dbConn db.Conn
listener *pq.Listener
pipelineDBFactory db.PipelineDBFactory
sqlDB *db.SQLDB
pipelineDB db.PipelineDB
)
BeforeEach(func() {
postgresRunner.Truncate()
dbConn = db.Wrap(postgresRunner.Open())
listener = pq.NewListener(postgresRunner.DataSourceName(), time.Second, time.Minute, nil)
Eventually(listener.Ping, 5*time.Second).ShouldNot(HaveOccurred())
bus := db.NewNotificationsBus(listener, dbConn)
sqlDB = db.NewSQL(lagertest.NewTestLogger("test"), dbConn, bus)
开发者ID:pcfdev-forks,项目名称:atc,代码行数:30,代码来源:lease_test.go
示例12:
"github.com/tedsuo/ifrit/ginkgomon"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
"github.com/onsi/gomega/gexec"
. "github.com/sclevine/agouti/matchers"
"github.com/cloudfoundry/gunk/urljoiner"
"github.com/concourse/atc"
"github.com/concourse/atc/db"
)
var _ = Describe("Resource Pagination", func() {
var atcProcess ifrit.Process
var dbListener *pq.Listener
var pipelineDBFactory db.PipelineDBFactory
var atcPort uint16
BeforeEach(func() {
atcBin, err := gexec.Build("github.com/concourse/atc/cmd/atc")
Ω(err).ShouldNot(HaveOccurred())
dbLogger := lagertest.NewTestLogger("test")
postgresRunner.CreateTestDB()
dbConn = postgresRunner.Open()
dbListener = pq.NewListener(postgresRunner.DataSourceName(), time.Second, time.Minute, nil)
bus := db.NewNotificationsBus(dbListener)
sqlDB = db.NewSQL(dbLogger, dbConn, bus)
Ω(err).ShouldNot(HaveOccurred())
开发者ID:utako,项目名称:atc,代码行数:30,代码来源:resource_pagination_test.go
示例13:
"github.com/tedsuo/ifrit/ginkgomon"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
. "github.com/sclevine/agouti/matchers"
"github.com/cloudfoundry/gunk/urljoiner"
"github.com/concourse/atc"
"github.com/concourse/atc/db"
)
var _ = Describe("Pipeline Pausing", func() {
var atcProcess ifrit.Process
var dbListener *pq.Listener
var atcPort uint16
var pipelineDBFactory db.PipelineDBFactory
BeforeEach(func() {
dbLogger := lagertest.NewTestLogger("test")
postgresRunner.Truncate()
dbConn = postgresRunner.Open()
dbListener = pq.NewListener(postgresRunner.DataSourceName(), time.Second, time.Minute, nil)
bus := db.NewNotificationsBus(dbListener, dbConn)
sqlDB = db.NewSQL(dbLogger, dbConn, bus)
pipelineDBFactory = db.NewPipelineDBFactory(dbLogger, dbConn, bus, sqlDB)
atcProcess, atcPort = startATC(atcBin, 1)
})
AfterEach(func() {
ginkgomon.Interrupt(atcProcess)
开发者ID:ACPK,项目名称:atc,代码行数:30,代码来源:pipeline_pausing_test.go
示例14:
"github.com/lib/pq"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
"github.com/pivotal-golang/lager/lagertest"
"github.com/concourse/atc"
"github.com/concourse/atc/db"
)
var _ = Describe("Keeping track of pipeline configs", func() {
var dbConn db.Conn
var listener *pq.Listener
var database *db.SQLDB
var pipelineDBFactory db.PipelineDBFactory
var team db.SavedTeam
var config atc.Config
var otherConfig atc.Config
BeforeEach(func() {
postgresRunner.Truncate()
dbConn = db.Wrap(postgresRunner.Open())
listener = pq.NewListener(postgresRunner.DataSourceName(), time.Second, time.Minute, nil)
Eventually(listener.Ping, 5*time.Second).ShouldNot(HaveOccurred())
bus := db.NewNotificationsBus(listener, dbConn)
开发者ID:pcfdev-forks,项目名称:atc,代码行数:29,代码来源:db_config_test.go
注:本文中的github.com/concourse/atc/db.PipelineDBFactory类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论