letter

package
v0.0.0-...-feeaf7e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 19, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

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 Action

type Action string

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL