websocket

type WebsocketClient struct {
	WsConn *websocket.Conn

	Ctx    context.Context    // corresponds to ws session, so ok in struct
	Cancel context.CancelFunc // as above
	// contains filtered or unexported fields
}

type WebsocketOptions struct {
	PingPeriod     time.Duration
	PongWait       time.Duration
	MaxMessageSize int64
	WriteWait      time.Duration
}

type WorkFlowResponseData struct {
	Result       interface{} `json:"result"`
	WorkflowId   string      `json:"workflowId"`
	WorkflowName string      `json:"workflowName"`
	WsClientId   string      `json:"wsClientId"`
}

type WorkflowResponse struct {
	SpecVersion     string               `json:"specversion"`
	Id              string               `json:"id"`
	Source          string               `json:"source"`
	Type            string               `json:"type"`
	Subject         string               `json:"subject"`
	DataContentType string               `json:"datacontenttype"`
	Time            string               `json:"time"`
	Data            WorkFlowResponseData `json:"data"`
	EventKind       string               `json:"eventkind"`
	EventResource   string               `json:"eventresource"`
	Recipient       string               `json:"recipient"`
	CorrelationId   string               `json:"correlationid"`
	Stream          string               `json:"stream"`
}