metathings_moqusitto_plugin_storage

Documentation

Index

• Variables
• type MongoStorage
  • func (s *MongoStorage) AddPermission(u string, p *Permission) error
  • func (s *MongoStorage) AddUser(u *User) error
  • func (s *MongoStorage) ExistUser(u string) (bool, error)
  • func (s *MongoStorage) GetUser(u string) (*User, error)
  • func (s *MongoStorage) RemovePermission(u string, t string) error
  • func (s *MongoStorage) RemoveUser(u string) error
• type MongoStorageFactory
  • func (*MongoStorageFactory) New(args ...interface{}) (Storage, error)
• type MongoStorageOption
• type Permission
• type Storage
  • func NewStorage(name string, args ...interface{}) (Storage, error)
• type StorageFactory
• type User

Variables

var (
	ErrUnknownStorageDriver = errors.New(" unknown storage driver")
)

Types

type MongoStorage

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

func (*MongoStorage) AddPermission

func (s *MongoStorage) AddPermission(u string, p *Permission) error

func (*MongoStorage) AddUser

func (s *MongoStorage) AddUser(u *User) error

func (*MongoStorage) ExistUser

func (s *MongoStorage) ExistUser(u string) (bool, error)

func (*MongoStorage) GetUser

func (s *MongoStorage) GetUser(u string) (*User, error)

func (*MongoStorage) RemovePermission

func (s *MongoStorage) RemovePermission(u string, t string) error

func (*MongoStorage) RemoveUser

func (s *MongoStorage) RemoveUser(u string) error

type MongoStorageFactory

type MongoStorageFactory struct{}

func (*MongoStorageFactory) New

func (*MongoStorageFactory) New(args ...interface{}) (Storage, error)

type MongoStorageOption

type MongoStorageOption struct {
	Mongo struct {
		Uri        string
		Database   string
		Collection string
	}
	Pool struct {
		Initial int
		Max     int
	}
}

type Permission

type Permission struct {
	Topic *string
	Mask  *string
}

type Storage

type Storage interface {
	AddUser(*User) error
	RemoveUser(string) error
	AddPermission(string, *Permission) error
	RemovePermission(username string, topic string) error
	GetUser(string) (*User, error)
	ExistUser(string) (bool, error)
}

func NewStorage

func NewStorage(name string, args ...interface{}) (Storage, error)

type StorageFactory

type StorageFactory interface {
	New(...interface{}) (Storage, error)
}

type User

type User struct {
	Username    *string
	Password    *string
	Superuser   *bool
	Permissions []*Permission
}