messages

package
v0.30.0 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PassedOutputChannel = "passed"
	FailedOutputChannel = "failed"
	ActionRunTimeout    = "onRunTimeout"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AppMetadata added in v0.30.0 

type AppMetadata struct {
	ID   string `json:"id" mapstructure:"id"`
	Name string `json:"name" mapstructure:"name"`
}

type BroadcastMessage 

type BroadcastMessage struct{}

func (*BroadcastMessage) Cancel 

func (c *BroadcastMessage) Cancel(ctx core.ExecutionContext) error

func (*BroadcastMessage) Cleanup 

func (c *BroadcastMessage) Cleanup(ctx core.SetupContext) error

func (*BroadcastMessage) Color 

func (c *BroadcastMessage) Color() string

func (*BroadcastMessage) Configuration 

func (c *BroadcastMessage) Configuration() []configuration.Field

func (*BroadcastMessage) Description 

func (c *BroadcastMessage) Description() string

func (*BroadcastMessage) Documentation 

func (c *BroadcastMessage) Documentation() string

func (*BroadcastMessage) ExampleOutput 

func (c *BroadcastMessage) ExampleOutput() map[string]any

func (*BroadcastMessage) Execute 

func (c *BroadcastMessage) Execute(ctx core.ExecutionContext) error

func (*BroadcastMessage) HandleHook 

func (c *BroadcastMessage) HandleHook(ctx core.ActionHookContext) error

func (*BroadcastMessage) HandleWebhook 

func (c *BroadcastMessage) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*BroadcastMessage) Hooks 

func (c *BroadcastMessage) Hooks() []core.Hook

func (*BroadcastMessage) Icon 

func (c *BroadcastMessage) Icon() string

func (*BroadcastMessage) Label 

func (c *BroadcastMessage) Label() string

func (*BroadcastMessage) Name 

func (c *BroadcastMessage) Name() string

func (*BroadcastMessage) OutputChannels 

func (c *BroadcastMessage) OutputChannels(configuration any) []core.OutputChannel

func (*BroadcastMessage) ProcessQueueItem 

func (c *BroadcastMessage) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*BroadcastMessage) Setup 

func (c *BroadcastMessage) Setup(ctx core.SetupContext) error

type BroadcastMessageConfiguration 

type BroadcastMessageConfiguration struct {
	Payload any `json:"payload" mapstructure:"payload"`
}

type CanvasNodeMetadata added in v0.30.0 

type CanvasNodeMetadata struct {
	ID   string `json:"id" mapstructure:"id"`
	Name string `json:"name" mapstructure:"name"`
}

type RunApp added in v0.30.0 

type RunApp struct{}

func (*RunApp) Cancel added in v0.30.0 

func (c *RunApp) Cancel(ctx core.ExecutionContext) error

func (*RunApp) Cleanup added in v0.30.0 

func (c *RunApp) Cleanup(ctx core.SetupContext) error

func (*RunApp) Color added in v0.30.0 

func (c *RunApp) Color() string

func (*RunApp) Configuration added in v0.30.0 

func (c *RunApp) Configuration() []configuration.Field

func (*RunApp) Description added in v0.30.0 

func (c *RunApp) Description() string

func (*RunApp) Documentation added in v0.30.0 

func (c *RunApp) Documentation() string

func (*RunApp) ExampleOutput added in v0.30.0 

func (c *RunApp) ExampleOutput() map[string]any

func (*RunApp) Execute added in v0.30.0 

func (c *RunApp) Execute(ctx core.ExecutionContext) error

func (*RunApp) HandleHook added in v0.30.0 

func (c *RunApp) HandleHook(ctx core.ActionHookContext) error

func (*RunApp) HandleWebhook added in v0.30.0 

func (c *RunApp) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*RunApp) Hooks added in v0.30.0 

func (c *RunApp) Hooks() []core.Hook

func (*RunApp) Icon added in v0.30.0 

func (c *RunApp) Icon() string

func (*RunApp) Label added in v0.30.0 

func (c *RunApp) Label() string

func (*RunApp) Name added in v0.30.0 

func (c *RunApp) Name() string

func (*RunApp) OutputChannels added in v0.30.0 

func (c *RunApp) OutputChannels(configuration any) []core.OutputChannel

func (*RunApp) ProcessQueueItem added in v0.30.0 

func (c *RunApp) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*RunApp) Setup added in v0.30.0 

func (c *RunApp) Setup(ctx core.SetupContext) error

type RunAppConfiguration added in v0.30.0 

type RunAppConfiguration struct {
	App        string         `json:"app" mapstructure:"app"`
	Node       string         `json:"node" mapstructure:"node"`
	Parameters map[string]any `json:"parameters" mapstructure:"parameters"`
	Timeout    *int           `json:"timeout,omitempty" mapstructure:"timeout,omitempty"`
}

func (*RunAppConfiguration) TimeoutDuration added in v0.30.0 

func (c *RunAppConfiguration) TimeoutDuration() time.Duration

type RunAppMetadata added in v0.30.0 

type RunAppMetadata struct {
	App  *AppMetadata        `json:"app" mapstructure:"app"`
	Node *CanvasNodeMetadata `json:"node" mapstructure:"node"`
}

type RunMetadata added in v0.30.0 

type RunMetadata struct {
	ID     string  `json:"id" mapstructure:"id"`
	Result string  `json:"result" mapstructure:"result"`
	Error  *string `json:"error,omitempty" mapstructure:"error,omitempty"`
}

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.