client

package

v0.2.2 Latest Latest Go to latest Published: Jan 18, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Client OpenSearch client

func NewClient(addresses []string, username, password string, insecure bool) (*Client, error)

NewClient creates a new OpenSearch client

func (c *Client) BulkIndex(ctx context.Context, indexName string, documents []any) error

BulkIndex indexes multiple documents in OpenSearch

func (c *Client) CreateIndex(ctx context.Context, indexName string, mappings string) error

CreateIndex creates a new index with optional mappings

func (c *Client) DeleteDocument(ctx context.Context, indexName, documentID string) error

DeleteDocument deletes a document from OpenSearch

func (c *Client) DeleteIndex(ctx context.Context, indexName string) error

DeleteIndex deletes an index

func (c *Client) GetClient() *opensearchapi.Client

GetClient returns the OpenSearch client

func (c *Client) Health(ctx context.Context) (string, error)

Health checks cluster health

func (c *Client) IndexDocument(ctx context.Context, indexName string, documentID string, document any) error

IndexDocument indexes a document in OpenSearch

func (c *Client) IndexExists(ctx context.Context, indexName string) (bool, error)

IndexExists checks if an index exists

func (c *Client) Search(ctx context.Context, indexName, query string) (*opensearchapi.SearchResp, error)

Search performs a search in OpenSearch