repository

Documentation

Index

• func MustInit(config *Config, logger *log.Logger) error
• type Config
• type Context
  • func (ctx *Context) Decode(value string) error
• type IRepo
• type Repository
  • func (r *Repository) DeletePlanets(planets []model.Planet) (*mongo.DeleteResult, error)
  • func (r *Repository) Disconnect() error
  • func (r *Repository) GetAllPlanets() ([]*model.Planet, error)
  • func (r *Repository) GetPlanet(filter interface{}, model *model.Planet) error
  • func (r *Repository) InsertPlanets(planets []model.Planet) (*mongo.InsertManyResult, error)
  • func (r *Repository) Planets() *mongo.Collection
  • func (r *Repository) UpdateMovieRefs(planets []swapi.Planet) (*mongo.BulkWriteResult, error)
  • func (r *Repository) UpdatePlanets(planets []model.Planet) (*mongo.BulkWriteResult, error)

Functions

func MustInit

func MustInit(config *Config, logger *log.Logger) error

Types

type Config

type Config struct {
	Username string  `default:"mongo_user"`
	Password string  `default:"mongo_pass"`
	Host     string  `default:"localhost"`
	Port     string  `default:"27017"`
	AuthDB   string  `default:"test"`
	Context  Context `default:"TODO"`
}

Config - Configuration for logging

type Context

type Context struct {
	context.Context
}

func (*Context) Decode

func (ctx *Context) Decode(value string) error

type IRepo

type IRepo interface {
	GetPlanet(interface{}, *model.Planet) error
	GetAllPlanets() ([]*model.Planet, error)
	InsertPlanets([]model.Planet) (*mongo.InsertManyResult, error)
	UpdatePlanets([]model.Planet) (*mongo.BulkWriteResult, error)
	UpdateMovieRefs([]swapi.Planet) (*mongo.BulkWriteResult, error)
	DeletePlanets([]model.Planet) (*mongo.DeleteResult, error)
}

type Repository

type Repository struct {
	*mongo.Client
	Context context.Context
	Logger  *log.Logger
}

var Repo Repository

func (*Repository) DeletePlanets

func (r *Repository) DeletePlanets(planets []model.Planet) (*mongo.DeleteResult, error)

func (*Repository) Disconnect

func (r *Repository) Disconnect() error

func (*Repository) GetAllPlanets

func (r *Repository) GetAllPlanets() ([]*model.Planet, error)

func (*Repository) GetPlanet

func (r *Repository) GetPlanet(filter interface{}, model *model.Planet) error

func (*Repository) InsertPlanets

func (r *Repository) InsertPlanets(planets []model.Planet) (*mongo.InsertManyResult, error)

func (*Repository) Planets

func (r *Repository) Planets() *mongo.Collection

func (*Repository) UpdateMovieRefs

func (r *Repository) UpdateMovieRefs(planets []swapi.Planet) (*mongo.BulkWriteResult, error)

func (*Repository) UpdatePlanets

func (r *Repository) UpdatePlanets(planets []model.Planet) (*mongo.BulkWriteResult, error)