client

package
v1.26.2-121.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 2, 2024 License: MIT Imports: 22 Imported by: 3

Documentation

Overview

Package client is a generated GoMock package.

Package client is a generated GoMock package.

Index

Constants

View Source 
const (
	// VisibilityAppName is used to find ES indexName for visibility
	VisibilityAppName          = "visibility"
	SecondaryVisibilityAppName = "secondary_visibility"
)

Variables

This section is empty.

Functions

func NewAwsHttpClient 

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

Types

type BulkProcessor 

type BulkProcessor interface {
	Stop() error
	Add(request *BulkableRequest)
}

type BulkProcessorParameters 

type BulkProcessorParameters struct {
	Name          string
	NumOfWorkers  int
	BulkActions   int
	BulkSize      int
	FlushInterval time.Duration
	BeforeFunc    elastic.BulkBeforeFunc
	AfterFunc     elastic.BulkAfterFunc
}

BulkProcessorParameters holds all required and optional parameters for executing bulk service

type BulkService 

type BulkService interface {
	Do(ctx context.Context) error
	NumberOfActions() int
	Add(request *BulkableRequest)
}

type BulkableRequest 

type BulkableRequest struct {
	RequestType BulkableRequestType
	Index       string
	ID          string
	Version     int64
	Doc         map[string]interface{}
}

type BulkableRequestType 

type BulkableRequestType uint8
const (
	BulkableRequestTypeIndex BulkableRequestType = iota
	BulkableRequestTypeDelete
)

type CLIClient 

type CLIClient interface {
	Client
	Delete(ctx context.Context, indexName string, docID string, version int64) error
}

func NewCLIClient 

func NewCLIClient(config *Config, logger log.Logger) (CLIClient, error)

type Client 

type Client interface {
	Get(ctx context.Context, index string, docID string) (*elastic.GetResult, error)
	Search(ctx context.Context, p *SearchParameters) (*elastic.SearchResult, error)
	Count(ctx context.Context, index string, query elastic.Query) (int64, error)
	CountGroupBy(ctx context.Context, index string, query elastic.Query, aggName string, agg elastic.Aggregation) (*elastic.SearchResult, error)
	RunBulkProcessor(ctx context.Context, p *BulkProcessorParameters) (BulkProcessor, error)

	// TODO (alex): move this to some admin client (and join with IntegrationTestsClient)
	PutMapping(ctx context.Context, index string, mapping map[string]enumspb.IndexedValueType) (bool, error)
	WaitForYellowStatus(ctx context.Context, index string) (string, error)
	GetMapping(ctx context.Context, index string) (map[string]string, error)
	IndexExists(ctx context.Context, indexName string) (bool, error)
	CreateIndex(ctx context.Context, index string, body map[string]any) (bool, error)
	DeleteIndex(ctx context.Context, indexName string) (bool, error)
	CatIndices(ctx context.Context, target string) (elastic.CatIndicesResponse, error)

	OpenScroll(ctx context.Context, p *SearchParameters, keepAliveInterval string) (*elastic.SearchResult, error)
	Scroll(ctx context.Context, id string, keepAliveInterval string) (*elastic.SearchResult, error)
	CloseScroll(ctx context.Context, id string) error

	IsPointInTimeSupported(ctx context.Context) bool
	OpenPointInTime(ctx context.Context, index string, keepAliveInterval string) (string, error)
	ClosePointInTime(ctx context.Context, id string) (bool, error)
}

Client is a wrapper around Elasticsearch client library.

func NewClient 

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

type Config 

type Config struct {
	Version                      string                    `yaml:"version"`
	URL                          url.URL                   `yaml:"url"`
	URLs                         []url.URL                 `yaml:"urls"`
	Username                     string                    `yaml:"username"`
	Password                     string                    `yaml:"password"`
	Indices                      map[string]string         `yaml:"indices"`
	LogLevel                     string                    `yaml:"logLevel"`
	AWSRequestSigning            ESAWSRequestSigningConfig `yaml:"aws-request-signing"`
	CloseIdleConnectionsInterval time.Duration             `yaml:"closeIdleConnectionsInterval"`
	EnableSniff                  bool                      `yaml:"enableSniff"`
	EnableHealthcheck            bool                      `yaml:"enableHealthcheck"`
	TLS                          *auth.TLS                 `yaml:"tls"`
	// contains filtered or unexported fields
}

Config for connecting to Elasticsearch

func (*Config) GetHttpClient added in v1.25.0 

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

func (*Config) GetSecondaryVisibilityIndex added in v1.14.3 

func (cfg *Config) GetSecondaryVisibilityIndex() string

func (*Config) GetVisibilityIndex 

func (cfg *Config) GetVisibilityIndex() string

GetVisibilityIndex return visibility index name from Elasticsearch config or empty string if it is not defined.

func (*Config) SetHttpClient added in v1.25.0 

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

func (*Config) Validate 

func (cfg *Config) Validate() error

type ESAWSRequestSigningConfig 

type ESAWSRequestSigningConfig struct {
	Enabled bool   `yaml:"enabled"`
	Region  string `yaml:"region"`

	// Possible options for CredentialProvider include:
	//   1) static (fill out static Credential Provider)
	//   2) environment
	//		a) AccessKeyID from either AWS_ACCESS_KEY_ID or AWS_ACCESS_KEY environment variable
	//		b) SecretAccessKey from either AWS_SECRET_ACCESS_KEY or AWS_SECRET_KEY environment variable
	//   3) aws-sdk-default
	//		a) Follows aws-go-sdk default credential resolution for session.NewSession
	CredentialProvider string `yaml:"credentialProvider"`

	Static ESAWSStaticCredentialProvider `yaml:"static"`
}

ESAWSRequestSigningConfig represents configuration for signing ES requests to AWS

type ESAWSStaticCredentialProvider 

type ESAWSStaticCredentialProvider struct {
	AccessKeyID     string `yaml:"accessKeyID"`
	SecretAccessKey string `yaml:"secretAccessKey"`

	// Token only required for temporary security credentials retrieved via STS. Otherwise, this is optional.
	Token string `yaml:"token"`
}

ESAWSStaticCredentialProvider represents static AWS credentials

type IntegrationTestsClient 

type IntegrationTestsClient interface {
	Client
	IndexPutTemplate(ctx context.Context, templateName string, bodyString string) (bool, error)
	IndexPutSettings(ctx context.Context, indexName string, bodyString string) (bool, error)
	IndexGetSettings(ctx context.Context, indexName string) (map[string]*elastic.IndicesGetSettingsResponse, error)
	Ping(ctx context.Context) error
}

func NewFunctionalTestsClient added in v1.23.0 

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

type MockBulkProcessor 

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

MockBulkProcessor is a mock of BulkProcessor interface.

func NewMockBulkProcessor 

func NewMockBulkProcessor(ctrl *gomock.Controller) *MockBulkProcessor

NewMockBulkProcessor creates a new mock instance.

func (*MockBulkProcessor) Add 

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

Add mocks base method.

func (*MockBulkProcessor) EXPECT 

func (m *MockBulkProcessor) EXPECT() *MockBulkProcessorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBulkProcessor) Stop 

func (m *MockBulkProcessor) Stop() error

Stop mocks base method.

type MockBulkProcessorMockRecorder 

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

MockBulkProcessorMockRecorder is the mock recorder for MockBulkProcessor.

func (*MockBulkProcessorMockRecorder) Add 

func (mr *MockBulkProcessorMockRecorder) Add(request any) *gomock.Call

Add indicates an expected call of Add.

func (*MockBulkProcessorMockRecorder) Stop 

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

Stop indicates an expected call of Stop.

type MockCLIClient 

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

MockCLIClient is a mock of CLIClient interface.

func NewMockCLIClient 

func NewMockCLIClient(ctrl *gomock.Controller) *MockCLIClient

NewMockCLIClient creates a new mock instance.

func (*MockCLIClient) CatIndices 

func (m *MockCLIClient) CatIndices(ctx context.Context, target string) (elastic.CatIndicesResponse, error)

CatIndices mocks base method.

func (*MockCLIClient) ClosePointInTime added in v1.18.0 

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

ClosePointInTime mocks base method.

func (*MockCLIClient) CloseScroll 

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

CloseScroll mocks base method.

func (*MockCLIClient) Count 

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

Count mocks base method.

func (*MockCLIClient) CountGroupBy added in v1.22.0 

func (m *MockCLIClient) CountGroupBy(ctx context.Context, index string, query elastic.Query, aggName string, agg elastic.Aggregation) (*elastic.SearchResult, error)

CountGroupBy mocks base method.

func (*MockCLIClient) CreateIndex added in v1.25.0 

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

CreateIndex mocks base method.

func (*MockCLIClient) Delete 

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

Delete mocks base method.

func (*MockCLIClient) DeleteIndex added in v1.25.0 

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

DeleteIndex mocks base method.

func (*MockCLIClient) EXPECT 

func (m *MockCLIClient) EXPECT() *MockCLIClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCLIClient) Get added in v1.19.0 

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

Get mocks base method.

func (*MockCLIClient) GetMapping 

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

GetMapping mocks base method.

func (*MockCLIClient) IndexExists added in v1.25.0 

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

IndexExists mocks base method.

func (*MockCLIClient) IsPointInTimeSupported added in v1.18.0 

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

IsPointInTimeSupported mocks base method.

func (*MockCLIClient) OpenPointInTime added in v1.18.0 

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

OpenPointInTime mocks base method.

func (*MockCLIClient) OpenScroll 

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

OpenScroll mocks base method.

func (*MockCLIClient) PutMapping 

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

PutMapping mocks base method.

func (*MockCLIClient) RunBulkProcessor 

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

RunBulkProcessor mocks base method.

func (*MockCLIClient) Scroll 

func (m *MockCLIClient) Scroll(ctx context.Context, id, keepAliveInterval string) (*elastic.SearchResult, error)

Scroll mocks base method.

func (*MockCLIClient) Search 

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

Search mocks base method.

func (*MockCLIClient) WaitForYellowStatus 

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

WaitForYellowStatus mocks base method.

type MockCLIClientMockRecorder 

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

MockCLIClientMockRecorder is the mock recorder for MockCLIClient.

func (*MockCLIClientMockRecorder) CatIndices 

func (mr *MockCLIClientMockRecorder) CatIndices(ctx, target any) *gomock.Call

CatIndices indicates an expected call of CatIndices.

func (*MockCLIClientMockRecorder) ClosePointInTime added in v1.18.0 

func (mr *MockCLIClientMockRecorder) ClosePointInTime(ctx, id any) *gomock.Call

ClosePointInTime indicates an expected call of ClosePointInTime.

func (*MockCLIClientMockRecorder) CloseScroll 

func (mr *MockCLIClientMockRecorder) CloseScroll(ctx, id any) *gomock.Call

CloseScroll indicates an expected call of CloseScroll.

func (*MockCLIClientMockRecorder) Count 

func (mr *MockCLIClientMockRecorder) Count(ctx, index, query any) *gomock.Call

Count indicates an expected call of Count.

func (*MockCLIClientMockRecorder) CountGroupBy added in v1.22.0 

func (mr *MockCLIClientMockRecorder) CountGroupBy(ctx, index, query, aggName, agg any) *gomock.Call

CountGroupBy indicates an expected call of CountGroupBy.

func (*MockCLIClientMockRecorder) CreateIndex added in v1.25.0 

func (mr *MockCLIClientMockRecorder) CreateIndex(ctx, index, body any) *gomock.Call

CreateIndex indicates an expected call of CreateIndex.

func (*MockCLIClientMockRecorder) Delete 

func (mr *MockCLIClientMockRecorder) Delete(ctx, indexName, docID, version any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockCLIClientMockRecorder) DeleteIndex added in v1.25.0 

func (mr *MockCLIClientMockRecorder) DeleteIndex(ctx, indexName any) *gomock.Call

DeleteIndex indicates an expected call of DeleteIndex.

func (*MockCLIClientMockRecorder) Get added in v1.19.0 

func (mr *MockCLIClientMockRecorder) Get(ctx, index, docID any) *gomock.Call

Get indicates an expected call of Get.

func (*MockCLIClientMockRecorder) GetMapping 

func (mr *MockCLIClientMockRecorder) GetMapping(ctx, index any) *gomock.Call

GetMapping indicates an expected call of GetMapping.

func (*MockCLIClientMockRecorder) IndexExists added in v1.25.0 

func (mr *MockCLIClientMockRecorder) IndexExists(ctx, indexName any) *gomock.Call

IndexExists indicates an expected call of IndexExists.

func (*MockCLIClientMockRecorder) IsPointInTimeSupported added in v1.18.0 

func (mr *MockCLIClientMockRecorder) IsPointInTimeSupported(ctx any) *gomock.Call

IsPointInTimeSupported indicates an expected call of IsPointInTimeSupported.

func (*MockCLIClientMockRecorder) OpenPointInTime added in v1.18.0 

func (mr *MockCLIClientMockRecorder) OpenPointInTime(ctx, index, keepAliveInterval any) *gomock.Call

OpenPointInTime indicates an expected call of OpenPointInTime.

func (*MockCLIClientMockRecorder) OpenScroll 

func (mr *MockCLIClientMockRecorder) OpenScroll(ctx, p, keepAliveInterval any) *gomock.Call

OpenScroll indicates an expected call of OpenScroll.

func (*MockCLIClientMockRecorder) PutMapping 

func (mr *MockCLIClientMockRecorder) PutMapping(ctx, index, mapping any) *gomock.Call

PutMapping indicates an expected call of PutMapping.

func (*MockCLIClientMockRecorder) RunBulkProcessor 

func (mr *MockCLIClientMockRecorder) RunBulkProcessor(ctx, p any) *gomock.Call

RunBulkProcessor indicates an expected call of RunBulkProcessor.

func (*MockCLIClientMockRecorder) Scroll 

func (mr *MockCLIClientMockRecorder) Scroll(ctx, id, keepAliveInterval any) *gomock.Call

Scroll indicates an expected call of Scroll.

func (*MockCLIClientMockRecorder) Search 

func (mr *MockCLIClientMockRecorder) Search(ctx, p any) *gomock.Call

Search indicates an expected call of Search.

func (*MockCLIClientMockRecorder) WaitForYellowStatus 

func (mr *MockCLIClientMockRecorder) WaitForYellowStatus(ctx, index any) *gomock.Call

WaitForYellowStatus indicates an expected call of WaitForYellowStatus.

type MockClient 

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

MockClient is a mock of Client interface.

func NewMockClient 

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) CatIndices added in v1.25.0 

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

CatIndices mocks base method.

func (*MockClient) ClosePointInTime added in v1.18.0 

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

ClosePointInTime mocks base method.

func (*MockClient) CloseScroll 

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

CloseScroll mocks base method.

func (*MockClient) Count 

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

Count mocks base method.

func (*MockClient) CountGroupBy added in v1.22.0 

func (m *MockClient) CountGroupBy(ctx context.Context, index string, query elastic.Query, aggName string, agg elastic.Aggregation) (*elastic.SearchResult, error)

CountGroupBy mocks base method.

func (*MockClient) CreateIndex added in v1.25.0 

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

CreateIndex mocks base method.

func (*MockClient) DeleteIndex added in v1.25.0 

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

DeleteIndex mocks base method.

func (*MockClient) EXPECT 

func (m *MockClient) EXPECT() *MockClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockClient) Get added in v1.19.0 

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

Get mocks base method.

func (*MockClient) GetMapping 

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

GetMapping mocks base method.

func (*MockClient) IndexExists added in v1.25.0 

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

IndexExists mocks base method.

func (*MockClient) IsPointInTimeSupported added in v1.18.0 

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

IsPointInTimeSupported mocks base method.

func (*MockClient) OpenPointInTime added in v1.18.0 

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

OpenPointInTime mocks base method.

func (*MockClient) OpenScroll 

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

OpenScroll mocks base method.

func (*MockClient) PutMapping 

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

PutMapping mocks base method.

func (*MockClient) RunBulkProcessor 

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

RunBulkProcessor mocks base method.

func (*MockClient) Scroll 

func (m *MockClient) Scroll(ctx context.Context, id, keepAliveInterval string) (*elastic.SearchResult, error)

Scroll mocks base method.

func (*MockClient) Search 

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

Search mocks base method.

func (*MockClient) WaitForYellowStatus 

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

WaitForYellowStatus mocks base method.

type MockClientMockRecorder 

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

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) CatIndices added in v1.25.0 

func (mr *MockClientMockRecorder) CatIndices(ctx, target any) *gomock.Call

CatIndices indicates an expected call of CatIndices.

func (*MockClientMockRecorder) ClosePointInTime added in v1.18.0 

func (mr *MockClientMockRecorder) ClosePointInTime(ctx, id any) *gomock.Call

ClosePointInTime indicates an expected call of ClosePointInTime.

func (*MockClientMockRecorder) CloseScroll 

func (mr *MockClientMockRecorder) CloseScroll(ctx, id any) *gomock.Call

CloseScroll indicates an expected call of CloseScroll.

func (*MockClientMockRecorder) Count 

func (mr *MockClientMockRecorder) Count(ctx, index, query any) *gomock.Call

Count indicates an expected call of Count.

func (*MockClientMockRecorder) CountGroupBy added in v1.22.0 

func (mr *MockClientMockRecorder) CountGroupBy(ctx, index, query, aggName, agg any) *gomock.Call

CountGroupBy indicates an expected call of CountGroupBy.

func (*MockClientMockRecorder) CreateIndex added in v1.25.0 

func (mr *MockClientMockRecorder) CreateIndex(ctx, index, body any) *gomock.Call

CreateIndex indicates an expected call of CreateIndex.

func (*MockClientMockRecorder) DeleteIndex added in v1.25.0 

func (mr *MockClientMockRecorder) DeleteIndex(ctx, indexName any) *gomock.Call

DeleteIndex indicates an expected call of DeleteIndex.

func (*MockClientMockRecorder) Get added in v1.19.0 

func (mr *MockClientMockRecorder) Get(ctx, index, docID any) *gomock.Call

Get indicates an expected call of Get.

func (*MockClientMockRecorder) GetMapping 

func (mr *MockClientMockRecorder) GetMapping(ctx, index any) *gomock.Call

GetMapping indicates an expected call of GetMapping.

func (*MockClientMockRecorder) IndexExists added in v1.25.0 

func (mr *MockClientMockRecorder) IndexExists(ctx, indexName any) *gomock.Call

IndexExists indicates an expected call of IndexExists.

func (*MockClientMockRecorder) IsPointInTimeSupported added in v1.18.0 

func (mr *MockClientMockRecorder) IsPointInTimeSupported(ctx any) *gomock.Call

IsPointInTimeSupported indicates an expected call of IsPointInTimeSupported.

func (*MockClientMockRecorder) OpenPointInTime added in v1.18.0 

func (mr *MockClientMockRecorder) OpenPointInTime(ctx, index, keepAliveInterval any) *gomock.Call

OpenPointInTime indicates an expected call of OpenPointInTime.

func (*MockClientMockRecorder) OpenScroll 

func (mr *MockClientMockRecorder) OpenScroll(ctx, p, keepAliveInterval any) *gomock.Call

OpenScroll indicates an expected call of OpenScroll.

func (*MockClientMockRecorder) PutMapping 

func (mr *MockClientMockRecorder) PutMapping(ctx, index, mapping any) *gomock.Call

PutMapping indicates an expected call of PutMapping.

func (*MockClientMockRecorder) RunBulkProcessor 

func (mr *MockClientMockRecorder) RunBulkProcessor(ctx, p any) *gomock.Call

RunBulkProcessor indicates an expected call of RunBulkProcessor.

func (*MockClientMockRecorder) Scroll 

func (mr *MockClientMockRecorder) Scroll(ctx, id, keepAliveInterval any) *gomock.Call

Scroll indicates an expected call of Scroll.

func (*MockClientMockRecorder) Search 

func (mr *MockClientMockRecorder) Search(ctx, p any) *gomock.Call

Search indicates an expected call of Search.

func (*MockClientMockRecorder) WaitForYellowStatus 

func (mr *MockClientMockRecorder) WaitForYellowStatus(ctx, index any) *gomock.Call

WaitForYellowStatus indicates an expected call of WaitForYellowStatus.

type MockIntegrationTestsClient 

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

MockIntegrationTestsClient is a mock of IntegrationTestsClient interface.

func NewMockIntegrationTestsClient 

func NewMockIntegrationTestsClient(ctrl *gomock.Controller) *MockIntegrationTestsClient

NewMockIntegrationTestsClient creates a new mock instance.

func (*MockIntegrationTestsClient) CatIndices added in v1.25.0 

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

CatIndices mocks base method.

func (*MockIntegrationTestsClient) ClosePointInTime added in v1.25.0 

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

ClosePointInTime mocks base method.

func (*MockIntegrationTestsClient) CloseScroll added in v1.25.0 

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

CloseScroll mocks base method.

func (*MockIntegrationTestsClient) Count added in v1.25.0 

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

Count mocks base method.

func (*MockIntegrationTestsClient) CountGroupBy added in v1.25.0 

func (m *MockIntegrationTestsClient) CountGroupBy(ctx context.Context, index string, query elastic.Query, aggName string, agg elastic.Aggregation) (*elastic.SearchResult, error)

CountGroupBy mocks base method.

func (*MockIntegrationTestsClient) CreateIndex 

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

CreateIndex mocks base method.

func (*MockIntegrationTestsClient) DeleteIndex 

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

DeleteIndex mocks base method.

func (*MockIntegrationTestsClient) EXPECT 

func (m *MockIntegrationTestsClient) EXPECT() *MockIntegrationTestsClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockIntegrationTestsClient) Get added in v1.25.0 

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

Get mocks base method.

func (*MockIntegrationTestsClient) GetMapping added in v1.25.0 

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

GetMapping mocks base method.

func (*MockIntegrationTestsClient) IndexExists 

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

IndexExists mocks base method.

func (*MockIntegrationTestsClient) IndexGetSettings 

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

IndexGetSettings mocks base method.

func (*MockIntegrationTestsClient) IndexPutSettings 

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

IndexPutSettings mocks base method.

func (*MockIntegrationTestsClient) IndexPutTemplate 

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

IndexPutTemplate mocks base method.

func (*MockIntegrationTestsClient) IsPointInTimeSupported added in v1.25.0 

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

IsPointInTimeSupported mocks base method.

func (*MockIntegrationTestsClient) OpenPointInTime added in v1.25.0 

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

OpenPointInTime mocks base method.

func (*MockIntegrationTestsClient) OpenScroll added in v1.25.0 

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

OpenScroll mocks base method.

func (*MockIntegrationTestsClient) Ping added in v1.23.0 

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

Ping mocks base method.

func (*MockIntegrationTestsClient) PutMapping added in v1.20.0 

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

PutMapping mocks base method.

func (*MockIntegrationTestsClient) RunBulkProcessor added in v1.25.0 

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

RunBulkProcessor mocks base method.

func (*MockIntegrationTestsClient) Scroll added in v1.25.0 

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

Scroll mocks base method.

func (*MockIntegrationTestsClient) Search added in v1.25.0 

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

Search mocks base method.

func (*MockIntegrationTestsClient) WaitForYellowStatus added in v1.25.0 

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

WaitForYellowStatus mocks base method.

type MockIntegrationTestsClientMockRecorder 

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

MockIntegrationTestsClientMockRecorder is the mock recorder for MockIntegrationTestsClient.

func (*MockIntegrationTestsClientMockRecorder) CatIndices added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) CatIndices(ctx, target any) *gomock.Call

CatIndices indicates an expected call of CatIndices.

func (*MockIntegrationTestsClientMockRecorder) ClosePointInTime added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) ClosePointInTime(ctx, id any) *gomock.Call

ClosePointInTime indicates an expected call of ClosePointInTime.

func (*MockIntegrationTestsClientMockRecorder) CloseScroll added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) CloseScroll(ctx, id any) *gomock.Call

CloseScroll indicates an expected call of CloseScroll.

func (*MockIntegrationTestsClientMockRecorder) Count added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) Count(ctx, index, query any) *gomock.Call

Count indicates an expected call of Count.

func (*MockIntegrationTestsClientMockRecorder) CountGroupBy added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) CountGroupBy(ctx, index, query, aggName, agg any) *gomock.Call

CountGroupBy indicates an expected call of CountGroupBy.

func (*MockIntegrationTestsClientMockRecorder) CreateIndex 

func (mr *MockIntegrationTestsClientMockRecorder) CreateIndex(ctx, index, body any) *gomock.Call

CreateIndex indicates an expected call of CreateIndex.

func (*MockIntegrationTestsClientMockRecorder) DeleteIndex 

func (mr *MockIntegrationTestsClientMockRecorder) DeleteIndex(ctx, indexName any) *gomock.Call

DeleteIndex indicates an expected call of DeleteIndex.

func (*MockIntegrationTestsClientMockRecorder) Get added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) Get(ctx, index, docID any) *gomock.Call

Get indicates an expected call of Get.

func (*MockIntegrationTestsClientMockRecorder) GetMapping added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) GetMapping(ctx, index any) *gomock.Call

GetMapping indicates an expected call of GetMapping.

func (*MockIntegrationTestsClientMockRecorder) IndexExists 

func (mr *MockIntegrationTestsClientMockRecorder) IndexExists(ctx, indexName any) *gomock.Call

IndexExists indicates an expected call of IndexExists.

func (*MockIntegrationTestsClientMockRecorder) IndexGetSettings 

func (mr *MockIntegrationTestsClientMockRecorder) IndexGetSettings(ctx, indexName any) *gomock.Call

IndexGetSettings indicates an expected call of IndexGetSettings.

func (*MockIntegrationTestsClientMockRecorder) IndexPutSettings 

func (mr *MockIntegrationTestsClientMockRecorder) IndexPutSettings(ctx, indexName, bodyString any) *gomock.Call

IndexPutSettings indicates an expected call of IndexPutSettings.

func (*MockIntegrationTestsClientMockRecorder) IndexPutTemplate 

func (mr *MockIntegrationTestsClientMockRecorder) IndexPutTemplate(ctx, templateName, bodyString any) *gomock.Call

IndexPutTemplate indicates an expected call of IndexPutTemplate.

func (*MockIntegrationTestsClientMockRecorder) IsPointInTimeSupported added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) IsPointInTimeSupported(ctx any) *gomock.Call

IsPointInTimeSupported indicates an expected call of IsPointInTimeSupported.

func (*MockIntegrationTestsClientMockRecorder) OpenPointInTime added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) OpenPointInTime(ctx, index, keepAliveInterval any) *gomock.Call

OpenPointInTime indicates an expected call of OpenPointInTime.

func (*MockIntegrationTestsClientMockRecorder) OpenScroll added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) OpenScroll(ctx, p, keepAliveInterval any) *gomock.Call

OpenScroll indicates an expected call of OpenScroll.

func (*MockIntegrationTestsClientMockRecorder) Ping added in v1.23.0 

func (mr *MockIntegrationTestsClientMockRecorder) Ping(ctx any) *gomock.Call

Ping indicates an expected call of Ping.

func (*MockIntegrationTestsClientMockRecorder) PutMapping added in v1.20.0 

func (mr *MockIntegrationTestsClientMockRecorder) PutMapping(ctx, index, mapping any) *gomock.Call

PutMapping indicates an expected call of PutMapping.

func (*MockIntegrationTestsClientMockRecorder) RunBulkProcessor added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) RunBulkProcessor(ctx, p any) *gomock.Call

RunBulkProcessor indicates an expected call of RunBulkProcessor.

func (*MockIntegrationTestsClientMockRecorder) Scroll added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) Scroll(ctx, id, keepAliveInterval any) *gomock.Call

Scroll indicates an expected call of Scroll.

func (*MockIntegrationTestsClientMockRecorder) Search added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) Search(ctx, p any) *gomock.Call

Search indicates an expected call of Search.

func (*MockIntegrationTestsClientMockRecorder) WaitForYellowStatus added in v1.25.0 

func (mr *MockIntegrationTestsClientMockRecorder) WaitForYellowStatus(ctx, index any) *gomock.Call

WaitForYellowStatus indicates an expected call of WaitForYellowStatus.

type SearchParameters 

type SearchParameters struct {
	Index    string
	Query    elastic.Query
	PageSize int
	Sorter   []elastic.Sorter

	SearchAfter []interface{}
	ScrollID    string
	PointInTime *elastic.PointInTime
}

SearchParameters holds all required and optional parameters for executing a search.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.