gql

Documentation

Index

• func ClusterConfirm(clusterData map[string]string) ([]byte, error)
• func ClusterConnect(clusterData map[string]string)
• func CommonHeaders(req *http.Request)
• func CreatePodLog(podLog types.PodLogRequest) (types.PodLog, error)
• func GenerateLogPayload(cid, accessKey string, podLog types.PodLogRequest) ([]byte, error)
• func GenerateWorkflowPayload(cid, accessKey string, wfEvent types.WorkflowEvent) ([]byte, error)
• func MarshalGQLData(gqlData interface{}) (string, error)
• func SendPodLogs(clusterData map[string]string, podLog types.PodLogRequest)
• func SendWorkflowUpdates(clusterData map[string]string, event chan types.WorkflowEvent)

Functions

func ClusterConfirm

func ClusterConfirm(clusterData map[string]string) ([]byte, error)

func ClusterConnect

func ClusterConnect(clusterData map[string]string)

func CommonHeaders

func CommonHeaders(req *http.Request)

func CreatePodLog

func CreatePodLog(podLog types.PodLogRequest) (types.PodLog, error)

create pod log for normal pods and chaos-engine pods

func GenerateLogPayload

func GenerateLogPayload(cid, accessKey string, podLog types.PodLogRequest) ([]byte, error)

func GenerateWorkflowPayload

func GenerateWorkflowPayload(cid, accessKey string, wfEvent types.WorkflowEvent) ([]byte, error)

generate gql mutation payload for workflow event

func MarshalGQLData

func MarshalGQLData(gqlData interface{}) (string, error)

process event data into proper format acceptable by gql

func SendPodLogs

func SendPodLogs(clusterData map[string]string, podLog types.PodLogRequest)

SendPodLogs generates gql mutation to send workflow updates to gql server

func SendWorkflowUpdates

func SendWorkflowUpdates(clusterData map[string]string, event chan types.WorkflowEvent)

SendWorkflowUpdates generates gql mutation to send workflow updates to gql server