service

type Broker struct {

	// Events are pushed to this channel by the main events-gathering routine
	Notifier chan []byte
	// contains filtered or unexported fields
}

type BrokerEvent struct {
	Event     string      `json:"event"`
	User      string      `json:"user_id,omitempty"`
	Namespace string      `json:"namespace"`
	Key       string      `json:"key,omitempty"`
	Value     interface{} `json:"value,omitempty"`
}

type Database interface {
	Init()
	Upsert(namespace string, key string, value []byte) *database.DbError
	Get(namespace string, key string) ([]byte, *database.DbError)
	GetAll(namespace string) (map[string][]byte, *database.DbError)
	Delete(namespace string, key string) *database.DbError
	DeleteAll(namespace string) *database.DbError
	GetNamespaces() []string
}

type JWTAuthMiddleware struct {
	VerifyBytes []byte
}

type Payload struct {
	User string      `json:"user_id"`
	Data interface{} `json:"data"`
}

type Server struct {
	Address     string
	AuthEnabled bool
	// contains filtered or unexported fields
}

type TestingRouter struct {
	Router *mux.Router
}