mutations

func ClusterRegister ¶

func ClusterRegister(input model.ClusterInput) (string, error)

ClusterRegister creates an entry for a new cluster in DB and generates the url used to apply manifest

func ConfirmClusterRegistration ¶

func ConfirmClusterRegistration(identity model.ClusterIdentity, r store.StateData) (*model.ClusterConfirmResponse, error)

ConfirmClusterRegistration takes the cluster_id and access_key from the subscriber and validates it, if validated generates and sends new access_key

func CreateChaosWorkflow ¶

func CreateChaosWorkflow(input *model.ChaosWorkFlowInput, r store.StateData) (*model.ChaosWorkFlowResponse, error)

func LogsHandler ¶

func LogsHandler(podLog model.PodLog, r store.StateData) (string, error)

LogsHandler receives logs from the workflow-agent and publishes to frontend clients

func NewEvent ¶

func NewEvent(clusterEvent model.ClusterEventInput, r store.StateData) (string, error)

NewEvent takes a event from a subscriber, validates identity and broadcasts the event to the users

func WorkFlowRunHandler ¶

func WorkFlowRunHandler(input model.WorkflowRunInput, r store.StateData) (string, error)

WorkFlowRunHandler Updates or Inserts a new Workflow Run into the DB