workflow

package
v0.0.0-...-09efcc3 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2024 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

View Source 
const Lifetime = duration.UserInteraction

Variables

View Source 
var DependencySet = wire.NewSet(
	wire.Struct(new(Dependencies), "*"),
	NewServiceLogger,
	wire.Struct(new(Service), "*"),
	wire.Struct(new(StoreImpl), "*"),
	wire.Bind(new(Store), new(*StoreImpl)),
	wire.Bind(new(EventStore), new(*EventStoreImpl)),
	wire.Struct(new(IntlMiddleware), "*"),
	NewEventStore,
)
View Source 
var ErrEOF = errors.New("eof")

ErrEOF means end of workflow. This error originates from CanReactTo and will be propagated to public API.

View Source 
var ErrIncompatibleInput = errors.New("incompatible input")

ErrIncompatibleInput means the input reactor cannot react to the input. This error can only be returned by ReactTo.

View Source 
var ErrInvalidInputKind = apierrors.BadRequest.WithReason("WorkflowInvalidInputKind").New("invalid input kind")
View Source 
var ErrNoChange = errors.New("no change")

ErrNoChange means the input does not cause the workflow to change. This error originates from Accept and will be propagated to public API.

View Source 
var ErrSameNode = errors.New("same node")

ErrSameNode means the input is reacted to, but no node is produced. This typically means the node has performed some immediate side effects. This error can only be returned by ReactTo.

View Source 
var ErrUnknownInput = apierrors.BadRequest.WithReason("WorkflowUnknownInput").New("unknown input")
View Source 
var ErrUnknownIntent = apierrors.BadRequest.WithReason("WorkflowUnknownIntent").New("unknown intent")
View Source 
var ErrUpdateNode = errors.New("update node")

ErrUpdateNode means the input is reacted to, but instead of producing a new node to be appended, the returned node should replace the node. This error can only be returned by ReactTo.

View Source 
var ErrUserAgentUnmatched = apierrors.Forbidden.WithReason("UserAgentUnmatched").New("workflow cannot be used in other user agent")
View Source 
var ErrWorkflowNotFound = apierrors.NotFound.WithReason("WorkflowNotFound").New("workflow not found")
View Source 
var UserAgentIDCookieDef = &httputil.CookieDef{
	NameSuffix:        "workflow_ua_id",
	Path:              "/",
	AllowScriptAccess: false,
	SameSite:          http.SameSiteNoneMode,
	IsNonHostOnly:     true,
}

Functions

func AsInput 

func AsInput(i Input, iface interface{}) bool

func FindSingleNode 

func FindSingleNode[T NodeSimple](w *Workflow) (T, bool)

func GetOAuthSessionID 

func GetOAuthSessionID(ctx context.Context) string

func GetSuppressIDPSessionCookie 

func GetSuppressIDPSessionCookie(ctx context.Context) bool

func GetUserIDHint 

func GetUserIDHint(ctx context.Context) string

func GetWorkflowID 

func GetWorkflowID(ctx context.Context) string

func NewUserAgentID 

func NewUserAgentID() string

func RegisterNode 

func RegisterNode(node NodeSimple)

func RegisterPrivateIntent 

func RegisterPrivateIntent(intent Intent)

func RegisterPublicInput 

func RegisterPublicInput(input Input)

func RegisterPublicIntent 

func RegisterPublicIntent(intent Intent)

Types

type AccountMigrationService 

type AccountMigrationService interface {
	Run(ctx context.Context, migrationTokenString string) (*accountmigration.HookResponse, error)
}

type AuthenticationInfoEntryGetter 

type AuthenticationInfoEntryGetter interface {
	GetAuthenticationInfoEntry(ctx context.Context, deps *Dependencies, flows Workflows) *authenticationinfo.Entry
}

type AuthenticationInfoService 

type AuthenticationInfoService interface {
	Save(ctx context.Context, entry *authenticationinfo.Entry) error
}

type AuthenticatorService 

type AuthenticatorService interface {
	NewWithAuthenticatorID(ctx context.Context, authenticatorID string, spec *authenticator.Spec) (*authenticator.Info, error)
	UpdatePassword(ctx context.Context, authenticatorInfo *authenticator.Info, options *service.UpdatePasswordOptions) (changed bool, info *authenticator.Info, err error)

	Get(ctx context.Context, authenticatorID string) (*authenticator.Info, error)
	Create(ctx context.Context, authenticatorInfo *authenticator.Info, markVerified bool) error
	Update(ctx context.Context, authenticatorInfo *authenticator.Info) error
	List(ctx context.Context, userID string, filters ...authenticator.Filter) ([]*authenticator.Info, error)
	VerifyWithSpec(ctx context.Context, info *authenticator.Info, spec *authenticator.Spec, options *facade.VerifyOptions) (verifyResult *service.VerifyResult, err error)
	VerifyOneWithSpec(ctx context.Context, userID string, authenticatorType model.AuthenticatorType, infos []*authenticator.Info, spec *authenticator.Spec, options *facade.VerifyOptions) (info *authenticator.Info, verifyResult *service.VerifyResult, err error)
	ClearLockoutAttempts(ctx context.Context, userID string, usedMethods []config.AuthenticationLockoutMethod) error
}

type CaptchaService 

type CaptchaService interface {
	VerifyToken(ctx context.Context, token string) error
}

type CookieGetter 

type CookieGetter interface {
	GetCookies(ctx context.Context, deps *Dependencies, workflows Workflows) ([]*http.Cookie, error)
}

type CookieManager 

type CookieManager interface {
	GetCookie(r *http.Request, def *httputil.CookieDef) (*http.Cookie, error)
	ValueCookie(def *httputil.CookieDef, value string) *http.Cookie
	ClearCookie(def *httputil.CookieDef) *http.Cookie
}

type CustomAttrsService 

type CustomAttrsService interface {
	UpdateCustomAttributesWithList(ctx context.Context, role accesscontrol.Role, userID string, attrs attrs.List) error
}

type Dependencies 

type Dependencies struct {
	Config        *config.AppConfig
	FeatureConfig *config.FeatureConfig

	Clock    clock.Clock
	RemoteIP httputil.RemoteIP

	HTTPRequest *http.Request

	Users              UserService
	Identities         IdentityService
	Authenticators     AuthenticatorService
	MFA                MFAService
	StdAttrsService    StdAttrsService
	CustomAttrsService CustomAttrsService
	OTPCodes           OTPCodeService
	OTPSender          OTPSender
	Verification       VerificationService
	ForgotPassword     ForgotPasswordService
	ResetPassword      ResetPasswordService
	AccountMigrations  AccountMigrationService
	Captcha            CaptchaService

	IDPSessions          IDPSessionService
	Sessions             SessionService
	AuthenticationInfos  AuthenticationInfoService
	SessionCookie        session.CookieDef
	MFADeviceTokenCookie mfa.CookieDef

	Cookies CookieManager

	Events         EventService
	RateLimiter    RateLimiter
	WorkflowEvents EventStore

	OfflineGrants OfflineGrantStore
}

type Effect 

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

type EffectGetter 

type EffectGetter interface {
	GetEffects(ctx context.Context, deps *Dependencies, workflows Workflows) (effs []Effect, err error)
}

type Event 

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

type EventKind 

type EventKind string
const (
	// WorkflowEventKindRefresh indicates client should re-fetch current instance of workflow for updated state.
	EventKindRefresh EventKind = "refresh"
)

type EventRefresh 

type EventRefresh struct {
	Kind EventKind `json:"kind"`
}

func NewEventRefresh 

func NewEventRefresh() *EventRefresh

type EventService 

type EventService interface {
	DispatchEventOnCommit(ctx context.Context, payload event.Payload) error
	DispatchEventImmediately(ctx context.Context, payload event.NonBlockingPayload) error
}

type EventStore 

type EventStore interface {
	Publish(ctx context.Context, workflowID string, e Event) error
}

type EventStoreImpl 

type EventStoreImpl struct {
	AppID       config.AppID
	RedisHandle *appredis.Handle
	Store       Store
	// contains filtered or unexported fields
}

func NewEventStore 

func NewEventStore(appID config.AppID, handle *appredis.Handle, store Store) *EventStoreImpl

func (*EventStoreImpl) ChannelName 

func (s *EventStoreImpl) ChannelName(ctx context.Context, workflowID string) (string, error)

func (*EventStoreImpl) Publish 

func (s *EventStoreImpl) Publish(ctx context.Context, workflowID string, e Event) error

type ForgotPasswordService 

type ForgotPasswordService interface {
	SendCode(ctx context.Context, loginID string, options *forgotpassword.CodeOptions) error
}

type IDPSessionService 

type IDPSessionService interface {
	MakeSession(*session.Attrs) (*idpsession.IDPSession, string)
	Create(ctx context.Context, s *idpsession.IDPSession) error
	Reauthenticate(ctx context.Context, idpSessionID string, amr []string) error
}

type IdentityService 

type IdentityService interface {
	New(ctx context.Context, userID string, spec *identity.Spec, options identity.NewIdentityOptions) (*identity.Info, error)
	UpdateWithSpec(ctx context.Context, is *identity.Info, spec *identity.Spec, options identity.NewIdentityOptions) (*identity.Info, error)

	Get(ctx context.Context, id string) (*identity.Info, error)
	SearchBySpec(ctx context.Context, spec *identity.Spec) (exactMatch *identity.Info, otherMatches []*identity.Info, err error)
	ListByClaim(ctx context.Context, name string, value string) ([]*identity.Info, error)
	ListByUser(ctx context.Context, userID string) ([]*identity.Info, error)
	CheckDuplicated(ctx context.Context, info *identity.Info) (*identity.Info, error)
	Create(ctx context.Context, is *identity.Info) error
	Update(ctx context.Context, oldIs *identity.Info, newIs *identity.Info) error
}

type Input 

type Input interface {
	Kind() string
	JSONSchema() *validation.SimpleSchema
}

func InstantiateInputFromPublicRegistry 

func InstantiateInputFromPublicRegistry(j InputJSON) (Input, error)

type InputFactory 

type InputFactory func() Input

type InputJSON 

type InputJSON struct {
	Kind string          `json:"kind"`
	Data json.RawMessage `json:"data"`
}

type InputReactor 

type InputReactor interface {
	CanReactTo(ctx context.Context, deps *Dependencies, workflows Workflows) ([]Input, error)
	ReactTo(ctx context.Context, deps *Dependencies, workflows Workflows, input Input) (*Node, error)
}

type Intent 

type Intent interface {
	InputReactor
	EffectGetter
	Kind() string
	JSONSchema() *validation.SimpleSchema
	OutputData(ctx context.Context, deps *Dependencies, workflows Workflows) (interface{}, error)
}

Intent can optionally implement CookieGetter.

func InstantiateIntentFromPrivateRegistry 

func InstantiateIntentFromPrivateRegistry(j IntentJSON) (Intent, error)

func InstantiateIntentFromPublicRegistry 

func InstantiateIntentFromPublicRegistry(j IntentJSON) (Intent, error)

type IntentFactory 

type IntentFactory func() Intent

type IntentJSON 

type IntentJSON struct {
	Kind string          `json:"kind"`
	Data json.RawMessage `json:"data"`
}

type IntentOutput 

type IntentOutput struct {
	Kind string      `json:"kind"`
	Data interface{} `json:"data,omitempty"`
}

type IntlMiddleware 

type IntlMiddleware struct{}

func (*IntlMiddleware) Handle 

func (m *IntlMiddleware) Handle(next http.Handler) http.Handler

type MFAService 

type MFAService interface {
	GenerateRecoveryCodes(ctx context.Context) []string
	ReplaceRecoveryCodes(ctx context.Context, userID string, codes []string) ([]*mfa.RecoveryCode, error)
	VerifyRecoveryCode(ctx context.Context, userID string, code string) (*mfa.RecoveryCode, error)
	ConsumeRecoveryCode(ctx context.Context, c *mfa.RecoveryCode) error

	GenerateDeviceToken(ctx context.Context) string
	CreateDeviceToken(ctx context.Context, userID string, token string) (*mfa.DeviceToken, error)
	VerifyDeviceToken(ctx context.Context, userID string, deviceToken string) error
}

type Node 

type Node struct {
	Type        NodeType   `json:"type"`
	Simple      NodeSimple `json:"simple,omitempty"`
	SubWorkflow *Workflow  `json:"workflow,omitempty"`
}

func NewNodeSimple 

func NewNodeSimple(simple NodeSimple) *Node

func NewSubWorkflow 

func NewSubWorkflow(intent Intent) *Node

func (*Node) Clone 

func (n *Node) Clone() *Node

func (*Node) FindInputReactor 

func (n *Node) FindInputReactor(ctx context.Context, deps *Dependencies, workflows Workflows) (*Workflow, InputReactor, error)

func (*Node) MarshalJSON 

func (n *Node) MarshalJSON() ([]byte, error)

func (*Node) ToOutput 

func (n *Node) ToOutput(ctx context.Context, deps *Dependencies, workflows Workflows) (*NodeOutput, error)

func (*Node) Traverse 

func (n *Node) Traverse(t WorkflowTraverser, w *Workflow) error

func (*Node) UnmarshalJSON 

func (n *Node) UnmarshalJSON(d []byte) (err error)

type NodeFactory 

type NodeFactory func() NodeSimple

type NodeOutput 

type NodeOutput struct {
	Type        NodeType          `json:"type"`
	Simple      *NodeSimpleOutput `json:"simple,omitempty"`
	SubWorkflow *WorkflowOutput   `json:"workflow,omitempty"`
}

type NodeSimple 

type NodeSimple interface {
	InputReactor
	EffectGetter
	Kind() string
	OutputData(ctx context.Context, deps *Dependencies, workflows Workflows) (interface{}, error)
}

NodeSimple can optionally implement CookieGetter.

func InstantiateNode 

func InstantiateNode(kind string) (NodeSimple, error)

type NodeSimpleOutput 

type NodeSimpleOutput struct {
	Kind string      `json:"kind"`
	Data interface{} `json:"data,omitempty"`
}

type NodeType 

type NodeType string
const (
	NodeTypeSimple      NodeType = "SIMPLE"
	NodeTypeSubWorkflow NodeType = "SUB_WORKFLOW"
)

type OTPCodeService 

type OTPCodeService interface {
	GenerateOTP(ctx context.Context, kind otp.Kind, target string, form otp.Form, opt *otp.GenerateOptions) (string, error)
	VerifyOTP(ctx context.Context, kind otp.Kind, target string, otp string, opts *otp.VerifyOptions) error
	InspectState(ctx context.Context, kind otp.Kind, target string) (*otp.State, error)
	LookupCode(ctx context.Context, purpose otp.Purpose, code string) (target string, err error)
	SetSubmittedCode(ctx context.Context, kind otp.Kind, target string, code string) (*otp.State, error)
}

type OTPSender 

type OTPSender interface {
	Send(ctx context.Context, opts otp.SendOptions) error
}

type OfflineGrantStore 

type OfflineGrantStore interface {
	ListClientOfflineGrants(ctx context.Context, clientID string, userID string) ([]*oauth.OfflineGrant, error)
}

type OnCommitEffect 

type OnCommitEffect func(ctx context.Context, deps *Dependencies) error

type RateLimiter 

type RateLimiter interface {
	Allow(ctx context.Context, spec ratelimit.BucketSpec) (*ratelimit.FailedReservation, error)
	Reserve(ctx context.Context, spec ratelimit.BucketSpec) (*ratelimit.Reservation, *ratelimit.FailedReservation, error)
	Cancel(ctx context.Context, r *ratelimit.Reservation)
}

type ResetPasswordService 

type ResetPasswordService interface {
	VerifyCode(ctx context.Context, code string) (state *otp.State, err error)
	ResetPasswordByEndUser(ctx context.Context, code string, newPassword string) error
}

type RunEffect 

type RunEffect func(ctx context.Context, deps *Dependencies) error

type Service 

type Service struct {
	Deps           *Dependencies
	Logger         ServiceLogger
	Store          Store
	Database       ServiceDatabase
	UIInfoResolver ServiceUIInfoResolver
}

func (*Service) CreateNewWorkflow 

func (s *Service) CreateNewWorkflow(ctx context.Context, intent Intent, sessionOptions *SessionOptions) (output *ServiceOutput, err error)

func (*Service) FeedInput 

func (s *Service) FeedInput(ctx context.Context, workflowID string, instanceID string, userAgentID string, input Input) (output *ServiceOutput, err error)

func (*Service) Get 

func (s *Service) Get(ctx context.Context, workflowID string, instanceID string, userAgentID string) (output *ServiceOutput, err error)

type ServiceDatabase 

type ServiceDatabase interface {
	WithTx(ctx context.Context, do func(ctx context.Context) error) (err error)
	ReadOnly(ctx context.Context, do func(ctx context.Context) error) (err error)
}

type ServiceLogger 

type ServiceLogger struct{ *log.Logger }

func NewServiceLogger 

func NewServiceLogger(lf *log.Factory) ServiceLogger

type ServiceOutput 

type ServiceOutput struct {
	Session        *Session
	SessionOutput  *SessionOutput
	Workflow       *Workflow
	WorkflowOutput *WorkflowOutput
	Action         *WorkflowAction
	Cookies        []*http.Cookie
}

type ServiceUIInfoResolver 

type ServiceUIInfoResolver interface {
	SetAuthenticationInfoInQuery(redirectURI string, e *authenticationinfo.Entry) string
}

type Session 

type Session struct {
	WorkflowID string `json:"workflow_id"`

	OAuthSessionID           string `json:"oauth_session_id,omitempty"`
	ClientID                 string `json:"client_id,omitempty"`
	RedirectURI              string `json:"redirect_uri,omitempty"`
	SuppressIDPSessionCookie bool   `json:"suppress_idp_session_cookie,omitempty"`
	State                    string `json:"state,omitempty"`
	XState                   string `json:"x_state,omitempty"`
	UILocales                string `json:"ui_locales,omitempty"`
	UserAgentID              string `json:"user_agent_id,omitempty"`
	// UserIDHint is for reauthentication.
	UserIDHint string `json:"user_id_hint,omitempty"`
}

func NewSession 

func NewSession(opts *SessionOptions) *Session

func (*Session) Context 

func (s *Session) Context(ctx context.Context) context.Context

func (*Session) ToOutput 

func (s *Session) ToOutput() *SessionOutput

type SessionOptions 

type SessionOptions struct {
	OAuthSessionID           string
	ClientID                 string
	RedirectURI              string
	SuppressIDPSessionCookie bool
	State                    string
	XState                   string
	UILocales                string
	UserAgentID              string
	// UserIDHint is for reauthentication.
	UserIDHint string
}

func (*SessionOptions) PartiallyMergeFrom 

func (s *SessionOptions) PartiallyMergeFrom(o *SessionOptions) *SessionOptions

type SessionOutput 

type SessionOutput struct {
	WorkflowID  string `json:"workflow_id"`
	ClientID    string `json:"client_id,omitempty"`
	RedirectURI string `json:"redirect_uri,omitempty"`
}

type SessionService 

type SessionService interface {
	RevokeWithoutEvent(ctx context.Context, s session.SessionBase) error
}

type StdAttrsService 

type StdAttrsService interface {
	PopulateStandardAttributes(ctx context.Context, userID string, iden *identity.Info) error
	UpdateStandardAttributesWithList(ctx context.Context, role accesscontrol.Role, userID string, attrs attrs.List) error
}

type Store 

type Store interface {
	CreateSession(ctx context.Context, session *Session) error
	GetSession(ctx context.Context, workflowID string) (*Session, error)
	DeleteSession(ctx context.Context, session *Session) error

	CreateWorkflow(ctx context.Context, workflow *Workflow) error
	GetWorkflowByInstanceID(ctx context.Context, instanceID string) (*Workflow, error)
	DeleteWorkflow(ctx context.Context, workflow *Workflow) error
}

type StoreImpl 

type StoreImpl struct {
	Redis *appredis.Handle
	AppID config.AppID
}

func (*StoreImpl) CreateSession 

func (s *StoreImpl) CreateSession(ctx context.Context, session *Session) error

func (*StoreImpl) CreateWorkflow 

func (s *StoreImpl) CreateWorkflow(ctx context.Context, workflow *Workflow) error

func (*StoreImpl) DeleteSession 

func (s *StoreImpl) DeleteSession(ctx context.Context, session *Session) error

func (*StoreImpl) DeleteWorkflow 

func (s *StoreImpl) DeleteWorkflow(ctx context.Context, workflow *Workflow) error

func (*StoreImpl) GetSession 

func (s *StoreImpl) GetSession(ctx context.Context, workflowID string) (*Session, error)

func (*StoreImpl) GetWorkflowByInstanceID 

func (s *StoreImpl) GetWorkflowByInstanceID(ctx context.Context, instanceID string) (*Workflow, error)

type UserService 

type UserService interface {
	GetRaw(ctx context.Context, id string) (*user.User, error)
	Create(ctx context.Context, userID string) (*user.User, error)
	UpdateLoginTime(ctx context.Context, userID string, t time.Time) error
	AfterCreate(
		ctx context.Context,
		user *user.User,
		identities []*identity.Info,
		authenticators []*authenticator.Info,
		isAdminAPI bool,
	) error
}

type VerificationService 

type VerificationService interface {
	NewVerifiedClaim(ctx context.Context, userID string, claimName string, claimValue string) *verification.Claim
	GetIdentityVerificationStatus(ctx context.Context, i *identity.Info) ([]verification.ClaimStatus, error)
	MarkClaimVerified(ctx context.Context, claim *verification.Claim) error
}

type Workflow 

type Workflow struct {
	WorkflowID string
	InstanceID string
	Intent     Intent
	Nodes      []Node
}

func FindSubWorkflows 

func FindSubWorkflows[T Intent](w *Workflow) []*Workflow

func MustFindSubWorkflow 

func MustFindSubWorkflow[T Intent](w *Workflow) (T, *Workflow)

func NewWorkflow 

func NewWorkflow(workflowID string, intent Intent) *Workflow

func (*Workflow) Accept 

func (w *Workflow) Accept(ctx context.Context, deps *Dependencies, workflows Workflows, input Input) (err error)

Accept executes the workflow to the deepest using input. In addition to the errors caused by intents and nodes, ErrEOF and ErrNoChange can be returned.

func (*Workflow) ApplyAllEffects 

func (w *Workflow) ApplyAllEffects(ctx context.Context, deps *Dependencies, workflows Workflows) error

func (*Workflow) ApplyRunEffects 

func (w *Workflow) ApplyRunEffects(ctx context.Context, deps *Dependencies, workflows Workflows) error

func (*Workflow) Clone 

func (w *Workflow) Clone() *Workflow

func (*Workflow) CollectCookies 

func (w *Workflow) CollectCookies(ctx context.Context, deps *Dependencies, workflows Workflows) (cookies []*http.Cookie, err error)

func (*Workflow) FindInputReactor 

func (w *Workflow) FindInputReactor(ctx context.Context, deps *Dependencies, workflows Workflows) (*Workflow, InputReactor, error)

func (*Workflow) GetAuthenticationInfoEntry 

func (w *Workflow) GetAuthenticationInfoEntry(ctx context.Context, deps *Dependencies, workflows Workflows) (*authenticationinfo.Entry, bool)

func (*Workflow) IsEOF 

func (w *Workflow) IsEOF(ctx context.Context, deps *Dependencies, workflows Workflows) (bool, error)

func (*Workflow) MarshalJSON 

func (w *Workflow) MarshalJSON() ([]byte, error)

func (*Workflow) ToOutput 

func (w *Workflow) ToOutput(ctx context.Context, deps *Dependencies, workflows Workflows) (*WorkflowOutput, error)

func (*Workflow) Traverse 

func (w *Workflow) Traverse(t WorkflowTraverser) error

func (*Workflow) UnmarshalJSON 

func (w *Workflow) UnmarshalJSON(d []byte) (err error)

type WorkflowAction 

type WorkflowAction struct {
	Type        WorkflowActionType `json:"type"`
	RedirectURI string             `json:"redirect_uri,omitempty"`
}

type WorkflowActionType 

type WorkflowActionType string
const (
	WorkflowActionTypeContinue WorkflowActionType = "continue"
	WorkflowActionTypeFinish   WorkflowActionType = "finish"
	WorkflowActionTypeRedirect WorkflowActionType = "redirect"
)

type WorkflowOutput 

type WorkflowOutput struct {
	WorkflowID string       `json:"workflow_id,omitempty"`
	InstanceID string       `json:"instance_id,omitempty"`
	Intent     IntentOutput `json:"intent"`
	Nodes      []NodeOutput `json:"nodes,omitempty"`
}

type WorkflowTraverser 

type WorkflowTraverser struct {
	Intent     func(intent Intent, w *Workflow) error
	NodeSimple func(nodeSimple NodeSimple, w *Workflow) error
}

type Workflows 

type Workflows struct {
	Root    *Workflow
	Nearest *Workflow
}

func NewWorkflows 

func NewWorkflows(root *Workflow) Workflows

func (Workflows) Replace 

func (w Workflows) Replace(nearest *Workflow) Workflows

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.