Versions in this module Expand all Collapse all v0 v0.5.0 Mar 30, 2026 Changes in this version + type Severity int + const SeverityError + const SeverityInfo + const SeverityWarning + type StepDefinition struct + Command string + Config map[string]any + Description string + OnFailure string + OnSuccess string + Operation string + Timeout int + Type string + type StepExecuteRequest struct + Config map[string]any + Inputs map[string]any + StepName string + StepType string + type StepExecuteResult struct + Data map[string]any + ExitCode int32 + Output string + type StepTypeHandler interface + ExecuteStep func(ctx context.Context, req StepExecuteRequest) (StepExecuteResult, error) + StepTypes func() []StepTypeInfo + type StepTypeInfo struct + Description string + Name string + type ValidationIssue struct + Field string + Message string + Severity Severity + Step string + type Validator interface + ValidateStep func(ctx context.Context, workflow WorkflowDefinition, stepName string) ([]ValidationIssue, error) + ValidateWorkflow func(ctx context.Context, workflow WorkflowDefinition) ([]ValidationIssue, error) + type WorkflowDefinition struct + Author string + Description string + Initial string + Name string + Steps map[string]StepDefinition + Tags []string + Version string v0.4.1 Mar 28, 2026 Changes in this version + const InputTypeArray + const InputTypeBoolean + const InputTypeInteger + const InputTypeObject + const InputTypeString + var ErrInvalidInput = errors.New("invalid input") + var ErrNotImplemented = errors.New("not implemented") + var ErrOperationFailed = errors.New("operation failed") + var Handshake = goplugin.HandshakeConfig + var ValidInputTypes = []string + func GetBool(inputs map[string]any, key string) (value, ok bool) + func GetBoolDefault(inputs map[string]any, key string, defaultValue bool) bool + func GetInt(inputs map[string]any, key string) (int, bool) + func GetIntDefault(inputs map[string]any, key string, defaultValue int) int + func GetString(inputs map[string]any, key string) (string, bool) + func GetStringDefault(inputs map[string]any, key, defaultValue string) string + func IsValidInputType(t string) bool + func Serve(p Plugin) + func TestConfig(keyValues ...any) map[string]any + func TestInputs(keyValues ...any) map[string]any + type BasePlugin struct + PluginName string + PluginVersion string + func (p *BasePlugin) Init(_ context.Context, _ map[string]any) error + func (p *BasePlugin) Name() string + func (p *BasePlugin) Shutdown(_ context.Context) error + func (p *BasePlugin) Version() string + type GRPCPluginBridge struct + func (b *GRPCPluginBridge) GRPCClient(_ context.Context, _ *goplugin.GRPCBroker, _ *grpc.ClientConn) (interface{}, error) + func (b *GRPCPluginBridge) GRPCServer(_ *goplugin.GRPCBroker, s *grpc.Server) (err error) + type InputSchema struct + Default any + Description string + Required bool + Type string + Validation string + func OptionalInput(inputType, description string, defaultValue any) InputSchema + func RequiredInput(inputType, description string) InputSchema + type MockOperationHandler struct + CallCount int + Error error + HandleFunc func(ctx context.Context, inputs map[string]any) (map[string]any, error) + LastInputs map[string]any + Outputs map[string]any + func NewMockOperationHandler() *MockOperationHandler + func (m *MockOperationHandler) GetCallCount() int + func (m *MockOperationHandler) Handle(ctx context.Context, inputs map[string]any) (map[string]any, error) + func (m *MockOperationHandler) Reset() + type MockOperationProvider struct + Errors map[string]error + HandleFunc func(ctx context.Context, name string, inputs map[string]any) (*OperationResult, error) + LastInputs map[string]any + LastOperation string + OperationNames []string + Results map[string]*OperationResult + func NewMockOperationProvider(operations ...string) *MockOperationProvider + func (m *MockOperationProvider) HandleOperation(ctx context.Context, name string, inputs map[string]any) (*OperationResult, error) + func (m *MockOperationProvider) Operations() []string + func (m *MockOperationProvider) SetCommandResult(operation string, result *OperationResult) + func (m *MockOperationProvider) SetError(operation string, err error) + func (m *MockOperationProvider) SetResult(operation string, result *OperationResult) + type MockPlugin struct + InitCalled bool + InitError error + LastConfig map[string]any + PluginName string + PluginVersion string + ShutdownCalled bool + ShutdownError error + func NewMockPlugin(name, version string) *MockPlugin + func (m *MockPlugin) Init(_ context.Context, config map[string]any) error + func (m *MockPlugin) Name() string + func (m *MockPlugin) Reset() + func (m *MockPlugin) Shutdown(_ context.Context) error + func (m *MockPlugin) Version() string + func (m *MockPlugin) WasInitCalled() bool + func (m *MockPlugin) WasShutdownCalled() bool + type OperationHandler interface + Handle func(ctx context.Context, inputs map[string]any) (map[string]any, error) + type OperationProvider interface + HandleOperation func(ctx context.Context, name string, inputs map[string]any) (*OperationResult, error) + Operations func() []string + type OperationResult struct + Data map[string]any + Error string + Output string + Success bool + func NewErrorResult(errMsg string) *OperationResult + func NewErrorResultf(format string, args ...any) *OperationResult + func NewSuccessResult(output string, data map[string]any) *OperationResult + func (r *OperationResult) ToMap() map[string]any + type OperationSchema struct + Description string + Inputs map[string]InputSchema + Name string + Outputs []string + type Plugin interface + Init func(ctx context.Context, config map[string]any) error + Name func() string + Shutdown func(ctx context.Context) error + Version func() string
Go to main page