datastore

package
v0.7.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 20, 2017 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TABLE_NAME_API          = utils.Cfg.Datastore.TableNamePrefix + "api"
	TABLE_NAME_USER         = utils.Cfg.Datastore.TableNamePrefix + "user"
	TABLE_NAME_BLOCK_USER   = utils.Cfg.Datastore.TableNamePrefix + "block_user"
	TABLE_NAME_ROOM         = utils.Cfg.Datastore.TableNamePrefix + "room"
	TABLE_NAME_ROOM_USER    = utils.Cfg.Datastore.TableNamePrefix + "room_user"
	TABLE_NAME_MESSAGE      = utils.Cfg.Datastore.TableNamePrefix + "message"
	TABLE_NAME_DEVICE       = utils.Cfg.Datastore.TableNamePrefix + "device"
	TABLE_NAME_SUBSCRIPTION = utils.Cfg.Datastore.TableNamePrefix + "subscription"
)

Functions

func RdbCreateApiStore added in v0.6.0 

func RdbCreateApiStore()

func RdbCreateBlockUserStore added in v0.7.0 

func RdbCreateBlockUserStore()

func RdbCreateDeviceStore added in v0.2.0 

func RdbCreateDeviceStore()

func RdbCreateMessageStore 

func RdbCreateMessageStore()

func RdbCreateRoomStore added in v0.2.0 

func RdbCreateRoomStore()

func RdbCreateRoomUserStore added in v0.2.0 

func RdbCreateRoomUserStore()

func RdbCreateSubscriptionStore added in v0.2.0 

func RdbCreateSubscriptionStore()

func RdbCreateUserStore added in v0.2.0 

func RdbCreateUserStore()

Types

type ApiStore added in v0.6.0 

type ApiStore interface {
	CreateApiStore()

	InsertApi(name string) StoreResult
	SelectLatestApi(name string) StoreResult
}

type BlockUserStore added in v0.7.0 

type BlockUserStore interface {
	CreateBlockUserStore()

	InsertBlockUsers(blockUsers []*models.BlockUser) StoreResult
	SelectBlockUser(userId, blockUserId string) StoreResult
	SelectBlockUsersByUserId(userId string) StoreResult
	DeleteBlockUser(userId string, blockUserIds []string) StoreResult
}

type DeviceStore added in v0.2.0 

type DeviceStore interface {
	CreateDeviceStore()

	InsertDevice(device *models.Device) StoreResult
	SelectDevices(userId string) StoreResult
	SelectDevice(userId string, platform int) StoreResult
	SelectDevicesByUserId(userId string) StoreResult
	SelectDevicesByToken(token string) StoreResult
	UpdateDevice(device *models.Device) StoreResult
	DeleteDevice(userId string, platform int) StoreResult
}

type GcpSqlProvider 

type GcpSqlProvider struct {
	// contains filtered or unexported fields
}

func (GcpSqlProvider) Connect 

func (provider GcpSqlProvider) Connect() error

func (GcpSqlProvider) CreateApiStore added in v0.6.0 

func (provider GcpSqlProvider) CreateApiStore()

func (GcpSqlProvider) CreateBlockUserStore added in v0.7.0 

func (provider GcpSqlProvider) CreateBlockUserStore()

func (GcpSqlProvider) CreateDeviceStore added in v0.2.0 

func (provider GcpSqlProvider) CreateDeviceStore()

func (GcpSqlProvider) CreateMessageStore added in v0.2.0 

func (provider GcpSqlProvider) CreateMessageStore()

func (GcpSqlProvider) CreateRoomStore added in v0.2.0 

func (provider GcpSqlProvider) CreateRoomStore()

func (GcpSqlProvider) CreateRoomUserStore added in v0.2.0 

func (provider GcpSqlProvider) CreateRoomUserStore()

func (GcpSqlProvider) CreateSubscriptionStore added in v0.2.0 

func (provider GcpSqlProvider) CreateSubscriptionStore()

func (GcpSqlProvider) CreateUserStore added in v0.2.0 

func (provider GcpSqlProvider) CreateUserStore()

func (GcpSqlProvider) DeleteAndInsertRoomUsers added in v0.2.0 

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

func (GcpSqlProvider) DeleteBlockUser added in v0.7.0 

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

func (GcpSqlProvider) DeleteDevice added in v0.2.0 

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

func (GcpSqlProvider) DeleteRoomUser added in v0.2.0 

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

func (GcpSqlProvider) DeleteSubscription added in v0.2.0 

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

func (GcpSqlProvider) DropDatabase 

func (provider GcpSqlProvider) DropDatabase() error

func (GcpSqlProvider) Init 

func (provider GcpSqlProvider) Init()

func (GcpSqlProvider) InsertApi added in v0.6.0 

func (provider GcpSqlProvider) InsertApi(name string) StoreResult

func (GcpSqlProvider) InsertBlockUsers added in v0.7.0 

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

func (GcpSqlProvider) InsertDevice added in v0.2.0 

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

func (GcpSqlProvider) InsertMessage added in v0.2.0 

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

func (GcpSqlProvider) InsertRoom added in v0.2.0 

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

func (GcpSqlProvider) InsertRoomUsers added in v0.2.0 

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

func (GcpSqlProvider) InsertSubscription added in v0.2.0 

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

func (GcpSqlProvider) InsertUser added in v0.2.0 

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

func (GcpSqlProvider) SelectBlockUser added in v0.7.0 

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

func (GcpSqlProvider) SelectBlockUsersByUserId added in v0.7.0 

func (provider GcpSqlProvider) SelectBlockUsersByUserId(userId string) StoreResult

func (GcpSqlProvider) SelectContacts added in v0.7.0 

func (provider GcpSqlProvider) SelectContacts(userId string) StoreResult

func (GcpSqlProvider) SelectCountMessagesByRoomId added in v0.2.0 

func (provider GcpSqlProvider) SelectCountMessagesByRoomId(roomId string) StoreResult

func (GcpSqlProvider) SelectCountRooms added in v0.2.0 

func (provider GcpSqlProvider) SelectCountRooms() StoreResult

func (GcpSqlProvider) SelectDeletedSubscriptionsByRoomId added in v0.7.1 

func (provider GcpSqlProvider) SelectDeletedSubscriptionsByRoomId(roomId string) StoreResult

func (GcpSqlProvider) SelectDeletedSubscriptionsByUserId added in v0.7.1 

func (provider GcpSqlProvider) SelectDeletedSubscriptionsByUserId(userId string) StoreResult

func (GcpSqlProvider) SelectDeletedSubscriptionsByUserIdAndPlatform added in v0.7.1 

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

func (GcpSqlProvider) SelectDevice added in v0.2.0 

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

func (GcpSqlProvider) SelectDevices added in v0.2.0 

func (provider GcpSqlProvider) SelectDevices(userId string) StoreResult

func (GcpSqlProvider) SelectDevicesByToken added in v0.7.1 

func (provider GcpSqlProvider) SelectDevicesByToken(token string) StoreResult

func (GcpSqlProvider) SelectDevicesByUserId added in v0.2.0 

func (provider GcpSqlProvider) SelectDevicesByUserId(userId string) StoreResult

func (GcpSqlProvider) SelectLatestApi added in v0.6.0 

func (provider GcpSqlProvider) SelectLatestApi(name string) StoreResult

func (GcpSqlProvider) SelectMessage added in v0.2.0 

func (provider GcpSqlProvider) SelectMessage(messageId string) StoreResult

func (GcpSqlProvider) SelectMessages added in v0.2.0 

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

func (GcpSqlProvider) SelectRoom added in v0.2.0 

func (provider GcpSqlProvider) SelectRoom(roomId string) StoreResult

func (GcpSqlProvider) SelectRoomUser added in v0.2.0 

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

func (GcpSqlProvider) SelectRoomUsersByRoomId added in v0.2.0 

func (provider GcpSqlProvider) SelectRoomUsersByRoomId(roomId string) StoreResult

func (GcpSqlProvider) SelectRoomUsersByRoomIdAndUserIds added in v0.2.0 

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

func (GcpSqlProvider) SelectRoomUsersByUserId added in v0.2.0 

func (provider GcpSqlProvider) SelectRoomUsersByUserId(userId string) StoreResult

func (GcpSqlProvider) SelectRooms added in v0.2.0 

func (provider GcpSqlProvider) SelectRooms() StoreResult

func (GcpSqlProvider) SelectSubscription added in v0.2.0 

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

func (GcpSqlProvider) SelectUser added in v0.2.0 

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

func (GcpSqlProvider) SelectUserByUserIdAndAccessToken added in v0.5.0 

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

func (GcpSqlProvider) SelectUserIdsByUserIds added in v0.2.0 

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

func (GcpSqlProvider) SelectUsers added in v0.2.0 

func (provider GcpSqlProvider) SelectUsers() StoreResult

func (GcpSqlProvider) SelectUsersForRoom added in v0.2.0 

func (provider GcpSqlProvider) SelectUsersForRoom(roomId string) StoreResult

func (GcpSqlProvider) UpdateDevice added in v0.2.0 

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

func (GcpSqlProvider) UpdateMessage added in v0.2.0 

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

func (GcpSqlProvider) UpdateRoom added in v0.2.0 

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

func (GcpSqlProvider) UpdateRoomDeleted added in v0.2.0 

func (provider GcpSqlProvider) UpdateRoomDeleted(roomId string) StoreResult

func (GcpSqlProvider) UpdateRoomUser added in v0.2.0 

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

func (GcpSqlProvider) UpdateUser added in v0.2.0 

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

func (GcpSqlProvider) UpdateUserDeleted added in v0.2.0 

func (provider GcpSqlProvider) UpdateUserDeleted(userId string) StoreResult

type MessageStore 

type MessageStore interface {
	CreateMessageStore()

	InsertMessage(message *models.Message) StoreResult
	SelectMessage(messageId string) StoreResult
	SelectMessages(roomId string, limit, offset int, order string) StoreResult
	SelectCountMessagesByRoomId(roomId string) StoreResult
	UpdateMessage(message *models.Message) StoreResult
}

type MysqlProvider 

type MysqlProvider struct {
	// contains filtered or unexported fields
}

func (MysqlProvider) Connect 

func (provider MysqlProvider) Connect() error

func (MysqlProvider) CreateApiStore added in v0.6.0 

func (provider MysqlProvider) CreateApiStore()

func (MysqlProvider) CreateBlockUserStore added in v0.7.0 

func (provider MysqlProvider) CreateBlockUserStore()

func (MysqlProvider) CreateDeviceStore added in v0.2.0 

func (provider MysqlProvider) CreateDeviceStore()

func (MysqlProvider) CreateMessageStore added in v0.2.0 

func (provider MysqlProvider) CreateMessageStore()

func (MysqlProvider) CreateRoomStore added in v0.2.0 

func (provider MysqlProvider) CreateRoomStore()

func (MysqlProvider) CreateRoomUserStore added in v0.2.0 

func (provider MysqlProvider) CreateRoomUserStore()

func (MysqlProvider) CreateSubscriptionStore added in v0.2.0 

func (provider MysqlProvider) CreateSubscriptionStore()

func (MysqlProvider) CreateUserStore added in v0.2.0 

func (provider MysqlProvider) CreateUserStore()

func (MysqlProvider) DeleteAndInsertRoomUsers added in v0.2.0 

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

func (MysqlProvider) DeleteBlockUser added in v0.7.0 

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

func (MysqlProvider) DeleteDevice added in v0.2.0 

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

func (MysqlProvider) DeleteRoomUser added in v0.2.0 

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

func (MysqlProvider) DeleteSubscription added in v0.2.0 

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

func (MysqlProvider) DropDatabase 

func (provider MysqlProvider) DropDatabase() error

func (MysqlProvider) Init 

func (provider MysqlProvider) Init()

func (MysqlProvider) InsertApi added in v0.6.0 

func (provider MysqlProvider) InsertApi(name string) StoreResult

func (MysqlProvider) InsertBlockUsers added in v0.7.0 

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

func (MysqlProvider) InsertDevice added in v0.2.0 

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

func (MysqlProvider) InsertMessage added in v0.2.0 

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

func (MysqlProvider) InsertRoom added in v0.2.0 

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

func (MysqlProvider) InsertRoomUsers added in v0.2.0 

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

func (MysqlProvider) InsertSubscription added in v0.2.0 

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

func (MysqlProvider) InsertUser added in v0.2.0 

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

func (MysqlProvider) SelectBlockUser added in v0.7.0 

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

func (MysqlProvider) SelectBlockUsersByUserId added in v0.7.0 

func (provider MysqlProvider) SelectBlockUsersByUserId(userId string) StoreResult

func (MysqlProvider) SelectContacts added in v0.7.0 

func (provider MysqlProvider) SelectContacts(userId string) StoreResult

func (MysqlProvider) SelectCountMessagesByRoomId added in v0.2.0 

func (provider MysqlProvider) SelectCountMessagesByRoomId(roomId string) StoreResult

func (MysqlProvider) SelectCountRooms added in v0.2.0 

func (provider MysqlProvider) SelectCountRooms() StoreResult

func (MysqlProvider) SelectDeletedSubscriptionsByRoomId added in v0.7.1 

func (provider MysqlProvider) SelectDeletedSubscriptionsByRoomId(roomId string) StoreResult

func (MysqlProvider) SelectDeletedSubscriptionsByUserId added in v0.7.1 

func (provider MysqlProvider) SelectDeletedSubscriptionsByUserId(userId string) StoreResult

func (MysqlProvider) SelectDeletedSubscriptionsByUserIdAndPlatform added in v0.7.1 

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

func (MysqlProvider) SelectDevice added in v0.2.0 

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

func (MysqlProvider) SelectDevices added in v0.2.0 

func (provider MysqlProvider) SelectDevices(userId string) StoreResult

func (MysqlProvider) SelectDevicesByToken added in v0.7.1 

func (provider MysqlProvider) SelectDevicesByToken(token string) StoreResult

func (MysqlProvider) SelectDevicesByUserId added in v0.2.0 

func (provider MysqlProvider) SelectDevicesByUserId(userId string) StoreResult

func (MysqlProvider) SelectLatestApi added in v0.6.0 

func (provider MysqlProvider) SelectLatestApi(name string) StoreResult

func (MysqlProvider) SelectMessage added in v0.2.0 

func (provider MysqlProvider) SelectMessage(messageId string) StoreResult

func (MysqlProvider) SelectMessages added in v0.2.0 

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

func (MysqlProvider) SelectRoom added in v0.2.0 

func (provider MysqlProvider) SelectRoom(roomId string) StoreResult

func (MysqlProvider) SelectRoomUser added in v0.2.0 

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

func (MysqlProvider) SelectRoomUsersByRoomId added in v0.2.0 

func (provider MysqlProvider) SelectRoomUsersByRoomId(roomId string) StoreResult

func (MysqlProvider) SelectRoomUsersByRoomIdAndUserIds added in v0.2.0 

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

func (MysqlProvider) SelectRoomUsersByUserId added in v0.2.0 

func (provider MysqlProvider) SelectRoomUsersByUserId(userId string) StoreResult

func (MysqlProvider) SelectRooms added in v0.2.0 

func (provider MysqlProvider) SelectRooms() StoreResult

func (MysqlProvider) SelectSubscription added in v0.2.0 

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

func (MysqlProvider) SelectUser added in v0.2.0 

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

func (MysqlProvider) SelectUserByUserIdAndAccessToken added in v0.5.0 

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

func (MysqlProvider) SelectUserIdsByUserIds added in v0.2.0 

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

func (MysqlProvider) SelectUsers added in v0.2.0 

func (provider MysqlProvider) SelectUsers() StoreResult

func (MysqlProvider) SelectUsersForRoom added in v0.2.0 

func (provider MysqlProvider) SelectUsersForRoom(roomId string) StoreResult

func (MysqlProvider) UpdateDevice added in v0.2.0 

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

func (MysqlProvider) UpdateMessage added in v0.2.0 

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

func (MysqlProvider) UpdateRoom added in v0.2.0 

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

func (MysqlProvider) UpdateRoomDeleted added in v0.2.0 

func (provider MysqlProvider) UpdateRoomDeleted(roomId string) StoreResult

func (MysqlProvider) UpdateRoomUser added in v0.2.0 

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

func (MysqlProvider) UpdateUser added in v0.2.0 

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

func (MysqlProvider) UpdateUserDeleted added in v0.2.0 

func (provider MysqlProvider) UpdateUserDeleted(userId string) StoreResult

type Provider 

type Provider interface {
	Connect() error
	Init()
	DropDatabase() error
	ApiStore
	UserStore
	BlockUserStore
	RoomStore
	RoomUserStore
	MessageStore
	DeviceStore
	SubscriptionStore
}

func GetProvider 

func GetProvider() Provider

type RoomStore 

type RoomStore interface {
	CreateRoomStore()

	InsertRoom(room *models.Room) StoreResult
	SelectRoom(roomId string) StoreResult
	SelectRooms() StoreResult
	SelectUsersForRoom(roomId string) StoreResult
	SelectCountRooms() StoreResult
	UpdateRoom(room *models.Room) StoreResult
	UpdateRoomDeleted(roomId string) StoreResult
}

type RoomUserStore 

type RoomUserStore interface {
	CreateRoomUserStore()

	DeleteAndInsertRoomUsers(roomUsers []*models.RoomUser) StoreResult
	InsertRoomUsers(roomUsers []*models.RoomUser) StoreResult
	SelectRoomUser(roomId, userId string) StoreResult
	SelectRoomUsersByRoomId(roomId string) StoreResult
	SelectRoomUsersByUserId(userId string) StoreResult
	SelectRoomUsersByRoomIdAndUserIds(roomId *string, userIds []string) StoreResult
	UpdateRoomUser(*models.RoomUser) StoreResult
	DeleteRoomUser(roomId string, userIds []string) StoreResult
}

type SqliteProvider 

type SqliteProvider struct {
	// contains filtered or unexported fields
}

func (SqliteProvider) Connect 

func (provider SqliteProvider) Connect() error

func (SqliteProvider) CreateApiStore added in v0.6.0 

func (provider SqliteProvider) CreateApiStore()

func (SqliteProvider) CreateBlockUserStore added in v0.7.0 

func (provider SqliteProvider) CreateBlockUserStore()

func (SqliteProvider) CreateDeviceStore added in v0.2.0 

func (provider SqliteProvider) CreateDeviceStore()

func (SqliteProvider) CreateMessageStore added in v0.2.0 

func (provider SqliteProvider) CreateMessageStore()

func (SqliteProvider) CreateRoomStore added in v0.2.0 

func (provider SqliteProvider) CreateRoomStore()

func (SqliteProvider) CreateRoomUserStore added in v0.2.0 

func (provider SqliteProvider) CreateRoomUserStore()

func (SqliteProvider) CreateSubscriptionStore added in v0.2.0 

func (provider SqliteProvider) CreateSubscriptionStore()

func (SqliteProvider) CreateUserStore added in v0.2.0 

func (provider SqliteProvider) CreateUserStore()

func (SqliteProvider) DeleteAndInsertRoomUsers added in v0.2.0 

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

func (SqliteProvider) DeleteBlockUser added in v0.7.0 

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

func (SqliteProvider) DeleteDevice added in v0.2.0 

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

func (SqliteProvider) DeleteRoomUser added in v0.2.0 

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

func (SqliteProvider) DeleteSubscription added in v0.2.0 

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

func (SqliteProvider) DropDatabase 

func (provider SqliteProvider) DropDatabase() error

func (SqliteProvider) Init 

func (provider SqliteProvider) Init()

func (SqliteProvider) InsertApi added in v0.6.0 

func (provider SqliteProvider) InsertApi(name string) StoreResult

func (SqliteProvider) InsertBlockUsers added in v0.7.0 

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

func (SqliteProvider) InsertDevice added in v0.2.0 

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

func (SqliteProvider) InsertMessage added in v0.2.0 

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

func (SqliteProvider) InsertRoom added in v0.2.0 

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

func (SqliteProvider) InsertRoomUsers added in v0.2.0 

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

func (SqliteProvider) InsertSubscription added in v0.2.0 

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

func (SqliteProvider) InsertUser added in v0.2.0 

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

func (SqliteProvider) SelectBlockUser added in v0.7.0 

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

func (SqliteProvider) SelectBlockUsersByUserId added in v0.7.0 

func (provider SqliteProvider) SelectBlockUsersByUserId(userId string) StoreResult

func (SqliteProvider) SelectContacts added in v0.7.0 

func (provider SqliteProvider) SelectContacts(userId string) StoreResult

func (SqliteProvider) SelectCountMessagesByRoomId added in v0.2.0 

func (provider SqliteProvider) SelectCountMessagesByRoomId(roomId string) StoreResult

func (SqliteProvider) SelectCountRooms added in v0.2.0 

func (provider SqliteProvider) SelectCountRooms() StoreResult

func (SqliteProvider) SelectDeletedSubscriptionsByRoomId added in v0.7.1 

func (provider SqliteProvider) SelectDeletedSubscriptionsByRoomId(roomId string) StoreResult

func (SqliteProvider) SelectDeletedSubscriptionsByUserId added in v0.7.1 

func (provider SqliteProvider) SelectDeletedSubscriptionsByUserId(userId string) StoreResult

func (SqliteProvider) SelectDeletedSubscriptionsByUserIdAndPlatform added in v0.7.1 

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

func (SqliteProvider) SelectDevice added in v0.2.0 

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

func (SqliteProvider) SelectDevices added in v0.2.0 

func (provider SqliteProvider) SelectDevices(userId string) StoreResult

func (SqliteProvider) SelectDevicesByToken added in v0.7.1 

func (provider SqliteProvider) SelectDevicesByToken(token string) StoreResult

func (SqliteProvider) SelectDevicesByUserId added in v0.2.0 

func (provider SqliteProvider) SelectDevicesByUserId(userId string) StoreResult

func (SqliteProvider) SelectLatestApi added in v0.6.0 

func (provider SqliteProvider) SelectLatestApi(name string) StoreResult

func (SqliteProvider) SelectMessage added in v0.2.0 

func (provider SqliteProvider) SelectMessage(messageId string) StoreResult

func (SqliteProvider) SelectMessages added in v0.2.0 

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

func (SqliteProvider) SelectRoom added in v0.2.0 

func (provider SqliteProvider) SelectRoom(roomId string) StoreResult

func (SqliteProvider) SelectRoomUser added in v0.2.0 

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

func (SqliteProvider) SelectRoomUsersByRoomId added in v0.2.0 

func (provider SqliteProvider) SelectRoomUsersByRoomId(roomId string) StoreResult

func (SqliteProvider) SelectRoomUsersByRoomIdAndUserIds added in v0.2.0 

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

func (SqliteProvider) SelectRoomUsersByUserId added in v0.2.0 

func (provider SqliteProvider) SelectRoomUsersByUserId(userId string) StoreResult

func (SqliteProvider) SelectRooms added in v0.2.0 

func (provider SqliteProvider) SelectRooms() StoreResult

func (SqliteProvider) SelectSubscription added in v0.2.0 

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

func (SqliteProvider) SelectUser added in v0.2.0 

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

func (SqliteProvider) SelectUserByUserIdAndAccessToken added in v0.5.0 

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

func (SqliteProvider) SelectUserIdsByUserIds added in v0.2.0 

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

func (SqliteProvider) SelectUsers added in v0.2.0 

func (provider SqliteProvider) SelectUsers() StoreResult

func (SqliteProvider) SelectUsersForRoom added in v0.2.0 

func (provider SqliteProvider) SelectUsersForRoom(roomId string) StoreResult

func (SqliteProvider) UpdateDevice added in v0.2.0 

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

func (SqliteProvider) UpdateMessage added in v0.2.0 

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

func (SqliteProvider) UpdateRoom added in v0.2.0 

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

func (SqliteProvider) UpdateRoomDeleted added in v0.2.0 

func (provider SqliteProvider) UpdateRoomDeleted(roomId string) StoreResult

func (SqliteProvider) UpdateRoomUser added in v0.2.0 

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

func (SqliteProvider) UpdateUser added in v0.2.0 

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

func (SqliteProvider) UpdateUserDeleted added in v0.2.0 

func (provider SqliteProvider) UpdateUserDeleted(userId string) StoreResult

type StoreChannel 

type StoreChannel chan StoreResult

type StoreResult 

type StoreResult struct {
	Data          interface{}
	ProblemDetail *models.ProblemDetail
}

func RdbDeleteAndInsertRoomUsers added in v0.2.0 

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

func RdbDeleteBlockUser added in v0.7.0 

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

func RdbDeleteDevice added in v0.2.0 

func RdbDeleteDevice(userId string, platform int) StoreResult

func RdbDeleteRoomUser added in v0.2.0 

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

func RdbDeleteSubscription added in v0.2.0 

func RdbDeleteSubscription(subscription *models.Subscription) StoreResult

func RdbInsertApi added in v0.6.0 

func RdbInsertApi(name string) StoreResult

func RdbInsertBlockUsers added in v0.7.0 

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

func RdbInsertDevice added in v0.2.0 

func RdbInsertDevice(device *models.Device) StoreResult

func RdbInsertMessage added in v0.2.0 

func RdbInsertMessage(message *models.Message) StoreResult

func RdbInsertRoom added in v0.2.0 

func RdbInsertRoom(room *models.Room) StoreResult

func RdbInsertRoomUsers added in v0.2.0 

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

func RdbInsertSubscription added in v0.2.0 

func RdbInsertSubscription(subscription *models.Subscription) StoreResult

func RdbInsertUser added in v0.2.0 

func RdbInsertUser(user *models.User) StoreResult

func RdbSelectBlockUser added in v0.7.0 

func RdbSelectBlockUser(userId, blockUserId string) StoreResult

func RdbSelectBlockUsersByUserId added in v0.7.0 

func RdbSelectBlockUsersByUserId(userId string) StoreResult

func RdbSelectContacts added in v0.7.0 

func RdbSelectContacts(userId string) StoreResult

func RdbSelectCountMessagesByRoomId added in v0.2.0 

func RdbSelectCountMessagesByRoomId(roomId string) StoreResult

func RdbSelectCountRooms added in v0.2.0 

func RdbSelectCountRooms() StoreResult

func RdbSelectDeletedSubscriptionsByRoomId added in v0.7.1 

func RdbSelectDeletedSubscriptionsByRoomId(roomId string) StoreResult

func RdbSelectDeletedSubscriptionsByUserId added in v0.7.1 

func RdbSelectDeletedSubscriptionsByUserId(userId string) StoreResult

func RdbSelectDeletedSubscriptionsByUserIdAndPlatform added in v0.7.1 

func RdbSelectDeletedSubscriptionsByUserIdAndPlatform(userId string, platform int) StoreResult

func RdbSelectDevice added in v0.2.0 

func RdbSelectDevice(userId string, platform int) StoreResult

func RdbSelectDevices added in v0.2.0 

func RdbSelectDevices(userId string) StoreResult

func RdbSelectDevicesByToken added in v0.7.1 

func RdbSelectDevicesByToken(token string) StoreResult

func RdbSelectDevicesByUserId added in v0.2.0 

func RdbSelectDevicesByUserId(userId string) StoreResult

func RdbSelectLatestApi added in v0.6.0 

func RdbSelectLatestApi(name string) StoreResult

func RdbSelectMessage added in v0.2.0 

func RdbSelectMessage(messageId string) StoreResult

func RdbSelectMessages added in v0.2.0 

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

func RdbSelectRoom added in v0.2.0 

func RdbSelectRoom(roomId string) StoreResult

func RdbSelectRoomUser added in v0.2.0 

func RdbSelectRoomUser(roomId, userId string) StoreResult

func RdbSelectRoomUsersByRoomId added in v0.2.0 

func RdbSelectRoomUsersByRoomId(roomId string) StoreResult

func RdbSelectRoomUsersByRoomIdAndUserIds added in v0.2.0 

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

func RdbSelectRoomUsersByUserId added in v0.2.0 

func RdbSelectRoomUsersByUserId(userId string) StoreResult

func RdbSelectRooms added in v0.2.0 

func RdbSelectRooms() StoreResult

func RdbSelectSubscription added in v0.2.0 

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

func RdbSelectUser added in v0.2.0 

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

func RdbSelectUserByUserIdAndAccessToken added in v0.5.0 

func RdbSelectUserByUserIdAndAccessToken(userId, accessToken string) StoreResult

func RdbSelectUserIdsByUserIds added in v0.2.0 

func RdbSelectUserIdsByUserIds(userIds []string) StoreResult

func RdbSelectUsers added in v0.2.0 

func RdbSelectUsers() StoreResult

func RdbSelectUsersForRoom added in v0.2.0 

func RdbSelectUsersForRoom(roomId string) StoreResult

func RdbUpdateDevice added in v0.2.0 

func RdbUpdateDevice(device *models.Device) StoreResult

func RdbUpdateMessage added in v0.2.0 

func RdbUpdateMessage(message *models.Message) StoreResult

func RdbUpdateRoom added in v0.2.0 

func RdbUpdateRoom(room *models.Room) StoreResult

func RdbUpdateRoomDeleted added in v0.2.0 

func RdbUpdateRoomDeleted(roomId string) StoreResult

func RdbUpdateRoomUser added in v0.2.0 

func RdbUpdateRoomUser(roomUser *models.RoomUser) StoreResult

func RdbUpdateUser added in v0.2.0 

func RdbUpdateUser(user *models.User) StoreResult

func RdbUpdateUserDeleted added in v0.2.0 

func RdbUpdateUserDeleted(userId string) StoreResult

type SubscriptionStore added in v0.2.0 

type SubscriptionStore interface {
	CreateSubscriptionStore()

	InsertSubscription(subscription *models.Subscription) StoreResult
	SelectSubscription(roomId, userId string, platform int) StoreResult
	SelectDeletedSubscriptionsByRoomId(roomId string) StoreResult
	SelectDeletedSubscriptionsByUserId(userId string) StoreResult
	SelectDeletedSubscriptionsByUserIdAndPlatform(userId string, platform int) StoreResult
	DeleteSubscription(subscription *models.Subscription) StoreResult
}

type UserStore 

type UserStore interface {
	CreateUserStore()

	InsertUser(user *models.User) StoreResult
	SelectUser(userId string, isWithRooms, isWithDevices, isWithBlocks bool) StoreResult
	SelectUserByUserIdAndAccessToken(userId, accessToken string) StoreResult
	SelectUsers() StoreResult
	SelectUserIdsByUserIds(userIds []string) StoreResult
	UpdateUser(user *models.User) StoreResult
	UpdateUserDeleted(userId string) StoreResult
	SelectContacts(userId string) StoreResult
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.