mongo

Documentation

Index

• Constants
• Variables
• func IDStringFromResult(oid interface{}) string
• func IDToObjectID(id string) (primitive.ObjectID, error)
• func IDsToObjectIDs(ids []string) ([]primitive.ObjectID, error)
• func NewMongoDatastore() (datastore.Datastore, error)
• func ToObjectID(id string) (primitive.ObjectID, error)
• type CourseStore
  • func (s *CourseStore) Count(c context.Context) (int64, error)
  • func (s *CourseStore) Get(c context.Context, id string) (*models.Course, error)
  • func (s *CourseStore) GetAll(c context.Context) ([]*models.Course, error)
  • func (s *CourseStore) Save(c context.Context, course *models.Course) error
• type FileInfoStore
  • func (s *FileInfoStore) Count(c context.Context) (int64, error)
  • func (s *FileInfoStore) Get(c context.Context, id string) (*models.FileInfo, error)
  • func (s *FileInfoStore) GetAll(c context.Context) ([]*models.FileInfo, error)
  • func (s *FileInfoStore) Save(c context.Context, fi *models.FileInfo) error
• type Model
• type MongoDatastore
  • func (s *MongoDatastore) Coll(name string) *mongo.Collection
  • func (s *MongoDatastore) Count(c context.Context, collection string) (int64, error)
  • func (s *MongoDatastore) Course() datastore.CourseStore
  • func (s *MongoDatastore) FileInfo() datastore.FileInfoStore
  • func (s *MongoDatastore) Find(c context.Context, collection string, decode interface{}) error
  • func (s *MongoDatastore) FindByID(c context.Context, collection string, id string, decode interface{}) error
  • func (s *MongoDatastore) FindByIDs(c context.Context, collection string, ids []string, decode interface{}) error
  • func (s *MongoDatastore) Insert(c context.Context, collection string, model interface{}) (string, error)
  • func (s *MongoDatastore) TestConnection(c context.Context) error
  • func (s *MongoDatastore) Update(c context.Context, collection string, model Model) error
  • func (s *MongoDatastore) User() datastore.UserStore
• type UserStore
  • func (s *UserStore) Count(c context.Context) (int64, error)
  • func (s *UserStore) Get(c context.Context, id string) (*models.User, error)
  • func (s *UserStore) GetAll(c context.Context, opts *models.UserGetOptions) ([]*models.User, error)
  • func (s *UserStore) GetByIDs(c context.Context, userIDs []string) ([]*models.User, error)
  • func (s *UserStore) GetByUsername(c context.Context, username string) (*models.User, error)
  • func (s *UserStore) Save(c context.Context, user *models.User) error
  • func (s *UserStore) Update(c context.Context, user *models.User) error

Constants

const (
	USERS = "users"
)

Variables

var (
	ErrConnectionRefused = errors.New("Cannot connect to database")
)

var (
	ErrCourseExists = errors.New("datastore.mongo.user.save.user_exists")
)

var (
	ErrUserExists = errors.New("datastore.mongo.user.save.user_exists")
)

Functions

func IDStringFromResult

func IDStringFromResult(oid interface{}) string

func IDToObjectID

func IDToObjectID(id string) (primitive.ObjectID, error)

func IDsToObjectIDs

func IDsToObjectIDs(ids []string) ([]primitive.ObjectID, error)

func NewMongoDatastore

func NewMongoDatastore() (datastore.Datastore, error)

func ToObjectID

func ToObjectID(id string) (primitive.ObjectID, error)

Types

type CourseStore

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

func (*CourseStore) Count

func (s *CourseStore) Count(c context.Context) (int64, error)

func (*CourseStore) Get

func (s *CourseStore) Get(c context.Context, id string) (*models.Course, error)

func (*CourseStore) GetAll

func (s *CourseStore) GetAll(c context.Context) ([]*models.Course, error)

func (*CourseStore) Save

func (s *CourseStore) Save(c context.Context, course *models.Course) error

type FileInfoStore

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

func (*FileInfoStore) Count

func (s *FileInfoStore) Count(c context.Context) (int64, error)

func (*FileInfoStore) Get

func (s *FileInfoStore) Get(c context.Context, id string) (*models.FileInfo, error)

func (*FileInfoStore) GetAll

func (s *FileInfoStore) GetAll(c context.Context) ([]*models.FileInfo, error)

func (*FileInfoStore) Save

func (s *FileInfoStore) Save(c context.Context, fi *models.FileInfo) error

type Model

type Model interface {
	GetID() string
	SetID(string)
}

type MongoDatastore

type MongoDatastore struct {
	DB     *mongo.Database
	Client *mongo.Client
	// contains filtered or unexported fields
}

func (*MongoDatastore) Coll

func (s *MongoDatastore) Coll(name string) *mongo.Collection

func (*MongoDatastore) Count

func (s *MongoDatastore) Count(c context.Context, collection string) (int64, error)

func (*MongoDatastore) Course

func (s *MongoDatastore) Course() datastore.CourseStore

func (*MongoDatastore) FileInfo

func (s *MongoDatastore) FileInfo() datastore.FileInfoStore

func (*MongoDatastore) Find

func (s *MongoDatastore) Find(c context.Context, collection string, decode interface{}) error

func (*MongoDatastore) FindByID

func (s *MongoDatastore) FindByID(c context.Context, collection string, id string, decode interface{}) error

func (*MongoDatastore) FindByIDs

func (s *MongoDatastore) FindByIDs(c context.Context, collection string, ids []string, decode interface{}) error

func (*MongoDatastore) Insert

func (s *MongoDatastore) Insert(c context.Context, collection string, model interface{}) (string, error)

func (*MongoDatastore) TestConnection

func (s *MongoDatastore) TestConnection(c context.Context) error

func (*MongoDatastore) Update

func (s *MongoDatastore) Update(c context.Context, collection string, model Model) error

func (*MongoDatastore) User

func (s *MongoDatastore) User() datastore.UserStore

type UserStore

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

func (*UserStore) Count

func (s *UserStore) Count(c context.Context) (int64, error)

func (*UserStore) Get

func (s *UserStore) Get(c context.Context, id string) (*models.User, error)

func (*UserStore) GetAll

func (s *UserStore) GetAll(c context.Context, opts *models.UserGetOptions) ([]*models.User, error)

func (*UserStore) GetByIDs

func (s *UserStore) GetByIDs(c context.Context, userIDs []string) ([]*models.User, error)

func (*UserStore) GetByUsername

func (s *UserStore) GetByUsername(c context.Context, username string) (*models.User, error)

func (*UserStore) Save

func (s *UserStore) Save(c context.Context, user *models.User) error

func (*UserStore) Update

func (s *UserStore) Update(c context.Context, user *models.User) error