flowcore

package
v19.2.0-rc44 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2026 License: MIT Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WorkflowStateUnknown      = autocore.WorkflowStateUnknown
	WorkflowStateRunning      = autocore.WorkflowStateRunning
	WorkflowStateCompleted    = autocore.WorkflowStateCompleted
	WorkflowStateFailed       = autocore.WorkflowStateFailed
	WorkflowStateCanceled     = autocore.WorkflowStateCanceled
	WorkflowStateTimedOut     = autocore.WorkflowStateTimedOut
	WorkflowStateSystemFailed = autocore.WorkflowStateSystemFailed
)

Variables

View Source 
var ErrInvalidWorkflowKey = autocore.ErrInvalidWorkflowKey

ErrInvalidWorkflowKey is returned by GetWorkflow when the key is malformed.

View Source 
var ErrWorkflowNotFound = autocore.ErrWorkflowNotFound

ErrWorkflowNotFound is returned by GetWorkflow when no workflow exists for the given key.

View Source 
var File_internal_flowcore_channel_token_proto protoreflect.FileDescriptor
View Source 
var File_internal_flowcore_engine_proto protoreflect.FileDescriptor

Functions

func NewSensitiveBytes added in v19.2.0 

func NewSensitiveBytes(b []byte) starlark.Value

func NewSensitiveString added in v19.2.0 

func NewSensitiveString(s string) starlark.Value

Types

type ChannelSignalPayload added in v19.2.0 

type ChannelSignalPayload struct {
	Token   string `protobuf:"bytes,1,opt,name=token" json:"token,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelSignalPayload) Descriptor deprecated added in v19.2.0 

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

Deprecated: Use ChannelSignalPayload.ProtoReflect.Descriptor instead.

func (*ChannelSignalPayload) GetPayload added in v19.2.0 

func (x *ChannelSignalPayload) GetPayload() []byte

func (*ChannelSignalPayload) GetToken added in v19.2.0 

func (x *ChannelSignalPayload) GetToken() string

func (*ChannelSignalPayload) ProtoMessage added in v19.2.0 

func (*ChannelSignalPayload) ProtoMessage()

func (*ChannelSignalPayload) ProtoReflect added in v19.2.0 

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

func (*ChannelSignalPayload) Reset added in v19.2.0 

func (x *ChannelSignalPayload) Reset()

func (*ChannelSignalPayload) String added in v19.2.0 

func (x *ChannelSignalPayload) String() string

type ChannelTokenClaims added in v19.2.0 

type ChannelTokenClaims struct {
	RegisteredClaimIssuer    string   `protobuf:"bytes,1,opt,name=registered_claim_issuer,json=iss" json:"registered_claim_issuer,omitempty"`
	RegisteredClaimAudience  []string `protobuf:"bytes,2,rep,name=registered_claim_audience,json=aud" json:"registered_claim_audience,omitempty"`
	RegisteredClaimExpiresAt int64    `protobuf:"varint,3,opt,name=registered_claim_expires_at,json=exp" json:"registered_claim_expires_at,omitempty"`
	RegisteredClaimNotBefore int64    `protobuf:"varint,4,opt,name=registered_claim_not_before,json=nbf" json:"registered_claim_not_before,omitempty"`
	RegisteredClaimIssuedAt  int64    `protobuf:"varint,5,opt,name=registered_claim_issued_at,json=iat" json:"registered_claim_issued_at,omitempty"`
	ShardId                  int32    `protobuf:"varint,6,opt,name=shard_id" json:"shard_id,omitempty"`
	WorkflowId               string   `protobuf:"bytes,7,opt,name=workflow_id,json=wf_id" json:"workflow_id,omitempty"`
	ChannelName              string   `protobuf:"bytes,8,opt,name=channel_name" json:"channel_name,omitempty"`
	AgentId                  int64    `protobuf:"varint,9,opt,name=agent_id" json:"agent_id,omitempty"`
	AgentType                uint32   `protobuf:"varint,10,opt,name=agent_type" json:"agent_type,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelTokenClaims) Descriptor deprecated added in v19.2.0 

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

Deprecated: Use ChannelTokenClaims.ProtoReflect.Descriptor instead.

func (*ChannelTokenClaims) GetAgentId added in v19.2.0 

func (x *ChannelTokenClaims) GetAgentId() int64

func (*ChannelTokenClaims) GetAgentType added in v19.2.0 

func (x *ChannelTokenClaims) GetAgentType() uint32

func (*ChannelTokenClaims) GetAudience added in v19.2.0 

func (c *ChannelTokenClaims) GetAudience() (jwt.ClaimStrings, error)

func (*ChannelTokenClaims) GetChannelName added in v19.2.0 

func (x *ChannelTokenClaims) GetChannelName() string

func (*ChannelTokenClaims) GetExpirationTime added in v19.2.0 

func (c *ChannelTokenClaims) GetExpirationTime() (*jwt.NumericDate, error)

func (*ChannelTokenClaims) GetIssuedAt added in v19.2.0 

func (c *ChannelTokenClaims) GetIssuedAt() (*jwt.NumericDate, error)

func (*ChannelTokenClaims) GetIssuer added in v19.2.0 

func (c *ChannelTokenClaims) GetIssuer() (string, error)

func (*ChannelTokenClaims) GetNotBefore added in v19.2.0 

func (c *ChannelTokenClaims) GetNotBefore() (*jwt.NumericDate, error)

func (*ChannelTokenClaims) GetRegisteredClaimAudience added in v19.2.0 

func (x *ChannelTokenClaims) GetRegisteredClaimAudience() []string

func (*ChannelTokenClaims) GetRegisteredClaimExpiresAt added in v19.2.0 

func (x *ChannelTokenClaims) GetRegisteredClaimExpiresAt() int64

func (*ChannelTokenClaims) GetRegisteredClaimIssuedAt added in v19.2.0 

func (x *ChannelTokenClaims) GetRegisteredClaimIssuedAt() int64

func (*ChannelTokenClaims) GetRegisteredClaimIssuer added in v19.2.0 

func (x *ChannelTokenClaims) GetRegisteredClaimIssuer() string

func (*ChannelTokenClaims) GetRegisteredClaimNotBefore added in v19.2.0 

func (x *ChannelTokenClaims) GetRegisteredClaimNotBefore() int64

func (*ChannelTokenClaims) GetShardId added in v19.2.0 

func (x *ChannelTokenClaims) GetShardId() int32

func (*ChannelTokenClaims) GetSubject added in v19.2.0 

func (c *ChannelTokenClaims) GetSubject() (string, error)

func (*ChannelTokenClaims) GetWorkflowId added in v19.2.0 

func (x *ChannelTokenClaims) GetWorkflowId() string

func (*ChannelTokenClaims) MarshalJSON added in v19.2.0 

func (c *ChannelTokenClaims) MarshalJSON() ([]byte, error)

func (*ChannelTokenClaims) ProtoMessage added in v19.2.0 

func (*ChannelTokenClaims) ProtoMessage()

func (*ChannelTokenClaims) ProtoReflect added in v19.2.0 

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

func (*ChannelTokenClaims) Reset added in v19.2.0 

func (x *ChannelTokenClaims) Reset()

func (*ChannelTokenClaims) String added in v19.2.0 

func (x *ChannelTokenClaims) String() string

func (*ChannelTokenClaims) UnmarshalJSON added in v19.2.0 

func (c *ChannelTokenClaims) UnmarshalJSON(b []byte) error

func (*ChannelTokenClaims) WorkflowKey added in v19.2.0 

func (c *ChannelTokenClaims) WorkflowKey() (autocore.WorkflowKey, error)

type Engine 

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

func NewEngine 

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

func (*Engine) CancelWorkflow 

func (e *Engine) CancelWorkflow(ctx context.Context, workflowKey string) error

CancelWorkflow requests cancellation of the workflow addressed by workflowKey. Cancellation is an asynchronous best-effort signal: the workflow transitions to a canceled state on a later replay round. Returns ErrInvalidWorkflowKey if the key is malformed, or ErrWorkflowNotFound if no such workflow exists.

func (*Engine) GetWorkflow 

func (e *Engine) GetWorkflow(ctx context.Context, workflowKey string) (*Workflow, error)

GetWorkflow returns a snapshot of the workflow addressed by workflowKey, the key string returned by RunWorkflow. Returns autocore.ErrWorkflowNotFound if no such workflow exists, or an error if the key is malformed.

func (*Engine) RunWorkflow 

func (e *Engine) RunWorkflow(ctx context.Context, namespaceID int64, identityKey string, input *RunWorkflowInput) (string, error)

RunWorkflow submits a RunWorkflow with the given input. Returns the autocore-assigned workflow key. If a workflow with the given (namespaceID, identityKey) already exists, returns its existing workflow key without re-creating.

func (*Engine) SendToChannel added in v19.2.0 

func (e *Engine) SendToChannel(ctx context.Context, agentKey api.AgentKey, identityKey, channelToken string, value *pkg_autoflow.Value) error

type InvokeActionActivityInput 

type InvokeActionActivityInput struct {
	AgentId       int64               `protobuf:"varint,1,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	AgentType     uint32              `protobuf:"varint,2,opt,name=agent_type,json=agentType" json:"agent_type,omitempty"`
	ModuleName    string              `protobuf:"bytes,3,opt,name=module_name,json=moduleName" json:"module_name,omitempty"`
	ActionName    string              `protobuf:"bytes,4,opt,name=action_name,json=actionName" json:"action_name,omitempty"`
	Args          []*v19.Value        `protobuf:"bytes,5,rep,name=args" json:"args,omitempty"`
	Kwargs        []*v19.NamedValue   `protobuf:"bytes,6,rep,name=kwargs" json:"kwargs,omitempty"`
	ChannelTokens []*v19.ChannelToken `protobuf:"bytes,7,rep,name=channel_tokens,json=channelTokens" json:"channel_tokens,omitempty"`
	// contains filtered or unexported fields
}

func (*InvokeActionActivityInput) Descriptor deprecated 

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

Deprecated: Use InvokeActionActivityInput.ProtoReflect.Descriptor instead.

func (*InvokeActionActivityInput) GetActionName 

func (x *InvokeActionActivityInput) GetActionName() string

func (*InvokeActionActivityInput) GetAgentId added in v19.2.0 

func (x *InvokeActionActivityInput) GetAgentId() int64

func (*InvokeActionActivityInput) GetAgentType added in v19.2.0 

func (x *InvokeActionActivityInput) GetAgentType() uint32

func (*InvokeActionActivityInput) GetArgs 

func (x *InvokeActionActivityInput) GetArgs() []*v19.Value

func (*InvokeActionActivityInput) GetChannelTokens added in v19.2.0 

func (x *InvokeActionActivityInput) GetChannelTokens() []*v19.ChannelToken

func (*InvokeActionActivityInput) GetKwargs 

func (x *InvokeActionActivityInput) GetKwargs() []*v19.NamedValue

func (*InvokeActionActivityInput) GetModuleName 

func (x *InvokeActionActivityInput) GetModuleName() string

func (*InvokeActionActivityInput) ProtoMessage 

func (*InvokeActionActivityInput) ProtoMessage()

func (*InvokeActionActivityInput) ProtoReflect 

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

func (*InvokeActionActivityInput) Reset 

func (x *InvokeActionActivityInput) Reset()

func (*InvokeActionActivityInput) String 

func (x *InvokeActionActivityInput) String() string

type InvokeActionActivityOutput 

type InvokeActionActivityOutput struct {
	Result *v19.Result `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*InvokeActionActivityOutput) Descriptor deprecated 

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

Deprecated: Use InvokeActionActivityOutput.ProtoReflect.Descriptor instead.

func (*InvokeActionActivityOutput) GetResult 

func (x *InvokeActionActivityOutput) GetResult() *v19.Result

func (*InvokeActionActivityOutput) ProtoMessage 

func (*InvokeActionActivityOutput) ProtoMessage()

func (*InvokeActionActivityOutput) ProtoReflect 

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

func (*InvokeActionActivityOutput) Reset 

func (x *InvokeActionActivityOutput) Reset()

func (*InvokeActionActivityOutput) String 

func (x *InvokeActionActivityOutput) String() string

type LoadModuleActivityInput 

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

func (*LoadModuleActivityInput) Descriptor deprecated 

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

Deprecated: Use LoadModuleActivityInput.ProtoReflect.Descriptor instead.

func (*LoadModuleActivityInput) GetModuleName added in v19.2.0 

func (x *LoadModuleActivityInput) GetModuleName() 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 {
	RegisteredModuleDesc *RegisteredModuleDescriptor `protobuf:"bytes,1,opt,name=registered_module_desc,json=registeredModuleDesc" json:"registered_module_desc,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadModuleActivityOutput) Descriptor deprecated 

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

Deprecated: Use LoadModuleActivityOutput.ProtoReflect.Descriptor instead.

func (*LoadModuleActivityOutput) GetRegisteredModuleDesc added in v19.2.0 

func (x *LoadModuleActivityOutput) GetRegisteredModuleDesc() *RegisteredModuleDescriptor

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 ModuleDescriptorResolver 

type ModuleDescriptorResolver struct {
	ModuleName       string
	AgentKey         api.AgentKey
	Desc             *pkg_autoflow.ModuleDescriptor
	PredeclaredFiles *protoregistry.Files
	InvokeAction     func(
		ctx context.Context,
		thread *starlark.Thread,
		conv *ValueConverter,
		moduleName string,
		agentKey api.AgentKey,
		actionName string,
		args []*pkg_autoflow.Value,
		kwargs []*pkg_autoflow.NamedValue,
	) (autoflow.Future, error)
}

func (*ModuleDescriptorResolver) LoadSymbols 

func (r *ModuleDescriptorResolver) LoadSymbols() (starlark.StringDict, error)

type ModuleManager 

type ModuleManager interface {
	// LoadModuleDescriptor loads a registered module's descriptor.
	// Returns (nil, nil) if not found.
	LoadModuleDescriptor(ctx context.Context, moduleName string) (*RegisteredModuleDescriptor, error)
	InvokeAction(
		ctx context.Context,
		agentKey api.AgentKey,
		actionName, workflowKey, identityKey string,
		args []*pkg_autoflow.Value,
		kwargs []*pkg_autoflow.NamedValue,
		channelTokens []*pkg_autoflow.ChannelToken,
	) (*pkg_autoflow.Result, error)
}

type Options 

type Options struct {
	Log            *slog.Logger
	Client         autocore.Client
	Registry       *autocore.Registry
	RateLimiter    RateLimiter
	ModuleManager  ModuleManager
	TracerProvider oteltrace.TracerProvider
	Validator      protovalidate.Validator
	// PredeclaredProtoFiles is the set of proto file descriptors that
	// AutoFlow modules' descriptor sets may import. Used to resolve
	// imports when reconstructing module proto descriptors; we deliberately
	// do not fall back to protoregistry.GlobalFiles so a module cannot pull
	// in arbitrary types linked into the binary.
	// Order is important here - files that come later can import files that come earlier,
	// but not the other way around.
	PredeclaredProtoFiles     []protoreflect.FileDescriptor
	ChannelTokenSigningMethod *jwt.SigningMethodHMAC
	ChannelTokenIssuer        string
	ChannelTokenAudience      jwt.ClaimStrings
}

type RateLimiter 

type RateLimiter interface {
	Allow(ctx context.Context, projectID int64, eventType string) bool
}

type RegisteredModuleDescriptor added in v19.2.0 

type RegisteredModuleDescriptor struct {
	ModuleDesc *v19.ModuleDescriptor `protobuf:"bytes,1,opt,name=module_desc,json=moduleDesc" json:"module_desc,omitempty"`
	AgentId    int64                 `protobuf:"varint,2,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	AgentType  uint32                `protobuf:"varint,3,opt,name=agent_type,json=agentType" json:"agent_type,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisteredModuleDescriptor) Descriptor deprecated added in v19.2.0 

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

Deprecated: Use RegisteredModuleDescriptor.ProtoReflect.Descriptor instead.

func (*RegisteredModuleDescriptor) GetAgentId added in v19.2.0 

func (x *RegisteredModuleDescriptor) GetAgentId() int64

func (*RegisteredModuleDescriptor) GetAgentType added in v19.2.0 

func (x *RegisteredModuleDescriptor) GetAgentType() uint32

func (*RegisteredModuleDescriptor) GetModuleDesc added in v19.2.0 

func (x *RegisteredModuleDescriptor) GetModuleDesc() *v19.ModuleDescriptor

func (*RegisteredModuleDescriptor) ProtoMessage added in v19.2.0 

func (*RegisteredModuleDescriptor) ProtoMessage()

func (*RegisteredModuleDescriptor) ProtoReflect added in v19.2.0 

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

func (*RegisteredModuleDescriptor) Reset added in v19.2.0 

func (x *RegisteredModuleDescriptor) Reset()

func (*RegisteredModuleDescriptor) String added in v19.2.0 

func (x *RegisteredModuleDescriptor) String() string

type RunWorkflowInput 

type RunWorkflowInput struct {
	WorkflowDefinition        []byte                     `protobuf:"bytes,1,opt,name=workflow_definition,json=workflowDefinition" json:"workflow_definition,omitempty"`
	Args                      []*v19.Value               `protobuf:"bytes,2,rep,name=args" json:"args,omitempty"`
	Kwargs                    []*v19.NamedValue          `protobuf:"bytes,3,rep,name=kwargs" json:"kwargs,omitempty"`
	ScheduleToCompleteTimeout *durationpb.Duration       `` /* 133-byte string literal not displayed */
	Metadata                  *RunWorkflowInput_Metadata `protobuf:"bytes,5,opt,name=metadata" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*RunWorkflowInput) Descriptor deprecated 

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

Deprecated: Use RunWorkflowInput.ProtoReflect.Descriptor instead.

func (*RunWorkflowInput) GetArgs added in v19.2.0 

func (x *RunWorkflowInput) GetArgs() []*v19.Value

func (*RunWorkflowInput) GetKwargs added in v19.2.0 

func (x *RunWorkflowInput) GetKwargs() []*v19.NamedValue

func (*RunWorkflowInput) GetMetadata added in v19.2.0 

func (x *RunWorkflowInput) GetMetadata() *RunWorkflowInput_Metadata

func (*RunWorkflowInput) GetScheduleToCompleteTimeout added in v19.2.0 

func (x *RunWorkflowInput) GetScheduleToCompleteTimeout() *durationpb.Duration

func (*RunWorkflowInput) GetWorkflowDefinition 

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

func (*RunWorkflowInput) ProtoMessage 

func (*RunWorkflowInput) ProtoMessage()

func (*RunWorkflowInput) ProtoReflect 

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

func (*RunWorkflowInput) Reset 

func (x *RunWorkflowInput) Reset()

func (*RunWorkflowInput) String 

func (x *RunWorkflowInput) String() string

type RunWorkflowInput_Metadata added in v19.2.0 

type RunWorkflowInput_Metadata struct {
	ChannelSecret []byte `protobuf:"bytes,4,opt,name=channel_secret,json=channelSecret" json:"channel_secret,omitempty"`
	// contains filtered or unexported fields
}

func (*RunWorkflowInput_Metadata) Descriptor deprecated added in v19.2.0 

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

Deprecated: Use RunWorkflowInput_Metadata.ProtoReflect.Descriptor instead.

func (*RunWorkflowInput_Metadata) GetChannelSecret added in v19.2.0 

func (x *RunWorkflowInput_Metadata) GetChannelSecret() []byte

func (*RunWorkflowInput_Metadata) ProtoMessage added in v19.2.0 

func (*RunWorkflowInput_Metadata) ProtoMessage()

func (*RunWorkflowInput_Metadata) ProtoReflect added in v19.2.0 

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

func (*RunWorkflowInput_Metadata) Reset added in v19.2.0 

func (x *RunWorkflowInput_Metadata) Reset()

func (*RunWorkflowInput_Metadata) String added in v19.2.0 

func (x *RunWorkflowInput_Metadata) String() string

type RunWorkflowOutput 

type RunWorkflowOutput struct {
	Result *v19.Value `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*RunWorkflowOutput) Descriptor deprecated 

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

Deprecated: Use RunWorkflowOutput.ProtoReflect.Descriptor instead.

func (*RunWorkflowOutput) GetResult added in v19.2.0 

func (x *RunWorkflowOutput) GetResult() *v19.Value

func (*RunWorkflowOutput) ProtoMessage 

func (*RunWorkflowOutput) ProtoMessage()

func (*RunWorkflowOutput) ProtoReflect 

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

func (*RunWorkflowOutput) Reset 

func (x *RunWorkflowOutput) Reset()

func (*RunWorkflowOutput) String 

func (x *RunWorkflowOutput) String() string

type ValidatingChannelTokenClaims added in v19.2.0 

type ValidatingChannelTokenClaims struct {
	ChannelTokenClaims

	Validator           protovalidate.Validator
	ExpectedAgentKey    api.AgentKey // optional, ignored when zero value
	ExpectedChannelName string
	ExpectedShardID     autocore.ShardID
	ExpectedWorkflowID  autocore.WorkflowID
}

func (*ValidatingChannelTokenClaims) Validate added in v19.2.0 

func (v *ValidatingChannelTokenClaims) Validate() error

type ValueConverter 

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

ValueConverter converts between AutoFlow proto Values and Starlark values.

Proto message Values (google.protobuf.Any) are resolved against the supplied descriptor set, falling back to the predeclared files. protoregistry.GlobalFiles is intentionally NOT consulted. Safe to use concurrently.

func NewValueConverter 

func NewValueConverter(predeclaredFiles *protoregistry.Files, descriptorSet *descriptorpb.FileDescriptorSet) *ValueConverter

NewValueConverter constructs a new ValueConverter. descriptorSet is optional, can be nil

func (*ValueConverter) FromStarlark 

func (c *ValueConverter) FromStarlark(v starlark.Value) (*pkg_autoflow.Value, error)

FromStarlark converts a Starlark value into a proto Value.

func (*ValueConverter) ToStarlark 

func (c *ValueConverter) ToStarlark(v *pkg_autoflow.Value) (starlark.Value, error)

ToStarlark converts a proto Value into a Starlark value.

type ValueToStarlarkConverter added in v19.2.0 

type ValueToStarlarkConverter interface {
	ToStarlark(*pkg_autoflow.Value) (starlark.Value, error)
}

ValueToStarlarkConverter converts an AutoFlow proto Value into a Starlark value.

type Workflow 

type Workflow struct {
	Key         string
	Name        string
	IdentityKey string
	State       WorkflowState
	CreatedAt   time.Time
	UpdatedAt   time.Time
	Output      *RunWorkflowOutput
	Error       string
}

Workflow is a read-only snapshot of a workflow returned by GetWorkflow. Output holds the workflow's decoded output and is set only when the workflow completed; Error holds the failure message and is set only when it failed.

type WorkflowState 

type WorkflowState = autocore.WorkflowState

WorkflowState is the lifecycle state of an AutoFlow workflow.

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.