generated

Documentation

Index

• func NewExecutableSchema(cfg Config) graphql.ExecutableSchema
• type ComplexityRoot
• type Config
• type DirectiveRoot
• type MutationResolver
• type QueryResolver
• type ResolverRoot
• type SubscriptionResolver

Functions

func NewExecutableSchema

func NewExecutableSchema(cfg Config) graphql.ExecutableSchema

NewExecutableSchema creates an ExecutableSchema from the ResolverRoot interface.

Types

type ComplexityRoot

type ComplexityRoot struct {
	ActionPayload struct {
		ExternalData func(childComplexity int) int
		K8sManifest  func(childComplexity int) int
		Namespace    func(childComplexity int) int
		RequestType  func(childComplexity int) int
	}

	ChaosWorkFlowResponse struct {
		CronSyntax          func(childComplexity int) int
		IsCustomWorkflow    func(childComplexity int) int
		WorkflowDescription func(childComplexity int) int
		WorkflowID          func(childComplexity int) int
		WorkflowName        func(childComplexity int) int
	}

	Cluster struct {
		AccessKey          func(childComplexity int) int
		ClusterID          func(childComplexity int) int
		ClusterName        func(childComplexity int) int
		ClusterType        func(childComplexity int) int
		CreatedAt          func(childComplexity int) int
		Description        func(childComplexity int) int
		IsActive           func(childComplexity int) int
		IsClusterConfirmed func(childComplexity int) int
		IsRegistered       func(childComplexity int) int
		PlatformName       func(childComplexity int) int
		ProjectID          func(childComplexity int) int
		UpdatedAt          func(childComplexity int) int
	}

	ClusterAction struct {
		Action    func(childComplexity int) int
		ProjectID func(childComplexity int) int
	}

	ClusterConfirmResponse struct {
		ClusterID          func(childComplexity int) int
		IsClusterConfirmed func(childComplexity int) int
		NewClusterKey      func(childComplexity int) int
	}

	ClusterEvent struct {
		Cluster     func(childComplexity int) int
		Description func(childComplexity int) int
		EventID     func(childComplexity int) int
		EventName   func(childComplexity int) int
		EventType   func(childComplexity int) int
	}

	Member struct {
		Invitation func(childComplexity int) int
		Role       func(childComplexity int) int
		UserID     func(childComplexity int) int
		UserName   func(childComplexity int) int
	}

	Mutation struct {
		ChaosWorkflowRun    func(childComplexity int, workflowData model.WorkflowRunInput) int
		ClusterConfirm      func(childComplexity int, identity model.ClusterIdentity) int
		CreateChaosWorkFlow func(childComplexity int, input model.ChaosWorkFlowInput) int
		CreateUser          func(childComplexity int, user model.UserInput) int
		DeleteChaosWorkflow func(childComplexity int, workflowid string) int
		NewClusterEvent     func(childComplexity int, clusterEvent model.ClusterEventInput) int
		PodLog              func(childComplexity int, log model.PodLog) int
		UserClusterReg      func(childComplexity int, clusterInput model.ClusterInput) int
	}

	PodLogResponse struct {
		Log           func(childComplexity int) int
		PodName       func(childComplexity int) int
		PodType       func(childComplexity int) int
		WorkflowRunID func(childComplexity int) int
	}

	Project struct {
		CreatedAt func(childComplexity int) int
		ID        func(childComplexity int) int
		Members   func(childComplexity int) int
		Name      func(childComplexity int) int
		RemovedAt func(childComplexity int) int
		State     func(childComplexity int) int
		UpdatedAt func(childComplexity int) int
	}

	Query struct {
		GetCluster      func(childComplexity int, projectID string, clusterType *string) int
		GetProject      func(childComplexity int, projectID string) int
		GetUser         func(childComplexity int, username string) int
		GetWorkFlowRuns func(childComplexity int, projectID string) int
	}

	Subscription struct {
		ClusterConnect        func(childComplexity int, clusterInfo model.ClusterIdentity) int
		ClusterEventListener  func(childComplexity int, projectID string) int
		GetPodLog             func(childComplexity int, podDetails model.PodLogRequest) int
		WorkflowEventListener func(childComplexity int, projectID string) int
	}

	User struct {
		CompanyName     func(childComplexity int) int
		CreatedAt       func(childComplexity int) int
		Email           func(childComplexity int) int
		ID              func(childComplexity int) int
		IsEmailVerified func(childComplexity int) int
		Name            func(childComplexity int) int
		Projects        func(childComplexity int) int
		RemovedAt       func(childComplexity int) int
		Role            func(childComplexity int) int
		State           func(childComplexity int) int
		UpdatedAt       func(childComplexity int) int
		Username        func(childComplexity int) int
	}

	WorkflowRun struct {
		ClusterID     func(childComplexity int) int
		ClusterName   func(childComplexity int) int
		ExecutionData func(childComplexity int) int
		LastUpdated   func(childComplexity int) int
		ProjectID     func(childComplexity int) int
		WorkflowID    func(childComplexity int) int
		WorkflowName  func(childComplexity int) int
		WorkflowRunID func(childComplexity int) int
	}

	Weightages struct {
		ExperimentName func(childComplexity int) int
		Weightage      func(childComplexity int) int
	}
}

type Config

type Config struct {
	Resolvers  ResolverRoot
	Directives DirectiveRoot
	Complexity ComplexityRoot
}

type DirectiveRoot

type DirectiveRoot struct {
}

type MutationResolver

type MutationResolver interface {
	UserClusterReg(ctx context.Context, clusterInput model.ClusterInput) (string, error)
	ClusterConfirm(ctx context.Context, identity model.ClusterIdentity) (*model.ClusterConfirmResponse, error)
	NewClusterEvent(ctx context.Context, clusterEvent model.ClusterEventInput) (string, error)
	CreateChaosWorkFlow(ctx context.Context, input model.ChaosWorkFlowInput) (*model.ChaosWorkFlowResponse, error)
	ChaosWorkflowRun(ctx context.Context, workflowData model.WorkflowRunInput) (string, error)
	PodLog(ctx context.Context, log model.PodLog) (string, error)
	CreateUser(ctx context.Context, user model.UserInput) (*model.User, error)
	DeleteChaosWorkflow(ctx context.Context, workflowid string) (bool, error)
}

type QueryResolver

type QueryResolver interface {
	GetWorkFlowRuns(ctx context.Context, projectID string) ([]*model.WorkflowRun, error)
	GetCluster(ctx context.Context, projectID string, clusterType *string) ([]*model.Cluster, error)
	GetUser(ctx context.Context, username string) (*model.User, error)
	GetProject(ctx context.Context, projectID string) (*model.Project, error)
}

type ResolverRoot

type ResolverRoot interface {
	Mutation() MutationResolver
	Query() QueryResolver
	Subscription() SubscriptionResolver
}

type SubscriptionResolver

type SubscriptionResolver interface {
	ClusterEventListener(ctx context.Context, projectID string) (<-chan *model.ClusterEvent, error)
	ClusterConnect(ctx context.Context, clusterInfo model.ClusterIdentity) (<-chan *model.ClusterAction, error)
	WorkflowEventListener(ctx context.Context, projectID string) (<-chan *model.WorkflowRun, error)
	GetPodLog(ctx context.Context, podDetails model.PodLogRequest) (<-chan *model.PodLogResponse, error)
}