utils

Documentation

Index

• Variables
• func GetActivityOptions() workflow.ActivityOptions
• func GetProdActivityOptions() workflow.ActivityOptions
• func GetProdWorkflowOptions(id string, taskQueue string) client.StartWorkflowOptions
• func GetWFClient(namespace, hostPort string) client.Client
• func GetWorkflowOptionsWithWorkflowRunTimeout(id string, taskQueue string) client.StartWorkflowOptions
• func WithCEActivityOptions(ctx workflow.Context) workflow.Context
• func WithCEPActivityOptions(ctx workflow.Context) workflow.Context
• func WithCMPSActivityOptions(ctx workflow.Context) workflow.Context
• func WithChildWorkflowOptions(ctx workflow.Context, id string) workflow.Context
• func WithChildWorkflowOptionsDuplicates(ctx workflow.Context, id string) workflow.Context
• func WithChildWorkflowOptionsTaskQueue(ctx workflow.Context, taskQueue string, id string) workflow.Context
• func WithChildWorkflowOptionsTaskQueueDuplicates(ctx workflow.Context, taskQueue string, id string) workflow.Context
• func WithIOTChildWorkflowOptionsDuplicates(ctx workflow.Context, id string) workflow.Context
• func WithShortLivedChildWorkflowOptionsDuplicates(ctx workflow.Context, id string) workflow.Context

Variables

var (
	TemporalHostPort  = "localhost:7233"
	TemporalNamespace = "default"
	SupportedChannels = []Common.CommunicationChannel{Common.CommunicationChannel_SMS,
		Common.CommunicationChannel_WHATSAPP}
)

var DefaultTimezone, _ = time.LoadLocation("Asia/Kolkata")

var GRPCClientConfig map[string]string

var LOG = getLogger()

var SMSTemplatesConfig map[string]string

var ServiceSpecSpecificTemplatesConfig map[string]map[string]map[string]string

var TemplatesConfig map[string]map[string]string

var WorkflowClient client.Client = getClient()

var WorkflowConfig map[string]string

Functions

func GetActivityOptions

func GetActivityOptions() workflow.ActivityOptions

func GetProdActivityOptions

func GetProdActivityOptions() workflow.ActivityOptions

func GetProdWorkflowOptions

func GetProdWorkflowOptions(id string, taskQueue string) client.StartWorkflowOptions

func GetWFClient

func GetWFClient(namespace, hostPort string) client.Client

func GetWorkflowOptionsWithWorkflowRunTimeout

func GetWorkflowOptionsWithWorkflowRunTimeout(id string, taskQueue string) client.StartWorkflowOptions

func WithCEActivityOptions

func WithCEActivityOptions(ctx workflow.Context) workflow.Context

func WithCEPActivityOptions

func WithCEPActivityOptions(ctx workflow.Context) workflow.Context

func WithCMPSActivityOptions

func WithCMPSActivityOptions(ctx workflow.Context) workflow.Context

func WithChildWorkflowOptions

func WithChildWorkflowOptions(ctx workflow.Context, id string) workflow.Context

func WithChildWorkflowOptionsDuplicates

func WithChildWorkflowOptionsDuplicates(ctx workflow.Context, id string) workflow.Context

func WithChildWorkflowOptionsTaskQueue

func WithChildWorkflowOptionsTaskQueue(ctx workflow.Context, taskQueue string, id string) workflow.Context

func WithChildWorkflowOptionsTaskQueueDuplicates

func WithChildWorkflowOptionsTaskQueueDuplicates(ctx workflow.Context, taskQueue string, id string) workflow.Context

func WithIOTChildWorkflowOptionsDuplicates

func WithIOTChildWorkflowOptionsDuplicates(ctx workflow.Context, id string) workflow.Context

func WithShortLivedChildWorkflowOptionsDuplicates

func WithShortLivedChildWorkflowOptionsDuplicates(ctx workflow.Context, id string) workflow.Context