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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClusterConnect ¶
func CommonHeaders ¶
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 ¶
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
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.