lib

Documentation

Index

• func ExecuteWorkflow(ctx context.Context, tClient client.Client, options ExecuteWorkflowOptions) error
• func NewTemporalClient(cfg *TemporalClientConfig) (client.Client, error)
• type ExecuteWorkflowOptions
  • func (options *ExecuteWorkflowOptions) Validate() error
• type TemporalClientConfig
  • func (cfg *TemporalClientConfig) Validate() error

Functions

func ExecuteWorkflow

func ExecuteWorkflow(ctx context.Context, tClient client.Client, options ExecuteWorkflowOptions) error

func NewTemporalClient

func NewTemporalClient(cfg *TemporalClientConfig) (client.Client, error)

Types

type ExecuteWorkflowOptions

type ExecuteWorkflowOptions struct {
	ID        string      `validate:"required"`
	TaskQueue string      `validate:"required"`
	Input     interface{} `validate:"required"`
	Type      string      `validate:"required"`
}

func (*ExecuteWorkflowOptions) Validate

func (options *ExecuteWorkflowOptions) Validate() error

type TemporalClientConfig

type TemporalClientConfig struct {
	HostPort  string `validate:"required"`
	Namespace string
}

func (*TemporalClientConfig) Validate

func (cfg *TemporalClientConfig) Validate() error