sql

package

Go to main page

Versions in this module

v0

v0.51.0

Nov 7, 2024

v0.50.0

Oct 31, 2024

v0.49.0

Oct 14, 2024

Changes in this version

type Alert

+ NotifyOnOk bool

type CreateAlertRequestAlert

+ NotifyOnOk bool

type ListAlertsResponseAlert

+ NotifyOnOk bool

type UpdateAlertRequestAlert

+ NotifyOnOk bool

v0.48.0

Oct 3, 2024

v0.47.0

Oct 1, 2024

v0.46.0

Sep 4, 2024

v0.45.0

Aug 21, 2024

v0.44.0

Aug 13, 2024

Changes in this version

type Alert

+ Condition *AlertCondition

+ CreateTime string

+ CustomBody string

+ CustomSubject string

+ DisplayName string

+ LifecycleState LifecycleState

+ OwnerUserName string

+ ParentPath string

+ QueryId string

+ SecondsToRetrigger int

+ TriggerTime string

+ UpdateTime string

+ type AlertCondition struct

+ EmptyResultState AlertState

+ Op AlertOperator

+ Operand *AlertConditionOperand

+ Threshold *AlertConditionThreshold

+ type AlertConditionOperand struct

+ Column *AlertOperandColumn

+ type AlertConditionThreshold struct

+ Value *AlertOperandValue

+ type AlertOperandColumn struct

+ ForceSendFields []string

+ Name string

+ func (s *AlertOperandColumn) UnmarshalJSON(b []byte) error

+ func (s AlertOperandColumn) MarshalJSON() ([]byte, error)

+ type AlertOperandValue struct

+ BoolValue bool

+ DoubleValue float64

+ ForceSendFields []string

+ StringValue string

+ func (s *AlertOperandValue) UnmarshalJSON(b []byte) error

+ func (s AlertOperandValue) MarshalJSON() ([]byte, error)

+ type AlertOperator string

+ const AlertOperatorEqual

+ const AlertOperatorGreaterThan

+ const AlertOperatorGreaterThanOrEqual

+ const AlertOperatorIsNull

+ const AlertOperatorLessThan

+ const AlertOperatorLessThanOrEqual

+ const AlertOperatorNotEqual

+ func (f *AlertOperator) Set(v string) error

+ func (f *AlertOperator) String() string

+ func (f *AlertOperator) Type() string

type AlertsAPI

+ func (a *AlertsAPI) DeleteById(ctx context.Context, id string) error

+ func (a *AlertsAPI) GetByDisplayName(ctx context.Context, name string) (*ListAlertsResponseAlert, error)

+ func (a *AlertsAPI) GetById(ctx context.Context, id string) (*Alert, error)

+ func (a *AlertsAPI) ListAlertsResponseAlertDisplayNameToIdMap(ctx context.Context, request ListAlertsRequest) (map[string]string, error)

+ func (a *AlertsAPI) ListAll(ctx context.Context, request ListAlertsRequest) ([]ListAlertsResponseAlert, error)

type AlertsInterface

+ DeleteById func(ctx context.Context, id string) error

+ GetByDisplayName func(ctx context.Context, name string) (*ListAlertsResponseAlert, error)

+ GetById func(ctx context.Context, id string) (*Alert, error)

+ ListAlertsResponseAlertDisplayNameToIdMap func(ctx context.Context, request ListAlertsRequest) (map[string]string, error)

+ ListAll func(ctx context.Context, request ListAlertsRequest) ([]ListAlertsResponseAlert, error)

+ type AlertsLegacyAPI struct

+ func NewAlertsLegacy(client *client.DatabricksClient) *AlertsLegacyAPI

+ func (a *AlertsLegacyAPI) Create(ctx context.Context, request CreateAlert) (*LegacyAlert, error)

+ func (a *AlertsLegacyAPI) Delete(ctx context.Context, request DeleteAlertsLegacyRequest) error

+ func (a *AlertsLegacyAPI) DeleteByAlertId(ctx context.Context, alertId string) error

+ func (a *AlertsLegacyAPI) Get(ctx context.Context, request GetAlertsLegacyRequest) (*LegacyAlert, error)

+ func (a *AlertsLegacyAPI) GetByAlertId(ctx context.Context, alertId string) (*LegacyAlert, error)

+ func (a *AlertsLegacyAPI) GetByName(ctx context.Context, name string) (*LegacyAlert, error)

+ func (a *AlertsLegacyAPI) LegacyAlertNameToIdMap(ctx context.Context) (map[string]string, error)

+ func (a *AlertsLegacyAPI) List(ctx context.Context) ([]LegacyAlert, error)

+ func (a *AlertsLegacyAPI) Update(ctx context.Context, request EditAlert) error

+ type AlertsLegacyInterface interface

+ Create func(ctx context.Context, request CreateAlert) (*LegacyAlert, error)

+ Delete func(ctx context.Context, request DeleteAlertsLegacyRequest) error

+ DeleteByAlertId func(ctx context.Context, alertId string) error

+ Get func(ctx context.Context, request GetAlertsLegacyRequest) (*LegacyAlert, error)

+ GetByAlertId func(ctx context.Context, alertId string) (*LegacyAlert, error)

+ GetByName func(ctx context.Context, name string) (*LegacyAlert, error)

+ LegacyAlertNameToIdMap func(ctx context.Context) (map[string]string, error)

+ List func(ctx context.Context) ([]LegacyAlert, error)

+ Update func(ctx context.Context, request EditAlert) error

+ type AlertsLegacyService interface

+ Create func(ctx context.Context, request CreateAlert) (*LegacyAlert, error)

+ Delete func(ctx context.Context, request DeleteAlertsLegacyRequest) error

+ Get func(ctx context.Context, request GetAlertsLegacyRequest) (*LegacyAlert, error)

+ List func(ctx context.Context) ([]LegacyAlert, error)

+ Update func(ctx context.Context, request EditAlert) error

+ type ClientCallContext struct

+ FileName *EncodedText

+ ForceSendFields []string

+ LineNumber int

+ func (s *ClientCallContext) UnmarshalJSON(b []byte) error

+ func (s ClientCallContext) MarshalJSON() ([]byte, error)

+ type ContextFilter struct

+ DbsqlAlertId string

+ DbsqlDashboardId string

+ DbsqlQueryId string

+ DbsqlSessionId string

+ ForceSendFields []string

+ JobId string

+ JobRunId string

+ LakeviewDashboardId string

+ NotebookCellRunId string

+ NotebookId string

+ StatementIds []string

+ func (s *ContextFilter) UnmarshalJSON(b []byte) error

+ func (s ContextFilter) MarshalJSON() ([]byte, error)

+ type CreateAlertRequest struct

+ Alert *CreateAlertRequestAlert

+ type CreateAlertRequestAlert struct

+ Condition *AlertCondition

+ CustomBody string

+ CustomSubject string

+ DisplayName string

+ ForceSendFields []string

+ ParentPath string

+ QueryId string

+ SecondsToRetrigger int

+ func (s *CreateAlertRequestAlert) UnmarshalJSON(b []byte) error

+ func (s CreateAlertRequestAlert) MarshalJSON() ([]byte, error)

+ type CreateQueryRequest struct

+ Query *CreateQueryRequestQuery

+ type CreateQueryRequestQuery struct

+ ApplyAutoLimit bool

+ Catalog string

+ Description string

+ DisplayName string

+ ForceSendFields []string

+ Parameters []QueryParameter

+ ParentPath string

+ QueryText string

+ RunAsMode RunAsMode

+ Schema string

+ Tags []string

+ WarehouseId string

+ func (s *CreateQueryRequestQuery) UnmarshalJSON(b []byte) error

+ func (s CreateQueryRequestQuery) MarshalJSON() ([]byte, error)

+ type CreateQueryVisualizationsLegacyRequest struct

+ Description string

+ ForceSendFields []string

+ Name string

+ Options any

+ QueryId string

+ Type string

+ func (s *CreateQueryVisualizationsLegacyRequest) UnmarshalJSON(b []byte) error

+ func (s CreateQueryVisualizationsLegacyRequest) MarshalJSON() ([]byte, error)

+ type CreateVisualizationRequest struct

+ Visualization *CreateVisualizationRequestVisualization

+ type CreateVisualizationRequestVisualization struct

+ DisplayName string

+ ForceSendFields []string

+ QueryId string

+ SerializedOptions string

+ SerializedQueryPlan string

+ Type string

+ func (s *CreateVisualizationRequestVisualization) UnmarshalJSON(b []byte) error

+ func (s CreateVisualizationRequestVisualization) MarshalJSON() ([]byte, error)

+ type DatePrecision string

+ const DatePrecisionDayPrecision

+ const DatePrecisionMinutePrecision

+ const DatePrecisionSecondPrecision

+ func (f *DatePrecision) Set(v string) error

+ func (f *DatePrecision) String() string

+ func (f *DatePrecision) Type() string

+ type DateRange struct

+ End string

+ Start string

+ type DateRangeValue struct

+ DateRangeValue *DateRange

+ DynamicDateRangeValue DateRangeValueDynamicDateRange

+ ForceSendFields []string

+ Precision DatePrecision

+ StartDayOfWeek int

+ func (s *DateRangeValue) UnmarshalJSON(b []byte) error

+ func (s DateRangeValue) MarshalJSON() ([]byte, error)

+ type DateRangeValueDynamicDateRange string

+ const DateRangeValueDynamicDateRangeLast12Months

+ const DateRangeValueDynamicDateRangeLast14Days

+ const DateRangeValueDynamicDateRangeLast24Hours

+ const DateRangeValueDynamicDateRangeLast30Days

+ const DateRangeValueDynamicDateRangeLast60Days

+ const DateRangeValueDynamicDateRangeLast7Days

+ const DateRangeValueDynamicDateRangeLast8Hours

+ const DateRangeValueDynamicDateRangeLast90Days

+ const DateRangeValueDynamicDateRangeLastHour

+ const DateRangeValueDynamicDateRangeLastMonth

+ const DateRangeValueDynamicDateRangeLastWeek

+ const DateRangeValueDynamicDateRangeLastYear

+ const DateRangeValueDynamicDateRangeThisMonth

+ const DateRangeValueDynamicDateRangeThisWeek

+ const DateRangeValueDynamicDateRangeThisYear

+ const DateRangeValueDynamicDateRangeToday

+ const DateRangeValueDynamicDateRangeYesterday

+ func (f *DateRangeValueDynamicDateRange) Set(v string) error

+ func (f *DateRangeValueDynamicDateRange) String() string

+ func (f *DateRangeValueDynamicDateRange) Type() string

+ type DateValue struct

+ DateValue string

+ DynamicDateValue DateValueDynamicDate

+ ForceSendFields []string

+ Precision DatePrecision

+ func (s *DateValue) UnmarshalJSON(b []byte) error

+ func (s DateValue) MarshalJSON() ([]byte, error)

+ type DateValueDynamicDate string

+ const DateValueDynamicDateNow

+ const DateValueDynamicDateYesterday

+ func (f *DateValueDynamicDate) Set(v string) error

+ func (f *DateValueDynamicDate) String() string

+ func (f *DateValueDynamicDate) Type() string

+ type DeleteAlertsLegacyRequest struct

+ AlertId string

+ type DeleteQueriesLegacyRequest struct

+ QueryId string

+ type DeleteQueryVisualizationsLegacyRequest struct

+ Id string

+ type DeleteVisualizationRequest struct

+ Id string

+ type Empty struct

+ type EncodedText struct

+ Encoding EncodedTextEncoding

+ ForceSendFields []string

+ Text string

+ func (s *EncodedText) UnmarshalJSON(b []byte) error

+ func (s EncodedText) MarshalJSON() ([]byte, error)

+ type EncodedTextEncoding string

+ const EncodedTextEncodingBase64

+ const EncodedTextEncodingPlain

+ func (f *EncodedTextEncoding) Set(v string) error

+ func (f *EncodedTextEncoding) String() string

+ func (f *EncodedTextEncoding) Type() string

+ type EnumValue struct

+ EnumOptions string

+ ForceSendFields []string

+ MultiValuesOptions *MultiValuesOptions

+ Values []string

+ func (s *EnumValue) UnmarshalJSON(b []byte) error

+ func (s EnumValue) MarshalJSON() ([]byte, error)

type GetAlertRequest

+ Id string

+ type GetAlertsLegacyRequest struct

+ AlertId string

+ type GetQueriesLegacyRequest struct

+ QueryId string

type GetQueryRequest

+ Id string

+ type LegacyAlert struct

+ CreatedAt string

+ ForceSendFields []string

+ Id string

+ LastTriggeredAt string

+ Name string

+ Options *AlertOptions

+ Parent string

+ Query *AlertQuery

+ Rearm int

+ State LegacyAlertState

+ UpdatedAt string

+ User *User

+ func (s *LegacyAlert) UnmarshalJSON(b []byte) error

+ func (s LegacyAlert) MarshalJSON() ([]byte, error)

+ type LegacyAlertState string

+ const LegacyAlertStateOk

+ const LegacyAlertStateTriggered

+ const LegacyAlertStateUnknown

+ func (f *LegacyAlertState) Set(v string) error

+ func (f *LegacyAlertState) String() string

+ func (f *LegacyAlertState) Type() string

+ type LegacyQuery struct

+ CanEdit bool

+ CreatedAt string

+ DataSourceId string

+ Description string

+ ForceSendFields []string

+ Id string

+ IsArchived bool

+ IsDraft bool

+ IsFavorite bool

+ IsSafe bool

+ LastModifiedBy *User

+ LastModifiedById int

+ LatestQueryDataId string

+ Name string

+ Options *QueryOptions

+ Parent string

+ PermissionTier PermissionLevel

+ Query string

+ QueryHash string

+ RunAsRole RunAsRole

+ Tags []string

+ UpdatedAt string

+ User *User

+ UserId int

+ Visualizations []LegacyVisualization

+ func (s *LegacyQuery) UnmarshalJSON(b []byte) error

+ func (s LegacyQuery) MarshalJSON() ([]byte, error)

+ type LegacyVisualization struct

+ CreatedAt string

+ Description string

+ ForceSendFields []string

+ Id string

+ Name string

+ Options any

+ Query *LegacyQuery

+ Type string

+ UpdatedAt string

+ func (s *LegacyVisualization) UnmarshalJSON(b []byte) error

+ func (s LegacyVisualization) MarshalJSON() ([]byte, error)

+ type LifecycleState string

+ const LifecycleStateActive

+ const LifecycleStateTrashed

+ func (f *LifecycleState) Set(v string) error

+ func (f *LifecycleState) String() string

+ func (f *LifecycleState) Type() string

+ type ListAlertsRequest struct

+ ForceSendFields []string

+ PageSize int

+ PageToken string

+ func (s *ListAlertsRequest) UnmarshalJSON(b []byte) error

+ func (s ListAlertsRequest) MarshalJSON() ([]byte, error)

+ type ListAlertsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ Results []ListAlertsResponseAlert

+ func (s *ListAlertsResponse) UnmarshalJSON(b []byte) error

+ func (s ListAlertsResponse) MarshalJSON() ([]byte, error)

+ type ListAlertsResponseAlert struct

+ Condition *AlertCondition

+ CreateTime string

+ CustomBody string

+ CustomSubject string

+ DisplayName string

+ ForceSendFields []string

+ Id string

+ LifecycleState LifecycleState

+ OwnerUserName string

+ QueryId string

+ SecondsToRetrigger int

+ State AlertState

+ TriggerTime string

+ UpdateTime string

+ func (s *ListAlertsResponseAlert) UnmarshalJSON(b []byte) error

+ func (s ListAlertsResponseAlert) MarshalJSON() ([]byte, error)

+ type ListQueriesLegacyRequest struct

+ ForceSendFields []string

+ Order string

+ Page int

+ PageSize int

+ Q string

+ func (s *ListQueriesLegacyRequest) UnmarshalJSON(b []byte) error

+ func (s ListQueriesLegacyRequest) MarshalJSON() ([]byte, error)

type ListQueriesRequest

+ PageToken string

+ type ListQueryObjectsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ Results []ListQueryObjectsResponseQuery

+ func (s *ListQueryObjectsResponse) UnmarshalJSON(b []byte) error

+ func (s ListQueryObjectsResponse) MarshalJSON() ([]byte, error)

+ type ListQueryObjectsResponseQuery struct

+ ApplyAutoLimit bool

+ Catalog string

+ CreateTime string

+ Description string

+ DisplayName string

+ ForceSendFields []string

+ Id string

+ LastModifierUserName string

+ LifecycleState LifecycleState

+ OwnerUserName string

+ Parameters []QueryParameter

+ QueryText string

+ RunAsMode RunAsMode

+ Schema string

+ Tags []string

+ UpdateTime string

+ WarehouseId string

+ func (s *ListQueryObjectsResponseQuery) UnmarshalJSON(b []byte) error

+ func (s ListQueryObjectsResponseQuery) MarshalJSON() ([]byte, error)

+ type ListVisualizationsForQueryRequest struct

+ ForceSendFields []string

+ Id string

+ PageSize int

+ PageToken string

+ func (s *ListVisualizationsForQueryRequest) UnmarshalJSON(b []byte) error

+ func (s ListVisualizationsForQueryRequest) MarshalJSON() ([]byte, error)

+ type ListVisualizationsForQueryResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ Results []Visualization

+ func (s *ListVisualizationsForQueryResponse) UnmarshalJSON(b []byte) error

+ func (s ListVisualizationsForQueryResponse) MarshalJSON() ([]byte, error)

+ type NumericValue struct

+ ForceSendFields []string

+ Value float64

+ func (s *NumericValue) UnmarshalJSON(b []byte) error

+ func (s NumericValue) MarshalJSON() ([]byte, error)

type QueriesAPI

+ func (a *QueriesAPI) DeleteById(ctx context.Context, id string) error

+ func (a *QueriesAPI) GetByDisplayName(ctx context.Context, name string) (*ListQueryObjectsResponseQuery, error)

+ func (a *QueriesAPI) GetById(ctx context.Context, id string) (*Query, error)

+ func (a *QueriesAPI) ListQueryObjectsResponseQueryDisplayNameToIdMap(ctx context.Context, request ListQueriesRequest) (map[string]string, error)

+ func (a *QueriesAPI) ListVisualizations(ctx context.Context, request ListVisualizationsForQueryRequest) listing.Iterator[Visualization]

+ func (a *QueriesAPI) ListVisualizationsAll(ctx context.Context, request ListVisualizationsForQueryRequest) ([]Visualization, error)

+ func (a *QueriesAPI) ListVisualizationsById(ctx context.Context, id string) (*ListVisualizationsForQueryResponse, error)

type QueriesInterface

+ DeleteById func(ctx context.Context, id string) error

+ GetByDisplayName func(ctx context.Context, name string) (*ListQueryObjectsResponseQuery, error)

+ GetById func(ctx context.Context, id string) (*Query, error)

+ ListQueryObjectsResponseQueryDisplayNameToIdMap func(ctx context.Context, request ListQueriesRequest) (map[string]string, error)

+ ListVisualizations func(ctx context.Context, request ListVisualizationsForQueryRequest) listing.Iterator[Visualization]

+ ListVisualizationsAll func(ctx context.Context, request ListVisualizationsForQueryRequest) ([]Visualization, error)

+ ListVisualizationsById func(ctx context.Context, id string) (*ListVisualizationsForQueryResponse, error)

+ type QueriesLegacyAPI struct

+ func NewQueriesLegacy(client *client.DatabricksClient) *QueriesLegacyAPI

+ func (a *QueriesLegacyAPI) Create(ctx context.Context, request QueryPostContent) (*LegacyQuery, error)

+ func (a *QueriesLegacyAPI) Delete(ctx context.Context, request DeleteQueriesLegacyRequest) error

+ func (a *QueriesLegacyAPI) DeleteByQueryId(ctx context.Context, queryId string) error

+ func (a *QueriesLegacyAPI) Get(ctx context.Context, request GetQueriesLegacyRequest) (*LegacyQuery, error)

+ func (a *QueriesLegacyAPI) GetByName(ctx context.Context, name string) (*LegacyQuery, error)

+ func (a *QueriesLegacyAPI) GetByQueryId(ctx context.Context, queryId string) (*LegacyQuery, error)

+ func (a *QueriesLegacyAPI) LegacyQueryNameToIdMap(ctx context.Context, request ListQueriesLegacyRequest) (map[string]string, error)

+ func (a *QueriesLegacyAPI) List(ctx context.Context, request ListQueriesLegacyRequest) listing.Iterator[LegacyQuery]

+ func (a *QueriesLegacyAPI) ListAll(ctx context.Context, request ListQueriesLegacyRequest) ([]LegacyQuery, error)

+ func (a *QueriesLegacyAPI) Restore(ctx context.Context, request RestoreQueriesLegacyRequest) error

+ func (a *QueriesLegacyAPI) Update(ctx context.Context, request QueryEditContent) (*LegacyQuery, error)

+ type QueriesLegacyInterface interface

+ Create func(ctx context.Context, request QueryPostContent) (*LegacyQuery, error)

+ Delete func(ctx context.Context, request DeleteQueriesLegacyRequest) error

+ DeleteByQueryId func(ctx context.Context, queryId string) error

+ Get func(ctx context.Context, request GetQueriesLegacyRequest) (*LegacyQuery, error)

+ GetByName func(ctx context.Context, name string) (*LegacyQuery, error)

+ GetByQueryId func(ctx context.Context, queryId string) (*LegacyQuery, error)

+ LegacyQueryNameToIdMap func(ctx context.Context, request ListQueriesLegacyRequest) (map[string]string, error)

+ List func(ctx context.Context, request ListQueriesLegacyRequest) listing.Iterator[LegacyQuery]

+ ListAll func(ctx context.Context, request ListQueriesLegacyRequest) ([]LegacyQuery, error)

+ Restore func(ctx context.Context, request RestoreQueriesLegacyRequest) error

+ Update func(ctx context.Context, request QueryEditContent) (*LegacyQuery, error)

+ type QueriesLegacyService interface

+ Create func(ctx context.Context, request QueryPostContent) (*LegacyQuery, error)

+ Delete func(ctx context.Context, request DeleteQueriesLegacyRequest) error

+ Get func(ctx context.Context, request GetQueriesLegacyRequest) (*LegacyQuery, error)

+ List func(ctx context.Context, request ListQueriesLegacyRequest) (*QueryList, error)

+ Restore func(ctx context.Context, request RestoreQueriesLegacyRequest) error

+ Update func(ctx context.Context, request QueryEditContent) (*LegacyQuery, error)

type QueriesService

+ ListVisualizations func(ctx context.Context, request ListVisualizationsForQueryRequest) (*ListVisualizationsForQueryResponse, error)

type Query

+ ApplyAutoLimit bool

+ Catalog string

+ CreateTime string

+ DisplayName string

+ LastModifierUserName string

+ LifecycleState LifecycleState

+ OwnerUserName string

+ Parameters []QueryParameter

+ ParentPath string

+ QueryText string

+ RunAsMode RunAsMode

+ Schema string

+ UpdateTime string

+ WarehouseId string

+ type QueryBackedValue struct

+ ForceSendFields []string

+ MultiValuesOptions *MultiValuesOptions

+ QueryId string

+ Values []string

+ func (s *QueryBackedValue) UnmarshalJSON(b []byte) error

+ func (s QueryBackedValue) MarshalJSON() ([]byte, error)

type QueryFilter

+ ContextFilter *ContextFilter

type QueryInfo

+ QuerySource *QuerySource

+ type QueryParameter struct

+ DateRangeValue *DateRangeValue

+ DateValue *DateValue

+ EnumValue *EnumValue

+ ForceSendFields []string

+ Name string

+ NumericValue *NumericValue

+ QueryBackedValue *QueryBackedValue

+ TextValue *TextValue

+ Title string

+ func (s *QueryParameter) UnmarshalJSON(b []byte) error

+ func (s QueryParameter) MarshalJSON() ([]byte, error)

+ type QuerySource struct

+ AlertId string

+ ClientCallContext *ClientCallContext

+ CommandId string

+ CommandRunId string

+ DashboardId string

+ DashboardV3Id string

+ DriverInfo *QuerySourceDriverInfo

+ EntryPoint QuerySourceEntryPoint

+ ForceSendFields []string

+ GenieSpaceId string

+ IsCloudFetch bool

+ IsDatabricksSqlExecApi bool

+ JobId string

+ JobManagedBy QuerySourceJobManager

+ NotebookId string

+ PipelineId string

+ PipelineUpdateId string

+ QueryTags string

+ RunId string

+ RunnableCommandId string

+ ScheduledBy QuerySourceTrigger

+ ServerlessChannelInfo *ServerlessChannelInfo

+ SourceQueryId string

+ func (s *QuerySource) UnmarshalJSON(b []byte) error

+ func (s QuerySource) MarshalJSON() ([]byte, error)

+ type QuerySourceDriverInfo struct

+ BiToolEntry string

+ DriverName string

+ ForceSendFields []string

+ SimbaBrandingVendor string

+ VersionNumber string

+ func (s *QuerySourceDriverInfo) UnmarshalJSON(b []byte) error

+ func (s QuerySourceDriverInfo) MarshalJSON() ([]byte, error)

+ type QuerySourceEntryPoint string

+ const QuerySourceEntryPointDlt

+ const QuerySourceEntryPointSparkConnect

+ const QuerySourceEntryPointThriftServer

+ func (f *QuerySourceEntryPoint) Set(v string) error

+ func (f *QuerySourceEntryPoint) String() string

+ func (f *QuerySourceEntryPoint) Type() string

+ type QuerySourceJobManager string

+ const QuerySourceJobManagerAppSystemTable

+ const QuerySourceJobManagerAutoMaintenance

+ const QuerySourceJobManagerAutoml

+ const QuerySourceJobManagerCleanRooms

+ const QuerySourceJobManagerDataMonitoring

+ const QuerySourceJobManagerDataSharing

+ const QuerySourceJobManagerEncryption

+ const QuerySourceJobManagerFabricCrawler

+ const QuerySourceJobManagerJobs

+ const QuerySourceJobManagerLakeview

+ const QuerySourceJobManagerManagedRag

+ const QuerySourceJobManagerScheduledMvRefresh

+ const QuerySourceJobManagerTesting

+ func (f *QuerySourceJobManager) Set(v string) error

+ func (f *QuerySourceJobManager) String() string

+ func (f *QuerySourceJobManager) Type() string

+ type QuerySourceTrigger string

+ const QuerySourceTriggerManual

+ const QuerySourceTriggerScheduled

+ func (f *QuerySourceTrigger) Set(v string) error

+ func (f *QuerySourceTrigger) String() string

+ func (f *QuerySourceTrigger) Type() string

type QueryStatus

+ const QueryStatusCompiled

+ const QueryStatusCompiling

+ const QueryStatusStarted

+ type QueryVisualizationsLegacyAPI struct

+ func NewQueryVisualizationsLegacy(client *client.DatabricksClient) *QueryVisualizationsLegacyAPI

+ func (a *QueryVisualizationsLegacyAPI) Create(ctx context.Context, request CreateQueryVisualizationsLegacyRequest) (*LegacyVisualization, error)

+ func (a *QueryVisualizationsLegacyAPI) Delete(ctx context.Context, request DeleteQueryVisualizationsLegacyRequest) error

+ func (a *QueryVisualizationsLegacyAPI) DeleteById(ctx context.Context, id string) error

+ func (a *QueryVisualizationsLegacyAPI) Update(ctx context.Context, request LegacyVisualization) (*LegacyVisualization, error)

+ type QueryVisualizationsLegacyInterface interface

+ Create func(ctx context.Context, request CreateQueryVisualizationsLegacyRequest) (*LegacyVisualization, error)

+ Delete func(ctx context.Context, request DeleteQueryVisualizationsLegacyRequest) error

+ DeleteById func(ctx context.Context, id string) error

+ Update func(ctx context.Context, request LegacyVisualization) (*LegacyVisualization, error)

+ type QueryVisualizationsLegacyService interface

+ Create func(ctx context.Context, request CreateQueryVisualizationsLegacyRequest) (*LegacyVisualization, error)

+ Delete func(ctx context.Context, request DeleteQueryVisualizationsLegacyRequest) error

+ Update func(ctx context.Context, request LegacyVisualization) (*LegacyVisualization, error)

+ type RestoreQueriesLegacyRequest struct

+ QueryId string

+ type RunAsMode string

+ const RunAsModeOwner

+ const RunAsModeViewer

+ func (f *RunAsMode) Set(v string) error

+ func (f *RunAsMode) String() string

+ func (f *RunAsMode) Type() string

+ type ServerlessChannelInfo struct

+ Name ChannelName

+ type StatementResponse struct

+ ForceSendFields []string

+ Manifest *ResultManifest

+ Result *ResultData

+ StatementId string

+ Status *StatementStatus

+ func (s *StatementResponse) UnmarshalJSON(b []byte) error

+ func (s StatementResponse) MarshalJSON() ([]byte, error)

+ type TextValue struct

+ ForceSendFields []string

+ Value string

+ func (s *TextValue) UnmarshalJSON(b []byte) error

+ func (s TextValue) MarshalJSON() ([]byte, error)

+ type TrashAlertRequest struct

+ Id string

+ type TrashQueryRequest struct

+ Id string

+ type UpdateAlertRequest struct

+ Alert *UpdateAlertRequestAlert

+ Id string

+ UpdateMask string

+ type UpdateAlertRequestAlert struct

+ Condition *AlertCondition

+ CustomBody string

+ CustomSubject string

+ DisplayName string

+ ForceSendFields []string

+ OwnerUserName string

+ QueryId string

+ SecondsToRetrigger int

+ func (s *UpdateAlertRequestAlert) UnmarshalJSON(b []byte) error

+ func (s UpdateAlertRequestAlert) MarshalJSON() ([]byte, error)

+ type UpdateQueryRequest struct

+ Id string

+ Query *UpdateQueryRequestQuery

+ UpdateMask string

+ type UpdateQueryRequestQuery struct

+ ApplyAutoLimit bool

+ Catalog string

+ Description string

+ DisplayName string

+ ForceSendFields []string

+ OwnerUserName string

+ Parameters []QueryParameter

+ QueryText string

+ RunAsMode RunAsMode

+ Schema string

+ Tags []string

+ WarehouseId string

+ func (s *UpdateQueryRequestQuery) UnmarshalJSON(b []byte) error

+ func (s UpdateQueryRequestQuery) MarshalJSON() ([]byte, error)

+ type UpdateVisualizationRequest struct

+ Id string

+ UpdateMask string

+ Visualization *UpdateVisualizationRequestVisualization

+ type UpdateVisualizationRequestVisualization struct

+ DisplayName string

+ ForceSendFields []string

+ SerializedOptions string

+ SerializedQueryPlan string

+ Type string

+ func (s *UpdateVisualizationRequestVisualization) UnmarshalJSON(b []byte) error

+ func (s UpdateVisualizationRequestVisualization) MarshalJSON() ([]byte, error)

type Visualization

+ CreateTime string

+ DisplayName string

+ QueryId string

+ SerializedOptions string

+ SerializedQueryPlan string

+ UpdateTime string

type WarehousePermissionLevel

+ const WarehousePermissionLevelCanMonitor

v0.43.2

Jul 9, 2024

v0.43.1

Jul 8, 2024

v0.43.0

Jun 24, 2024

v0.42.0

Jun 3, 2024

v0.41.0

May 21, 2024

v0.40.1

May 14, 2024

v0.40.0

May 2, 2024

Changes in this version

type DashboardEditContent

+ Tags []string

type QueryEditContent

+ Tags []string

type QueryOptions

+ Catalog string

+ Schema string

type QueryPostContent

+ Tags []string

type Visualization

+ Query *Query

v0.39.0

Apr 24, 2024

v0.38.0

Apr 11, 2024

v0.37.0

Mar 28, 2024

v0.36.0

Mar 20, 2024

v0.35.0

Mar 20, 2024

v0.34.0

Mar 5, 2024

Changes in this version

+ type CancelExecutionResponse struct

+ type DeleteResponse struct

+ type DeleteWarehouseResponse struct

+ type EditWarehouseResponse struct

+ type RestoreResponse struct

+ type SetWorkspaceWarehouseConfigResponse struct

+ type StartWarehouseResponse struct

+ type StopWarehouseResponse struct

+ type UpdateResponse struct

v0.33.0

Feb 19, 2024

v0.32.0

Feb 14, 2024

Changes in this version

+ type MultiValuesOptions struct

+ ForceSendFields []string

+ Prefix string

+ Separator string

+ Suffix string

+ func (s *MultiValuesOptions) UnmarshalJSON(b []byte) error

+ func (s MultiValuesOptions) MarshalJSON() ([]byte, error)

type Parameter

+ EnumOptions string

+ MultiValuesOptions *MultiValuesOptions

+ QueryId string

type ParameterType

+ const ParameterTypeEnum

+ const ParameterTypeQuery

v0.31.0

Feb 8, 2024

v0.30.1

Jan 25, 2024

v0.30.0

Jan 24, 2024

Changes in this version

+ type DashboardEditContent struct

+ DashboardId string

+ ForceSendFields []string

+ Name string

+ RunAsRole RunAsRole

+ func (s *DashboardEditContent) UnmarshalJSON(b []byte) error

+ func (s DashboardEditContent) MarshalJSON() ([]byte, error)

+ type DashboardPostContent struct

+ DashboardFiltersEnabled bool

+ ForceSendFields []string

+ IsFavorite bool

+ Name string

+ Parent string

+ RunAsRole RunAsRole

+ Tags []string

+ func (s *DashboardPostContent) UnmarshalJSON(b []byte) error

+ func (s DashboardPostContent) MarshalJSON() ([]byte, error)

type DashboardsAPI

+ func (a *DashboardsAPI) Update(ctx context.Context, request DashboardEditContent) (*Dashboard, error)

type DashboardsInterface

+ Update func(ctx context.Context, request DashboardEditContent) (*Dashboard, error)

type DashboardsService

+ Update func(ctx context.Context, request DashboardEditContent) (*Dashboard, error)

type ExternalLink

+ HttpHeaders map[string]string

type QueryEditContent

+ RunAsRole RunAsRole

v0.29.1

Jan 16, 2024

Changes in this version

type WaitGetWarehouseRunning

+ Poll func(time.Duration, func(*GetWarehouseResponse)) (*GetWarehouseResponse, error)

type WaitGetWarehouseStopped

+ Poll func(time.Duration, func(*GetWarehouseResponse)) (*GetWarehouseResponse, error)

v0.29.0

Jan 10, 2024

Changes in this version

+ type AlertsInterface interface

+ AlertNameToIdMap func(ctx context.Context) (map[string]string, error)

+ Create func(ctx context.Context, request CreateAlert) (*Alert, error)

+ Delete func(ctx context.Context, request DeleteAlertRequest) error

+ DeleteByAlertId func(ctx context.Context, alertId string) error

+ Get func(ctx context.Context, request GetAlertRequest) (*Alert, error)

+ GetByAlertId func(ctx context.Context, alertId string) (*Alert, error)

+ GetByName func(ctx context.Context, name string) (*Alert, error)

+ Impl func() AlertsService

+ List func(ctx context.Context) ([]Alert, error)

+ Update func(ctx context.Context, request EditAlert) error

+ WithImpl func(impl AlertsService) AlertsInterface

+ type DashboardWidgetsInterface interface

+ Create func(ctx context.Context, request CreateWidget) (*Widget, error)

+ Delete func(ctx context.Context, request DeleteDashboardWidgetRequest) error

+ DeleteById func(ctx context.Context, id string) error

+ Impl func() DashboardWidgetsService

+ Update func(ctx context.Context, request CreateWidget) (*Widget, error)

+ WithImpl func(impl DashboardWidgetsService) DashboardWidgetsInterface

+ type DashboardsInterface interface

+ Create func(ctx context.Context, request CreateDashboardRequest) (*Dashboard, error)

+ DashboardNameToIdMap func(ctx context.Context, request ListDashboardsRequest) (map[string]string, error)

+ Delete func(ctx context.Context, request DeleteDashboardRequest) error

+ DeleteByDashboardId func(ctx context.Context, dashboardId string) error

+ Get func(ctx context.Context, request GetDashboardRequest) (*Dashboard, error)

+ GetByDashboardId func(ctx context.Context, dashboardId string) (*Dashboard, error)

+ GetByName func(ctx context.Context, name string) (*Dashboard, error)

+ Impl func() DashboardsService

+ List func(ctx context.Context, request ListDashboardsRequest) *listing.DeduplicatingIterator[Dashboard, string]

+ ListAll func(ctx context.Context, request ListDashboardsRequest) ([]Dashboard, error)

+ Restore func(ctx context.Context, request RestoreDashboardRequest) error

+ WithImpl func(impl DashboardsService) DashboardsInterface

+ type DataSourcesInterface interface

+ DataSourceNameToIdMap func(ctx context.Context) (map[string]string, error)

+ GetByName func(ctx context.Context, name string) (*DataSource, error)

+ Impl func() DataSourcesService

+ List func(ctx context.Context) ([]DataSource, error)

+ WithImpl func(impl DataSourcesService) DataSourcesInterface

+ type DbsqlPermissionsInterface interface

+ Get func(ctx context.Context, request GetDbsqlPermissionRequest) (*GetResponse, error)

+ GetByObjectTypeAndObjectId func(ctx context.Context, objectType ObjectTypePlural, objectId string) (*GetResponse, error)

+ Impl func() DbsqlPermissionsService

+ Set func(ctx context.Context, request SetRequest) (*SetResponse, error)

+ TransferOwnership func(ctx context.Context, request TransferOwnershipRequest) (*Success, error)

+ WithImpl func(impl DbsqlPermissionsService) DbsqlPermissionsInterface

type PermissionLevel

+ const PermissionLevelCanEdit

+ type QueriesInterface interface

+ Create func(ctx context.Context, request QueryPostContent) (*Query, error)

+ Delete func(ctx context.Context, request DeleteQueryRequest) error

+ DeleteByQueryId func(ctx context.Context, queryId string) error

+ Get func(ctx context.Context, request GetQueryRequest) (*Query, error)

+ GetByName func(ctx context.Context, name string) (*Query, error)

+ GetByQueryId func(ctx context.Context, queryId string) (*Query, error)

+ Impl func() QueriesService

+ List func(ctx context.Context, request ListQueriesRequest) *listing.DeduplicatingIterator[Query, string]

+ ListAll func(ctx context.Context, request ListQueriesRequest) ([]Query, error)

+ QueryNameToIdMap func(ctx context.Context, request ListQueriesRequest) (map[string]string, error)

+ Restore func(ctx context.Context, request RestoreQueryRequest) error

+ Update func(ctx context.Context, request QueryEditContent) (*Query, error)

+ WithImpl func(impl QueriesService) QueriesInterface

+ type QueryHistoryInterface interface

+ Impl func() QueryHistoryService

+ List func(ctx context.Context, request ListQueryHistoryRequest) ...

+ ListAll func(ctx context.Context, request ListQueryHistoryRequest) ([]QueryInfo, error)

+ WithImpl func(impl QueryHistoryService) QueryHistoryInterface

+ type QueryVisualizationsInterface interface

+ Create func(ctx context.Context, request CreateQueryVisualizationRequest) (*Visualization, error)

+ Delete func(ctx context.Context, request DeleteQueryVisualizationRequest) error

+ DeleteById func(ctx context.Context, id string) error

+ Impl func() QueryVisualizationsService

+ Update func(ctx context.Context, request Visualization) (*Visualization, error)

+ WithImpl func(impl QueryVisualizationsService) QueryVisualizationsInterface

+ type StatementExecutionInterface interface

+ CancelExecution func(ctx context.Context, request CancelExecutionRequest) error

+ ExecuteStatement func(ctx context.Context, request ExecuteStatementRequest) (*ExecuteStatementResponse, error)

+ GetStatement func(ctx context.Context, request GetStatementRequest) (*GetStatementResponse, error)

+ GetStatementByStatementId func(ctx context.Context, statementId string) (*GetStatementResponse, error)

+ GetStatementResultChunkN func(ctx context.Context, request GetStatementResultChunkNRequest) (*ResultData, error)

+ GetStatementResultChunkNByStatementIdAndChunkIndex func(ctx context.Context, statementId string, chunkIndex int) (*ResultData, error)

+ Impl func() StatementExecutionService

+ WithImpl func(impl StatementExecutionService) StatementExecutionInterface

+ type WarehousesInterface interface

+ Create func(ctx context.Context, createWarehouseRequest CreateWarehouseRequest) (*WaitGetWarehouseRunning[CreateWarehouseResponse], error)

+ CreateAndWait func(ctx context.Context, createWarehouseRequest CreateWarehouseRequest, ...) (*GetWarehouseResponse, error)

+ Delete func(ctx context.Context, request DeleteWarehouseRequest) error

+ DeleteById func(ctx context.Context, id string) error

+ Edit func(ctx context.Context, editWarehouseRequest EditWarehouseRequest) (*WaitGetWarehouseRunning[any], error)

+ EditAndWait func(ctx context.Context, editWarehouseRequest EditWarehouseRequest, ...) (*GetWarehouseResponse, error)

+ EndpointInfoNameToIdMap func(ctx context.Context, request ListWarehousesRequest) (map[string]string, error)

+ Get func(ctx context.Context, request GetWarehouseRequest) (*GetWarehouseResponse, error)

+ GetById func(ctx context.Context, id string) (*GetWarehouseResponse, error)

+ GetByName func(ctx context.Context, name string) (*EndpointInfo, error)

+ GetPermissionLevels func(ctx context.Context, request GetWarehousePermissionLevelsRequest) (*GetWarehousePermissionLevelsResponse, error)

+ GetPermissionLevelsByWarehouseId func(ctx context.Context, warehouseId string) (*GetWarehousePermissionLevelsResponse, error)

+ GetPermissions func(ctx context.Context, request GetWarehousePermissionsRequest) (*WarehousePermissions, error)

+ GetPermissionsByWarehouseId func(ctx context.Context, warehouseId string) (*WarehousePermissions, error)

+ GetWorkspaceWarehouseConfig func(ctx context.Context) (*GetWorkspaceWarehouseConfigResponse, error)

+ Impl func() WarehousesService

+ List func(ctx context.Context, request ListWarehousesRequest) ...

+ ListAll func(ctx context.Context, request ListWarehousesRequest) ([]EndpointInfo, error)

+ SetPermissions func(ctx context.Context, request WarehousePermissionsRequest) (*WarehousePermissions, error)

+ SetWorkspaceWarehouseConfig func(ctx context.Context, request SetWorkspaceWarehouseConfigRequest) error

+ Start func(ctx context.Context, startRequest StartRequest) (*WaitGetWarehouseRunning[any], error)

+ StartAndWait func(ctx context.Context, startRequest StartRequest, ...) (*GetWarehouseResponse, error)

+ Stop func(ctx context.Context, stopRequest StopRequest) (*WaitGetWarehouseStopped[any], error)

+ StopAndWait func(ctx context.Context, stopRequest StopRequest, ...) (*GetWarehouseResponse, error)

+ UpdatePermissions func(ctx context.Context, request WarehousePermissionsRequest) (*WarehousePermissions, error)

+ WaitGetWarehouseRunning func(ctx context.Context, id string, timeout time.Duration, ...) (*GetWarehouseResponse, error)

+ WaitGetWarehouseStopped func(ctx context.Context, id string, timeout time.Duration, ...) (*GetWarehouseResponse, error)

+ WithImpl func(impl WarehousesService) WarehousesInterface

v0.28.0

Dec 15, 2023

v0.27.0

Dec 12, 2023

Changes in this version

type QueryFilter

+ StatementIds []string

v0.26.2

Dec 7, 2023

v0.26.1

Nov 30, 2023

v0.26.0

Nov 29, 2023

v0.25.0

Nov 10, 2023

v0.24.0

Oct 24, 2023

Changes in this version

type DashboardsAPI

+ func (a *DashboardsAPI) List(ctx context.Context, request ListDashboardsRequest) *listing.DeduplicatingIterator[Dashboard, string]

type QueriesAPI

+ func (a *QueriesAPI) List(ctx context.Context, request ListQueriesRequest) *listing.DeduplicatingIterator[Query, string]

type QueryHistoryAPI

+ func (a *QueryHistoryAPI) List(ctx context.Context, request ListQueryHistoryRequest) ...

type WarehousesAPI

+ func (a *WarehousesAPI) List(ctx context.Context, request ListWarehousesRequest) ...

v0.23.0

Oct 12, 2023

Changes in this version

type AccessControl

+ ForceSendFields []string

+ func (s *AccessControl) UnmarshalJSON(b []byte) error

+ func (s AccessControl) MarshalJSON() ([]byte, error)

type Alert

+ ForceSendFields []string

+ func (s *Alert) UnmarshalJSON(b []byte) error

+ func (s Alert) MarshalJSON() ([]byte, error)

type AlertOptions

+ ForceSendFields []string

+ func (s *AlertOptions) UnmarshalJSON(b []byte) error

+ func (s AlertOptions) MarshalJSON() ([]byte, error)

type AlertQuery

+ ForceSendFields []string

+ func (s *AlertQuery) UnmarshalJSON(b []byte) error

+ func (s AlertQuery) MarshalJSON() ([]byte, error)

type BaseChunkInfo

+ ForceSendFields []string

+ func (s *BaseChunkInfo) UnmarshalJSON(b []byte) error

+ func (s BaseChunkInfo) MarshalJSON() ([]byte, error)

type Channel

+ ForceSendFields []string

+ func (s *Channel) UnmarshalJSON(b []byte) error

+ func (s Channel) MarshalJSON() ([]byte, error)

type ChannelInfo

+ ForceSendFields []string

+ func (s *ChannelInfo) UnmarshalJSON(b []byte) error

+ func (s ChannelInfo) MarshalJSON() ([]byte, error)

type ColumnInfo

+ ForceSendFields []string

+ func (s *ColumnInfo) UnmarshalJSON(b []byte) error

+ func (s ColumnInfo) MarshalJSON() ([]byte, error)

type CreateAlert

+ ForceSendFields []string

+ func (s *CreateAlert) UnmarshalJSON(b []byte) error

+ func (s CreateAlert) MarshalJSON() ([]byte, error)

type CreateDashboardRequest

+ ForceSendFields []string

+ func (s *CreateDashboardRequest) UnmarshalJSON(b []byte) error

+ func (s CreateDashboardRequest) MarshalJSON() ([]byte, error)

type CreateQueryVisualizationRequest

+ ForceSendFields []string

+ func (s *CreateQueryVisualizationRequest) UnmarshalJSON(b []byte) error

+ func (s CreateQueryVisualizationRequest) MarshalJSON() ([]byte, error)

type CreateWarehouseRequest

+ ForceSendFields []string

+ func (s *CreateWarehouseRequest) UnmarshalJSON(b []byte) error

+ func (s CreateWarehouseRequest) MarshalJSON() ([]byte, error)

type CreateWarehouseResponse

+ ForceSendFields []string

+ func (s *CreateWarehouseResponse) UnmarshalJSON(b []byte) error

+ func (s CreateWarehouseResponse) MarshalJSON() ([]byte, error)

type CreateWidget

+ ForceSendFields []string

+ func (s *CreateWidget) UnmarshalJSON(b []byte) error

+ func (s CreateWidget) MarshalJSON() ([]byte, error)

type Dashboard

+ ForceSendFields []string

+ func (s *Dashboard) UnmarshalJSON(b []byte) error

+ func (s Dashboard) MarshalJSON() ([]byte, error)

type DashboardOptions

+ ForceSendFields []string

+ func (s *DashboardOptions) UnmarshalJSON(b []byte) error

+ func (s DashboardOptions) MarshalJSON() ([]byte, error)

type DataSource

+ ForceSendFields []string

+ func (s *DataSource) UnmarshalJSON(b []byte) error

+ func (s DataSource) MarshalJSON() ([]byte, error)

type EditAlert

+ ForceSendFields []string

+ func (s *EditAlert) UnmarshalJSON(b []byte) error

+ func (s EditAlert) MarshalJSON() ([]byte, error)

type EditWarehouseRequest

+ ForceSendFields []string

+ func (s *EditWarehouseRequest) UnmarshalJSON(b []byte) error

+ func (s EditWarehouseRequest) MarshalJSON() ([]byte, error)

type EndpointConfPair

+ ForceSendFields []string

+ func (s *EndpointConfPair) UnmarshalJSON(b []byte) error

+ func (s EndpointConfPair) MarshalJSON() ([]byte, error)

type EndpointHealth

+ ForceSendFields []string

+ func (s *EndpointHealth) UnmarshalJSON(b []byte) error

+ func (s EndpointHealth) MarshalJSON() ([]byte, error)

type EndpointInfo

+ ForceSendFields []string

+ func (s *EndpointInfo) UnmarshalJSON(b []byte) error

+ func (s EndpointInfo) MarshalJSON() ([]byte, error)

type EndpointTagPair

+ ForceSendFields []string

+ func (s *EndpointTagPair) UnmarshalJSON(b []byte) error

+ func (s EndpointTagPair) MarshalJSON() ([]byte, error)

type ExecuteStatementRequest

+ ForceSendFields []string

+ func (s *ExecuteStatementRequest) UnmarshalJSON(b []byte) error

+ func (s ExecuteStatementRequest) MarshalJSON() ([]byte, error)

type ExecuteStatementResponse

+ ForceSendFields []string

+ func (s *ExecuteStatementResponse) UnmarshalJSON(b []byte) error

+ func (s ExecuteStatementResponse) MarshalJSON() ([]byte, error)

type ExternalLink

+ ForceSendFields []string

+ func (s *ExternalLink) UnmarshalJSON(b []byte) error

+ func (s ExternalLink) MarshalJSON() ([]byte, error)

type GetResponse

+ ForceSendFields []string

+ func (s *GetResponse) UnmarshalJSON(b []byte) error

+ func (s GetResponse) MarshalJSON() ([]byte, error)

type GetStatementResponse

+ ForceSendFields []string

+ func (s *GetStatementResponse) UnmarshalJSON(b []byte) error

+ func (s GetStatementResponse) MarshalJSON() ([]byte, error)

type GetWarehouseResponse

+ ForceSendFields []string

+ func (s *GetWarehouseResponse) UnmarshalJSON(b []byte) error

+ func (s GetWarehouseResponse) MarshalJSON() ([]byte, error)

type GetWorkspaceWarehouseConfigResponse

+ ForceSendFields []string

+ func (s *GetWorkspaceWarehouseConfigResponse) UnmarshalJSON(b []byte) error

+ func (s GetWorkspaceWarehouseConfigResponse) MarshalJSON() ([]byte, error)

type ListDashboardsRequest

+ ForceSendFields []string

+ func (s *ListDashboardsRequest) UnmarshalJSON(b []byte) error

+ func (s ListDashboardsRequest) MarshalJSON() ([]byte, error)

type ListQueriesRequest

+ ForceSendFields []string

+ func (s *ListQueriesRequest) UnmarshalJSON(b []byte) error

+ func (s ListQueriesRequest) MarshalJSON() ([]byte, error)

type ListQueriesResponse

+ ForceSendFields []string

+ func (s *ListQueriesResponse) UnmarshalJSON(b []byte) error

+ func (s ListQueriesResponse) MarshalJSON() ([]byte, error)

type ListQueryHistoryRequest

+ ForceSendFields []string

+ func (s *ListQueryHistoryRequest) UnmarshalJSON(b []byte) error

+ func (s ListQueryHistoryRequest) MarshalJSON() ([]byte, error)

type ListResponse

+ ForceSendFields []string

+ func (s *ListResponse) UnmarshalJSON(b []byte) error

+ func (s ListResponse) MarshalJSON() ([]byte, error)

type ListWarehousesRequest

+ ForceSendFields []string

+ func (s *ListWarehousesRequest) UnmarshalJSON(b []byte) error

+ func (s ListWarehousesRequest) MarshalJSON() ([]byte, error)

type OdbcParams

+ ForceSendFields []string

+ func (s *OdbcParams) UnmarshalJSON(b []byte) error

+ func (s OdbcParams) MarshalJSON() ([]byte, error)

type Parameter

+ ForceSendFields []string

+ func (s *Parameter) UnmarshalJSON(b []byte) error

+ func (s Parameter) MarshalJSON() ([]byte, error)

type Query

+ ForceSendFields []string

+ func (s *Query) UnmarshalJSON(b []byte) error

+ func (s Query) MarshalJSON() ([]byte, error)

type QueryEditContent

+ ForceSendFields []string

+ func (s *QueryEditContent) UnmarshalJSON(b []byte) error

+ func (s QueryEditContent) MarshalJSON() ([]byte, error)

type QueryInfo

+ ForceSendFields []string

+ func (s *QueryInfo) UnmarshalJSON(b []byte) error

+ func (s QueryInfo) MarshalJSON() ([]byte, error)

type QueryList

+ ForceSendFields []string

+ func (s *QueryList) UnmarshalJSON(b []byte) error

+ func (s QueryList) MarshalJSON() ([]byte, error)

type QueryMetrics

+ ForceSendFields []string

+ func (s *QueryMetrics) UnmarshalJSON(b []byte) error

+ func (s QueryMetrics) MarshalJSON() ([]byte, error)

type QueryOptions

+ ForceSendFields []string

+ func (s *QueryOptions) UnmarshalJSON(b []byte) error

+ func (s QueryOptions) MarshalJSON() ([]byte, error)

type QueryPostContent

+ ForceSendFields []string

+ func (s *QueryPostContent) UnmarshalJSON(b []byte) error

+ func (s QueryPostContent) MarshalJSON() ([]byte, error)

type ResultData

+ ForceSendFields []string

+ func (s *ResultData) UnmarshalJSON(b []byte) error

+ func (s ResultData) MarshalJSON() ([]byte, error)

type ResultManifest

+ ForceSendFields []string

+ func (s *ResultManifest) UnmarshalJSON(b []byte) error

+ func (s ResultManifest) MarshalJSON() ([]byte, error)

type ResultSchema

+ ForceSendFields []string

+ func (s *ResultSchema) UnmarshalJSON(b []byte) error

+ func (s ResultSchema) MarshalJSON() ([]byte, error)

type ServiceError

+ ForceSendFields []string

+ func (s *ServiceError) UnmarshalJSON(b []byte) error

+ func (s ServiceError) MarshalJSON() ([]byte, error)

type SetResponse

+ ForceSendFields []string

+ func (s *SetResponse) UnmarshalJSON(b []byte) error

+ func (s SetResponse) MarshalJSON() ([]byte, error)

type SetWorkspaceWarehouseConfigRequest

+ ForceSendFields []string

+ func (s *SetWorkspaceWarehouseConfigRequest) UnmarshalJSON(b []byte) error

+ func (s SetWorkspaceWarehouseConfigRequest) MarshalJSON() ([]byte, error)

type StatementParameterListItem

+ ForceSendFields []string

+ func (s *StatementParameterListItem) UnmarshalJSON(b []byte) error

+ func (s StatementParameterListItem) MarshalJSON() ([]byte, error)

type TimeRange

+ ForceSendFields []string

+ func (s *TimeRange) UnmarshalJSON(b []byte) error

+ func (s TimeRange) MarshalJSON() ([]byte, error)

type TransferOwnershipObjectId

+ ForceSendFields []string

+ func (s *TransferOwnershipObjectId) UnmarshalJSON(b []byte) error

+ func (s TransferOwnershipObjectId) MarshalJSON() ([]byte, error)

type TransferOwnershipRequest

+ ForceSendFields []string

+ func (s *TransferOwnershipRequest) UnmarshalJSON(b []byte) error

+ func (s TransferOwnershipRequest) MarshalJSON() ([]byte, error)

type User

+ ForceSendFields []string

+ func (s *User) UnmarshalJSON(b []byte) error

+ func (s User) MarshalJSON() ([]byte, error)

type Visualization

+ ForceSendFields []string

+ func (s *Visualization) UnmarshalJSON(b []byte) error

+ func (s Visualization) MarshalJSON() ([]byte, error)

type WarehouseAccessControlRequest

+ ForceSendFields []string

+ func (s *WarehouseAccessControlRequest) UnmarshalJSON(b []byte) error

+ func (s WarehouseAccessControlRequest) MarshalJSON() ([]byte, error)

type WarehouseAccessControlResponse

+ ForceSendFields []string

+ func (s *WarehouseAccessControlResponse) UnmarshalJSON(b []byte) error

+ func (s WarehouseAccessControlResponse) MarshalJSON() ([]byte, error)

type WarehousePermission

+ ForceSendFields []string

+ func (s *WarehousePermission) UnmarshalJSON(b []byte) error

+ func (s WarehousePermission) MarshalJSON() ([]byte, error)

type WarehousePermissions

+ ForceSendFields []string

+ func (s *WarehousePermissions) UnmarshalJSON(b []byte) error

+ func (s WarehousePermissions) MarshalJSON() ([]byte, error)

type WarehousePermissionsDescription

+ ForceSendFields []string

+ func (s *WarehousePermissionsDescription) UnmarshalJSON(b []byte) error

+ func (s WarehousePermissionsDescription) MarshalJSON() ([]byte, error)

type WarehouseTypePair

+ ForceSendFields []string

+ func (s *WarehouseTypePair) UnmarshalJSON(b []byte) error

+ func (s WarehouseTypePair) MarshalJSON() ([]byte, error)

type Widget

+ ForceSendFields []string

+ func (s *Widget) UnmarshalJSON(b []byte) error

+ func (s Widget) MarshalJSON() ([]byte, error)

type WidgetOptions

+ ForceSendFields []string

+ func (s *WidgetOptions) UnmarshalJSON(b []byte) error

+ func (s WidgetOptions) MarshalJSON() ([]byte, error)

type WidgetPosition

+ ForceSendFields []string

+ func (s *WidgetPosition) UnmarshalJSON(b []byte) error

+ func (s WidgetPosition) MarshalJSON() ([]byte, error)

v0.22.0

Oct 3, 2023

v0.21.0

Sep 27, 2023

v0.20.0

Sep 21, 2023

Changes in this version

type AlertOptions

+ EmptyResultState AlertOptionsEmptyResultState

+ type AlertOptionsEmptyResultState string

+ const AlertOptionsEmptyResultStateOk

+ const AlertOptionsEmptyResultStateTriggered

+ const AlertOptionsEmptyResultStateUnknown

+ func (f *AlertOptionsEmptyResultState) Set(v string) error

+ func (f *AlertOptionsEmptyResultState) String() string

+ func (f *AlertOptionsEmptyResultState) Type() string

+ type BaseChunkInfo struct

+ ByteCount int64

+ ChunkIndex int

+ RowCount int64

+ RowOffset int64

+ type ExecuteStatementRequestOnWaitTimeout string

+ const ExecuteStatementRequestOnWaitTimeoutCancel

+ const ExecuteStatementRequestOnWaitTimeoutContinue

+ func (f *ExecuteStatementRequestOnWaitTimeout) Set(v string) error

+ func (f *ExecuteStatementRequestOnWaitTimeout) String() string

+ func (f *ExecuteStatementRequestOnWaitTimeout) Type() string

type ResultManifest

+ Truncated bool

v0.19.2

Sep 13, 2023

v0.19.1

Sep 7, 2023

v0.19.0

Sep 4, 2023

Changes in this version

type CreateDashboardRequest

+ RunAsRole RunAsRole

+ type CreateQueryVisualizationRequest struct

+ Description string

+ Name string

+ Options any

+ QueryId string

+ Type string

+ type CreateWidget struct

+ DashboardId string

+ Id string

+ Options WidgetOptions

+ Text string

+ VisualizationId string

+ Width int

+ type DashboardWidgetsAPI struct

+ func NewDashboardWidgets(client *client.DatabricksClient) *DashboardWidgetsAPI

+ func (a *DashboardWidgetsAPI) Create(ctx context.Context, request CreateWidget) (*Widget, error)

+ func (a *DashboardWidgetsAPI) Delete(ctx context.Context, request DeleteDashboardWidgetRequest) error

+ func (a *DashboardWidgetsAPI) DeleteById(ctx context.Context, id string) error

+ func (a *DashboardWidgetsAPI) Impl() DashboardWidgetsService

+ func (a *DashboardWidgetsAPI) Update(ctx context.Context, request CreateWidget) (*Widget, error)

+ func (a *DashboardWidgetsAPI) WithImpl(impl DashboardWidgetsService) *DashboardWidgetsAPI

+ type DashboardWidgetsService interface

+ Create func(ctx context.Context, request CreateWidget) (*Widget, error)

+ Delete func(ctx context.Context, request DeleteDashboardWidgetRequest) error

+ Update func(ctx context.Context, request CreateWidget) (*Widget, error)

+ type DeleteDashboardWidgetRequest struct

+ Id string

+ type DeleteQueryVisualizationRequest struct

+ Id string

type Query

+ RunAsRole RunAsRole

type QueryPostContent

+ RunAsRole RunAsRole

+ type QueryVisualizationsAPI struct

+ func NewQueryVisualizations(client *client.DatabricksClient) *QueryVisualizationsAPI

+ func (a *QueryVisualizationsAPI) Create(ctx context.Context, request CreateQueryVisualizationRequest) (*Visualization, error)

+ func (a *QueryVisualizationsAPI) Delete(ctx context.Context, request DeleteQueryVisualizationRequest) error

+ func (a *QueryVisualizationsAPI) DeleteById(ctx context.Context, id string) error

+ func (a *QueryVisualizationsAPI) Impl() QueryVisualizationsService

+ func (a *QueryVisualizationsAPI) Update(ctx context.Context, request Visualization) (*Visualization, error)

+ func (a *QueryVisualizationsAPI) WithImpl(impl QueryVisualizationsService) *QueryVisualizationsAPI

+ type QueryVisualizationsService interface

+ Create func(ctx context.Context, request CreateQueryVisualizationRequest) (*Visualization, error)

+ Delete func(ctx context.Context, request DeleteQueryVisualizationRequest) error

+ Update func(ctx context.Context, request Visualization) (*Visualization, error)

+ type RunAsRole string

+ const RunAsRoleOwner

+ const RunAsRoleViewer

+ func (f *RunAsRole) Set(v string) error

+ func (f *RunAsRole) String() string

+ func (f *RunAsRole) Type() string

type WarehousesAPI

+ func (a *WarehousesAPI) GetPermissionLevels(ctx context.Context, request GetWarehousePermissionLevelsRequest) (*GetWarehousePermissionLevelsResponse, error)

+ func (a *WarehousesAPI) GetPermissionLevelsByWarehouseId(ctx context.Context, warehouseId string) (*GetWarehousePermissionLevelsResponse, error)

+ func (a *WarehousesAPI) GetPermissions(ctx context.Context, request GetWarehousePermissionsRequest) (*WarehousePermissions, error)

+ func (a *WarehousesAPI) GetPermissionsByWarehouseId(ctx context.Context, warehouseId string) (*WarehousePermissions, error)

+ func (a *WarehousesAPI) SetPermissions(ctx context.Context, request WarehousePermissionsRequest) (*WarehousePermissions, error)

+ func (a *WarehousesAPI) UpdatePermissions(ctx context.Context, request WarehousePermissionsRequest) (*WarehousePermissions, error)

type WarehousesService

+ GetPermissionLevels func(ctx context.Context, request GetWarehousePermissionLevelsRequest) (*GetWarehousePermissionLevelsResponse, error)

+ GetPermissions func(ctx context.Context, request GetWarehousePermissionsRequest) (*WarehousePermissions, error)

+ SetPermissions func(ctx context.Context, request WarehousePermissionsRequest) (*WarehousePermissions, error)

+ UpdatePermissions func(ctx context.Context, request WarehousePermissionsRequest) (*WarehousePermissions, error)

type WidgetOptions

+ Description string

+ Title string

+ type WidgetPosition struct

+ AutoHeight bool

+ Col int

+ Row int

+ SizeX int

+ SizeY int

v0.18.0

Aug 29, 2023

Changes in this version

type ExecuteStatementRequest

+ Parameters []StatementParameterListItem

+ RowLimit int64

+ type StatementParameterListItem struct

+ Name string

+ Type string

+ Value string

v0.17.0

Aug 18, 2023

v0.16.0

Aug 14, 2023

v0.15.0

Aug 7, 2023

Changes in this version

+ type GetWarehousePermissionLevelsRequest struct

+ WarehouseId string

+ type GetWarehousePermissionLevelsResponse struct

+ PermissionLevels []WarehousePermissionsDescription

+ type GetWarehousePermissionsRequest struct

+ WarehouseId string

type QueryInfo

+ CanSubscribeToLiveQuery bool

type QueryMetrics

+ MetadataTimeMs int

+ OverloadingQueueStartTimestamp int

+ PlanningPhases []any

+ PlanningTimeMs int

+ ProvisioningQueueStartTimestamp int

+ PrunedBytes int

+ PrunedFilesCount int

+ QueryCompilationStartTimestamp int

+ QueryExecutionTimeMs int

+ type WarehouseAccessControlRequest struct

+ GroupName string

+ PermissionLevel WarehousePermissionLevel

+ ServicePrincipalName string

+ UserName string

+ type WarehouseAccessControlResponse struct

+ AllPermissions []WarehousePermission

+ DisplayName string

+ GroupName string

+ ServicePrincipalName string

+ UserName string

+ type WarehousePermission struct

+ Inherited bool

+ InheritedFromObject []string

+ PermissionLevel WarehousePermissionLevel

+ type WarehousePermissionLevel string

+ const WarehousePermissionLevelCanManage

+ const WarehousePermissionLevelCanUse

+ const WarehousePermissionLevelIsOwner

+ func (f *WarehousePermissionLevel) Set(v string) error

+ func (f *WarehousePermissionLevel) String() string

+ func (f *WarehousePermissionLevel) Type() string

+ type WarehousePermissions struct

+ AccessControlList []WarehouseAccessControlResponse

+ ObjectId string

+ ObjectType string

+ type WarehousePermissionsDescription struct

+ Description string

+ PermissionLevel WarehousePermissionLevel

+ type WarehousePermissionsRequest struct

+ AccessControlList []WarehouseAccessControlRequest

+ WarehouseId string

type WarehousesAPI

+ func (a *WarehousesAPI) GetWarehousePermissionLevels(ctx context.Context, request GetWarehousePermissionLevelsRequest) (*GetWarehousePermissionLevelsResponse, error)

+ func (a *WarehousesAPI) GetWarehousePermissionLevelsByWarehouseId(ctx context.Context, warehouseId string) (*GetWarehousePermissionLevelsResponse, error)

+ func (a *WarehousesAPI) GetWarehousePermissions(ctx context.Context, request GetWarehousePermissionsRequest) (*WarehousePermissions, error)

+ func (a *WarehousesAPI) GetWarehousePermissionsByWarehouseId(ctx context.Context, warehouseId string) (*WarehousePermissions, error)

+ func (a *WarehousesAPI) SetWarehousePermissions(ctx context.Context, request WarehousePermissionsRequest) (*WarehousePermissions, error)

+ func (a *WarehousesAPI) UpdateWarehousePermissions(ctx context.Context, request WarehousePermissionsRequest) (*WarehousePermissions, error)

type WarehousesService

+ GetWarehousePermissionLevels func(ctx context.Context, request GetWarehousePermissionLevelsRequest) (*GetWarehousePermissionLevelsResponse, error)

+ GetWarehousePermissions func(ctx context.Context, request GetWarehousePermissionsRequest) (*WarehousePermissions, error)

+ SetWarehousePermissions func(ctx context.Context, request WarehousePermissionsRequest) (*WarehousePermissions, error)

+ UpdateWarehousePermissions func(ctx context.Context, request WarehousePermissionsRequest) (*WarehousePermissions, error)

v0.14.1

Jul 27, 2023

v0.14.0

Jul 26, 2023

v0.13.0

Jul 18, 2023

Changes in this version

+ type AlertQuery struct

+ CreatedAt string

+ DataSourceId string

+ Description string

+ Id string

+ IsArchived bool

+ IsDraft bool

+ IsSafe bool

+ Name string

+ Options *QueryOptions

+ Query string

+ Tags []string

+ UpdatedAt string

+ UserId int

type TerminationReasonCode

+ const TerminationReasonCodeK8sAutoscalingFailure

+ const TerminationReasonCodeK8sDbrClusterLaunchTimeout

v0.12.0

Jun 28, 2023

v0.11.0

Jun 28, 2023

v0.10.1

Jun 21, 2023

v0.10.0

Jun 15, 2023

Changes in this version

type Format

+ const FormatCsv

type StatementExecutionAPI

+ func (a *StatementExecutionAPI) ExecuteAndWait(ctx context.Context, request ExecuteStatementRequest) (*ExecuteStatementResponse, error)

+ type WaitGetWarehouseRunning struct

+ Id string

+ Response *R

+ func (w *WaitGetWarehouseRunning[R]) Get() (*GetWarehouseResponse, error)

+ func (w *WaitGetWarehouseRunning[R]) GetWithTimeout(timeout time.Duration) (*GetWarehouseResponse, error)

+ func (w *WaitGetWarehouseRunning[R]) OnProgress(callback func(*GetWarehouseResponse)) *WaitGetWarehouseRunning[R]

+ type WaitGetWarehouseStopped struct

+ Id string

+ Response *R

+ func (w *WaitGetWarehouseStopped[R]) Get() (*GetWarehouseResponse, error)

+ func (w *WaitGetWarehouseStopped[R]) GetWithTimeout(timeout time.Duration) (*GetWarehouseResponse, error)

+ func (w *WaitGetWarehouseStopped[R]) OnProgress(callback func(*GetWarehouseResponse)) *WaitGetWarehouseStopped[R]

type WarehousesAPI

+ func (a *WarehousesAPI) WaitGetWarehouseRunning(ctx context.Context, id string, timeout time.Duration, ...) (*GetWarehouseResponse, error)

+ func (a *WarehousesAPI) WaitGetWarehouseStopped(ctx context.Context, id string, timeout time.Duration, ...) (*GetWarehouseResponse, error)

v0.9.0

May 22, 2023

Changes in this version

type CreateDashboardRequest

+ IsFavorite bool

+ type CreateWarehouseRequestWarehouseType string

+ const CreateWarehouseRequestWarehouseTypeClassic

+ const CreateWarehouseRequestWarehouseTypePro

+ const CreateWarehouseRequestWarehouseTypeTypeUnspecified

+ func (cwrwt *CreateWarehouseRequestWarehouseType) Set(v string) error

+ func (cwrwt *CreateWarehouseRequestWarehouseType) String() string

+ func (cwrwt *CreateWarehouseRequestWarehouseType) Type() string

+ type EditWarehouseRequestWarehouseType string

+ const EditWarehouseRequestWarehouseTypeClassic

+ const EditWarehouseRequestWarehouseTypePro

+ const EditWarehouseRequestWarehouseTypeTypeUnspecified

+ func (ewrwt *EditWarehouseRequestWarehouseType) Set(v string) error

+ func (ewrwt *EditWarehouseRequestWarehouseType) String() string

+ func (ewrwt *EditWarehouseRequestWarehouseType) Type() string

+ type EndpointInfoWarehouseType string

+ const EndpointInfoWarehouseTypeClassic

+ const EndpointInfoWarehouseTypePro

+ const EndpointInfoWarehouseTypeTypeUnspecified

+ func (eiwt *EndpointInfoWarehouseType) Set(v string) error

+ func (eiwt *EndpointInfoWarehouseType) String() string

+ func (eiwt *EndpointInfoWarehouseType) Type() string

+ type GetWarehouseResponseWarehouseType string

+ const GetWarehouseResponseWarehouseTypeClassic

+ const GetWarehouseResponseWarehouseTypePro

+ const GetWarehouseResponseWarehouseTypeTypeUnspecified

+ func (gwrwt *GetWarehouseResponseWarehouseType) Set(v string) error

+ func (gwrwt *GetWarehouseResponseWarehouseType) String() string

+ func (gwrwt *GetWarehouseResponseWarehouseType) Type() string

+ type WarehouseTypePairWarehouseType string

+ const WarehouseTypePairWarehouseTypeClassic

+ const WarehouseTypePairWarehouseTypePro

+ const WarehouseTypePairWarehouseTypeTypeUnspecified

+ func (wtpwt *WarehouseTypePairWarehouseType) Set(v string) error

+ func (wtpwt *WarehouseTypePairWarehouseType) String() string

+ func (wtpwt *WarehouseTypePairWarehouseType) Type() string

v0.8.1

May 11, 2023

v0.8.0

Apr 20, 2023

v0.7.0

Apr 5, 2023

v0.6.0

Apr 3, 2023

v0.5.0

Mar 14, 2023

v0.4.1

Mar 9, 2023

v0.4.0

Mar 8, 2023

Changes in this version

type ExecuteStatementRequest

+ ByteLimit int64

v0.3.3

Feb 24, 2023

v0.3.2

Feb 17, 2023

v0.3.1

Feb 17, 2023

v0.3.0

Feb 3, 2023

Changes in this version

type Alert

+ Parent string

+ type CancelExecutionRequest struct

+ StatementId string

+ type ChunkInfo struct

+ ByteCount int64

+ ChunkIndex int

+ NextChunkIndex int

+ NextChunkInternalLink string

+ RowCount int64

+ RowOffset int64

+ type ColumnInfo struct

+ Name string

+ Position int

+ TypeIntervalType string

+ TypeName ColumnInfoTypeName

+ TypePrecision int

+ TypeScale int

+ TypeText string

+ type ColumnInfoTypeName string

+ const ColumnInfoTypeNameArray

+ const ColumnInfoTypeNameBinary

+ const ColumnInfoTypeNameBoolean

+ const ColumnInfoTypeNameByte

+ const ColumnInfoTypeNameChar

+ const ColumnInfoTypeNameDate

+ const ColumnInfoTypeNameDecimal

+ const ColumnInfoTypeNameDouble

+ const ColumnInfoTypeNameFloat

+ const ColumnInfoTypeNameInt

+ const ColumnInfoTypeNameInterval

+ const ColumnInfoTypeNameLong

+ const ColumnInfoTypeNameMap

+ const ColumnInfoTypeNameNull

+ const ColumnInfoTypeNameShort

+ const ColumnInfoTypeNameString

+ const ColumnInfoTypeNameStruct

+ const ColumnInfoTypeNameTimestamp

+ const ColumnInfoTypeNameUserDefinedType

+ func (citn *ColumnInfoTypeName) Set(v string) error

+ func (citn *ColumnInfoTypeName) String() string

+ func (citn *ColumnInfoTypeName) Type() string

+ type CreateAlert struct

+ Name string

+ Options AlertOptions

+ Parent string

+ QueryId string

+ Rearm int

type CreateDashboardRequest

+ Parent string

type Dashboard

+ Parent string

+ type Disposition string

+ const DispositionExternalLinks

+ const DispositionInline

+ func (d *Disposition) Set(v string) error

+ func (d *Disposition) String() string

+ func (d *Disposition) Type() string

+ type ExecuteStatementRequest struct

+ Catalog string

+ Disposition Disposition

+ Format Format

+ OnWaitTimeout TimeoutAction

+ Schema string

+ Statement string

+ WaitTimeout string

+ WarehouseId string

+ type ExecuteStatementResponse struct

+ Manifest *ResultManifest

+ Result *ResultData

+ StatementId string

+ Status *StatementStatus

+ type ExternalLink struct

+ ByteCount int64

+ ChunkIndex int

+ Expiration string

+ ExternalLink string

+ NextChunkIndex int

+ NextChunkInternalLink string

+ RowCount int64

+ RowOffset int64

+ type Format string

+ const FormatArrowStream

+ const FormatJsonArray

+ func (f *Format) Set(v string) error

+ func (f *Format) String() string

+ func (f *Format) Type() string

+ type GetStatementRequest struct

+ StatementId string

+ type GetStatementResponse struct

+ Manifest *ResultManifest

+ Result *ResultData

+ StatementId string

+ Status *StatementStatus

+ type GetStatementResultChunkNRequest struct

+ ChunkIndex int

+ RowOffset int64

+ StatementId string

type Query

+ Parent string

+ type QueryEditContent struct

+ DataSourceId string

+ Description string

+ Name string

+ Options any

+ Query string

+ QueryId string

+ Schedule *QueryInterval

type QueryPostContent

+ Parent string

+ type ResultData struct

+ ByteCount int64

+ ChunkIndex int

+ DataArray [][]string

+ ExternalLinks []ExternalLink

+ NextChunkIndex int

+ NextChunkInternalLink string

+ RowCount int64

+ RowOffset int64

+ type ResultManifest struct

+ Chunks []ChunkInfo

+ Format Format

+ Schema *ResultSchema

+ TotalByteCount int64

+ TotalChunkCount int

+ TotalRowCount int64

+ type ResultSchema struct

+ ColumnCount int

+ Columns []ColumnInfo

+ type ServiceError struct

+ ErrorCode ServiceErrorCode

+ Message string

+ type ServiceErrorCode string

+ const ServiceErrorCodeAborted

+ const ServiceErrorCodeAlreadyExists

+ const ServiceErrorCodeBadRequest

+ const ServiceErrorCodeCancelled

+ const ServiceErrorCodeDeadlineExceeded

+ const ServiceErrorCodeInternalError

+ const ServiceErrorCodeIoError

+ const ServiceErrorCodeNotFound

+ const ServiceErrorCodeResourceExhausted

+ const ServiceErrorCodeServiceUnderMaintenance

+ const ServiceErrorCodeTemporarilyUnavailable

+ const ServiceErrorCodeUnauthenticated

+ const ServiceErrorCodeUnknown

+ const ServiceErrorCodeWorkspaceTemporarilyUnavailable

+ func (sec *ServiceErrorCode) Set(v string) error

+ func (sec *ServiceErrorCode) String() string

+ func (sec *ServiceErrorCode) Type() string

+ type StatementExecutionAPI struct

+ func NewStatementExecution(client *client.DatabricksClient) *StatementExecutionAPI

+ func (a *StatementExecutionAPI) CancelExecution(ctx context.Context, request CancelExecutionRequest) error

+ func (a *StatementExecutionAPI) ExecuteStatement(ctx context.Context, request ExecuteStatementRequest) (*ExecuteStatementResponse, error)

+ func (a *StatementExecutionAPI) GetStatement(ctx context.Context, request GetStatementRequest) (*GetStatementResponse, error)

+ func (a *StatementExecutionAPI) GetStatementByStatementId(ctx context.Context, statementId string) (*GetStatementResponse, error)

+ func (a *StatementExecutionAPI) GetStatementResultChunkN(ctx context.Context, request GetStatementResultChunkNRequest) (*ResultData, error)

+ func (a *StatementExecutionAPI) GetStatementResultChunkNByStatementIdAndChunkIndex(ctx context.Context, statementId string, chunkIndex int) (*ResultData, error)

+ func (a *StatementExecutionAPI) Impl() StatementExecutionService

+ func (a *StatementExecutionAPI) WithImpl(impl StatementExecutionService) *StatementExecutionAPI

+ type StatementExecutionService interface

+ CancelExecution func(ctx context.Context, request CancelExecutionRequest) error

+ ExecuteStatement func(ctx context.Context, request ExecuteStatementRequest) (*ExecuteStatementResponse, error)

+ GetStatement func(ctx context.Context, request GetStatementRequest) (*GetStatementResponse, error)

+ GetStatementResultChunkN func(ctx context.Context, request GetStatementResultChunkNRequest) (*ResultData, error)

+ type StatementState string

+ const StatementStateCanceled

+ const StatementStateClosed

+ const StatementStateFailed

+ const StatementStatePending

+ const StatementStateRunning

+ const StatementStateSucceeded

+ func (ss *StatementState) Set(v string) error

+ func (ss *StatementState) String() string

+ func (ss *StatementState) Type() string

+ type StatementStatus struct

+ Error *ServiceError

+ State StatementState

+ type TimeoutAction string

+ const TimeoutActionCancel

+ const TimeoutActionContinue

+ func (ta *TimeoutAction) Set(v string) error

+ func (ta *TimeoutAction) String() string

+ func (ta *TimeoutAction) Type() string

v0.2.0

Dec 23, 2022

Changes in this version

+ type AccessControl struct

+ GroupName string

+ PermissionLevel PermissionLevel

+ UserName string

+ type Alert struct

+ CreatedAt string

+ Id string

+ LastTriggeredAt string

+ Name string

+ Options *AlertOptions

+ Query *Query

+ Rearm int

+ State AlertState

+ UpdatedAt string

+ User *User

+ type AlertOptions struct

+ Column string

+ CustomBody string

+ CustomSubject string

+ Muted bool

+ Op string

+ ScheduleFailures int

+ Value string

+ type AlertState string

+ const AlertStateOk

+ const AlertStateTriggered

+ const AlertStateUnknown

+ func (as *AlertState) Set(v string) error

+ func (as *AlertState) String() string

+ func (as *AlertState) Type() string

+ type AlertsAPI struct

+ func NewAlerts(client *client.DatabricksClient) *AlertsAPI

+ func (a *AlertsAPI) AlertNameToIdMap(ctx context.Context) (map[string]string, error)

+ func (a *AlertsAPI) Create(ctx context.Context, request EditAlert) (*Alert, error)

+ func (a *AlertsAPI) CreateSchedule(ctx context.Context, request CreateRefreshSchedule) (*RefreshSchedule, error)

+ func (a *AlertsAPI) Delete(ctx context.Context, request DeleteAlertRequest) error

+ func (a *AlertsAPI) DeleteByAlertId(ctx context.Context, alertId string) error

+ func (a *AlertsAPI) DeleteSchedule(ctx context.Context, request DeleteScheduleRequest) error

+ func (a *AlertsAPI) DeleteScheduleByAlertIdAndScheduleId(ctx context.Context, alertId string, scheduleId string) error

+ func (a *AlertsAPI) Get(ctx context.Context, request GetAlertRequest) (*Alert, error)

+ func (a *AlertsAPI) GetByAlertId(ctx context.Context, alertId string) (*Alert, error)

+ func (a *AlertsAPI) GetByName(ctx context.Context, name string) (*Alert, error)

+ func (a *AlertsAPI) GetSubscriptions(ctx context.Context, request GetSubscriptionsRequest) ([]Subscription, error)

+ func (a *AlertsAPI) GetSubscriptionsByAlertId(ctx context.Context, alertId string) ([]Subscription, error)

+ func (a *AlertsAPI) Impl() AlertsService

+ func (a *AlertsAPI) List(ctx context.Context) ([]Alert, error)

+ func (a *AlertsAPI) ListSchedules(ctx context.Context, request ListSchedulesRequest) ([]RefreshSchedule, error)

+ func (a *AlertsAPI) ListSchedulesByAlertId(ctx context.Context, alertId string) ([]RefreshSchedule, error)

+ func (a *AlertsAPI) Subscribe(ctx context.Context, request CreateSubscription) (*Subscription, error)

+ func (a *AlertsAPI) Unsubscribe(ctx context.Context, request UnsubscribeRequest) error

+ func (a *AlertsAPI) UnsubscribeByAlertIdAndSubscriptionId(ctx context.Context, alertId string, subscriptionId string) error

+ func (a *AlertsAPI) Update(ctx context.Context, request EditAlert) error

+ func (a *AlertsAPI) WithImpl(impl AlertsService) *AlertsAPI

+ type AlertsService interface

+ Create func(ctx context.Context, request EditAlert) (*Alert, error)

+ CreateSchedule func(ctx context.Context, request CreateRefreshSchedule) (*RefreshSchedule, error)

+ Delete func(ctx context.Context, request DeleteAlertRequest) error

+ DeleteSchedule func(ctx context.Context, request DeleteScheduleRequest) error

+ Get func(ctx context.Context, request GetAlertRequest) (*Alert, error)

+ GetSubscriptions func(ctx context.Context, request GetSubscriptionsRequest) ([]Subscription, error)

+ List func(ctx context.Context) ([]Alert, error)

+ ListSchedules func(ctx context.Context, request ListSchedulesRequest) ([]RefreshSchedule, error)

+ Subscribe func(ctx context.Context, request CreateSubscription) (*Subscription, error)

+ Unsubscribe func(ctx context.Context, request UnsubscribeRequest) error

+ Update func(ctx context.Context, request EditAlert) error

+ type Channel struct

+ DbsqlVersion string

+ Name ChannelName

+ type ChannelInfo struct

+ DbsqlVersion string

+ Name ChannelName

+ type ChannelName string

+ const ChannelNameChannelNameCurrent

+ const ChannelNameChannelNameCustom

+ const ChannelNameChannelNamePreview

+ const ChannelNameChannelNamePrevious

+ const ChannelNameChannelNameUnspecified

+ func (cn *ChannelName) Set(v string) error

+ func (cn *ChannelName) String() string

+ func (cn *ChannelName) Type() string

+ type CreateDashboardRequest struct

+ DashboardFiltersEnabled bool

+ IsDraft bool

+ IsTrashed bool

+ Name string

+ Tags []string

+ Widgets []Widget

+ type CreateRefreshSchedule struct

+ AlertId string

+ Cron string

+ DataSourceId string

+ type CreateSubscription struct

+ AlertId string

+ DestinationId string

+ UserId int64

+ type CreateWarehouseRequest struct

+ AutoStopMins int

+ Channel *Channel

+ ClusterSize string

+ CreatorName string

+ EnablePhoton bool

+ EnableServerlessCompute bool

+ InstanceProfileArn string

+ MaxNumClusters int

+ MinNumClusters int

+ Name string

+ SpotInstancePolicy SpotInstancePolicy

+ Tags *EndpointTags

+ WarehouseType WarehouseType

+ type CreateWarehouseResponse struct

+ Id string

+ type Dashboard struct

+ CanEdit bool

+ CreatedAt string

+ DashboardFiltersEnabled bool

+ Id string

+ IsArchived bool

+ IsDraft bool

+ IsFavorite bool

+ Name string

+ Options *DashboardOptions

+ PermissionTier PermissionLevel

+ Slug string

+ Tags []string

+ UpdatedAt string

+ User *User

+ UserId int

+ Widgets []Widget

+ type DashboardOptions struct

+ MovedToTrashAt string

+ type DashboardsAPI struct

+ func NewDashboards(client *client.DatabricksClient) *DashboardsAPI

+ func (a *DashboardsAPI) Create(ctx context.Context, request CreateDashboardRequest) (*Dashboard, error)

+ func (a *DashboardsAPI) DashboardNameToIdMap(ctx context.Context, request ListDashboardsRequest) (map[string]string, error)

+ func (a *DashboardsAPI) Delete(ctx context.Context, request DeleteDashboardRequest) error

+ func (a *DashboardsAPI) DeleteByDashboardId(ctx context.Context, dashboardId string) error

+ func (a *DashboardsAPI) Get(ctx context.Context, request GetDashboardRequest) (*Dashboard, error)

+ func (a *DashboardsAPI) GetByDashboardId(ctx context.Context, dashboardId string) (*Dashboard, error)

+ func (a *DashboardsAPI) GetByName(ctx context.Context, name string) (*Dashboard, error)

+ func (a *DashboardsAPI) Impl() DashboardsService

+ func (a *DashboardsAPI) ListAll(ctx context.Context, request ListDashboardsRequest) ([]Dashboard, error)

+ func (a *DashboardsAPI) Restore(ctx context.Context, request RestoreDashboardRequest) error

+ func (a *DashboardsAPI) WithImpl(impl DashboardsService) *DashboardsAPI

+ type DashboardsService interface

+ Create func(ctx context.Context, request CreateDashboardRequest) (*Dashboard, error)

+ Delete func(ctx context.Context, request DeleteDashboardRequest) error

+ Get func(ctx context.Context, request GetDashboardRequest) (*Dashboard, error)

+ List func(ctx context.Context, request ListDashboardsRequest) (*ListResponse, error)

+ Restore func(ctx context.Context, request RestoreDashboardRequest) error

+ type DataSource struct

+ Id string

+ Name string

+ PauseReason string

+ Paused int

+ SupportsAutoLimit bool

+ Syntax string

+ Type string

+ ViewOnly bool

+ WarehouseId string

+ type DataSourcesAPI struct

+ func NewDataSources(client *client.DatabricksClient) *DataSourcesAPI

+ func (a *DataSourcesAPI) DataSourceNameToIdMap(ctx context.Context) (map[string]string, error)

+ func (a *DataSourcesAPI) GetByName(ctx context.Context, name string) (*DataSource, error)

+ func (a *DataSourcesAPI) Impl() DataSourcesService

+ func (a *DataSourcesAPI) List(ctx context.Context) ([]DataSource, error)

+ func (a *DataSourcesAPI) WithImpl(impl DataSourcesService) *DataSourcesAPI

+ type DataSourcesService interface

+ List func(ctx context.Context) ([]DataSource, error)

+ type DbsqlPermissionsAPI struct

+ func NewDbsqlPermissions(client *client.DatabricksClient) *DbsqlPermissionsAPI

+ func (a *DbsqlPermissionsAPI) Get(ctx context.Context, request GetDbsqlPermissionRequest) (*GetResponse, error)

+ func (a *DbsqlPermissionsAPI) GetByObjectTypeAndObjectId(ctx context.Context, objectType ObjectTypePlural, objectId string) (*GetResponse, error)

+ func (a *DbsqlPermissionsAPI) Impl() DbsqlPermissionsService

+ func (a *DbsqlPermissionsAPI) Set(ctx context.Context, request SetRequest) (*SetResponse, error)

+ func (a *DbsqlPermissionsAPI) TransferOwnership(ctx context.Context, request TransferOwnershipRequest) (*Success, error)

+ func (a *DbsqlPermissionsAPI) WithImpl(impl DbsqlPermissionsService) *DbsqlPermissionsAPI

+ type DbsqlPermissionsService interface

+ Get func(ctx context.Context, request GetDbsqlPermissionRequest) (*GetResponse, error)

+ Set func(ctx context.Context, request SetRequest) (*SetResponse, error)

+ TransferOwnership func(ctx context.Context, request TransferOwnershipRequest) (*Success, error)

+ type DeleteAlertRequest struct

+ AlertId string

+ type DeleteDashboardRequest struct

+ DashboardId string

+ type DeleteQueryRequest struct

+ QueryId string

+ type DeleteScheduleRequest struct

+ AlertId string

+ ScheduleId string

+ type DeleteWarehouseRequest struct

+ Id string

+ type Destination struct

+ Id string

+ Name string

+ Type DestinationType

+ type DestinationType string

+ const DestinationTypeEmail

+ const DestinationTypeHangoutsChat

+ const DestinationTypeMattermost

+ const DestinationTypeMicrosoftTeams

+ const DestinationTypePagerduty

+ const DestinationTypeSlack

+ const DestinationTypeWebhook

+ func (dt *DestinationType) Set(v string) error

+ func (dt *DestinationType) String() string

+ func (dt *DestinationType) Type() string

+ type EditAlert struct

+ AlertId string

+ Name string

+ Options AlertOptions

+ QueryId string

+ Rearm int

+ type EditWarehouseRequest struct

+ AutoStopMins int

+ Channel *Channel

+ ClusterSize string

+ CreatorName string

+ EnableDatabricksCompute bool

+ EnablePhoton bool

+ EnableServerlessCompute bool

+ Id string

+ InstanceProfileArn string

+ MaxNumClusters int

+ MinNumClusters int

+ Name string

+ SpotInstancePolicy SpotInstancePolicy

+ Tags *EndpointTags

+ WarehouseType WarehouseType

+ type EndpointConfPair struct

+ Key string

+ Value string

+ type EndpointHealth struct

+ Details string

+ FailureReason *TerminationReason

+ Message string

+ Status Status

+ Summary string

+ type EndpointInfo struct

+ AutoStopMins int

+ Channel *Channel

+ ClusterSize string

+ CreatorName string

+ EnableDatabricksCompute bool

+ EnablePhoton bool

+ EnableServerlessCompute bool

+ Health *EndpointHealth

+ Id string

+ InstanceProfileArn string

+ JdbcUrl string

+ MaxNumClusters int

+ MinNumClusters int

+ Name string

+ NumActiveSessions int64

+ NumClusters int

+ OdbcParams *OdbcParams

+ SpotInstancePolicy SpotInstancePolicy

+ State State

+ Tags *EndpointTags

+ WarehouseType WarehouseType

+ type EndpointTagPair struct

+ Key string

+ Value string

+ type EndpointTags struct

+ CustomTags []EndpointTagPair

+ type GetAlertRequest struct

+ AlertId string

+ type GetDashboardRequest struct

+ DashboardId string

+ type GetDbsqlPermissionRequest struct

+ ObjectId string

+ ObjectType ObjectTypePlural

+ type GetQueryRequest struct

+ QueryId string

+ type GetResponse struct

+ AccessControlList []AccessControl

+ ObjectId ObjectType

+ ObjectType string

+ type GetSubscriptionsRequest struct

+ AlertId string

+ type GetWarehouseRequest struct

+ Id string

+ type GetWarehouseResponse struct

+ AutoStopMins int

+ Channel *Channel

+ ClusterSize string

+ CreatorName string

+ EnableDatabricksCompute bool

+ EnablePhoton bool

+ EnableServerlessCompute bool

+ Health *EndpointHealth

+ Id string

+ InstanceProfileArn string

+ JdbcUrl string

+ MaxNumClusters int

+ MinNumClusters int

+ Name string

+ NumActiveSessions int64

+ NumClusters int

+ OdbcParams *OdbcParams

+ SpotInstancePolicy SpotInstancePolicy

+ State State

+ Tags *EndpointTags

+ WarehouseType WarehouseType

+ type GetWorkspaceWarehouseConfigResponse struct

+ Channel *Channel

+ ConfigParam *RepeatedEndpointConfPairs

+ DataAccessConfig []EndpointConfPair

+ EnableDatabricksCompute bool

+ EnableServerlessCompute bool

+ EnabledWarehouseTypes []WarehouseTypePair

+ GlobalParam *RepeatedEndpointConfPairs

+ GoogleServiceAccount string

+ InstanceProfileArn string

+ SecurityPolicy GetWorkspaceWarehouseConfigResponseSecurityPolicy

+ SqlConfigurationParameters *RepeatedEndpointConfPairs

+ type GetWorkspaceWarehouseConfigResponseSecurityPolicy string

+ const GetWorkspaceWarehouseConfigResponseSecurityPolicyDataAccessControl

+ const GetWorkspaceWarehouseConfigResponseSecurityPolicyNone

+ const GetWorkspaceWarehouseConfigResponseSecurityPolicyPassthrough

+ func (gwwcrsp *GetWorkspaceWarehouseConfigResponseSecurityPolicy) Set(v string) error

+ func (gwwcrsp *GetWorkspaceWarehouseConfigResponseSecurityPolicy) String() string

+ func (gwwcrsp *GetWorkspaceWarehouseConfigResponseSecurityPolicy) Type() string

+ type ListDashboardsRequest struct

+ Order ListOrder

+ Page int

+ PageSize int

+ Q string

+ type ListOrder string

+ const ListOrderCreatedAt

+ const ListOrderName

+ func (lo *ListOrder) Set(v string) error

+ func (lo *ListOrder) String() string

+ func (lo *ListOrder) Type() string

+ type ListQueriesRequest struct

+ Order string

+ Page int

+ PageSize int

+ Q string

+ type ListQueriesResponse struct

+ HasNextPage bool

+ NextPageToken string

+ Res []QueryInfo

+ type ListQueryHistoryRequest struct

+ FilterBy *QueryFilter

+ IncludeMetrics bool

+ MaxResults int

+ PageToken string

+ type ListResponse struct

+ Count int

+ Page int

+ PageSize int

+ Results []Dashboard

+ type ListSchedulesRequest struct

+ AlertId string

+ type ListWarehousesRequest struct

+ RunAsUserId int

+ type ListWarehousesResponse struct

+ Warehouses []EndpointInfo

+ type ObjectType string

+ const ObjectTypeAlert

+ const ObjectTypeDashboard

+ const ObjectTypeDataSource

+ const ObjectTypeQuery

+ func (ot *ObjectType) Set(v string) error

+ func (ot *ObjectType) String() string

+ func (ot *ObjectType) Type() string

+ type ObjectTypePlural string

+ const ObjectTypePluralAlerts

+ const ObjectTypePluralDashboards

+ const ObjectTypePluralDataSources

+ const ObjectTypePluralQueries

+ func (otp *ObjectTypePlural) Set(v string) error

+ func (otp *ObjectTypePlural) String() string

+ func (otp *ObjectTypePlural) Type() string

+ type OdbcParams struct

+ Hostname string

+ Path string

+ Port int

+ Protocol string

+ type OwnableObjectType string

+ const OwnableObjectTypeAlert

+ const OwnableObjectTypeDashboard

+ const OwnableObjectTypeQuery

+ func (oot *OwnableObjectType) Set(v string) error

+ func (oot *OwnableObjectType) String() string

+ func (oot *OwnableObjectType) Type() string

+ type Parameter struct

+ Name string

+ Title string

+ Type ParameterType

+ Value any

+ type ParameterType string

+ const ParameterTypeDatetime

+ const ParameterTypeNumber

+ const ParameterTypeText

+ func (pt *ParameterType) Set(v string) error

+ func (pt *ParameterType) String() string

+ func (pt *ParameterType) Type() string

+ type PermissionLevel string

+ const PermissionLevelCanManage

+ const PermissionLevelCanRun

+ const PermissionLevelCanView

+ func (pl *PermissionLevel) Set(v string) error

+ func (pl *PermissionLevel) String() string

+ func (pl *PermissionLevel) Type() string

+ type PlansState string

+ const PlansStateEmpty

+ const PlansStateExists

+ const PlansStateIgnoredLargePlansSize

+ const PlansStateIgnoredSmallDuration

+ const PlansStateIgnoredSparkPlanType

+ const PlansStateUnknown

+ func (ps *PlansState) Set(v string) error

+ func (ps *PlansState) String() string

+ func (ps *PlansState) Type() string

+ type QueriesAPI struct

+ func NewQueries(client *client.DatabricksClient) *QueriesAPI

+ func (a *QueriesAPI) Create(ctx context.Context, request QueryPostContent) (*Query, error)

+ func (a *QueriesAPI) Delete(ctx context.Context, request DeleteQueryRequest) error

+ func (a *QueriesAPI) DeleteByQueryId(ctx context.Context, queryId string) error

+ func (a *QueriesAPI) Get(ctx context.Context, request GetQueryRequest) (*Query, error)

+ func (a *QueriesAPI) GetByName(ctx context.Context, name string) (*Query, error)

+ func (a *QueriesAPI) GetByQueryId(ctx context.Context, queryId string) (*Query, error)

+ func (a *QueriesAPI) Impl() QueriesService

+ func (a *QueriesAPI) ListAll(ctx context.Context, request ListQueriesRequest) ([]Query, error)

+ func (a *QueriesAPI) QueryNameToIdMap(ctx context.Context, request ListQueriesRequest) (map[string]string, error)

+ func (a *QueriesAPI) Restore(ctx context.Context, request RestoreQueryRequest) error

+ func (a *QueriesAPI) Update(ctx context.Context, request QueryPostContent) (*Query, error)

+ func (a *QueriesAPI) WithImpl(impl QueriesService) *QueriesAPI

+ type QueriesService interface

+ Create func(ctx context.Context, request QueryPostContent) (*Query, error)

+ Delete func(ctx context.Context, request DeleteQueryRequest) error

+ Get func(ctx context.Context, request GetQueryRequest) (*Query, error)

+ List func(ctx context.Context, request ListQueriesRequest) (*QueryList, error)

+ Restore func(ctx context.Context, request RestoreQueryRequest) error

+ Update func(ctx context.Context, request QueryPostContent) (*Query, error)

+ type Query struct

+ CanEdit bool

+ CreatedAt string

+ DataSourceId string

+ Description string

+ Id string

+ IsArchived bool

+ IsDraft bool

+ IsFavorite bool

+ IsSafe bool

+ LastModifiedBy *User

+ LastModifiedById int

+ LatestQueryDataId string

+ Name string

+ Options *QueryOptions

+ PermissionTier PermissionLevel

+ Query string

+ QueryHash string

+ Schedule *QueryInterval

+ Tags []string

+ UpdatedAt string

+ User *User

+ UserId int

+ Visualizations []Visualization

+ type QueryFilter struct

+ QueryStartTimeRange *TimeRange

+ Statuses []QueryStatus

+ UserIds []int

+ WarehouseIds []string

+ type QueryHistoryAPI struct

+ func NewQueryHistory(client *client.DatabricksClient) *QueryHistoryAPI

+ func (a *QueryHistoryAPI) Impl() QueryHistoryService

+ func (a *QueryHistoryAPI) ListAll(ctx context.Context, request ListQueryHistoryRequest) ([]QueryInfo, error)

+ func (a *QueryHistoryAPI) WithImpl(impl QueryHistoryService) *QueryHistoryAPI

+ type QueryHistoryService interface

+ List func(ctx context.Context, request ListQueryHistoryRequest) (*ListQueriesResponse, error)

+ type QueryInfo struct

+ ChannelUsed *ChannelInfo

+ Duration int

+ EndpointId string

+ ErrorMessage string

+ ExecutedAsUserId int

+ ExecutedAsUserName string

+ ExecutionEndTimeMs int

+ IsFinal bool

+ LookupKey string

+ Metrics *QueryMetrics

+ PlansState PlansState

+ QueryEndTimeMs int

+ QueryId string

+ QueryStartTimeMs int

+ QueryText string

+ RowsProduced int

+ SparkUiUrl string

+ StatementType QueryStatementType

+ Status QueryStatus

+ UserId int

+ UserName string

+ WarehouseId string

+ type QueryInterval struct

+ DayOfWeek string

+ Interval int

+ Time string

+ Until string

+ type QueryList struct

+ Count int

+ Page int

+ PageSize int

+ Results []Query

+ type QueryMetrics struct

+ CompilationTimeMs int

+ ExecutionTimeMs int

+ NetworkSentBytes int

+ PhotonTotalTimeMs int

+ QueuedOverloadTimeMs int

+ QueuedProvisioningTimeMs int

+ ReadBytes int

+ ReadCacheBytes int

+ ReadFilesCount int

+ ReadPartitionsCount int

+ ReadRemoteBytes int

+ ResultFetchTimeMs int

+ ResultFromCache bool

+ RowsProducedCount int

+ RowsReadCount int

+ SpillToDiskBytes int

+ TaskTotalTimeMs int

+ TotalFilesCount int

+ TotalPartitionsCount int

+ TotalTimeMs int

+ WriteRemoteBytes int

+ type QueryOptions struct

+ MovedToTrashAt string

+ Parameters []Parameter

+ type QueryPostContent struct

+ DataSourceId string

+ Description string

+ Name string

+ Options any

+ Query string

+ QueryId string

+ Schedule *QueryInterval

+ type QueryStatementType string

+ const QueryStatementTypeAlter

+ const QueryStatementTypeAnalyze

+ const QueryStatementTypeCopy

+ const QueryStatementTypeCreate

+ const QueryStatementTypeDelete

+ const QueryStatementTypeDescribe

+ const QueryStatementTypeDrop

+ const QueryStatementTypeExplain

+ const QueryStatementTypeGrant

+ const QueryStatementTypeInsert

+ const QueryStatementTypeMerge

+ const QueryStatementTypeOptimize

+ const QueryStatementTypeOther

+ const QueryStatementTypeRefresh

+ const QueryStatementTypeReplace

+ const QueryStatementTypeRevoke

+ const QueryStatementTypeSelect

+ const QueryStatementTypeSet

+ const QueryStatementTypeShow

+ const QueryStatementTypeTruncate

+ const QueryStatementTypeUpdate

+ const QueryStatementTypeUse

+ func (qst *QueryStatementType) Set(v string) error

+ func (qst *QueryStatementType) String() string

+ func (qst *QueryStatementType) Type() string

+ type QueryStatus string

+ const QueryStatusCanceled

+ const QueryStatusFailed

+ const QueryStatusFinished

+ const QueryStatusQueued

+ const QueryStatusRunning

+ func (qs *QueryStatus) Set(v string) error

+ func (qs *QueryStatus) String() string

+ func (qs *QueryStatus) Type() string

+ type RefreshSchedule struct

+ Cron string

+ DataSourceId string

+ Id string

+ type RepeatedEndpointConfPairs struct

+ ConfigPair []EndpointConfPair

+ ConfigurationPairs []EndpointConfPair

+ type RestoreDashboardRequest struct

+ DashboardId string

+ type RestoreQueryRequest struct

+ QueryId string

+ type SetRequest struct

+ AccessControlList []AccessControl

+ ObjectId string

+ ObjectType ObjectTypePlural

+ type SetResponse struct

+ AccessControlList []AccessControl

+ ObjectId ObjectType

+ ObjectType string

+ type SetWorkspaceWarehouseConfigRequest struct

+ Channel *Channel

+ ConfigParam *RepeatedEndpointConfPairs

+ DataAccessConfig []EndpointConfPair

+ EnableDatabricksCompute bool

+ EnableServerlessCompute bool

+ EnabledWarehouseTypes []WarehouseTypePair

+ GlobalParam *RepeatedEndpointConfPairs

+ GoogleServiceAccount string

+ InstanceProfileArn string

+ SecurityPolicy SetWorkspaceWarehouseConfigRequestSecurityPolicy

+ ServerlessAgreement bool

+ SqlConfigurationParameters *RepeatedEndpointConfPairs

+ type SetWorkspaceWarehouseConfigRequestSecurityPolicy string

+ const SetWorkspaceWarehouseConfigRequestSecurityPolicyDataAccessControl

+ const SetWorkspaceWarehouseConfigRequestSecurityPolicyNone

+ const SetWorkspaceWarehouseConfigRequestSecurityPolicyPassthrough

+ func (swwcrsp *SetWorkspaceWarehouseConfigRequestSecurityPolicy) Set(v string) error

+ func (swwcrsp *SetWorkspaceWarehouseConfigRequestSecurityPolicy) String() string

+ func (swwcrsp *SetWorkspaceWarehouseConfigRequestSecurityPolicy) Type() string

+ type SpotInstancePolicy string

+ const SpotInstancePolicyCostOptimized

+ const SpotInstancePolicyPolicyUnspecified

+ const SpotInstancePolicyReliabilityOptimized

+ func (sip *SpotInstancePolicy) Set(v string) error

+ func (sip *SpotInstancePolicy) String() string

+ func (sip *SpotInstancePolicy) Type() string

+ type StartRequest struct

+ Id string

+ type State string

+ const StateDeleted

+ const StateDeleting

+ const StateRunning

+ const StateStarting

+ const StateStopped

+ const StateStopping

+ func (s *State) Set(v string) error

+ func (s *State) String() string

+ func (s *State) Type() string

+ type Status string

+ const StatusDegraded

+ const StatusFailed

+ const StatusHealthy

+ const StatusStatusUnspecified

+ func (s *Status) Set(v string) error

+ func (s *Status) String() string

+ func (s *Status) Type() string

+ type StopRequest struct

+ Id string

+ type Subscription struct

+ AlertId string

+ Destination *Destination

+ Id string

+ User *User

+ type Success struct

+ Message SuccessMessage

+ type SuccessMessage string

+ const SuccessMessageSuccess

+ func (sm *SuccessMessage) Set(v string) error

+ func (sm *SuccessMessage) String() string

+ func (sm *SuccessMessage) Type() string

+ type TerminationReason struct

+ Code TerminationReasonCode

+ Parameters map[string]string

+ Type TerminationReasonType

+ type TerminationReasonCode string

+ const TerminationReasonCodeAbuseDetected

+ const TerminationReasonCodeAttachProjectFailure

+ const TerminationReasonCodeAwsAuthorizationFailure

+ const TerminationReasonCodeAwsInsufficientFreeAddressesInSubnetFailure

+ const TerminationReasonCodeAwsInsufficientInstanceCapacityFailure

+ const TerminationReasonCodeAwsMaxSpotInstanceCountExceededFailure

+ const TerminationReasonCodeAwsRequestLimitExceeded

+ const TerminationReasonCodeAwsUnsupportedFailure

+ const TerminationReasonCodeAzureByokKeyPermissionFailure

+ const TerminationReasonCodeAzureEphemeralDiskFailure

+ const TerminationReasonCodeAzureInvalidDeploymentTemplate

+ const TerminationReasonCodeAzureOperationNotAllowedException

+ const TerminationReasonCodeAzureQuotaExceededException

+ const TerminationReasonCodeAzureResourceManagerThrottling

+ const TerminationReasonCodeAzureResourceProviderThrottling

+ const TerminationReasonCodeAzureUnexpectedDeploymentTemplateFailure

+ const TerminationReasonCodeAzureVmExtensionFailure

+ const TerminationReasonCodeAzureVnetConfigurationFailure

+ const TerminationReasonCodeBootstrapTimeout

+ const TerminationReasonCodeBootstrapTimeoutCloudProviderException

+ const TerminationReasonCodeCloudProviderDiskSetupFailure

+ const TerminationReasonCodeCloudProviderLaunchFailure

+ const TerminationReasonCodeCloudProviderResourceStockout

+ const TerminationReasonCodeCloudProviderShutdown

+ const TerminationReasonCodeCommunicationLost

+ const TerminationReasonCodeContainerLaunchFailure

+ const TerminationReasonCodeControlPlaneRequestFailure

+ const TerminationReasonCodeDatabaseConnectionFailure

+ const TerminationReasonCodeDbfsComponentUnhealthy

+ const TerminationReasonCodeDockerImagePullFailure

+ const TerminationReasonCodeDriverUnreachable

+ const TerminationReasonCodeDriverUnresponsive

+ const TerminationReasonCodeExecutionComponentUnhealthy

+ const TerminationReasonCodeGcpQuotaExceeded

+ const TerminationReasonCodeGcpServiceAccountDeleted

+ const TerminationReasonCodeGlobalInitScriptFailure

+ const TerminationReasonCodeHiveMetastoreProvisioningFailure

+ const TerminationReasonCodeImagePullPermissionDenied

+ const TerminationReasonCodeInactivity

+ const TerminationReasonCodeInitScriptFailure

+ const TerminationReasonCodeInstancePoolClusterFailure

+ const TerminationReasonCodeInstanceUnreachable

+ const TerminationReasonCodeInternalError

+ const TerminationReasonCodeInvalidArgument

+ const TerminationReasonCodeInvalidSparkImage

+ const TerminationReasonCodeIpExhaustionFailure

+ const TerminationReasonCodeJobFinished

+ const TerminationReasonCodeKsAutoscalingFailure

+ const TerminationReasonCodeKsDbrClusterLaunchTimeout

+ const TerminationReasonCodeMetastoreComponentUnhealthy

+ const TerminationReasonCodeNephosResourceManagement

+ const TerminationReasonCodeNetworkConfigurationFailure

+ const TerminationReasonCodeNfsMountFailure

+ const TerminationReasonCodeNpipTunnelSetupFailure

+ const TerminationReasonCodeNpipTunnelTokenFailure

+ const TerminationReasonCodeRequestRejected

+ const TerminationReasonCodeRequestThrottled

+ const TerminationReasonCodeSecretResolutionError

+ const TerminationReasonCodeSecurityDaemonRegistrationException

+ const TerminationReasonCodeSelfBootstrapFailure

+ const TerminationReasonCodeSkippedSlowNodes

+ const TerminationReasonCodeSlowImageDownload

+ const TerminationReasonCodeSparkError

+ const TerminationReasonCodeSparkImageDownloadFailure

+ const TerminationReasonCodeSparkStartupFailure

+ const TerminationReasonCodeSpotInstanceTermination

+ const TerminationReasonCodeStorageDownloadFailure

+ const TerminationReasonCodeStsClientSetupFailure

+ const TerminationReasonCodeSubnetExhaustedFailure

+ const TerminationReasonCodeTemporarilyUnavailable

+ const TerminationReasonCodeTrialExpired

+ const TerminationReasonCodeUnexpectedLaunchFailure

+ const TerminationReasonCodeUnknown

+ const TerminationReasonCodeUnsupportedInstanceType

+ const TerminationReasonCodeUpdateInstanceProfileFailure

+ const TerminationReasonCodeUserRequest

+ const TerminationReasonCodeWorkerSetupFailure

+ const TerminationReasonCodeWorkspaceCancelledError

+ const TerminationReasonCodeWorkspaceConfigurationError

+ func (trc *TerminationReasonCode) Set(v string) error

+ func (trc *TerminationReasonCode) String() string

+ func (trc *TerminationReasonCode) Type() string

+ type TerminationReasonType string

+ const TerminationReasonTypeClientError

+ const TerminationReasonTypeCloudFailure

+ const TerminationReasonTypeServiceFault

+ const TerminationReasonTypeSuccess

+ func (trt *TerminationReasonType) Set(v string) error

+ func (trt *TerminationReasonType) String() string

+ func (trt *TerminationReasonType) Type() string

+ type TimeRange struct

+ EndTimeMs int

+ StartTimeMs int

+ type TransferOwnershipObjectId struct

+ NewOwner string

+ type TransferOwnershipRequest struct

+ NewOwner string

+ ObjectId TransferOwnershipObjectId

+ ObjectType OwnableObjectType

+ type UnsubscribeRequest struct

+ AlertId string

+ SubscriptionId string

+ type User struct

+ Email string

+ Id int

+ IsDbAdmin bool

+ Name string

+ ProfileImageUrl string

+ type Visualization struct

+ CreatedAt string

+ Description string

+ Id string

+ Name string

+ Options any

+ Type string

+ UpdatedAt string

+ type WarehouseType string

+ const WarehouseTypeClassic

+ const WarehouseTypePro

+ const WarehouseTypeTypeUnspecified

+ func (wt *WarehouseType) Set(v string) error

+ func (wt *WarehouseType) String() string

+ func (wt *WarehouseType) Type() string

+ type WarehouseTypePair struct

+ Enabled bool

+ WarehouseType WarehouseType

+ type WarehousesAPI struct

+ func NewWarehouses(client *client.DatabricksClient) *WarehousesAPI

+ func (a *WarehousesAPI) Create(ctx context.Context, request CreateWarehouseRequest) (*CreateWarehouseResponse, error)

+ func (a *WarehousesAPI) CreateAndWait(ctx context.Context, createWarehouseRequest CreateWarehouseRequest, ...) (*GetWarehouseResponse, error)

+ func (a *WarehousesAPI) Delete(ctx context.Context, request DeleteWarehouseRequest) error

+ func (a *WarehousesAPI) DeleteAndWait(ctx context.Context, deleteWarehouseRequest DeleteWarehouseRequest, ...) (*GetWarehouseResponse, error)

+ func (a *WarehousesAPI) DeleteById(ctx context.Context, id string) error

+ func (a *WarehousesAPI) DeleteByIdAndWait(ctx context.Context, id string, ...) (*GetWarehouseResponse, error)

+ func (a *WarehousesAPI) Edit(ctx context.Context, request EditWarehouseRequest) error

+ func (a *WarehousesAPI) EditAndWait(ctx context.Context, editWarehouseRequest EditWarehouseRequest, ...) (*GetWarehouseResponse, error)

+ func (a *WarehousesAPI) EndpointInfoNameToIdMap(ctx context.Context, request ListWarehousesRequest) (map[string]string, error)

+ func (a *WarehousesAPI) Get(ctx context.Context, request GetWarehouseRequest) (*GetWarehouseResponse, error)

+ func (a *WarehousesAPI) GetAndWait(ctx context.Context, getWarehouseRequest GetWarehouseRequest, ...) (*GetWarehouseResponse, error)

+ func (a *WarehousesAPI) GetById(ctx context.Context, id string) (*GetWarehouseResponse, error)

+ func (a *WarehousesAPI) GetByIdAndWait(ctx context.Context, id string, ...) (*GetWarehouseResponse, error)

+ func (a *WarehousesAPI) GetByName(ctx context.Context, name string) (*EndpointInfo, error)

+ func (a *WarehousesAPI) GetWorkspaceWarehouseConfig(ctx context.Context) (*GetWorkspaceWarehouseConfigResponse, error)

+ func (a *WarehousesAPI) Impl() WarehousesService

+ func (a *WarehousesAPI) ListAll(ctx context.Context, request ListWarehousesRequest) ([]EndpointInfo, error)

+ func (a *WarehousesAPI) SetWorkspaceWarehouseConfig(ctx context.Context, request SetWorkspaceWarehouseConfigRequest) error

+ func (a *WarehousesAPI) Start(ctx context.Context, request StartRequest) error

+ func (a *WarehousesAPI) StartAndWait(ctx context.Context, startRequest StartRequest, ...) (*GetWarehouseResponse, error)

+ func (a *WarehousesAPI) Stop(ctx context.Context, request StopRequest) error

+ func (a *WarehousesAPI) StopAndWait(ctx context.Context, stopRequest StopRequest, ...) (*GetWarehouseResponse, error)

+ func (a *WarehousesAPI) WithImpl(impl WarehousesService) *WarehousesAPI

+ type WarehousesService interface

+ Create func(ctx context.Context, request CreateWarehouseRequest) (*CreateWarehouseResponse, error)

+ Delete func(ctx context.Context, request DeleteWarehouseRequest) error

+ Edit func(ctx context.Context, request EditWarehouseRequest) error

+ Get func(ctx context.Context, request GetWarehouseRequest) (*GetWarehouseResponse, error)

+ GetWorkspaceWarehouseConfig func(ctx context.Context) (*GetWorkspaceWarehouseConfigResponse, error)

+ List func(ctx context.Context, request ListWarehousesRequest) (*ListWarehousesResponse, error)

+ SetWorkspaceWarehouseConfig func(ctx context.Context, request SetWorkspaceWarehouseConfigRequest) error

+ Start func(ctx context.Context, request StartRequest) error

+ Stop func(ctx context.Context, request StopRequest) error

+ type Widget struct

+ Id int

+ Options *WidgetOptions

+ Visualization *Visualization

+ Width int

+ type WidgetOptions struct

+ CreatedAt string

+ DashboardId string

+ IsHidden bool

+ ParameterMappings any

+ Position any

+ Text string

+ UpdatedAt string

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