Versions in this module Expand all Collapse all v0 v0.13.3 Jul 20, 2023 v0.13.2 Jul 20, 2023 Changes in this version + type BuildLogsRequest struct + Name string + ServedModelName string + type BuildLogsResponse struct + Logs string + type CreateServingEndpoint struct + Config EndpointCoreConfigInput + Name string + type DeleteServingEndpointRequest struct + Name string + type EndpointCoreConfigInput struct + Name string + ServedModels []ServedModelInput + TrafficConfig *TrafficConfig + type EndpointCoreConfigOutput struct + ConfigVersion int + ServedModels []ServedModelOutput + TrafficConfig *TrafficConfig + type EndpointCoreConfigSummary struct + ServedModels []ServedModelSpec + type EndpointPendingConfig struct + ConfigVersion int + ServedModels []ServedModelOutput + StartTime int64 + TrafficConfig *TrafficConfig + type EndpointState struct + ConfigUpdate EndpointStateConfigUpdate + Ready EndpointStateReady + type EndpointStateConfigUpdate string + const EndpointStateConfigUpdateInProgress + const EndpointStateConfigUpdateNotUpdating + const EndpointStateConfigUpdateUpdateFailed + func (f *EndpointStateConfigUpdate) Set(v string) error + func (f *EndpointStateConfigUpdate) String() string + func (f *EndpointStateConfigUpdate) Type() string + type EndpointStateReady string + const EndpointStateReadyNotReady + const EndpointStateReadyReady + func (f *EndpointStateReady) Set(v string) error + func (f *EndpointStateReady) String() string + func (f *EndpointStateReady) Type() string + type ExportMetricsRequest struct + Name string + type GetServingEndpointRequest struct + Name string + type ListEndpointsResponse struct + Endpoints []ServingEndpoint + type LogsRequest struct + Name string + ServedModelName string + type QueryEndpointResponse struct + Predictions []any + type QueryRequest struct + Name string + type Route struct + ServedModelName string + TrafficPercentage int + type ServedModelInput struct + EnvironmentVars map[string]string + ModelName string + ModelVersion string + Name string + ScaleToZeroEnabled bool + WorkloadSize string + type ServedModelOutput struct + CreationTimestamp int64 + Creator string + EnvironmentVars map[string]string + ModelName string + ModelVersion string + Name string + ScaleToZeroEnabled bool + State *ServedModelState + WorkloadSize string + type ServedModelSpec struct + ModelName string + ModelVersion string + Name string + type ServedModelState struct + Deployment ServedModelStateDeployment + DeploymentStateMessage string + type ServedModelStateDeployment string + const ServedModelStateDeploymentDeploymentAborted + const ServedModelStateDeploymentDeploymentCreating + const ServedModelStateDeploymentDeploymentFailed + const ServedModelStateDeploymentDeploymentReady + const ServedModelStateDeploymentDeploymentRecovering + func (f *ServedModelStateDeployment) Set(v string) error + func (f *ServedModelStateDeployment) String() string + func (f *ServedModelStateDeployment) Type() string + type ServerLogsResponse struct + Logs string + type ServingEndpoint struct + Config *EndpointCoreConfigSummary + CreationTimestamp int64 + Creator string + Id string + LastUpdatedTimestamp int64 + Name string + State *EndpointState + type ServingEndpointDetailed struct + Config *EndpointCoreConfigOutput + CreationTimestamp int64 + Creator string + Id string + LastUpdatedTimestamp int64 + Name string + PendingConfig *EndpointPendingConfig + PermissionLevel ServingEndpointDetailedPermissionLevel + State *EndpointState + type ServingEndpointDetailedPermissionLevel string + const ServingEndpointDetailedPermissionLevelCanManage + const ServingEndpointDetailedPermissionLevelCanQuery + const ServingEndpointDetailedPermissionLevelCanView + func (f *ServingEndpointDetailedPermissionLevel) Set(v string) error + func (f *ServingEndpointDetailedPermissionLevel) String() string + func (f *ServingEndpointDetailedPermissionLevel) Type() string + type ServingEndpointsAPI struct + func NewServingEndpoints(client *client.DatabricksClient) *ServingEndpointsAPI + func (a *ServingEndpointsAPI) BuildLogs(ctx context.Context, request BuildLogsRequest) (*BuildLogsResponse, error) + func (a *ServingEndpointsAPI) BuildLogsByNameAndServedModelName(ctx context.Context, name string, servedModelName string) (*BuildLogsResponse, error) + func (a *ServingEndpointsAPI) Create(ctx context.Context, createServingEndpoint CreateServingEndpoint) (*WaitGetServingEndpointNotUpdating[ServingEndpointDetailed], error) + func (a *ServingEndpointsAPI) CreateAndWait(ctx context.Context, createServingEndpoint CreateServingEndpoint, ...) (*ServingEndpointDetailed, error) + func (a *ServingEndpointsAPI) Delete(ctx context.Context, request DeleteServingEndpointRequest) error + func (a *ServingEndpointsAPI) DeleteByName(ctx context.Context, name string) error + func (a *ServingEndpointsAPI) ExportMetrics(ctx context.Context, request ExportMetricsRequest) error + func (a *ServingEndpointsAPI) ExportMetricsByName(ctx context.Context, name string) error + func (a *ServingEndpointsAPI) Get(ctx context.Context, request GetServingEndpointRequest) (*ServingEndpointDetailed, error) + func (a *ServingEndpointsAPI) GetByName(ctx context.Context, name string) (*ServingEndpointDetailed, error) + func (a *ServingEndpointsAPI) Impl() ServingEndpointsService + func (a *ServingEndpointsAPI) ListAll(ctx context.Context) ([]ServingEndpoint, error) + func (a *ServingEndpointsAPI) Logs(ctx context.Context, request LogsRequest) (*ServerLogsResponse, error) + func (a *ServingEndpointsAPI) LogsByNameAndServedModelName(ctx context.Context, name string, servedModelName string) (*ServerLogsResponse, error) + func (a *ServingEndpointsAPI) Query(ctx context.Context, request QueryRequest) (*QueryEndpointResponse, error) + func (a *ServingEndpointsAPI) UpdateConfig(ctx context.Context, endpointCoreConfigInput EndpointCoreConfigInput) (*WaitGetServingEndpointNotUpdating[ServingEndpointDetailed], error) + func (a *ServingEndpointsAPI) UpdateConfigAndWait(ctx context.Context, endpointCoreConfigInput EndpointCoreConfigInput, ...) (*ServingEndpointDetailed, error) + func (a *ServingEndpointsAPI) WaitGetServingEndpointNotUpdating(ctx context.Context, name string, timeout time.Duration, ...) (*ServingEndpointDetailed, error) + func (a *ServingEndpointsAPI) WithImpl(impl ServingEndpointsService) *ServingEndpointsAPI + type ServingEndpointsService interface + BuildLogs func(ctx context.Context, request BuildLogsRequest) (*BuildLogsResponse, error) + Create func(ctx context.Context, request CreateServingEndpoint) (*ServingEndpointDetailed, error) + Delete func(ctx context.Context, request DeleteServingEndpointRequest) error + ExportMetrics func(ctx context.Context, request ExportMetricsRequest) error + Get func(ctx context.Context, request GetServingEndpointRequest) (*ServingEndpointDetailed, error) + List func(ctx context.Context) (*ListEndpointsResponse, error) + Logs func(ctx context.Context, request LogsRequest) (*ServerLogsResponse, error) + Query func(ctx context.Context, request QueryRequest) (*QueryEndpointResponse, error) + UpdateConfig func(ctx context.Context, request EndpointCoreConfigInput) (*ServingEndpointDetailed, error) + type TrafficConfig struct + Routes []Route + type WaitGetServingEndpointNotUpdating struct + Name string + Response *R + func (w *WaitGetServingEndpointNotUpdating[R]) Get() (*ServingEndpointDetailed, error) + func (w *WaitGetServingEndpointNotUpdating[R]) GetWithTimeout(timeout time.Duration) (*ServingEndpointDetailed, error) + func (w *WaitGetServingEndpointNotUpdating[R]) OnProgress(callback func(*ServingEndpointDetailed)) *WaitGetServingEndpointNotUpdating[R]