engine

Mar 19, 2025

Changes in this version

+ type AllowLimiter interface

+ Allow func(ctx context.Context) bool

type Options

+ HandleProcessingError func(msg string, err error)

+ Meter otelmetric.Meter

+ RL *workflowRateLimiter

+ RedisClient rueidis.Client

+ RedisKeyPrefix string

+ Tracer trace.Tracer

+ WorkerInterceptors []tinterceptor.WorkerInterceptor

+ WorkflowsPerProjectIDEventTypePerMinute uint32

+ type RateLimiterCtxKey string

Dec 18, 2024

Changes in this version

+ func EventToDict(e *event.CloudEvent) (*starlark.Dict, error)

+ func HTTPDo(ctx context.Context, rt http.RoundTripper, url, method string, body []byte, ...) (statusCode int, status string, respHeader http.Header, respBody []byte, ...)

type Engine

+ func (e *Engine) HandleEvent(ctx context.Context, req *HandleEventRequest) error

+ type HandleEventRequest struct

+ Event *event.CloudEvent

+ FlowProject *event.Project

+ Variables map[string]string

+ func (*HandleEventRequest) Descriptor() ([]byte, []int)

+ func (*HandleEventRequest) ProtoMessage()

+ func (x *HandleEventRequest) GetEvent() *event.CloudEvent

+ func (x *HandleEventRequest) GetFlowProject() *event.Project

+ func (x *HandleEventRequest) GetVariables() map[string]string

+ func (x *HandleEventRequest) ProtoReflect() protoreflect.Message

+ func (x *HandleEventRequest) Reset()

+ func (x *HandleEventRequest) String() string

type HandleEventWorkflowInput

+ Variables map[string]string

+ func (x *HandleEventWorkflowInput) GetVariables() map[string]string

type RunEventHandlerWorkflowInput

+ Variables map[string]string

+ func (x *RunEventHandlerWorkflowInput) GetVariables() map[string]string

Aug 14, 2024

Changes in this version

+ var File_internal_module_autoflow_engine_engine_proto protoreflect.FileDescriptor

+ type Engine struct

+ func NewEngine(opts Options) (*Engine, error)

+ func (e *Engine) Event(ctx context.Context, req *rpc.CloudEventRequest) error

+ func (e *Engine) Run(ctx context.Context) error

+ type HandleEventWorkflowInput struct

+ Entrypoint string

+ Event *event.CloudEvent

+ FlowProject *event.Project

+ func (*HandleEventWorkflowInput) Descriptor() ([]byte, []int)

+ func (*HandleEventWorkflowInput) ProtoMessage()

+ func (x *HandleEventWorkflowInput) GetEntrypoint() string

+ func (x *HandleEventWorkflowInput) GetEvent() *event.CloudEvent

+ func (x *HandleEventWorkflowInput) GetFlowProject() *event.Project

+ func (x *HandleEventWorkflowInput) ProtoReflect() protoreflect.Message

+ func (x *HandleEventWorkflowInput) Reset()

+ func (x *HandleEventWorkflowInput) String() string

+ type HandleEventWorkflowOutput struct

+ func (*HandleEventWorkflowOutput) Descriptor() ([]byte, []int)

+ func (*HandleEventWorkflowOutput) ProtoMessage()

+ func (x *HandleEventWorkflowOutput) ProtoReflect() protoreflect.Message

+ func (x *HandleEventWorkflowOutput) Reset()

+ func (x *HandleEventWorkflowOutput) String() string

+ type HandlerInfo struct

+ WorkflowId string

+ func (*HandlerInfo) Descriptor() ([]byte, []int)

+ func (*HandlerInfo) ProtoMessage()

+ func (x *HandlerInfo) GetWorkflowId() string

+ func (x *HandlerInfo) ProtoReflect() protoreflect.Message

+ func (x *HandlerInfo) Reset()

+ func (x *HandlerInfo) String() string

+ type HttpDoActivityInput struct

+ Body []byte

+ Header map[string]*Values

+ Method string

+ Url string

+ func (*HttpDoActivityInput) Descriptor() ([]byte, []int)

+ func (*HttpDoActivityInput) ProtoMessage()

+ func (x *HttpDoActivityInput) GetBody() []byte

+ func (x *HttpDoActivityInput) GetHeader() map[string]*Values

+ func (x *HttpDoActivityInput) GetMethod() string

+ func (x *HttpDoActivityInput) GetUrl() string

+ func (x *HttpDoActivityInput) ProtoReflect() protoreflect.Message

+ func (x *HttpDoActivityInput) Reset()

+ func (x *HttpDoActivityInput) String() string

+ type HttpDoActivityOutput struct

+ Body []byte

+ Header map[string]*Values

+ Status string

+ StatusCode uint32

+ func (*HttpDoActivityOutput) Descriptor() ([]byte, []int)

+ func (*HttpDoActivityOutput) ProtoMessage()

+ func (x *HttpDoActivityOutput) GetBody() []byte

+ func (x *HttpDoActivityOutput) GetHeader() map[string]*Values

+ func (x *HttpDoActivityOutput) GetStatus() string

+ func (x *HttpDoActivityOutput) GetStatusCode() uint32

+ func (x *HttpDoActivityOutput) ProtoReflect() protoreflect.Message

+ func (x *HttpDoActivityOutput) Reset()

+ func (x *HttpDoActivityOutput) String() string

+ type LoadAllEventHandlersActivityInput struct

+ Entrypoint string

+ Event *event.CloudEvent

+ FlowProject *event.Project

+ func (*LoadAllEventHandlersActivityInput) Descriptor() ([]byte, []int)

+ func (*LoadAllEventHandlersActivityInput) ProtoMessage()

+ func (x *LoadAllEventHandlersActivityInput) GetEntrypoint() string

+ func (x *LoadAllEventHandlersActivityInput) GetEvent() *event.CloudEvent

+ func (x *LoadAllEventHandlersActivityInput) GetFlowProject() *event.Project

+ func (x *LoadAllEventHandlersActivityInput) ProtoReflect() protoreflect.Message

+ func (x *LoadAllEventHandlersActivityInput) Reset()

+ func (x *LoadAllEventHandlersActivityInput) String() string

+ type LoadAllEventHandlersActivityOutput struct

+ Handlers []*HandlerInfo

+ Modules []*ModuleSource

+ func (*LoadAllEventHandlersActivityOutput) Descriptor() ([]byte, []int)

+ func (*LoadAllEventHandlersActivityOutput) ProtoMessage()

+ func (x *LoadAllEventHandlersActivityOutput) GetHandlers() []*HandlerInfo

+ func (x *LoadAllEventHandlersActivityOutput) GetModules() []*ModuleSource

+ func (x *LoadAllEventHandlersActivityOutput) ProtoReflect() protoreflect.Message

+ func (x *LoadAllEventHandlersActivityOutput) Reset()

+ func (x *LoadAllEventHandlersActivityOutput) String() string

+ type ModuleSource struct

+ Data []byte

+ File string

+ SourceName string

+ func (*ModuleSource) Descriptor() ([]byte, []int)

+ func (*ModuleSource) ProtoMessage()

+ func (x *ModuleSource) GetData() []byte

+ func (x *ModuleSource) GetFile() string

+ func (x *ModuleSource) GetSourceName() string

+ func (x *ModuleSource) ProtoReflect() protoreflect.Message

+ func (x *ModuleSource) Reset()

+ func (x *ModuleSource) String() string

+ type Options struct

+ GitLabClient gitlab.ClientInterface

+ GitLabURL string

+ GitalyPool gitaly.PoolInterface

+ HTTPRT http.RoundTripper

+ Log *slog.Logger

+ RepoInfoCache *cache.CacheWithErr[RepoInfoCacheKey, *api.ProjectInfo]

+ TC tclient.Client

+ TaskQueue string

+ type RepoInfoCacheKey struct

+ ProjectID string

+ type RunEventHandlerWorkflowInput struct

+ Entrypoint string

+ Event *event.CloudEvent

+ FlowProject *event.Project

+ Handler uint32

+ Modules []*ModuleSource

+ WorkflowIdPrefix string

+ func (*RunEventHandlerWorkflowInput) Descriptor() ([]byte, []int)

+ func (*RunEventHandlerWorkflowInput) ProtoMessage()

+ func (x *RunEventHandlerWorkflowInput) GetEntrypoint() string

+ func (x *RunEventHandlerWorkflowInput) GetEvent() *event.CloudEvent

+ func (x *RunEventHandlerWorkflowInput) GetFlowProject() *event.Project

+ func (x *RunEventHandlerWorkflowInput) GetHandler() uint32

+ func (x *RunEventHandlerWorkflowInput) GetModules() []*ModuleSource

+ func (x *RunEventHandlerWorkflowInput) GetWorkflowIdPrefix() string

+ func (x *RunEventHandlerWorkflowInput) ProtoReflect() protoreflect.Message

+ func (x *RunEventHandlerWorkflowInput) Reset()

+ func (x *RunEventHandlerWorkflowInput) String() string

+ type RunEventHandlerWorkflowOutput struct

+ func (*RunEventHandlerWorkflowOutput) Descriptor() ([]byte, []int)

+ func (*RunEventHandlerWorkflowOutput) ProtoMessage()

+ func (x *RunEventHandlerWorkflowOutput) ProtoReflect() protoreflect.Message

+ func (x *RunEventHandlerWorkflowOutput) Reset()

+ func (x *RunEventHandlerWorkflowOutput) String() string

+ type SignalPayload struct

+ Payload string

+ func (*SignalPayload) Descriptor() ([]byte, []int)

+ func (*SignalPayload) ProtoMessage()

+ func (x *SignalPayload) GetPayload() string

+ func (x *SignalPayload) ProtoReflect() protoreflect.Message

+ func (x *SignalPayload) Reset()

+ func (x *SignalPayload) String() string

+ type Values struct

+ Value []string

+ func (*Values) Descriptor() ([]byte, []int)

+ func (*Values) ProtoMessage()

+ func (x *Values) GetValue() []string

+ func (x *Values) ProtoReflect() protoreflect.Message

+ func (x *Values) Reset()

+ func (x *Values) String() string