target

package
v0.8.4 Latest Latest
Warning

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

Go to latest
Published: Mar 28, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	FlowPluginName = "target-flow"
)
View Source
const (
	InstantResponsePluginName = "instant-response"
)
View Source
const (
	NamespaceFilePluginName = "target-namespace-file"
)
View Source
const (
	TargetFlowVarPluginName = "target-flow-var"
)
View Source
const (
	TargetNamespaceVarPluginName = "target-namespace-var"
)

Variables

This section is empty.

Functions

func ConfigureInstantResponse

func ConfigureInstantResponse(config interface{}, _ string) (core.PluginInstance, error)

func ConfigureNamespaceFilePlugin

func ConfigureNamespaceFilePlugin(config interface{}, ns string) (core.PluginInstance, error)

func ConfigureNamespaceVarPlugin

func ConfigureNamespaceVarPlugin(config interface{}, ns string) (core.PluginInstance, error)

func ConfigureTargetFlowPlugin

func ConfigureTargetFlowPlugin(config interface{}, ns string) (core.PluginInstance, error)

func ConfigureWorkflowVar

func ConfigureWorkflowVar(config interface{}, ns string) (core.PluginInstance, error)

Types

type FlowPlugin

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

TargetFlowPlugin executes a flow in a configured namespace. Flows can be executed async and sync.

func (FlowPlugin) Config

func (tf FlowPlugin) Config() interface{}

func (FlowPlugin) ExecutePlugin

func (tf FlowPlugin) ExecutePlugin(_ *core.ConsumerFile,
	w http.ResponseWriter, r *http.Request,
) bool

func (FlowPlugin) Type

func (tf FlowPlugin) Type() string

type FlowVarPlugin

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

TargetFlowVarPlugin returns a workflow variable.

func (FlowVarPlugin) Config

func (tfv FlowVarPlugin) Config() interface{}

func (FlowVarPlugin) ExecutePlugin

func (tfv FlowVarPlugin) ExecutePlugin(_ *core.ConsumerFile,
	w http.ResponseWriter, r *http.Request,
) bool

func (FlowVarPlugin) Type

func (tfv FlowVarPlugin) Type() string

type InstantResponseConfig

type InstantResponseConfig struct {
	StatusCode    int    `mapstructure:"status_code"    yaml:"status_code"`
	StatusMessage string `mapstructure:"status_message" yaml:"status_message"`
	ContentType   string `mapstructure:"content_type"   yaml:"content_type"`
}

type InstantResponsePlugin

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

func (*InstantResponsePlugin) Config

func (ir *InstantResponsePlugin) Config() interface{}

func (*InstantResponsePlugin) ExecutePlugin

func (ir *InstantResponsePlugin) ExecutePlugin(_ *core.ConsumerFile,
	w http.ResponseWriter, _ *http.Request,
) bool

func (*InstantResponsePlugin) Type

func (ir *InstantResponsePlugin) Type() string

type NamespaceFileConfig

type NamespaceFileConfig struct {
	Namespace   string `mapstructure:"namespace"    yaml:"namespace"`
	File        string `mapstructure:"file"         yaml:"file"`
	ContentType string `mapstructure:"content_type" yaml:"content_type"`
}

type NamespaceFilePlugin

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

TargetNamespaceFilePlugin returns a files in the explorer tree.

func (NamespaceFilePlugin) Config

func (tnf NamespaceFilePlugin) Config() interface{}

func (NamespaceFilePlugin) ExecutePlugin

func (tnf NamespaceFilePlugin) ExecutePlugin(
	_ *core.ConsumerFile,
	w http.ResponseWriter, r *http.Request,
) bool

func (NamespaceFilePlugin) Type

func (tnf NamespaceFilePlugin) Type() string

type NamespaceVarConfig

type NamespaceVarConfig struct {
	Namespace   string `mapstructure:"namespace"    yaml:"namespace"`
	Variable    string `mapstructure:"variable"     yaml:"variable"`
	ContentType string `mapstructure:"content_type" yaml:"content_type"`
}

type NamespaceVarPlugin

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

func (NamespaceVarPlugin) Config

func (tnv NamespaceVarPlugin) Config() interface{}

func (NamespaceVarPlugin) ExecutePlugin

func (tnv NamespaceVarPlugin) ExecutePlugin(_ *core.ConsumerFile,
	w http.ResponseWriter, r *http.Request,
) bool

func (NamespaceVarPlugin) Type

func (tnv NamespaceVarPlugin) Type() string

type Node

type Node struct {
	Namespace string `json:"namespace"`
	Node      struct {
		CreatedAt    time.Time `json:"createdAt"`
		UpdatedAt    time.Time `json:"updatedAt"`
		Name         string    `json:"name"`
		Path         string    `json:"path"`
		Parent       string    `json:"parent"`
		Type         string    `json:"type"`
		Attributes   []any     `json:"attributes"`
		Oid          string    `json:"oid"`
		ReadOnly     bool      `json:"readOnly"`
		ExpandedType string    `json:"expandedType"`
		MimeType     string    `json:"mimeType"`
	} `json:"node"`
	EventLogging string `json:"eventLogging"`
	Oid          string `json:"oid"`
	Source       string `json:"source"`
}

nolint

type WorkflowConfig

type WorkflowConfig struct {
	Namespace   string `mapstructure:"namespace"    yaml:"namespace"`
	Flow        string `mapstructure:"flow"         yaml:"flow"`
	Async       bool   `mapstructure:"async"        yaml:"async"`
	ContentType string `mapstructure:"content_type" yaml:"content_type"`
	// contains filtered or unexported fields
}

type WorkflowVarConfig

type WorkflowVarConfig struct {
	Namespace   string `mapstructure:"namespace"    yaml:"namespace"`
	Flow        string `mapstructure:"flow"         yaml:"flow"`
	Variable    string `mapstructure:"variable"     yaml:"variable"`
	ContentType string `mapstructure:"content_type" yaml:"content_type"`
}

Jump to

Keyboard shortcuts

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