Documentation ¶
Index ¶
- func ConvertObjects(input []*model.ObjectInput) []*pb.Object
- func ConvertProperties(input []*model.PropertyInput) []*pb.Property
- type ConfigurationResolver
- type ConfigurationsConnectionResolver
- type ConfigurationsEdgeResolver
- type ExperimentResolver
- func (r *ExperimentResolver) EstimatedDuration() *float64
- func (r *ExperimentResolver) ID() graphql.ID
- func (r *ExperimentResolver) Modules() *[]*ModuleResolver
- func (r *ExperimentResolver) Name() *string
- func (r *ExperimentResolver) Properties() *[]*PropertyResolver
- func (r *ExperimentResolver) StartTime() *float64
- func (r *ExperimentResolver) Status() *model.ExperimentStatus
- func (r *ExperimentResolver) TimeElapsed() *float64
- type JobResolver
- type JobsConnectionResolver
- type JobsEdgeResolver
- type ModuleResolver
- func (r *ModuleResolver) Configuration() *ConfigurationResolver
- func (r *ModuleResolver) Jobs() *[]*JobResolver
- func (r *ModuleResolver) ModuleName() string
- func (r *ModuleResolver) Properties(args struct{ ... }) *[]*PropertyResolver
- func (r *ModuleResolver) ServiceName() string
- func (r *ModuleResolver) State() *model.ModuleState
- func (r *ModuleResolver) Status() *StatusResolver
- type ModulesConnectionResolver
- type ModulesEdgeResolver
- type MutationResolver
- func (r *MutationResolver) CancelJob(ctx context.Context, serviceName string, moduleName string, jobID string) (*model.Job, error)
- func (r *MutationResolver) CreateUser(ctx context.Context, input model.UserInput) (*model.User, error)
- func (r *MutationResolver) DeleteUser(ctx context.Context, id string) (bool, error)
- func (r *MutationResolver) SetModuleProperties(ctx context.Context, serviceName string, moduleName string, ...) ([]*model.Property, error)
- func (r *MutationResolver) SetModuleProperty(ctx context.Context, serviceName string, moduleName string, ...) (*model.Property, error)
- func (r *MutationResolver) SetModuleRecipe(ctx context.Context, serviceName string, moduleName string, recipeID string) ([]*model.Property, error)
- func (r *MutationResolver) SubmitExpDeleteJob(ctx context.Context, serviceName string, experimentIds []*string) (*model.Job, error)
- func (r *MutationResolver) SubmitJob(ctx context.Context, serviceName string, moduleName string, action string, ...) (*model.Job, error)
- func (r *MutationResolver) UpdateUser(ctx context.Context, id string, input model.UserInput) (*model.User, error)
- type NewModuleArgs
- type ObjectResolver
- type PageInfoResolver
- type PropertyResolver
- type QueryResolver
- func (r *QueryResolver) Job(ctx context.Context, serviceName string, moduleName string, id string) (*model.Job, error)
- func (r *QueryResolver) Jobs(ctx context.Context, serviceName string, moduleName string, first *int32, ...) (*model.JobsConnection, error)
- func (r *QueryResolver) Module(ctx context.Context, serviceName string, moduleName string) (*model.Module, error)
- func (r *QueryResolver) ModuleConfiguration(ctx context.Context, serviceName string, moduleName string) (*model.Configuration, error)
- func (r *QueryResolver) ModuleJob(ctx context.Context, serviceName string, moduleName string, id string) (*model.Job, error)
- func (r *QueryResolver) ModuleJobs(ctx context.Context, serviceName string, moduleName string, first *int, ...) (*model.JobsConnection, error)
- func (r *QueryResolver) ModuleProperties(ctx context.Context, serviceName string, moduleName string, ...) ([]*model.Property, error)
- func (r *QueryResolver) ModuleProperty(ctx context.Context, serviceName string, moduleName string, ...) (*model.Property, error)
- func (r *QueryResolver) ModuleSettings(ctx context.Context, serviceName string, moduleName string) ([]*model.Property, error)
- func (r *QueryResolver) ModuleStatus(ctx context.Context, serviceName string, moduleName string) (*model.Status, error)
- func (r *QueryResolver) Modules(ctx context.Context, first *int, after *string) (*model.ModulesConnection, error)
- func (r *QueryResolver) User(ctx context.Context, email string) (*model.User, error)
- func (r *QueryResolver) Users(ctx context.Context, first *int, after *string) (*model.UsersConnection, error)
- type Resolver
- func (r *Resolver) Configuration(ctx context.Context, id string, namespace string) (*model.Configuration, error)
- func (r *Resolver) Configurations(ctx context.Context, namespace string, first *int, after *string) (*model.ConfigurationsConnection, error)
- func (r *Resolver) CreateConfiguration(ctx context.Context, conf model.ConfigurationInput) (*model.Configuration, error)
- func (r *Resolver) CreateRole(ctx context.Context, name string) (*model.Role, error)
- func (r *Resolver) CreateUser(ctx context.Context, args ...) (*UserResolver, error)
- func (r *Resolver) CurrentExperiment(ctx context.Context) (*model.Experiment, error)
- func (r *Resolver) DeleteConfiguration(ctx context.Context, id string, namespace string) (*model.Configuration, error)
- func (r *Resolver) DeleteRole(ctx context.Context, id string) (bool, error)
- func (r *Resolver) DeleteUser(ctx context.Context, args ...) (bool, error)
- func (r *Resolver) Experiment(ctx context.Context, id string) (*model.Experiment, error)
- func (r *Resolver) Experiments(ctx context.Context, serviceName string) (*model.Configuration, error)
- func (r *Resolver) ManagerStatus(ctx context.Context) ([]*model.Property, error)
- func (r *Resolver) Mutation() schema.MutationResolver
- func (r *Resolver) Query() schema.QueryResolver
- func (r *Resolver) Role(ctx context.Context, name string) (*model.Role, error)
- func (r *Resolver) Roles(ctx context.Context, first *int, after *string) (*model.RolesConnection, error)
- func (r *Resolver) SubmitExpBundleJob(ctx context.Context, serviceName string, experimentIds []*string) (*model.Job, error)
- func (r *Resolver) SubmitExpUpdateJob(ctx context.Context, serviceName string) (*model.Job, error)
- func (r *Resolver) SubmitManagerCommand(ctx context.Context, command string) (*model.Job, error)
- func (r *Resolver) UpdateConfiguration(ctx context.Context, id string, namespace string, ...) (*model.Configuration, error)
- func (r *Resolver) UpdateRole(ctx context.Context, id string, input model.RoleInput) (*model.Role, error)
- func (r *Resolver) UpdateUser(ctx context.Context, args ...) (*UserResolver, error)
- func (r *Resolver) User(ctx context.Context, args struct{ ... }) (*UserResolver, error)
- func (r *Resolver) Users(ctx context.Context, args struct{ ... }) (*UsersConnectionResolver, error)
- type RoleResolver
- type RolesConnectionResolver
- type RolesEdgeResolver
- type StatusResolver
- type UserResolver
- type UsersConnectionResolver
- type UsersEdgeResolver
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertObjects ¶
func ConvertObjects(input []*model.ObjectInput) []*pb.Object
ConvertObjects converts an array of objectInput to an array of protobuf objects
func ConvertProperties ¶
func ConvertProperties(input []*model.PropertyInput) []*pb.Property
Converts an array of propertyInput to an array of protobuf properties
Types ¶
type ConfigurationResolver ¶
type ConfigurationResolver struct {
// contains filtered or unexported fields
}
func (*ConfigurationResolver) ID ¶
func (r *ConfigurationResolver) ID() graphql.ID
func (*ConfigurationResolver) Name ¶
func (r *ConfigurationResolver) Name() *string
func (*ConfigurationResolver) Namespace ¶
func (r *ConfigurationResolver) Namespace() *string
func (*ConfigurationResolver) Objects ¶
func (r *ConfigurationResolver) Objects() *[]*ObjectResolver
func (*ConfigurationResolver) Properties ¶
func (r *ConfigurationResolver) Properties() *[]*PropertyResolver
type ConfigurationsConnectionResolver ¶
type ConfigurationsConnectionResolver struct {
// contains filtered or unexported fields
}
TODO: drop? these get replaced by models generated with gqlgen
func (*ConfigurationsConnectionResolver) Edges ¶
func (r *ConfigurationsConnectionResolver) Edges() *[]*ConfigurationsEdgeResolver
func (*ConfigurationsConnectionResolver) PageInfo ¶
func (r *ConfigurationsConnectionResolver) PageInfo() *PageInfoResolver
func (*ConfigurationsConnectionResolver) TotalCount ¶
func (r *ConfigurationsConnectionResolver) TotalCount() int32
type ConfigurationsEdgeResolver ¶
type ConfigurationsEdgeResolver struct {
// contains filtered or unexported fields
}
TODO: drop? these get replaced by models generated with gqlgen
func (*ConfigurationsEdgeResolver) Cursor ¶
func (r *ConfigurationsEdgeResolver) Cursor() graphql.ID
func (*ConfigurationsEdgeResolver) Node ¶
func (r *ConfigurationsEdgeResolver) Node() *ConfigurationResolver
type ExperimentResolver ¶
type ExperimentResolver struct {
// contains filtered or unexported fields
}
func (*ExperimentResolver) EstimatedDuration ¶
func (r *ExperimentResolver) EstimatedDuration() *float64
func (*ExperimentResolver) ID ¶
func (r *ExperimentResolver) ID() graphql.ID
func (*ExperimentResolver) Modules ¶
func (r *ExperimentResolver) Modules() *[]*ModuleResolver
func (*ExperimentResolver) Name ¶
func (r *ExperimentResolver) Name() *string
func (*ExperimentResolver) Properties ¶
func (r *ExperimentResolver) Properties() *[]*PropertyResolver
func (*ExperimentResolver) StartTime ¶
func (r *ExperimentResolver) StartTime() *float64
func (*ExperimentResolver) Status ¶
func (r *ExperimentResolver) Status() *model.ExperimentStatus
func (*ExperimentResolver) TimeElapsed ¶
func (r *ExperimentResolver) TimeElapsed() *float64
type JobResolver ¶
type JobResolver struct {
// contains filtered or unexported fields
}
func (*JobResolver) FinishTime ¶
func (r *JobResolver) FinishTime() *float64
func (*JobResolver) ID ¶
func (r *JobResolver) ID() graphql.ID
func (*JobResolver) Module ¶
func (r *JobResolver) Module() *ModuleResolver
func (*JobResolver) Properties ¶
func (r *JobResolver) Properties(args struct{ Filter *[]*string }) *[]*PropertyResolver
func (*JobResolver) StartTime ¶
func (r *JobResolver) StartTime() *float64
func (*JobResolver) Status ¶
func (r *JobResolver) Status() *model.JobStatus
type JobsConnectionResolver ¶
type JobsConnectionResolver struct {
// contains filtered or unexported fields
}
func (*JobsConnectionResolver) Edges ¶
func (r *JobsConnectionResolver) Edges() *[]*JobsEdgeResolver
func (*JobsConnectionResolver) PageInfo ¶
func (r *JobsConnectionResolver) PageInfo() *PageInfoResolver
func (*JobsConnectionResolver) TotalCount ¶
func (r *JobsConnectionResolver) TotalCount() int32
type JobsEdgeResolver ¶
type JobsEdgeResolver struct {
// contains filtered or unexported fields
}
func (*JobsEdgeResolver) Cursor ¶
func (r *JobsEdgeResolver) Cursor() graphql.ID
func (*JobsEdgeResolver) Node ¶
func (r *JobsEdgeResolver) Node() *JobResolver
type ModuleResolver ¶
type ModuleResolver struct {
// contains filtered or unexported fields
}
func NewModule ¶
func NewModule(ctx context.Context, args NewModuleArgs) (*ModuleResolver, error)
func (*ModuleResolver) Configuration ¶
func (r *ModuleResolver) Configuration() *ConfigurationResolver
func (*ModuleResolver) Jobs ¶
func (r *ModuleResolver) Jobs() *[]*JobResolver
func (*ModuleResolver) ModuleName ¶
func (r *ModuleResolver) ModuleName() string
func (*ModuleResolver) Properties ¶
func (r *ModuleResolver) Properties(args struct{ Filter *[]*string }) *[]*PropertyResolver
func (*ModuleResolver) ServiceName ¶
func (r *ModuleResolver) ServiceName() string
func (*ModuleResolver) State ¶
func (r *ModuleResolver) State() *model.ModuleState
func (*ModuleResolver) Status ¶
func (r *ModuleResolver) Status() *StatusResolver
type ModulesConnectionResolver ¶
type ModulesConnectionResolver struct {
// contains filtered or unexported fields
}
func (*ModulesConnectionResolver) Edges ¶
func (r *ModulesConnectionResolver) Edges() *[]*ModulesEdgeResolver
func (*ModulesConnectionResolver) PageInfo ¶
func (r *ModulesConnectionResolver) PageInfo() *PageInfoResolver
func (*ModulesConnectionResolver) TotalCount ¶
func (r *ModulesConnectionResolver) TotalCount() int32
type ModulesEdgeResolver ¶
type ModulesEdgeResolver struct {
// contains filtered or unexported fields
}
func (*ModulesEdgeResolver) Cursor ¶
func (r *ModulesEdgeResolver) Cursor() string
func (*ModulesEdgeResolver) Node ¶
func (r *ModulesEdgeResolver) Node() *ModuleResolver
type MutationResolver ¶
type MutationResolver struct{ *Resolver }
func (*MutationResolver) CreateUser ¶
func (r *MutationResolver) CreateUser(ctx context.Context, input model.UserInput) (*model.User, error)
CreateUser creates a record
func (*MutationResolver) DeleteUser ¶
DeleteUser deletes a record
func (*MutationResolver) SetModuleProperties ¶
func (r *MutationResolver) SetModuleProperties( ctx context.Context, serviceName string, moduleName string, properties []*model.PropertyInput, ) ([]*model.Property, error)
func (*MutationResolver) SetModuleProperty ¶
func (r *MutationResolver) SetModuleProperty( ctx context.Context, serviceName string, moduleName string, property model.PropertyInput, ) (*model.Property, error)
func (*MutationResolver) SetModuleRecipe ¶
func (*MutationResolver) SubmitExpDeleteJob ¶
type NewModuleArgs ¶
type ObjectResolver ¶
type ObjectResolver struct {
// contains filtered or unexported fields
}
func (*ObjectResolver) ID ¶
func (r *ObjectResolver) ID() graphql.ID
func (*ObjectResolver) Name ¶
func (r *ObjectResolver) Name() *string
func (*ObjectResolver) Objects ¶
func (r *ObjectResolver) Objects() *[]*ObjectResolver
func (*ObjectResolver) Properties ¶
func (r *ObjectResolver) Properties() *[]*PropertyResolver
func (*ObjectResolver) Type ¶
func (r *ObjectResolver) Type() *string
type PageInfoResolver ¶
type PageInfoResolver struct {
// contains filtered or unexported fields
}
func (*PageInfoResolver) EndCursor ¶
func (r *PageInfoResolver) EndCursor() *graphql.ID
func (*PageInfoResolver) HasNextPage ¶
func (r *PageInfoResolver) HasNextPage() bool
func (*PageInfoResolver) StartCursor ¶
func (r *PageInfoResolver) StartCursor() *graphql.ID
type PropertyResolver ¶
type PropertyResolver struct {
// contains filtered or unexported fields
}
func (*PropertyResolver) Key ¶
func (r *PropertyResolver) Key() *string
func (*PropertyResolver) Value ¶
func (r *PropertyResolver) Value() *string
type QueryResolver ¶
type QueryResolver struct{ *Resolver }
func (*QueryResolver) Jobs ¶
func (r *QueryResolver) Jobs( ctx context.Context, serviceName string, moduleName string, first *int32, after *string, ) (*model.JobsConnection, error)
func (*QueryResolver) ModuleConfiguration ¶
func (r *QueryResolver) ModuleConfiguration( ctx context.Context, serviceName string, moduleName string, ) (*model.Configuration, error)
func (*QueryResolver) ModuleJobs ¶
func (r *QueryResolver) ModuleJobs( ctx context.Context, serviceName string, moduleName string, first *int, after *string, ) (*model.JobsConnection, error)
func (*QueryResolver) ModuleProperties ¶
func (*QueryResolver) ModuleProperty ¶
func (*QueryResolver) ModuleSettings ¶
func (*QueryResolver) ModuleStatus ¶
func (*QueryResolver) Modules ¶
func (r *QueryResolver) Modules(ctx context.Context, first *int, after *string) (*model.ModulesConnection, error)
func (*QueryResolver) Users ¶
func (r *QueryResolver) Users(ctx context.Context, first *int, after *string) (*model.UsersConnection, error)
Users lists records
type Resolver ¶
func (*Resolver) Configuration ¶
func (*Resolver) Configurations ¶
func (*Resolver) CreateConfiguration ¶
func (r *Resolver) CreateConfiguration( ctx context.Context, conf model.ConfigurationInput, ) (*model.Configuration, error)
func (*Resolver) CreateRole ¶
CreateRole returns a role if found by name in the database
func (*Resolver) CreateUser ¶
func (*Resolver) CurrentExperiment ¶
func (*Resolver) DeleteConfiguration ¶
func (*Resolver) DeleteRole ¶
DeleteRole removes a role if found by ID in the database
func (*Resolver) DeleteUser ¶
func (*Resolver) Experiment ¶
func (*Resolver) Experiments ¶
func (*Resolver) ManagerStatus ¶
func (*Resolver) Mutation ¶
func (r *Resolver) Mutation() schema.MutationResolver
Mutation returns gql.MutationResolver implementation.
func (*Resolver) Query ¶
func (r *Resolver) Query() schema.QueryResolver
Query returns gql.QueryResolver implementation.
func (*Resolver) SubmitExpBundleJob ¶
func (*Resolver) SubmitExpUpdateJob ¶
func (*Resolver) SubmitManagerCommand ¶
func (*Resolver) UpdateConfiguration ¶
func (r *Resolver) UpdateConfiguration( ctx context.Context, id string, namespace string, input model.ConfigurationInput, ) (*model.Configuration, error)
TODO: remove input.ID
func (*Resolver) UpdateRole ¶
func (r *Resolver) UpdateRole(ctx context.Context, id string, input model.RoleInput) (*model.Role, error)
UpdateRole modifies a role if found by ID in the database
func (*Resolver) UpdateUser ¶
type RoleResolver ¶
type RoleResolver struct {
// contains filtered or unexported fields
}
func (*RoleResolver) CreatedAt ¶
func (r *RoleResolver) CreatedAt() (*graphql.Time, error)
func (*RoleResolver) ID ¶
func (r *RoleResolver) ID() graphql.ID
func (*RoleResolver) Name ¶
func (r *RoleResolver) Name() *string
type RolesConnectionResolver ¶
type RolesConnectionResolver struct {
// contains filtered or unexported fields
}
func (*RolesConnectionResolver) Edges ¶
func (r *RolesConnectionResolver) Edges() *[]*RolesEdgeResolver
func (*RolesConnectionResolver) PageInfo ¶
func (r *RolesConnectionResolver) PageInfo() *PageInfoResolver
func (*RolesConnectionResolver) TotalCount ¶
func (r *RolesConnectionResolver) TotalCount() int32
type RolesEdgeResolver ¶
type RolesEdgeResolver struct {
// contains filtered or unexported fields
}
func (*RolesEdgeResolver) Cursor ¶
func (r *RolesEdgeResolver) Cursor() graphql.ID
func (*RolesEdgeResolver) Node ¶
func (r *RolesEdgeResolver) Node() *RoleResolver
type StatusResolver ¶
type StatusResolver struct {
// contains filtered or unexported fields
}
func (*StatusResolver) Active ¶
func (r *StatusResolver) Active() *bool
func (*StatusResolver) Details ¶
func (r *StatusResolver) Details() *[]*PropertyResolver
func (*StatusResolver) Enabled ¶
func (r *StatusResolver) Enabled() *bool
func (*StatusResolver) Loaded ¶
func (r *StatusResolver) Loaded() *bool
type UserResolver ¶
type UserResolver struct {
// contains filtered or unexported fields
}
UserResolver is used to resolve a user model
func (*UserResolver) CreatedAt ¶
func (r *UserResolver) CreatedAt() (*graphql.Time, error)
CreatedAt returns the GraphQL value for the date the user registered
func (*UserResolver) Email ¶
func (r *UserResolver) Email() *string
Email returns the email for the user model
func (*UserResolver) ID ¶
func (r *UserResolver) ID() graphql.ID
ID returns the GraphQL value for the user model
func (*UserResolver) Password ¶
func (r *UserResolver) Password() *string
Password returns the password for the user model
type UsersConnectionResolver ¶
type UsersConnectionResolver struct {
// contains filtered or unexported fields
}
func (*UsersConnectionResolver) Edges ¶
func (r *UsersConnectionResolver) Edges() *[]*UsersEdgeResolver
func (*UsersConnectionResolver) PageInfo ¶
func (r *UsersConnectionResolver) PageInfo() *PageInfoResolver
func (*UsersConnectionResolver) TotalCount ¶
func (r *UsersConnectionResolver) TotalCount() int32
type UsersEdgeResolver ¶
type UsersEdgeResolver struct {
// contains filtered or unexported fields
}
func (*UsersEdgeResolver) Cursor ¶
func (r *UsersEdgeResolver) Cursor() graphql.ID
func (*UsersEdgeResolver) Node ¶
func (r *UsersEdgeResolver) Node() *UserResolver