resolver

package
v0.0.0-...-87de96b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 16, 2020 License: MIT Imports: 22 Imported by: 0

Documentation

Index

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) CancelJob 

func (r *MutationResolver) CancelJob(
	ctx context.Context,
	serviceName string,
	moduleName string,
	jobID string,
) (*model.Job, error)

func (*MutationResolver) CreateUser 

func (r *MutationResolver) CreateUser(ctx context.Context, input model.UserInput) (*model.User, error)

CreateUser creates a record

func (*MutationResolver) DeleteUser 

func (r *MutationResolver) DeleteUser(ctx context.Context, id string) (bool, error)

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 (r *MutationResolver) SetModuleRecipe(
	ctx context.Context,
	serviceName string,
	moduleName string,
	recipeID string,
) ([]*model.Property, error)

func (*MutationResolver) SubmitExpDeleteJob 

func (r *MutationResolver) SubmitExpDeleteJob(
	ctx context.Context,
	serviceName string,
	experimentIds []*string,
) (*model.Job, error)

func (*MutationResolver) SubmitJob 

func (r *MutationResolver) SubmitJob(
	ctx context.Context,
	serviceName string,
	moduleName string,
	action string,
	actionValue *string,
	properties []*model.PropertyInput,
) (*model.Job, error)

func (*MutationResolver) UpdateUser 

func (r *MutationResolver) UpdateUser(ctx context.Context, id string, input model.UserInput) (*model.User, error)

UpdateUser updates a record

type NewModuleArgs 

type NewModuleArgs struct {
	Module *model.Module
	Name   string
}

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) Job 

func (r *QueryResolver) Job(
	ctx context.Context,
	serviceName string,
	moduleName string,
	id string,
) (*model.Job, error)

func (*QueryResolver) Jobs 

func (r *QueryResolver) Jobs(
	ctx context.Context,
	serviceName string,
	moduleName string,
	first *int32,
	after *string,
) (*model.JobsConnection, error)

func (*QueryResolver) Module 

func (r *QueryResolver) Module(ctx context.Context, serviceName string, moduleName string) (*model.Module, error)

func (*QueryResolver) ModuleConfiguration 

func (r *QueryResolver) ModuleConfiguration(
	ctx context.Context,
	serviceName string,
	moduleName string,
) (*model.Configuration, error)

func (*QueryResolver) ModuleJob 

func (r *QueryResolver) ModuleJob(
	ctx context.Context,
	serviceName string,
	moduleName string,
	id string,
) (*model.Job, 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 (r *QueryResolver) ModuleProperties(
	ctx context.Context,
	serviceName string,
	moduleName string,
	propertyNames []*string,
) ([]*model.Property, error)

func (*QueryResolver) ModuleProperty 

func (r *QueryResolver) ModuleProperty(
	ctx context.Context,
	serviceName string,
	moduleName string,
	propertyName string,
) (*model.Property, error)

func (*QueryResolver) ModuleSettings 

func (r *QueryResolver) ModuleSettings(
	ctx context.Context,
	serviceName string,
	moduleName string,
) ([]*model.Property, error)

func (*QueryResolver) ModuleStatus 

func (r *QueryResolver) ModuleStatus(
	ctx context.Context,
	serviceName string,
	moduleName string,
) (*model.Status, error)

func (*QueryResolver) Modules 

func (r *QueryResolver) Modules(ctx context.Context, first *int, after *string) (*model.ModulesConnection, error)

func (*QueryResolver) User 

func (r *QueryResolver) User(ctx context.Context, email string) (*model.User, error)

func (*QueryResolver) Users 

func (r *QueryResolver) Users(ctx context.Context, first *int, after *string) (*model.UsersConnection, error)

Users lists records

type Resolver 

type Resolver struct {
	ORM *orm.ORM
}

func (*Resolver) Configuration 

func (r *Resolver) Configuration(ctx context.Context, id string, namespace string) (*model.Configuration, error)

func (*Resolver) Configurations 

func (r *Resolver) Configurations(
	ctx context.Context,
	namespace string,
	first *int,
	after *string,
) (*model.ConfigurationsConnection, error)

func (*Resolver) CreateConfiguration 

func (r *Resolver) CreateConfiguration(
	ctx context.Context,
	conf model.ConfigurationInput,
) (*model.Configuration, error)

func (*Resolver) CreateRole 

func (r *Resolver) CreateRole(ctx context.Context, name string) (*model.Role, error)

CreateRole returns a role if found by name in the database

func (*Resolver) CreateUser 

func (r *Resolver) CreateUser(ctx context.Context, args *struct {
	Email    string
	Password string
}) (*UserResolver, error)

func (*Resolver) CurrentExperiment 

func (r *Resolver) CurrentExperiment(ctx context.Context) (*model.Experiment, error)

func (*Resolver) DeleteConfiguration 

func (r *Resolver) DeleteConfiguration(
	ctx context.Context,
	id string,
	namespace string,
) (*model.Configuration, error)

func (*Resolver) DeleteRole 

func (r *Resolver) DeleteRole(ctx context.Context, id string) (bool, error)

DeleteRole removes a role if found by ID in the database

func (*Resolver) DeleteUser 

func (r *Resolver) DeleteUser(ctx context.Context, args *struct {
	ID string
}) (bool, error)

func (*Resolver) Experiment 

func (r *Resolver) Experiment(ctx context.Context, id string) (*model.Experiment, error)

func (*Resolver) Experiments 

func (r *Resolver) Experiments(ctx context.Context, serviceName string) (*model.Configuration, error)

func (*Resolver) ManagerStatus 

func (r *Resolver) ManagerStatus(ctx context.Context) ([]*model.Property, error)

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) Role 

func (r *Resolver) Role(ctx context.Context, name string) (*model.Role, error)

func (*Resolver) Roles 

func (r *Resolver) Roles(ctx context.Context, first *int, after *string) (*model.RolesConnection, error)

func (*Resolver) SubmitExpBundleJob 

func (r *Resolver) SubmitExpBundleJob(
	ctx context.Context,
	serviceName string,
	experimentIds []*string,
) (*model.Job, error)

func (*Resolver) SubmitExpUpdateJob 

func (r *Resolver) SubmitExpUpdateJob(ctx context.Context, serviceName string) (*model.Job, error)

func (*Resolver) SubmitManagerCommand 

func (r *Resolver) SubmitManagerCommand(ctx context.Context, command string) (*model.Job, error)

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 

func (r *Resolver) UpdateUser(ctx context.Context, args *struct {
	ID    string
	Input model.UserInput
}) (*UserResolver, error)

func (*Resolver) User 

func (r *Resolver) User(ctx context.Context, args struct {
	Email string
}) (*UserResolver, error)

User resolves a user using the associated data loader

func (*Resolver) Users 

func (r *Resolver) Users(ctx context.Context, args struct {
	First *int32
	After *string
}) (*UsersConnectionResolver, error)

Users resolves a list of users using the associated data loader

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.