Versions in this module Expand all Collapse all v0 v0.10.0 Jul 23, 2026 Changes in this version + func Bool(b bool) *bool + func Float32(f float32) *float32 + func Float64(f float64) *float64 + func Int(i int) *int + func Int64(i int64) *int64 + func Pointer[T any](v T) *T + func String(s string) *string + type ACL struct + Teams *Teams + func (s *ACL) Get(ctx context.Context, product components.ProductsCore, id string, ...) (*operations.GetProductsGroupsACLByProductAndIDResponse, error) + type Auth struct + Tokens *Tokens + type Branches struct + func (s *Branches) Get(ctx context.Context, opts ...operations.Option) (*operations.GetVersionCurrentBranchResponse, error) + func (s *Branches) List(ctx context.Context, opts ...operations.Option) (*operations.GetVersionBranchResponse, error) + type Captures struct + func (s *Captures) Create(ctx context.Context, request components.CaptureParamsReq, ...) (*operations.CreateSystemCaptureResponse, error) + type Collectors struct + func (s *Collectors) Create(ctx context.Context, request components.SavedJob, opts ...operations.Option) (*operations.CreateSavedJobResponse, error) + func (s *Collectors) Delete(ctx context.Context, id string, opts ...operations.Option) (*operations.DeleteSavedJobByIDResponse, error) + func (s *Collectors) Get(ctx context.Context, id string, opts ...operations.Option) (*operations.GetSavedJobByIDResponse, error) + func (s *Collectors) List(ctx context.Context, collectorType *components.CollectorType, offset *int64, ...) (*operations.GetSavedJobResponse, error) + func (s *Collectors) Update(ctx context.Context, id string, savedJob components.SavedJob, ...) (*operations.UpdateSavedJobByIDResponse, error) + type Commits struct + Files *Files + func (s *Commits) Create(ctx context.Context, request components.GitCommitBody, ...) (*operations.CreateVersionCommitResponse, error) + func (s *Commits) Diff(ctx context.Context, commit *string, filename *string, diffLineLimit *int64, ...) (*operations.GetVersionDiffResponse, error) + func (s *Commits) Get(ctx context.Context, commit *string, filename *string, diffLineLimit *int64, ...) (*operations.GetVersionShowResponse, error) + func (s *Commits) List(ctx context.Context, count *int64, offset *int64, limit *int64, ...) (*operations.GetVersionResponse, error) + func (s *Commits) Push(ctx context.Context, opts ...operations.Option) (*operations.CreateVersionPushResponse, error) + func (s *Commits) Revert(ctx context.Context, request components.GitRevertParams, ...) (*operations.CreateVersionRevertResponse, error) + func (s *Commits) Undo(ctx context.Context, opts ...operations.Option) (*operations.CreateVersionUndoResponse, error) + type ConfigsVersions struct + func (s *ConfigsVersions) Get(ctx context.Context, product components.ProductsCore, id string, ...) (*operations.GetProductsGroupsConfigVersionByProductAndIDResponse, error) + type Cribl struct + func (s *Cribl) List(ctx context.Context, opts ...operations.Option) (*operations.GetSystemSettingsConfResponse, error) + func (s *Cribl) Update(ctx context.Context, request components.SystemSettingsConfUpdate, ...) (*operations.UpdateSystemSettingsConfResponse, error) + type CriblControlPlane struct + Auth *Auth + Collectors *Collectors + DatabaseConnections *DatabaseConnections + Destinations *Destinations + Functions *Functions + Groups *Groups + Health *Health + Lakes *Lakes + Nodes *Nodes + Packs *Packs + Pipelines *Pipelines + Routes *Routes + SDKVersion string + Sources *Sources + System *System + Versions *Versions + func New(serverURL string, opts ...SDKOption) *CriblControlPlane + type DatabaseConnections struct + func (s *DatabaseConnections) Create(ctx context.Context, request components.DatabaseConnectionConfig, ...) (*operations.CreateDatabaseConnectionConfigResponse, error) + func (s *DatabaseConnections) Delete(ctx context.Context, id string, opts ...operations.Option) (*operations.DeleteDatabaseConnectionConfigByIDResponse, error) + func (s *DatabaseConnections) Get(ctx context.Context, id string, opts ...operations.Option) (*operations.GetDatabaseConnectionConfigByIDResponse, error) + func (s *DatabaseConnections) List(ctx context.Context, databaseType *components.DatabaseConnectionType, ...) (*operations.GetDatabaseConnectionConfigResponse, error) + func (s *DatabaseConnections) Update(ctx context.Context, id string, ...) (*operations.UpdateDatabaseConnectionConfigByIDResponse, error) + type Datasets struct + func (s *Datasets) Create(ctx context.Context, lakeID string, ...) (*operations.CreateCriblLakeDatasetByLakeIDResponse, error) + func (s *Datasets) Delete(ctx context.Context, lakeID string, id string, opts ...operations.Option) (*operations.DeleteCriblLakeDatasetByLakeIDAndIDResponse, error) + func (s *Datasets) Get(ctx context.Context, lakeID string, id string, includeMetrics *bool, ...) (*operations.GetCriblLakeDatasetByLakeIDAndIDResponse, error) + func (s *Datasets) List(ctx context.Context, request operations.GetCriblLakeDatasetByLakeIDRequest, ...) (*operations.GetCriblLakeDatasetByLakeIDResponse, error) + func (s *Datasets) Update(ctx context.Context, lakeID string, id string, ...) (*operations.UpdateCriblLakeDatasetByLakeIDAndIDResponse, error) + type Destinations struct + Pq *DestinationsPq + Samples *Samples + Statuses *DestinationsStatuses + func (s *Destinations) Create(ctx context.Context, request operations.CreateOutputRequest, ...) (*operations.CreateOutputResponse, error) + func (s *Destinations) Delete(ctx context.Context, id string, opts ...operations.Option) (*operations.DeleteOutputByIDResponse, error) + func (s *Destinations) Get(ctx context.Context, id string, opts ...operations.Option) (*operations.GetOutputByIDResponse, error) + func (s *Destinations) List(ctx context.Context, type_ *components.DestinationType, offset *int64, ...) (*operations.ListOutputResponse, error) + func (s *Destinations) Update(ctx context.Context, id string, output components.Output, ...) (*operations.UpdateOutputByIDResponse, error) + type DestinationsPq struct + func (s *DestinationsPq) Clear(ctx context.Context, id string, opts ...operations.Option) (*operations.DeleteOutputPqByIDResponse, error) + func (s *DestinationsPq) Get(ctx context.Context, id string, opts ...operations.Option) (*operations.GetOutputPqByIDResponse, error) + type DestinationsStatuses struct + func (s *DestinationsStatuses) Get(ctx context.Context, id string, metrics *bool, type_ *bool, ...) (*operations.GetOutputStatusByIDResponse, error) + func (s *DestinationsStatuses) List(ctx context.Context, metrics *bool, type_ *bool, offset *int64, limit *int64, ...) (*operations.GetOutputStatusResponse, error) + type Files struct + func (s *Files) Count(ctx context.Context, commit *string, opts ...operations.Option) (*operations.GetVersionCountResponse, error) + func (s *Files) List(ctx context.Context, commit *string, opts ...operations.Option) (*operations.GetVersionFilesResponse, error) + type Functions struct + func (s *Functions) Get(ctx context.Context, id string, opts ...operations.Option) (*operations.GetFunctionsByIDResponse, error) + func (s *Functions) List(ctx context.Context, showHidden *bool, offset *int64, limit *int64, ...) (*operations.GetFunctionsResponse, error) + type Groups struct + ACL *ACL + Configs *GroupsConfigs + func (s *Groups) Create(ctx context.Context, product components.ProductsCore, ...) (*operations.CreateProductsGroupsByProductResponse, error) + func (s *Groups) Delete(ctx context.Context, product components.ProductsCore, id string, ...) (*operations.DeleteProductsGroupsByProductAndIDResponse, error) + func (s *Groups) Deploy(ctx context.Context, product components.ProductsCore, id string, ...) (*operations.UpdateProductsGroupsDeployByProductAndIDResponse, error) + func (s *Groups) Get(ctx context.Context, product components.ProductsCore, id string, ...) (*operations.GetProductsGroupsByProductAndIDResponse, error) + func (s *Groups) List(ctx context.Context, product components.ProductsCore, fields *string, ...) (*operations.GetProductsGroupsByProductResponse, error) + func (s *Groups) Update(ctx context.Context, product components.ProductsCore, id string, ...) (*operations.UpdateProductsGroupsByProductAndIDResponse, error) + type GroupsConfigs struct + Versions *ConfigsVersions + type HTTPClient interface + Do func(req *http.Request) (*http.Response, error) + type Health struct + func (s *Health) Get(ctx context.Context, opts ...operations.Option) (*operations.GetHealthResponse, error) + type HecTokens struct + func (s *HecTokens) Create(ctx context.Context, id string, ...) (*operations.CreateInputHecTokenByIDResponse, error) + func (s *HecTokens) Update(ctx context.Context, id string, token string, ...) (*operations.UpdateInputHecTokenByIDAndTokenResponse, error) + type Lakes struct + Datasets *Datasets + type Nodes struct + Summaries *Summaries + func (s *Nodes) Count(ctx context.Context, product components.ProductsCore, filterExp *string, ...) (*operations.GetProductsSummaryWorkersByProductResponse, error) + func (s *Nodes) Get(ctx context.Context, product components.ProductsCore, id string, ...) (*operations.GetProductsWorkersByProductAndIDResponse, error) + func (s *Nodes) List(ctx context.Context, request operations.GetProductsWorkersByProductRequest, ...) (*operations.GetProductsWorkersByProductResponse, error) + func (s *Nodes) Restart(ctx context.Context, product components.ProductsCore, ...) (*operations.UpdateProductsWorkersRestartByProductResponse, error) + type Packs struct + Destinations *PacksDestinations + Pipelines *PacksPipelines + Routes *PacksRoutes + Sources *PacksSources + func (s *Packs) Delete(ctx context.Context, id string, opts ...operations.Option) (*operations.DeletePacksByIDResponse, error) + func (s *Packs) Get(ctx context.Context, id string, opts ...operations.Option) (*operations.GetPacksByIDResponse, error) + func (s *Packs) Install(ctx context.Context, request components.PackRequestBodyUnion, ...) (*operations.CreatePacksResponse, error) + func (s *Packs) List(ctx context.Context, with *string, offset *int64, limit *int64, ...) (*operations.GetPacksResponse, error) + func (s *Packs) Update(ctx context.Context, id string, ...) (*operations.UpdatePacksByIDResponse, error) + func (s *Packs) Upload(ctx context.Context, filename string, requestBody any, ...) (*operations.UpdatePacksResponse, error) + type PacksDestinations struct + Pq *PacksDestinationsPq + Samples *PacksSamples + Statuses *PacksDestinationsStatuses + func (s *PacksDestinations) Create(ctx context.Context, pack string, ...) (*operations.CreateOutputSystemByPackResponse, error) + func (s *PacksDestinations) Delete(ctx context.Context, id string, pack string, opts ...operations.Option) (*operations.DeleteOutputSystemByPackAndIDResponse, error) + func (s *PacksDestinations) Get(ctx context.Context, id string, pack string, opts ...operations.Option) (*operations.GetOutputSystemByPackAndIDResponse, error) + func (s *PacksDestinations) List(ctx context.Context, pack string, type_ *components.DestinationType, ...) (*operations.GetOutputSystemByPackResponse, error) + func (s *PacksDestinations) Update(ctx context.Context, id string, pack string, output components.Output, ...) (*operations.UpdateOutputSystemByPackAndIDResponse, error) + type PacksDestinationsPq struct + func (s *PacksDestinationsPq) Clear(ctx context.Context, id string, pack string, opts ...operations.Option) (*operations.DeleteOutputSystemPqByPackAndIDResponse, error) + func (s *PacksDestinationsPq) Get(ctx context.Context, id string, pack string, opts ...operations.Option) (*operations.GetOutputSystemPqByPackAndIDResponse, error) + type PacksDestinationsStatuses struct + func (s *PacksDestinationsStatuses) Get(ctx context.Context, id string, pack string, metrics *bool, type_ *bool, ...) (*operations.GetOutputStatusSystemOutputsByPackAndIDResponse, error) + func (s *PacksDestinationsStatuses) List(ctx context.Context, ...) (*operations.GetOutputStatusSystemOutputsByPackResponse, error) + type PacksHecTokens struct + func (s *PacksHecTokens) Create(ctx context.Context, id string, pack string, ...) (*operations.CreateInputSystemHecTokenByPackAndIDResponse, error) + func (s *PacksHecTokens) Update(ctx context.Context, id string, token string, pack string, ...) (*operations.UpdateInputSystemHecTokenByPackAndIDAndTokenResponse, error) + type PacksPipelines struct + func (s *PacksPipelines) Create(ctx context.Context, pack string, pipeline components.PipelineInput, ...) (*operations.CreatePipelinesByPackResponse, error) + func (s *PacksPipelines) Delete(ctx context.Context, id string, pack string, opts ...operations.Option) (*operations.DeletePipelinesByPackAndIDResponse, error) + func (s *PacksPipelines) Get(ctx context.Context, id string, pack string, opts ...operations.Option) (*operations.GetPipelinesByPackAndIDResponse, error) + func (s *PacksPipelines) List(ctx context.Context, pack string, offset *int64, limit *int64, ...) (*operations.GetPipelinesByPackResponse, error) + func (s *PacksPipelines) Update(ctx context.Context, id string, pack string, pipeline components.PipelineInput, ...) (*operations.UpdatePipelinesByPackAndIDResponse, error) + type PacksRoutes struct + func (s *PacksRoutes) Append(ctx context.Context, id string, pack string, ...) (*operations.CreateRoutesAppendByPackAndIDResponse, error) + func (s *PacksRoutes) Get(ctx context.Context, id string, pack string, opts ...operations.Option) (*operations.GetRoutesByPackAndIDResponse, error) + func (s *PacksRoutes) List(ctx context.Context, pack string, opts ...operations.Option) (*operations.GetRoutesByPackResponse, error) + func (s *PacksRoutes) Update(ctx context.Context, id string, pack string, ...) (*operations.UpdateRoutesByPackAndIDResponse, error) + type PacksSamples struct + func (s *PacksSamples) Create(ctx context.Context, id string, pack string, ...) (*operations.CreateOutputSystemTestByPackAndIDResponse, error) + func (s *PacksSamples) Get(ctx context.Context, id string, pack string, opts ...operations.Option) (*operations.GetOutputSystemSamplesByPackAndIDResponse, error) + type PacksSources struct + HecTokens *PacksHecTokens + Pq *PacksSourcesPq + Statuses *PacksSourcesStatuses + func (s *PacksSources) Create(ctx context.Context, pack string, ...) (*operations.CreateInputSystemByPackResponse, error) + func (s *PacksSources) Delete(ctx context.Context, id string, pack string, opts ...operations.Option) (*operations.DeleteInputSystemByPackAndIDResponse, error) + func (s *PacksSources) Get(ctx context.Context, id string, pack string, opts ...operations.Option) (*operations.GetInputSystemByPackAndIDResponse, error) + func (s *PacksSources) List(ctx context.Context, pack string, type_ []string, offset *int64, limit *int64, ...) (*operations.GetInputSystemByPackResponse, error) + func (s *PacksSources) Update(ctx context.Context, id string, pack string, input components.Input, ...) (*operations.UpdateInputSystemByPackAndIDResponse, error) + type PacksSourcesPq struct + func (s *PacksSourcesPq) Clear(ctx context.Context, id string, pack string, opts ...operations.Option) (*operations.DeleteInputSystemPqByPackAndIDResponse, error) + func (s *PacksSourcesPq) Get(ctx context.Context, id string, pack string, opts ...operations.Option) (*operations.GetInputSystemPqByPackAndIDResponse, error) + type PacksSourcesStatuses struct + func (s *PacksSourcesStatuses) Get(ctx context.Context, id string, pack string, metrics *bool, type_ *bool, ...) (*operations.GetInputStatusSystemInputsByPackAndIDResponse, error) + func (s *PacksSourcesStatuses) List(ctx context.Context, ...) (*operations.GetInputStatusSystemInputsByPackResponse, error) + type Pipelines struct + func (s *Pipelines) Create(ctx context.Context, request components.PipelineInput, ...) (*operations.CreatePipelinesResponse, error) + func (s *Pipelines) Delete(ctx context.Context, id string, opts ...operations.Option) (*operations.DeletePipelinesByIDResponse, error) + func (s *Pipelines) Get(ctx context.Context, id string, opts ...operations.Option) (*operations.GetPipelinesByIDResponse, error) + func (s *Pipelines) List(ctx context.Context, offset *int64, limit *int64, opts ...operations.Option) (*operations.GetPipelinesResponse, error) + func (s *Pipelines) Update(ctx context.Context, id string, pipeline components.PipelineInput, ...) (*operations.UpdatePipelinesByIDResponse, error) + type Routes struct + func (s *Routes) Append(ctx context.Context, id string, requestBody []components.RouteConfInput, ...) (*operations.CreateRoutesAppendByIDResponse, error) + func (s *Routes) Get(ctx context.Context, id string, opts ...operations.Option) (*operations.GetRoutesByIDResponse, error) + func (s *Routes) List(ctx context.Context, opts ...operations.Option) (*operations.GetRoutesResponse, error) + func (s *Routes) Update(ctx context.Context, id string, routesInput components.RoutesInput, ...) (*operations.UpdateRoutesByIDResponse, error) + type SDKOption func(*CriblControlPlane) + func WithClient(client HTTPClient) SDKOption + func WithRetryConfig(retryConfig retry.Config) SDKOption + func WithSecurity(security components.Security) SDKOption + func WithSecuritySource(security func(context.Context) (components.Security, error)) SDKOption + func WithServerURL(serverURL string) SDKOption + func WithTemplatedServerURL(serverURL string, params map[string]string) SDKOption + func WithTimeout(timeout time.Duration) SDKOption + type Samples struct + func (s *Samples) Create(ctx context.Context, id string, outputTestRequest components.OutputTestRequest, ...) (*operations.CreateOutputTestByIDResponse, error) + func (s *Samples) Get(ctx context.Context, id string, opts ...operations.Option) (*operations.GetOutputSamplesByIDResponse, error) + type Settings struct + Cribl *Cribl + func (s *Settings) Restart(ctx context.Context, opts ...operations.Option) (*operations.CreateSystemSettingsRestartResponse, error) + type Sources struct + HecTokens *HecTokens + Pq *SourcesPq + Statuses *SourcesStatuses + func (s *Sources) Create(ctx context.Context, request operations.CreateInputRequest, ...) (*operations.CreateInputResponse, error) + func (s *Sources) Delete(ctx context.Context, id string, opts ...operations.Option) (*operations.DeleteInputByIDResponse, error) + func (s *Sources) Get(ctx context.Context, id string, opts ...operations.Option) (*operations.GetInputByIDResponse, error) + func (s *Sources) List(ctx context.Context, type_ []string, offset *int64, limit *int64, ...) (*operations.ListInputResponse, error) + func (s *Sources) Update(ctx context.Context, id string, input components.Input, ...) (*operations.UpdateInputByIDResponse, error) + type SourcesPq struct + func (s *SourcesPq) Clear(ctx context.Context, id string, opts ...operations.Option) (*operations.DeleteInputPqByIDResponse, error) + func (s *SourcesPq) Get(ctx context.Context, id string, opts ...operations.Option) (*operations.GetInputPqByIDResponse, error) + type SourcesStatuses struct + func (s *SourcesStatuses) Get(ctx context.Context, id string, metrics *bool, type_ *bool, ...) (*operations.GetInputStatusByIDResponse, error) + func (s *SourcesStatuses) List(ctx context.Context, metrics *bool, type_ *bool, offset *int64, limit *int64, ...) (*operations.GetInputStatusResponse, error) + type Summaries struct + func (s *Summaries) Get(ctx context.Context, product components.ProductsBase, offset *int64, ...) (*operations.GetProductsSummaryByProductResponse, error) + type System struct + Captures *Captures + Settings *Settings + type Teams struct + func (s *Teams) Get(ctx context.Context, product components.ProductsCore, id string, ...) (*operations.GetProductsGroupsACLTeamsByProductAndIDResponse, error) + type Tokens struct + func (s *Tokens) Get(ctx context.Context, request components.LoginInfo, opts ...operations.Option) (*operations.CreateAuthLoginResponse, error) + type Versions struct + Branches *Branches + Commits *Commits + Configs *VersionsConfigs + Statuses *VersionsStatuses + type VersionsConfigs struct + func (s *VersionsConfigs) Get(ctx context.Context, opts ...operations.Option) (*operations.GetVersionInfoResponse, error) + type VersionsStatuses struct + func (s *VersionsStatuses) Get(ctx context.Context, opts ...operations.Option) (*operations.GetVersionStatusResponse, error) v0.10.0-rc.3 Jul 23, 2026
Go to main page