example

Documentation

Index

• func NewTemporalClient(opts TemporalOptions) (client.Client, error)
• func StartWorkflow(ctx context.Context, cli client.Client, workflowType string, workflowID string, ...) (client.WorkflowRun, error)
• type TemporalOptions

Functions

func NewTemporalClient

func NewTemporalClient(opts TemporalOptions) (client.Client, error)

NewTemporalClient creates a new Temporal client zap.NewNop() is used for the logger because the logger is already configured in the application and we don't want to configure it again here The logger is used by the Temporal encryption converter The Temporal encryption converter is used to encrypt the payloads of the Temporal workflows

func StartWorkflow

func StartWorkflow(ctx context.Context, cli client.Client, workflowType string, workflowID string, workflowArgs ...interface{}) (client.WorkflowRun, error)

StartWorkflow starts a new Temporal workflow The salt is passed to the Temporal encryption converter The Temporal encryption converter is used to encrypt the payloads of the Temporal workflows

Types

type TemporalOptions

type TemporalOptions struct {
	Namespace             string
	HostPort              string
	WorkflowIdleTimeout   time.Duration
	TaskQueue             string
	X25519PublicKey       string
	X25519PrivateKey      string
	X25519SharedPublicKey string
}