diff --git a/pkg/notifications/README.md b/pkg/notifications/README.md
index cd8e99d..c74dab7 100644
--- a/pkg/notifications/README.md
+++ b/pkg/notifications/README.md
@@ -76,10 +76,9 @@ type Level string
```go
const (
- LevelInfo Level = "info"
- LevelWarning Level = "warning"
- LevelError Level = "error"
- LevelCritical Level = "critical"
+ LevelInfo Level = "info"
+ LevelWarning Level = "warning"
+ LevelError Level = "error"
)
```
diff --git a/pkg/openSearch/openSearchClient/README.md b/pkg/openSearch/openSearchClient/README.md
index 2d935dd..63bf4b9 100644
--- a/pkg/openSearch/openSearchClient/README.md
+++ b/pkg/openSearch/openSearchClient/README.md
@@ -60,6 +60,7 @@ For further usage examples see ./client\_test.go.
- [func \(c \*Client\) AsyncDeleteByQuery\(indexName string, requestBody \[\]byte\) error](<#Client.AsyncDeleteByQuery>)
- [func \(c \*Client\) BulkUpdate\(indexName string, requestBody \[\]byte\) error](<#Client.BulkUpdate>)
- [func \(c \*Client\) Close\(\)](<#Client.Close>)
+ - [func \(c \*Client\) CompositeAggStream\(indexName string, requestBody \[\]byte, ctx context.Context\) \(io.Reader, error\)](<#Client.CompositeAggStream>)
- [func \(c \*Client\) Count\(indexName string, requestBody \[\]byte\) \(count int64, err error\)](<#Client.Count>)
- [func \(c \*Client\) DeleteByQuery\(indexName string, requestBody \[\]byte\) error](<#Client.DeleteByQuery>)
- [func \(c \*Client\) Search\(indexName string, requestBody \[\]byte\) \(responseBody \[\]byte, err error\)](<#Client.Search>)
@@ -155,7 +156,7 @@ NewOpenSearchProjectClient creates a new official OpenSearch client \(package gi
ctx is the context to use for the connection. config is the configuration for the client.
-## func [SerializeDocumentsForBulkUpdate]()
+## func [SerializeDocumentsForBulkUpdate]()
```go
func SerializeDocumentsForBulkUpdate[T any](indexName string, documents []T) ([]byte, error)
@@ -273,7 +274,7 @@ NewClient creates a new OpenSearch client.
openSearchProjectClient is the official OpenSearch client to wrap. Use NewOpenSearchProjectClient to create it. updateMaxRetries is the number of retries for update requests. updateRetryDelay is the delay between retries.
-### func \(\*Client\) [AsyncDeleteByQuery]()
+### func \(\*Client\) [AsyncDeleteByQuery]()
```go
func (c *Client) AsyncDeleteByQuery(indexName string, requestBody []byte) error
@@ -284,7 +285,7 @@ AsyncDeleteByQuery updates documents in the given index asynchronously. It does
indexName is the name of the index to delete from. requestBody is the request body to send to OpenSearch to identify the documents to be deleted.
-### func \(\*Client\) [BulkUpdate]()
+### func \(\*Client\) [BulkUpdate]()
```go
func (c *Client) BulkUpdate(indexName string, requestBody []byte) error
@@ -295,7 +296,7 @@ BulkUpdate performs a bulk update in the given index. It returns an error in cas
indexName is the name of the index to update. requestBody is the request body to send to OpenSearch specifying the bulk update.
-### func \(\*Client\) [Close]()
+### func \(\*Client\) [Close]()
```go
func (c *Client) Close()
@@ -303,6 +304,15 @@ func (c *Client) Close()
Close stops the underlying UpdateQueue allowing a graceful shutdown.
+
+### func \(\*Client\) [CompositeAggStream]()
+
+```go
+func (c *Client) CompositeAggStream(indexName string, requestBody []byte, ctx context.Context) (io.Reader, error)
+```
+
+
+
### func \(\*Client\) [Count]()
@@ -313,7 +323,7 @@ func (c *Client) Count(indexName string, requestBody []byte) (count int64, err e
-### func \(\*Client\) [DeleteByQuery]()
+### func \(\*Client\) [DeleteByQuery]()
```go
func (c *Client) DeleteByQuery(indexName string, requestBody []byte) error
@@ -344,7 +354,7 @@ func (c *Client) SearchStream(indexName string, requestBody []byte, scrollTimeou
-### func \(\*Client\) [Update]()
+### func \(\*Client\) [Update]()
```go
func (c *Client) Update(indexName string, requestBody []byte) (responseBody []byte, err error)
@@ -355,7 +365,7 @@ Update updates documents in the given index using UpdateQueue \(which is also pa
indexName is the name of the index to update. requestBody is the request body to send to OpenSearch specifying the update.
-## type [CountReq]()
+## type [CountReq]()
@@ -369,7 +379,7 @@ type CountReq struct {
```
-### func \(CountReq\) [GetRequest]()
+### func \(CountReq\) [GetRequest]()
```go
func (r CountReq) GetRequest() (*http.Request, error)
@@ -378,7 +388,7 @@ func (r CountReq) GetRequest() (*http.Request, error)
GetRequest returns the \*http.Request that gets executed by the client
-## type [CountResp]()
+## type [CountResp]()
@@ -390,7 +400,7 @@ type CountResp struct {
```
-### func \(CountResp\) [Inspect]()
+### func \(CountResp\) [Inspect]()
```go
func (r CountResp) Inspect() opensearchapi.Inspect
@@ -902,7 +912,7 @@ type SearchResponseHitsTotal struct {
```
-## type [ShardStats]()
+## type [ShardStats]()