client

Sep 6, 2024

Changes in this version

type Client

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

+ CreateIndex func(ctx context.Context, index string, body map[string]any) (bool, error)

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

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

type Config

+ func (cfg *Config) GetHttpClient() *http.Client

+ func (cfg *Config) SetHttpClient(httpClient *http.Client)

type MockCLIClient

+ func (m *MockCLIClient) CreateIndex(ctx context.Context, index string, body map[string]any) (bool, error)

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

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

type MockCLIClientMockRecorder

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

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

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

type MockClient

+ func (m *MockClient) CatIndices(ctx context.Context, target string) (v7.CatIndicesResponse, error)

+ func (m *MockClient) CreateIndex(ctx context.Context, index string, body map[string]any) (bool, error)

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

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

type MockClientMockRecorder

+ func (mr *MockClientMockRecorder) CatIndices(ctx, target interface{}) *gomock.Call

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

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

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

type MockIntegrationTestsClient

+ func (m *MockIntegrationTestsClient) CatIndices(ctx context.Context, target string) (v7.CatIndicesResponse, error)

+ func (m *MockIntegrationTestsClient) ClosePointInTime(ctx context.Context, id string) (bool, error)

+ func (m *MockIntegrationTestsClient) CloseScroll(ctx context.Context, id string) error

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

+ func (m *MockIntegrationTestsClient) CountGroupBy(ctx context.Context, index string, query v7.Query, aggName string, ...) (*v7.SearchResult, error)

+ func (m *MockIntegrationTestsClient) Get(ctx context.Context, index, docID string) (*v7.GetResult, error)

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

+ func (m *MockIntegrationTestsClient) IsPointInTimeSupported(ctx context.Context) bool

+ func (m *MockIntegrationTestsClient) OpenPointInTime(ctx context.Context, index, keepAliveInterval string) (string, error)

+ func (m *MockIntegrationTestsClient) OpenScroll(ctx context.Context, p *SearchParameters, keepAliveInterval string) (*v7.SearchResult, error)

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

+ func (m *MockIntegrationTestsClient) Scroll(ctx context.Context, id, keepAliveInterval string) (*v7.SearchResult, error)

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

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

type MockIntegrationTestsClientMockRecorder

+ func (mr *MockIntegrationTestsClientMockRecorder) CatIndices(ctx, target interface{}) *gomock.Call

+ func (mr *MockIntegrationTestsClientMockRecorder) ClosePointInTime(ctx, id interface{}) *gomock.Call

+ func (mr *MockIntegrationTestsClientMockRecorder) CloseScroll(ctx, id interface{}) *gomock.Call

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

+ func (mr *MockIntegrationTestsClientMockRecorder) CountGroupBy(ctx, index, query, aggName, agg interface{}) *gomock.Call

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

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

+ func (mr *MockIntegrationTestsClientMockRecorder) IsPointInTimeSupported(ctx interface{}) *gomock.Call

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

+ func (mr *MockIntegrationTestsClientMockRecorder) OpenScroll(ctx, p, keepAliveInterval interface{}) *gomock.Call

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

+ func (mr *MockIntegrationTestsClientMockRecorder) Scroll(ctx, id, keepAliveInterval interface{}) *gomock.Call

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

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

Mar 22, 2024

Changes in this version

type Config

+ TLS *auth.TLS

+ URLs []url.URL

type IntegrationTestsClient

+ func NewFunctionalTestsClient(config *Config, logger log.Logger) (IntegrationTestsClient, error)

+ Ping func(ctx context.Context) error

type MockIntegrationTestsClient

+ func (m *MockIntegrationTestsClient) Ping(ctx context.Context) error

type MockIntegrationTestsClientMockRecorder

+ func (mr *MockIntegrationTestsClientMockRecorder) Ping(ctx interface{}) *gomock.Call

Feb 29, 2024 GO-2024-2689

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

Feb 22, 2024 GO-2024-2689

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

Feb 22, 2024 GO-2024-2689

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

Feb 2, 2024 GO-2024-2689

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

Jan 12, 2024 GO-2024-2689

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

Dec 7, 2023 GO-2024-2689

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

Nov 30, 2023 GO-2024-2689

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

Nov 28, 2023 GO-2024-2689

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

Nov 22, 2023 GO-2024-2689

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

Nov 13, 2023 GO-2024-2689

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

Nov 3, 2023 GO-2024-2689

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

Nov 1, 2023 GO-2024-2689

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

Oct 31, 2023 GO-2024-2689

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

Oct 13, 2023 GO-2024-2689

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

Oct 6, 2023 GO-2024-2689

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

Nov 1, 2023 GO-2024-2689

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

Sep 5, 2023 GO-2024-2689

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

Changes in this version

type Client

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

type MockCLIClient

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

type MockCLIClientMockRecorder

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

type MockClient

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

type MockClientMockRecorder

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

Aug 28, 2023 GO-2024-2689

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

Aug 21, 2023 GO-2024-2689

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

Aug 14, 2023 GO-2024-2689

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

Aug 14, 2023 GO-2024-2689

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

Aug 14, 2023 GO-2024-2689

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

Aug 8, 2023 GO-2024-2689

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

Jul 28, 2023 GO-2024-2689

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

Jul 24, 2023 GO-2024-2689

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

Changes in this version

type SearchParameters

+ ScrollID string

Jul 14, 2023 GO-2024-2689

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

Jul 1, 2023 GO-2024-2689

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

Jun 23, 2023 GO-2024-2689

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

Jul 13, 2023 GO-2024-2689

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

May 15, 2023 GO-2024-2689

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

Apr 17, 2023 GO-2024-2689

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

Mar 29, 2023 GO-2024-2689

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

Feb 17, 2023 GO-2024-2689

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

Changes in this version

type IntegrationTestsClient

+ PutMapping func(ctx context.Context, index string, mapping map[string]enumspb.IndexedValueType) (bool, error)

type MockIntegrationTestsClient

+ func (m *MockIntegrationTestsClient) PutMapping(ctx context.Context, index string, mapping map[string]v1.IndexedValueType) (bool, error)

type MockIntegrationTestsClientMockRecorder

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

Jan 13, 2023 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

Dec 1, 2022 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

type Client

+ Get func(ctx context.Context, index string, docID string) (*elastic.GetResult, error)

type MockCLIClient

+ func (m *MockCLIClient) Get(ctx context.Context, index, docID string) (*v7.GetResult, error)

type MockCLIClientMockRecorder

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

type MockClient

+ func (m *MockClient) Get(ctx context.Context, index, docID string) (*v7.GetResult, error)

type MockClientMockRecorder

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

Nov 15, 2022 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 31, 2022 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 20, 2022 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 18, 2022 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 10, 2022 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, 2022 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

type Client

+ ClosePointInTime func(ctx context.Context, id string) (bool, error)

+ IsPointInTimeSupported func(ctx context.Context) bool

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

type MockCLIClient

+ func (m *MockCLIClient) ClosePointInTime(ctx context.Context, id string) (bool, error)

+ func (m *MockCLIClient) IsPointInTimeSupported(ctx context.Context) bool

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

type MockCLIClientMockRecorder

+ func (mr *MockCLIClientMockRecorder) ClosePointInTime(ctx, id interface{}) *gomock.Call

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

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

type MockClient

+ func (m *MockClient) ClosePointInTime(ctx context.Context, id string) (bool, error)

+ func (m *MockClient) IsPointInTimeSupported(ctx context.Context) bool

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

type MockClientMockRecorder

+ func (mr *MockClientMockRecorder) ClosePointInTime(ctx, id interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) IsPointInTimeSupported(ctx interface{}) *gomock.Call

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

Sep 14, 2022 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 30, 2022 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 16, 2022 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 17, 2022 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 2, 2022 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 11, 2022 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 17, 2022 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 11, 2022 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, 2022 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 19, 2022 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 11, 2022 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 4, 2022 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 1, 2022 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

Feb 9, 2022 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 4, 2022 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

Feb 11, 2022 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

Jan 21, 2022 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

Jan 18, 2022 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

+ const SecondaryVisibilityAppName

type Config

+ func (cfg *Config) GetSecondaryVisibilityIndex() string

Jan 10, 2022 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

Dec 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

Dec 13, 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 HttpStatus(err error) int

Feb 10, 2022 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

Jan 12, 2022 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

Dec 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

Nov 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

Oct 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

Changes in this version

+ const VisibilityAppName

+ func IsRetryableError(err error) bool

+ func IsRetryableStatus(status int) bool

+ func NewAwsHttpClient(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)

+ Delete func(ctx context.Context, indexName string, docID string, version int64) error

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

+ type Client interface

+ CloseScroll func(ctx context.Context, id string) error

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

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

+ OpenScroll func(ctx context.Context, p *SearchParameters, keepAliveInterval string) (*elastic.SearchResult, error)

+ PutMapping func(ctx context.Context, index string, mapping map[string]enumspb.IndexedValueType) (bool, error)

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

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

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

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

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

+ type ClientV7 interface

+ ClosePointInTime func(ctx context.Context, id string) (bool, error)

+ IsPointInTimeSupported func(ctx context.Context) bool

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

+ type Config struct

+ AWSRequestSigning ESAWSRequestSigningConfig

+ CloseIdleConnectionsInterval time.Duration

+ EnableHealthcheck bool

+ EnableSniff bool

+ Indices map[string]string

+ LogLevel string

+ Password string

+ URL url.URL

+ Username string

+ Version string

+ func (cfg *Config) GetVisibilityIndex() string

+ func (cfg *Config) Validate(storeName string) error

+ type ESAWSRequestSigningConfig struct

+ CredentialProvider string

+ Enabled bool

+ Region string

+ Static ESAWSStaticCredentialProvider

+ type ESAWSStaticCredentialProvider struct

+ AccessKeyID string

+ SecretAccessKey string

+ Token string

+ 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) CloseScroll(ctx context.Context, id string) error

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

+ func (m *MockCLIClient) Delete(ctx context.Context, indexName, docID string, version int64) error

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

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

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

+ func (m *MockCLIClient) PutMapping(ctx context.Context, index string, mapping map[string]v1.IndexedValueType) (bool, error)

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

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

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

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

+ type MockCLIClientMockRecorder struct

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

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

+ func (mr *MockCLIClientMockRecorder) CloseScroll(ctx, id interface{}) *gomock.Call

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

+ func (mr *MockCLIClientMockRecorder) Delete(ctx, indexName, docID, version interface{}) *gomock.Call

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

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

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

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

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

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

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

+ type MockClient struct

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

+ func (m *MockClient) CloseScroll(ctx context.Context, id string) error

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

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

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

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

+ func (m *MockClient) PutMapping(ctx context.Context, index string, mapping map[string]v1.IndexedValueType) (bool, error)

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

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

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

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

+ type MockClientMockRecorder struct

+ func (mr *MockClientMockRecorder) CloseScroll(ctx, id interface{}) *gomock.Call

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

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

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

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

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

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

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

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

+ type MockClientV7 struct

+ func NewMockClientV7(ctrl *gomock.Controller) *MockClientV7

+ func (m *MockClientV7) ClosePointInTime(ctx context.Context, id string) (bool, error)

+ func (m *MockClientV7) CloseScroll(ctx context.Context, id string) error

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

+ func (m *MockClientV7) EXPECT() *MockClientV7MockRecorder

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

+ func (m *MockClientV7) IsPointInTimeSupported(ctx context.Context) bool

+ func (m *MockClientV7) OpenPointInTime(ctx context.Context, index, keepAliveInterval string) (string, error)

+ func (m *MockClientV7) OpenScroll(ctx context.Context, p *SearchParameters, keepAliveInterval string) (*v7.SearchResult, error)

+ func (m *MockClientV7) PutMapping(ctx context.Context, index string, mapping map[string]v1.IndexedValueType) (bool, error)

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

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

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

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

+ type MockClientV7MockRecorder struct

+ func (mr *MockClientV7MockRecorder) ClosePointInTime(ctx, id interface{}) *gomock.Call

+ func (mr *MockClientV7MockRecorder) CloseScroll(ctx, id interface{}) *gomock.Call

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

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

+ func (mr *MockClientV7MockRecorder) IsPointInTimeSupported(ctx interface{}) *gomock.Call

+ func (mr *MockClientV7MockRecorder) OpenPointInTime(ctx, index, keepAliveInterval interface{}) *gomock.Call

+ func (mr *MockClientV7MockRecorder) OpenScroll(ctx, p, keepAliveInterval interface{}) *gomock.Call

+ func (mr *MockClientV7MockRecorder) PutMapping(ctx, index, mapping interface{}) *gomock.Call

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

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

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

+ func (mr *MockClientV7MockRecorder) WaitForYellowStatus(ctx, index 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 SearchParameters struct

+ Index string

+ PageSize int

+ PointInTime *elastic.PointInTime

+ Query elastic.Query

+ SearchAfter []interface{}

+ Sorter []elastic.Sorter