datastore

package

Go to main page

Versions in this module

v0

v0.9.1

Sep 27, 2017

v0.9.0

Sep 22, 2017

Changes in this version

+ func RdbStoreInstance() *rdbStore

v0.8.7

Sep 20, 2017

v0.8.6

Aug 24, 2017

v0.8.5

Aug 24, 2017

v0.8.4

Aug 23, 2017

v0.8.3

Aug 8, 2017

v0.8.2

Aug 3, 2017

v0.8.1

Jul 26, 2017

v0.8.0

Jul 23, 2017

Changes in this version

type GcpSqlProvider

+ func (provider GcpSqlProvider) SelectRoomUserOfOneOnOne(myUserId, opponentUserId string) StoreResult

type MysqlProvider

+ func (provider MysqlProvider) SelectRoomUserOfOneOnOne(myUserId, opponentUserId string) StoreResult

type RoomUserStore

+ SelectRoomUserOfOneOnOne func(myUserId, opponentUserId string) StoreResult

type SqliteProvider

+ func (provider SqliteProvider) SelectRoomUserOfOneOnOne(myUserId, opponentUserId string) StoreResult

type StoreResult

+ func RdbSelectRoomUserOfOneOnOne(myUserId, opponentUserId string) StoreResult

v0.7.1

Jul 20, 2017

Changes in this version

type DeviceStore

+ SelectDevicesByToken func(token string) StoreResult

type GcpSqlProvider

+ func (provider GcpSqlProvider) SelectDeletedSubscriptionsByRoomId(roomId string) StoreResult

+ func (provider GcpSqlProvider) SelectDeletedSubscriptionsByUserId(userId string) StoreResult

+ func (provider GcpSqlProvider) SelectDeletedSubscriptionsByUserIdAndPlatform(userId string, platform int) StoreResult

+ func (provider GcpSqlProvider) SelectDevicesByToken(token string) StoreResult

type MysqlProvider

+ func (provider MysqlProvider) SelectDeletedSubscriptionsByRoomId(roomId string) StoreResult

+ func (provider MysqlProvider) SelectDeletedSubscriptionsByUserId(userId string) StoreResult

+ func (provider MysqlProvider) SelectDeletedSubscriptionsByUserIdAndPlatform(userId string, platform int) StoreResult

+ func (provider MysqlProvider) SelectDevicesByToken(token string) StoreResult

type SqliteProvider

+ func (provider SqliteProvider) SelectDeletedSubscriptionsByRoomId(roomId string) StoreResult

+ func (provider SqliteProvider) SelectDeletedSubscriptionsByUserId(userId string) StoreResult

+ func (provider SqliteProvider) SelectDeletedSubscriptionsByUserIdAndPlatform(userId string, platform int) StoreResult

+ func (provider SqliteProvider) SelectDevicesByToken(token string) StoreResult

type StoreResult

+ func RdbSelectDeletedSubscriptionsByRoomId(roomId string) StoreResult

+ func RdbSelectDeletedSubscriptionsByUserId(userId string) StoreResult

+ func RdbSelectDeletedSubscriptionsByUserIdAndPlatform(userId string, platform int) StoreResult

+ func RdbSelectDevicesByToken(token string) StoreResult

type SubscriptionStore

+ SelectDeletedSubscriptionsByRoomId func(roomId string) StoreResult

+ SelectDeletedSubscriptionsByUserId func(userId string) StoreResult

+ SelectDeletedSubscriptionsByUserIdAndPlatform func(userId string, platform int) StoreResult

v0.7.0

Jun 30, 2017

Changes in this version

+ var TABLE_NAME_BLOCK_USER = utils.Cfg.Datastore.TableNamePrefix + "block_user"

+ func RdbCreateBlockUserStore()

+ type BlockUserStore interface

+ CreateBlockUserStore func()

+ DeleteBlockUser func(userId string, blockUserIds []string) StoreResult

+ InsertBlockUsers func(blockUsers []*models.BlockUser) StoreResult

+ SelectBlockUser func(userId, blockUserId string) StoreResult

+ SelectBlockUsersByUserId func(userId string) StoreResult

type GcpSqlProvider

+ func (provider GcpSqlProvider) CreateBlockUserStore()

+ func (provider GcpSqlProvider) DeleteBlockUser(userId string, blockUserIds []string) StoreResult

+ func (provider GcpSqlProvider) InsertBlockUsers(blockUsers []*models.BlockUser) StoreResult

+ func (provider GcpSqlProvider) SelectBlockUser(userId, blockUserId string) StoreResult

+ func (provider GcpSqlProvider) SelectBlockUsersByUserId(userId string) StoreResult

+ func (provider GcpSqlProvider) SelectContacts(userId string) StoreResult

type MysqlProvider

+ func (provider MysqlProvider) CreateBlockUserStore()

+ func (provider MysqlProvider) DeleteBlockUser(userId string, blockUserIds []string) StoreResult

+ func (provider MysqlProvider) InsertBlockUsers(blockUsers []*models.BlockUser) StoreResult

+ func (provider MysqlProvider) SelectBlockUser(userId, blockUserId string) StoreResult

+ func (provider MysqlProvider) SelectBlockUsersByUserId(userId string) StoreResult

+ func (provider MysqlProvider) SelectContacts(userId string) StoreResult

type SqliteProvider

+ func (provider SqliteProvider) CreateBlockUserStore()

+ func (provider SqliteProvider) DeleteBlockUser(userId string, blockUserIds []string) StoreResult

+ func (provider SqliteProvider) InsertBlockUsers(blockUsers []*models.BlockUser) StoreResult

+ func (provider SqliteProvider) SelectBlockUser(userId, blockUserId string) StoreResult

+ func (provider SqliteProvider) SelectBlockUsersByUserId(userId string) StoreResult

+ func (provider SqliteProvider) SelectContacts(userId string) StoreResult

type StoreResult

+ func RdbDeleteBlockUser(userId string, blockUserIds []string) StoreResult

+ func RdbInsertBlockUsers(blockUsers []*models.BlockUser) StoreResult

+ func RdbSelectBlockUser(userId, blockUserId string) StoreResult

+ func RdbSelectBlockUsersByUserId(userId string) StoreResult

+ func RdbSelectContacts(userId string) StoreResult

type UserStore

+ SelectContacts func(userId string) StoreResult

v0.6.0

Jun 5, 2017

Changes in this version

+ var TABLE_NAME_API = utils.Cfg.Datastore.TableNamePrefix + "api"

+ func RdbCreateApiStore()

+ type ApiStore interface

+ CreateApiStore func()

+ InsertApi func(name string) StoreResult

+ SelectLatestApi func(name string) StoreResult

type GcpSqlProvider

+ func (provider GcpSqlProvider) CreateApiStore()

+ func (provider GcpSqlProvider) InsertApi(name string) StoreResult

+ func (provider GcpSqlProvider) SelectLatestApi(name string) StoreResult

type MysqlProvider

+ func (provider MysqlProvider) CreateApiStore()

+ func (provider MysqlProvider) InsertApi(name string) StoreResult

+ func (provider MysqlProvider) SelectLatestApi(name string) StoreResult

type SqliteProvider

+ func (provider SqliteProvider) CreateApiStore()

+ func (provider SqliteProvider) InsertApi(name string) StoreResult

+ func (provider SqliteProvider) SelectLatestApi(name string) StoreResult

type StoreResult

+ func RdbInsertApi(name string) StoreResult

+ func RdbSelectLatestApi(name string) StoreResult

v0.5.0

May 13, 2017

Changes in this version

+ var TABLE_NAME_ADMIN = utils.Cfg.Datastore.TableNamePrefix + "admin"

+ func RdbCreateAdminStore()

+ type AdminStore interface

+ CreateAdminStore func()

+ InsertAdmin func() StoreResult

+ SelectLatestAdmin func() StoreResult

type GcpSqlProvider

+ func (provider GcpSqlProvider) CreateAdminStore()

+ func (provider GcpSqlProvider) InsertAdmin() StoreResult

+ func (provider GcpSqlProvider) SelectLatestAdmin() StoreResult

+ func (provider GcpSqlProvider) SelectUserByUserIdAndAccessToken(userId, accessToken string) StoreResult

type MysqlProvider

+ func (provider MysqlProvider) CreateAdminStore()

+ func (provider MysqlProvider) InsertAdmin() StoreResult

+ func (provider MysqlProvider) SelectLatestAdmin() StoreResult

+ func (provider MysqlProvider) SelectUserByUserIdAndAccessToken(userId, accessToken string) StoreResult

type SqliteProvider

+ func (provider SqliteProvider) CreateAdminStore()

+ func (provider SqliteProvider) InsertAdmin() StoreResult

+ func (provider SqliteProvider) SelectLatestAdmin() StoreResult

+ func (provider SqliteProvider) SelectUserByUserIdAndAccessToken(userId, accessToken string) StoreResult

type StoreResult

+ func RdbInsertAdmin() StoreResult

+ func RdbSelectLatestAdmin() StoreResult

+ func RdbSelectUserByUserIdAndAccessToken(userId, accessToken string) StoreResult

type UserStore

+ SelectUserByUserIdAndAccessToken func(userId, accessToken string) StoreResult

v0.4.0

May 5, 2017

v0.3.2

May 1, 2017

v0.3.1

Apr 27, 2017

v0.3.0

Apr 27, 2017

v0.2.0

Apr 24, 2017

Changes in this version

+ const TABLE_NAME_DEVICE

+ const TABLE_NAME_SUBSCRIPTION

+ func RdbCreateDeviceStore()

+ func RdbCreateRoomStore()

+ func RdbCreateRoomUserStore()

+ func RdbCreateSubscriptionStore()

+ func RdbCreateUserStore()

+ type DeviceStore interface

+ CreateDeviceStore func()

+ DeleteDevice func(userId string, platform int) StoreResult

+ InsertDevice func(device *models.Device) StoreResult

+ SelectDevice func(userId string, platform int) StoreResult

+ SelectDevices func() StoreResult

+ SelectDevicesByUserId func(userId string) StoreResult

+ UpdateDevice func(device *models.Device) StoreResult

type GcpSqlProvider

+ func (provider GcpSqlProvider) CreateDeviceStore()

+ func (provider GcpSqlProvider) CreateMessageStore()

+ func (provider GcpSqlProvider) CreateRoomStore()

+ func (provider GcpSqlProvider) CreateRoomUserStore()

+ func (provider GcpSqlProvider) CreateSubscriptionStore()

+ func (provider GcpSqlProvider) CreateUserStore()

+ func (provider GcpSqlProvider) DeleteAndInsertRoomUsers(roomUsers []*models.RoomUser) StoreResult

+ func (provider GcpSqlProvider) DeleteDevice(userId string, platform int) StoreResult

+ func (provider GcpSqlProvider) DeleteRoomUser(roomId string, userIds []string) StoreResult

+ func (provider GcpSqlProvider) DeleteSubscription(subscription *models.Subscription) StoreResult

+ func (provider GcpSqlProvider) InsertDevice(device *models.Device) StoreResult

+ func (provider GcpSqlProvider) InsertMessage(message *models.Message) StoreResult

+ func (provider GcpSqlProvider) InsertRoom(room *models.Room) StoreResult

+ func (provider GcpSqlProvider) InsertRoomUsers(roomUsers []*models.RoomUser) StoreResult

+ func (provider GcpSqlProvider) InsertSubscription(room *models.Subscription) StoreResult

+ func (provider GcpSqlProvider) InsertUser(user *models.User) StoreResult

+ func (provider GcpSqlProvider) SelectCountMessagesByRoomId(roomId string) StoreResult

+ func (provider GcpSqlProvider) SelectCountRooms() StoreResult

+ func (provider GcpSqlProvider) SelectDevice(userId string, platform int) StoreResult

+ func (provider GcpSqlProvider) SelectDevices() StoreResult

+ func (provider GcpSqlProvider) SelectDevicesByUserId(userId string) StoreResult

+ func (provider GcpSqlProvider) SelectMessage(messageId string) StoreResult

+ func (provider GcpSqlProvider) SelectMessages(roomId string, limit, offset int) StoreResult

+ func (provider GcpSqlProvider) SelectRoom(roomId string) StoreResult

+ func (provider GcpSqlProvider) SelectRoomUser(roomId, userId string) StoreResult

+ func (provider GcpSqlProvider) SelectRoomUsersByRoomId(roomId string) StoreResult

+ func (provider GcpSqlProvider) SelectRoomUsersByRoomIdAndUserIds(roomId *string, userIds []string) StoreResult

+ func (provider GcpSqlProvider) SelectRoomUsersByUserId(userId string) StoreResult

+ func (provider GcpSqlProvider) SelectRooms() StoreResult

+ func (provider GcpSqlProvider) SelectRoomsForUser(userId string) StoreResult

+ func (provider GcpSqlProvider) SelectSubscription(roomId, userId string, platform int) StoreResult

+ func (provider GcpSqlProvider) SelectSubscriptionsByRoomId(roomId string) StoreResult

+ func (provider GcpSqlProvider) SelectSubscriptionsByRoomIdAndPlatform(roomId string, platform int) StoreResult

+ func (provider GcpSqlProvider) SelectSubscriptionsByUserId(userId string) StoreResult

+ func (provider GcpSqlProvider) SelectSubscriptionsByUserIdAndPlatform(userId string, platform int) StoreResult

+ func (provider GcpSqlProvider) SelectUser(userId string, isWithRooms, isWithDevices bool) StoreResult

+ func (provider GcpSqlProvider) SelectUserIdsByUserIds(userIds []string) StoreResult

+ func (provider GcpSqlProvider) SelectUsers() StoreResult

+ func (provider GcpSqlProvider) SelectUsersForRoom(roomId string) StoreResult

+ func (provider GcpSqlProvider) UpdateDevice(device *models.Device) StoreResult

+ func (provider GcpSqlProvider) UpdateMessage(message *models.Message) StoreResult

+ func (provider GcpSqlProvider) UpdateRoom(room *models.Room) StoreResult

+ func (provider GcpSqlProvider) UpdateRoomDeleted(roomId string) StoreResult

+ func (provider GcpSqlProvider) UpdateRoomUser(roomUser *models.RoomUser) StoreResult

+ func (provider GcpSqlProvider) UpdateUser(user *models.User) StoreResult

+ func (provider GcpSqlProvider) UpdateUserDeleted(userId string) StoreResult

type MessageStore

+ CreateMessageStore func()

+ InsertMessage func(message *models.Message) StoreResult

+ SelectCountMessagesByRoomId func(roomId string) StoreResult

+ SelectMessage func(messageId string) StoreResult

+ SelectMessages func(roomId string, limit, offset int) StoreResult

+ UpdateMessage func(message *models.Message) StoreResult

type MysqlProvider

+ func (provider MysqlProvider) CreateDeviceStore()

+ func (provider MysqlProvider) CreateMessageStore()

+ func (provider MysqlProvider) CreateRoomStore()

+ func (provider MysqlProvider) CreateRoomUserStore()

+ func (provider MysqlProvider) CreateSubscriptionStore()

+ func (provider MysqlProvider) CreateUserStore()

+ func (provider MysqlProvider) DeleteAndInsertRoomUsers(roomUsers []*models.RoomUser) StoreResult

+ func (provider MysqlProvider) DeleteDevice(userId string, platform int) StoreResult

+ func (provider MysqlProvider) DeleteRoomUser(roomId string, userIds []string) StoreResult

+ func (provider MysqlProvider) DeleteSubscription(subscription *models.Subscription) StoreResult

+ func (provider MysqlProvider) InsertDevice(device *models.Device) StoreResult

+ func (provider MysqlProvider) InsertMessage(message *models.Message) StoreResult

+ func (provider MysqlProvider) InsertRoom(room *models.Room) StoreResult

+ func (provider MysqlProvider) InsertRoomUsers(roomUsers []*models.RoomUser) StoreResult

+ func (provider MysqlProvider) InsertSubscription(room *models.Subscription) StoreResult

+ func (provider MysqlProvider) InsertUser(user *models.User) StoreResult

+ func (provider MysqlProvider) SelectCountMessagesByRoomId(roomId string) StoreResult

+ func (provider MysqlProvider) SelectCountRooms() StoreResult

+ func (provider MysqlProvider) SelectDevice(userId string, platform int) StoreResult

+ func (provider MysqlProvider) SelectDevices() StoreResult

+ func (provider MysqlProvider) SelectDevicesByUserId(userId string) StoreResult

+ func (provider MysqlProvider) SelectMessage(messageId string) StoreResult

+ func (provider MysqlProvider) SelectMessages(roomId string, limit, offset int) StoreResult

+ func (provider MysqlProvider) SelectRoom(roomId string) StoreResult

+ func (provider MysqlProvider) SelectRoomUser(roomId, userId string) StoreResult

+ func (provider MysqlProvider) SelectRoomUsersByRoomId(roomId string) StoreResult

+ func (provider MysqlProvider) SelectRoomUsersByRoomIdAndUserIds(roomId *string, userIds []string) StoreResult

+ func (provider MysqlProvider) SelectRoomUsersByUserId(userId string) StoreResult

+ func (provider MysqlProvider) SelectRooms() StoreResult

+ func (provider MysqlProvider) SelectRoomsForUser(userId string) StoreResult

+ func (provider MysqlProvider) SelectSubscription(roomId, userId string, platform int) StoreResult

+ func (provider MysqlProvider) SelectSubscriptionsByRoomId(roomId string) StoreResult

+ func (provider MysqlProvider) SelectSubscriptionsByRoomIdAndPlatform(roomId string, platform int) StoreResult

+ func (provider MysqlProvider) SelectSubscriptionsByUserId(userId string) StoreResult

+ func (provider MysqlProvider) SelectSubscriptionsByUserIdAndPlatform(userId string, platform int) StoreResult

+ func (provider MysqlProvider) SelectUser(userId string, isWithRooms, isWithDevices bool) StoreResult

+ func (provider MysqlProvider) SelectUserIdsByUserIds(userIds []string) StoreResult

+ func (provider MysqlProvider) SelectUsers() StoreResult

+ func (provider MysqlProvider) SelectUsersForRoom(roomId string) StoreResult

+ func (provider MysqlProvider) UpdateDevice(device *models.Device) StoreResult

+ func (provider MysqlProvider) UpdateMessage(message *models.Message) StoreResult

+ func (provider MysqlProvider) UpdateRoom(room *models.Room) StoreResult

+ func (provider MysqlProvider) UpdateRoomDeleted(roomId string) StoreResult

+ func (provider MysqlProvider) UpdateRoomUser(roomUser *models.RoomUser) StoreResult

+ func (provider MysqlProvider) UpdateUser(user *models.User) StoreResult

+ func (provider MysqlProvider) UpdateUserDeleted(userId string) StoreResult

type RoomStore

+ CreateRoomStore func()

+ InsertRoom func(room *models.Room) StoreResult

+ SelectCountRooms func() StoreResult

+ SelectRoom func(roomId string) StoreResult

+ SelectRooms func() StoreResult

+ SelectUsersForRoom func(roomId string) StoreResult

+ UpdateRoom func(room *models.Room) StoreResult

+ UpdateRoomDeleted func(roomId string) StoreResult

type RoomUserStore

+ CreateRoomUserStore func()

+ DeleteAndInsertRoomUsers func(roomUsers []*models.RoomUser) StoreResult

+ DeleteRoomUser func(roomId string, userIds []string) StoreResult

+ InsertRoomUsers func(roomUsers []*models.RoomUser) StoreResult

+ SelectRoomUser func(roomId, userId string) StoreResult

+ SelectRoomUsersByRoomId func(roomId string) StoreResult

+ SelectRoomUsersByRoomIdAndUserIds func(roomId *string, userIds []string) StoreResult

+ SelectRoomUsersByUserId func(userId string) StoreResult

+ UpdateRoomUser func(*models.RoomUser) StoreResult

type SqliteProvider

+ func (provider SqliteProvider) CreateDeviceStore()

+ func (provider SqliteProvider) CreateMessageStore()

+ func (provider SqliteProvider) CreateRoomStore()

+ func (provider SqliteProvider) CreateRoomUserStore()

+ func (provider SqliteProvider) CreateSubscriptionStore()

+ func (provider SqliteProvider) CreateUserStore()

+ func (provider SqliteProvider) DeleteAndInsertRoomUsers(roomUsers []*models.RoomUser) StoreResult

+ func (provider SqliteProvider) DeleteDevice(userId string, platform int) StoreResult

+ func (provider SqliteProvider) DeleteRoomUser(roomId string, userIds []string) StoreResult

+ func (provider SqliteProvider) DeleteSubscription(subscription *models.Subscription) StoreResult

+ func (provider SqliteProvider) InsertDevice(device *models.Device) StoreResult

+ func (provider SqliteProvider) InsertMessage(message *models.Message) StoreResult

+ func (provider SqliteProvider) InsertRoom(room *models.Room) StoreResult

+ func (provider SqliteProvider) InsertRoomUsers(roomUsers []*models.RoomUser) StoreResult

+ func (provider SqliteProvider) InsertSubscription(room *models.Subscription) StoreResult

+ func (provider SqliteProvider) InsertUser(user *models.User) StoreResult

+ func (provider SqliteProvider) SelectCountMessagesByRoomId(roomId string) StoreResult

+ func (provider SqliteProvider) SelectCountRooms() StoreResult

+ func (provider SqliteProvider) SelectDevice(userId string, platform int) StoreResult

+ func (provider SqliteProvider) SelectDevices() StoreResult

+ func (provider SqliteProvider) SelectDevicesByUserId(userId string) StoreResult

+ func (provider SqliteProvider) SelectMessage(messageId string) StoreResult

+ func (provider SqliteProvider) SelectMessages(roomId string, limit, offset int) StoreResult

+ func (provider SqliteProvider) SelectRoom(roomId string) StoreResult

+ func (provider SqliteProvider) SelectRoomUser(roomId, userId string) StoreResult

+ func (provider SqliteProvider) SelectRoomUsersByRoomId(roomId string) StoreResult

+ func (provider SqliteProvider) SelectRoomUsersByRoomIdAndUserIds(roomId *string, userIds []string) StoreResult

+ func (provider SqliteProvider) SelectRoomUsersByUserId(userId string) StoreResult

+ func (provider SqliteProvider) SelectRooms() StoreResult

+ func (provider SqliteProvider) SelectRoomsForUser(userId string) StoreResult

+ func (provider SqliteProvider) SelectSubscription(roomId, userId string, platform int) StoreResult

+ func (provider SqliteProvider) SelectSubscriptionsByRoomId(roomId string) StoreResult

+ func (provider SqliteProvider) SelectSubscriptionsByRoomIdAndPlatform(roomId string, platform int) StoreResult

+ func (provider SqliteProvider) SelectSubscriptionsByUserId(userId string) StoreResult

+ func (provider SqliteProvider) SelectSubscriptionsByUserIdAndPlatform(userId string, platform int) StoreResult

+ func (provider SqliteProvider) SelectUser(userId string, isWithRooms, isWithDevices bool) StoreResult

+ func (provider SqliteProvider) SelectUserIdsByUserIds(userIds []string) StoreResult

+ func (provider SqliteProvider) SelectUsers() StoreResult

+ func (provider SqliteProvider) SelectUsersForRoom(roomId string) StoreResult

+ func (provider SqliteProvider) UpdateDevice(device *models.Device) StoreResult

+ func (provider SqliteProvider) UpdateMessage(message *models.Message) StoreResult

+ func (provider SqliteProvider) UpdateRoom(room *models.Room) StoreResult

+ func (provider SqliteProvider) UpdateRoomDeleted(roomId string) StoreResult

+ func (provider SqliteProvider) UpdateRoomUser(roomUser *models.RoomUser) StoreResult

+ func (provider SqliteProvider) UpdateUser(user *models.User) StoreResult

+ func (provider SqliteProvider) UpdateUserDeleted(userId string) StoreResult

type StoreResult

+ func RdbDeleteAndInsertRoomUsers(roomUsers []*models.RoomUser) StoreResult

+ func RdbDeleteDevice(userId string, platform int) StoreResult

+ func RdbDeleteRoomUser(roomId string, userIds []string) StoreResult

+ func RdbDeleteSubscription(subscription *models.Subscription) StoreResult

+ func RdbInsertDevice(device *models.Device) StoreResult

+ func RdbInsertMessage(message *models.Message) StoreResult

+ func RdbInsertRoom(room *models.Room) StoreResult

+ func RdbInsertRoomUsers(roomUsers []*models.RoomUser) StoreResult

+ func RdbInsertSubscription(subscription *models.Subscription) StoreResult

+ func RdbInsertUser(user *models.User) StoreResult

+ func RdbSelectCountMessagesByRoomId(roomId string) StoreResult

+ func RdbSelectCountRooms() StoreResult

+ func RdbSelectDevice(userId string, platform int) StoreResult

+ func RdbSelectDevices() StoreResult

+ func RdbSelectDevicesByUserId(userId string) StoreResult

+ func RdbSelectMessage(messageId string) StoreResult

+ func RdbSelectMessages(roomId string, limit, offset int) StoreResult

+ func RdbSelectRoom(roomId string) StoreResult

+ func RdbSelectRoomUser(roomId, userId string) StoreResult

+ func RdbSelectRoomUsersByRoomId(roomId string) StoreResult

+ func RdbSelectRoomUsersByRoomIdAndUserIds(roomId *string, userIds []string) StoreResult

+ func RdbSelectRoomUsersByUserId(userId string) StoreResult

+ func RdbSelectRooms() StoreResult

+ func RdbSelectRoomsForUser(userId string) StoreResult

+ func RdbSelectSubscription(roomId, userId string, platform int) StoreResult

+ func RdbSelectSubscriptionsByRoomId(roomId string) StoreResult

+ func RdbSelectSubscriptionsByRoomIdAndPlatform(roomId string, platform int) StoreResult

+ func RdbSelectSubscriptionsByUserId(userId string) StoreResult

+ func RdbSelectSubscriptionsByUserIdAndPlatform(userId string, platform int) StoreResult

+ func RdbSelectUser(userId string, isWithRooms, isWithDevices bool) StoreResult

+ func RdbSelectUserIdsByUserIds(userIds []string) StoreResult

+ func RdbSelectUsers() StoreResult

+ func RdbSelectUsersForRoom(roomId string) StoreResult

+ func RdbUpdateDevice(device *models.Device) StoreResult

+ func RdbUpdateMessage(message *models.Message) StoreResult

+ func RdbUpdateRoom(room *models.Room) StoreResult

+ func RdbUpdateRoomDeleted(roomId string) StoreResult

+ func RdbUpdateRoomUser(roomUser *models.RoomUser) StoreResult

+ func RdbUpdateUser(user *models.User) StoreResult

+ func RdbUpdateUserDeleted(userId string) StoreResult

+ type SubscriptionStore interface

+ CreateSubscriptionStore func()

+ DeleteSubscription func(subscription *models.Subscription) StoreResult

+ InsertSubscription func(subscription *models.Subscription) StoreResult

+ SelectSubscription func(roomId, userId string, platform int) StoreResult

+ SelectSubscriptionsByRoomId func(roomId string) StoreResult

+ SelectSubscriptionsByRoomIdAndPlatform func(roomId string, platform int) StoreResult

+ SelectSubscriptionsByUserId func(userId string) StoreResult

+ SelectSubscriptionsByUserIdAndPlatform func(userId string, platform int) StoreResult

type UserStore

+ CreateUserStore func()

+ InsertUser func(user *models.User) StoreResult

+ SelectRoomsForUser func(userId string) StoreResult

+ SelectUser func(userId string, isWithRooms, isWithDevices bool) StoreResult

+ SelectUserIdsByUserIds func(userIds []string) StoreResult

+ SelectUsers func() StoreResult

+ UpdateUser func(user *models.User) StoreResult

+ UpdateUserDeleted func(userId string) StoreResult

v0.1.0

Apr 5, 2017

Changes in this version

+ const EXIT_DB_OPEN

+ const EXIT_NO_DRIVER

+ const EXIT_PING

+ const TABLE_NAME_MESSAGE

+ const TABLE_NAME_ROOM

+ const TABLE_NAME_ROOM_USER

+ const TABLE_NAME_USER

+ func RdbCreateMessageStore()

+ func RdbRoomCreateStore()

+ func RdbRoomUserCreateStore()

+ func RdbUserCreateStore()

+ type GcpSqlProvider struct

+ func (provider GcpSqlProvider) Connect() error

+ func (provider GcpSqlProvider) DropDatabase() error

+ func (provider GcpSqlProvider) Init()

+ func (provider GcpSqlProvider) MessageCount(roomId string) StoreChannel

+ func (provider GcpSqlProvider) MessageCreateStore()

+ func (provider GcpSqlProvider) MessageInsert(message *models.Message) StoreChannel

+ func (provider GcpSqlProvider) MessageSelect(messageId string) StoreChannel

+ func (provider GcpSqlProvider) MessageSelectAll(roomId string, limit, offset int) StoreChannel

+ func (provider GcpSqlProvider) MessageUpdate(message *models.Message) StoreChannel

+ func (provider GcpSqlProvider) RoomCreateStore()

+ func (provider GcpSqlProvider) RoomInsert(room *models.Room) StoreChannel

+ func (provider GcpSqlProvider) RoomSelect(roomId string) StoreChannel

+ func (provider GcpSqlProvider) RoomSelectAll() StoreChannel

+ func (provider GcpSqlProvider) RoomSelectUsersForRoom(roomId string) StoreChannel

+ func (provider GcpSqlProvider) RoomUpdate(room *models.Room) StoreChannel

+ func (provider GcpSqlProvider) RoomUserCreateStore()

+ func (provider GcpSqlProvider) RoomUserDelete(roomId string, userIds []string) StoreChannel

+ func (provider GcpSqlProvider) RoomUserInsert(roomUser *models.RoomUser) StoreChannel

+ func (provider GcpSqlProvider) RoomUserMarkAllAsRead(userId string) StoreChannel

+ func (provider GcpSqlProvider) RoomUserSelect(roomId, userId string) StoreChannel

+ func (provider GcpSqlProvider) RoomUserUnreadCountUp(roomId string, currentUserId string) StoreChannel

+ func (provider GcpSqlProvider) RoomUserUpdate(roomUser *models.RoomUser) StoreChannel

+ func (provider GcpSqlProvider) RoomUserUsersSelect(roomId string) StoreChannel

+ func (provider GcpSqlProvider) RoomUsersDeleteByUserIds(roomId *string, userIds []string) StoreChannel

+ func (provider GcpSqlProvider) RoomUsersInsert(roomId string, roomUsers []*models.RoomUser, isDeleteFirst bool) StoreChannel

+ func (provider GcpSqlProvider) RoomUsersSelect(roomId *string, userIds []string) StoreChannel

+ func (provider GcpSqlProvider) RoomUsersSelectIds(roomId *string, userIds []string) StoreChannel

+ func (provider GcpSqlProvider) RoomUsersSelectUserIds(roomId string) StoreChannel

+ func (provider GcpSqlProvider) UserCreateStore()

+ func (provider GcpSqlProvider) UserInsert(user *models.User) StoreChannel

+ func (provider GcpSqlProvider) UserSelect(userId string) StoreChannel

+ func (provider GcpSqlProvider) UserSelectAll() StoreChannel

+ func (provider GcpSqlProvider) UserSelectByUserIds(userIds []string) StoreChannel

+ func (provider GcpSqlProvider) UserSelectRoomsForUser(userId string) StoreChannel

+ func (provider GcpSqlProvider) UserSelectUserRooms(userId string) StoreChannel

+ func (provider GcpSqlProvider) UserUnreadCountRecalc(userId string) StoreChannel

+ func (provider GcpSqlProvider) UserUnreadCountUp(userId string) StoreChannel

+ func (provider GcpSqlProvider) UserUpdate(user *models.User) StoreChannel

+ type MessageStore interface

+ MessageCount func(roomId string) StoreChannel

+ MessageCreateStore func()

+ MessageInsert func(message *models.Message) StoreChannel

+ MessageSelect func(messageId string) StoreChannel

+ MessageSelectAll func(roomId string, limit, offset int) StoreChannel

+ MessageUpdate func(message *models.Message) StoreChannel

+ type MysqlProvider struct

+ func (provider MysqlProvider) Connect() error

+ func (provider MysqlProvider) DropDatabase() error

+ func (provider MysqlProvider) Init()

+ func (provider MysqlProvider) MessageCount(roomId string) StoreChannel

+ func (provider MysqlProvider) MessageCreateStore()

+ func (provider MysqlProvider) MessageInsert(message *models.Message) StoreChannel

+ func (provider MysqlProvider) MessageSelect(messageId string) StoreChannel

+ func (provider MysqlProvider) MessageSelectAll(roomId string, limit, offset int) StoreChannel

+ func (provider MysqlProvider) MessageUpdate(message *models.Message) StoreChannel

+ func (provider MysqlProvider) RoomCreateStore()

+ func (provider MysqlProvider) RoomInsert(room *models.Room) StoreChannel

+ func (provider MysqlProvider) RoomSelect(roomId string) StoreChannel

+ func (provider MysqlProvider) RoomSelectAll() StoreChannel

+ func (provider MysqlProvider) RoomSelectUsersForRoom(roomId string) StoreChannel

+ func (provider MysqlProvider) RoomUpdate(room *models.Room) StoreChannel

+ func (provider MysqlProvider) RoomUserCreateStore()

+ func (provider MysqlProvider) RoomUserDelete(roomId string, userIds []string) StoreChannel

+ func (provider MysqlProvider) RoomUserInsert(roomUser *models.RoomUser) StoreChannel

+ func (provider MysqlProvider) RoomUserMarkAllAsRead(userId string) StoreChannel

+ func (provider MysqlProvider) RoomUserSelect(roomId, userId string) StoreChannel

+ func (provider MysqlProvider) RoomUserUnreadCountUp(roomId string, currentUserId string) StoreChannel

+ func (provider MysqlProvider) RoomUserUpdate(roomUser *models.RoomUser) StoreChannel

+ func (provider MysqlProvider) RoomUserUsersSelect(roomId string) StoreChannel

+ func (provider MysqlProvider) RoomUsersDeleteByUserIds(roomId *string, userIds []string) StoreChannel

+ func (provider MysqlProvider) RoomUsersInsert(roomId string, roomUsers []*models.RoomUser, isDeleteFirst bool) StoreChannel

+ func (provider MysqlProvider) RoomUsersSelect(roomId *string, userIds []string) StoreChannel

+ func (provider MysqlProvider) RoomUsersSelectIds(roomId *string, userIds []string) StoreChannel

+ func (provider MysqlProvider) RoomUsersSelectUserIds(roomId string) StoreChannel

+ func (provider MysqlProvider) UserCreateStore()

+ func (provider MysqlProvider) UserInsert(user *models.User) StoreChannel

+ func (provider MysqlProvider) UserSelect(userId string) StoreChannel

+ func (provider MysqlProvider) UserSelectAll() StoreChannel

+ func (provider MysqlProvider) UserSelectByUserIds(userIds []string) StoreChannel

+ func (provider MysqlProvider) UserSelectRoomsForUser(userId string) StoreChannel

+ func (provider MysqlProvider) UserSelectUserRooms(userId string) StoreChannel

+ func (provider MysqlProvider) UserUnreadCountRecalc(userId string) StoreChannel

+ func (provider MysqlProvider) UserUnreadCountUp(userId string) StoreChannel

+ func (provider MysqlProvider) UserUpdate(user *models.User) StoreChannel

+ type Provider interface

+ Connect func() error

+ DropDatabase func() error

+ Init func()

+ func GetProvider() Provider

+ type RoomStore interface

+ RoomCreateStore func()

+ RoomInsert func(room *models.Room) StoreChannel

+ RoomSelect func(roomId string) StoreChannel

+ RoomSelectAll func() StoreChannel

+ RoomSelectUsersForRoom func(roomId string) StoreChannel

+ RoomUpdate func(room *models.Room) StoreChannel

+ type RoomUserStore interface

+ RoomUserCreateStore func()

+ RoomUserDelete func(roomId string, userIds []string) StoreChannel

+ RoomUserInsert func(roomUser *models.RoomUser) StoreChannel

+ RoomUserMarkAllAsRead func(userId string) StoreChannel

+ RoomUserSelect func(roomId, userId string) StoreChannel

+ RoomUserUnreadCountUp func(roomId string, currentUserId string) StoreChannel

+ RoomUserUpdate func(*models.RoomUser) StoreChannel

+ RoomUserUsersSelect func(roomId string) StoreChannel

+ RoomUsersDeleteByUserIds func(roomId *string, userIds []string) StoreChannel

+ RoomUsersInsert func(roomId string, roomUsers []*models.RoomUser, isDeleteFirst bool) StoreChannel

+ RoomUsersSelect func(roomId *string, userIds []string) StoreChannel

+ RoomUsersSelectIds func(roomId *string, userIds []string) StoreChannel

+ RoomUsersSelectUserIds func(roomId string) StoreChannel

+ type SqliteProvider struct

+ func (provider SqliteProvider) Connect() error

+ func (provider SqliteProvider) DropDatabase() error

+ func (provider SqliteProvider) Init()

+ func (provider SqliteProvider) MessageCount(roomId string) StoreChannel

+ func (provider SqliteProvider) MessageCreateStore()

+ func (provider SqliteProvider) MessageInsert(message *models.Message) StoreChannel

+ func (provider SqliteProvider) MessageSelect(messageId string) StoreChannel

+ func (provider SqliteProvider) MessageSelectAll(roomId string, limit, offset int) StoreChannel

+ func (provider SqliteProvider) MessageUpdate(message *models.Message) StoreChannel

+ func (provider SqliteProvider) RoomCreateStore()

+ func (provider SqliteProvider) RoomInsert(room *models.Room) StoreChannel

+ func (provider SqliteProvider) RoomSelect(roomId string) StoreChannel

+ func (provider SqliteProvider) RoomSelectAll() StoreChannel

+ func (provider SqliteProvider) RoomSelectUsersForRoom(roomId string) StoreChannel

+ func (provider SqliteProvider) RoomUpdate(room *models.Room) StoreChannel

+ func (provider SqliteProvider) RoomUserCreateStore()

+ func (provider SqliteProvider) RoomUserDelete(roomId string, userIds []string) StoreChannel

+ func (provider SqliteProvider) RoomUserInsert(roomUser *models.RoomUser) StoreChannel

+ func (provider SqliteProvider) RoomUserMarkAllAsRead(userId string) StoreChannel

+ func (provider SqliteProvider) RoomUserSelect(roomId, userId string) StoreChannel

+ func (provider SqliteProvider) RoomUserUnreadCountUp(roomId string, currentUserId string) StoreChannel

+ func (provider SqliteProvider) RoomUserUpdate(roomUser *models.RoomUser) StoreChannel

+ func (provider SqliteProvider) RoomUserUsersSelect(roomId string) StoreChannel

+ func (provider SqliteProvider) RoomUsersDeleteByUserIds(roomId *string, userIds []string) StoreChannel

+ func (provider SqliteProvider) RoomUsersInsert(roomId string, roomUsers []*models.RoomUser, isDeleteFirst bool) StoreChannel

+ func (provider SqliteProvider) RoomUsersSelect(roomId *string, userIds []string) StoreChannel

+ func (provider SqliteProvider) RoomUsersSelectIds(roomId *string, userIds []string) StoreChannel

+ func (provider SqliteProvider) RoomUsersSelectUserIds(roomId string) StoreChannel

+ func (provider SqliteProvider) UserCreateStore()

+ func (provider SqliteProvider) UserInsert(user *models.User) StoreChannel

+ func (provider SqliteProvider) UserSelect(userId string) StoreChannel

+ func (provider SqliteProvider) UserSelectAll() StoreChannel

+ func (provider SqliteProvider) UserSelectByUserIds(userIds []string) StoreChannel

+ func (provider SqliteProvider) UserSelectRoomsForUser(userId string) StoreChannel

+ func (provider SqliteProvider) UserSelectUserRooms(userId string) StoreChannel

+ func (provider SqliteProvider) UserUnreadCountRecalc(userId string) StoreChannel

+ func (provider SqliteProvider) UserUnreadCountUp(userId string) StoreChannel

+ func (provider SqliteProvider) UserUpdate(user *models.User) StoreChannel

+ type StoreChannel chan StoreResult

+ func RdbMessageCount(roomId string) StoreChannel

+ func RdbMessageInsert(message *models.Message) StoreChannel

+ func RdbMessageSelect(messageId string) StoreChannel

+ func RdbMessageSelectAll(roomId string, limit, offset int) StoreChannel

+ func RdbMessageUpdate(message *models.Message) StoreChannel

+ func RdbRoomInsert(room *models.Room) StoreChannel

+ func RdbRoomSelect(roomId string) StoreChannel

+ func RdbRoomSelectAll() StoreChannel

+ func RdbRoomSelectUsersForRoom(roomId string) StoreChannel

+ func RdbRoomUpdate(room *models.Room) StoreChannel

+ func RdbRoomUserDelete(roomId string, userIds []string) StoreChannel

+ func RdbRoomUserInsert(roomUser *models.RoomUser) StoreChannel

+ func RdbRoomUserMarkAllAsRead(userId string) StoreChannel

+ func RdbRoomUserSelect(roomId, userId string) StoreChannel

+ func RdbRoomUserUnreadCountUp(roomId string, currentUserId string) StoreChannel

+ func RdbRoomUserUpdate(roomUser *models.RoomUser) StoreChannel

+ func RdbRoomUserUsersSelect(roomId string) StoreChannel

+ func RdbRoomUsersDeleteByUserIds(roomId *string, userIds []string) StoreChannel

+ func RdbRoomUsersInsert(roomId string, roomUsers []*models.RoomUser, isDeleteFirst bool) StoreChannel

+ func RdbRoomUsersSelect(roomId *string, userIds []string) StoreChannel

+ func RdbRoomUsersSelectIds(roomId *string, userIds []string) StoreChannel

+ func RdbRoomUsersSelectUserIds(roomId string) StoreChannel

+ func RdbUserInsert(user *models.User) StoreChannel

+ func RdbUserSelect(userId string) StoreChannel

+ func RdbUserSelectAll() StoreChannel

+ func RdbUserSelectByUserIds(userIds []string) StoreChannel

+ func RdbUserSelectRoomsForUser(userId string) StoreChannel

+ func RdbUserSelectUserRooms(userId string) StoreChannel

+ func RdbUserUnreadCountRecalc(userId string) StoreChannel

+ func RdbUserUnreadCountUp(userId string) StoreChannel

+ func RdbUserUpdate(user *models.User) StoreChannel

+ type StoreResult struct

+ Data interface{}

+ ProblemDetail *models.ProblemDetail

+ type UserStore interface

+ UserCreateStore func()

+ UserInsert func(user *models.User) StoreChannel

+ UserSelect func(userId string) StoreChannel

+ UserSelectAll func() StoreChannel

+ UserSelectByUserIds func(userIds []string) StoreChannel

+ UserSelectRoomsForUser func(userId string) StoreChannel

+ UserSelectUserRooms func(userId string) StoreChannel

+ UserUnreadCountRecalc func(userId string) StoreChannel

+ UserUnreadCountUp func(userId string) StoreChannel

+ UserUpdate func(user *models.User) StoreChannel

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL