Apr 30, 2025
Ingestion API client
This client is new in v4 of the Go API clients.
The Ingestion API client is part of the algoliasearch-client-go package.
To install it, run:
Copy
1
go get github.com/algolia/algoliasearch-client-go
To use the Ingestion client, add this import to your files:
Copy
1
import "github.com/algolia/algoliasearch-client-go/v4/algolia/ingestion"
To create an instance of the client:
Copy
1
2
3
4
5
client, err := ingestion.NewClient("ALGOLIA_APPLICATION_ID", "ALGOLIA_API_KEY", ingestion.US)
if err != nil {
// The client can fail to initialize if you pass an invalid parameter.
panic(err)
}
Make sure to use the region that matches your Algolia application’s analytics region:
ingestion.US for the United States or ingestion.EU for Europe.
You can check your analytics region in the Infrastructure > Analytics section of the Algolia dashboard.
List of methods
Each method makes one request to the Ingestion API.
Tasks
| client.Push | Push records by indexName |
| client.ListTasks | List tasks |
| client.CreateTask | Create a task |
| client.SearchTasks | Search for tasks |
| client.GetTask | Retrieve a task |
| client.UpdateTask | Update a task |
| client.DeleteTask | Delete a task |
| client.RunTask | Run a task |
| client.PushTask | Push records by taskID |
| client.EnableTask | Enable a task |
| client.DisableTask | Disable a task |
| client.ListTasksV1 | List tasks V1 |
| client.CreateTaskV1 | Create a task V1 |
| client.SearchTasksV1 | Search for tasks V1 |
| client.GetTaskV1 | Retrieve a task V1 |
| client.UpdateTaskV1 | Update a task V1 |
| client.DeleteTaskV1 | Delete a task |
| client.RunTaskV1 | Run a task V1 |
| client.EnableTaskV1 | Enable a task V1 |
| client.DisableTaskV1 | Disable a task V1 |
Authentications
| client.ListAuthentications | List authentication resources |
| client.CreateAuthentication | Create an authentication resource |
| client.SearchAuthentications | Search for authentication resources |
| client.GetAuthentication | Retrieve an authentication resource |
| client.UpdateAuthentication | Update an authentication resource |
| client.DeleteAuthentication | Delete an authentication resource |
Destinations
| client.ListDestinations | List destinations |
| client.CreateDestination | Create a destination |
| client.SearchDestinations | Search for destinations |
| client.GetDestination | Retrieve a destination |
| client.UpdateDestination | Update a destination |
| client.DeleteDestination | Delete a destination |
Sources
| client.ListSources | List sources |
| client.CreateSource | Create a source |
| client.ValidateSource | Validates a source payload |
| client.SearchSources | Search for sources |
| client.GetSource | Retrieve a source |
| client.UpdateSource | Update a source |
| client.DeleteSource | Delete a source |
| client.ValidateSourceBeforeUpdate | Validates an update of a source payload |
| client.TriggerDockerSourceDiscover | Trigger a stream-listing request |
| client.RunSource | Run all tasks linked to a source |
Transformations
| client.ListTransformations | List transformations |
| client.CreateTransformation | Create a transformation |
| client.TryTransformation | Try a transformation before creating it |
| client.SearchTransformations | Search for transformations |
| client.GetTransformation | Retrieve a transformation |
| client.UpdateTransformation | Update a transformation |
| client.DeleteTransformation | Delete a transformation |
| client.TryTransformationBeforeUpdate | Try a transformation before updating it |
Observability
| client.ListRuns | List task runs |
| client.GetRun | Retrieve a task run |
| client.ListEvents | List task run events |
| client.GetEvent | Retrieve a task run event |
Did you find this page helpful?