Documentation ¶
Index ¶
- Variables
- func RegisterModelBoxAdminServer(s grpc.ServiceRegistrar, srv ModelBoxAdminServer)
- func RegisterModelStoreServer(s grpc.ServiceRegistrar, srv ModelStoreServer)
- type Artifact
- func (*Artifact) Descriptor() ([]byte, []int)deprecated
- func (x *Artifact) GetFiles() []*FileMetadata
- func (x *Artifact) GetId() string
- func (x *Artifact) GetName() string
- func (x *Artifact) GetObjectId() string
- func (*Artifact) ProtoMessage()
- func (x *Artifact) ProtoReflect() protoreflect.Message
- func (x *Artifact) Reset()
- func (x *Artifact) String() string
- type ChangeEvent
- func (ChangeEvent) Descriptor() protoreflect.EnumDescriptor
- func (x ChangeEvent) Enum() *ChangeEvent
- func (ChangeEvent) EnumDescriptor() ([]byte, []int)deprecated
- func (x ChangeEvent) Number() protoreflect.EnumNumber
- func (x ChangeEvent) String() string
- func (ChangeEvent) Type() protoreflect.EnumType
- type ClusterMember
- func (*ClusterMember) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterMember) GetHostName() string
- func (x *ClusterMember) GetHttpAddr() string
- func (x *ClusterMember) GetId() string
- func (x *ClusterMember) GetRpcAddr() string
- func (*ClusterMember) ProtoMessage()
- func (x *ClusterMember) ProtoReflect() protoreflect.Message
- func (x *ClusterMember) Reset()
- func (x *ClusterMember) String() string
- type CreateExperimentRequest
- func (*CreateExperimentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateExperimentRequest) GetExternalId() string
- func (x *CreateExperimentRequest) GetFramework() MLFramework
- func (x *CreateExperimentRequest) GetName() string
- func (x *CreateExperimentRequest) GetNamespace() string
- func (x *CreateExperimentRequest) GetOwner() string
- func (x *CreateExperimentRequest) GetTask() string
- func (*CreateExperimentRequest) ProtoMessage()
- func (x *CreateExperimentRequest) ProtoReflect() protoreflect.Message
- func (x *CreateExperimentRequest) Reset()
- func (x *CreateExperimentRequest) String() string
- type CreateExperimentResponse
- func (*CreateExperimentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateExperimentResponse) GetCreatedAt() *timestamppb.Timestamp
- func (x *CreateExperimentResponse) GetExperimentExists() bool
- func (x *CreateExperimentResponse) GetExperimentId() string
- func (x *CreateExperimentResponse) GetUpdatedAt() *timestamppb.Timestamp
- func (*CreateExperimentResponse) ProtoMessage()
- func (x *CreateExperimentResponse) ProtoReflect() protoreflect.Message
- func (x *CreateExperimentResponse) Reset()
- func (x *CreateExperimentResponse) String() string
- type CreateModelRequest
- func (*CreateModelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateModelRequest) GetDescription() string
- func (x *CreateModelRequest) GetName() string
- func (x *CreateModelRequest) GetNamespace() string
- func (x *CreateModelRequest) GetOwner() string
- func (x *CreateModelRequest) GetTask() string
- func (*CreateModelRequest) ProtoMessage()
- func (x *CreateModelRequest) ProtoReflect() protoreflect.Message
- func (x *CreateModelRequest) Reset()
- func (x *CreateModelRequest) String() string
- type CreateModelResponse
- func (*CreateModelResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateModelResponse) GetCreatedAt() *timestamppb.Timestamp
- func (x *CreateModelResponse) GetExists() bool
- func (x *CreateModelResponse) GetId() string
- func (x *CreateModelResponse) GetUpdatedAt() *timestamppb.Timestamp
- func (*CreateModelResponse) ProtoMessage()
- func (x *CreateModelResponse) ProtoReflect() protoreflect.Message
- func (x *CreateModelResponse) Reset()
- func (x *CreateModelResponse) String() string
- type CreateModelVersionRequest
- func (*CreateModelVersionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateModelVersionRequest) GetDescription() string
- func (x *CreateModelVersionRequest) GetFramework() MLFramework
- func (x *CreateModelVersionRequest) GetModel() string
- func (x *CreateModelVersionRequest) GetName() string
- func (x *CreateModelVersionRequest) GetNamespace() string
- func (x *CreateModelVersionRequest) GetUniqueTags() []string
- func (x *CreateModelVersionRequest) GetVersion() string
- func (*CreateModelVersionRequest) ProtoMessage()
- func (x *CreateModelVersionRequest) ProtoReflect() protoreflect.Message
- func (x *CreateModelVersionRequest) Reset()
- func (x *CreateModelVersionRequest) String() string
- type CreateModelVersionResponse
- func (*CreateModelVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateModelVersionResponse) GetCreatedAt() *timestamppb.Timestamp
- func (x *CreateModelVersionResponse) GetExists() bool
- func (x *CreateModelVersionResponse) GetModelVersion() string
- func (x *CreateModelVersionResponse) GetUpdatedAt() *timestamppb.Timestamp
- func (*CreateModelVersionResponse) ProtoMessage()
- func (x *CreateModelVersionResponse) ProtoReflect() protoreflect.Message
- func (x *CreateModelVersionResponse) Reset()
- func (x *CreateModelVersionResponse) String() string
- type DownloadFileRequest
- func (*DownloadFileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadFileRequest) GetFileId() string
- func (*DownloadFileRequest) ProtoMessage()
- func (x *DownloadFileRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadFileRequest) Reset()
- func (x *DownloadFileRequest) String() string
- type DownloadFileResponse
- func (*DownloadFileResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadFileResponse) GetChunks() []byte
- func (x *DownloadFileResponse) GetMetadata() *FileMetadata
- func (m *DownloadFileResponse) GetStreamFrame() isDownloadFileResponse_StreamFrame
- func (*DownloadFileResponse) ProtoMessage()
- func (x *DownloadFileResponse) ProtoReflect() protoreflect.Message
- func (x *DownloadFileResponse) Reset()
- func (x *DownloadFileResponse) String() string
- type DownloadFileResponse_Chunks
- type DownloadFileResponse_Metadata
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetMetadata() *Metadata
- func (x *Event) GetName() string
- func (x *Event) GetSource() *EventSource
- func (x *Event) GetWallclockTime() *timestamppb.Timestamp
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type EventSource
- type Experiment
- func (*Experiment) Descriptor() ([]byte, []int)deprecated
- func (x *Experiment) GetCreatedAt() *timestamppb.Timestamp
- func (x *Experiment) GetExternalId() string
- func (x *Experiment) GetFramework() MLFramework
- func (x *Experiment) GetId() string
- func (x *Experiment) GetName() string
- func (x *Experiment) GetNamespace() string
- func (x *Experiment) GetOwner() string
- func (x *Experiment) GetUpdatedAt() *timestamppb.Timestamp
- func (*Experiment) ProtoMessage()
- func (x *Experiment) ProtoReflect() protoreflect.Message
- func (x *Experiment) Reset()
- func (x *Experiment) String() string
- type FileMetadata
- func (*FileMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *FileMetadata) GetChecksum() string
- func (x *FileMetadata) GetCreatedAt() *timestamppb.Timestamp
- func (x *FileMetadata) GetFileType() FileType
- func (x *FileMetadata) GetId() string
- func (x *FileMetadata) GetParentId() string
- func (x *FileMetadata) GetSrcPath() string
- func (x *FileMetadata) GetUpdatedAt() *timestamppb.Timestamp
- func (x *FileMetadata) GetUploadPath() string
- func (*FileMetadata) ProtoMessage()
- func (x *FileMetadata) ProtoReflect() protoreflect.Message
- func (x *FileMetadata) Reset()
- func (x *FileMetadata) String() string
- type FileType
- type GetClusterMembersRequest
- type GetClusterMembersResponse
- func (*GetClusterMembersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetClusterMembersResponse) GetMembers() []*ClusterMember
- func (*GetClusterMembersResponse) ProtoMessage()
- func (x *GetClusterMembersResponse) ProtoReflect() protoreflect.Message
- func (x *GetClusterMembersResponse) Reset()
- func (x *GetClusterMembersResponse) String() string
- type GetExperimentRequest
- func (*GetExperimentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetExperimentRequest) GetId() string
- func (*GetExperimentRequest) ProtoMessage()
- func (x *GetExperimentRequest) ProtoReflect() protoreflect.Message
- func (x *GetExperimentRequest) Reset()
- func (x *GetExperimentRequest) String() string
- type GetExperimentResponse
- func (*GetExperimentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetExperimentResponse) GetExperiment() *Experiment
- func (*GetExperimentResponse) ProtoMessage()
- func (x *GetExperimentResponse) ProtoReflect() protoreflect.Message
- func (x *GetExperimentResponse) Reset()
- func (x *GetExperimentResponse) String() string
- type GetMetricsRequest
- type GetMetricsResponse
- func (*GetMetricsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetMetricsResponse) GetMetrics() map[string]*Metrics
- func (*GetMetricsResponse) ProtoMessage()
- func (x *GetMetricsResponse) ProtoReflect() protoreflect.Message
- func (x *GetMetricsResponse) Reset()
- func (x *GetMetricsResponse) String() string
- type GetRunnableActionInstancesRequest
- func (*GetRunnableActionInstancesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRunnableActionInstancesRequest) GetActionName() string
- func (x *GetRunnableActionInstancesRequest) GetArch() string
- func (*GetRunnableActionInstancesRequest) ProtoMessage()
- func (x *GetRunnableActionInstancesRequest) ProtoReflect() protoreflect.Message
- func (x *GetRunnableActionInstancesRequest) Reset()
- func (x *GetRunnableActionInstancesRequest) String() string
- type GetRunnableActionInstancesResponse
- func (*GetRunnableActionInstancesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetRunnableActionInstancesResponse) GetInstances() []*RunnableAction
- func (*GetRunnableActionInstancesResponse) ProtoMessage()
- func (x *GetRunnableActionInstancesResponse) ProtoReflect() protoreflect.Message
- func (x *GetRunnableActionInstancesResponse) Reset()
- func (x *GetRunnableActionInstancesResponse) String() string
- type HeartbeatRequest
- func (*HeartbeatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HeartbeatRequest) GetAt() *timestamppb.Timestamp
- func (x *HeartbeatRequest) GetNodeId() string
- func (*HeartbeatRequest) ProtoMessage()
- func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
- func (x *HeartbeatRequest) Reset()
- func (x *HeartbeatRequest) String() string
- type HeartbeatResponse
- type ListArtifactsRequest
- func (*ListArtifactsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListArtifactsRequest) GetObjectId() string
- func (*ListArtifactsRequest) ProtoMessage()
- func (x *ListArtifactsRequest) ProtoReflect() protoreflect.Message
- func (x *ListArtifactsRequest) Reset()
- func (x *ListArtifactsRequest) String() string
- type ListArtifactsResponse
- func (*ListArtifactsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListArtifactsResponse) GetArtifacts() []*Artifact
- func (*ListArtifactsResponse) ProtoMessage()
- func (x *ListArtifactsResponse) ProtoReflect() protoreflect.Message
- func (x *ListArtifactsResponse) Reset()
- func (x *ListArtifactsResponse) String() string
- type ListEventsRequest
- func (*ListEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListEventsRequest) GetParentId() string
- func (x *ListEventsRequest) GetSince() *timestamppb.Timestamp
- func (*ListEventsRequest) ProtoMessage()
- func (x *ListEventsRequest) ProtoReflect() protoreflect.Message
- func (x *ListEventsRequest) Reset()
- func (x *ListEventsRequest) String() string
- type ListEventsResponse
- func (*ListEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListEventsResponse) GetEvents() []*Event
- func (*ListEventsResponse) ProtoMessage()
- func (x *ListEventsResponse) ProtoReflect() protoreflect.Message
- func (x *ListEventsResponse) Reset()
- func (x *ListEventsResponse) String() string
- type ListExperimentsRequest
- func (*ListExperimentsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListExperimentsRequest) GetNamespace() string
- func (*ListExperimentsRequest) ProtoMessage()
- func (x *ListExperimentsRequest) ProtoReflect() protoreflect.Message
- func (x *ListExperimentsRequest) Reset()
- func (x *ListExperimentsRequest) String() string
- type ListExperimentsResponse
- func (*ListExperimentsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListExperimentsResponse) GetExperiments() []*Experiment
- func (*ListExperimentsResponse) ProtoMessage()
- func (x *ListExperimentsResponse) ProtoReflect() protoreflect.Message
- func (x *ListExperimentsResponse) Reset()
- func (x *ListExperimentsResponse) String() string
- type ListMetadataRequest
- func (*ListMetadataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListMetadataRequest) GetParentId() string
- func (*ListMetadataRequest) ProtoMessage()
- func (x *ListMetadataRequest) ProtoReflect() protoreflect.Message
- func (x *ListMetadataRequest) Reset()
- func (x *ListMetadataRequest) String() string
- type ListMetadataResponse
- func (*ListMetadataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListMetadataResponse) GetMetadata() *Metadata
- func (*ListMetadataResponse) ProtoMessage()
- func (x *ListMetadataResponse) ProtoReflect() protoreflect.Message
- func (x *ListMetadataResponse) Reset()
- func (x *ListMetadataResponse) String() string
- type ListModelVersionsRequest
- func (*ListModelVersionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListModelVersionsRequest) GetModel() string
- func (*ListModelVersionsRequest) ProtoMessage()
- func (x *ListModelVersionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListModelVersionsRequest) Reset()
- func (x *ListModelVersionsRequest) String() string
- type ListModelVersionsResponse
- func (*ListModelVersionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListModelVersionsResponse) GetModelVersions() []*ModelVersion
- func (*ListModelVersionsResponse) ProtoMessage()
- func (x *ListModelVersionsResponse) ProtoReflect() protoreflect.Message
- func (x *ListModelVersionsResponse) Reset()
- func (x *ListModelVersionsResponse) String() string
- type ListModelsRequest
- type ListModelsResponse
- func (*ListModelsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListModelsResponse) GetModels() []*Model
- func (*ListModelsResponse) ProtoMessage()
- func (x *ListModelsResponse) ProtoReflect() protoreflect.Message
- func (x *ListModelsResponse) Reset()
- func (x *ListModelsResponse) String() string
- type LogEventRequest
- func (*LogEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LogEventRequest) GetEvent() *Event
- func (x *LogEventRequest) GetParentId() string
- func (*LogEventRequest) ProtoMessage()
- func (x *LogEventRequest) ProtoReflect() protoreflect.Message
- func (x *LogEventRequest) Reset()
- func (x *LogEventRequest) String() string
- type LogEventResponse
- func (*LogEventResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LogEventResponse) GetCreatedAt() *timestamppb.Timestamp
- func (*LogEventResponse) ProtoMessage()
- func (x *LogEventResponse) ProtoReflect() protoreflect.Message
- func (x *LogEventResponse) Reset()
- func (x *LogEventResponse) String() string
- type LogMetricsRequest
- func (*LogMetricsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LogMetricsRequest) GetKey() string
- func (x *LogMetricsRequest) GetParentId() string
- func (x *LogMetricsRequest) GetValue() *MetricsValue
- func (*LogMetricsRequest) ProtoMessage()
- func (x *LogMetricsRequest) ProtoReflect() protoreflect.Message
- func (x *LogMetricsRequest) Reset()
- func (x *LogMetricsRequest) String() string
- type LogMetricsResponse
- type MLFramework
- func (MLFramework) Descriptor() protoreflect.EnumDescriptor
- func (x MLFramework) Enum() *MLFramework
- func (MLFramework) EnumDescriptor() ([]byte, []int)deprecated
- func (x MLFramework) Number() protoreflect.EnumNumber
- func (x MLFramework) String() string
- func (MLFramework) Type() protoreflect.EnumType
- type Metadata
- type Metrics
- type MetricsValue
- func (*MetricsValue) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsValue) GetBTensor() []byte
- func (x *MetricsValue) GetFVal() float32
- func (x *MetricsValue) GetSTensor() string
- func (x *MetricsValue) GetStep() uint64
- func (m *MetricsValue) GetValue() isMetricsValue_Value
- func (x *MetricsValue) GetWallclockTime() uint64
- func (*MetricsValue) ProtoMessage()
- func (x *MetricsValue) ProtoReflect() protoreflect.Message
- func (x *MetricsValue) Reset()
- func (x *MetricsValue) String() string
- type MetricsValue_BTensor
- type MetricsValue_FVal
- type MetricsValue_STensor
- type Model
- func (*Model) Descriptor() ([]byte, []int)deprecated
- func (x *Model) GetCreatedAt() *timestamppb.Timestamp
- func (x *Model) GetDescription() string
- func (x *Model) GetId() string
- func (x *Model) GetName() string
- func (x *Model) GetNamespace() string
- func (x *Model) GetOwner() string
- func (x *Model) GetTask() string
- func (x *Model) GetUpdatedAt() *timestamppb.Timestamp
- func (*Model) ProtoMessage()
- func (x *Model) ProtoReflect() protoreflect.Message
- func (x *Model) Reset()
- func (x *Model) String() string
- type ModelBoxAdminClient
- type ModelBoxAdminServer
- type ModelStoreClient
- type ModelStoreServer
- type ModelStore_DownloadFileClient
- type ModelStore_DownloadFileServer
- type ModelStore_UploadFileClient
- type ModelStore_UploadFileServer
- type ModelStore_WatchNamespaceClient
- type ModelStore_WatchNamespaceServer
- type ModelVersion
- func (*ModelVersion) Descriptor() ([]byte, []int)deprecated
- func (x *ModelVersion) GetCreatedAt() *timestamppb.Timestamp
- func (x *ModelVersion) GetDescription() string
- func (x *ModelVersion) GetFramework() MLFramework
- func (x *ModelVersion) GetId() string
- func (x *ModelVersion) GetModelId() string
- func (x *ModelVersion) GetName() string
- func (x *ModelVersion) GetUniqueTags() []string
- func (x *ModelVersion) GetUpdatedAt() *timestamppb.Timestamp
- func (x *ModelVersion) GetVersion() string
- func (*ModelVersion) ProtoMessage()
- func (x *ModelVersion) ProtoReflect() protoreflect.Message
- func (x *ModelVersion) Reset()
- func (x *ModelVersion) String() string
- type NodeInfo
- func (*NodeInfo) Descriptor() ([]byte, []int)deprecated
- func (x *NodeInfo) GetArch() string
- func (x *NodeInfo) GetHostName() string
- func (x *NodeInfo) GetIpAddr() string
- func (*NodeInfo) ProtoMessage()
- func (x *NodeInfo) ProtoReflect() protoreflect.Message
- func (x *NodeInfo) Reset()
- func (x *NodeInfo) String() string
- type RegisterAgentRequest
- func (*RegisterAgentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterAgentRequest) GetAgentName() string
- func (x *RegisterAgentRequest) GetNodeInfo() *NodeInfo
- func (*RegisterAgentRequest) ProtoMessage()
- func (x *RegisterAgentRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterAgentRequest) Reset()
- func (x *RegisterAgentRequest) String() string
- type RegisterAgentResponse
- func (*RegisterAgentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterAgentResponse) GetNodeId() string
- func (*RegisterAgentResponse) ProtoMessage()
- func (x *RegisterAgentResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterAgentResponse) Reset()
- func (x *RegisterAgentResponse) String() string
- type RunnableAction
- func (*RunnableAction) Descriptor() ([]byte, []int)deprecated
- func (x *RunnableAction) GetActionId() string
- func (x *RunnableAction) GetCommand() string
- func (x *RunnableAction) GetId() string
- func (x *RunnableAction) GetParams() map[string]*structpb.Value
- func (*RunnableAction) ProtoMessage()
- func (x *RunnableAction) ProtoReflect() protoreflect.Message
- func (x *RunnableAction) Reset()
- func (x *RunnableAction) String() string
- type SubscribeEventRequest
- func (*SubscribeEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeEventRequest) GetActions() []string
- func (x *SubscribeEventRequest) GetMlFramework() string
- func (x *SubscribeEventRequest) GetNamespace() string
- func (x *SubscribeEventRequest) GetOwner() string
- func (*SubscribeEventRequest) ProtoMessage()
- func (x *SubscribeEventRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeEventRequest) Reset()
- func (x *SubscribeEventRequest) String() string
- type TrackArtifactsRequest
- func (*TrackArtifactsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TrackArtifactsRequest) GetFiles() []*FileMetadata
- func (x *TrackArtifactsRequest) GetName() string
- func (x *TrackArtifactsRequest) GetObjectId() string
- func (*TrackArtifactsRequest) ProtoMessage()
- func (x *TrackArtifactsRequest) ProtoReflect() protoreflect.Message
- func (x *TrackArtifactsRequest) Reset()
- func (x *TrackArtifactsRequest) String() string
- type TrackArtifactsResponse
- func (*TrackArtifactsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TrackArtifactsResponse) GetId() string
- func (*TrackArtifactsResponse) ProtoMessage()
- func (x *TrackArtifactsResponse) ProtoReflect() protoreflect.Message
- func (x *TrackArtifactsResponse) Reset()
- func (x *TrackArtifactsResponse) String() string
- type UnimplementedModelBoxAdminServer
- func (UnimplementedModelBoxAdminServer) GetClusterMembers(context.Context, *GetClusterMembersRequest) (*GetClusterMembersResponse, error)
- func (UnimplementedModelBoxAdminServer) GetRunnableActionInstances(context.Context, *GetRunnableActionInstancesRequest) (*GetRunnableActionInstancesResponse, error)
- func (UnimplementedModelBoxAdminServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
- func (UnimplementedModelBoxAdminServer) RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)
- func (UnimplementedModelBoxAdminServer) UpdateActionStatus(context.Context, *UpdateActionStatusRequest) (*UpdateActionStatusResponse, error)
- type UnimplementedModelStoreServer
- func (UnimplementedModelStoreServer) CreateExperiment(context.Context, *CreateExperimentRequest) (*CreateExperimentResponse, error)
- func (UnimplementedModelStoreServer) CreateModel(context.Context, *CreateModelRequest) (*CreateModelResponse, error)
- func (UnimplementedModelStoreServer) CreateModelVersion(context.Context, *CreateModelVersionRequest) (*CreateModelVersionResponse, error)
- func (UnimplementedModelStoreServer) DownloadFile(*DownloadFileRequest, ModelStore_DownloadFileServer) error
- func (UnimplementedModelStoreServer) GetExperiment(context.Context, *GetExperimentRequest) (*GetExperimentResponse, error)
- func (UnimplementedModelStoreServer) GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)
- func (UnimplementedModelStoreServer) ListArtifacts(context.Context, *ListArtifactsRequest) (*ListArtifactsResponse, error)
- func (UnimplementedModelStoreServer) ListEvents(context.Context, *ListEventsRequest) (*ListEventsResponse, error)
- func (UnimplementedModelStoreServer) ListExperiments(context.Context, *ListExperimentsRequest) (*ListExperimentsResponse, error)
- func (UnimplementedModelStoreServer) ListMetadata(context.Context, *ListMetadataRequest) (*ListMetadataResponse, error)
- func (UnimplementedModelStoreServer) ListModelVersions(context.Context, *ListModelVersionsRequest) (*ListModelVersionsResponse, error)
- func (UnimplementedModelStoreServer) ListModels(context.Context, *ListModelsRequest) (*ListModelsResponse, error)
- func (UnimplementedModelStoreServer) LogEvent(context.Context, *LogEventRequest) (*LogEventResponse, error)
- func (UnimplementedModelStoreServer) LogMetrics(context.Context, *LogMetricsRequest) (*LogMetricsResponse, error)
- func (UnimplementedModelStoreServer) TrackArtifacts(context.Context, *TrackArtifactsRequest) (*TrackArtifactsResponse, error)
- func (UnimplementedModelStoreServer) UpdateMetadata(context.Context, *UpdateMetadataRequest) (*UpdateMetadataResponse, error)
- func (UnimplementedModelStoreServer) UploadFile(ModelStore_UploadFileServer) error
- func (UnimplementedModelStoreServer) WatchNamespace(*WatchNamespaceRequest, ModelStore_WatchNamespaceServer) error
- type UnsafeModelBoxAdminServer
- type UnsafeModelStoreServer
- type UpdateActionStatusRequest
- func (*UpdateActionStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateActionStatusRequest) GetActionInstanceId() string
- func (x *UpdateActionStatusRequest) GetOutcome() uint32
- func (x *UpdateActionStatusRequest) GetOutcomeReason() string
- func (x *UpdateActionStatusRequest) GetStatus() uint32
- func (x *UpdateActionStatusRequest) GetUdpateTime() uint64
- func (*UpdateActionStatusRequest) ProtoMessage()
- func (x *UpdateActionStatusRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateActionStatusRequest) Reset()
- func (x *UpdateActionStatusRequest) String() string
- type UpdateActionStatusResponse
- type UpdateMetadataRequest
- func (*UpdateMetadataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateMetadataRequest) GetMetadata() *Metadata
- func (x *UpdateMetadataRequest) GetParentId() string
- func (*UpdateMetadataRequest) ProtoMessage()
- func (x *UpdateMetadataRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateMetadataRequest) Reset()
- func (x *UpdateMetadataRequest) String() string
- type UpdateMetadataResponse
- type UploadFileMetadata
- func (*UploadFileMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *UploadFileMetadata) GetArtifactName() string
- func (x *UploadFileMetadata) GetMetadata() *FileMetadata
- func (x *UploadFileMetadata) GetObjectId() string
- func (*UploadFileMetadata) ProtoMessage()
- func (x *UploadFileMetadata) ProtoReflect() protoreflect.Message
- func (x *UploadFileMetadata) Reset()
- func (x *UploadFileMetadata) String() string
- type UploadFileRequest
- func (*UploadFileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UploadFileRequest) GetChunks() []byte
- func (x *UploadFileRequest) GetMetadata() *UploadFileMetadata
- func (m *UploadFileRequest) GetStreamFrame() isUploadFileRequest_StreamFrame
- func (*UploadFileRequest) ProtoMessage()
- func (x *UploadFileRequest) ProtoReflect() protoreflect.Message
- func (x *UploadFileRequest) Reset()
- func (x *UploadFileRequest) String() string
- type UploadFileRequest_Chunks
- type UploadFileRequest_Metadata
- type UploadFileResponse
- func (*UploadFileResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UploadFileResponse) GetArtifactId() string
- func (x *UploadFileResponse) GetFileId() string
- func (*UploadFileResponse) ProtoMessage()
- func (x *UploadFileResponse) ProtoReflect() protoreflect.Message
- func (x *UploadFileResponse) Reset()
- func (x *UploadFileResponse) String() string
- type WatchNamespaceRequest
- func (*WatchNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchNamespaceRequest) GetNamespace() string
- func (x *WatchNamespaceRequest) GetSince() uint64
- func (*WatchNamespaceRequest) ProtoMessage()
- func (x *WatchNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *WatchNamespaceRequest) Reset()
- func (x *WatchNamespaceRequest) String() string
- type WatchNamespaceResponse
- func (*WatchNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WatchNamespaceResponse) GetEvent() ChangeEvent
- func (x *WatchNamespaceResponse) GetPayload() *structpb.Value
- func (*WatchNamespaceResponse) ProtoMessage()
- func (x *WatchNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *WatchNamespaceResponse) Reset()
- func (x *WatchNamespaceResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var ( ChangeEvent_name = map[int32]string{ 0: "CHANGE_EVENT_UNDEFINED", 1: "OBJECT_CREATED", 2: "OBJECT_UPDATED", } ChangeEvent_value = map[string]int32{ "CHANGE_EVENT_UNDEFINED": 0, "OBJECT_CREATED": 1, "OBJECT_UPDATED": 2, } )
Enum value maps for ChangeEvent.
var ( FileType_name = map[int32]string{ 0: "UNDEFINED", 1: "MODEL", 2: "CHECKPOINT", 3: "TEXT", 4: "IMAGE", 5: "AUDIO", 6: "VIDEO", } FileType_value = map[string]int32{ "UNDEFINED": 0, "MODEL": 1, "CHECKPOINT": 2, "TEXT": 3, "IMAGE": 4, "AUDIO": 5, "VIDEO": 6, } )
Enum value maps for FileType.
var ( MLFramework_name = map[int32]string{ 0: "UNKNOWN", 1: "PYTORCH", 2: "KERAS", } MLFramework_value = map[string]int32{ "UNKNOWN": 0, "PYTORCH": 1, "KERAS": 2, } )
Enum value maps for MLFramework.
var File_admin_proto protoreflect.FileDescriptor
var File_proto_service_proto protoreflect.FileDescriptor
var ModelBoxAdmin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "modelbox.ModelBoxAdmin", HandlerType: (*ModelBoxAdminServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RegisterAgent", Handler: _ModelBoxAdmin_RegisterAgent_Handler, }, { MethodName: "Heartbeat", Handler: _ModelBoxAdmin_Heartbeat_Handler, }, { MethodName: "GetRunnableActionInstances", Handler: _ModelBoxAdmin_GetRunnableActionInstances_Handler, }, { MethodName: "UpdateActionStatus", Handler: _ModelBoxAdmin_UpdateActionStatus_Handler, }, { MethodName: "GetClusterMembers", Handler: _ModelBoxAdmin_GetClusterMembers_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "admin.proto", }
ModelBoxAdmin_ServiceDesc is the grpc.ServiceDesc for ModelBoxAdmin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ModelStore_ServiceDesc = grpc.ServiceDesc{ ServiceName: "modelbox.ModelStore", HandlerType: (*ModelStoreServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateModel", Handler: _ModelStore_CreateModel_Handler, }, { MethodName: "ListModels", Handler: _ModelStore_ListModels_Handler, }, { MethodName: "CreateModelVersion", Handler: _ModelStore_CreateModelVersion_Handler, }, { MethodName: "ListModelVersions", Handler: _ModelStore_ListModelVersions_Handler, }, { MethodName: "CreateExperiment", Handler: _ModelStore_CreateExperiment_Handler, }, { MethodName: "ListExperiments", Handler: _ModelStore_ListExperiments_Handler, }, { MethodName: "GetExperiment", Handler: _ModelStore_GetExperiment_Handler, }, { MethodName: "UpdateMetadata", Handler: _ModelStore_UpdateMetadata_Handler, }, { MethodName: "ListMetadata", Handler: _ModelStore_ListMetadata_Handler, }, { MethodName: "TrackArtifacts", Handler: _ModelStore_TrackArtifacts_Handler, }, { MethodName: "ListArtifacts", Handler: _ModelStore_ListArtifacts_Handler, }, { MethodName: "LogMetrics", Handler: _ModelStore_LogMetrics_Handler, }, { MethodName: "GetMetrics", Handler: _ModelStore_GetMetrics_Handler, }, { MethodName: "LogEvent", Handler: _ModelStore_LogEvent_Handler, }, { MethodName: "ListEvents", Handler: _ModelStore_ListEvents_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "UploadFile", Handler: _ModelStore_UploadFile_Handler, ClientStreams: true, }, { StreamName: "DownloadFile", Handler: _ModelStore_DownloadFile_Handler, ServerStreams: true, }, { StreamName: "WatchNamespace", Handler: _ModelStore_WatchNamespace_Handler, ServerStreams: true, }, }, Metadata: "proto/service.proto", }
ModelStore_ServiceDesc is the grpc.ServiceDesc for ModelStore service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterModelBoxAdminServer ¶
func RegisterModelBoxAdminServer(s grpc.ServiceRegistrar, srv ModelBoxAdminServer)
func RegisterModelStoreServer ¶
func RegisterModelStoreServer(s grpc.ServiceRegistrar, srv ModelStoreServer)
Types ¶
type Artifact ¶
type Artifact struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` ObjectId string `protobuf:"bytes,3,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"` Files []*FileMetadata `protobuf:"bytes,4,rep,name=files,proto3" json:"files,omitempty"` // contains filtered or unexported fields }
func (*Artifact) Descriptor
deprecated
func (*Artifact) GetFiles ¶
func (x *Artifact) GetFiles() []*FileMetadata
func (*Artifact) GetObjectId ¶
func (*Artifact) ProtoMessage ¶
func (*Artifact) ProtoMessage()
func (*Artifact) ProtoReflect ¶
func (x *Artifact) ProtoReflect() protoreflect.Message
type ChangeEvent ¶
type ChangeEvent int32
const ( ChangeEvent_CHANGE_EVENT_UNDEFINED ChangeEvent = 0 ChangeEvent_OBJECT_CREATED ChangeEvent = 1 ChangeEvent_OBJECT_UPDATED ChangeEvent = 2 )
func (ChangeEvent) Descriptor ¶
func (ChangeEvent) Descriptor() protoreflect.EnumDescriptor
func (ChangeEvent) Enum ¶
func (x ChangeEvent) Enum() *ChangeEvent
func (ChangeEvent) EnumDescriptor
deprecated
func (ChangeEvent) EnumDescriptor() ([]byte, []int)
Deprecated: Use ChangeEvent.Descriptor instead.
func (ChangeEvent) Number ¶
func (x ChangeEvent) Number() protoreflect.EnumNumber
func (ChangeEvent) String ¶
func (x ChangeEvent) String() string
func (ChangeEvent) Type ¶
func (ChangeEvent) Type() protoreflect.EnumType
type ClusterMember ¶
type ClusterMember struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` RpcAddr string `protobuf:"bytes,3,opt,name=rpc_addr,json=rpcAddr,proto3" json:"rpc_addr,omitempty"` HttpAddr string `protobuf:"bytes,4,opt,name=http_addr,json=httpAddr,proto3" json:"http_addr,omitempty"` // contains filtered or unexported fields }
func (*ClusterMember) Descriptor
deprecated
func (*ClusterMember) Descriptor() ([]byte, []int)
Deprecated: Use ClusterMember.ProtoReflect.Descriptor instead.
func (*ClusterMember) GetHostName ¶
func (x *ClusterMember) GetHostName() string
func (*ClusterMember) GetHttpAddr ¶
func (x *ClusterMember) GetHttpAddr() string
func (*ClusterMember) GetId ¶
func (x *ClusterMember) GetId() string
func (*ClusterMember) GetRpcAddr ¶
func (x *ClusterMember) GetRpcAddr() string
func (*ClusterMember) ProtoMessage ¶
func (*ClusterMember) ProtoMessage()
func (*ClusterMember) ProtoReflect ¶
func (x *ClusterMember) ProtoReflect() protoreflect.Message
func (*ClusterMember) Reset ¶
func (x *ClusterMember) Reset()
func (*ClusterMember) String ¶
func (x *ClusterMember) String() string
type CreateExperimentRequest ¶
type CreateExperimentRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"` Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` Framework MLFramework `protobuf:"varint,4,opt,name=framework,proto3,enum=modelbox.MLFramework" json:"framework,omitempty"` Task string `protobuf:"bytes,5,opt,name=task,proto3" json:"task,omitempty"` ExternalId string `protobuf:"bytes,7,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` // contains filtered or unexported fields }
func (*CreateExperimentRequest) Descriptor
deprecated
func (*CreateExperimentRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateExperimentRequest.ProtoReflect.Descriptor instead.
func (*CreateExperimentRequest) GetExternalId ¶
func (x *CreateExperimentRequest) GetExternalId() string
func (*CreateExperimentRequest) GetFramework ¶
func (x *CreateExperimentRequest) GetFramework() MLFramework
func (*CreateExperimentRequest) GetName ¶
func (x *CreateExperimentRequest) GetName() string
func (*CreateExperimentRequest) GetNamespace ¶
func (x *CreateExperimentRequest) GetNamespace() string
func (*CreateExperimentRequest) GetOwner ¶
func (x *CreateExperimentRequest) GetOwner() string
func (*CreateExperimentRequest) GetTask ¶
func (x *CreateExperimentRequest) GetTask() string
func (*CreateExperimentRequest) ProtoMessage ¶
func (*CreateExperimentRequest) ProtoMessage()
func (*CreateExperimentRequest) ProtoReflect ¶
func (x *CreateExperimentRequest) ProtoReflect() protoreflect.Message
func (*CreateExperimentRequest) Reset ¶
func (x *CreateExperimentRequest) Reset()
func (*CreateExperimentRequest) String ¶
func (x *CreateExperimentRequest) String() string
type CreateExperimentResponse ¶
type CreateExperimentResponse struct { ExperimentId string `protobuf:"bytes,1,opt,name=experiment_id,json=experimentId,proto3" json:"experiment_id,omitempty"` ExperimentExists bool `protobuf:"varint,2,opt,name=experiment_exists,json=experimentExists,proto3" json:"experiment_exists,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,21,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // contains filtered or unexported fields }
func (*CreateExperimentResponse) Descriptor
deprecated
func (*CreateExperimentResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateExperimentResponse.ProtoReflect.Descriptor instead.
func (*CreateExperimentResponse) GetCreatedAt ¶
func (x *CreateExperimentResponse) GetCreatedAt() *timestamppb.Timestamp
func (*CreateExperimentResponse) GetExperimentExists ¶
func (x *CreateExperimentResponse) GetExperimentExists() bool
func (*CreateExperimentResponse) GetExperimentId ¶
func (x *CreateExperimentResponse) GetExperimentId() string
func (*CreateExperimentResponse) GetUpdatedAt ¶
func (x *CreateExperimentResponse) GetUpdatedAt() *timestamppb.Timestamp
func (*CreateExperimentResponse) ProtoMessage ¶
func (*CreateExperimentResponse) ProtoMessage()
func (*CreateExperimentResponse) ProtoReflect ¶
func (x *CreateExperimentResponse) ProtoReflect() protoreflect.Message
func (*CreateExperimentResponse) Reset ¶
func (x *CreateExperimentResponse) Reset()
func (*CreateExperimentResponse) String ¶
func (x *CreateExperimentResponse) String() string
type CreateModelRequest ¶
type CreateModelRequest struct { Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"` Task string `protobuf:"bytes,5,opt,name=task,proto3" json:"task,omitempty"` Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"` // contains filtered or unexported fields }
* Create a new Model. If the id points to an existing model a new model version is created.
func (*CreateModelRequest) Descriptor
deprecated
func (*CreateModelRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateModelRequest.ProtoReflect.Descriptor instead.
func (*CreateModelRequest) GetDescription ¶
func (x *CreateModelRequest) GetDescription() string
func (*CreateModelRequest) GetName ¶
func (x *CreateModelRequest) GetName() string
func (*CreateModelRequest) GetNamespace ¶
func (x *CreateModelRequest) GetNamespace() string
func (*CreateModelRequest) GetOwner ¶
func (x *CreateModelRequest) GetOwner() string
func (*CreateModelRequest) GetTask ¶
func (x *CreateModelRequest) GetTask() string
func (*CreateModelRequest) ProtoMessage ¶
func (*CreateModelRequest) ProtoMessage()
func (*CreateModelRequest) ProtoReflect ¶
func (x *CreateModelRequest) ProtoReflect() protoreflect.Message
func (*CreateModelRequest) Reset ¶
func (x *CreateModelRequest) Reset()
func (*CreateModelRequest) String ¶
func (x *CreateModelRequest) String() string
type CreateModelResponse ¶
type CreateModelResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Exists bool `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,21,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // contains filtered or unexported fields }
func (*CreateModelResponse) Descriptor
deprecated
func (*CreateModelResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateModelResponse.ProtoReflect.Descriptor instead.
func (*CreateModelResponse) GetCreatedAt ¶
func (x *CreateModelResponse) GetCreatedAt() *timestamppb.Timestamp
func (*CreateModelResponse) GetExists ¶
func (x *CreateModelResponse) GetExists() bool
func (*CreateModelResponse) GetId ¶
func (x *CreateModelResponse) GetId() string
func (*CreateModelResponse) GetUpdatedAt ¶
func (x *CreateModelResponse) GetUpdatedAt() *timestamppb.Timestamp
func (*CreateModelResponse) ProtoMessage ¶
func (*CreateModelResponse) ProtoMessage()
func (*CreateModelResponse) ProtoReflect ¶
func (x *CreateModelResponse) ProtoReflect() protoreflect.Message
func (*CreateModelResponse) Reset ¶
func (x *CreateModelResponse) Reset()
func (*CreateModelResponse) String ¶
func (x *CreateModelResponse) String() string
type CreateModelVersionRequest ¶
type CreateModelVersionRequest struct { Model string `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` Namespace string `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"` Framework MLFramework `protobuf:"varint,8,opt,name=framework,proto3,enum=modelbox.MLFramework" json:"framework,omitempty"` UniqueTags []string `protobuf:"bytes,9,rep,name=unique_tags,json=uniqueTags,proto3" json:"unique_tags,omitempty"` // contains filtered or unexported fields }
func (*CreateModelVersionRequest) Descriptor
deprecated
func (*CreateModelVersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateModelVersionRequest.ProtoReflect.Descriptor instead.
func (*CreateModelVersionRequest) GetDescription ¶
func (x *CreateModelVersionRequest) GetDescription() string
func (*CreateModelVersionRequest) GetFramework ¶
func (x *CreateModelVersionRequest) GetFramework() MLFramework
func (*CreateModelVersionRequest) GetModel ¶
func (x *CreateModelVersionRequest) GetModel() string
func (*CreateModelVersionRequest) GetName ¶
func (x *CreateModelVersionRequest) GetName() string
func (*CreateModelVersionRequest) GetNamespace ¶
func (x *CreateModelVersionRequest) GetNamespace() string
func (*CreateModelVersionRequest) GetUniqueTags ¶
func (x *CreateModelVersionRequest) GetUniqueTags() []string
func (*CreateModelVersionRequest) GetVersion ¶
func (x *CreateModelVersionRequest) GetVersion() string
func (*CreateModelVersionRequest) ProtoMessage ¶
func (*CreateModelVersionRequest) ProtoMessage()
func (*CreateModelVersionRequest) ProtoReflect ¶
func (x *CreateModelVersionRequest) ProtoReflect() protoreflect.Message
func (*CreateModelVersionRequest) Reset ¶
func (x *CreateModelVersionRequest) Reset()
func (*CreateModelVersionRequest) String ¶
func (x *CreateModelVersionRequest) String() string
type CreateModelVersionResponse ¶
type CreateModelVersionResponse struct { ModelVersion string `protobuf:"bytes,1,opt,name=model_version,json=modelVersion,proto3" json:"model_version,omitempty"` Exists bool `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,21,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // contains filtered or unexported fields }
func (*CreateModelVersionResponse) Descriptor
deprecated
func (*CreateModelVersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateModelVersionResponse.ProtoReflect.Descriptor instead.
func (*CreateModelVersionResponse) GetCreatedAt ¶
func (x *CreateModelVersionResponse) GetCreatedAt() *timestamppb.Timestamp
func (*CreateModelVersionResponse) GetExists ¶
func (x *CreateModelVersionResponse) GetExists() bool
func (*CreateModelVersionResponse) GetModelVersion ¶
func (x *CreateModelVersionResponse) GetModelVersion() string
func (*CreateModelVersionResponse) GetUpdatedAt ¶
func (x *CreateModelVersionResponse) GetUpdatedAt() *timestamppb.Timestamp
func (*CreateModelVersionResponse) ProtoMessage ¶
func (*CreateModelVersionResponse) ProtoMessage()
func (*CreateModelVersionResponse) ProtoReflect ¶
func (x *CreateModelVersionResponse) ProtoReflect() protoreflect.Message
func (*CreateModelVersionResponse) Reset ¶
func (x *CreateModelVersionResponse) Reset()
func (*CreateModelVersionResponse) String ¶
func (x *CreateModelVersionResponse) String() string
type DownloadFileRequest ¶
type DownloadFileRequest struct { FileId string `protobuf:"bytes,1,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"` // contains filtered or unexported fields }
func (*DownloadFileRequest) Descriptor
deprecated
func (*DownloadFileRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadFileRequest.ProtoReflect.Descriptor instead.
func (*DownloadFileRequest) GetFileId ¶
func (x *DownloadFileRequest) GetFileId() string
func (*DownloadFileRequest) ProtoMessage ¶
func (*DownloadFileRequest) ProtoMessage()
func (*DownloadFileRequest) ProtoReflect ¶
func (x *DownloadFileRequest) ProtoReflect() protoreflect.Message
func (*DownloadFileRequest) Reset ¶
func (x *DownloadFileRequest) Reset()
func (*DownloadFileRequest) String ¶
func (x *DownloadFileRequest) String() string
type DownloadFileResponse ¶
type DownloadFileResponse struct { // Types that are assignable to StreamFrame: // // *DownloadFileResponse_Metadata // *DownloadFileResponse_Chunks StreamFrame isDownloadFileResponse_StreamFrame `protobuf_oneof:"stream_frame"` // contains filtered or unexported fields }
func (*DownloadFileResponse) Descriptor
deprecated
func (*DownloadFileResponse) Descriptor() ([]byte, []int)
Deprecated: Use DownloadFileResponse.ProtoReflect.Descriptor instead.
func (*DownloadFileResponse) GetChunks ¶
func (x *DownloadFileResponse) GetChunks() []byte
func (*DownloadFileResponse) GetMetadata ¶
func (x *DownloadFileResponse) GetMetadata() *FileMetadata
func (*DownloadFileResponse) GetStreamFrame ¶
func (m *DownloadFileResponse) GetStreamFrame() isDownloadFileResponse_StreamFrame
func (*DownloadFileResponse) ProtoMessage ¶
func (*DownloadFileResponse) ProtoMessage()
func (*DownloadFileResponse) ProtoReflect ¶
func (x *DownloadFileResponse) ProtoReflect() protoreflect.Message
func (*DownloadFileResponse) Reset ¶
func (x *DownloadFileResponse) Reset()
func (*DownloadFileResponse) String ¶
func (x *DownloadFileResponse) String() string
type DownloadFileResponse_Chunks ¶
type DownloadFileResponse_Chunks struct {
Chunks []byte `protobuf:"bytes,2,opt,name=chunks,proto3,oneof"`
}
type DownloadFileResponse_Metadata ¶
type DownloadFileResponse_Metadata struct {
Metadata *FileMetadata `protobuf:"bytes,1,opt,name=metadata,proto3,oneof"`
}
type Event ¶
type Event struct { Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Source *EventSource `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` WallclockTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=wallclock_time,json=wallclockTime,proto3" json:"wallclock_time,omitempty"` Metadata *Metadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) GetMetadata ¶
func (*Event) GetSource ¶
func (x *Event) GetSource() *EventSource
func (*Event) GetWallclockTime ¶
func (x *Event) GetWallclockTime() *timestamppb.Timestamp
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type EventSource ¶
type EventSource struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*EventSource) Descriptor
deprecated
func (*EventSource) Descriptor() ([]byte, []int)
Deprecated: Use EventSource.ProtoReflect.Descriptor instead.
func (*EventSource) GetName ¶
func (x *EventSource) GetName() string
func (*EventSource) ProtoMessage ¶
func (*EventSource) ProtoMessage()
func (*EventSource) ProtoReflect ¶
func (x *EventSource) ProtoReflect() protoreflect.Message
func (*EventSource) Reset ¶
func (x *EventSource) Reset()
func (*EventSource) String ¶
func (x *EventSource) String() string
type Experiment ¶
type Experiment struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` Framework MLFramework `protobuf:"varint,5,opt,name=framework,proto3,enum=modelbox.MLFramework" json:"framework,omitempty"` ExternalId string `protobuf:"bytes,7,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,21,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // contains filtered or unexported fields }
* Experiments are the sources of Model checkpoints. They track various details related to the training runs which created the models such as hyper parameters, etc.
func (*Experiment) Descriptor
deprecated
func (*Experiment) Descriptor() ([]byte, []int)
Deprecated: Use Experiment.ProtoReflect.Descriptor instead.
func (*Experiment) GetCreatedAt ¶
func (x *Experiment) GetCreatedAt() *timestamppb.Timestamp
func (*Experiment) GetExternalId ¶
func (x *Experiment) GetExternalId() string
func (*Experiment) GetFramework ¶
func (x *Experiment) GetFramework() MLFramework
func (*Experiment) GetId ¶
func (x *Experiment) GetId() string
func (*Experiment) GetName ¶
func (x *Experiment) GetName() string
func (*Experiment) GetNamespace ¶
func (x *Experiment) GetNamespace() string
func (*Experiment) GetOwner ¶
func (x *Experiment) GetOwner() string
func (*Experiment) GetUpdatedAt ¶
func (x *Experiment) GetUpdatedAt() *timestamppb.Timestamp
func (*Experiment) ProtoMessage ¶
func (*Experiment) ProtoMessage()
func (*Experiment) ProtoReflect ¶
func (x *Experiment) ProtoReflect() protoreflect.Message
func (*Experiment) Reset ¶
func (x *Experiment) Reset()
func (*Experiment) String ¶
func (x *Experiment) String() string
type FileMetadata ¶
type FileMetadata struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // The ID of the experiment, model to which this file belongs to ParentId string `protobuf:"bytes,2,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` // MIMEType of the file FileType FileType `protobuf:"varint,3,opt,name=file_type,json=fileType,proto3,enum=modelbox.FileType" json:"file_type,omitempty"` // checksum of the file Checksum string `protobuf:"bytes,4,opt,name=checksum,proto3" json:"checksum,omitempty"` // path of the file SrcPath string `protobuf:"bytes,5,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"` // path of uploaded file UploadPath string `protobuf:"bytes,6,opt,name=upload_path,json=uploadPath,proto3" json:"upload_path,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,21,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // contains filtered or unexported fields }
FileMetadata contains information about the file associated with a model version such as model binaries, other meta data files related to the model. This could either be sent as part of the model version creation request to track files already managed by another storage service, or as the first message while uploading a file to be managed by ModelBox.
func (*FileMetadata) Descriptor
deprecated
func (*FileMetadata) Descriptor() ([]byte, []int)
Deprecated: Use FileMetadata.ProtoReflect.Descriptor instead.
func (*FileMetadata) GetChecksum ¶
func (x *FileMetadata) GetChecksum() string
func (*FileMetadata) GetCreatedAt ¶
func (x *FileMetadata) GetCreatedAt() *timestamppb.Timestamp
func (*FileMetadata) GetFileType ¶
func (x *FileMetadata) GetFileType() FileType
func (*FileMetadata) GetId ¶
func (x *FileMetadata) GetId() string
func (*FileMetadata) GetParentId ¶
func (x *FileMetadata) GetParentId() string
func (*FileMetadata) GetSrcPath ¶
func (x *FileMetadata) GetSrcPath() string
func (*FileMetadata) GetUpdatedAt ¶
func (x *FileMetadata) GetUpdatedAt() *timestamppb.Timestamp
func (*FileMetadata) GetUploadPath ¶
func (x *FileMetadata) GetUploadPath() string
func (*FileMetadata) ProtoMessage ¶
func (*FileMetadata) ProtoMessage()
func (*FileMetadata) ProtoReflect ¶
func (x *FileMetadata) ProtoReflect() protoreflect.Message
func (*FileMetadata) Reset ¶
func (x *FileMetadata) Reset()
func (*FileMetadata) String ¶
func (x *FileMetadata) String() string
type FileType ¶
type FileType int32
func (FileType) Descriptor ¶
func (FileType) Descriptor() protoreflect.EnumDescriptor
func (FileType) EnumDescriptor
deprecated
func (FileType) Number ¶
func (x FileType) Number() protoreflect.EnumNumber
func (FileType) Type ¶
func (FileType) Type() protoreflect.EnumType
type GetClusterMembersRequest ¶
type GetClusterMembersRequest struct {
// contains filtered or unexported fields
}
func (*GetClusterMembersRequest) Descriptor
deprecated
func (*GetClusterMembersRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetClusterMembersRequest.ProtoReflect.Descriptor instead.
func (*GetClusterMembersRequest) ProtoMessage ¶
func (*GetClusterMembersRequest) ProtoMessage()
func (*GetClusterMembersRequest) ProtoReflect ¶
func (x *GetClusterMembersRequest) ProtoReflect() protoreflect.Message
func (*GetClusterMembersRequest) Reset ¶
func (x *GetClusterMembersRequest) Reset()
func (*GetClusterMembersRequest) String ¶
func (x *GetClusterMembersRequest) String() string
type GetClusterMembersResponse ¶
type GetClusterMembersResponse struct { Members []*ClusterMember `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"` // contains filtered or unexported fields }
func (*GetClusterMembersResponse) Descriptor
deprecated
func (*GetClusterMembersResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetClusterMembersResponse.ProtoReflect.Descriptor instead.
func (*GetClusterMembersResponse) GetMembers ¶
func (x *GetClusterMembersResponse) GetMembers() []*ClusterMember
func (*GetClusterMembersResponse) ProtoMessage ¶
func (*GetClusterMembersResponse) ProtoMessage()
func (*GetClusterMembersResponse) ProtoReflect ¶
func (x *GetClusterMembersResponse) ProtoReflect() protoreflect.Message
func (*GetClusterMembersResponse) Reset ¶
func (x *GetClusterMembersResponse) Reset()
func (*GetClusterMembersResponse) String ¶
func (x *GetClusterMembersResponse) String() string
type GetExperimentRequest ¶
type GetExperimentRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetExperimentRequest) Descriptor
deprecated
func (*GetExperimentRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetExperimentRequest.ProtoReflect.Descriptor instead.
func (*GetExperimentRequest) GetId ¶
func (x *GetExperimentRequest) GetId() string
func (*GetExperimentRequest) ProtoMessage ¶
func (*GetExperimentRequest) ProtoMessage()
func (*GetExperimentRequest) ProtoReflect ¶
func (x *GetExperimentRequest) ProtoReflect() protoreflect.Message
func (*GetExperimentRequest) Reset ¶
func (x *GetExperimentRequest) Reset()
func (*GetExperimentRequest) String ¶
func (x *GetExperimentRequest) String() string
type GetExperimentResponse ¶
type GetExperimentResponse struct { Experiment *Experiment `protobuf:"bytes,1,opt,name=experiment,proto3" json:"experiment,omitempty"` // contains filtered or unexported fields }
func (*GetExperimentResponse) Descriptor
deprecated
func (*GetExperimentResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetExperimentResponse.ProtoReflect.Descriptor instead.
func (*GetExperimentResponse) GetExperiment ¶
func (x *GetExperimentResponse) GetExperiment() *Experiment
func (*GetExperimentResponse) ProtoMessage ¶
func (*GetExperimentResponse) ProtoMessage()
func (*GetExperimentResponse) ProtoReflect ¶
func (x *GetExperimentResponse) ProtoReflect() protoreflect.Message
func (*GetExperimentResponse) Reset ¶
func (x *GetExperimentResponse) Reset()
func (*GetExperimentResponse) String ¶
func (x *GetExperimentResponse) String() string
type GetMetricsRequest ¶
type GetMetricsRequest struct { ParentId string `protobuf:"bytes,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` // contains filtered or unexported fields }
func (*GetMetricsRequest) Descriptor
deprecated
func (*GetMetricsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMetricsRequest.ProtoReflect.Descriptor instead.
func (*GetMetricsRequest) GetParentId ¶
func (x *GetMetricsRequest) GetParentId() string
func (*GetMetricsRequest) ProtoMessage ¶
func (*GetMetricsRequest) ProtoMessage()
func (*GetMetricsRequest) ProtoReflect ¶
func (x *GetMetricsRequest) ProtoReflect() protoreflect.Message
func (*GetMetricsRequest) Reset ¶
func (x *GetMetricsRequest) Reset()
func (*GetMetricsRequest) String ¶
func (x *GetMetricsRequest) String() string
type GetMetricsResponse ¶
type GetMetricsResponse struct { Metrics map[string]*Metrics `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetMetricsResponse) Descriptor
deprecated
func (*GetMetricsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetMetricsResponse.ProtoReflect.Descriptor instead.
func (*GetMetricsResponse) GetMetrics ¶
func (x *GetMetricsResponse) GetMetrics() map[string]*Metrics
func (*GetMetricsResponse) ProtoMessage ¶
func (*GetMetricsResponse) ProtoMessage()
func (*GetMetricsResponse) ProtoReflect ¶
func (x *GetMetricsResponse) ProtoReflect() protoreflect.Message
func (*GetMetricsResponse) Reset ¶
func (x *GetMetricsResponse) Reset()
func (*GetMetricsResponse) String ¶
func (x *GetMetricsResponse) String() string
type GetRunnableActionInstancesRequest ¶
type GetRunnableActionInstancesRequest struct { ActionName string `protobuf:"bytes,1,opt,name=action_name,json=actionName,proto3" json:"action_name,omitempty"` Arch string `protobuf:"bytes,2,opt,name=arch,proto3" json:"arch,omitempty"` // contains filtered or unexported fields }
func (*GetRunnableActionInstancesRequest) Descriptor
deprecated
func (*GetRunnableActionInstancesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRunnableActionInstancesRequest.ProtoReflect.Descriptor instead.
func (*GetRunnableActionInstancesRequest) GetActionName ¶
func (x *GetRunnableActionInstancesRequest) GetActionName() string
func (*GetRunnableActionInstancesRequest) GetArch ¶
func (x *GetRunnableActionInstancesRequest) GetArch() string
func (*GetRunnableActionInstancesRequest) ProtoMessage ¶
func (*GetRunnableActionInstancesRequest) ProtoMessage()
func (*GetRunnableActionInstancesRequest) ProtoReflect ¶
func (x *GetRunnableActionInstancesRequest) ProtoReflect() protoreflect.Message
func (*GetRunnableActionInstancesRequest) Reset ¶
func (x *GetRunnableActionInstancesRequest) Reset()
func (*GetRunnableActionInstancesRequest) String ¶
func (x *GetRunnableActionInstancesRequest) String() string
type GetRunnableActionInstancesResponse ¶
type GetRunnableActionInstancesResponse struct { Instances []*RunnableAction `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"` // contains filtered or unexported fields }
func (*GetRunnableActionInstancesResponse) Descriptor
deprecated
func (*GetRunnableActionInstancesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetRunnableActionInstancesResponse.ProtoReflect.Descriptor instead.
func (*GetRunnableActionInstancesResponse) GetInstances ¶
func (x *GetRunnableActionInstancesResponse) GetInstances() []*RunnableAction
func (*GetRunnableActionInstancesResponse) ProtoMessage ¶
func (*GetRunnableActionInstancesResponse) ProtoMessage()
func (*GetRunnableActionInstancesResponse) ProtoReflect ¶
func (x *GetRunnableActionInstancesResponse) ProtoReflect() protoreflect.Message
func (*GetRunnableActionInstancesResponse) Reset ¶
func (x *GetRunnableActionInstancesResponse) Reset()
func (*GetRunnableActionInstancesResponse) String ¶
func (x *GetRunnableActionInstancesResponse) String() string
type HeartbeatRequest ¶
type HeartbeatRequest struct { NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` At *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=at,proto3" json:"at,omitempty"` // contains filtered or unexported fields }
func (*HeartbeatRequest) Descriptor
deprecated
func (*HeartbeatRequest) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.
func (*HeartbeatRequest) GetAt ¶
func (x *HeartbeatRequest) GetAt() *timestamppb.Timestamp
func (*HeartbeatRequest) GetNodeId ¶
func (x *HeartbeatRequest) GetNodeId() string
func (*HeartbeatRequest) ProtoMessage ¶
func (*HeartbeatRequest) ProtoMessage()
func (*HeartbeatRequest) ProtoReflect ¶
func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
func (*HeartbeatRequest) Reset ¶
func (x *HeartbeatRequest) Reset()
func (*HeartbeatRequest) String ¶
func (x *HeartbeatRequest) String() string
type HeartbeatResponse ¶
type HeartbeatResponse struct {
// contains filtered or unexported fields
}
func (*HeartbeatResponse) Descriptor
deprecated
func (*HeartbeatResponse) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.
func (*HeartbeatResponse) ProtoMessage ¶
func (*HeartbeatResponse) ProtoMessage()
func (*HeartbeatResponse) ProtoReflect ¶
func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message
func (*HeartbeatResponse) Reset ¶
func (x *HeartbeatResponse) Reset()
func (*HeartbeatResponse) String ¶
func (x *HeartbeatResponse) String() string
type ListArtifactsRequest ¶
type ListArtifactsRequest struct { ObjectId string `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"` // contains filtered or unexported fields }
func (*ListArtifactsRequest) Descriptor
deprecated
func (*ListArtifactsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListArtifactsRequest.ProtoReflect.Descriptor instead.
func (*ListArtifactsRequest) GetObjectId ¶
func (x *ListArtifactsRequest) GetObjectId() string
func (*ListArtifactsRequest) ProtoMessage ¶
func (*ListArtifactsRequest) ProtoMessage()
func (*ListArtifactsRequest) ProtoReflect ¶
func (x *ListArtifactsRequest) ProtoReflect() protoreflect.Message
func (*ListArtifactsRequest) Reset ¶
func (x *ListArtifactsRequest) Reset()
func (*ListArtifactsRequest) String ¶
func (x *ListArtifactsRequest) String() string
type ListArtifactsResponse ¶
type ListArtifactsResponse struct { Artifacts []*Artifact `protobuf:"bytes,1,rep,name=artifacts,proto3" json:"artifacts,omitempty"` // contains filtered or unexported fields }
func (*ListArtifactsResponse) Descriptor
deprecated
func (*ListArtifactsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListArtifactsResponse.ProtoReflect.Descriptor instead.
func (*ListArtifactsResponse) GetArtifacts ¶
func (x *ListArtifactsResponse) GetArtifacts() []*Artifact
func (*ListArtifactsResponse) ProtoMessage ¶
func (*ListArtifactsResponse) ProtoMessage()
func (*ListArtifactsResponse) ProtoReflect ¶
func (x *ListArtifactsResponse) ProtoReflect() protoreflect.Message
func (*ListArtifactsResponse) Reset ¶
func (x *ListArtifactsResponse) Reset()
func (*ListArtifactsResponse) String ¶
func (x *ListArtifactsResponse) String() string
type ListEventsRequest ¶
type ListEventsRequest struct { ParentId string `protobuf:"bytes,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` Since *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=since,proto3" json:"since,omitempty"` // contains filtered or unexported fields }
func (*ListEventsRequest) Descriptor
deprecated
func (*ListEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListEventsRequest.ProtoReflect.Descriptor instead.
func (*ListEventsRequest) GetParentId ¶
func (x *ListEventsRequest) GetParentId() string
func (*ListEventsRequest) GetSince ¶
func (x *ListEventsRequest) GetSince() *timestamppb.Timestamp
func (*ListEventsRequest) ProtoMessage ¶
func (*ListEventsRequest) ProtoMessage()
func (*ListEventsRequest) ProtoReflect ¶
func (x *ListEventsRequest) ProtoReflect() protoreflect.Message
func (*ListEventsRequest) Reset ¶
func (x *ListEventsRequest) Reset()
func (*ListEventsRequest) String ¶
func (x *ListEventsRequest) String() string
type ListEventsResponse ¶
type ListEventsResponse struct { Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*ListEventsResponse) Descriptor
deprecated
func (*ListEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListEventsResponse.ProtoReflect.Descriptor instead.
func (*ListEventsResponse) GetEvents ¶
func (x *ListEventsResponse) GetEvents() []*Event
func (*ListEventsResponse) ProtoMessage ¶
func (*ListEventsResponse) ProtoMessage()
func (*ListEventsResponse) ProtoReflect ¶
func (x *ListEventsResponse) ProtoReflect() protoreflect.Message
func (*ListEventsResponse) Reset ¶
func (x *ListEventsResponse) Reset()
func (*ListEventsResponse) String ¶
func (x *ListEventsResponse) String() string
type ListExperimentsRequest ¶
type ListExperimentsRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*ListExperimentsRequest) Descriptor
deprecated
func (*ListExperimentsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListExperimentsRequest.ProtoReflect.Descriptor instead.
func (*ListExperimentsRequest) GetNamespace ¶
func (x *ListExperimentsRequest) GetNamespace() string
func (*ListExperimentsRequest) ProtoMessage ¶
func (*ListExperimentsRequest) ProtoMessage()
func (*ListExperimentsRequest) ProtoReflect ¶
func (x *ListExperimentsRequest) ProtoReflect() protoreflect.Message
func (*ListExperimentsRequest) Reset ¶
func (x *ListExperimentsRequest) Reset()
func (*ListExperimentsRequest) String ¶
func (x *ListExperimentsRequest) String() string
type ListExperimentsResponse ¶
type ListExperimentsResponse struct { Experiments []*Experiment `protobuf:"bytes,1,rep,name=experiments,proto3" json:"experiments,omitempty"` // contains filtered or unexported fields }
func (*ListExperimentsResponse) Descriptor
deprecated
func (*ListExperimentsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListExperimentsResponse.ProtoReflect.Descriptor instead.
func (*ListExperimentsResponse) GetExperiments ¶
func (x *ListExperimentsResponse) GetExperiments() []*Experiment
func (*ListExperimentsResponse) ProtoMessage ¶
func (*ListExperimentsResponse) ProtoMessage()
func (*ListExperimentsResponse) ProtoReflect ¶
func (x *ListExperimentsResponse) ProtoReflect() protoreflect.Message
func (*ListExperimentsResponse) Reset ¶
func (x *ListExperimentsResponse) Reset()
func (*ListExperimentsResponse) String ¶
func (x *ListExperimentsResponse) String() string
type ListMetadataRequest ¶
type ListMetadataRequest struct { ParentId string `protobuf:"bytes,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` // contains filtered or unexported fields }
func (*ListMetadataRequest) Descriptor
deprecated
func (*ListMetadataRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListMetadataRequest.ProtoReflect.Descriptor instead.
func (*ListMetadataRequest) GetParentId ¶
func (x *ListMetadataRequest) GetParentId() string
func (*ListMetadataRequest) ProtoMessage ¶
func (*ListMetadataRequest) ProtoMessage()
func (*ListMetadataRequest) ProtoReflect ¶
func (x *ListMetadataRequest) ProtoReflect() protoreflect.Message
func (*ListMetadataRequest) Reset ¶
func (x *ListMetadataRequest) Reset()
func (*ListMetadataRequest) String ¶
func (x *ListMetadataRequest) String() string
type ListMetadataResponse ¶
type ListMetadataResponse struct { Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*ListMetadataResponse) Descriptor
deprecated
func (*ListMetadataResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListMetadataResponse.ProtoReflect.Descriptor instead.
func (*ListMetadataResponse) GetMetadata ¶
func (x *ListMetadataResponse) GetMetadata() *Metadata
func (*ListMetadataResponse) ProtoMessage ¶
func (*ListMetadataResponse) ProtoMessage()
func (*ListMetadataResponse) ProtoReflect ¶
func (x *ListMetadataResponse) ProtoReflect() protoreflect.Message
func (*ListMetadataResponse) Reset ¶
func (x *ListMetadataResponse) Reset()
func (*ListMetadataResponse) String ¶
func (x *ListMetadataResponse) String() string
type ListModelVersionsRequest ¶
type ListModelVersionsRequest struct { Model string `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"` // contains filtered or unexported fields }
func (*ListModelVersionsRequest) Descriptor
deprecated
func (*ListModelVersionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListModelVersionsRequest.ProtoReflect.Descriptor instead.
func (*ListModelVersionsRequest) GetModel ¶
func (x *ListModelVersionsRequest) GetModel() string
func (*ListModelVersionsRequest) ProtoMessage ¶
func (*ListModelVersionsRequest) ProtoMessage()
func (*ListModelVersionsRequest) ProtoReflect ¶
func (x *ListModelVersionsRequest) ProtoReflect() protoreflect.Message
func (*ListModelVersionsRequest) Reset ¶
func (x *ListModelVersionsRequest) Reset()
func (*ListModelVersionsRequest) String ¶
func (x *ListModelVersionsRequest) String() string
type ListModelVersionsResponse ¶
type ListModelVersionsResponse struct { ModelVersions []*ModelVersion `protobuf:"bytes,1,rep,name=model_versions,json=modelVersions,proto3" json:"model_versions,omitempty"` // contains filtered or unexported fields }
func (*ListModelVersionsResponse) Descriptor
deprecated
func (*ListModelVersionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListModelVersionsResponse.ProtoReflect.Descriptor instead.
func (*ListModelVersionsResponse) GetModelVersions ¶
func (x *ListModelVersionsResponse) GetModelVersions() []*ModelVersion
func (*ListModelVersionsResponse) ProtoMessage ¶
func (*ListModelVersionsResponse) ProtoMessage()
func (*ListModelVersionsResponse) ProtoReflect ¶
func (x *ListModelVersionsResponse) ProtoReflect() protoreflect.Message
func (*ListModelVersionsResponse) Reset ¶
func (x *ListModelVersionsResponse) Reset()
func (*ListModelVersionsResponse) String ¶
func (x *ListModelVersionsResponse) String() string
type ListModelsRequest ¶
type ListModelsRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*ListModelsRequest) Descriptor
deprecated
func (*ListModelsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListModelsRequest.ProtoReflect.Descriptor instead.
func (*ListModelsRequest) GetNamespace ¶
func (x *ListModelsRequest) GetNamespace() string
func (*ListModelsRequest) ProtoMessage ¶
func (*ListModelsRequest) ProtoMessage()
func (*ListModelsRequest) ProtoReflect ¶
func (x *ListModelsRequest) ProtoReflect() protoreflect.Message
func (*ListModelsRequest) Reset ¶
func (x *ListModelsRequest) Reset()
func (*ListModelsRequest) String ¶
func (x *ListModelsRequest) String() string
type ListModelsResponse ¶
type ListModelsResponse struct { Models []*Model `protobuf:"bytes,1,rep,name=models,proto3" json:"models,omitempty"` // contains filtered or unexported fields }
func (*ListModelsResponse) Descriptor
deprecated
func (*ListModelsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListModelsResponse.ProtoReflect.Descriptor instead.
func (*ListModelsResponse) GetModels ¶
func (x *ListModelsResponse) GetModels() []*Model
func (*ListModelsResponse) ProtoMessage ¶
func (*ListModelsResponse) ProtoMessage()
func (*ListModelsResponse) ProtoReflect ¶
func (x *ListModelsResponse) ProtoReflect() protoreflect.Message
func (*ListModelsResponse) Reset ¶
func (x *ListModelsResponse) Reset()
func (*ListModelsResponse) String ¶
func (x *ListModelsResponse) String() string
type LogEventRequest ¶
type LogEventRequest struct { ParentId string `protobuf:"bytes,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` Event *Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"` // contains filtered or unexported fields }
* Contains information about an event being logged about an experiment or a model or a checkpoint by any system interacting or using the object.
func (*LogEventRequest) Descriptor
deprecated
func (*LogEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogEventRequest.ProtoReflect.Descriptor instead.
func (*LogEventRequest) GetEvent ¶
func (x *LogEventRequest) GetEvent() *Event
func (*LogEventRequest) GetParentId ¶
func (x *LogEventRequest) GetParentId() string
func (*LogEventRequest) ProtoMessage ¶
func (*LogEventRequest) ProtoMessage()
func (*LogEventRequest) ProtoReflect ¶
func (x *LogEventRequest) ProtoReflect() protoreflect.Message
func (*LogEventRequest) Reset ¶
func (x *LogEventRequest) Reset()
func (*LogEventRequest) String ¶
func (x *LogEventRequest) String() string
type LogEventResponse ¶
type LogEventResponse struct { CreatedAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // contains filtered or unexported fields }
func (*LogEventResponse) Descriptor
deprecated
func (*LogEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use LogEventResponse.ProtoReflect.Descriptor instead.
func (*LogEventResponse) GetCreatedAt ¶
func (x *LogEventResponse) GetCreatedAt() *timestamppb.Timestamp
func (*LogEventResponse) ProtoMessage ¶
func (*LogEventResponse) ProtoMessage()
func (*LogEventResponse) ProtoReflect ¶
func (x *LogEventResponse) ProtoReflect() protoreflect.Message
func (*LogEventResponse) Reset ¶
func (x *LogEventResponse) Reset()
func (*LogEventResponse) String ¶
func (x *LogEventResponse) String() string
type LogMetricsRequest ¶
type LogMetricsRequest struct { ParentId string `protobuf:"bytes,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value *MetricsValue `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
Message for logging a metric value at a given time
func (*LogMetricsRequest) Descriptor
deprecated
func (*LogMetricsRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogMetricsRequest.ProtoReflect.Descriptor instead.
func (*LogMetricsRequest) GetKey ¶
func (x *LogMetricsRequest) GetKey() string
func (*LogMetricsRequest) GetParentId ¶
func (x *LogMetricsRequest) GetParentId() string
func (*LogMetricsRequest) GetValue ¶
func (x *LogMetricsRequest) GetValue() *MetricsValue
func (*LogMetricsRequest) ProtoMessage ¶
func (*LogMetricsRequest) ProtoMessage()
func (*LogMetricsRequest) ProtoReflect ¶
func (x *LogMetricsRequest) ProtoReflect() protoreflect.Message
func (*LogMetricsRequest) Reset ¶
func (x *LogMetricsRequest) Reset()
func (*LogMetricsRequest) String ¶
func (x *LogMetricsRequest) String() string
type LogMetricsResponse ¶
type LogMetricsResponse struct {
// contains filtered or unexported fields
}
func (*LogMetricsResponse) Descriptor
deprecated
func (*LogMetricsResponse) Descriptor() ([]byte, []int)
Deprecated: Use LogMetricsResponse.ProtoReflect.Descriptor instead.
func (*LogMetricsResponse) ProtoMessage ¶
func (*LogMetricsResponse) ProtoMessage()
func (*LogMetricsResponse) ProtoReflect ¶
func (x *LogMetricsResponse) ProtoReflect() protoreflect.Message
func (*LogMetricsResponse) Reset ¶
func (x *LogMetricsResponse) Reset()
func (*LogMetricsResponse) String ¶
func (x *LogMetricsResponse) String() string
type MLFramework ¶
type MLFramework int32
Deep Learning frameworks known to ModelBox
const ( MLFramework_UNKNOWN MLFramework = 0 MLFramework_PYTORCH MLFramework = 1 MLFramework_KERAS MLFramework = 2 )
func (MLFramework) Descriptor ¶
func (MLFramework) Descriptor() protoreflect.EnumDescriptor
func (MLFramework) Enum ¶
func (x MLFramework) Enum() *MLFramework
func (MLFramework) EnumDescriptor
deprecated
func (MLFramework) EnumDescriptor() ([]byte, []int)
Deprecated: Use MLFramework.Descriptor instead.
func (MLFramework) Number ¶
func (x MLFramework) Number() protoreflect.EnumNumber
func (MLFramework) String ¶
func (x MLFramework) String() string
func (MLFramework) Type ¶
func (MLFramework) Type() protoreflect.EnumType
type Metadata ¶
type Metadata struct { Metadata map[string]string `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Metadata) Descriptor
deprecated
func (*Metadata) GetMetadata ¶
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
func (*Metadata) ProtoReflect ¶
func (x *Metadata) ProtoReflect() protoreflect.Message
type Metrics ¶
type Metrics struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Values []*MetricsValue `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
Metrics contain the metric values for a given key
func (*Metrics) Descriptor
deprecated
func (*Metrics) GetValues ¶
func (x *Metrics) GetValues() []*MetricsValue
func (*Metrics) ProtoMessage ¶
func (*Metrics) ProtoMessage()
func (*Metrics) ProtoReflect ¶
func (x *Metrics) ProtoReflect() protoreflect.Message
type MetricsValue ¶
type MetricsValue struct { Step uint64 `protobuf:"varint,1,opt,name=step,proto3" json:"step,omitempty"` WallclockTime uint64 `protobuf:"varint,2,opt,name=wallclock_time,json=wallclockTime,proto3" json:"wallclock_time,omitempty"` // Types that are assignable to Value: // // *MetricsValue_FVal // *MetricsValue_STensor // *MetricsValue_BTensor Value isMetricsValue_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
Metric Value at a given point of time.
func (*MetricsValue) Descriptor
deprecated
func (*MetricsValue) Descriptor() ([]byte, []int)
Deprecated: Use MetricsValue.ProtoReflect.Descriptor instead.
func (*MetricsValue) GetBTensor ¶
func (x *MetricsValue) GetBTensor() []byte
func (*MetricsValue) GetFVal ¶
func (x *MetricsValue) GetFVal() float32
func (*MetricsValue) GetSTensor ¶
func (x *MetricsValue) GetSTensor() string
func (*MetricsValue) GetStep ¶
func (x *MetricsValue) GetStep() uint64
func (*MetricsValue) GetValue ¶
func (m *MetricsValue) GetValue() isMetricsValue_Value
func (*MetricsValue) GetWallclockTime ¶
func (x *MetricsValue) GetWallclockTime() uint64
func (*MetricsValue) ProtoMessage ¶
func (*MetricsValue) ProtoMessage()
func (*MetricsValue) ProtoReflect ¶
func (x *MetricsValue) ProtoReflect() protoreflect.Message
func (*MetricsValue) Reset ¶
func (x *MetricsValue) Reset()
func (*MetricsValue) String ¶
func (x *MetricsValue) String() string
type MetricsValue_BTensor ¶
type MetricsValue_BTensor struct {
BTensor []byte `protobuf:"bytes,7,opt,name=b_tensor,json=bTensor,proto3,oneof"`
}
type MetricsValue_FVal ¶
type MetricsValue_FVal struct {
FVal float32 `protobuf:"fixed32,5,opt,name=f_val,json=fVal,proto3,oneof"`
}
type MetricsValue_STensor ¶
type MetricsValue_STensor struct {
STensor string `protobuf:"bytes,6,opt,name=s_tensor,json=sTensor,proto3,oneof"`
}
type Model ¶
type Model struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"` Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` Task string `protobuf:"bytes,6,opt,name=task,proto3" json:"task,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,21,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // contains filtered or unexported fields }
Model contains metadata about a model which solves a particular use case.
func (*Model) Descriptor
deprecated
func (*Model) GetCreatedAt ¶
func (x *Model) GetCreatedAt() *timestamppb.Timestamp
func (*Model) GetDescription ¶
func (*Model) GetNamespace ¶
func (*Model) GetUpdatedAt ¶
func (x *Model) GetUpdatedAt() *timestamppb.Timestamp
func (*Model) ProtoMessage ¶
func (*Model) ProtoMessage()
func (*Model) ProtoReflect ¶
func (x *Model) ProtoReflect() protoreflect.Message
type ModelBoxAdminClient ¶
type ModelBoxAdminClient interface { // Register an agent capable of running plugins RegisterAgent(ctx context.Context, in *RegisterAgentRequest, opts ...grpc.CallOption) (*RegisterAgentResponse, error) // Workers heartbeat with the server about their presence // and work progress periodically Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error) // Download the list of work that can be exectuted by a action runner GetRunnableActionInstances(ctx context.Context, in *GetRunnableActionInstancesRequest, opts ...grpc.CallOption) (*GetRunnableActionInstancesResponse, error) // Update action status UpdateActionStatus(ctx context.Context, in *UpdateActionStatusRequest, opts ...grpc.CallOption) (*UpdateActionStatusResponse, error) // Returns the list of servers in a cluster. GetClusterMembers(ctx context.Context, in *GetClusterMembersRequest, opts ...grpc.CallOption) (*GetClusterMembersResponse, error) }
ModelBoxAdminClient is the client API for ModelBoxAdmin service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewModelBoxAdminClient ¶
func NewModelBoxAdminClient(cc grpc.ClientConnInterface) ModelBoxAdminClient
type ModelBoxAdminServer ¶
type ModelBoxAdminServer interface { // Register an agent capable of running plugins RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error) // Workers heartbeat with the server about their presence // and work progress periodically Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error) // Download the list of work that can be exectuted by a action runner GetRunnableActionInstances(context.Context, *GetRunnableActionInstancesRequest) (*GetRunnableActionInstancesResponse, error) // Update action status UpdateActionStatus(context.Context, *UpdateActionStatusRequest) (*UpdateActionStatusResponse, error) // Returns the list of servers in a cluster. GetClusterMembers(context.Context, *GetClusterMembersRequest) (*GetClusterMembersResponse, error) // contains filtered or unexported methods }
ModelBoxAdminServer is the server API for ModelBoxAdmin service. All implementations must embed UnimplementedModelBoxAdminServer for forward compatibility
type ModelStoreClient ¶
type ModelStoreClient interface { // Create a new Model under a namespace. If no namespace is specified, models // are created under a default namespace. CreateModel(ctx context.Context, in *CreateModelRequest, opts ...grpc.CallOption) (*CreateModelResponse, error) // List Models uploaded for a namespace ListModels(ctx context.Context, in *ListModelsRequest, opts ...grpc.CallOption) (*ListModelsResponse, error) // Creates a new model version for a model CreateModelVersion(ctx context.Context, in *CreateModelVersionRequest, opts ...grpc.CallOption) (*CreateModelVersionResponse, error) // Lists model versions for a model. ListModelVersions(ctx context.Context, in *ListModelVersionsRequest, opts ...grpc.CallOption) (*ListModelVersionsResponse, error) // Creates a new experiment CreateExperiment(ctx context.Context, in *CreateExperimentRequest, opts ...grpc.CallOption) (*CreateExperimentResponse, error) // List Experiments ListExperiments(ctx context.Context, in *ListExperimentsRequest, opts ...grpc.CallOption) (*ListExperimentsResponse, error) // Get Experiments GetExperiment(ctx context.Context, in *GetExperimentRequest, opts ...grpc.CallOption) (*GetExperimentResponse, error) // UploadFile streams a files to ModelBox and stores the binaries to the condfigured storage UploadFile(ctx context.Context, opts ...grpc.CallOption) (ModelStore_UploadFileClient, error) // DownloadFile downloads a file from configured storage DownloadFile(ctx context.Context, in *DownloadFileRequest, opts ...grpc.CallOption) (ModelStore_DownloadFileClient, error) // Persists a set of metadata related to objects UpdateMetadata(ctx context.Context, in *UpdateMetadataRequest, opts ...grpc.CallOption) (*UpdateMetadataResponse, error) // Lists metadata associated with an object ListMetadata(ctx context.Context, in *ListMetadataRequest, opts ...grpc.CallOption) (*ListMetadataResponse, error) // Tracks a set of artifacts with a experiment/checkpoint/model TrackArtifacts(ctx context.Context, in *TrackArtifactsRequest, opts ...grpc.CallOption) (*TrackArtifactsResponse, error) // List artifacts for an expriment/model/model version ListArtifacts(ctx context.Context, in *ListArtifactsRequest, opts ...grpc.CallOption) (*ListArtifactsResponse, error) // Log Metrics for an experiment, model or checkpoint LogMetrics(ctx context.Context, in *LogMetricsRequest, opts ...grpc.CallOption) (*LogMetricsResponse, error) // Get metrics logged for an experiment, model or checkpoint. GetMetrics(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*GetMetricsResponse, error) // Log an event from any system interacting with metadata of a experiment, models or // using a trained model or checkpoint. LogEvent(ctx context.Context, in *LogEventRequest, opts ...grpc.CallOption) (*LogEventResponse, error) // List events logged for an experiment/model, etc. ListEvents(ctx context.Context, in *ListEventsRequest, opts ...grpc.CallOption) (*ListEventsResponse, error) // Streams change events in any of objects such as experiments, models, etc, for a given namespace // Response is a json representation of the new state of the obejct WatchNamespace(ctx context.Context, in *WatchNamespaceRequest, opts ...grpc.CallOption) (ModelStore_WatchNamespaceClient, error) }
ModelStoreClient is the client API for ModelStore service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewModelStoreClient ¶
func NewModelStoreClient(cc grpc.ClientConnInterface) ModelStoreClient
type ModelStoreServer ¶
type ModelStoreServer interface { // Create a new Model under a namespace. If no namespace is specified, models // are created under a default namespace. CreateModel(context.Context, *CreateModelRequest) (*CreateModelResponse, error) // List Models uploaded for a namespace ListModels(context.Context, *ListModelsRequest) (*ListModelsResponse, error) // Creates a new model version for a model CreateModelVersion(context.Context, *CreateModelVersionRequest) (*CreateModelVersionResponse, error) // Lists model versions for a model. ListModelVersions(context.Context, *ListModelVersionsRequest) (*ListModelVersionsResponse, error) // Creates a new experiment CreateExperiment(context.Context, *CreateExperimentRequest) (*CreateExperimentResponse, error) // List Experiments ListExperiments(context.Context, *ListExperimentsRequest) (*ListExperimentsResponse, error) // Get Experiments GetExperiment(context.Context, *GetExperimentRequest) (*GetExperimentResponse, error) // UploadFile streams a files to ModelBox and stores the binaries to the condfigured storage UploadFile(ModelStore_UploadFileServer) error // DownloadFile downloads a file from configured storage DownloadFile(*DownloadFileRequest, ModelStore_DownloadFileServer) error // Persists a set of metadata related to objects UpdateMetadata(context.Context, *UpdateMetadataRequest) (*UpdateMetadataResponse, error) // Lists metadata associated with an object ListMetadata(context.Context, *ListMetadataRequest) (*ListMetadataResponse, error) // Tracks a set of artifacts with a experiment/checkpoint/model TrackArtifacts(context.Context, *TrackArtifactsRequest) (*TrackArtifactsResponse, error) // List artifacts for an expriment/model/model version ListArtifacts(context.Context, *ListArtifactsRequest) (*ListArtifactsResponse, error) // Log Metrics for an experiment, model or checkpoint LogMetrics(context.Context, *LogMetricsRequest) (*LogMetricsResponse, error) // Get metrics logged for an experiment, model or checkpoint. GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error) // Log an event from any system interacting with metadata of a experiment, models or // using a trained model or checkpoint. LogEvent(context.Context, *LogEventRequest) (*LogEventResponse, error) // List events logged for an experiment/model, etc. ListEvents(context.Context, *ListEventsRequest) (*ListEventsResponse, error) // Streams change events in any of objects such as experiments, models, etc, for a given namespace // Response is a json representation of the new state of the obejct WatchNamespace(*WatchNamespaceRequest, ModelStore_WatchNamespaceServer) error // contains filtered or unexported methods }
ModelStoreServer is the server API for ModelStore service. All implementations must embed UnimplementedModelStoreServer for forward compatibility
type ModelStore_DownloadFileClient ¶
type ModelStore_DownloadFileClient interface { Recv() (*DownloadFileResponse, error) grpc.ClientStream }
type ModelStore_DownloadFileServer ¶
type ModelStore_DownloadFileServer interface { Send(*DownloadFileResponse) error grpc.ServerStream }
type ModelStore_UploadFileClient ¶
type ModelStore_UploadFileClient interface { Send(*UploadFileRequest) error CloseAndRecv() (*UploadFileResponse, error) grpc.ClientStream }
type ModelStore_UploadFileServer ¶
type ModelStore_UploadFileServer interface { SendAndClose(*UploadFileResponse) error Recv() (*UploadFileRequest, error) grpc.ServerStream }
type ModelStore_WatchNamespaceClient ¶
type ModelStore_WatchNamespaceClient interface { Recv() (*WatchNamespaceResponse, error) grpc.ClientStream }
type ModelStore_WatchNamespaceServer ¶
type ModelStore_WatchNamespaceServer interface { Send(*WatchNamespaceResponse) error grpc.ServerStream }
type ModelVersion ¶
type ModelVersion struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ModelId string `protobuf:"bytes,2,opt,name=model_id,json=modelId,proto3" json:"model_id,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"` Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` Framework MLFramework `protobuf:"varint,8,opt,name=framework,proto3,enum=modelbox.MLFramework" json:"framework,omitempty"` UniqueTags []string `protobuf:"bytes,9,rep,name=unique_tags,json=uniqueTags,proto3" json:"unique_tags,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,21,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // contains filtered or unexported fields }
* ModelVersion contains a trained model binary, metrics related to the mode such as accuracy on various datasets, performance on a hardware, etc. Model Versions are always linked to a model.
func (*ModelVersion) Descriptor
deprecated
func (*ModelVersion) Descriptor() ([]byte, []int)
Deprecated: Use ModelVersion.ProtoReflect.Descriptor instead.
func (*ModelVersion) GetCreatedAt ¶
func (x *ModelVersion) GetCreatedAt() *timestamppb.Timestamp
func (*ModelVersion) GetDescription ¶
func (x *ModelVersion) GetDescription() string
func (*ModelVersion) GetFramework ¶
func (x *ModelVersion) GetFramework() MLFramework
func (*ModelVersion) GetId ¶
func (x *ModelVersion) GetId() string
func (*ModelVersion) GetModelId ¶
func (x *ModelVersion) GetModelId() string
func (*ModelVersion) GetName ¶
func (x *ModelVersion) GetName() string
func (*ModelVersion) GetUniqueTags ¶
func (x *ModelVersion) GetUniqueTags() []string
func (*ModelVersion) GetUpdatedAt ¶
func (x *ModelVersion) GetUpdatedAt() *timestamppb.Timestamp
func (*ModelVersion) GetVersion ¶
func (x *ModelVersion) GetVersion() string
func (*ModelVersion) ProtoMessage ¶
func (*ModelVersion) ProtoMessage()
func (*ModelVersion) ProtoReflect ¶
func (x *ModelVersion) ProtoReflect() protoreflect.Message
func (*ModelVersion) Reset ¶
func (x *ModelVersion) Reset()
func (*ModelVersion) String ¶
func (x *ModelVersion) String() string
type NodeInfo ¶
type NodeInfo struct { HostName string `protobuf:"bytes,1,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` IpAddr string `protobuf:"bytes,2,opt,name=ip_addr,json=ipAddr,proto3" json:"ip_addr,omitempty"` Arch string `protobuf:"bytes,3,opt,name=arch,proto3" json:"arch,omitempty"` // contains filtered or unexported fields }
func (*NodeInfo) Descriptor
deprecated
func (*NodeInfo) GetHostName ¶
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
func (*NodeInfo) ProtoReflect ¶
func (x *NodeInfo) ProtoReflect() protoreflect.Message
type RegisterAgentRequest ¶
type RegisterAgentRequest struct { NodeInfo *NodeInfo `protobuf:"bytes,1,opt,name=node_info,json=nodeInfo,proto3" json:"node_info,omitempty"` AgentName string `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"` // contains filtered or unexported fields }
func (*RegisterAgentRequest) Descriptor
deprecated
func (*RegisterAgentRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterAgentRequest.ProtoReflect.Descriptor instead.
func (*RegisterAgentRequest) GetAgentName ¶
func (x *RegisterAgentRequest) GetAgentName() string
func (*RegisterAgentRequest) GetNodeInfo ¶
func (x *RegisterAgentRequest) GetNodeInfo() *NodeInfo
func (*RegisterAgentRequest) ProtoMessage ¶
func (*RegisterAgentRequest) ProtoMessage()
func (*RegisterAgentRequest) ProtoReflect ¶
func (x *RegisterAgentRequest) ProtoReflect() protoreflect.Message
func (*RegisterAgentRequest) Reset ¶
func (x *RegisterAgentRequest) Reset()
func (*RegisterAgentRequest) String ¶
func (x *RegisterAgentRequest) String() string
type RegisterAgentResponse ¶
type RegisterAgentResponse struct { NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // contains filtered or unexported fields }
func (*RegisterAgentResponse) Descriptor
deprecated
func (*RegisterAgentResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterAgentResponse.ProtoReflect.Descriptor instead.
func (*RegisterAgentResponse) GetNodeId ¶
func (x *RegisterAgentResponse) GetNodeId() string
func (*RegisterAgentResponse) ProtoMessage ¶
func (*RegisterAgentResponse) ProtoMessage()
func (*RegisterAgentResponse) ProtoReflect ¶
func (x *RegisterAgentResponse) ProtoReflect() protoreflect.Message
func (*RegisterAgentResponse) Reset ¶
func (x *RegisterAgentResponse) Reset()
func (*RegisterAgentResponse) String ¶
func (x *RegisterAgentResponse) String() string
type RunnableAction ¶
type RunnableAction struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ActionId string `protobuf:"bytes,2,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"` Command string `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"` Params map[string]*structpb.Value `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RunnableAction) Descriptor
deprecated
func (*RunnableAction) Descriptor() ([]byte, []int)
Deprecated: Use RunnableAction.ProtoReflect.Descriptor instead.
func (*RunnableAction) GetActionId ¶
func (x *RunnableAction) GetActionId() string
func (*RunnableAction) GetCommand ¶
func (x *RunnableAction) GetCommand() string
func (*RunnableAction) GetId ¶
func (x *RunnableAction) GetId() string
func (*RunnableAction) ProtoMessage ¶
func (*RunnableAction) ProtoMessage()
func (*RunnableAction) ProtoReflect ¶
func (x *RunnableAction) ProtoReflect() protoreflect.Message
func (*RunnableAction) Reset ¶
func (x *RunnableAction) Reset()
func (*RunnableAction) String ¶
func (x *RunnableAction) String() string
type SubscribeEventRequest ¶
type SubscribeEventRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` MlFramework string `protobuf:"bytes,2,opt,name=ml_framework,json=mlFramework,proto3" json:"ml_framework,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Actions []string `protobuf:"bytes,4,rep,name=actions,proto3" json:"actions,omitempty"` // contains filtered or unexported fields }
func (*SubscribeEventRequest) Descriptor
deprecated
func (*SubscribeEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeEventRequest.ProtoReflect.Descriptor instead.
func (*SubscribeEventRequest) GetActions ¶
func (x *SubscribeEventRequest) GetActions() []string
func (*SubscribeEventRequest) GetMlFramework ¶
func (x *SubscribeEventRequest) GetMlFramework() string
func (*SubscribeEventRequest) GetNamespace ¶
func (x *SubscribeEventRequest) GetNamespace() string
func (*SubscribeEventRequest) GetOwner ¶
func (x *SubscribeEventRequest) GetOwner() string
func (*SubscribeEventRequest) ProtoMessage ¶
func (*SubscribeEventRequest) ProtoMessage()
func (*SubscribeEventRequest) ProtoReflect ¶
func (x *SubscribeEventRequest) ProtoReflect() protoreflect.Message
func (*SubscribeEventRequest) Reset ¶
func (x *SubscribeEventRequest) Reset()
func (*SubscribeEventRequest) String ¶
func (x *SubscribeEventRequest) String() string
type TrackArtifactsRequest ¶
type TrackArtifactsRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ObjectId string `protobuf:"bytes,2,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"` Files []*FileMetadata `protobuf:"bytes,3,rep,name=files,proto3" json:"files,omitempty"` // contains filtered or unexported fields }
func (*TrackArtifactsRequest) Descriptor
deprecated
func (*TrackArtifactsRequest) Descriptor() ([]byte, []int)
Deprecated: Use TrackArtifactsRequest.ProtoReflect.Descriptor instead.
func (*TrackArtifactsRequest) GetFiles ¶
func (x *TrackArtifactsRequest) GetFiles() []*FileMetadata
func (*TrackArtifactsRequest) GetName ¶
func (x *TrackArtifactsRequest) GetName() string
func (*TrackArtifactsRequest) GetObjectId ¶
func (x *TrackArtifactsRequest) GetObjectId() string
func (*TrackArtifactsRequest) ProtoMessage ¶
func (*TrackArtifactsRequest) ProtoMessage()
func (*TrackArtifactsRequest) ProtoReflect ¶
func (x *TrackArtifactsRequest) ProtoReflect() protoreflect.Message
func (*TrackArtifactsRequest) Reset ¶
func (x *TrackArtifactsRequest) Reset()
func (*TrackArtifactsRequest) String ¶
func (x *TrackArtifactsRequest) String() string
type TrackArtifactsResponse ¶
type TrackArtifactsResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*TrackArtifactsResponse) Descriptor
deprecated
func (*TrackArtifactsResponse) Descriptor() ([]byte, []int)
Deprecated: Use TrackArtifactsResponse.ProtoReflect.Descriptor instead.
func (*TrackArtifactsResponse) GetId ¶
func (x *TrackArtifactsResponse) GetId() string
func (*TrackArtifactsResponse) ProtoMessage ¶
func (*TrackArtifactsResponse) ProtoMessage()
func (*TrackArtifactsResponse) ProtoReflect ¶
func (x *TrackArtifactsResponse) ProtoReflect() protoreflect.Message
func (*TrackArtifactsResponse) Reset ¶
func (x *TrackArtifactsResponse) Reset()
func (*TrackArtifactsResponse) String ¶
func (x *TrackArtifactsResponse) String() string
type UnimplementedModelBoxAdminServer ¶
type UnimplementedModelBoxAdminServer struct { }
UnimplementedModelBoxAdminServer must be embedded to have forward compatible implementations.
func (UnimplementedModelBoxAdminServer) GetClusterMembers ¶
func (UnimplementedModelBoxAdminServer) GetClusterMembers(context.Context, *GetClusterMembersRequest) (*GetClusterMembersResponse, error)
func (UnimplementedModelBoxAdminServer) GetRunnableActionInstances ¶
func (UnimplementedModelBoxAdminServer) GetRunnableActionInstances(context.Context, *GetRunnableActionInstancesRequest) (*GetRunnableActionInstancesResponse, error)
func (UnimplementedModelBoxAdminServer) Heartbeat ¶
func (UnimplementedModelBoxAdminServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
func (UnimplementedModelBoxAdminServer) RegisterAgent ¶
func (UnimplementedModelBoxAdminServer) RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)
func (UnimplementedModelBoxAdminServer) UpdateActionStatus ¶
func (UnimplementedModelBoxAdminServer) UpdateActionStatus(context.Context, *UpdateActionStatusRequest) (*UpdateActionStatusResponse, error)
type UnimplementedModelStoreServer ¶
type UnimplementedModelStoreServer struct { }
UnimplementedModelStoreServer must be embedded to have forward compatible implementations.
func (UnimplementedModelStoreServer) CreateExperiment ¶
func (UnimplementedModelStoreServer) CreateExperiment(context.Context, *CreateExperimentRequest) (*CreateExperimentResponse, error)
func (UnimplementedModelStoreServer) CreateModel ¶
func (UnimplementedModelStoreServer) CreateModel(context.Context, *CreateModelRequest) (*CreateModelResponse, error)
func (UnimplementedModelStoreServer) CreateModelVersion ¶
func (UnimplementedModelStoreServer) CreateModelVersion(context.Context, *CreateModelVersionRequest) (*CreateModelVersionResponse, error)
func (UnimplementedModelStoreServer) DownloadFile ¶
func (UnimplementedModelStoreServer) DownloadFile(*DownloadFileRequest, ModelStore_DownloadFileServer) error
func (UnimplementedModelStoreServer) GetExperiment ¶
func (UnimplementedModelStoreServer) GetExperiment(context.Context, *GetExperimentRequest) (*GetExperimentResponse, error)
func (UnimplementedModelStoreServer) GetMetrics ¶
func (UnimplementedModelStoreServer) GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)
func (UnimplementedModelStoreServer) ListArtifacts ¶
func (UnimplementedModelStoreServer) ListArtifacts(context.Context, *ListArtifactsRequest) (*ListArtifactsResponse, error)
func (UnimplementedModelStoreServer) ListEvents ¶
func (UnimplementedModelStoreServer) ListEvents(context.Context, *ListEventsRequest) (*ListEventsResponse, error)
func (UnimplementedModelStoreServer) ListExperiments ¶
func (UnimplementedModelStoreServer) ListExperiments(context.Context, *ListExperimentsRequest) (*ListExperimentsResponse, error)
func (UnimplementedModelStoreServer) ListMetadata ¶
func (UnimplementedModelStoreServer) ListMetadata(context.Context, *ListMetadataRequest) (*ListMetadataResponse, error)
func (UnimplementedModelStoreServer) ListModelVersions ¶
func (UnimplementedModelStoreServer) ListModelVersions(context.Context, *ListModelVersionsRequest) (*ListModelVersionsResponse, error)
func (UnimplementedModelStoreServer) ListModels ¶
func (UnimplementedModelStoreServer) ListModels(context.Context, *ListModelsRequest) (*ListModelsResponse, error)
func (UnimplementedModelStoreServer) LogEvent ¶
func (UnimplementedModelStoreServer) LogEvent(context.Context, *LogEventRequest) (*LogEventResponse, error)
func (UnimplementedModelStoreServer) LogMetrics ¶
func (UnimplementedModelStoreServer) LogMetrics(context.Context, *LogMetricsRequest) (*LogMetricsResponse, error)
func (UnimplementedModelStoreServer) TrackArtifacts ¶
func (UnimplementedModelStoreServer) TrackArtifacts(context.Context, *TrackArtifactsRequest) (*TrackArtifactsResponse, error)
func (UnimplementedModelStoreServer) UpdateMetadata ¶
func (UnimplementedModelStoreServer) UpdateMetadata(context.Context, *UpdateMetadataRequest) (*UpdateMetadataResponse, error)
func (UnimplementedModelStoreServer) UploadFile ¶
func (UnimplementedModelStoreServer) UploadFile(ModelStore_UploadFileServer) error
func (UnimplementedModelStoreServer) WatchNamespace ¶
func (UnimplementedModelStoreServer) WatchNamespace(*WatchNamespaceRequest, ModelStore_WatchNamespaceServer) error
type UnsafeModelBoxAdminServer ¶
type UnsafeModelBoxAdminServer interface {
// contains filtered or unexported methods
}
UnsafeModelBoxAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ModelBoxAdminServer will result in compilation errors.
type UnsafeModelStoreServer ¶
type UnsafeModelStoreServer interface {
// contains filtered or unexported methods
}
UnsafeModelStoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ModelStoreServer will result in compilation errors.
type UpdateActionStatusRequest ¶
type UpdateActionStatusRequest struct { ActionInstanceId string `protobuf:"bytes,1,opt,name=action_instance_id,json=actionInstanceId,proto3" json:"action_instance_id,omitempty"` // Make the following uint32 enum Status uint32 `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"` Outcome uint32 `protobuf:"varint,3,opt,name=outcome,proto3" json:"outcome,omitempty"` OutcomeReason string `protobuf:"bytes,4,opt,name=outcome_reason,json=outcomeReason,proto3" json:"outcome_reason,omitempty"` UdpateTime uint64 `protobuf:"varint,5,opt,name=udpate_time,json=udpateTime,proto3" json:"udpate_time,omitempty"` // contains filtered or unexported fields }
func (*UpdateActionStatusRequest) Descriptor
deprecated
func (*UpdateActionStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateActionStatusRequest.ProtoReflect.Descriptor instead.
func (*UpdateActionStatusRequest) GetActionInstanceId ¶
func (x *UpdateActionStatusRequest) GetActionInstanceId() string
func (*UpdateActionStatusRequest) GetOutcome ¶
func (x *UpdateActionStatusRequest) GetOutcome() uint32
func (*UpdateActionStatusRequest) GetOutcomeReason ¶
func (x *UpdateActionStatusRequest) GetOutcomeReason() string
func (*UpdateActionStatusRequest) GetStatus ¶
func (x *UpdateActionStatusRequest) GetStatus() uint32
func (*UpdateActionStatusRequest) GetUdpateTime ¶
func (x *UpdateActionStatusRequest) GetUdpateTime() uint64
func (*UpdateActionStatusRequest) ProtoMessage ¶
func (*UpdateActionStatusRequest) ProtoMessage()
func (*UpdateActionStatusRequest) ProtoReflect ¶
func (x *UpdateActionStatusRequest) ProtoReflect() protoreflect.Message
func (*UpdateActionStatusRequest) Reset ¶
func (x *UpdateActionStatusRequest) Reset()
func (*UpdateActionStatusRequest) String ¶
func (x *UpdateActionStatusRequest) String() string
type UpdateActionStatusResponse ¶
type UpdateActionStatusResponse struct {
// contains filtered or unexported fields
}
func (*UpdateActionStatusResponse) Descriptor
deprecated
func (*UpdateActionStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateActionStatusResponse.ProtoReflect.Descriptor instead.
func (*UpdateActionStatusResponse) ProtoMessage ¶
func (*UpdateActionStatusResponse) ProtoMessage()
func (*UpdateActionStatusResponse) ProtoReflect ¶
func (x *UpdateActionStatusResponse) ProtoReflect() protoreflect.Message
func (*UpdateActionStatusResponse) Reset ¶
func (x *UpdateActionStatusResponse) Reset()
func (*UpdateActionStatusResponse) String ¶
func (x *UpdateActionStatusResponse) String() string
type UpdateMetadataRequest ¶
type UpdateMetadataRequest struct { ParentId string `protobuf:"bytes,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` Metadata *Metadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*UpdateMetadataRequest) Descriptor
deprecated
func (*UpdateMetadataRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateMetadataRequest.ProtoReflect.Descriptor instead.
func (*UpdateMetadataRequest) GetMetadata ¶
func (x *UpdateMetadataRequest) GetMetadata() *Metadata
func (*UpdateMetadataRequest) GetParentId ¶
func (x *UpdateMetadataRequest) GetParentId() string
func (*UpdateMetadataRequest) ProtoMessage ¶
func (*UpdateMetadataRequest) ProtoMessage()
func (*UpdateMetadataRequest) ProtoReflect ¶
func (x *UpdateMetadataRequest) ProtoReflect() protoreflect.Message
func (*UpdateMetadataRequest) Reset ¶
func (x *UpdateMetadataRequest) Reset()
func (*UpdateMetadataRequest) String ¶
func (x *UpdateMetadataRequest) String() string
type UpdateMetadataResponse ¶
type UpdateMetadataResponse struct {
// contains filtered or unexported fields
}
func (*UpdateMetadataResponse) Descriptor
deprecated
func (*UpdateMetadataResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateMetadataResponse.ProtoReflect.Descriptor instead.
func (*UpdateMetadataResponse) ProtoMessage ¶
func (*UpdateMetadataResponse) ProtoMessage()
func (*UpdateMetadataResponse) ProtoReflect ¶
func (x *UpdateMetadataResponse) ProtoReflect() protoreflect.Message
func (*UpdateMetadataResponse) Reset ¶
func (x *UpdateMetadataResponse) Reset()
func (*UpdateMetadataResponse) String ¶
func (x *UpdateMetadataResponse) String() string
type UploadFileMetadata ¶
type UploadFileMetadata struct { ArtifactName string `protobuf:"bytes,1,opt,name=artifact_name,json=artifactName,proto3" json:"artifact_name,omitempty"` ObjectId string `protobuf:"bytes,2,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"` Metadata *FileMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*UploadFileMetadata) Descriptor
deprecated
func (*UploadFileMetadata) Descriptor() ([]byte, []int)
Deprecated: Use UploadFileMetadata.ProtoReflect.Descriptor instead.
func (*UploadFileMetadata) GetArtifactName ¶
func (x *UploadFileMetadata) GetArtifactName() string
func (*UploadFileMetadata) GetMetadata ¶
func (x *UploadFileMetadata) GetMetadata() *FileMetadata
func (*UploadFileMetadata) GetObjectId ¶
func (x *UploadFileMetadata) GetObjectId() string
func (*UploadFileMetadata) ProtoMessage ¶
func (*UploadFileMetadata) ProtoMessage()
func (*UploadFileMetadata) ProtoReflect ¶
func (x *UploadFileMetadata) ProtoReflect() protoreflect.Message
func (*UploadFileMetadata) Reset ¶
func (x *UploadFileMetadata) Reset()
func (*UploadFileMetadata) String ¶
func (x *UploadFileMetadata) String() string
type UploadFileRequest ¶
type UploadFileRequest struct { // Types that are assignable to StreamFrame: // // *UploadFileRequest_Metadata // *UploadFileRequest_Chunks StreamFrame isUploadFileRequest_StreamFrame `protobuf_oneof:"stream_frame"` // contains filtered or unexported fields }
func (*UploadFileRequest) Descriptor
deprecated
func (*UploadFileRequest) Descriptor() ([]byte, []int)
Deprecated: Use UploadFileRequest.ProtoReflect.Descriptor instead.
func (*UploadFileRequest) GetChunks ¶
func (x *UploadFileRequest) GetChunks() []byte
func (*UploadFileRequest) GetMetadata ¶
func (x *UploadFileRequest) GetMetadata() *UploadFileMetadata
func (*UploadFileRequest) GetStreamFrame ¶
func (m *UploadFileRequest) GetStreamFrame() isUploadFileRequest_StreamFrame
func (*UploadFileRequest) ProtoMessage ¶
func (*UploadFileRequest) ProtoMessage()
func (*UploadFileRequest) ProtoReflect ¶
func (x *UploadFileRequest) ProtoReflect() protoreflect.Message
func (*UploadFileRequest) Reset ¶
func (x *UploadFileRequest) Reset()
func (*UploadFileRequest) String ¶
func (x *UploadFileRequest) String() string
type UploadFileRequest_Chunks ¶
type UploadFileRequest_Chunks struct {
Chunks []byte `protobuf:"bytes,2,opt,name=chunks,proto3,oneof"`
}
type UploadFileRequest_Metadata ¶
type UploadFileRequest_Metadata struct {
Metadata *UploadFileMetadata `protobuf:"bytes,1,opt,name=metadata,proto3,oneof"`
}
type UploadFileResponse ¶
type UploadFileResponse struct { FileId string `protobuf:"bytes,1,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"` ArtifactId string `protobuf:"bytes,2,opt,name=artifact_id,json=artifactId,proto3" json:"artifact_id,omitempty"` // contains filtered or unexported fields }
func (*UploadFileResponse) Descriptor
deprecated
func (*UploadFileResponse) Descriptor() ([]byte, []int)
Deprecated: Use UploadFileResponse.ProtoReflect.Descriptor instead.
func (*UploadFileResponse) GetArtifactId ¶
func (x *UploadFileResponse) GetArtifactId() string
func (*UploadFileResponse) GetFileId ¶
func (x *UploadFileResponse) GetFileId() string
func (*UploadFileResponse) ProtoMessage ¶
func (*UploadFileResponse) ProtoMessage()
func (*UploadFileResponse) ProtoReflect ¶
func (x *UploadFileResponse) ProtoReflect() protoreflect.Message
func (*UploadFileResponse) Reset ¶
func (x *UploadFileResponse) Reset()
func (*UploadFileResponse) String ¶
func (x *UploadFileResponse) String() string
type WatchNamespaceRequest ¶
type WatchNamespaceRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Since uint64 `protobuf:"varint,2,opt,name=since,proto3" json:"since,omitempty"` // contains filtered or unexported fields }
Request to watch events in a namespace, such as experiments/models/mocel versions being created or updated.
func (*WatchNamespaceRequest) Descriptor
deprecated
func (*WatchNamespaceRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchNamespaceRequest.ProtoReflect.Descriptor instead.
func (*WatchNamespaceRequest) GetNamespace ¶
func (x *WatchNamespaceRequest) GetNamespace() string
func (*WatchNamespaceRequest) GetSince ¶
func (x *WatchNamespaceRequest) GetSince() uint64
func (*WatchNamespaceRequest) ProtoMessage ¶
func (*WatchNamespaceRequest) ProtoMessage()
func (*WatchNamespaceRequest) ProtoReflect ¶
func (x *WatchNamespaceRequest) ProtoReflect() protoreflect.Message
func (*WatchNamespaceRequest) Reset ¶
func (x *WatchNamespaceRequest) Reset()
func (*WatchNamespaceRequest) String ¶
func (x *WatchNamespaceRequest) String() string
type WatchNamespaceResponse ¶
type WatchNamespaceResponse struct { Event ChangeEvent `protobuf:"varint,1,opt,name=event,proto3,enum=modelbox.ChangeEvent" json:"event,omitempty"` Payload *structpb.Value `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
func (*WatchNamespaceResponse) Descriptor
deprecated
func (*WatchNamespaceResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchNamespaceResponse.ProtoReflect.Descriptor instead.
func (*WatchNamespaceResponse) GetEvent ¶
func (x *WatchNamespaceResponse) GetEvent() ChangeEvent
func (*WatchNamespaceResponse) GetPayload ¶
func (x *WatchNamespaceResponse) GetPayload() *structpb.Value
func (*WatchNamespaceResponse) ProtoMessage ¶
func (*WatchNamespaceResponse) ProtoMessage()
func (*WatchNamespaceResponse) ProtoReflect ¶
func (x *WatchNamespaceResponse) ProtoReflect() protoreflect.Message
func (*WatchNamespaceResponse) Reset ¶
func (x *WatchNamespaceResponse) Reset()
func (*WatchNamespaceResponse) String ¶
func (x *WatchNamespaceResponse) String() string