temporal

Documentation

Index

• func NewTemporalWorkflow(logger logger.Logger) workflows.Workflow
• type TemporalWF
  • func (c *TemporalWF) Close()
  • func (c *TemporalWF) Get(ctx context.Context, req *workflows.WorkflowReference) (*workflows.StateResponse, error)
  • func (c *TemporalWF) GetComponentMetadata() map[string]string
  • func (c *TemporalWF) Init(metadata workflows.Metadata) error
  • func (c *TemporalWF) Pause(ctx context.Context, req *workflows.WorkflowReference) error
  • func (c *TemporalWF) RaiseEvent(ctx context.Context, req *workflows.RaiseEventRequest) error
  • func (c *TemporalWF) Resume(ctx context.Context, req *workflows.WorkflowReference) error
  • func (c *TemporalWF) Start(ctx context.Context, req *workflows.StartRequest) (*workflows.WorkflowReference, error)
  • func (c *TemporalWF) Terminate(ctx context.Context, req *workflows.WorkflowReference) error

Functions

func NewTemporalWorkflow

func NewTemporalWorkflow(logger logger.Logger) workflows.Workflow

NewTemporalWorkflow returns a new workflow.

Types

type TemporalWF

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

func (*TemporalWF) Close

func (c *TemporalWF) Close()

func (*TemporalWF) Get

func (c *TemporalWF) Get(ctx context.Context, req *workflows.WorkflowReference) (*workflows.StateResponse, error)

func (*TemporalWF) GetComponentMetadata

func (c *TemporalWF) GetComponentMetadata() map[string]string

func (*TemporalWF) Init

func (c *TemporalWF) Init(metadata workflows.Metadata) error

func (*TemporalWF) Pause

func (c *TemporalWF) Pause(ctx context.Context, req *workflows.WorkflowReference) error

func (*TemporalWF) RaiseEvent

func (c *TemporalWF) RaiseEvent(ctx context.Context, req *workflows.RaiseEventRequest) error

func (*TemporalWF) Resume

func (c *TemporalWF) Resume(ctx context.Context, req *workflows.WorkflowReference) error

func (*TemporalWF) Start

func (c *TemporalWF) Start(ctx context.Context, req *workflows.StartRequest) (*workflows.WorkflowReference, error)

func (*TemporalWF) Terminate

func (c *TemporalWF) Terminate(ctx context.Context, req *workflows.WorkflowReference) error