engine

package
v19.1.0-rc2 Latest Latest
Warning

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

 Go to latest Published: May 27, 2026 License: MIT Imports: 48 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_internal_module_autoflow_engine_engine_proto protoreflect.FileDescriptor

Functions

func EventToDict 

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

func HTTPDo 

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

func NewGitalySource 

func NewGitalySource(
	pool gitaly.PoolInterface,
	gl gitlab.ClientInterface,
	repoInfoCache *cache.CacheWithErr[RepoInfoCacheKey, *server_api.ProjectInfo],
) flow.Source

NewGitalySource returns the production flow.Source that loads Starlark from Gitaly, using gl to resolve project paths to repository info and caching the resolution in repoInfoCache.

Types

type AllowLimiter 

type AllowLimiter interface {
	Allow(ctx context.Context) bool
}

func NewRedisAllowLimiter 

func NewRedisAllowLimiter(
	redisClient rueidis.Client,
	keyPrefix string,
	perMinute uint32,
	log *slog.Logger,
	handleProcessingError func(msg string, err error),
	tracer trace.Tracer,
	meter otelmetric.Meter,
) (AllowLimiter, error)

NewRedisAllowLimiter returns a metrics-instrumented AllowLimiter backed by a Redis token bucket keyed per project ID + event type, allowing perMinute events through each one-minute window. Returns an error if the metric instrumentation fails to register.

type CallResult 

type CallResult struct {
	Data  []byte
	Error string
}

type CallUnaryFunctionActivityInput 

type CallUnaryFunctionActivityInput struct {
	ModuleName string `protobuf:"bytes,1,opt,name=module_name,json=moduleName" json:"module_name,omitempty"`
	FuncName   string `protobuf:"bytes,2,opt,name=func_name,json=funcName" json:"func_name,omitempty"`
	Input      []byte `protobuf:"bytes,3,opt,name=input" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*CallUnaryFunctionActivityInput) Descriptor deprecated 

func (*CallUnaryFunctionActivityInput) Descriptor() ([]byte, []int)

Deprecated: Use CallUnaryFunctionActivityInput.ProtoReflect.Descriptor instead.

func (*CallUnaryFunctionActivityInput) GetFuncName 

func (x *CallUnaryFunctionActivityInput) GetFuncName() string

func (*CallUnaryFunctionActivityInput) GetInput 

func (x *CallUnaryFunctionActivityInput) GetInput() []byte

func (*CallUnaryFunctionActivityInput) GetModuleName 

func (x *CallUnaryFunctionActivityInput) GetModuleName() string

func (*CallUnaryFunctionActivityInput) ProtoMessage 

func (*CallUnaryFunctionActivityInput) ProtoMessage()

func (*CallUnaryFunctionActivityInput) ProtoReflect 

func (x *CallUnaryFunctionActivityInput) ProtoReflect() protoreflect.Message

func (*CallUnaryFunctionActivityInput) Reset 

func (x *CallUnaryFunctionActivityInput) Reset()

func (*CallUnaryFunctionActivityInput) String 

func (x *CallUnaryFunctionActivityInput) String() string

type CallUnaryFunctionActivityOutput 

type CallUnaryFunctionActivityOutput struct {

	// Types that are valid to be assigned to Response:
	//
	//	*CallUnaryFunctionActivityOutput_Output
	//	*CallUnaryFunctionActivityOutput_Error
	Response isCallUnaryFunctionActivityOutput_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*CallUnaryFunctionActivityOutput) Descriptor deprecated 

func (*CallUnaryFunctionActivityOutput) Descriptor() ([]byte, []int)

Deprecated: Use CallUnaryFunctionActivityOutput.ProtoReflect.Descriptor instead.

func (*CallUnaryFunctionActivityOutput) GetError 

func (x *CallUnaryFunctionActivityOutput) GetError() string

func (*CallUnaryFunctionActivityOutput) GetOutput 

func (x *CallUnaryFunctionActivityOutput) GetOutput() []byte

func (*CallUnaryFunctionActivityOutput) GetResponse 

func (x *CallUnaryFunctionActivityOutput) GetResponse() isCallUnaryFunctionActivityOutput_Response

func (*CallUnaryFunctionActivityOutput) ProtoMessage 

func (*CallUnaryFunctionActivityOutput) ProtoMessage()

func (*CallUnaryFunctionActivityOutput) ProtoReflect 

func (x *CallUnaryFunctionActivityOutput) ProtoReflect() protoreflect.Message

func (*CallUnaryFunctionActivityOutput) Reset 

func (x *CallUnaryFunctionActivityOutput) Reset()

func (*CallUnaryFunctionActivityOutput) String 

func (x *CallUnaryFunctionActivityOutput) String() string

type CallUnaryFunctionActivityOutput_Error 

type CallUnaryFunctionActivityOutput_Error struct {
	Error string `protobuf:"bytes,2,opt,name=error,oneof"`
}

type CallUnaryFunctionActivityOutput_Output 

type CallUnaryFunctionActivityOutput_Output struct {
	Output []byte `protobuf:"bytes,1,opt,name=output,oneof"`
}

type Engine 

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

func NewEngine 

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

func (*Engine) HandleEvent 

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

func (*Engine) RegisterOn 

func (e *Engine) RegisterOn(r *autocore.Registry)

func (*Engine) RunStarlark 

func (e *Engine) RunStarlark(ctx context.Context, identityKey string, input *RunStarlarkWorkflowInput) (string, error)

RunStarlark submits a RunStarlarkWorkflow with the given input. Returns the autocore-assigned workflow ID. If a workflow with the given identityKey already exists, returns its existing workflow ID without re-creating.

type HandleEventRequest 

type HandleEventRequest struct {
	Event       *event.CloudEvent `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
	FlowProject *event.Project    `protobuf:"bytes,2,opt,name=flow_project,json=flowProject" json:"flow_project,omitempty"`
	Variables   map[string]string `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*HandleEventRequest) Descriptor deprecated 

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

Deprecated: Use HandleEventRequest.ProtoReflect.Descriptor instead.

func (*HandleEventRequest) GetEvent 

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

func (*HandleEventRequest) GetFlowProject 

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

func (*HandleEventRequest) GetVariables 

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

func (*HandleEventRequest) ProtoMessage 

func (*HandleEventRequest) ProtoMessage()

func (*HandleEventRequest) ProtoReflect 

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

func (*HandleEventRequest) Reset 

func (x *HandleEventRequest) Reset()

func (*HandleEventRequest) String 

func (x *HandleEventRequest) String() string

type HandleEventWorkflowInput 

type HandleEventWorkflowInput struct {
	Event       *event.CloudEvent `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
	FlowProject *event.Project    `protobuf:"bytes,2,opt,name=flow_project,json=flowProject" json:"flow_project,omitempty"`
	Entrypoint  string            `protobuf:"bytes,3,opt,name=entrypoint" json:"entrypoint,omitempty"`
	Variables   map[string]string `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*HandleEventWorkflowInput) Descriptor deprecated 

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

Deprecated: Use HandleEventWorkflowInput.ProtoReflect.Descriptor instead.

func (*HandleEventWorkflowInput) GetEntrypoint 

func (x *HandleEventWorkflowInput) GetEntrypoint() string

func (*HandleEventWorkflowInput) GetEvent 

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

func (*HandleEventWorkflowInput) GetFlowProject 

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

func (*HandleEventWorkflowInput) GetVariables 

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

func (*HandleEventWorkflowInput) ProtoMessage 

func (*HandleEventWorkflowInput) ProtoMessage()

func (*HandleEventWorkflowInput) ProtoReflect 

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

func (*HandleEventWorkflowInput) Reset 

func (x *HandleEventWorkflowInput) Reset()

func (*HandleEventWorkflowInput) String 

func (x *HandleEventWorkflowInput) String() string

type HandleEventWorkflowOutput 

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

func (*HandleEventWorkflowOutput) Descriptor deprecated 

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

Deprecated: Use HandleEventWorkflowOutput.ProtoReflect.Descriptor instead.

func (*HandleEventWorkflowOutput) ProtoMessage 

func (*HandleEventWorkflowOutput) ProtoMessage()

func (*HandleEventWorkflowOutput) ProtoReflect 

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

func (*HandleEventWorkflowOutput) Reset 

func (x *HandleEventWorkflowOutput) Reset()

func (*HandleEventWorkflowOutput) String 

func (x *HandleEventWorkflowOutput) String() string

type HandlerInfo 

type HandlerInfo struct {
	WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId" json:"workflow_id,omitempty"`
	// contains filtered or unexported fields
}

func (*HandlerInfo) Descriptor deprecated 

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

Deprecated: Use HandlerInfo.ProtoReflect.Descriptor instead.

func (*HandlerInfo) GetWorkflowId 

func (x *HandlerInfo) GetWorkflowId() string

func (*HandlerInfo) ProtoMessage 

func (*HandlerInfo) ProtoMessage()

func (*HandlerInfo) ProtoReflect 

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

func (*HandlerInfo) Reset 

func (x *HandlerInfo) Reset()

func (*HandlerInfo) String 

func (x *HandlerInfo) String() string

type HttpDoActivityInput 

type HttpDoActivityInput struct {
	Method string             `protobuf:"bytes,1,opt,name=method" json:"method,omitempty"`
	Url    string             `protobuf:"bytes,2,opt,name=url" json:"url,omitempty"`
	Header map[string]*Values `` /* 132-byte string literal not displayed */
	Body   []byte             `protobuf:"bytes,4,opt,name=body" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpDoActivityInput) Descriptor deprecated 

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

Deprecated: Use HttpDoActivityInput.ProtoReflect.Descriptor instead.

func (*HttpDoActivityInput) GetBody 

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

func (*HttpDoActivityInput) GetHeader 

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

func (*HttpDoActivityInput) GetMethod 

func (x *HttpDoActivityInput) GetMethod() string

func (*HttpDoActivityInput) GetUrl 

func (x *HttpDoActivityInput) GetUrl() string

func (*HttpDoActivityInput) ProtoMessage 

func (*HttpDoActivityInput) ProtoMessage()

func (*HttpDoActivityInput) ProtoReflect 

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

func (*HttpDoActivityInput) Reset 

func (x *HttpDoActivityInput) Reset()

func (*HttpDoActivityInput) String 

func (x *HttpDoActivityInput) String() string

type HttpDoActivityOutput 

type HttpDoActivityOutput struct {
	StatusCode uint32             `protobuf:"varint,1,opt,name=status_code,json=statusCode" json:"status_code,omitempty"`
	Status     string             `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"`
	Header     map[string]*Values `` /* 132-byte string literal not displayed */
	Body       []byte             `protobuf:"bytes,4,opt,name=body" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpDoActivityOutput) Descriptor deprecated 

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

Deprecated: Use HttpDoActivityOutput.ProtoReflect.Descriptor instead.

func (*HttpDoActivityOutput) GetBody 

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

func (*HttpDoActivityOutput) GetHeader 

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

func (*HttpDoActivityOutput) GetStatus 

func (x *HttpDoActivityOutput) GetStatus() string

func (*HttpDoActivityOutput) GetStatusCode 

func (x *HttpDoActivityOutput) GetStatusCode() uint32

func (*HttpDoActivityOutput) ProtoMessage 

func (*HttpDoActivityOutput) ProtoMessage()

func (*HttpDoActivityOutput) ProtoReflect 

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

func (*HttpDoActivityOutput) Reset 

func (x *HttpDoActivityOutput) Reset()

func (*HttpDoActivityOutput) String 

func (x *HttpDoActivityOutput) String() string

type LoadAllEventHandlersActivityInput 

type LoadAllEventHandlersActivityInput struct {
	Event       *event.CloudEvent `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
	FlowProject *event.Project    `protobuf:"bytes,2,opt,name=flow_project,json=flowProject" json:"flow_project,omitempty"`
	Entrypoint  string            `protobuf:"bytes,3,opt,name=entrypoint" json:"entrypoint,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadAllEventHandlersActivityInput) Descriptor deprecated 

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

Deprecated: Use LoadAllEventHandlersActivityInput.ProtoReflect.Descriptor instead.

func (*LoadAllEventHandlersActivityInput) GetEntrypoint 

func (x *LoadAllEventHandlersActivityInput) GetEntrypoint() string

func (*LoadAllEventHandlersActivityInput) GetEvent 

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

func (*LoadAllEventHandlersActivityInput) GetFlowProject 

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

func (*LoadAllEventHandlersActivityInput) ProtoMessage 

func (*LoadAllEventHandlersActivityInput) ProtoMessage()

func (*LoadAllEventHandlersActivityInput) ProtoReflect 

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

func (*LoadAllEventHandlersActivityInput) Reset 

func (x *LoadAllEventHandlersActivityInput) Reset()

func (*LoadAllEventHandlersActivityInput) String 

func (x *LoadAllEventHandlersActivityInput) String() string

type LoadAllEventHandlersActivityOutput 

type LoadAllEventHandlersActivityOutput struct {
	Handlers []*HandlerInfo  `protobuf:"bytes,1,rep,name=handlers" json:"handlers,omitempty"`
	Modules  []*ModuleSource `protobuf:"bytes,2,rep,name=modules" json:"modules,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadAllEventHandlersActivityOutput) Descriptor deprecated 

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

Deprecated: Use LoadAllEventHandlersActivityOutput.ProtoReflect.Descriptor instead.

func (*LoadAllEventHandlersActivityOutput) GetHandlers 

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

func (*LoadAllEventHandlersActivityOutput) GetModules 

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

func (*LoadAllEventHandlersActivityOutput) ProtoMessage 

func (*LoadAllEventHandlersActivityOutput) ProtoMessage()

func (*LoadAllEventHandlersActivityOutput) ProtoReflect 

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

func (*LoadAllEventHandlersActivityOutput) Reset 

func (x *LoadAllEventHandlersActivityOutput) Reset()

func (*LoadAllEventHandlersActivityOutput) String 

func (x *LoadAllEventHandlersActivityOutput) String() string

type LoadModuleActivityInput 

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

func (*LoadModuleActivityInput) Descriptor deprecated 

func (*LoadModuleActivityInput) Descriptor() ([]byte, []int)

Deprecated: Use LoadModuleActivityInput.ProtoReflect.Descriptor instead.

func (*LoadModuleActivityInput) GetName 

func (x *LoadModuleActivityInput) GetName() string

func (*LoadModuleActivityInput) ProtoMessage 

func (*LoadModuleActivityInput) ProtoMessage()

func (*LoadModuleActivityInput) ProtoReflect 

func (x *LoadModuleActivityInput) ProtoReflect() protoreflect.Message

func (*LoadModuleActivityInput) Reset 

func (x *LoadModuleActivityInput) Reset()

func (*LoadModuleActivityInput) String 

func (x *LoadModuleActivityInput) String() string

type LoadModuleActivityOutput 

type LoadModuleActivityOutput struct {
	ModuleDescriptor *ModuleDescriptor `protobuf:"bytes,1,opt,name=module_descriptor,json=moduleDescriptor" json:"module_descriptor,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadModuleActivityOutput) Descriptor deprecated 

func (*LoadModuleActivityOutput) Descriptor() ([]byte, []int)

Deprecated: Use LoadModuleActivityOutput.ProtoReflect.Descriptor instead.

func (*LoadModuleActivityOutput) GetModuleDescriptor 

func (x *LoadModuleActivityOutput) GetModuleDescriptor() *ModuleDescriptor

func (*LoadModuleActivityOutput) ProtoMessage 

func (*LoadModuleActivityOutput) ProtoMessage()

func (*LoadModuleActivityOutput) ProtoReflect 

func (x *LoadModuleActivityOutput) ProtoReflect() protoreflect.Message

func (*LoadModuleActivityOutput) Reset 

func (x *LoadModuleActivityOutput) Reset()

func (*LoadModuleActivityOutput) String 

func (x *LoadModuleActivityOutput) String() string

type ModuleDescriptor 

type ModuleDescriptor struct {
	Vars       []*ModuleVar       `protobuf:"bytes,1,rep,name=vars" json:"vars,omitempty"`
	UnaryFuncs []*ModuleUnaryFunc `protobuf:"bytes,2,rep,name=unary_funcs,json=unaryFuncs" json:"unary_funcs,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleDescriptor) Descriptor deprecated 

func (*ModuleDescriptor) Descriptor() ([]byte, []int)

Deprecated: Use ModuleDescriptor.ProtoReflect.Descriptor instead.

func (*ModuleDescriptor) GetUnaryFuncs 

func (x *ModuleDescriptor) GetUnaryFuncs() []*ModuleUnaryFunc

func (*ModuleDescriptor) GetVars 

func (x *ModuleDescriptor) GetVars() []*ModuleVar

func (*ModuleDescriptor) ProtoMessage 

func (*ModuleDescriptor) ProtoMessage()

func (*ModuleDescriptor) ProtoReflect 

func (x *ModuleDescriptor) ProtoReflect() protoreflect.Message

func (*ModuleDescriptor) Reset 

func (x *ModuleDescriptor) Reset()

func (*ModuleDescriptor) String 

func (x *ModuleDescriptor) String() string

type ModuleManager 

type ModuleManager interface {
	// LoadModuleDescriptor loads a module descriptor.
	// Returns (nil, nil) if not found.
	LoadModuleDescriptor(ctx context.Context, moduleName string) (*ModuleDescriptor, error)
	CallUnary(ctx context.Context, moduleName, funcName, idempotencyKey string, input []byte) (CallResult, error)
}

type ModuleSource 

type ModuleSource struct {
	SourceName string `protobuf:"bytes,1,opt,name=source_name,json=sourceName" json:"source_name,omitempty"`
	File       string `protobuf:"bytes,2,opt,name=file" json:"file,omitempty"`
	Data       []byte `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleSource) Descriptor deprecated 

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

Deprecated: Use ModuleSource.ProtoReflect.Descriptor instead.

func (*ModuleSource) GetData 

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

func (*ModuleSource) GetFile 

func (x *ModuleSource) GetFile() string

func (*ModuleSource) GetSourceName 

func (x *ModuleSource) GetSourceName() string

func (*ModuleSource) ProtoMessage 

func (*ModuleSource) ProtoMessage()

func (*ModuleSource) ProtoReflect 

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

func (*ModuleSource) Reset 

func (x *ModuleSource) Reset()

func (*ModuleSource) String 

func (x *ModuleSource) String() string

type ModuleUnaryFunc 

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

func (*ModuleUnaryFunc) Descriptor deprecated 

func (*ModuleUnaryFunc) Descriptor() ([]byte, []int)

Deprecated: Use ModuleUnaryFunc.ProtoReflect.Descriptor instead.

func (*ModuleUnaryFunc) GetName 

func (x *ModuleUnaryFunc) GetName() string

func (*ModuleUnaryFunc) ProtoMessage 

func (*ModuleUnaryFunc) ProtoMessage()

func (*ModuleUnaryFunc) ProtoReflect 

func (x *ModuleUnaryFunc) ProtoReflect() protoreflect.Message

func (*ModuleUnaryFunc) Reset 

func (x *ModuleUnaryFunc) Reset()

func (*ModuleUnaryFunc) String 

func (x *ModuleUnaryFunc) String() string

type ModuleVar 

type ModuleVar struct {
	Name      string          `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Value     *structpb.Value `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	Sensitive bool            `protobuf:"varint,3,opt,name=sensitive" json:"sensitive,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleVar) Descriptor deprecated 

func (*ModuleVar) Descriptor() ([]byte, []int)

Deprecated: Use ModuleVar.ProtoReflect.Descriptor instead.

func (*ModuleVar) GetName 

func (x *ModuleVar) GetName() string

func (*ModuleVar) GetSensitive 

func (x *ModuleVar) GetSensitive() bool

func (*ModuleVar) GetValue 

func (x *ModuleVar) GetValue() *structpb.Value

func (*ModuleVar) ProtoMessage 

func (*ModuleVar) ProtoMessage()

func (*ModuleVar) ProtoReflect 

func (x *ModuleVar) ProtoReflect() protoreflect.Message

func (*ModuleVar) Reset 

func (x *ModuleVar) Reset()

func (*ModuleVar) String 

func (x *ModuleVar) String() string

type Options 

type Options struct {
	Log           *slog.Logger
	Client        autocore.Client
	HTTPRT        http.RoundTripper
	GitLabURL     string
	RL            *workflowRateLimiter
	Source        flow.Source
	AllowLimiter  AllowLimiter
	ModuleManager ModuleManager
}

type RateLimiterCtxKey 

type RateLimiterCtxKey string

type RegisteredModuleDescriptor 

type RegisteredModuleDescriptor struct {
	ModuleId   int64             `protobuf:"varint,1,opt,name=module_id,json=moduleId" json:"module_id,omitempty"`
	ModuleDesc *ModuleDescriptor `protobuf:"bytes,2,opt,name=module_desc,json=moduleDesc" json:"module_desc,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisteredModuleDescriptor) Descriptor deprecated 

func (*RegisteredModuleDescriptor) Descriptor() ([]byte, []int)

Deprecated: Use RegisteredModuleDescriptor.ProtoReflect.Descriptor instead.

func (*RegisteredModuleDescriptor) GetModuleDesc 

func (x *RegisteredModuleDescriptor) GetModuleDesc() *ModuleDescriptor

func (*RegisteredModuleDescriptor) GetModuleId 

func (x *RegisteredModuleDescriptor) GetModuleId() int64

func (*RegisteredModuleDescriptor) ProtoMessage 

func (*RegisteredModuleDescriptor) ProtoMessage()

func (*RegisteredModuleDescriptor) ProtoReflect 

func (x *RegisteredModuleDescriptor) ProtoReflect() protoreflect.Message

func (*RegisteredModuleDescriptor) Reset 

func (x *RegisteredModuleDescriptor) Reset()

func (*RegisteredModuleDescriptor) String 

func (x *RegisteredModuleDescriptor) String() string

type RepoInfoCacheKey 

type RepoInfoCacheKey struct {
	// TODO identity must be part of the cache key
	ProjectID string
}

type RunActivityInput 

type RunActivityInput struct {
	Uri           string   `protobuf:"bytes,1,opt,name=uri" json:"uri,omitempty"`
	WorkflowId    string   `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId" json:"workflow_id,omitempty"`
	Args          []string `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
	DuoCallNumber int32    `protobuf:"varint,4,opt,name=duo_call_number,json=duoCallNumber" json:"duo_call_number,omitempty"`
	// contains filtered or unexported fields
}

func (*RunActivityInput) Descriptor deprecated 

func (*RunActivityInput) Descriptor() ([]byte, []int)

Deprecated: Use RunActivityInput.ProtoReflect.Descriptor instead.

func (*RunActivityInput) GetArgs 

func (x *RunActivityInput) GetArgs() []string

func (*RunActivityInput) GetDuoCallNumber 

func (x *RunActivityInput) GetDuoCallNumber() int32

func (*RunActivityInput) GetUri 

func (x *RunActivityInput) GetUri() string

func (*RunActivityInput) GetWorkflowId 

func (x *RunActivityInput) GetWorkflowId() string

func (*RunActivityInput) ProtoMessage 

func (*RunActivityInput) ProtoMessage()

func (*RunActivityInput) ProtoReflect 

func (x *RunActivityInput) ProtoReflect() protoreflect.Message

func (*RunActivityInput) Reset 

func (x *RunActivityInput) Reset()

func (*RunActivityInput) String 

func (x *RunActivityInput) String() string

type RunActivityOutput 

type RunActivityOutput struct {
	Payload string `protobuf:"bytes,1,opt,name=payload" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*RunActivityOutput) Descriptor deprecated 

func (*RunActivityOutput) Descriptor() ([]byte, []int)

Deprecated: Use RunActivityOutput.ProtoReflect.Descriptor instead.

func (*RunActivityOutput) GetPayload 

func (x *RunActivityOutput) GetPayload() string

func (*RunActivityOutput) ProtoMessage 

func (*RunActivityOutput) ProtoMessage()

func (*RunActivityOutput) ProtoReflect 

func (x *RunActivityOutput) ProtoReflect() protoreflect.Message

func (*RunActivityOutput) Reset 

func (x *RunActivityOutput) Reset()

func (*RunActivityOutput) String 

func (x *RunActivityOutput) String() string

type RunEventHandlerWorkflowInput 

type RunEventHandlerWorkflowInput struct {
	Event            *event.CloudEvent `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
	FlowProject      *event.Project    `protobuf:"bytes,2,opt,name=flow_project,json=flowProject" json:"flow_project,omitempty"`
	Entrypoint       string            `protobuf:"bytes,3,opt,name=entrypoint" json:"entrypoint,omitempty"`
	Modules          []*ModuleSource   `protobuf:"bytes,4,rep,name=modules" json:"modules,omitempty"`
	Handler          uint32            `protobuf:"varint,5,opt,name=handler" json:"handler,omitempty"`
	WorkflowIdPrefix string            `protobuf:"bytes,6,opt,name=workflow_id_prefix,json=workflowIdPrefix" json:"workflow_id_prefix,omitempty"`
	Variables        map[string]string `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RunEventHandlerWorkflowInput) Descriptor deprecated 

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

Deprecated: Use RunEventHandlerWorkflowInput.ProtoReflect.Descriptor instead.

func (*RunEventHandlerWorkflowInput) GetEntrypoint 

func (x *RunEventHandlerWorkflowInput) GetEntrypoint() string

func (*RunEventHandlerWorkflowInput) GetEvent 

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

func (*RunEventHandlerWorkflowInput) GetFlowProject 

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

func (*RunEventHandlerWorkflowInput) GetHandler 

func (x *RunEventHandlerWorkflowInput) GetHandler() uint32

func (*RunEventHandlerWorkflowInput) GetModules 

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

func (*RunEventHandlerWorkflowInput) GetVariables 

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

func (*RunEventHandlerWorkflowInput) GetWorkflowIdPrefix 

func (x *RunEventHandlerWorkflowInput) GetWorkflowIdPrefix() string

func (*RunEventHandlerWorkflowInput) ProtoMessage 

func (*RunEventHandlerWorkflowInput) ProtoMessage()

func (*RunEventHandlerWorkflowInput) ProtoReflect 

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

func (*RunEventHandlerWorkflowInput) Reset 

func (x *RunEventHandlerWorkflowInput) Reset()

func (*RunEventHandlerWorkflowInput) String 

func (x *RunEventHandlerWorkflowInput) String() string

type RunEventHandlerWorkflowOutput 

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

func (*RunEventHandlerWorkflowOutput) Descriptor deprecated 

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

Deprecated: Use RunEventHandlerWorkflowOutput.ProtoReflect.Descriptor instead.

func (*RunEventHandlerWorkflowOutput) ProtoMessage 

func (*RunEventHandlerWorkflowOutput) ProtoMessage()

func (*RunEventHandlerWorkflowOutput) ProtoReflect 

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

func (*RunEventHandlerWorkflowOutput) Reset 

func (x *RunEventHandlerWorkflowOutput) Reset()

func (*RunEventHandlerWorkflowOutput) String 

func (x *RunEventHandlerWorkflowOutput) String() string

type RunStarlarkWorkflowInput 

type RunStarlarkWorkflowInput struct {
	WorkflowDefinition []byte    `protobuf:"bytes,1,opt,name=workflow_definition,json=workflowDefinition" json:"workflow_definition,omitempty"`
	Secrets            []*Secret `protobuf:"bytes,2,rep,name=secrets" json:"secrets,omitempty"`
	// contains filtered or unexported fields
}

func (*RunStarlarkWorkflowInput) Descriptor deprecated 

func (*RunStarlarkWorkflowInput) Descriptor() ([]byte, []int)

Deprecated: Use RunStarlarkWorkflowInput.ProtoReflect.Descriptor instead.

func (*RunStarlarkWorkflowInput) GetSecrets 

func (x *RunStarlarkWorkflowInput) GetSecrets() []*Secret

func (*RunStarlarkWorkflowInput) GetWorkflowDefinition 

func (x *RunStarlarkWorkflowInput) GetWorkflowDefinition() []byte

func (*RunStarlarkWorkflowInput) ProtoMessage 

func (*RunStarlarkWorkflowInput) ProtoMessage()

func (*RunStarlarkWorkflowInput) ProtoReflect 

func (x *RunStarlarkWorkflowInput) ProtoReflect() protoreflect.Message

func (*RunStarlarkWorkflowInput) Reset 

func (x *RunStarlarkWorkflowInput) Reset()

func (*RunStarlarkWorkflowInput) String 

func (x *RunStarlarkWorkflowInput) String() string

type RunStarlarkWorkflowOutput 

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

func (*RunStarlarkWorkflowOutput) Descriptor deprecated 

func (*RunStarlarkWorkflowOutput) Descriptor() ([]byte, []int)

Deprecated: Use RunStarlarkWorkflowOutput.ProtoReflect.Descriptor instead.

func (*RunStarlarkWorkflowOutput) ProtoMessage 

func (*RunStarlarkWorkflowOutput) ProtoMessage()

func (*RunStarlarkWorkflowOutput) ProtoReflect 

func (x *RunStarlarkWorkflowOutput) ProtoReflect() protoreflect.Message

func (*RunStarlarkWorkflowOutput) Reset 

func (x *RunStarlarkWorkflowOutput) Reset()

func (*RunStarlarkWorkflowOutput) String 

func (x *RunStarlarkWorkflowOutput) String() string

type Secret 

type Secret struct {
	Key   string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Secret) Descriptor deprecated 

func (*Secret) Descriptor() ([]byte, []int)

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetKey 

func (x *Secret) GetKey() string

func (*Secret) GetValue 

func (x *Secret) GetValue() string

func (*Secret) ProtoMessage 

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect 

func (x *Secret) ProtoReflect() protoreflect.Message

func (*Secret) Reset 

func (x *Secret) Reset()

func (*Secret) String 

func (x *Secret) String() string

type SignalPayload 

type SignalPayload struct {
	Payload string `protobuf:"bytes,1,opt,name=payload" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalPayload) Descriptor deprecated 

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

Deprecated: Use SignalPayload.ProtoReflect.Descriptor instead.

func (*SignalPayload) GetPayload 

func (x *SignalPayload) GetPayload() string

func (*SignalPayload) ProtoMessage 

func (*SignalPayload) ProtoMessage()

func (*SignalPayload) ProtoReflect 

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

func (*SignalPayload) Reset 

func (x *SignalPayload) Reset()

func (*SignalPayload) String 

func (x *SignalPayload) String() string

type Values 

type Values struct {
	Value []string `protobuf:"bytes,1,rep,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Values) Descriptor deprecated 

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

Deprecated: Use Values.ProtoReflect.Descriptor instead.

func (*Values) GetValue 

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

func (*Values) ProtoMessage 

func (*Values) ProtoMessage()

func (*Values) ProtoReflect 

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

func (*Values) Reset 

func (x *Values) Reset()

func (*Values) String 

func (x *Values) String() string

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.