primitive

package
v0.2.0-rc.6 Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2024 License: AGPL-3.0 Imports: 48 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DriverPostgres = "postgres"
	DriverMySQL    = "mysql"
	DriverDuckDB   = "duckdb"
	DriverSQLite   = "sqlite3"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Container 

type Container struct{}

func (*Container) Run 

func (e *Container) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Container) ValidateInput 

func (e *Container) ValidateInput(ctx context.Context, i modconfig.Input) error

type Email 

type Email struct {
	Input modconfig.Input
}

func (*Email) Run 

func (h *Email) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Email) ValidateInput 

func (h *Email) ValidateInput(ctx context.Context, i modconfig.Input) error

type Exec 

type Exec struct{}

func (*Exec) Run 

func (e *Exec) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Exec) ValidateInput 

func (e *Exec) ValidateInput(ctx context.Context, i modconfig.Input) error

type Function 

type Function struct{}

func (*Function) Run 

func (e *Function) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Function) ValidateInput 

func (e *Function) ValidateInput(ctx context.Context, i modconfig.Input) error

type HTTPInput 

type HTTPInput struct {
	URL            string
	Method         string
	RequestBody    string
	RequestHeaders map[string]interface{}
	CaCertPem      string
	Insecure       bool
	Timeout        time.Duration
}

type HTTPRequest 

type HTTPRequest struct {
	Input modconfig.Input
}

func (*HTTPRequest) Run 

func (h *HTTPRequest) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*HTTPRequest) ValidateInput 

func (h *HTTPRequest) ValidateInput(ctx context.Context, i modconfig.Input) error

type Input 

type Input struct {
	ExecutionID         string
	PipelineExecutionID string
	StepExecutionID     string
}

func (*Input) ProcessOutput 

func (ip *Input) ProcessOutput(c *gin.Context, inputType InputType, requestBody []byte) (*modconfig.Output, error)

func (*Input) Run 

func (ip *Input) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Input) ValidateInput 

func (ip *Input) ValidateInput(ctx context.Context, i modconfig.Input) error

type InputIntegration 

type InputIntegration interface {
	PostMessage(modconfig.Input) error
	ReceiveMessage() (*modconfig.Output, error)
}

type InputIntegrationBase 

type InputIntegrationBase struct {
	ExecutionID         string
	PipelineExecutionID string
	StepExecutionID     string
}

type InputIntegrationEmail 

type InputIntegrationEmail struct {
	InputIntegrationBase
}

func (*InputIntegrationEmail) PostMessage 

func (i *InputIntegrationEmail) PostMessage(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*InputIntegrationEmail) ReceiveMessage 

func (*InputIntegrationEmail) ReceiveMessage(c *gin.Context) (*modconfig.Output, error)

func (*InputIntegrationEmail) ValidateInputIntegrationEmail 

func (inputEmail *InputIntegrationEmail) ValidateInputIntegrationEmail(ctx context.Context, i modconfig.Input) error

type InputIntegrationSlack 

type InputIntegrationSlack struct {
	InputIntegrationBase
}

func (*InputIntegrationSlack) PostMessage 

func (ip *InputIntegrationSlack) PostMessage(input modconfig.Input) error

func (*InputIntegrationSlack) ReceiveMessage 

func (*InputIntegrationSlack) ReceiveMessage(ctx context.Context, requestBody []byte) (*modconfig.Output, error)

type InputType 

type InputType string
const (
	InputTypeSlack InputType = "slack"
	InputTypeEmail InputType = "email"
)

type JSONPayload 

type JSONPayload struct {
	PipelineExecutionID string `json:"pipeline_execution_id"`
	StepExecutionID     string `json:"step_execution_id"`
	ExecutionID         string `json:"execution_id"`
}

type Primitive 

type Primitive interface {
	Run(modconfig.Input) (*modconfig.Output, error)
}

type Query 

type Query struct {
	// contains filtered or unexported fields
}

func (*Query) InitializeDB 

func (e *Query) InitializeDB(ctx context.Context, i modconfig.Input) (*sql.DB, error)

func (*Query) Run 

func (e *Query) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Query) ValidateInput 

func (e *Query) ValidateInput(ctx context.Context, i modconfig.Input) error

type RunPipeline 

type RunPipeline struct{}

func (*RunPipeline) Run 

func (e *RunPipeline) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*RunPipeline) ValidateInput 

func (e *RunPipeline) ValidateInput(ctx context.Context, input modconfig.Input) error

type Sleep 

type Sleep struct{}

func (*Sleep) Run 

func (e *Sleep) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Sleep) ValidateInput 

func (e *Sleep) ValidateInput(ctx context.Context, input modconfig.Input) error

type Transform 

type Transform struct{}

func (*Transform) Run 

func (e *Transform) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Transform) ValidateInput 

func (e *Transform) ValidateInput(ctx context.Context, i modconfig.Input) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.