forked from zitadel/zitadel
-
Notifications
You must be signed in to change notification settings - Fork 0
/
view.go
38 lines (32 loc) · 923 Bytes
/
view.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
package view
import (
"database/sql"
"github.com/jinzhu/gorm"
"github.com/dennigogo/zitadel/internal/crypto"
eventstore "github.com/dennigogo/zitadel/internal/eventstore/v1"
"github.com/dennigogo/zitadel/internal/id"
"github.com/dennigogo/zitadel/internal/query"
)
type View struct {
Db *gorm.DB
keyAlgorithm crypto.EncryptionAlgorithm
idGenerator id.Generator
query *query.Queries
es eventstore.Eventstore
}
func StartView(sqlClient *sql.DB, keyAlgorithm crypto.EncryptionAlgorithm, queries *query.Queries, idGenerator id.Generator, es eventstore.Eventstore) (*View, error) {
gorm, err := gorm.Open("postgres", sqlClient)
if err != nil {
return nil, err
}
return &View{
Db: gorm,
keyAlgorithm: keyAlgorithm,
idGenerator: idGenerator,
query: queries,
es: es,
}, nil
}
func (v *View) Health() (err error) {
return v.Db.DB().Ping()
}