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.GetRequest) (*workflows.StateResponse, error)
  • func (c *TemporalWF) GetComponentMetadata() (metadataInfo metadata.MetadataMap)
  • func (c *TemporalWF) Init(metadata workflows.Metadata) error
  • func (c *TemporalWF) Pause(ctx context.Context, req *workflows.PauseRequest) error
  • func (c *TemporalWF) Purge(ctx context.Context, req *workflows.PurgeRequest) error
  • func (c *TemporalWF) RaiseEvent(ctx context.Context, req *workflows.RaiseEventRequest) error
  • func (c *TemporalWF) Resume(ctx context.Context, req *workflows.ResumeRequest) error
  • func (c *TemporalWF) Start(ctx context.Context, req *workflows.StartRequest) (*workflows.StartResponse, error)
  • func (c *TemporalWF) Terminate(ctx context.Context, req *workflows.TerminateRequest) 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.GetRequest) (*workflows.StateResponse, error)

func (*TemporalWF) GetComponentMetadata

func (c *TemporalWF) GetComponentMetadata() (metadataInfo metadata.MetadataMap)

func (*TemporalWF) Init

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

func (*TemporalWF) Pause

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

func (*TemporalWF) Purge

func (c *TemporalWF) Purge(ctx context.Context, req *workflows.PurgeRequest) 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.ResumeRequest) error

func (*TemporalWF) Start

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

func (*TemporalWF) Terminate

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