dune

Apr 8, 2026

Changes in this version

type DuneClient

+ DeleteVisualization func(visualizationID int) (*models.DeleteVisualizationResponse, error)

+ GetVisualization func(visualizationID int) (*models.GetVisualizationResponse, error)

+ ListQueryVisualizations func(queryID, limit, offset int) (*models.ListVisualizationsResponse, error)

+ UpdateVisualization func(visualizationID int, req models.UpdateVisualizationRequest) (*models.UpdateVisualizationResponse, error)

Apr 1, 2026

Changes in this version

type DuneClient

+ CreateVisualization func(req models.CreateVisualizationRequest) (*models.CreateVisualizationResponse, error)

Mar 20, 2026

Changes in this version

type DuneClient

+ WhoAmI func() (*models.WhoAmIResponse, error)

Mar 6, 2026

Changes in this version

type DuneClient

+ SearchDatasetsByContractAddress func(req models.SearchDatasetsByContractAddressRequest) (*models.SearchDatasetsResponse, error)

Mar 4, 2026

Changes in this version

type DuneClient

+ SearchDatasets func(req models.SearchDatasetsRequest) (*models.SearchDatasetsResponse, error)

Mar 2, 2026

Changes in this version

type DuneClient

+ ArchiveQuery func(queryID int) (*models.UpdateQueryResponse, error)

+ CreateQuery func(req models.CreateQueryRequest) (*models.CreateQueryResponse, error)

+ GetQuery func(queryID int) (*models.GetQueryResponse, error)

+ UpdateQuery func(queryID int, req models.UpdateQueryRequest) (*models.UpdateQueryResponse, error)

Nov 18, 2025

Changes in this version

+ func NewPipeline(client DuneClient, ID string) *pipeline

type DuneClient

+ ClearTable func(namespace, tableName string) (*models.UploadsClearResponse, error)

+ ClearUpload func(namespace, tableName string) (*models.UploadsClearResponse, error)

+ CreateTable func(req models.UploadsCreateRequest) (*models.UploadsCreateResponse, error)

+ CreateUpload func(req models.UploadsCreateRequest) (*models.UploadsCreateResponse, error)

+ DeleteTable func(namespace, tableName string) (*models.UploadsDeleteResponse, error)

+ DeleteUpload func(namespace, tableName string) (*models.UploadsDeleteResponse, error)

+ GetDataset func(slug string) (*models.DatasetResponse, error)

+ GetUsage func() (*models.UsageResponse, error)

+ GetUsageForDates func(startDate, endDate string) (*models.UsageResponse, error)

+ InsertIntoUpload func(namespace, tableName, data, contentType string) (*models.UploadsInsertResponse, error)

+ InsertTable func(namespace, tableName, data, contentType string) (*models.UploadsInsertResponse, error)

+ ListDatasets func(limit, offset int, ownerHandle, datasetType string) (*models.ListDatasetsResponse, error)

+ ListTables func(limit, offset int) (*models.UploadsListResponse, error)

+ ListUploads func(limit, offset int) (*models.UploadsListResponse, error)

+ PipelineStatus func(pipelineExecutionID string) (*models.PipelineStatusResponse, error)

+ QueryPipelineExecute func(queryID string, performance string) (*models.PipelineExecuteResponse, error)

+ RunSQL func(sql string, performance string) (Execution, error)

+ SQLExecute func(sql string, performance string) (*models.ExecuteResponse, error)

+ UploadCSV func(req models.UploadsCSVRequest) (*models.UploadsCSVResponse, error)

+ UploadCSVDeprecated func(req models.UploadsCSVRequest) (*models.UploadsCSVResponse, error)

+ type Pipeline interface

+ GetID func() string

+ GetStatus func() (*models.PipelineStatusResponse, error)

May 6, 2024

Changes in this version

+ var ErrorReqUnsuccessful = errors.New("request was not successful")

+ var ErrorRetriesExhausted = errors.New("retries have been exhausted")

+ func NewDuneClient(env *config.Env) *duneClient

+ func NewExecution(client DuneClient, ID string) *execution

+ type DuneClient interface

+ QueryCancel func(executionID string) error

+ QueryExecute func(queryID int, queryParameters map[string]any) (*models.ExecuteResponse, error)

+ QueryResults func(executionID string) (*models.ResultsResponse, error)

+ QueryResultsByQueryID func(queryID string) (*models.ResultsResponse, error)

+ QueryResultsCSV func(executionID string) (io.Reader, error)

+ QueryResultsCSVByQueryID func(queryID string) (io.Reader, error)

+ QueryResultsV2 func(executionID string, options models.ResultOptions) (*models.ResultsResponse, error)

+ QueryStatus func(executionID string) (*models.StatusResponse, error)

+ ResultsByQueryID func(queryID string, options models.ResultOptions) (*models.ResultsResponse, error)

+ RunQuery func(queryID int, queryParameters map[string]any) (Execution, error)

+ RunQueryGetRows func(queryID int, queryParameters map[string]any) ([]map[string]any, error)

+ type ErrorResponse struct

+ Error string

+ type Execution interface

+ Cancel func() error

+ GetID func() string

+ GetResults func() (*models.ResultsResponse, error)

+ GetResultsCSV func() (io.Reader, error)

+ GetResultsV2 func(options models.ResultOptions) (*models.ResultsResponse, error)

+ GetStatus func() (*models.StatusResponse, error)

+ WaitGetResults func(pollInterval time.Duration, maxRetries int) (*models.ResultsResponse, error)