proto

type ConfigFieldDef struct {
	Name         string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type         string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Description  string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	DefaultValue string   `protobuf:"bytes,4,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	Required     bool     `protobuf:"varint,5,opt,name=required,proto3" json:"required,omitempty"`
	Options      []string `protobuf:"bytes,6,rep,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type CreateModuleRequest struct {
	Type   string           `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Name   string           `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Config *structpb.Struct `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type CreateStepRequest struct {
	Type   string           `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Name   string           `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Config *structpb.Struct `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type EngineCallbackServiceClient interface {
	// TriggerWorkflow fires a workflow trigger from the plugin side.
	TriggerWorkflow(ctx context.Context, in *TriggerWorkflowRequest, opts ...grpc.CallOption) (*ErrorResponse, error)
	// GetService checks if a named service exists in the host registry.
	GetService(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*GetServiceResponse, error)
	// Log sends a log entry from the plugin to the host logger.
	Log(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type EngineCallbackServiceServer interface {
	// TriggerWorkflow fires a workflow trigger from the plugin side.
	TriggerWorkflow(context.Context, *TriggerWorkflowRequest) (*ErrorResponse, error)
	// GetService checks if a named service exists in the host registry.
	GetService(context.Context, *GetServiceRequest) (*GetServiceResponse, error)
	// Log sends a log entry from the plugin to the host logger.
	Log(context.Context, *LogRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type ErrorResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteStepRequest struct {
	HandleId    string                      `protobuf:"bytes,1,opt,name=handle_id,json=handleId,proto3" json:"handle_id,omitempty"`
	TriggerData *structpb.Struct            `protobuf:"bytes,2,opt,name=trigger_data,json=triggerData,proto3" json:"trigger_data,omitempty"`
	StepOutputs map[string]*structpb.Struct `` /* 168-byte string literal not displayed */
	Current     *structpb.Struct            `protobuf:"bytes,4,opt,name=current,proto3" json:"current,omitempty"`
	Metadata    *structpb.Struct            `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteStepResponse struct {
	Output       *structpb.Struct `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Error        string           `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	StopPipeline bool             `protobuf:"varint,3,opt,name=stop_pipeline,json=stopPipeline,proto3" json:"stop_pipeline,omitempty"`
	// contains filtered or unexported fields
}

type GetServiceRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetServiceResponse struct {
	Found bool `protobuf:"varint,1,opt,name=found,proto3" json:"found,omitempty"`
	// contains filtered or unexported fields
}

type HandleRequest struct {
	HandleId string `protobuf:"bytes,1,opt,name=handle_id,json=handleId,proto3" json:"handle_id,omitempty"`
	// contains filtered or unexported fields
}

type HandleResponse struct {
	HandleId string `protobuf:"bytes,1,opt,name=handle_id,json=handleId,proto3" json:"handle_id,omitempty"`
	Error    string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type InvokeServiceRequest struct {
	HandleId string           `protobuf:"bytes,1,opt,name=handle_id,json=handleId,proto3" json:"handle_id,omitempty"`
	Method   string           `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Args     *structpb.Struct `protobuf:"bytes,3,opt,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

type InvokeServiceResponse struct {
	Result *structpb.Struct `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Error  string           `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type LogRequest struct {
	Level   string           `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"`
	Message string           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Fields  *structpb.Struct `protobuf:"bytes,3,opt,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type Manifest struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version     string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Author      string `protobuf:"bytes,3,opt,name=author,proto3" json:"author,omitempty"`
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

type ModuleSchema struct {
	Type         string            `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Label        string            `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Category     string            `protobuf:"bytes,3,opt,name=category,proto3" json:"category,omitempty"`
	Description  string            `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Inputs       []*ServiceIODef   `protobuf:"bytes,5,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs      []*ServiceIODef   `protobuf:"bytes,6,rep,name=outputs,proto3" json:"outputs,omitempty"`
	ConfigFields []*ConfigFieldDef `protobuf:"bytes,7,rep,name=config_fields,json=configFields,proto3" json:"config_fields,omitempty"`
	// contains filtered or unexported fields
}

type ModuleSchemaList struct {
	Schemas []*ModuleSchema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
	// contains filtered or unexported fields
}

type PluginServiceClient interface {
	// GetManifest returns the plugin's metadata.
	GetManifest(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Manifest, error)
	// GetModuleTypes returns the module type names this plugin provides.
	GetModuleTypes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TypeList, error)
	// GetStepTypes returns the step type names this plugin provides.
	GetStepTypes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TypeList, error)
	// GetTriggerTypes returns the trigger type names this plugin provides.
	GetTriggerTypes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TypeList, error)
	// GetModuleSchemas returns UI schema definitions for the plugin's module types.
	GetModuleSchemas(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ModuleSchemaList, error)
	// CreateModule instantiates a module of the given type.
	CreateModule(ctx context.Context, in *CreateModuleRequest, opts ...grpc.CallOption) (*HandleResponse, error)
	// InitModule initializes a previously created module.
	InitModule(ctx context.Context, in *HandleRequest, opts ...grpc.CallOption) (*ErrorResponse, error)
	// StartModule starts a previously initialized module.
	StartModule(ctx context.Context, in *HandleRequest, opts ...grpc.CallOption) (*ErrorResponse, error)
	// StopModule stops a running module.
	StopModule(ctx context.Context, in *HandleRequest, opts ...grpc.CallOption) (*ErrorResponse, error)
	// DestroyModule destroys a module and releases its resources.
	DestroyModule(ctx context.Context, in *HandleRequest, opts ...grpc.CallOption) (*ErrorResponse, error)
	// CreateStep instantiates a pipeline step of the given type.
	CreateStep(ctx context.Context, in *CreateStepRequest, opts ...grpc.CallOption) (*HandleResponse, error)
	// ExecuteStep runs a pipeline step with the given context.
	ExecuteStep(ctx context.Context, in *ExecuteStepRequest, opts ...grpc.CallOption) (*ExecuteStepResponse, error)
	// DestroyStep destroys a step and releases its resources.
	DestroyStep(ctx context.Context, in *HandleRequest, opts ...grpc.CallOption) (*ErrorResponse, error)
	// InvokeService calls a named method on a module's service interface.
	InvokeService(ctx context.Context, in *InvokeServiceRequest, opts ...grpc.CallOption) (*InvokeServiceResponse, error)
}

type PluginServiceServer interface {
	// GetManifest returns the plugin's metadata.
	GetManifest(context.Context, *emptypb.Empty) (*Manifest, error)
	// GetModuleTypes returns the module type names this plugin provides.
	GetModuleTypes(context.Context, *emptypb.Empty) (*TypeList, error)
	// GetStepTypes returns the step type names this plugin provides.
	GetStepTypes(context.Context, *emptypb.Empty) (*TypeList, error)
	// GetTriggerTypes returns the trigger type names this plugin provides.
	GetTriggerTypes(context.Context, *emptypb.Empty) (*TypeList, error)
	// GetModuleSchemas returns UI schema definitions for the plugin's module types.
	GetModuleSchemas(context.Context, *emptypb.Empty) (*ModuleSchemaList, error)
	// CreateModule instantiates a module of the given type.
	CreateModule(context.Context, *CreateModuleRequest) (*HandleResponse, error)
	// InitModule initializes a previously created module.
	InitModule(context.Context, *HandleRequest) (*ErrorResponse, error)
	// StartModule starts a previously initialized module.
	StartModule(context.Context, *HandleRequest) (*ErrorResponse, error)
	// StopModule stops a running module.
	StopModule(context.Context, *HandleRequest) (*ErrorResponse, error)
	// DestroyModule destroys a module and releases its resources.
	DestroyModule(context.Context, *HandleRequest) (*ErrorResponse, error)
	// CreateStep instantiates a pipeline step of the given type.
	CreateStep(context.Context, *CreateStepRequest) (*HandleResponse, error)
	// ExecuteStep runs a pipeline step with the given context.
	ExecuteStep(context.Context, *ExecuteStepRequest) (*ExecuteStepResponse, error)
	// DestroyStep destroys a step and releases its resources.
	DestroyStep(context.Context, *HandleRequest) (*ErrorResponse, error)
	// InvokeService calls a named method on a module's service interface.
	InvokeService(context.Context, *InvokeServiceRequest) (*InvokeServiceResponse, error)
	// contains filtered or unexported methods
}

type ServiceIODef struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type        string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

type TriggerWorkflowRequest struct {
	TriggerType string           `protobuf:"bytes,1,opt,name=trigger_type,json=triggerType,proto3" json:"trigger_type,omitempty"`
	Action      string           `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	Data        *structpb.Struct `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type TypeList struct {
	Types []string `protobuf:"bytes,1,rep,name=types,proto3" json:"types,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedEngineCallbackServiceServer struct{}

type UnimplementedPluginServiceServer struct{}

type UnsafeEngineCallbackServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafePluginServiceServer interface {
	// contains filtered or unexported methods
}