Versions in this module Expand all Collapse all v0 v0.5.0 Mar 6, 2026 Changes in this version + var AllowedCatalogAuthTypeEnumValues = []CatalogAuthType + var AllowedPartitioningTypeEnumValues = []PartitioningType + var AllowedPartitioningUpdateTypeEnumValues = []PartitioningUpdateType + var AllowedUserTypeEnumValues = []UserType + var JsonCheck = regexp.MustCompile(`(?i:(?:application|text)/(?:[^;]+\+)?json)`) + var XmlCheck = regexp.MustCompile(`(?i:(?:application|text)/(?:[^;]+\+)?xml)`) + func CacheExpires(r *http.Response) time.Time + func IsNil(i interface{}) bool + func NewConfiguration() *config.Configuration + func PtrBool(v bool) *bool + func PtrFloat32(v float32) *float32 + func PtrFloat64(v float64) *float64 + func PtrInt(v int) *int + func PtrInt32(v int32) *int32 + func PtrInt64(v int64) *int64 + func PtrString(v string) *string + func PtrTime(v time.Time) *time.Time + type APIClient struct + DefaultAPI DefaultAPI + func NewAPIClient(opts ...config.ConfigurationOption) (*APIClient, error) + func (c *APIClient) GetConfig() *config.Configuration + type APIResponse struct + Message string + Method string + Operation string + Payload []byte + RequestURL string + func NewAPIResponse(r *http.Response) *APIResponse + func NewAPIResponseWithError(errorMessage string) *APIResponse + type ApiCreateIntakeRequest struct + ApiService DefaultAPI + func (r ApiCreateIntakeRequest) CreateIntakePayload(createIntakePayload CreateIntakePayload) ApiCreateIntakeRequest + func (r ApiCreateIntakeRequest) Execute() (*IntakeResponse, error) + type ApiCreateIntakeRunnerRequest struct + ApiService DefaultAPI + func (r ApiCreateIntakeRunnerRequest) CreateIntakeRunnerPayload(createIntakeRunnerPayload CreateIntakeRunnerPayload) ApiCreateIntakeRunnerRequest + func (r ApiCreateIntakeRunnerRequest) Execute() (*IntakeRunnerResponse, error) + type ApiCreateIntakeUserRequest struct + ApiService DefaultAPI + func (r ApiCreateIntakeUserRequest) CreateIntakeUserPayload(createIntakeUserPayload CreateIntakeUserPayload) ApiCreateIntakeUserRequest + func (r ApiCreateIntakeUserRequest) Execute() (*IntakeUserResponse, error) + type ApiDeleteIntakeRequest struct + ApiService DefaultAPI + func (r ApiDeleteIntakeRequest) Execute() error + func (r ApiDeleteIntakeRequest) Force(force bool) ApiDeleteIntakeRequest + type ApiDeleteIntakeRunnerRequest struct + ApiService DefaultAPI + func (r ApiDeleteIntakeRunnerRequest) Execute() error + func (r ApiDeleteIntakeRunnerRequest) Force(force bool) ApiDeleteIntakeRunnerRequest + type ApiDeleteIntakeUserRequest struct + ApiService DefaultAPI + func (r ApiDeleteIntakeUserRequest) Execute() error + type ApiGetIntakeRequest struct + ApiService DefaultAPI + func (r ApiGetIntakeRequest) Execute() (*IntakeResponse, error) + type ApiGetIntakeRunnerRequest struct + ApiService DefaultAPI + func (r ApiGetIntakeRunnerRequest) Execute() (*IntakeRunnerResponse, error) + type ApiGetIntakeUserRequest struct + ApiService DefaultAPI + func (r ApiGetIntakeUserRequest) Execute() (*IntakeUserResponse, error) + type ApiListIntakeRunnersRequest struct + ApiService DefaultAPI + func (r ApiListIntakeRunnersRequest) Execute() (*ListIntakeRunnersResponse, error) + func (r ApiListIntakeRunnersRequest) PageSize(pageSize int32) ApiListIntakeRunnersRequest + func (r ApiListIntakeRunnersRequest) PageToken(pageToken string) ApiListIntakeRunnersRequest + type ApiListIntakeUsersRequest struct + ApiService DefaultAPI + func (r ApiListIntakeUsersRequest) Execute() (*ListIntakeUsersResponse, error) + func (r ApiListIntakeUsersRequest) PageSize(pageSize int32) ApiListIntakeUsersRequest + func (r ApiListIntakeUsersRequest) PageToken(pageToken string) ApiListIntakeUsersRequest + type ApiListIntakesRequest struct + ApiService DefaultAPI + func (r ApiListIntakesRequest) Execute() (*ListIntakesResponse, error) + func (r ApiListIntakesRequest) PageSize(pageSize int32) ApiListIntakesRequest + func (r ApiListIntakesRequest) PageToken(pageToken string) ApiListIntakesRequest + type ApiUpdateIntakeRequest struct + ApiService DefaultAPI + func (r ApiUpdateIntakeRequest) Execute() (*IntakeResponse, error) + func (r ApiUpdateIntakeRequest) UpdateIntakePayload(updateIntakePayload UpdateIntakePayload) ApiUpdateIntakeRequest + type ApiUpdateIntakeRunnerRequest struct + ApiService DefaultAPI + func (r ApiUpdateIntakeRunnerRequest) Execute() (*IntakeRunnerResponse, error) + func (r ApiUpdateIntakeRunnerRequest) UpdateIntakeRunnerPayload(updateIntakeRunnerPayload UpdateIntakeRunnerPayload) ApiUpdateIntakeRunnerRequest + type ApiUpdateIntakeUserRequest struct + ApiService DefaultAPI + func (r ApiUpdateIntakeUserRequest) Execute() (*IntakeUserResponse, error) + func (r ApiUpdateIntakeUserRequest) UpdateIntakeUserPayload(updateIntakeUserPayload UpdateIntakeUserPayload) ApiUpdateIntakeUserRequest + type CatalogAuth struct + Dremio *DremioAuth + Type CatalogAuthType + func NewCatalogAuth(types CatalogAuthType) *CatalogAuth + func NewCatalogAuthWithDefaults() *CatalogAuth + func (o *CatalogAuth) GetDremio() DremioAuth + func (o *CatalogAuth) GetDremioOk() (*DremioAuth, bool) + func (o *CatalogAuth) GetType() CatalogAuthType + func (o *CatalogAuth) GetTypeOk() (*CatalogAuthType, bool) + func (o *CatalogAuth) HasDremio() bool + func (o *CatalogAuth) SetDremio(v DremioAuth) + func (o *CatalogAuth) SetType(v CatalogAuthType) + func (o *CatalogAuth) UnmarshalJSON(data []byte) (err error) + func (o CatalogAuth) MarshalJSON() ([]byte, error) + func (o CatalogAuth) ToMap() (map[string]interface{}, error) + type CatalogAuthPatch struct + Dremio *DremioAuthPatch + Type *CatalogAuthType + func NewCatalogAuthPatch() *CatalogAuthPatch + func NewCatalogAuthPatchWithDefaults() *CatalogAuthPatch + func (o *CatalogAuthPatch) GetDremio() DremioAuthPatch + func (o *CatalogAuthPatch) GetDremioOk() (*DremioAuthPatch, bool) + func (o *CatalogAuthPatch) GetType() CatalogAuthType + func (o *CatalogAuthPatch) GetTypeOk() (*CatalogAuthType, bool) + func (o *CatalogAuthPatch) HasDremio() bool + func (o *CatalogAuthPatch) HasType() bool + func (o *CatalogAuthPatch) SetDremio(v DremioAuthPatch) + func (o *CatalogAuthPatch) SetType(v CatalogAuthType) + func (o CatalogAuthPatch) MarshalJSON() ([]byte, error) + func (o CatalogAuthPatch) ToMap() (map[string]interface{}, error) + type CatalogAuthType string + const CATALOGAUTHTYPE_DREMIO + const CATALOGAUTHTYPE_NONE + func NewCatalogAuthTypeFromValue(v string) (*CatalogAuthType, error) + func (v *CatalogAuthType) UnmarshalJSON(src []byte) error + func (v CatalogAuthType) IsValid() bool + func (v CatalogAuthType) Ptr() *CatalogAuthType + type ClientConfig struct + Java string + Librdkafka string + func NewClientConfig(java string, librdkafka string) *ClientConfig + func NewClientConfigWithDefaults() *ClientConfig + func (o *ClientConfig) GetJava() string + func (o *ClientConfig) GetJavaOk() (*string, bool) + func (o *ClientConfig) GetLibrdkafka() string + func (o *ClientConfig) GetLibrdkafkaOk() (*string, bool) + func (o *ClientConfig) SetJava(v string) + func (o *ClientConfig) SetLibrdkafka(v string) + func (o *ClientConfig) UnmarshalJSON(data []byte) (err error) + func (o ClientConfig) MarshalJSON() ([]byte, error) + func (o ClientConfig) ToMap() (map[string]interface{}, error) + type CreateIntakePayload struct + Catalog IntakeCatalog + Description *string + DisplayName string + IntakeRunnerId string + Labels map[string]string + func NewCreateIntakePayload(catalog IntakeCatalog, displayName string, intakeRunnerId string) *CreateIntakePayload + func NewCreateIntakePayloadWithDefaults() *CreateIntakePayload + func (o *CreateIntakePayload) GetCatalog() IntakeCatalog + func (o *CreateIntakePayload) GetCatalogOk() (*IntakeCatalog, bool) + func (o *CreateIntakePayload) GetDescription() string + func (o *CreateIntakePayload) GetDescriptionOk() (*string, bool) + func (o *CreateIntakePayload) GetDisplayName() string + func (o *CreateIntakePayload) GetDisplayNameOk() (*string, bool) + func (o *CreateIntakePayload) GetIntakeRunnerId() string + func (o *CreateIntakePayload) GetIntakeRunnerIdOk() (*string, bool) + func (o *CreateIntakePayload) GetLabels() map[string]string + func (o *CreateIntakePayload) GetLabelsOk() (*map[string]string, bool) + func (o *CreateIntakePayload) HasDescription() bool + func (o *CreateIntakePayload) HasLabels() bool + func (o *CreateIntakePayload) SetCatalog(v IntakeCatalog) + func (o *CreateIntakePayload) SetDescription(v string) + func (o *CreateIntakePayload) SetDisplayName(v string) + func (o *CreateIntakePayload) SetIntakeRunnerId(v string) + func (o *CreateIntakePayload) SetLabels(v map[string]string) + func (o *CreateIntakePayload) UnmarshalJSON(data []byte) (err error) + func (o CreateIntakePayload) MarshalJSON() ([]byte, error) + func (o CreateIntakePayload) ToMap() (map[string]interface{}, error) + type CreateIntakeRunnerPayload struct + Description *string + DisplayName string + Labels map[string]string + MaxMessageSizeKiB int32 + MaxMessagesPerHour int32 + func NewCreateIntakeRunnerPayload(displayName string, maxMessageSizeKiB int32, maxMessagesPerHour int32) *CreateIntakeRunnerPayload + func NewCreateIntakeRunnerPayloadWithDefaults() *CreateIntakeRunnerPayload + func (o *CreateIntakeRunnerPayload) GetDescription() string + func (o *CreateIntakeRunnerPayload) GetDescriptionOk() (*string, bool) + func (o *CreateIntakeRunnerPayload) GetDisplayName() string + func (o *CreateIntakeRunnerPayload) GetDisplayNameOk() (*string, bool) + func (o *CreateIntakeRunnerPayload) GetLabels() map[string]string + func (o *CreateIntakeRunnerPayload) GetLabelsOk() (*map[string]string, bool) + func (o *CreateIntakeRunnerPayload) GetMaxMessageSizeKiB() int32 + func (o *CreateIntakeRunnerPayload) GetMaxMessageSizeKiBOk() (*int32, bool) + func (o *CreateIntakeRunnerPayload) GetMaxMessagesPerHour() int32 + func (o *CreateIntakeRunnerPayload) GetMaxMessagesPerHourOk() (*int32, bool) + func (o *CreateIntakeRunnerPayload) HasDescription() bool + func (o *CreateIntakeRunnerPayload) HasLabels() bool + func (o *CreateIntakeRunnerPayload) SetDescription(v string) + func (o *CreateIntakeRunnerPayload) SetDisplayName(v string) + func (o *CreateIntakeRunnerPayload) SetLabels(v map[string]string) + func (o *CreateIntakeRunnerPayload) SetMaxMessageSizeKiB(v int32) + func (o *CreateIntakeRunnerPayload) SetMaxMessagesPerHour(v int32) + func (o *CreateIntakeRunnerPayload) UnmarshalJSON(data []byte) (err error) + func (o CreateIntakeRunnerPayload) MarshalJSON() ([]byte, error) + func (o CreateIntakeRunnerPayload) ToMap() (map[string]interface{}, error) + type CreateIntakeUserPayload struct + Description *string + DisplayName string + Labels map[string]string + Password string + Type *UserType + func NewCreateIntakeUserPayload(displayName string, password string) *CreateIntakeUserPayload + func NewCreateIntakeUserPayloadWithDefaults() *CreateIntakeUserPayload + func (o *CreateIntakeUserPayload) GetDescription() string + func (o *CreateIntakeUserPayload) GetDescriptionOk() (*string, bool) + func (o *CreateIntakeUserPayload) GetDisplayName() string + func (o *CreateIntakeUserPayload) GetDisplayNameOk() (*string, bool) + func (o *CreateIntakeUserPayload) GetLabels() map[string]string + func (o *CreateIntakeUserPayload) GetLabelsOk() (*map[string]string, bool) + func (o *CreateIntakeUserPayload) GetPassword() string + func (o *CreateIntakeUserPayload) GetPasswordOk() (*string, bool) + func (o *CreateIntakeUserPayload) GetType() UserType + func (o *CreateIntakeUserPayload) GetTypeOk() (*UserType, bool) + func (o *CreateIntakeUserPayload) HasDescription() bool + func (o *CreateIntakeUserPayload) HasLabels() bool + func (o *CreateIntakeUserPayload) HasType() bool + func (o *CreateIntakeUserPayload) SetDescription(v string) + func (o *CreateIntakeUserPayload) SetDisplayName(v string) + func (o *CreateIntakeUserPayload) SetLabels(v map[string]string) + func (o *CreateIntakeUserPayload) SetPassword(v string) + func (o *CreateIntakeUserPayload) SetType(v UserType) + func (o *CreateIntakeUserPayload) UnmarshalJSON(data []byte) (err error) + func (o CreateIntakeUserPayload) MarshalJSON() ([]byte, error) + func (o CreateIntakeUserPayload) ToMap() (map[string]interface{}, error) + type DefaultAPI interface + CreateIntake func(ctx context.Context, projectId string, regionId string) ApiCreateIntakeRequest + CreateIntakeExecute func(r ApiCreateIntakeRequest) (*IntakeResponse, error) + CreateIntakeRunner func(ctx context.Context, projectId string, regionId string) ApiCreateIntakeRunnerRequest + CreateIntakeRunnerExecute func(r ApiCreateIntakeRunnerRequest) (*IntakeRunnerResponse, error) + CreateIntakeUser func(ctx context.Context, projectId string, regionId string, intakeId string) ApiCreateIntakeUserRequest + CreateIntakeUserExecute func(r ApiCreateIntakeUserRequest) (*IntakeUserResponse, error) + DeleteIntake func(ctx context.Context, projectId string, regionId string, intakeId string) ApiDeleteIntakeRequest + DeleteIntakeExecute func(r ApiDeleteIntakeRequest) error + DeleteIntakeRunner func(ctx context.Context, projectId string, regionId string, intakeRunnerId string) ApiDeleteIntakeRunnerRequest + DeleteIntakeRunnerExecute func(r ApiDeleteIntakeRunnerRequest) error + DeleteIntakeUser func(ctx context.Context, projectId string, regionId string, intakeId string, ...) ApiDeleteIntakeUserRequest + DeleteIntakeUserExecute func(r ApiDeleteIntakeUserRequest) error + GetIntake func(ctx context.Context, projectId string, regionId string, intakeId string) ApiGetIntakeRequest + GetIntakeExecute func(r ApiGetIntakeRequest) (*IntakeResponse, error) + GetIntakeRunner func(ctx context.Context, projectId string, regionId string, intakeRunnerId string) ApiGetIntakeRunnerRequest + GetIntakeRunnerExecute func(r ApiGetIntakeRunnerRequest) (*IntakeRunnerResponse, error) + GetIntakeUser func(ctx context.Context, projectId string, regionId string, intakeId string, ...) ApiGetIntakeUserRequest + GetIntakeUserExecute func(r ApiGetIntakeUserRequest) (*IntakeUserResponse, error) + ListIntakeRunners func(ctx context.Context, projectId string, regionId string) ApiListIntakeRunnersRequest + ListIntakeRunnersExecute func(r ApiListIntakeRunnersRequest) (*ListIntakeRunnersResponse, error) + ListIntakeUsers func(ctx context.Context, projectId string, regionId string, intakeId string) ApiListIntakeUsersRequest + ListIntakeUsersExecute func(r ApiListIntakeUsersRequest) (*ListIntakeUsersResponse, error) + ListIntakes func(ctx context.Context, projectId string, regionId string) ApiListIntakesRequest + ListIntakesExecute func(r ApiListIntakesRequest) (*ListIntakesResponse, error) + UpdateIntake func(ctx context.Context, projectId string, regionId string, intakeId string) ApiUpdateIntakeRequest + UpdateIntakeExecute func(r ApiUpdateIntakeRequest) (*IntakeResponse, error) + UpdateIntakeRunner func(ctx context.Context, projectId string, regionId string, intakeRunnerId string) ApiUpdateIntakeRunnerRequest + UpdateIntakeRunnerExecute func(r ApiUpdateIntakeRunnerRequest) (*IntakeRunnerResponse, error) + UpdateIntakeUser func(ctx context.Context, projectId string, regionId string, intakeId string, ...) ApiUpdateIntakeUserRequest + UpdateIntakeUserExecute func(r ApiUpdateIntakeUserRequest) (*IntakeUserResponse, error) + type DefaultAPIService service + func (a *DefaultAPIService) CreateIntake(ctx context.Context, projectId string, regionId string) ApiCreateIntakeRequest + func (a *DefaultAPIService) CreateIntakeExecute(r ApiCreateIntakeRequest) (*IntakeResponse, error) + func (a *DefaultAPIService) CreateIntakeRunner(ctx context.Context, projectId string, regionId string) ApiCreateIntakeRunnerRequest + func (a *DefaultAPIService) CreateIntakeRunnerExecute(r ApiCreateIntakeRunnerRequest) (*IntakeRunnerResponse, error) + func (a *DefaultAPIService) CreateIntakeUser(ctx context.Context, projectId string, regionId string, intakeId string) ApiCreateIntakeUserRequest + func (a *DefaultAPIService) CreateIntakeUserExecute(r ApiCreateIntakeUserRequest) (*IntakeUserResponse, error) + func (a *DefaultAPIService) DeleteIntake(ctx context.Context, projectId string, regionId string, intakeId string) ApiDeleteIntakeRequest + func (a *DefaultAPIService) DeleteIntakeExecute(r ApiDeleteIntakeRequest) error + func (a *DefaultAPIService) DeleteIntakeRunner(ctx context.Context, projectId string, regionId string, intakeRunnerId string) ApiDeleteIntakeRunnerRequest + func (a *DefaultAPIService) DeleteIntakeRunnerExecute(r ApiDeleteIntakeRunnerRequest) error + func (a *DefaultAPIService) DeleteIntakeUser(ctx context.Context, projectId string, regionId string, intakeId string, ...) ApiDeleteIntakeUserRequest + func (a *DefaultAPIService) DeleteIntakeUserExecute(r ApiDeleteIntakeUserRequest) error + func (a *DefaultAPIService) GetIntake(ctx context.Context, projectId string, regionId string, intakeId string) ApiGetIntakeRequest + func (a *DefaultAPIService) GetIntakeExecute(r ApiGetIntakeRequest) (*IntakeResponse, error) + func (a *DefaultAPIService) GetIntakeRunner(ctx context.Context, projectId string, regionId string, intakeRunnerId string) ApiGetIntakeRunnerRequest + func (a *DefaultAPIService) GetIntakeRunnerExecute(r ApiGetIntakeRunnerRequest) (*IntakeRunnerResponse, error) + func (a *DefaultAPIService) GetIntakeUser(ctx context.Context, projectId string, regionId string, intakeId string, ...) ApiGetIntakeUserRequest + func (a *DefaultAPIService) GetIntakeUserExecute(r ApiGetIntakeUserRequest) (*IntakeUserResponse, error) + func (a *DefaultAPIService) ListIntakeRunners(ctx context.Context, projectId string, regionId string) ApiListIntakeRunnersRequest + func (a *DefaultAPIService) ListIntakeRunnersExecute(r ApiListIntakeRunnersRequest) (*ListIntakeRunnersResponse, error) + func (a *DefaultAPIService) ListIntakeUsers(ctx context.Context, projectId string, regionId string, intakeId string) ApiListIntakeUsersRequest + func (a *DefaultAPIService) ListIntakeUsersExecute(r ApiListIntakeUsersRequest) (*ListIntakeUsersResponse, error) + func (a *DefaultAPIService) ListIntakes(ctx context.Context, projectId string, regionId string) ApiListIntakesRequest + func (a *DefaultAPIService) ListIntakesExecute(r ApiListIntakesRequest) (*ListIntakesResponse, error) + func (a *DefaultAPIService) UpdateIntake(ctx context.Context, projectId string, regionId string, intakeId string) ApiUpdateIntakeRequest + func (a *DefaultAPIService) UpdateIntakeExecute(r ApiUpdateIntakeRequest) (*IntakeResponse, error) + func (a *DefaultAPIService) UpdateIntakeRunner(ctx context.Context, projectId string, regionId string, intakeRunnerId string) ApiUpdateIntakeRunnerRequest + func (a *DefaultAPIService) UpdateIntakeRunnerExecute(r ApiUpdateIntakeRunnerRequest) (*IntakeRunnerResponse, error) + func (a *DefaultAPIService) UpdateIntakeUser(ctx context.Context, projectId string, regionId string, intakeId string, ...) ApiUpdateIntakeUserRequest + func (a *DefaultAPIService) UpdateIntakeUserExecute(r ApiUpdateIntakeUserRequest) (*IntakeUserResponse, error) + type DefaultAPIServiceMock struct + CreateIntakeExecuteMock *func(r ApiCreateIntakeRequest) (*IntakeResponse, error) + CreateIntakeRunnerExecuteMock *func(r ApiCreateIntakeRunnerRequest) (*IntakeRunnerResponse, error) + CreateIntakeUserExecuteMock *func(r ApiCreateIntakeUserRequest) (*IntakeUserResponse, error) + DeleteIntakeExecuteMock *func(r ApiDeleteIntakeRequest) error + DeleteIntakeRunnerExecuteMock *func(r ApiDeleteIntakeRunnerRequest) error + DeleteIntakeUserExecuteMock *func(r ApiDeleteIntakeUserRequest) error + GetIntakeExecuteMock *func(r ApiGetIntakeRequest) (*IntakeResponse, error) + GetIntakeRunnerExecuteMock *func(r ApiGetIntakeRunnerRequest) (*IntakeRunnerResponse, error) + GetIntakeUserExecuteMock *func(r ApiGetIntakeUserRequest) (*IntakeUserResponse, error) + ListIntakeRunnersExecuteMock *func(r ApiListIntakeRunnersRequest) (*ListIntakeRunnersResponse, error) + ListIntakeUsersExecuteMock *func(r ApiListIntakeUsersRequest) (*ListIntakeUsersResponse, error) + ListIntakesExecuteMock *func(r ApiListIntakesRequest) (*ListIntakesResponse, error) + UpdateIntakeExecuteMock *func(r ApiUpdateIntakeRequest) (*IntakeResponse, error) + UpdateIntakeRunnerExecuteMock *func(r ApiUpdateIntakeRunnerRequest) (*IntakeRunnerResponse, error) + UpdateIntakeUserExecuteMock *func(r ApiUpdateIntakeUserRequest) (*IntakeUserResponse, error) + func (a DefaultAPIServiceMock) CreateIntake(ctx context.Context, projectId string, regionId string) ApiCreateIntakeRequest + func (a DefaultAPIServiceMock) CreateIntakeExecute(r ApiCreateIntakeRequest) (*IntakeResponse, error) + func (a DefaultAPIServiceMock) CreateIntakeRunner(ctx context.Context, projectId string, regionId string) ApiCreateIntakeRunnerRequest + func (a DefaultAPIServiceMock) CreateIntakeRunnerExecute(r ApiCreateIntakeRunnerRequest) (*IntakeRunnerResponse, error) + func (a DefaultAPIServiceMock) CreateIntakeUser(ctx context.Context, projectId string, regionId string, intakeId string) ApiCreateIntakeUserRequest + func (a DefaultAPIServiceMock) CreateIntakeUserExecute(r ApiCreateIntakeUserRequest) (*IntakeUserResponse, error) + func (a DefaultAPIServiceMock) DeleteIntake(ctx context.Context, projectId string, regionId string, intakeId string) ApiDeleteIntakeRequest + func (a DefaultAPIServiceMock) DeleteIntakeExecute(r ApiDeleteIntakeRequest) error + func (a DefaultAPIServiceMock) DeleteIntakeRunner(ctx context.Context, projectId string, regionId string, intakeRunnerId string) ApiDeleteIntakeRunnerRequest + func (a DefaultAPIServiceMock) DeleteIntakeRunnerExecute(r ApiDeleteIntakeRunnerRequest) error + func (a DefaultAPIServiceMock) DeleteIntakeUser(ctx context.Context, projectId string, regionId string, intakeId string, ...) ApiDeleteIntakeUserRequest + func (a DefaultAPIServiceMock) DeleteIntakeUserExecute(r ApiDeleteIntakeUserRequest) error + func (a DefaultAPIServiceMock) GetIntake(ctx context.Context, projectId string, regionId string, intakeId string) ApiGetIntakeRequest + func (a DefaultAPIServiceMock) GetIntakeExecute(r ApiGetIntakeRequest) (*IntakeResponse, error) + func (a DefaultAPIServiceMock) GetIntakeRunner(ctx context.Context, projectId string, regionId string, intakeRunnerId string) ApiGetIntakeRunnerRequest + func (a DefaultAPIServiceMock) GetIntakeRunnerExecute(r ApiGetIntakeRunnerRequest) (*IntakeRunnerResponse, error) + func (a DefaultAPIServiceMock) GetIntakeUser(ctx context.Context, projectId string, regionId string, intakeId string, ...) ApiGetIntakeUserRequest + func (a DefaultAPIServiceMock) GetIntakeUserExecute(r ApiGetIntakeUserRequest) (*IntakeUserResponse, error) + func (a DefaultAPIServiceMock) ListIntakeRunners(ctx context.Context, projectId string, regionId string) ApiListIntakeRunnersRequest + func (a DefaultAPIServiceMock) ListIntakeRunnersExecute(r ApiListIntakeRunnersRequest) (*ListIntakeRunnersResponse, error) + func (a DefaultAPIServiceMock) ListIntakeUsers(ctx context.Context, projectId string, regionId string, intakeId string) ApiListIntakeUsersRequest + func (a DefaultAPIServiceMock) ListIntakeUsersExecute(r ApiListIntakeUsersRequest) (*ListIntakeUsersResponse, error) + func (a DefaultAPIServiceMock) ListIntakes(ctx context.Context, projectId string, regionId string) ApiListIntakesRequest + func (a DefaultAPIServiceMock) ListIntakesExecute(r ApiListIntakesRequest) (*ListIntakesResponse, error) + func (a DefaultAPIServiceMock) UpdateIntake(ctx context.Context, projectId string, regionId string, intakeId string) ApiUpdateIntakeRequest + func (a DefaultAPIServiceMock) UpdateIntakeExecute(r ApiUpdateIntakeRequest) (*IntakeResponse, error) + func (a DefaultAPIServiceMock) UpdateIntakeRunner(ctx context.Context, projectId string, regionId string, intakeRunnerId string) ApiUpdateIntakeRunnerRequest + func (a DefaultAPIServiceMock) UpdateIntakeRunnerExecute(r ApiUpdateIntakeRunnerRequest) (*IntakeRunnerResponse, error) + func (a DefaultAPIServiceMock) UpdateIntakeUser(ctx context.Context, projectId string, regionId string, intakeId string, ...) ApiUpdateIntakeUserRequest + func (a DefaultAPIServiceMock) UpdateIntakeUserExecute(r ApiUpdateIntakeUserRequest) (*IntakeUserResponse, error) + type DremioAuth struct + PersonalAccessToken string + TokenEndpoint string + func NewDremioAuth(personalAccessToken string, tokenEndpoint string) *DremioAuth + func NewDremioAuthWithDefaults() *DremioAuth + func (o *DremioAuth) GetPersonalAccessToken() string + func (o *DremioAuth) GetPersonalAccessTokenOk() (*string, bool) + func (o *DremioAuth) GetTokenEndpoint() string + func (o *DremioAuth) GetTokenEndpointOk() (*string, bool) + func (o *DremioAuth) SetPersonalAccessToken(v string) + func (o *DremioAuth) SetTokenEndpoint(v string) + func (o *DremioAuth) UnmarshalJSON(data []byte) (err error) + func (o DremioAuth) MarshalJSON() ([]byte, error) + func (o DremioAuth) ToMap() (map[string]interface{}, error) + type DremioAuthPatch struct + PersonalAccessToken *string + TokenEndpoint *string + func NewDremioAuthPatch() *DremioAuthPatch + func NewDremioAuthPatchWithDefaults() *DremioAuthPatch + func (o *DremioAuthPatch) GetPersonalAccessToken() string + func (o *DremioAuthPatch) GetPersonalAccessTokenOk() (*string, bool) + func (o *DremioAuthPatch) GetTokenEndpoint() string + func (o *DremioAuthPatch) GetTokenEndpointOk() (*string, bool) + func (o *DremioAuthPatch) HasPersonalAccessToken() bool + func (o *DremioAuthPatch) HasTokenEndpoint() bool + func (o *DremioAuthPatch) SetPersonalAccessToken(v string) + func (o *DremioAuthPatch) SetTokenEndpoint(v string) + func (o DremioAuthPatch) MarshalJSON() ([]byte, error) + func (o DremioAuthPatch) ToMap() (map[string]interface{}, error) + type IntakeCatalog struct + Auth *CatalogAuth + Namespace *string + PartitionBy []string + Partitioning *PartitioningType + TableName *string + Uri string + Warehouse string + func NewIntakeCatalog(uri string, warehouse string) *IntakeCatalog + func NewIntakeCatalogWithDefaults() *IntakeCatalog + func (o *IntakeCatalog) GetAuth() CatalogAuth + func (o *IntakeCatalog) GetAuthOk() (*CatalogAuth, bool) + func (o *IntakeCatalog) GetNamespace() string + func (o *IntakeCatalog) GetNamespaceOk() (*string, bool) + func (o *IntakeCatalog) GetPartitionBy() []string + func (o *IntakeCatalog) GetPartitionByOk() ([]string, bool) + func (o *IntakeCatalog) GetPartitioning() PartitioningType + func (o *IntakeCatalog) GetPartitioningOk() (*PartitioningType, bool) + func (o *IntakeCatalog) GetTableName() string + func (o *IntakeCatalog) GetTableNameOk() (*string, bool) + func (o *IntakeCatalog) GetUri() string + func (o *IntakeCatalog) GetUriOk() (*string, bool) + func (o *IntakeCatalog) GetWarehouse() string + func (o *IntakeCatalog) GetWarehouseOk() (*string, bool) + func (o *IntakeCatalog) HasAuth() bool + func (o *IntakeCatalog) HasNamespace() bool + func (o *IntakeCatalog) HasPartitionBy() bool + func (o *IntakeCatalog) HasPartitioning() bool + func (o *IntakeCatalog) HasTableName() bool + func (o *IntakeCatalog) SetAuth(v CatalogAuth) + func (o *IntakeCatalog) SetNamespace(v string) + func (o *IntakeCatalog) SetPartitionBy(v []string) + func (o *IntakeCatalog) SetPartitioning(v PartitioningType) + func (o *IntakeCatalog) SetTableName(v string) + func (o *IntakeCatalog) SetUri(v string) + func (o *IntakeCatalog) SetWarehouse(v string) + func (o *IntakeCatalog) UnmarshalJSON(data []byte) (err error) + func (o IntakeCatalog) MarshalJSON() ([]byte, error) + func (o IntakeCatalog) ToMap() (map[string]interface{}, error) + type IntakeCatalogPatch struct + Auth *CatalogAuthPatch + Namespace *string + PartitionBy []string + Partitioning *PartitioningUpdateType + TableName *string + Uri *string + Warehouse *string + func NewIntakeCatalogPatch() *IntakeCatalogPatch + func NewIntakeCatalogPatchWithDefaults() *IntakeCatalogPatch + func (o *IntakeCatalogPatch) GetAuth() CatalogAuthPatch + func (o *IntakeCatalogPatch) GetAuthOk() (*CatalogAuthPatch, bool) + func (o *IntakeCatalogPatch) GetNamespace() string + func (o *IntakeCatalogPatch) GetNamespaceOk() (*string, bool) + func (o *IntakeCatalogPatch) GetPartitionBy() []string + func (o *IntakeCatalogPatch) GetPartitionByOk() ([]string, bool) + func (o *IntakeCatalogPatch) GetPartitioning() PartitioningUpdateType + func (o *IntakeCatalogPatch) GetPartitioningOk() (*PartitioningUpdateType, bool) + func (o *IntakeCatalogPatch) GetTableName() string + func (o *IntakeCatalogPatch) GetTableNameOk() (*string, bool) + func (o *IntakeCatalogPatch) GetUri() string + func (o *IntakeCatalogPatch) GetUriOk() (*string, bool) + func (o *IntakeCatalogPatch) GetWarehouse() string + func (o *IntakeCatalogPatch) GetWarehouseOk() (*string, bool) + func (o *IntakeCatalogPatch) HasAuth() bool + func (o *IntakeCatalogPatch) HasNamespace() bool + func (o *IntakeCatalogPatch) HasPartitionBy() bool + func (o *IntakeCatalogPatch) HasPartitioning() bool + func (o *IntakeCatalogPatch) HasTableName() bool + func (o *IntakeCatalogPatch) HasUri() bool + func (o *IntakeCatalogPatch) HasWarehouse() bool + func (o *IntakeCatalogPatch) SetAuth(v CatalogAuthPatch) + func (o *IntakeCatalogPatch) SetNamespace(v string) + func (o *IntakeCatalogPatch) SetPartitionBy(v []string) + func (o *IntakeCatalogPatch) SetPartitioning(v PartitioningUpdateType) + func (o *IntakeCatalogPatch) SetTableName(v string) + func (o *IntakeCatalogPatch) SetUri(v string) + func (o *IntakeCatalogPatch) SetWarehouse(v string) + func (o IntakeCatalogPatch) MarshalJSON() ([]byte, error) + func (o IntakeCatalogPatch) ToMap() (map[string]interface{}, error) + type IntakeResponse struct + Catalog IntakeCatalog + CreateTime time.Time + DeadLetterTopic string + Description *string + DisplayName string + FailureMessage *string + Id string + IntakeRunnerId string + Labels map[string]string + State string + Topic string + UndeliveredMessageCount *int64 + Uri string + func NewIntakeResponse(catalog IntakeCatalog, createTime time.Time, deadLetterTopic string, ...) *IntakeResponse + func NewIntakeResponseWithDefaults() *IntakeResponse + func (o *IntakeResponse) GetCatalog() IntakeCatalog + func (o *IntakeResponse) GetCatalogOk() (*IntakeCatalog, bool) + func (o *IntakeResponse) GetCreateTime() time.Time + func (o *IntakeResponse) GetCreateTimeOk() (*time.Time, bool) + func (o *IntakeResponse) GetDeadLetterTopic() string + func (o *IntakeResponse) GetDeadLetterTopicOk() (*string, bool) + func (o *IntakeResponse) GetDescription() string + func (o *IntakeResponse) GetDescriptionOk() (*string, bool) + func (o *IntakeResponse) GetDisplayName() string + func (o *IntakeResponse) GetDisplayNameOk() (*string, bool) + func (o *IntakeResponse) GetFailureMessage() string + func (o *IntakeResponse) GetFailureMessageOk() (*string, bool) + func (o *IntakeResponse) GetId() string + func (o *IntakeResponse) GetIdOk() (*string, bool) + func (o *IntakeResponse) GetIntakeRunnerId() string + func (o *IntakeResponse) GetIntakeRunnerIdOk() (*string, bool) + func (o *IntakeResponse) GetLabels() map[string]string + func (o *IntakeResponse) GetLabelsOk() (*map[string]string, bool) + func (o *IntakeResponse) GetState() string + func (o *IntakeResponse) GetStateOk() (*string, bool) + func (o *IntakeResponse) GetTopic() string + func (o *IntakeResponse) GetTopicOk() (*string, bool) + func (o *IntakeResponse) GetUndeliveredMessageCount() int64 + func (o *IntakeResponse) GetUndeliveredMessageCountOk() (*int64, bool) + func (o *IntakeResponse) GetUri() string + func (o *IntakeResponse) GetUriOk() (*string, bool) + func (o *IntakeResponse) HasDescription() bool + func (o *IntakeResponse) HasFailureMessage() bool + func (o *IntakeResponse) HasLabels() bool + func (o *IntakeResponse) HasUndeliveredMessageCount() bool + func (o *IntakeResponse) SetCatalog(v IntakeCatalog) + func (o *IntakeResponse) SetCreateTime(v time.Time) + func (o *IntakeResponse) SetDeadLetterTopic(v string) + func (o *IntakeResponse) SetDescription(v string) + func (o *IntakeResponse) SetDisplayName(v string) + func (o *IntakeResponse) SetFailureMessage(v string) + func (o *IntakeResponse) SetId(v string) + func (o *IntakeResponse) SetIntakeRunnerId(v string) + func (o *IntakeResponse) SetLabels(v map[string]string) + func (o *IntakeResponse) SetState(v string) + func (o *IntakeResponse) SetTopic(v string) + func (o *IntakeResponse) SetUndeliveredMessageCount(v int64) + func (o *IntakeResponse) SetUri(v string) + func (o *IntakeResponse) UnmarshalJSON(data []byte) (err error) + func (o IntakeResponse) MarshalJSON() ([]byte, error) + func (o IntakeResponse) ToMap() (map[string]interface{}, error) + type IntakeRunnerResponse struct + CreateTime time.Time + Description *string + DisplayName string + Id string + Labels map[string]string + MaxMessageSizeKiB int32 + MaxMessagesPerHour int32 + State string + Uri string + func NewIntakeRunnerResponse(createTime time.Time, displayName string, id string, maxMessageSizeKiB int32, ...) *IntakeRunnerResponse + func NewIntakeRunnerResponseWithDefaults() *IntakeRunnerResponse + func (o *IntakeRunnerResponse) GetCreateTime() time.Time + func (o *IntakeRunnerResponse) GetCreateTimeOk() (*time.Time, bool) + func (o *IntakeRunnerResponse) GetDescription() string + func (o *IntakeRunnerResponse) GetDescriptionOk() (*string, bool) + func (o *IntakeRunnerResponse) GetDisplayName() string + func (o *IntakeRunnerResponse) GetDisplayNameOk() (*string, bool) + func (o *IntakeRunnerResponse) GetId() string + func (o *IntakeRunnerResponse) GetIdOk() (*string, bool) + func (o *IntakeRunnerResponse) GetLabels() map[string]string + func (o *IntakeRunnerResponse) GetLabelsOk() (*map[string]string, bool) + func (o *IntakeRunnerResponse) GetMaxMessageSizeKiB() int32 + func (o *IntakeRunnerResponse) GetMaxMessageSizeKiBOk() (*int32, bool) + func (o *IntakeRunnerResponse) GetMaxMessagesPerHour() int32 + func (o *IntakeRunnerResponse) GetMaxMessagesPerHourOk() (*int32, bool) + func (o *IntakeRunnerResponse) GetState() string + func (o *IntakeRunnerResponse) GetStateOk() (*string, bool) + func (o *IntakeRunnerResponse) GetUri() string + func (o *IntakeRunnerResponse) GetUriOk() (*string, bool) + func (o *IntakeRunnerResponse) HasDescription() bool + func (o *IntakeRunnerResponse) HasLabels() bool + func (o *IntakeRunnerResponse) SetCreateTime(v time.Time) + func (o *IntakeRunnerResponse) SetDescription(v string) + func (o *IntakeRunnerResponse) SetDisplayName(v string) + func (o *IntakeRunnerResponse) SetId(v string) + func (o *IntakeRunnerResponse) SetLabels(v map[string]string) + func (o *IntakeRunnerResponse) SetMaxMessageSizeKiB(v int32) + func (o *IntakeRunnerResponse) SetMaxMessagesPerHour(v int32) + func (o *IntakeRunnerResponse) SetState(v string) + func (o *IntakeRunnerResponse) SetUri(v string) + func (o *IntakeRunnerResponse) UnmarshalJSON(data []byte) (err error) + func (o IntakeRunnerResponse) MarshalJSON() ([]byte, error) + func (o IntakeRunnerResponse) ToMap() (map[string]interface{}, error) + type IntakeUserResponse struct + ClientConfig *ClientConfig + CreateTime time.Time + Description *string + DisplayName string + Id string + Labels map[string]string + State string + Type UserType + User string + func NewIntakeUserResponse(createTime time.Time, displayName string, id string, state string, ...) *IntakeUserResponse + func NewIntakeUserResponseWithDefaults() *IntakeUserResponse + func (o *IntakeUserResponse) GetClientConfig() ClientConfig + func (o *IntakeUserResponse) GetClientConfigOk() (*ClientConfig, bool) + func (o *IntakeUserResponse) GetCreateTime() time.Time + func (o *IntakeUserResponse) GetCreateTimeOk() (*time.Time, bool) + func (o *IntakeUserResponse) GetDescription() string + func (o *IntakeUserResponse) GetDescriptionOk() (*string, bool) + func (o *IntakeUserResponse) GetDisplayName() string + func (o *IntakeUserResponse) GetDisplayNameOk() (*string, bool) + func (o *IntakeUserResponse) GetId() string + func (o *IntakeUserResponse) GetIdOk() (*string, bool) + func (o *IntakeUserResponse) GetLabels() map[string]string + func (o *IntakeUserResponse) GetLabelsOk() (*map[string]string, bool) + func (o *IntakeUserResponse) GetState() string + func (o *IntakeUserResponse) GetStateOk() (*string, bool) + func (o *IntakeUserResponse) GetType() UserType + func (o *IntakeUserResponse) GetTypeOk() (*UserType, bool) + func (o *IntakeUserResponse) GetUser() string + func (o *IntakeUserResponse) GetUserOk() (*string, bool) + func (o *IntakeUserResponse) HasClientConfig() bool + func (o *IntakeUserResponse) HasDescription() bool + func (o *IntakeUserResponse) HasLabels() bool + func (o *IntakeUserResponse) SetClientConfig(v ClientConfig) + func (o *IntakeUserResponse) SetCreateTime(v time.Time) + func (o *IntakeUserResponse) SetDescription(v string) + func (o *IntakeUserResponse) SetDisplayName(v string) + func (o *IntakeUserResponse) SetId(v string) + func (o *IntakeUserResponse) SetLabels(v map[string]string) + func (o *IntakeUserResponse) SetState(v string) + func (o *IntakeUserResponse) SetType(v UserType) + func (o *IntakeUserResponse) SetUser(v string) + func (o *IntakeUserResponse) UnmarshalJSON(data []byte) (err error) + func (o IntakeUserResponse) MarshalJSON() ([]byte, error) + func (o IntakeUserResponse) ToMap() (map[string]interface{}, error) + type ListIntakeRunnersResponse struct + IntakeRunners []IntakeRunnerResponse + NextPageToken *string + func NewListIntakeRunnersResponse(intakeRunners []IntakeRunnerResponse) *ListIntakeRunnersResponse + func NewListIntakeRunnersResponseWithDefaults() *ListIntakeRunnersResponse + func (o *ListIntakeRunnersResponse) GetIntakeRunners() []IntakeRunnerResponse + func (o *ListIntakeRunnersResponse) GetIntakeRunnersOk() ([]IntakeRunnerResponse, bool) + func (o *ListIntakeRunnersResponse) GetNextPageToken() string + func (o *ListIntakeRunnersResponse) GetNextPageTokenOk() (*string, bool) + func (o *ListIntakeRunnersResponse) HasNextPageToken() bool + func (o *ListIntakeRunnersResponse) SetIntakeRunners(v []IntakeRunnerResponse) + func (o *ListIntakeRunnersResponse) SetNextPageToken(v string) + func (o *ListIntakeRunnersResponse) UnmarshalJSON(data []byte) (err error) + func (o ListIntakeRunnersResponse) MarshalJSON() ([]byte, error) + func (o ListIntakeRunnersResponse) ToMap() (map[string]interface{}, error) + type ListIntakeUsersResponse struct + IntakeUsers []IntakeUserResponse + NextPageToken *string + func NewListIntakeUsersResponse(intakeUsers []IntakeUserResponse) *ListIntakeUsersResponse + func NewListIntakeUsersResponseWithDefaults() *ListIntakeUsersResponse + func (o *ListIntakeUsersResponse) GetIntakeUsers() []IntakeUserResponse + func (o *ListIntakeUsersResponse) GetIntakeUsersOk() ([]IntakeUserResponse, bool) + func (o *ListIntakeUsersResponse) GetNextPageToken() string + func (o *ListIntakeUsersResponse) GetNextPageTokenOk() (*string, bool) + func (o *ListIntakeUsersResponse) HasNextPageToken() bool + func (o *ListIntakeUsersResponse) SetIntakeUsers(v []IntakeUserResponse) + func (o *ListIntakeUsersResponse) SetNextPageToken(v string) + func (o *ListIntakeUsersResponse) UnmarshalJSON(data []byte) (err error) + func (o ListIntakeUsersResponse) MarshalJSON() ([]byte, error) + func (o ListIntakeUsersResponse) ToMap() (map[string]interface{}, error) + type ListIntakesResponse struct + Intakes []IntakeResponse + NextPageToken *string + func NewListIntakesResponse(intakes []IntakeResponse) *ListIntakesResponse + func NewListIntakesResponseWithDefaults() *ListIntakesResponse + func (o *ListIntakesResponse) GetIntakes() []IntakeResponse + func (o *ListIntakesResponse) GetIntakesOk() ([]IntakeResponse, bool) + func (o *ListIntakesResponse) GetNextPageToken() string + func (o *ListIntakesResponse) GetNextPageTokenOk() (*string, bool) + func (o *ListIntakesResponse) HasNextPageToken() bool + func (o *ListIntakesResponse) SetIntakes(v []IntakeResponse) + func (o *ListIntakesResponse) SetNextPageToken(v string) + func (o *ListIntakesResponse) UnmarshalJSON(data []byte) (err error) + func (o ListIntakesResponse) MarshalJSON() ([]byte, error) + func (o ListIntakesResponse) ToMap() (map[string]interface{}, error) + type MappedNullable interface + ToMap func() (map[string]interface{}, error) + type NullableBool struct + func NewNullableBool(val *bool) *NullableBool + func (v *NullableBool) Set(val *bool) + func (v *NullableBool) UnmarshalJSON(src []byte) error + func (v *NullableBool) Unset() + func (v NullableBool) Get() *bool + func (v NullableBool) IsSet() bool + func (v NullableBool) MarshalJSON() ([]byte, error) + type NullableCatalogAuth struct + func NewNullableCatalogAuth(val *CatalogAuth) *NullableCatalogAuth + func (v *NullableCatalogAuth) Set(val *CatalogAuth) + func (v *NullableCatalogAuth) UnmarshalJSON(src []byte) error + func (v *NullableCatalogAuth) Unset() + func (v NullableCatalogAuth) Get() *CatalogAuth + func (v NullableCatalogAuth) IsSet() bool + func (v NullableCatalogAuth) MarshalJSON() ([]byte, error) + type NullableCatalogAuthPatch struct + func NewNullableCatalogAuthPatch(val *CatalogAuthPatch) *NullableCatalogAuthPatch + func (v *NullableCatalogAuthPatch) Set(val *CatalogAuthPatch) + func (v *NullableCatalogAuthPatch) UnmarshalJSON(src []byte) error + func (v *NullableCatalogAuthPatch) Unset() + func (v NullableCatalogAuthPatch) Get() *CatalogAuthPatch + func (v NullableCatalogAuthPatch) IsSet() bool + func (v NullableCatalogAuthPatch) MarshalJSON() ([]byte, error) + type NullableCatalogAuthType struct + func NewNullableCatalogAuthType(val *CatalogAuthType) *NullableCatalogAuthType + func (v *NullableCatalogAuthType) Set(val *CatalogAuthType) + func (v *NullableCatalogAuthType) UnmarshalJSON(src []byte) error + func (v *NullableCatalogAuthType) Unset() + func (v NullableCatalogAuthType) Get() *CatalogAuthType + func (v NullableCatalogAuthType) IsSet() bool + func (v NullableCatalogAuthType) MarshalJSON() ([]byte, error) + type NullableClientConfig struct + func NewNullableClientConfig(val *ClientConfig) *NullableClientConfig + func (v *NullableClientConfig) Set(val *ClientConfig) + func (v *NullableClientConfig) UnmarshalJSON(src []byte) error + func (v *NullableClientConfig) Unset() + func (v NullableClientConfig) Get() *ClientConfig + func (v NullableClientConfig) IsSet() bool + func (v NullableClientConfig) MarshalJSON() ([]byte, error) + type NullableCreateIntakePayload struct + func NewNullableCreateIntakePayload(val *CreateIntakePayload) *NullableCreateIntakePayload + func (v *NullableCreateIntakePayload) Set(val *CreateIntakePayload) + func (v *NullableCreateIntakePayload) UnmarshalJSON(src []byte) error + func (v *NullableCreateIntakePayload) Unset() + func (v NullableCreateIntakePayload) Get() *CreateIntakePayload + func (v NullableCreateIntakePayload) IsSet() bool + func (v NullableCreateIntakePayload) MarshalJSON() ([]byte, error) + type NullableCreateIntakeRunnerPayload struct + func NewNullableCreateIntakeRunnerPayload(val *CreateIntakeRunnerPayload) *NullableCreateIntakeRunnerPayload + func (v *NullableCreateIntakeRunnerPayload) Set(val *CreateIntakeRunnerPayload) + func (v *NullableCreateIntakeRunnerPayload) UnmarshalJSON(src []byte) error + func (v *NullableCreateIntakeRunnerPayload) Unset() + func (v NullableCreateIntakeRunnerPayload) Get() *CreateIntakeRunnerPayload + func (v NullableCreateIntakeRunnerPayload) IsSet() bool + func (v NullableCreateIntakeRunnerPayload) MarshalJSON() ([]byte, error) + type NullableCreateIntakeUserPayload struct + func NewNullableCreateIntakeUserPayload(val *CreateIntakeUserPayload) *NullableCreateIntakeUserPayload + func (v *NullableCreateIntakeUserPayload) Set(val *CreateIntakeUserPayload) + func (v *NullableCreateIntakeUserPayload) UnmarshalJSON(src []byte) error + func (v *NullableCreateIntakeUserPayload) Unset() + func (v NullableCreateIntakeUserPayload) Get() *CreateIntakeUserPayload + func (v NullableCreateIntakeUserPayload) IsSet() bool + func (v NullableCreateIntakeUserPayload) MarshalJSON() ([]byte, error) + type NullableDremioAuth struct + func NewNullableDremioAuth(val *DremioAuth) *NullableDremioAuth + func (v *NullableDremioAuth) Set(val *DremioAuth) + func (v *NullableDremioAuth) UnmarshalJSON(src []byte) error + func (v *NullableDremioAuth) Unset() + func (v NullableDremioAuth) Get() *DremioAuth + func (v NullableDremioAuth) IsSet() bool + func (v NullableDremioAuth) MarshalJSON() ([]byte, error) + type NullableDremioAuthPatch struct + func NewNullableDremioAuthPatch(val *DremioAuthPatch) *NullableDremioAuthPatch + func (v *NullableDremioAuthPatch) Set(val *DremioAuthPatch) + func (v *NullableDremioAuthPatch) UnmarshalJSON(src []byte) error + func (v *NullableDremioAuthPatch) Unset() + func (v NullableDremioAuthPatch) Get() *DremioAuthPatch + func (v NullableDremioAuthPatch) IsSet() bool + func (v NullableDremioAuthPatch) MarshalJSON() ([]byte, error) + type NullableFloat32 struct + func NewNullableFloat32(val *float32) *NullableFloat32 + func (v *NullableFloat32) Set(val *float32) + func (v *NullableFloat32) UnmarshalJSON(src []byte) error + func (v *NullableFloat32) Unset() + func (v NullableFloat32) Get() *float32 + func (v NullableFloat32) IsSet() bool + func (v NullableFloat32) MarshalJSON() ([]byte, error) + type NullableFloat64 struct + func NewNullableFloat64(val *float64) *NullableFloat64 + func (v *NullableFloat64) Set(val *float64) + func (v *NullableFloat64) UnmarshalJSON(src []byte) error + func (v *NullableFloat64) Unset() + func (v NullableFloat64) Get() *float64 + func (v NullableFloat64) IsSet() bool + func (v NullableFloat64) MarshalJSON() ([]byte, error) + type NullableInt struct + func NewNullableInt(val *int) *NullableInt + func (v *NullableInt) Set(val *int) + func (v *NullableInt) UnmarshalJSON(src []byte) error + func (v *NullableInt) Unset() + func (v NullableInt) Get() *int + func (v NullableInt) IsSet() bool + func (v NullableInt) MarshalJSON() ([]byte, error) + type NullableInt32 struct + func NewNullableInt32(val *int32) *NullableInt32 + func (v *NullableInt32) Set(val *int32) + func (v *NullableInt32) UnmarshalJSON(src []byte) error + func (v *NullableInt32) Unset() + func (v NullableInt32) Get() *int32 + func (v NullableInt32) IsSet() bool + func (v NullableInt32) MarshalJSON() ([]byte, error) + type NullableInt64 struct + func NewNullableInt64(val *int64) *NullableInt64 + func (v *NullableInt64) Set(val *int64) + func (v *NullableInt64) UnmarshalJSON(src []byte) error + func (v *NullableInt64) Unset() + func (v NullableInt64) Get() *int64 + func (v NullableInt64) IsSet() bool + func (v NullableInt64) MarshalJSON() ([]byte, error) + type NullableIntakeCatalog struct + func NewNullableIntakeCatalog(val *IntakeCatalog) *NullableIntakeCatalog + func (v *NullableIntakeCatalog) Set(val *IntakeCatalog) + func (v *NullableIntakeCatalog) UnmarshalJSON(src []byte) error + func (v *NullableIntakeCatalog) Unset() + func (v NullableIntakeCatalog) Get() *IntakeCatalog + func (v NullableIntakeCatalog) IsSet() bool + func (v NullableIntakeCatalog) MarshalJSON() ([]byte, error) + type NullableIntakeCatalogPatch struct + func NewNullableIntakeCatalogPatch(val *IntakeCatalogPatch) *NullableIntakeCatalogPatch + func (v *NullableIntakeCatalogPatch) Set(val *IntakeCatalogPatch) + func (v *NullableIntakeCatalogPatch) UnmarshalJSON(src []byte) error + func (v *NullableIntakeCatalogPatch) Unset() + func (v NullableIntakeCatalogPatch) Get() *IntakeCatalogPatch + func (v NullableIntakeCatalogPatch) IsSet() bool + func (v NullableIntakeCatalogPatch) MarshalJSON() ([]byte, error) + type NullableIntakeResponse struct + func NewNullableIntakeResponse(val *IntakeResponse) *NullableIntakeResponse + func (v *NullableIntakeResponse) Set(val *IntakeResponse) + func (v *NullableIntakeResponse) UnmarshalJSON(src []byte) error + func (v *NullableIntakeResponse) Unset() + func (v NullableIntakeResponse) Get() *IntakeResponse + func (v NullableIntakeResponse) IsSet() bool + func (v NullableIntakeResponse) MarshalJSON() ([]byte, error) + type NullableIntakeRunnerResponse struct + func NewNullableIntakeRunnerResponse(val *IntakeRunnerResponse) *NullableIntakeRunnerResponse + func (v *NullableIntakeRunnerResponse) Set(val *IntakeRunnerResponse) + func (v *NullableIntakeRunnerResponse) UnmarshalJSON(src []byte) error + func (v *NullableIntakeRunnerResponse) Unset() + func (v NullableIntakeRunnerResponse) Get() *IntakeRunnerResponse + func (v NullableIntakeRunnerResponse) IsSet() bool + func (v NullableIntakeRunnerResponse) MarshalJSON() ([]byte, error) + type NullableIntakeUserResponse struct + func NewNullableIntakeUserResponse(val *IntakeUserResponse) *NullableIntakeUserResponse + func (v *NullableIntakeUserResponse) Set(val *IntakeUserResponse) + func (v *NullableIntakeUserResponse) UnmarshalJSON(src []byte) error + func (v *NullableIntakeUserResponse) Unset() + func (v NullableIntakeUserResponse) Get() *IntakeUserResponse + func (v NullableIntakeUserResponse) IsSet() bool + func (v NullableIntakeUserResponse) MarshalJSON() ([]byte, error) + type NullableListIntakeRunnersResponse struct + func NewNullableListIntakeRunnersResponse(val *ListIntakeRunnersResponse) *NullableListIntakeRunnersResponse + func (v *NullableListIntakeRunnersResponse) Set(val *ListIntakeRunnersResponse) + func (v *NullableListIntakeRunnersResponse) UnmarshalJSON(src []byte) error + func (v *NullableListIntakeRunnersResponse) Unset() + func (v NullableListIntakeRunnersResponse) Get() *ListIntakeRunnersResponse + func (v NullableListIntakeRunnersResponse) IsSet() bool + func (v NullableListIntakeRunnersResponse) MarshalJSON() ([]byte, error) + type NullableListIntakeUsersResponse struct + func NewNullableListIntakeUsersResponse(val *ListIntakeUsersResponse) *NullableListIntakeUsersResponse + func (v *NullableListIntakeUsersResponse) Set(val *ListIntakeUsersResponse) + func (v *NullableListIntakeUsersResponse) UnmarshalJSON(src []byte) error + func (v *NullableListIntakeUsersResponse) Unset() + func (v NullableListIntakeUsersResponse) Get() *ListIntakeUsersResponse + func (v NullableListIntakeUsersResponse) IsSet() bool + func (v NullableListIntakeUsersResponse) MarshalJSON() ([]byte, error) + type NullableListIntakesResponse struct + func NewNullableListIntakesResponse(val *ListIntakesResponse) *NullableListIntakesResponse + func (v *NullableListIntakesResponse) Set(val *ListIntakesResponse) + func (v *NullableListIntakesResponse) UnmarshalJSON(src []byte) error + func (v *NullableListIntakesResponse) Unset() + func (v NullableListIntakesResponse) Get() *ListIntakesResponse + func (v NullableListIntakesResponse) IsSet() bool + func (v NullableListIntakesResponse) MarshalJSON() ([]byte, error) + type NullablePartitioningType struct + func NewNullablePartitioningType(val *PartitioningType) *NullablePartitioningType + func (v *NullablePartitioningType) Set(val *PartitioningType) + func (v *NullablePartitioningType) UnmarshalJSON(src []byte) error + func (v *NullablePartitioningType) Unset() + func (v NullablePartitioningType) Get() *PartitioningType + func (v NullablePartitioningType) IsSet() bool + func (v NullablePartitioningType) MarshalJSON() ([]byte, error) + type NullablePartitioningUpdateType struct + func NewNullablePartitioningUpdateType(val *PartitioningUpdateType) *NullablePartitioningUpdateType + func (v *NullablePartitioningUpdateType) Set(val *PartitioningUpdateType) + func (v *NullablePartitioningUpdateType) UnmarshalJSON(src []byte) error + func (v *NullablePartitioningUpdateType) Unset() + func (v NullablePartitioningUpdateType) Get() *PartitioningUpdateType + func (v NullablePartitioningUpdateType) IsSet() bool + func (v NullablePartitioningUpdateType) MarshalJSON() ([]byte, error) + type NullableString struct + func NewNullableString(val *string) *NullableString + func (v *NullableString) Set(val *string) + func (v *NullableString) UnmarshalJSON(src []byte) error + func (v *NullableString) Unset() + func (v NullableString) Get() *string + func (v NullableString) IsSet() bool + func (v NullableString) MarshalJSON() ([]byte, error) + type NullableTime struct + func NewNullableTime(val *time.Time) *NullableTime + func (v *NullableTime) Set(val *time.Time) + func (v *NullableTime) UnmarshalJSON(src []byte) error + func (v *NullableTime) Unset() + func (v NullableTime) Get() *time.Time + func (v NullableTime) IsSet() bool + func (v NullableTime) MarshalJSON() ([]byte, error) + type NullableUpdateIntakePayload struct + func NewNullableUpdateIntakePayload(val *UpdateIntakePayload) *NullableUpdateIntakePayload + func (v *NullableUpdateIntakePayload) Set(val *UpdateIntakePayload) + func (v *NullableUpdateIntakePayload) UnmarshalJSON(src []byte) error + func (v *NullableUpdateIntakePayload) Unset() + func (v NullableUpdateIntakePayload) Get() *UpdateIntakePayload + func (v NullableUpdateIntakePayload) IsSet() bool + func (v NullableUpdateIntakePayload) MarshalJSON() ([]byte, error) + type NullableUpdateIntakeRunnerPayload struct + func NewNullableUpdateIntakeRunnerPayload(val *UpdateIntakeRunnerPayload) *NullableUpdateIntakeRunnerPayload + func (v *NullableUpdateIntakeRunnerPayload) Set(val *UpdateIntakeRunnerPayload) + func (v *NullableUpdateIntakeRunnerPayload) UnmarshalJSON(src []byte) error + func (v *NullableUpdateIntakeRunnerPayload) Unset() + func (v NullableUpdateIntakeRunnerPayload) Get() *UpdateIntakeRunnerPayload + func (v NullableUpdateIntakeRunnerPayload) IsSet() bool + func (v NullableUpdateIntakeRunnerPayload) MarshalJSON() ([]byte, error) + type NullableUpdateIntakeUserPayload struct + func NewNullableUpdateIntakeUserPayload(val *UpdateIntakeUserPayload) *NullableUpdateIntakeUserPayload + func (v *NullableUpdateIntakeUserPayload) Set(val *UpdateIntakeUserPayload) + func (v *NullableUpdateIntakeUserPayload) UnmarshalJSON(src []byte) error + func (v *NullableUpdateIntakeUserPayload) Unset() + func (v NullableUpdateIntakeUserPayload) Get() *UpdateIntakeUserPayload + func (v NullableUpdateIntakeUserPayload) IsSet() bool + func (v NullableUpdateIntakeUserPayload) MarshalJSON() ([]byte, error) + type NullableUserType struct + func NewNullableUserType(val *UserType) *NullableUserType + func (v *NullableUserType) Set(val *UserType) + func (v *NullableUserType) UnmarshalJSON(src []byte) error + func (v *NullableUserType) Unset() + func (v NullableUserType) Get() *UserType + func (v NullableUserType) IsSet() bool + func (v NullableUserType) MarshalJSON() ([]byte, error) + type PartitioningType string + const PARTITIONINGTYPE_INTAKE_TIME + const PARTITIONINGTYPE_MANUAL + const PARTITIONINGTYPE_NONE + func NewPartitioningTypeFromValue(v string) (*PartitioningType, error) + func (v *PartitioningType) UnmarshalJSON(src []byte) error + func (v PartitioningType) IsValid() bool + func (v PartitioningType) Ptr() *PartitioningType + type PartitioningUpdateType string + const PARTITIONINGUPDATETYPE_INTAKE_TIME + const PARTITIONINGUPDATETYPE_MANUAL + const PARTITIONINGUPDATETYPE_NONE + func NewPartitioningUpdateTypeFromValue(v string) (*PartitioningUpdateType, error) + func (v *PartitioningUpdateType) UnmarshalJSON(src []byte) error + func (v PartitioningUpdateType) IsValid() bool + func (v PartitioningUpdateType) Ptr() *PartitioningUpdateType + type UpdateIntakePayload struct + Catalog *IntakeCatalogPatch + Description *string + DisplayName *string + IntakeRunnerId string + Labels map[string]string + func NewUpdateIntakePayload(intakeRunnerId string) *UpdateIntakePayload + func NewUpdateIntakePayloadWithDefaults() *UpdateIntakePayload + func (o *UpdateIntakePayload) GetCatalog() IntakeCatalogPatch + func (o *UpdateIntakePayload) GetCatalogOk() (*IntakeCatalogPatch, bool) + func (o *UpdateIntakePayload) GetDescription() string + func (o *UpdateIntakePayload) GetDescriptionOk() (*string, bool) + func (o *UpdateIntakePayload) GetDisplayName() string + func (o *UpdateIntakePayload) GetDisplayNameOk() (*string, bool) + func (o *UpdateIntakePayload) GetIntakeRunnerId() string + func (o *UpdateIntakePayload) GetIntakeRunnerIdOk() (*string, bool) + func (o *UpdateIntakePayload) GetLabels() map[string]string + func (o *UpdateIntakePayload) GetLabelsOk() (*map[string]string, bool) + func (o *UpdateIntakePayload) HasCatalog() bool + func (o *UpdateIntakePayload) HasDescription() bool + func (o *UpdateIntakePayload) HasDisplayName() bool + func (o *UpdateIntakePayload) HasLabels() bool + func (o *UpdateIntakePayload) SetCatalog(v IntakeCatalogPatch) + func (o *UpdateIntakePayload) SetDescription(v string) + func (o *UpdateIntakePayload) SetDisplayName(v string) + func (o *UpdateIntakePayload) SetIntakeRunnerId(v string) + func (o *UpdateIntakePayload) SetLabels(v map[string]string) + func (o *UpdateIntakePayload) UnmarshalJSON(data []byte) (err error) + func (o UpdateIntakePayload) MarshalJSON() ([]byte, error) + func (o UpdateIntakePayload) ToMap() (map[string]interface{}, error) + type UpdateIntakeRunnerPayload struct + Description *string + DisplayName *string + Labels map[string]string + MaxMessageSizeKiB *int32 + MaxMessagesPerHour *int32 + func NewUpdateIntakeRunnerPayload() *UpdateIntakeRunnerPayload + func NewUpdateIntakeRunnerPayloadWithDefaults() *UpdateIntakeRunnerPayload + func (o *UpdateIntakeRunnerPayload) GetDescription() string + func (o *UpdateIntakeRunnerPayload) GetDescriptionOk() (*string, bool) + func (o *UpdateIntakeRunnerPayload) GetDisplayName() string + func (o *UpdateIntakeRunnerPayload) GetDisplayNameOk() (*string, bool) + func (o *UpdateIntakeRunnerPayload) GetLabels() map[string]string + func (o *UpdateIntakeRunnerPayload) GetLabelsOk() (*map[string]string, bool) + func (o *UpdateIntakeRunnerPayload) GetMaxMessageSizeKiB() int32 + func (o *UpdateIntakeRunnerPayload) GetMaxMessageSizeKiBOk() (*int32, bool) + func (o *UpdateIntakeRunnerPayload) GetMaxMessagesPerHour() int32 + func (o *UpdateIntakeRunnerPayload) GetMaxMessagesPerHourOk() (*int32, bool) + func (o *UpdateIntakeRunnerPayload) HasDescription() bool + func (o *UpdateIntakeRunnerPayload) HasDisplayName() bool + func (o *UpdateIntakeRunnerPayload) HasLabels() bool + func (o *UpdateIntakeRunnerPayload) HasMaxMessageSizeKiB() bool + func (o *UpdateIntakeRunnerPayload) HasMaxMessagesPerHour() bool + func (o *UpdateIntakeRunnerPayload) SetDescription(v string) + func (o *UpdateIntakeRunnerPayload) SetDisplayName(v string) + func (o *UpdateIntakeRunnerPayload) SetLabels(v map[string]string) + func (o *UpdateIntakeRunnerPayload) SetMaxMessageSizeKiB(v int32) + func (o *UpdateIntakeRunnerPayload) SetMaxMessagesPerHour(v int32) + func (o UpdateIntakeRunnerPayload) MarshalJSON() ([]byte, error) + func (o UpdateIntakeRunnerPayload) ToMap() (map[string]interface{}, error) + type UpdateIntakeUserPayload struct + Description *string + DisplayName *string + Labels map[string]string + Password *string + Type *UserType + func NewUpdateIntakeUserPayload() *UpdateIntakeUserPayload + func NewUpdateIntakeUserPayloadWithDefaults() *UpdateIntakeUserPayload + func (o *UpdateIntakeUserPayload) GetDescription() string + func (o *UpdateIntakeUserPayload) GetDescriptionOk() (*string, bool) + func (o *UpdateIntakeUserPayload) GetDisplayName() string + func (o *UpdateIntakeUserPayload) GetDisplayNameOk() (*string, bool) + func (o *UpdateIntakeUserPayload) GetLabels() map[string]string + func (o *UpdateIntakeUserPayload) GetLabelsOk() (*map[string]string, bool) + func (o *UpdateIntakeUserPayload) GetPassword() string + func (o *UpdateIntakeUserPayload) GetPasswordOk() (*string, bool) + func (o *UpdateIntakeUserPayload) GetType() UserType + func (o *UpdateIntakeUserPayload) GetTypeOk() (*UserType, bool) + func (o *UpdateIntakeUserPayload) HasDescription() bool + func (o *UpdateIntakeUserPayload) HasDisplayName() bool + func (o *UpdateIntakeUserPayload) HasLabels() bool + func (o *UpdateIntakeUserPayload) HasPassword() bool + func (o *UpdateIntakeUserPayload) HasType() bool + func (o *UpdateIntakeUserPayload) SetDescription(v string) + func (o *UpdateIntakeUserPayload) SetDisplayName(v string) + func (o *UpdateIntakeUserPayload) SetLabels(v map[string]string) + func (o *UpdateIntakeUserPayload) SetPassword(v string) + func (o *UpdateIntakeUserPayload) SetType(v UserType) + func (o UpdateIntakeUserPayload) MarshalJSON() ([]byte, error) + func (o UpdateIntakeUserPayload) ToMap() (map[string]interface{}, error) + type UserType string + const USERTYPE_DEAD_LETTER + const USERTYPE_INTAKE + func NewUserTypeFromValue(v string) (*UserType, error) + func (v *UserType) UnmarshalJSON(src []byte) error + func (v UserType) IsValid() bool + func (v UserType) Ptr() *UserType
Go to main page