Documentation
¶
Index ¶
Constants ¶
View Source
const StartAction = "start_pipeline"
View Source
const StopAction = "stop_pipeline"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Letter ¶
type Letter struct {
Action Action `json:"action"`
Payload interface{} `json:"payload"`
Timestamp time.Time `json:"timestamp"`
AckId string `json:"ackId"`
}
func (*Letter) StartPipelinePayload ¶
func (l *Letter) StartPipelinePayload() (*StartPipelinePayload, error)
func (*Letter) StopPipelinePayload ¶
func (l *Letter) StopPipelinePayload() (*StopPipelinePayload, error)
type StartPipelinePayload ¶
type StartPipelinePayload struct {
WorkflowId int64 `json:"workflowId"`
PipelineId int64 `json:"pipelineId"`
Yaml string `json:"yaml"`
Salt string `json:"salt"`
Uuid string `json:"uuid"`
Envs map[string]string `json:"envs"`
}
func (*StartPipelinePayload) String ¶
func (s *StartPipelinePayload) String() string
type StopPipelinePayload ¶
type StopPipelinePayload struct {
WorkflowId int64 `json:"workflowId"`
PipelineId int64 `json:"pipelineId"`
Salt string `json:"salt"`
Uuid string `json:"uuid"`
}
func (*StopPipelinePayload) String ¶
func (s *StopPipelinePayload) String() string
Click to show internal directories.
Click to hide internal directories.