model

Documentation

Index

• Variables
• func InitDbManager(db *pg.DB)
• func SetSchema(s string)
• type ConfigRepository
  • func (r *ConfigRepository) CreateConfig(config *entity.Config) (*entity.Config, error)
  • func (r *ConfigRepository) DeleteConfig(identities []int64) (int, error)
  • func (r *ConfigRepository) GetConfigById(identity int64) (*entity.Config, error)
  • func (r *ConfigRepository) GetConfigByInstanceUUIDAndModuleName(instanceUUID string, moduleName string) (*entity.Config, error)
  • func (r *ConfigRepository) GetConfigs(identities []int64) ([]entity.Config, error)
  • func (r *ConfigRepository) GetConfigsByModulesId(modulesId []int32) ([]entity.Config, error)
  • func (r *ConfigRepository) GetModuleNameAndInstanceUUIDByConfigId(configId int64) (entity.ModuleInstanceIdentity, error)
  • func (r *ConfigRepository) UpdateConfig(config *entity.Config) (*entity.Config, error)
• type InstanceRepository
  • func (r *InstanceRepository) CreateInstance(instance entity.Instance) (entity.Instance, error)
  • func (r *InstanceRepository) DeleteInstance(identities []int32) (int, error)
  • func (r *InstanceRepository) GetInstanceById(identity int32) (entity.Instance, error)
  • func (r *InstanceRepository) GetInstanceByUuid(instanceUuid string) (entity.Instance, error)
  • func (r *InstanceRepository) GetInstances(identities []int32) ([]entity.Instance, error)
  • func (r *InstanceRepository) UpdateInstance(instance entity.Instance) (entity.Instance, error)
• type ModulesRepository
  • func (r *ModulesRepository) CreateModule(module entity.Module) (entity.Module, error)
  • func (r *ModulesRepository) DeleteModule(identities []int32) (int, error)
  • func (r *ModulesRepository) GetActiveModules() ([]entity.Module, error)
  • func (r *ModulesRepository) GetModule(identity int32) (*entity.Module, error)
  • func (r *ModulesRepository) GetModuleById(identity int32) (entity.Module, error)
  • func (r *ModulesRepository) GetModuleByInstanceIdAndName(instanceId int32, moduleName string) (entity.Module, error)
  • func (r *ModulesRepository) GetModules(identities []int32) ([]entity.Module, error)
  • func (r *ModulesRepository) GetModulesByInstanceUuid(instanceUuid string) ([]entity.Module, error)
  • func (r *ModulesRepository) GetModulesByInstanceUuidAndName(instanceUuid string, name string) (*entity.Module, error)
  • func (r *ModulesRepository) UpdateModule(module entity.Module) (entity.Module, error)
  • func (r *ModulesRepository) UpdateModuleDisconnect(instanceUuid string, moduleName string) error
• type SchemaRepository
  • func (r *SchemaRepository) GetSchemaByModuleId(moduleId int32) (*entity.ConfigSchema, error)
  • func (r *SchemaRepository) GetSchemasByModulesId(modulesId []int32) ([]entity.ConfigSchema, error)
  • func (r *SchemaRepository) InsertConfigSchema(s *entity.ConfigSchema) (*entity.ConfigSchema, error)
  • func (r *SchemaRepository) UpdateConfigSchema(s *entity.ConfigSchema) (*entity.ConfigSchema, error)

Variables

var (
	ConfigRep   ConfigRepository
	ModulesRep  ModulesRepository
	InstanceRep InstanceRepository
	SchemaRep   SchemaRepository
)

Functions

func InitDbManager

func InitDbManager(db *pg.DB)

func SetSchema

func SetSchema(s string)

Types

type ConfigRepository

type ConfigRepository struct {
	DB orm.DB
}

func (*ConfigRepository) CreateConfig

func (r *ConfigRepository) CreateConfig(config *entity.Config) (*entity.Config, error)

func (*ConfigRepository) DeleteConfig

func (r *ConfigRepository) DeleteConfig(identities []int64) (int, error)

func (*ConfigRepository) GetConfigById

func (r *ConfigRepository) GetConfigById(identity int64) (*entity.Config, error)

func (*ConfigRepository) GetConfigByInstanceUUIDAndModuleName

func (r *ConfigRepository) GetConfigByInstanceUUIDAndModuleName(instanceUUID string, moduleName string) (*entity.Config, error)

func (*ConfigRepository) GetConfigs

func (r *ConfigRepository) GetConfigs(identities []int64) ([]entity.Config, error)

func (*ConfigRepository) GetConfigsByModulesId

func (r *ConfigRepository) GetConfigsByModulesId(modulesId []int32) ([]entity.Config, error)

func (*ConfigRepository) GetModuleNameAndInstanceUUIDByConfigId

func (r *ConfigRepository) GetModuleNameAndInstanceUUIDByConfigId(configId int64) (entity.ModuleInstanceIdentity, error)

func (*ConfigRepository) UpdateConfig

func (r *ConfigRepository) UpdateConfig(config *entity.Config) (*entity.Config, error)

type InstanceRepository

type InstanceRepository struct {
	DB orm.DB
}

func (*InstanceRepository) CreateInstance

func (r *InstanceRepository) CreateInstance(instance entity.Instance) (entity.Instance, error)

func (*InstanceRepository) DeleteInstance

func (r *InstanceRepository) DeleteInstance(identities []int32) (int, error)

func (*InstanceRepository) GetInstanceById

func (r *InstanceRepository) GetInstanceById(identity int32) (entity.Instance, error)

func (*InstanceRepository) GetInstanceByUuid

func (r *InstanceRepository) GetInstanceByUuid(instanceUuid string) (entity.Instance, error)

func (*InstanceRepository) GetInstances

func (r *InstanceRepository) GetInstances(identities []int32) ([]entity.Instance, error)

func (*InstanceRepository) UpdateInstance

func (r *InstanceRepository) UpdateInstance(instance entity.Instance) (entity.Instance, error)

type ModulesRepository

type ModulesRepository struct {
	DB orm.DB
}

func (*ModulesRepository) CreateModule

func (r *ModulesRepository) CreateModule(module entity.Module) (entity.Module, error)

func (*ModulesRepository) DeleteModule

func (r *ModulesRepository) DeleteModule(identities []int32) (int, error)

func (*ModulesRepository) GetActiveModules

func (r *ModulesRepository) GetActiveModules() ([]entity.Module, error)

func (*ModulesRepository) GetModule

func (r *ModulesRepository) GetModule(identity int32) (*entity.Module, error)

func (*ModulesRepository) GetModuleById

func (r *ModulesRepository) GetModuleById(identity int32) (entity.Module, error)

func (*ModulesRepository) GetModuleByInstanceIdAndName

func (r *ModulesRepository) GetModuleByInstanceIdAndName(instanceId int32, moduleName string) (entity.Module, error)

func (*ModulesRepository) GetModules

func (r *ModulesRepository) GetModules(identities []int32) ([]entity.Module, error)

func (*ModulesRepository) GetModulesByInstanceUuid

func (r *ModulesRepository) GetModulesByInstanceUuid(instanceUuid string) ([]entity.Module, error)

func (*ModulesRepository) GetModulesByInstanceUuidAndName

func (r *ModulesRepository) GetModulesByInstanceUuidAndName(instanceUuid string, name string) (*entity.Module, error)

func (*ModulesRepository) UpdateModule

func (r *ModulesRepository) UpdateModule(module entity.Module) (entity.Module, error)

func (*ModulesRepository) UpdateModuleDisconnect

func (r *ModulesRepository) UpdateModuleDisconnect(instanceUuid string, moduleName string) error

type SchemaRepository

type SchemaRepository struct {
	DB orm.DB
}

func (*SchemaRepository) GetSchemaByModuleId

func (r *SchemaRepository) GetSchemaByModuleId(moduleId int32) (*entity.ConfigSchema, error)

func (*SchemaRepository) GetSchemasByModulesId

func (r *SchemaRepository) GetSchemasByModulesId(modulesId []int32) ([]entity.ConfigSchema, error)

func (*SchemaRepository) InsertConfigSchema

func (r *SchemaRepository) InsertConfigSchema(s *entity.ConfigSchema) (*entity.ConfigSchema, error)

func (*SchemaRepository) UpdateConfigSchema

func (r *SchemaRepository) UpdateConfigSchema(s *entity.ConfigSchema) (*entity.ConfigSchema, error)