/
dao.go
59 lines (51 loc) · 1.4 KB
/
dao.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
package dao
import (
"fmt"
"time"
log "github.com/cihub/seelog"
"github.com/HailoOSS/login-service/domain"
"github.com/HailoOSS/service/cassandra/timeseries"
"github.com/HailoOSS/gossie/src/gossie"
)
const (
Keyspace = "login"
cfSessions = "sessions"
cfUsers = "users"
cfEndpointAuths = "endpointAuths"
cfUserIndex = "usersIndex"
cfUserIndexIndex = "usersIndexIndex"
cfUserSessions = "userSessions"
defaultType = gossie.UTF8Type
separator = "§"
)
var (
sessionMapping gossie.Mapping
userMapping gossie.Mapping
userTs *timeseries.TimeSeries
Cfs []string = []string{cfSessions, cfUsers, cfEndpointAuths, cfUserIndex, cfUserIndexIndex}
)
func init() {
var err error
sessionMapping, err = gossie.NewMapping(&storedSession{})
if err != nil {
log.Flush()
panic(fmt.Sprintf("Invalid mapping - unexpected error: %v", err))
}
userMapping, err = gossie.NewMapping(&storedUser{})
if err != nil {
log.Flush()
panic(fmt.Sprintf("Invalid mapping - unexpected error: %v", err))
}
userTs = ×eries.TimeSeries{
Ks: Keyspace,
Cf: cfUserIndex,
RowGranularity: time.Hour,
Marshaler: func(i interface{}) (uid string, t time.Time) {
return i.(*domain.User).Uid, i.(*domain.User).Created
},
SecondaryIndexer: func(i interface{}) (index string) {
return string(i.(*domain.User).App)
},
IndexCf: cfUserIndexIndex,
}
}