addsearchattributes

Documentation

Index

• Constants
• Variables
• func AddSearchAttributesWorkflow(ctx workflow.Context, params WorkflowParams) error
• func New(sdkClient sdkclient.Client, esClient esclient.Client, ...) *addSearchAttributes
• type WorkflowParams

Constants

const (
	// TaskQueueName is the task queue name.
	TaskQueueName = "temporal-sys-add-search-attributes-task-queue"
	// WorkflowName is the workflow name.
	WorkflowName = "temporal-sys-add-search-attributes-workflow"
)

Variables

var (
	ErrUnableToUpdateESMapping      = errors.New("unable to update Elasticsearch mapping")
	ErrUnableToExecuteActivity      = errors.New("unable to execute activity")
	ErrUnableToGetSearchAttributes  = errors.New("unable to get search attributes from cluster metadata")
	ErrUnableToSaveSearchAttributes = errors.New("unable to save search attributes to cluster metadata")
)

Functions

func AddSearchAttributesWorkflow

func AddSearchAttributesWorkflow(ctx workflow.Context, params WorkflowParams) error

AddSearchAttributesWorkflow is the workflow that adds search attributes to the cluster for specific index.

func New

func New(
	sdkClient sdkclient.Client,
	esClient esclient.Client,
	saManager searchattribute.Manager,
	metricsClient metrics.Client,
	logger log.Logger,
) *addSearchAttributes

New returns a new instance of addSearchAttributes.

Types

type WorkflowParams

type WorkflowParams struct {
	// Elasticsearch index name. Can be empty string if Elasticsearch is not configured.
	IndexName string
	// Search attributes that need to be added to the index.
	CustomAttributesToAdd map[string]enumspb.IndexedValueType
	// If true skip Elasticsearch schema update and only update cluster metadata.
	SkipSchemaUpdate bool
}

WorkflowParams is the parameters for add search attributes workflow.