client

Aug 18, 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 6, 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

Jul 22, 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

Jul 20, 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

Jul 18, 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

Jun 24, 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

Jun 23, 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

Jun 18, 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

Jun 8, 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

Jun 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

Jun 2, 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

+ func IsRetryableError(err error) bool

+ func IsRetryableStatus(status int) bool

type Client

+ GetMapping func(ctx context.Context, index string) (map[string]string, error)

+ WaitForYellowStatus func(ctx context.Context, index string) (string, error)

type MockCLIClient

+ func (m *MockCLIClient) GetMapping(ctx context.Context, index string) (map[string]string, error)

+ func (m *MockCLIClient) WaitForYellowStatus(ctx context.Context, index string) (string, error)

type MockCLIClientMockRecorder

+ func (mr *MockCLIClientMockRecorder) GetMapping(ctx, index interface{}) *gomock.Call

+ func (mr *MockCLIClientMockRecorder) WaitForYellowStatus(ctx, index interface{}) *gomock.Call

type MockClient

+ func (m *MockClient) GetMapping(ctx context.Context, index string) (map[string]string, error)

+ func (m *MockClient) WaitForYellowStatus(ctx context.Context, index string) (string, error)

type MockClientMockRecorder

+ func (mr *MockClientMockRecorder) GetMapping(ctx, index interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) WaitForYellowStatus(ctx, index interface{}) *gomock.Call

Jun 23, 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

May 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

May 5, 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

Apr 27, 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

Apr 15, 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

Mar 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

Mar 23, 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

Mar 23, 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

+ func NewAwsHttpClient(config config.ESAWSRequestSigningConfig) (*http.Client, error)

+ type BulkProcessor interface

+ Add func(request *BulkableRequest)

+ Stop func() error

+ type BulkProcessorParameters struct

+ AfterFunc elastic.BulkAfterFunc

+ Backoff elastic.Backoff

+ BeforeFunc elastic.BulkBeforeFunc

+ BulkActions int

+ BulkSize int

+ FlushInterval time.Duration

+ Name string

+ NumOfWorkers int

+ type BulkService interface

+ Add func(request *BulkableRequest)

+ Do func(ctx context.Context) error

+ NumberOfActions func() int

+ type BulkableRequest struct

+ Doc map[string]interface{}

+ ID string

+ Index string

+ RequestType BulkableRequestType

+ Version int64

+ type BulkableRequestType uint8

+ const BulkableRequestTypeDelete

+ const BulkableRequestTypeIndex

+ type CLIClient interface

+ Bulk func() BulkService

+ CatIndices func(ctx context.Context) (elastic.CatIndicesResponse, error)

+ func NewCLIClient(url string, version string) (CLIClient, error)

+ type Client interface

+ Count func(ctx context.Context, index, query string) (int64, error)

+ PutMapping func(ctx context.Context, index, root, key, valueType string) error

+ RunBulkProcessor func(ctx context.Context, p *BulkProcessorParameters) (BulkProcessor, error)

+ Scroll func(ctx context.Context, scrollID string) (*elastic.SearchResult, ScrollService, error)

+ ScrollFirstPage func(ctx context.Context, index, query string) (*elastic.SearchResult, ScrollService, error)

+ Search func(ctx context.Context, p *SearchParameters) (*elastic.SearchResult, error)

+ SearchWithDSL func(ctx context.Context, index, query string) (*elastic.SearchResult, error)

+ func NewClient(config *config.Elasticsearch, httpClient *http.Client, logger log.Logger) (Client, error)

+ type IntegrationTestsClient interface

+ CreateIndex func(ctx context.Context, index string) (bool, error)

+ DeleteIndex func(ctx context.Context, indexName string) (bool, error)

+ IndexExists func(ctx context.Context, indexName string) (bool, error)

+ IndexGetSettings func(ctx context.Context, indexName string) (map[string]*elastic.IndicesGetSettingsResponse, error)

+ IndexPutSettings func(ctx context.Context, indexName string, bodyString string) (bool, error)

+ IndexPutTemplate func(ctx context.Context, templateName string, bodyString string) (bool, error)

+ func NewIntegrationTestsClient(url string, version string) (IntegrationTestsClient, error)

+ type MockBulkProcessor struct

+ func NewMockBulkProcessor(ctrl *gomock.Controller) *MockBulkProcessor

+ func (m *MockBulkProcessor) Add(request *BulkableRequest)

+ func (m *MockBulkProcessor) EXPECT() *MockBulkProcessorMockRecorder

+ func (m *MockBulkProcessor) Stop() error

+ type MockBulkProcessorMockRecorder struct

+ func (mr *MockBulkProcessorMockRecorder) Add(request interface{}) *gomock.Call

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

+ type MockCLIClient struct

+ func NewMockCLIClient(ctrl *gomock.Controller) *MockCLIClient

+ func (m *MockCLIClient) Bulk() BulkService

+ func (m *MockCLIClient) CatIndices(ctx context.Context) (v7.CatIndicesResponse, error)

+ func (m *MockCLIClient) Count(ctx context.Context, index, query string) (int64, error)

+ func (m *MockCLIClient) EXPECT() *MockCLIClientMockRecorder

+ func (m *MockCLIClient) PutMapping(ctx context.Context, index, root, key, valueType string) error

+ func (m *MockCLIClient) RunBulkProcessor(ctx context.Context, p *BulkProcessorParameters) (BulkProcessor, error)

+ func (m *MockCLIClient) Scroll(ctx context.Context, scrollID string) (*v7.SearchResult, ScrollService, error)

+ func (m *MockCLIClient) ScrollFirstPage(ctx context.Context, index, query string) (*v7.SearchResult, ScrollService, error)

+ func (m *MockCLIClient) Search(ctx context.Context, p *SearchParameters) (*v7.SearchResult, error)

+ func (m *MockCLIClient) SearchWithDSL(ctx context.Context, index, query string) (*v7.SearchResult, error)

+ type MockCLIClientMockRecorder struct

+ func (mr *MockCLIClientMockRecorder) Bulk() *gomock.Call

+ func (mr *MockCLIClientMockRecorder) CatIndices(ctx interface{}) *gomock.Call

+ func (mr *MockCLIClientMockRecorder) Count(ctx, index, query interface{}) *gomock.Call

+ func (mr *MockCLIClientMockRecorder) PutMapping(ctx, index, root, key, valueType interface{}) *gomock.Call

+ func (mr *MockCLIClientMockRecorder) RunBulkProcessor(ctx, p interface{}) *gomock.Call

+ func (mr *MockCLIClientMockRecorder) Scroll(ctx, scrollID interface{}) *gomock.Call

+ func (mr *MockCLIClientMockRecorder) ScrollFirstPage(ctx, index, query interface{}) *gomock.Call

+ func (mr *MockCLIClientMockRecorder) Search(ctx, p interface{}) *gomock.Call

+ func (mr *MockCLIClientMockRecorder) SearchWithDSL(ctx, index, query interface{}) *gomock.Call

+ type MockClient struct

+ func NewMockClient(ctrl *gomock.Controller) *MockClient

+ func (m *MockClient) Count(ctx context.Context, index, query string) (int64, error)

+ func (m *MockClient) EXPECT() *MockClientMockRecorder

+ func (m *MockClient) PutMapping(ctx context.Context, index, root, key, valueType string) error

+ func (m *MockClient) RunBulkProcessor(ctx context.Context, p *BulkProcessorParameters) (BulkProcessor, error)

+ func (m *MockClient) Scroll(ctx context.Context, scrollID string) (*v7.SearchResult, ScrollService, error)

+ func (m *MockClient) ScrollFirstPage(ctx context.Context, index, query string) (*v7.SearchResult, ScrollService, error)

+ func (m *MockClient) Search(ctx context.Context, p *SearchParameters) (*v7.SearchResult, error)

+ func (m *MockClient) SearchWithDSL(ctx context.Context, index, query string) (*v7.SearchResult, error)

+ type MockClientMockRecorder struct

+ func (mr *MockClientMockRecorder) Count(ctx, index, query interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) PutMapping(ctx, index, root, key, valueType interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) RunBulkProcessor(ctx, p interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) Scroll(ctx, scrollID interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) ScrollFirstPage(ctx, index, query interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) Search(ctx, p interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) SearchWithDSL(ctx, index, query interface{}) *gomock.Call

+ type MockIntegrationTestsClient struct

+ func NewMockIntegrationTestsClient(ctrl *gomock.Controller) *MockIntegrationTestsClient

+ func (m *MockIntegrationTestsClient) CreateIndex(ctx context.Context, index string) (bool, error)

+ func (m *MockIntegrationTestsClient) DeleteIndex(ctx context.Context, indexName string) (bool, error)

+ func (m *MockIntegrationTestsClient) EXPECT() *MockIntegrationTestsClientMockRecorder

+ func (m *MockIntegrationTestsClient) IndexExists(ctx context.Context, indexName string) (bool, error)

+ func (m *MockIntegrationTestsClient) IndexGetSettings(ctx context.Context, indexName string) (map[string]*v7.IndicesGetSettingsResponse, error)

+ func (m *MockIntegrationTestsClient) IndexPutSettings(ctx context.Context, indexName, bodyString string) (bool, error)

+ func (m *MockIntegrationTestsClient) IndexPutTemplate(ctx context.Context, templateName, bodyString string) (bool, error)

+ type MockIntegrationTestsClientMockRecorder struct

+ func (mr *MockIntegrationTestsClientMockRecorder) CreateIndex(ctx, index interface{}) *gomock.Call

+ func (mr *MockIntegrationTestsClientMockRecorder) DeleteIndex(ctx, indexName interface{}) *gomock.Call

+ func (mr *MockIntegrationTestsClientMockRecorder) IndexExists(ctx, indexName interface{}) *gomock.Call

+ func (mr *MockIntegrationTestsClientMockRecorder) IndexGetSettings(ctx, indexName interface{}) *gomock.Call

+ func (mr *MockIntegrationTestsClientMockRecorder) IndexPutSettings(ctx, indexName, bodyString interface{}) *gomock.Call

+ func (mr *MockIntegrationTestsClientMockRecorder) IndexPutTemplate(ctx, templateName, bodyString interface{}) *gomock.Call

+ type MockScrollService struct

+ func NewMockScrollService(ctrl *gomock.Controller) *MockScrollService

+ func (m *MockScrollService) Clear(ctx context.Context) error

+ func (m *MockScrollService) EXPECT() *MockScrollServiceMockRecorder

+ type MockScrollServiceMockRecorder struct

+ func (mr *MockScrollServiceMockRecorder) Clear(ctx interface{}) *gomock.Call

+ type ScrollService interface

+ Clear func(ctx context.Context) error

+ type SearchParameters struct

+ From int

+ Index string

+ PageSize int

+ Query elastic.Query

+ SearchAfter []interface{}

+ Sorter []elastic.Sorter