datastore

package
v0.3.2 Latest Latest
Warning

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

 Go to latest Published: May 1, 2017 License: MIT Imports: 20 Imported by: 6

Documentation

Index

Constants

View Source 
const (
	TABLE_NAME_USER         = "user"
	TABLE_NAME_ROOM         = "room"
	TABLE_NAME_ROOM_USER    = "room_user"
	TABLE_NAME_MESSAGE      = "message"
	TABLE_NAME_DEVICE       = "device"
	TABLE_NAME_SUBSCRIPTION = "subscription"
)

Variables

This section is empty.

Functions

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 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
	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) 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) 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) 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) 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) 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) SelectDevicesByUserId added in v0.2.0 

func (provider GcpSqlProvider) SelectDevicesByUserId(userId 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) 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) SelectSubscriptionsByRoomId added in v0.2.0 

func (provider GcpSqlProvider) SelectSubscriptionsByRoomId(roomId string) StoreResult

func (GcpSqlProvider) SelectSubscriptionsByRoomIdAndPlatform added in v0.2.0 

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

func (GcpSqlProvider) SelectSubscriptionsByUserId added in v0.2.0 

func (provider GcpSqlProvider) SelectSubscriptionsByUserId(userId string) StoreResult

func (GcpSqlProvider) SelectSubscriptionsByUserIdAndPlatform added in v0.2.0 

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

func (GcpSqlProvider) SelectUser added in v0.2.0 

func (provider GcpSqlProvider) SelectUser(userId string, isWithRooms, isWithDevices bool) 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) 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) 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) 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) 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) 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) 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) SelectDevicesByUserId added in v0.2.0 

func (provider MysqlProvider) SelectDevicesByUserId(userId 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) 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) SelectSubscriptionsByRoomId added in v0.2.0 

func (provider MysqlProvider) SelectSubscriptionsByRoomId(roomId string) StoreResult

func (MysqlProvider) SelectSubscriptionsByRoomIdAndPlatform added in v0.2.0 

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

func (MysqlProvider) SelectSubscriptionsByUserId added in v0.2.0 

func (provider MysqlProvider) SelectSubscriptionsByUserId(userId string) StoreResult

func (MysqlProvider) SelectSubscriptionsByUserIdAndPlatform added in v0.2.0 

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

func (MysqlProvider) SelectUser added in v0.2.0 

func (provider MysqlProvider) SelectUser(userId string, isWithRooms, isWithDevices bool) 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
	UserStore
	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) 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) 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) 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) 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) 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) SelectDevicesByUserId added in v0.2.0 

func (provider SqliteProvider) SelectDevicesByUserId(userId 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) 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) SelectSubscriptionsByRoomId added in v0.2.0 

func (provider SqliteProvider) SelectSubscriptionsByRoomId(roomId string) StoreResult

func (SqliteProvider) SelectSubscriptionsByRoomIdAndPlatform added in v0.2.0 

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

func (SqliteProvider) SelectSubscriptionsByUserId added in v0.2.0 

func (provider SqliteProvider) SelectSubscriptionsByUserId(userId string) StoreResult

func (SqliteProvider) SelectSubscriptionsByUserIdAndPlatform added in v0.2.0 

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

func (SqliteProvider) SelectUser added in v0.2.0 

func (provider SqliteProvider) SelectUser(userId string, isWithRooms, isWithDevices bool) 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 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 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 RdbSelectCountMessagesByRoomId added in v0.2.0 

func RdbSelectCountMessagesByRoomId(roomId string) StoreResult

func RdbSelectCountRooms added in v0.2.0 

func RdbSelectCountRooms() 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 RdbSelectDevicesByUserId added in v0.2.0 

func RdbSelectDevicesByUserId(userId 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) 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 RdbSelectSubscriptionsByRoomId added in v0.2.0 

func RdbSelectSubscriptionsByRoomId(roomId string) StoreResult

func RdbSelectSubscriptionsByRoomIdAndPlatform added in v0.2.0 

func RdbSelectSubscriptionsByRoomIdAndPlatform(roomId string, platform int) StoreResult

func RdbSelectSubscriptionsByUserId added in v0.2.0 

func RdbSelectSubscriptionsByUserId(userId string) StoreResult

func RdbSelectSubscriptionsByUserIdAndPlatform added in v0.2.0 

func RdbSelectSubscriptionsByUserIdAndPlatform(userId string, platform int) StoreResult

func RdbSelectUser added in v0.2.0 

func RdbSelectUser(userId string, isWithRooms, isWithDevices bool) 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
	SelectSubscriptionsByRoomId(roomId string) StoreResult
	SelectSubscriptionsByUserId(userId string) StoreResult
	SelectSubscriptionsByRoomIdAndPlatform(roomId string, platform int) StoreResult
	SelectSubscriptionsByUserIdAndPlatform(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 bool) StoreResult
	SelectUsers() StoreResult
	SelectUserIdsByUserIds(userIds []string) StoreResult
	UpdateUser(user *models.User) StoreResult
	UpdateUserDeleted(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.