validator

Documentation

Index

• type SearchAttributesValidator
  • func NewSearchAttributesValidator(logger log.Logger, validSearchAttributes dynamicconfig.MapPropertyFn, ...) *SearchAttributesValidator
  • func (sv *SearchAttributesValidator) ValidateSearchAttributes(input *commonpb.SearchAttributes, namespace string) error
• type VisibilityQueryValidator
  • func NewQueryValidator(validSearchAttributes dynamicconfig.MapPropertyFn) *VisibilityQueryValidator
  • func (qv *VisibilityQueryValidator) ValidateCountRequestForQuery(countRequest *workflowservice.CountWorkflowExecutionsRequest) error
  • func (qv *VisibilityQueryValidator) ValidateListRequestForQuery(listRequest *workflowservice.ListWorkflowExecutionsRequest) error
  • func (qv *VisibilityQueryValidator) ValidateScanRequestForQuery(listRequest *workflowservice.ScanWorkflowExecutionsRequest) error

Types

type SearchAttributesValidator

type SearchAttributesValidator struct {
	// contains filtered or unexported fields
}

SearchAttributesValidator is used to validate search attributes

func NewSearchAttributesValidator

func NewSearchAttributesValidator(
	logger log.Logger,
	validSearchAttributes dynamicconfig.MapPropertyFn,
	searchAttributesNumberOfKeysLimit dynamicconfig.IntPropertyFnWithNamespaceFilter,
	searchAttributesSizeOfValueLimit dynamicconfig.IntPropertyFnWithNamespaceFilter,
	searchAttributesTotalSizeLimit dynamicconfig.IntPropertyFnWithNamespaceFilter,
) *SearchAttributesValidator

NewSearchAttributesValidator create SearchAttributesValidator

func (*SearchAttributesValidator) ValidateSearchAttributes

func (sv *SearchAttributesValidator) ValidateSearchAttributes(input *commonpb.SearchAttributes, namespace string) error

ValidateSearchAttributes validate search attributes are valid for writing and not exceed limits

type VisibilityQueryValidator

type VisibilityQueryValidator struct {
	// contains filtered or unexported fields
}

VisibilityQueryValidator for sql query validation

func NewQueryValidator

func NewQueryValidator(validSearchAttributes dynamicconfig.MapPropertyFn) *VisibilityQueryValidator

NewQueryValidator create VisibilityQueryValidator

func (*VisibilityQueryValidator) ValidateCountRequestForQuery

func (qv *VisibilityQueryValidator) ValidateCountRequestForQuery(countRequest *workflowservice.CountWorkflowExecutionsRequest) error

ValidateCountRequestForQuery validate that search attributes in countRequest query is legal, and add prefix for custom keys

func (*VisibilityQueryValidator) ValidateListRequestForQuery

func (qv *VisibilityQueryValidator) ValidateListRequestForQuery(listRequest *workflowservice.ListWorkflowExecutionsRequest) error

ValidateListRequestForQuery validate that search attributes in listRequest query is legal, and add prefix for custom keys

func (*VisibilityQueryValidator) ValidateScanRequestForQuery

func (qv *VisibilityQueryValidator) ValidateScanRequestForQuery(listRequest *workflowservice.ScanWorkflowExecutionsRequest) error