Documentation
¶
Overview ¶
Package controller contains root neuron structure. It is responsible for getting access to registered models and their repositories. It contains the configuration, validators and default query processor.
Index ¶
- Variables
- func CtxStore(parent context.Context, c *Controller) context.Context
- type Controller
- func (c *Controller) CloseAll(ctx context.Context) error
- func (c *Controller) DialAll(ctx context.Context) error
- func (c *Controller) GetRepository(model mapping.Model) (repository.Repository, error)
- func (c *Controller) GetRepositoryByModelStruct(mStruct *mapping.ModelStruct) (repository.Repository, error)
- func (c *Controller) HealthCheck(ctx context.Context) (*repository.HealthResponse, error)
- func (c *Controller) ListModels() []*mapping.ModelStruct
- func (c *Controller) MapRepositoryModels(r repository.Repository, models ...mapping.Model) (err error)
- func (c *Controller) MigrateModels(ctx context.Context, models ...mapping.Model) error
- func (c *Controller) ModelStruct(model mapping.Model) (*mapping.ModelStruct, error)
- func (c *Controller) MustModelStruct(model mapping.Model) *mapping.ModelStruct
- func (c *Controller) Now() time.Time
- func (c *Controller) RegisterModels(models ...mapping.Model) (err error)
- func (c *Controller) RegisterRepositories(repositories ...repository.Repository)
- func (c *Controller) SetDefaultRepository(r repository.Repository) error
- func (c *Controller) VerifyModelRepositories() error
- type Options
Constants ¶
This section is empty.
Variables ¶
var ( // ErrController defines major classification for the controller. ErrController = errors.New("controller") // ErrRepository is an error related with the repository. ErrRepository = errors.Wrap(ErrController, "repository") // ErrRepositoryNotFound is an error when repository is not found. ErrRepositoryNotFound = errors.Wrap(ErrRepository, "not found") // ErrRepositoryAlreadyRegistered class of errors when repository is already registered. ErrRepositoryAlreadyRegistered = errors.Wrap(ErrRepository, "already registered") )
Functions ¶
Types ¶
type Controller ¶
type Controller struct { // Config is the configuration struct for the controller. Options *Options // ModelMap is a mapping for the model's structures. ModelMap *mapping.ModelMap // Repositories are the controller registered repositories. Repositories map[string]repository.Repository // ModelRepositories is the mapping between the model and related repositories. ModelRepositories map[*mapping.ModelStruct]repository.Repository // DefaultService is the default service or given controller. DefaultRepository repository.Repository }
Controller is the structure that contains, initialize and control the flow of the application. It contains repositories, model definitions.
func CtxGet ¶ added in v0.16.0
func CtxGet(ctx context.Context) (*Controller, bool)
CtxGet gets the controller from the context.
func NewDefault ¶
func NewDefault() *Controller
NewDefault creates new default controller based on the default config.
func (*Controller) CloseAll ¶ added in v0.15.0
func (c *Controller) CloseAll(ctx context.Context) error
CloseAll gently closes repository connections.
func (*Controller) DialAll ¶ added in v0.15.0
func (c *Controller) DialAll(ctx context.Context) error
DialAll establish connections for all repositories.
func (*Controller) GetRepository ¶ added in v0.15.0
func (c *Controller) GetRepository(model mapping.Model) (repository.Repository, error)
GetRepository gets the repository for the provided model.
func (*Controller) GetRepositoryByModelStruct ¶ added in v0.16.0
func (c *Controller) GetRepositoryByModelStruct(mStruct *mapping.ModelStruct) (repository.Repository, error)
GetRepositoryByModelStruct gets the service by model struct.
func (*Controller) HealthCheck ¶ added in v0.15.0
func (c *Controller) HealthCheck(ctx context.Context) (*repository.HealthResponse, error)
HealthCheck checks all repositories health.
func (*Controller) ListModels ¶ added in v0.15.0
func (c *Controller) ListModels() []*mapping.ModelStruct
ListModels returns a list of registered models for given controller.
func (*Controller) MapRepositoryModels ¶ added in v0.16.0
func (c *Controller) MapRepositoryModels(r repository.Repository, models ...mapping.Model) (err error)
MapRepositoryModels maps models to their repositories. If the model doesn't have repository name mapped then the controller would match default repository.
func (*Controller) MigrateModels ¶ added in v0.15.0
MigrateModels updates or creates provided models representation in their related repositories. A representation of model might be a database table, collection etc. Model's repository must implement repository.Migrator.
func (*Controller) ModelStruct ¶
func (c *Controller) ModelStruct(model mapping.Model) (*mapping.ModelStruct, error)
ModelStruct gets the model struct on the base of the provided model
func (*Controller) MustModelStruct ¶ added in v0.15.0
func (c *Controller) MustModelStruct(model mapping.Model) *mapping.ModelStruct
MustModelStruct gets the model struct from the cached model Map. Panics if the model does not exists in the map.
func (*Controller) Now ¶ added in v0.15.0
func (c *Controller) Now() time.Time
Now gets and returns current timestamp. If the configs specify the function might return UTC timestamp.
func (*Controller) RegisterModels ¶
func (c *Controller) RegisterModels(models ...mapping.Model) (err error)
RegisterModels registers provided models within the context of the provided Controller.
func (*Controller) RegisterRepositories ¶ added in v0.16.0
func (c *Controller) RegisterRepositories(repositories ...repository.Repository)
RegisterRepositories registers provided repositories.
func (*Controller) SetDefaultRepository ¶ added in v0.16.0
func (c *Controller) SetDefaultRepository(r repository.Repository) error
SetDefaultRepository sets the default repository for given controller.
func (*Controller) VerifyModelRepositories ¶ added in v0.16.0
func (c *Controller) VerifyModelRepositories() error
VerifyModelRepositories checks if all models have their repositories mapped.
type Options ¶ added in v0.16.0
type Options struct { // NamingConvention is the naming convention used while preparing the models. // Allowed values: // - camel // - lower_camel // - snake // - kebab NamingConvention mapping.NamingConvention // SynchronousConnections defines if the query relation includes would be taken concurrently. SynchronousConnections bool // UTCTimestamps is the flag that defines the format of the timestamps. UTCTimestamps bool }
Options defines the configuration for the Options.