inmem

package

v0.0.0-...-471d7c0 Latest Latest Go to latest Published: Sep 21, 2016 License: MIT Imports: 4 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type DB struct {
	UserDB
}

DB is an in-memory database.

func NewDB() *DB

NewDB creates a new in-memory database.

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

Queue is a message queue for queueing and sending messages to users.

func NewQueue(senderFunc SenderFunc) *Queue

NewQueue creates a new queue object.

func (q *Queue) AddRequest(userID string, method string, params interface{}, resHandler func(ctx *neptulon.ResCtx) error) error

AddRequest queues a request message to be sent to the given user.

func (q *Queue) Middleware(ctx *neptulon.ReqCtx) error

Middleware registers a queue middleware to register user/connection IDs for connecting users (upon their first incoming-message).

func (q *Queue) RemoveConn(userID string)

RemoveConn removes a user's associated connection ID.

type SenderFunc func(connID string, method string, params interface{}, resHandler func(ctx *neptulon.ResCtx) error) (reqID string, err error)

SenderFunc is a function for sending messages over connections ID.

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

UserDB is in-memory user database.

func (db UserDB) GetByEmail(email string) (u *models.User, ok bool)

GetByEmail retrieves a user by e-mail address.

func (db UserDB) GetByID(id string) (u *models.User, ok bool)

GetByID retrieves a user by ID.

func (db UserDB) SaveUser(u *models.User) error

SaveUser save or updates a user object in the database.

func (db UserDB) Seed(overwrite bool, jwtPass string) error

Seed seeds database with essential data.