Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

runtime

package

Go to main page

Versions in this module

v0

v0.0.5

Oct 14, 2024

v0.0.4

Oct 9, 2024

Changes in this version

type FlowExecutor

+ func (fe *FlowExecutor) SetEventHandler(handler *sdk.EventHandler)

v0.0.3

Sep 6, 2024

v0.0.2

Aug 15, 2024

Changes in this version

+ const AsyncRequestHeader

+ const FlowKeyInitial

+ const FlowNameParamName

+ const GoFlowRegisterInterval

+ const InternalRequestQueueInitial

+ const NewRequest

+ const PartialRequest

+ const PauseRequest

+ const RDBKeyTimeOut

+ const RequestIdHeaderName

+ const RequestIdParamName

+ const ResumeRequest

+ const StopRequest

+ const WorkerKeyInitial

+ func OpenConnectionV2(tag string, network string, address string, password string, db int, ...) (rmq.Connection, error)

+ func Router(fRuntime *FlowRuntime) http.Handler

+ type FlowDefinitionHandler func(flow *v1.Workflow, context *v1.Context) error

+ type FlowExecutor struct

+ CallbackURL string

+ DataStore sdk.DataStore

+ EnableMonitoring bool

+ EventHandler sdk.EventHandler

+ Handler FlowDefinitionHandler

+ IsLoggingEnabled bool

+ Logger sdk.Logger

+ RequestAuthEnabled bool

+ RequestAuthSharedSecret string

+ Runtime *FlowRuntime

+ StateStore sdk.StateStore

+ func (fe *FlowExecutor) Configure(requestID string)

+ func (fe *FlowExecutor) GetDataStore() (sdk.DataStore, error)

+ func (fe *FlowExecutor) GetEventHandler() (sdk.EventHandler, error)

+ func (fe *FlowExecutor) GetExecutionOption(_ sdk.Operation) map[string]interface{}

+ func (fe *FlowExecutor) GetFlowDefinition(pipeline *sdk.Pipeline, context *sdk.Context) error

+ func (fe *FlowExecutor) GetFlowName() string

+ func (fe *FlowExecutor) GetLogger() (sdk.Logger, error)

+ func (fe *FlowExecutor) GetReqAuthKey() (string, error)

+ func (fe *FlowExecutor) GetStateStore() (sdk.StateStore, error)

+ func (fe *FlowExecutor) GetValidationKey() (string, error)

+ func (fe *FlowExecutor) HandleExecutionCompletion(data []byte) error

+ func (fe *FlowExecutor) HandleNextNode(partial *executor.PartialState) error

+ func (fe *FlowExecutor) Init(request *runtime.Request) error

+ func (fe *FlowExecutor) LoggingEnabled() bool

+ func (fe *FlowExecutor) MonitoringEnabled() bool

+ func (fe *FlowExecutor) ReqAuthEnabled() bool

+ func (fe *FlowExecutor) ReqValidationEnabled() bool

+ type FlowRuntime struct

+ Concurrency int

+ DataStore sdk.DataStore

+ DebugEnabled bool

+ EnableMonitoring bool

+ Flows map[string]FlowDefinitionHandler

+ Logger sdk.Logger

+ OpenTracingUrl string

+ ReadTimeout time.Duration

+ RedisPassword string

+ RedisURL string

+ RequestAuthEnabled bool

+ RequestAuthSharedSecret string

+ RetryQueueCount int

+ ServerPort int

+ WriteTimeout time.Duration

+ func (fRuntime *FlowRuntime) Consume(message rmq.Delivery)

+ func (fRuntime *FlowRuntime) CreateExecutor(req *runtime.Request) (executor.Executor, error)

+ func (fRuntime *FlowRuntime) EnqueuePartialRequest(pr *runtime.Request) error

+ func (fRuntime *FlowRuntime) EnterWorkerMode() error

+ func (fRuntime *FlowRuntime) Execute(flowName string, request *runtime.Request) error

+ func (fRuntime *FlowRuntime) ExitWorkerMode() error

+ func (fRuntime *FlowRuntime) Init() error

+ func (fRuntime *FlowRuntime) Pause(flowName string, request *runtime.Request) error

+ func (fRuntime *FlowRuntime) Register(flows map[string]FlowDefinitionHandler) error

+ func (fRuntime *FlowRuntime) Resume(flowName string, request *runtime.Request) error

+ func (fRuntime *FlowRuntime) StartRuntime() error

+ func (fRuntime *FlowRuntime) StartServer() error

+ func (fRuntime *FlowRuntime) Stop(flowName string, request *runtime.Request) error

+ func (fRuntime *FlowRuntime) StopServer() error

+ type Task struct

+ Body string

+ FlowName string

+ Header map[string][]string

+ Query map[string][]string

+ RawQuery string

+ RequestID string

+ RequestType string

+ type Worker struct

+ Concurrency int

+ Flows []string

+ ID string