elasticsearch

Oct 29, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 4, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 16, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 31, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ var ErrInvalidDuration = errors.New("invalid duration format")

+ func NewProcessor(cfg *ProcessorConfig, esClient esclient.Client, logger log.Logger, ...) *processorImpl

+ func NewVisibilityManager(indexName string, esClient esclient.Client, cfg *config.VisibilityConfig, ...) visibility.VisibilityManager

+ func NewVisibilityManagerMetrics(persistence visibility.VisibilityManager, metricClient metrics.Client, ...) visibility.VisibilityManager

+ func NewVisibilityStore(esClient esclient.Client, index string, ...) *visibilityStore

+ type MockProcessor struct

+ func NewMockProcessor(ctrl *gomock.Controller) *MockProcessor

+ func (m *MockProcessor) Add(request *client.BulkableRequest, visibilityTaskKey string) <-chan bool

+ func (m *MockProcessor) EXPECT() *MockProcessorMockRecorder

+ func (m *MockProcessor) Start()

+ func (m *MockProcessor) Stop()

+ type MockProcessorMockRecorder struct

+ func (mr *MockProcessorMockRecorder) Add(request, visibilityTaskKey interface{}) *gomock.Call

+ func (mr *MockProcessorMockRecorder) Start() *gomock.Call

+ func (mr *MockProcessorMockRecorder) Stop() *gomock.Call

+ type Processor interface

+ Add func(request *esclient.BulkableRequest, visibilityTaskKey string) <-chan bool

+ type ProcessorConfig struct

+ ESProcessorBulkActions dynamicconfig.IntPropertyFn

+ ESProcessorBulkSize dynamicconfig.IntPropertyFn

+ ESProcessorFlushInterval dynamicconfig.DurationPropertyFn

+ ESProcessorNumOfWorkers dynamicconfig.IntPropertyFn

+ IndexerConcurrency dynamicconfig.IntPropertyFn

+ type VisibilityTaskAckTimeoutError struct

+ Timeout time.Duration

+ VisibilityTaskKey string

+ func (v *VisibilityTaskAckTimeoutError) Error() string

+ type VisibilityTaskNAckError struct

+ VisibilityTaskKey string

+ func (v *VisibilityTaskNAckError) Error() string