v1betaapi

package

Go to main page

Versions in this module

v0

v0.11.0

Jun 3, 2026

v0.10.0

May 27, 2026

Changes in this version

+ var AllowedIntakeResponseStateEnumValues = []IntakeResponseState

+ var AllowedIntakeRunnerResponseStateEnumValues = []IntakeRunnerResponseState

+ var AllowedIntakeUserResponseStateEnumValues = []IntakeUserResponseState

+ type IntakeResponseState string

+ const INTAKERESPONSESTATE_ACTIVE

+ const INTAKERESPONSESTATE_DELETING

+ const INTAKERESPONSESTATE_FAILED

+ const INTAKERESPONSESTATE_RECONCILING

+ const INTAKERESPONSESTATE_UNKNOWN_DEFAULT_OPEN_API

+ func NewIntakeResponseStateFromValue(v string) (*IntakeResponseState, error)

+ func (v *IntakeResponseState) UnmarshalJSON(src []byte) error

+ func (v IntakeResponseState) IsValid() bool

+ func (v IntakeResponseState) Ptr() *IntakeResponseState

+ type IntakeRunnerResponseState string

+ const INTAKERUNNERRESPONSESTATE_ACTIVE

+ const INTAKERUNNERRESPONSESTATE_DELETING

+ const INTAKERUNNERRESPONSESTATE_RECONCILING

+ const INTAKERUNNERRESPONSESTATE_UNKNOWN_DEFAULT_OPEN_API

+ func NewIntakeRunnerResponseStateFromValue(v string) (*IntakeRunnerResponseState, error)

+ func (v *IntakeRunnerResponseState) UnmarshalJSON(src []byte) error

+ func (v IntakeRunnerResponseState) IsValid() bool

+ func (v IntakeRunnerResponseState) Ptr() *IntakeRunnerResponseState

+ type IntakeUserResponseState string

+ const INTAKEUSERRESPONSESTATE_ACTIVE

+ const INTAKEUSERRESPONSESTATE_DELETING

+ const INTAKEUSERRESPONSESTATE_RECONCILING

+ const INTAKEUSERRESPONSESTATE_UNKNOWN_DEFAULT_OPEN_API

+ func NewIntakeUserResponseStateFromValue(v string) (*IntakeUserResponseState, error)

+ func (v *IntakeUserResponseState) UnmarshalJSON(src []byte) error

+ func (v IntakeUserResponseState) IsValid() bool

+ func (v IntakeUserResponseState) Ptr() *IntakeUserResponseState

+ type NullableIntakeResponseState struct

+ func NewNullableIntakeResponseState(val *IntakeResponseState) *NullableIntakeResponseState

+ func (v *NullableIntakeResponseState) Set(val *IntakeResponseState)

+ func (v *NullableIntakeResponseState) UnmarshalJSON(src []byte) error

+ func (v *NullableIntakeResponseState) Unset()

+ func (v NullableIntakeResponseState) Get() *IntakeResponseState

+ func (v NullableIntakeResponseState) IsSet() bool

+ func (v NullableIntakeResponseState) MarshalJSON() ([]byte, error)

+ type NullableIntakeRunnerResponseState struct

+ func NewNullableIntakeRunnerResponseState(val *IntakeRunnerResponseState) *NullableIntakeRunnerResponseState

+ func (v *NullableIntakeRunnerResponseState) Set(val *IntakeRunnerResponseState)

+ func (v *NullableIntakeRunnerResponseState) UnmarshalJSON(src []byte) error

+ func (v *NullableIntakeRunnerResponseState) Unset()

+ func (v NullableIntakeRunnerResponseState) Get() *IntakeRunnerResponseState

+ func (v NullableIntakeRunnerResponseState) IsSet() bool

+ func (v NullableIntakeRunnerResponseState) MarshalJSON() ([]byte, error)

+ type NullableIntakeUserResponseState struct

+ func NewNullableIntakeUserResponseState(val *IntakeUserResponseState) *NullableIntakeUserResponseState

+ func (v *NullableIntakeUserResponseState) Set(val *IntakeUserResponseState)

+ func (v *NullableIntakeUserResponseState) UnmarshalJSON(src []byte) error

+ func (v *NullableIntakeUserResponseState) Unset()

+ func (v NullableIntakeUserResponseState) Get() *IntakeUserResponseState

+ func (v NullableIntakeUserResponseState) IsSet() bool

+ func (v NullableIntakeUserResponseState) MarshalJSON() ([]byte, error)

v0.9.0

Apr 29, 2026

Changes in this version

type CatalogAuthType

+ const CATALOGAUTHTYPE_UNKNOWN_DEFAULT_OPEN_API

type PartitioningType

+ const PARTITIONINGTYPE_UNKNOWN_DEFAULT_OPEN_API

type PartitioningUpdateType

+ const PARTITIONINGUPDATETYPE_UNKNOWN_DEFAULT_OPEN_API

type UserType

+ const USERTYPE_UNKNOWN_DEFAULT_OPEN_API

v0.8.1

Apr 16, 2026

v0.8.0

Apr 13, 2026

v0.7.3

Apr 7, 2026

v0.7.2

Mar 31, 2026

v0.7.1

Mar 13, 2026

v0.7.0

Mar 13, 2026

Changes in this version

type CatalogAuth

+ AdditionalProperties map[string]interface{}

type CatalogAuthPatch

+ AdditionalProperties map[string]interface{}

+ func (o *CatalogAuthPatch) UnmarshalJSON(data []byte) (err error)

type ClientConfig

+ AdditionalProperties map[string]interface{}

type CreateIntakePayload

+ AdditionalProperties map[string]interface{}

type CreateIntakeRunnerPayload

+ AdditionalProperties map[string]interface{}

type CreateIntakeUserPayload

+ AdditionalProperties map[string]interface{}

type DremioAuth

+ AdditionalProperties map[string]interface{}

type DremioAuthPatch

+ AdditionalProperties map[string]interface{}

+ func (o *DremioAuthPatch) UnmarshalJSON(data []byte) (err error)

type IntakeCatalog

+ AdditionalProperties map[string]interface{}

type IntakeCatalogPatch

+ AdditionalProperties map[string]interface{}

+ func (o *IntakeCatalogPatch) UnmarshalJSON(data []byte) (err error)

type IntakeResponse

+ AdditionalProperties map[string]interface{}

type IntakeRunnerResponse

+ AdditionalProperties map[string]interface{}

type IntakeUserResponse

+ AdditionalProperties map[string]interface{}

type ListIntakeRunnersResponse

+ AdditionalProperties map[string]interface{}

type ListIntakeUsersResponse

+ AdditionalProperties map[string]interface{}

type ListIntakesResponse

+ AdditionalProperties map[string]interface{}

type UpdateIntakePayload

+ AdditionalProperties map[string]interface{}

type UpdateIntakeRunnerPayload

+ AdditionalProperties map[string]interface{}

+ func (o *UpdateIntakeRunnerPayload) UnmarshalJSON(data []byte) (err error)

type UpdateIntakeUserPayload

+ AdditionalProperties map[string]interface{}

+ func (o *UpdateIntakeUserPayload) UnmarshalJSON(data []byte) (err error)

v0.6.0

Mar 12, 2026

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL