service

Aug 27, 2019

Changes in this version

+ type ManagerService struct

+ func NewManagerService(client pb.ManagerClient, log *logging.Logger) *ManagerService

+ func (c *ManagerService) Install() (*model.Response, error)

+ func (c *ManagerService) Restart() (*model.Response, error)

+ func (c *ManagerService) Start() (*model.Response, error)

+ func (c *ManagerService) Status() (*[]*model.Property, error)

+ func (c *ManagerService) Stop() (*model.Response, error)

+ func (c *ManagerService) Uninstall() (*model.Response, error)

+ func (c *ManagerService) Upgrade() (*model.Response, error)

May 10, 2019

Changes in this version

type BrokerService

+ func (s *BrokerService) Module(ctx context.Context, moduleName string) (*model.Module, error)

Apr 17, 2019

Changes in this version

type BrokerService

+ func (b *BrokerService) GetModuleProperties(serviceName string, moduleID string, propertyKeys string) ([]*model.Property, error)

+ func (b *BrokerService) GetModuleProperty(serviceName string, moduleID string, propertyName string) (*model.Property, error)

+ func (b *BrokerService) SetModuleProperties(serviceName string, moduleID string, propertyKeys string, ...) ([]*model.Property, error)

+ func (b *BrokerService) SetModuleProperty(serviceName string, moduleID string, property *pb.Property) (*model.Property, error)

Apr 12, 2019

Changes in this version

type BrokerService

+ func (b *BrokerService) GetModuleActiveJob(serviceName string, moduleID string) (*model.Job, error)

+ func (b *BrokerService) GetModuleJob(serviceName string, moduleID string, jobID string) (*model.Job, error)

+ func (b *BrokerService) GetModuleJobs(serviceName string, moduleID string) (*[]*model.Job, error)

+ func (b *BrokerService) GetModuleSettings(serviceName string, moduleID string) (*[]*model.Property, error)

+ func (b *BrokerService) GetModules(serviceName string) (*[]*model.Module, error)

+ func (b *BrokerService) ModuleAvailableEvents(serviceName string, moduleID string) (*[]*model.Event, error)

+ func (b *BrokerService) ModuleCancelJob(serviceName string, moduleID string, jobID string) (*model.Job, error)

+ func (b *BrokerService) ModuleSubmitEvent(serviceName string, moduleID string) (*model.Job, error)

+ func (b *BrokerService) ModuleSubmitJob(serviceName string, moduleID string, action string) (*model.Job, error)

type ConfigureService

+ func (c *ConfigureService) CreateConfiguration(conf *pb.Configuration) (*model.Configuration, error)

+ func (c *ConfigureService) DeleteConfiguration(id string, namespace string) (*model.Configuration, error)

+ func (c *ConfigureService) UpdateConfiguration(id string, namespace string, conf *pb.Configuration) (*model.Configuration, error)

type UserService

+ func (u *UserService) FindByID(id string) (*model.User, error)

Mar 11, 2019

Changes in this version

+ type BrokerService struct

+ func NewBrokerService(config *gcontext.Config, log *logging.Logger) *BrokerService

+ func (b *BrokerService) CreateJob(serviceName string, moduleID string) error

+ func (b *BrokerService) GetModule(serviceName string, moduleID string) (*model.ProtoModule, error)

+ func (b *BrokerService) GetModuleConfiguration(serviceName string, moduleID string) (*model.Configuration, error)

+ func (b *BrokerService) GetModuleStatus(serviceName string, moduleID string) (*model.ProtoStatus, error)

Jan 31, 2019

Changes in this version

+ func DecodeCursor(after *string) (*string, error)

+ func EncodeCursor(i *string) graphql.ID

+ func NewLogger(config *context.Config) *logging.Logger

+ type AuthService struct

+ func NewAuthService(config *context.Config, log *logging.Logger) *AuthService

+ func (a *AuthService) SignJWT(user *model.User) (*string, error)

+ func (a *AuthService) ValidateJWT(tokenString *string) (*jwt.Token, error)

+ type ConfigureService struct

+ func NewConfigureService(client pb.ConfigureEndpointClient, log *logging.Logger) *ConfigureService

+ func (c *ConfigureService) Count() (int, error)

+ func (c *ConfigureService) FindById(confId string) (*model.Configuration, error)

+ func (c *ConfigureService) List(first *int32, after *string) ([]*model.Configuration, error)

+ type RoleService struct

+ func NewRoleService(db *sqlx.DB, log *logging.Logger) *RoleService

+ func (r *RoleService) Count() (int, error)

+ func (r *RoleService) CreateRole(role *model.Role) (*model.Role, error)

+ func (r *RoleService) FindByName(name string) (*model.Role, error)

+ func (r *RoleService) FindByUserId(userId *string) ([]*model.Role, error)

+ func (r *RoleService) List(first *int32, after *string) ([]*model.Role, error)

+ type UserService struct

+ func NewUserService(db *sqlx.DB, roleService *RoleService, log *logging.Logger) *UserService

+ func (u *UserService) ComparePassword(userCredentials *model.UserCredentials) (*model.User, error)

+ func (u *UserService) Count() (int, error)

+ func (u *UserService) CreateUser(user *model.User) (*model.User, error)

+ func (u *UserService) FindByEmail(email string) (*model.User, error)

+ func (u *UserService) List(first *int32, after *string) ([]*model.User, error)