mmesh

package
v0.8.0-rc0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 21, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ModelStatusInfo_ModelStatus_name = map[int32]string{
		0: "NOT_FOUND",
		1: "NOT_LOADED",
		2: "LOADING",
		3: "LOADED",
		4: "LOADING_FAILED",
		5: "UNKNOWN",
	}
	ModelStatusInfo_ModelStatus_value = map[string]int32{
		"NOT_FOUND":      0,
		"NOT_LOADED":     1,
		"LOADING":        2,
		"LOADED":         3,
		"LOADING_FAILED": 4,
		"UNKNOWN":        5,
	}
)

Enum value maps for ModelStatusInfo_ModelStatus.

View Source 
var (
	VModelStatusInfo_VModelStatus_name = map[int32]string{
		0: "NOT_FOUND",
		1: "DEFINED",
		2: "TRANSITIONING",
		3: "TRANSITION_FAILED",
		5: "UNKNOWN",
	}
	VModelStatusInfo_VModelStatus_value = map[string]int32{
		"NOT_FOUND":         0,
		"DEFINED":           1,
		"TRANSITIONING":     2,
		"TRANSITION_FAILED": 3,
		"UNKNOWN":           5,
	}
)

Enum value maps for VModelStatusInfo_VModelStatus.

View Source 
var File_mmesh_model_mesh_external_proto protoreflect.FileDescriptor
View Source 
var ModelMesh_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mmesh.ModelMesh",
	HandlerType: (*ModelMeshServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "registerModel",
			Handler:    _ModelMesh_RegisterModel_Handler,
		},
		{
			MethodName: "unregisterModel",
			Handler:    _ModelMesh_UnregisterModel_Handler,
		},
		{
			MethodName: "getModelStatus",
			Handler:    _ModelMesh_GetModelStatus_Handler,
		},
		{
			MethodName: "ensureLoaded",
			Handler:    _ModelMesh_EnsureLoaded_Handler,
		},
		{
			MethodName: "setVModel",
			Handler:    _ModelMesh_SetVModel_Handler,
		},
		{
			MethodName: "deleteVModel",
			Handler:    _ModelMesh_DeleteVModel_Handler,
		},
		{
			MethodName: "getVModelStatus",
			Handler:    _ModelMesh_GetVModelStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mmesh/model-mesh-external.proto",
}

ModelMesh_ServiceDesc is the grpc.ServiceDesc for ModelMesh service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterModelMeshServer 

func RegisterModelMeshServer(s grpc.ServiceRegistrar, srv ModelMeshServer)

Types

type DeleteVModelRequest 

type DeleteVModelRequest struct {
	VModelId string `protobuf:"bytes,1,opt,name=vModelId,proto3" json:"vModelId,omitempty"`
	// if provided the specified vmodel will be deleted only if its owner matches
	Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteVModelRequest) Descriptor deprecated 

func (*DeleteVModelRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteVModelRequest.ProtoReflect.Descriptor instead.

func (*DeleteVModelRequest) GetOwner 

func (x *DeleteVModelRequest) GetOwner() string

func (*DeleteVModelRequest) GetVModelId 

func (x *DeleteVModelRequest) GetVModelId() string

func (*DeleteVModelRequest) ProtoMessage 

func (*DeleteVModelRequest) ProtoMessage()

func (*DeleteVModelRequest) ProtoReflect 

func (x *DeleteVModelRequest) ProtoReflect() protoreflect.Message

func (*DeleteVModelRequest) Reset 

func (x *DeleteVModelRequest) Reset()

func (*DeleteVModelRequest) String 

func (x *DeleteVModelRequest) String() string

type DeleteVModelResponse 

type DeleteVModelResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteVModelResponse) Descriptor deprecated 

func (*DeleteVModelResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteVModelResponse.ProtoReflect.Descriptor instead.

func (*DeleteVModelResponse) ProtoMessage 

func (*DeleteVModelResponse) ProtoMessage()

func (*DeleteVModelResponse) ProtoReflect 

func (x *DeleteVModelResponse) ProtoReflect() protoreflect.Message

func (*DeleteVModelResponse) Reset 

func (x *DeleteVModelResponse) Reset()

func (*DeleteVModelResponse) String 

func (x *DeleteVModelResponse) String() string

type EnsureLoadedRequest 

type EnsureLoadedRequest struct {
	ModelId string `protobuf:"bytes,1,opt,name=modelId,proto3" json:"modelId,omitempty"`
	// timestamp to use when touching the model, 0 for "now" (default)
	LastUsedTime uint64 `protobuf:"varint,2,opt,name=lastUsedTime,proto3" json:"lastUsedTime,omitempty"`
	// whether to block until specified model completes loading
	Sync bool `protobuf:"varint,4,opt,name=sync,proto3" json:"sync,omitempty"`
	// contains filtered or unexported fields
}

func (*EnsureLoadedRequest) Descriptor deprecated 

func (*EnsureLoadedRequest) Descriptor() ([]byte, []int)

Deprecated: Use EnsureLoadedRequest.ProtoReflect.Descriptor instead.

func (*EnsureLoadedRequest) GetLastUsedTime 

func (x *EnsureLoadedRequest) GetLastUsedTime() uint64

func (*EnsureLoadedRequest) GetModelId 

func (x *EnsureLoadedRequest) GetModelId() string

func (*EnsureLoadedRequest) GetSync 

func (x *EnsureLoadedRequest) GetSync() bool

func (*EnsureLoadedRequest) ProtoMessage 

func (*EnsureLoadedRequest) ProtoMessage()

func (*EnsureLoadedRequest) ProtoReflect 

func (x *EnsureLoadedRequest) ProtoReflect() protoreflect.Message

func (*EnsureLoadedRequest) Reset 

func (x *EnsureLoadedRequest) Reset()

func (*EnsureLoadedRequest) String 

func (x *EnsureLoadedRequest) String() string

type GetStatusRequest 

type GetStatusRequest struct {
	ModelId string `protobuf:"bytes,1,opt,name=modelId,proto3" json:"modelId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatusRequest) Descriptor deprecated 

func (*GetStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStatusRequest) GetModelId 

func (x *GetStatusRequest) GetModelId() string

func (*GetStatusRequest) ProtoMessage 

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) ProtoReflect 

func (x *GetStatusRequest) ProtoReflect() protoreflect.Message

func (*GetStatusRequest) Reset 

func (x *GetStatusRequest) Reset()

func (*GetStatusRequest) String 

func (x *GetStatusRequest) String() string

type GetVModelStatusRequest 

type GetVModelStatusRequest struct {
	VModelId string `protobuf:"bytes,1,opt,name=vModelId,proto3" json:"vModelId,omitempty"`
	// if provided the specified vmodel must have matching owner or else the returned
	// response will indicate not found
	Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVModelStatusRequest) Descriptor deprecated 

func (*GetVModelStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetVModelStatusRequest.ProtoReflect.Descriptor instead.

func (*GetVModelStatusRequest) GetOwner 

func (x *GetVModelStatusRequest) GetOwner() string

func (*GetVModelStatusRequest) GetVModelId 

func (x *GetVModelStatusRequest) GetVModelId() string

func (*GetVModelStatusRequest) ProtoMessage 

func (*GetVModelStatusRequest) ProtoMessage()

func (*GetVModelStatusRequest) ProtoReflect 

func (x *GetVModelStatusRequest) ProtoReflect() protoreflect.Message

func (*GetVModelStatusRequest) Reset 

func (x *GetVModelStatusRequest) Reset()

func (*GetVModelStatusRequest) String 

func (x *GetVModelStatusRequest) String() string

type ModelInfo 

type ModelInfo struct {

	// arbitrary model metadata parameter, must be non-empty
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// arbitrary model metadata parameter
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// arbitrary model metadata parameter
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

Parameters holding information necessary to locate and load a given model, optional and for use only by your model runtime logic - they are passed to the model runtime loadModel api each time the model is loaded. These should *not* be use to store large amounts of data - the size of the strings should be as small as possible.

func (*ModelInfo) Descriptor deprecated 

func (*ModelInfo) Descriptor() ([]byte, []int)

Deprecated: Use ModelInfo.ProtoReflect.Descriptor instead.

func (*ModelInfo) GetKey 

func (x *ModelInfo) GetKey() string

func (*ModelInfo) GetPath 

func (x *ModelInfo) GetPath() string

func (*ModelInfo) GetType 

func (x *ModelInfo) GetType() string

func (*ModelInfo) ProtoMessage 

func (*ModelInfo) ProtoMessage()

func (*ModelInfo) ProtoReflect 

func (x *ModelInfo) ProtoReflect() protoreflect.Message

func (*ModelInfo) Reset 

func (x *ModelInfo) Reset()

func (*ModelInfo) String 

func (x *ModelInfo) String() string

type ModelMeshClient 

type ModelMeshClient interface {
	// Registers a trained model to this model-mesh cluster
	RegisterModel(ctx context.Context, in *RegisterModelRequest, opts ...grpc.CallOption) (*ModelStatusInfo, error)
	// Unregisters (deletes) a model from this model-mesh cluster,
	// has no effect if the specified model isn't found
	UnregisterModel(ctx context.Context, in *UnregisterModelRequest, opts ...grpc.CallOption) (*UnregisterModelResponse, error)
	// Returns the status of the specified model. See the ModelStatus enum
	GetModelStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*ModelStatusInfo, error)
	// Ensures the model with the specified id is loaded in this model-mesh cluster
	EnsureLoaded(ctx context.Context, in *EnsureLoadedRequest, opts ...grpc.CallOption) (*ModelStatusInfo, error)
	// Creates a new vmodel id (alias) which maps to a new or existing
	// concrete model, or sets the target model for an existing vmodel
	// to a new or existing concrete model
	SetVModel(ctx context.Context, in *SetVModelRequest, opts ...grpc.CallOption) (*VModelStatusInfo, error)
	// Deletes a vmodel, optionally deleting any referenced concrete
	// models at the same time
	DeleteVModel(ctx context.Context, in *DeleteVModelRequest, opts ...grpc.CallOption) (*DeleteVModelResponse, error)
	// Gets the status of a vmodel, including associated target/active model ids
	// If the vmodel is not found, the returned VModelStatusInfo will have empty
	// active and target model ids and an active model status of NOT_FOUND
	GetVModelStatus(ctx context.Context, in *GetVModelStatusRequest, opts ...grpc.CallOption) (*VModelStatusInfo, error)
}

ModelMeshClient is the client API for ModelMesh 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 NewModelMeshClient 

func NewModelMeshClient(cc grpc.ClientConnInterface) ModelMeshClient

type ModelMeshServer 

type ModelMeshServer interface {
	// Registers a trained model to this model-mesh cluster
	RegisterModel(context.Context, *RegisterModelRequest) (*ModelStatusInfo, error)
	// Unregisters (deletes) a model from this model-mesh cluster,
	// has no effect if the specified model isn't found
	UnregisterModel(context.Context, *UnregisterModelRequest) (*UnregisterModelResponse, error)
	// Returns the status of the specified model. See the ModelStatus enum
	GetModelStatus(context.Context, *GetStatusRequest) (*ModelStatusInfo, error)
	// Ensures the model with the specified id is loaded in this model-mesh cluster
	EnsureLoaded(context.Context, *EnsureLoadedRequest) (*ModelStatusInfo, error)
	// Creates a new vmodel id (alias) which maps to a new or existing
	// concrete model, or sets the target model for an existing vmodel
	// to a new or existing concrete model
	SetVModel(context.Context, *SetVModelRequest) (*VModelStatusInfo, error)
	// Deletes a vmodel, optionally deleting any referenced concrete
	// models at the same time
	DeleteVModel(context.Context, *DeleteVModelRequest) (*DeleteVModelResponse, error)
	// Gets the status of a vmodel, including associated target/active model ids
	// If the vmodel is not found, the returned VModelStatusInfo will have empty
	// active and target model ids and an active model status of NOT_FOUND
	GetVModelStatus(context.Context, *GetVModelStatusRequest) (*VModelStatusInfo, error)
	// contains filtered or unexported methods
}

ModelMeshServer is the server API for ModelMesh service. All implementations must embed UnimplementedModelMeshServer for forward compatibility

type ModelStatusInfo 

type ModelStatusInfo struct {
	Status ModelStatusInfo_ModelStatus `protobuf:"varint,1,opt,name=status,proto3,enum=mmesh.ModelStatusInfo_ModelStatus" json:"status,omitempty"`
	Errors []string                    `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	// Internal state of individual copies of this model - intended for
	// debugging/advanced uses only. The top-level model status field
	// should be sufficient for most cases. Arranged in reverse chronological order.
	ModelCopyInfos []*ModelStatusInfo_ModelCopyInfo `protobuf:"bytes,3,rep,name=modelCopyInfos,proto3" json:"modelCopyInfos,omitempty"`
	// contains filtered or unexported fields
}

func (*ModelStatusInfo) Descriptor deprecated 

func (*ModelStatusInfo) Descriptor() ([]byte, []int)

Deprecated: Use ModelStatusInfo.ProtoReflect.Descriptor instead.

func (*ModelStatusInfo) GetErrors 

func (x *ModelStatusInfo) GetErrors() []string

func (*ModelStatusInfo) GetModelCopyInfos 

func (x *ModelStatusInfo) GetModelCopyInfos() []*ModelStatusInfo_ModelCopyInfo

func (*ModelStatusInfo) GetStatus 

func (x *ModelStatusInfo) GetStatus() ModelStatusInfo_ModelStatus

func (*ModelStatusInfo) ProtoMessage 

func (*ModelStatusInfo) ProtoMessage()

func (*ModelStatusInfo) ProtoReflect 

func (x *ModelStatusInfo) ProtoReflect() protoreflect.Message

func (*ModelStatusInfo) Reset 

func (x *ModelStatusInfo) Reset()

func (*ModelStatusInfo) String 

func (x *ModelStatusInfo) String() string

type ModelStatusInfo_ModelCopyInfo 

type ModelStatusInfo_ModelCopyInfo struct {

	// id of instance in which the model copy resides
	Location string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// status of this copy, one of LOADING, LOADED, LOADING_FAILED, UNKNOWN
	CopyStatus ModelStatusInfo_ModelStatus `protobuf:"varint,2,opt,name=copyStatus,proto3,enum=mmesh.ModelStatusInfo_ModelStatus" json:"copyStatus,omitempty"`
	// time of latest state change
	Time uint64 `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ModelStatusInfo_ModelCopyInfo) Descriptor deprecated 

func (*ModelStatusInfo_ModelCopyInfo) Descriptor() ([]byte, []int)

Deprecated: Use ModelStatusInfo_ModelCopyInfo.ProtoReflect.Descriptor instead.

func (*ModelStatusInfo_ModelCopyInfo) GetCopyStatus 

func (x *ModelStatusInfo_ModelCopyInfo) GetCopyStatus() ModelStatusInfo_ModelStatus

func (*ModelStatusInfo_ModelCopyInfo) GetLocation 

func (x *ModelStatusInfo_ModelCopyInfo) GetLocation() string

func (*ModelStatusInfo_ModelCopyInfo) GetTime 

func (x *ModelStatusInfo_ModelCopyInfo) GetTime() uint64

func (*ModelStatusInfo_ModelCopyInfo) ProtoMessage 

func (*ModelStatusInfo_ModelCopyInfo) ProtoMessage()

func (*ModelStatusInfo_ModelCopyInfo) ProtoReflect 

func (x *ModelStatusInfo_ModelCopyInfo) ProtoReflect() protoreflect.Message

func (*ModelStatusInfo_ModelCopyInfo) Reset 

func (x *ModelStatusInfo_ModelCopyInfo) Reset()

func (*ModelStatusInfo_ModelCopyInfo) String 

func (x *ModelStatusInfo_ModelCopyInfo) String() string

type ModelStatusInfo_ModelStatus 

type ModelStatusInfo_ModelStatus int32
const (
	// model is not registered with the cluster
	ModelStatusInfo_NOT_FOUND ModelStatusInfo_ModelStatus = 0
	// model is registered but not currently loaded anywhere
	ModelStatusInfo_NOT_LOADED ModelStatusInfo_ModelStatus = 1
	// model is in the process of loading somewhere (and otherwise not loaded)
	ModelStatusInfo_LOADING ModelStatusInfo_ModelStatus = 2
	// model is loaded in at least one cluster instance
	ModelStatusInfo_LOADED ModelStatusInfo_ModelStatus = 3
	// model loading failed; will be retried periodically
	ModelStatusInfo_LOADING_FAILED ModelStatusInfo_ModelStatus = 4
	ModelStatusInfo_UNKNOWN        ModelStatusInfo_ModelStatus = 5
)

func (ModelStatusInfo_ModelStatus) Descriptor 

func (ModelStatusInfo_ModelStatus) Descriptor() protoreflect.EnumDescriptor

func (ModelStatusInfo_ModelStatus) Enum 

func (x ModelStatusInfo_ModelStatus) Enum() *ModelStatusInfo_ModelStatus

func (ModelStatusInfo_ModelStatus) EnumDescriptor deprecated 

func (ModelStatusInfo_ModelStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use ModelStatusInfo_ModelStatus.Descriptor instead.

func (ModelStatusInfo_ModelStatus) Number 

func (x ModelStatusInfo_ModelStatus) Number() protoreflect.EnumNumber

func (ModelStatusInfo_ModelStatus) String 

func (x ModelStatusInfo_ModelStatus) String() string

func (ModelStatusInfo_ModelStatus) Type 

func (ModelStatusInfo_ModelStatus) Type() protoreflect.EnumType

type RegisterModelRequest 

type RegisterModelRequest struct {
	ModelId   string     `protobuf:"bytes,1,opt,name=modelId,proto3" json:"modelId,omitempty"`
	ModelInfo *ModelInfo `protobuf:"bytes,2,opt,name=modelInfo,proto3" json:"modelInfo,omitempty"`
	// whether the model should be loaded immediately
	LoadNow bool `protobuf:"varint,3,opt,name=loadNow,proto3" json:"loadNow,omitempty"`
	// if loadNow is true, whether this method should block until the load completes
	Sync bool `protobuf:"varint,4,opt,name=sync,proto3" json:"sync,omitempty"`
	// OPTIONAL, ADVANCED - lastUsed timestamp to assign to newly registered
	// model, for initial priority in cache. This should not typically be set
	// (defaults to "recent")
	LastUsedTime uint64 `protobuf:"varint,5,opt,name=lastUsedTime,proto3" json:"lastUsedTime,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterModelRequest) Descriptor deprecated 

func (*RegisterModelRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterModelRequest.ProtoReflect.Descriptor instead.

func (*RegisterModelRequest) GetLastUsedTime 

func (x *RegisterModelRequest) GetLastUsedTime() uint64

func (*RegisterModelRequest) GetLoadNow 

func (x *RegisterModelRequest) GetLoadNow() bool

func (*RegisterModelRequest) GetModelId 

func (x *RegisterModelRequest) GetModelId() string

func (*RegisterModelRequest) GetModelInfo 

func (x *RegisterModelRequest) GetModelInfo() *ModelInfo

func (*RegisterModelRequest) GetSync 

func (x *RegisterModelRequest) GetSync() bool

func (*RegisterModelRequest) ProtoMessage 

func (*RegisterModelRequest) ProtoMessage()

func (*RegisterModelRequest) ProtoReflect 

func (x *RegisterModelRequest) ProtoReflect() protoreflect.Message

func (*RegisterModelRequest) Reset 

func (x *RegisterModelRequest) Reset()

func (*RegisterModelRequest) String 

func (x *RegisterModelRequest) String() string

type SetVModelRequest 

type SetVModelRequest struct {
	VModelId string `protobuf:"bytes,1,opt,name=vModelId,proto3" json:"vModelId,omitempty"`
	// if set and the vmodel does not already exist, it will be created with this owner.
	// if set and the vmodel already exists, the existing vmodel's owner must match or else
	// the call will fail with an ALREADY_EXISTS error
	Owner         string `protobuf:"bytes,10,opt,name=owner,proto3" json:"owner,omitempty"`
	TargetModelId string `protobuf:"bytes,2,opt,name=targetModelId,proto3" json:"targetModelId,omitempty"`
	// if true, the request will fail with NOT_FOUND if the vmodel does not already exist;
	// if false, non-existent vmodel ids will be created
	UpdateOnly bool `protobuf:"varint,3,opt,name=updateOnly,proto3" json:"updateOnly,omitempty"`
	// optional ModelInfo for target model - if provided then target model will be created,
	// otherwise it's expected to already exist
	ModelInfo *ModelInfo `protobuf:"bytes,4,opt,name=modelInfo,proto3" json:"modelInfo,omitempty"`
	// whether the newly created target model should be automatically deleted
	// once no longer referenced by any vmodel(s); applies only if modelInfo is provided
	AutoDeleteTargetModel bool `protobuf:"varint,5,opt,name=autoDeleteTargetModel,proto3" json:"autoDeleteTargetModel,omitempty"`
	// whether the new target model should be loaded immediately, even if the current
	// active model isn't loaded (otherwise the target model will be loaded to
	// the same scale as the current active model before it becomes the active model)
	LoadNow bool `protobuf:"varint,6,opt,name=loadNow,proto3" json:"loadNow,omitempty"`
	// if true, the active model will be updated immediately, regardless of the relative
	// states of the target and currently-active models
	Force bool `protobuf:"varint,7,opt,name=force,proto3" json:"force,omitempty"`
	// whether this method should block until the transition completes. if the vmodel
	// didn't already exist and loadNow is set to true, this will cause the method to
	// block until the target of the newly created vmodel has completed loading
	Sync bool `protobuf:"varint,8,opt,name=sync,proto3" json:"sync,omitempty"`
	// if provided, the request will only succeed (atomically) if the value matches the
	// vmodel's current targetModelId. If the provided value is equal to the
	// targetModelId in this same request message, the request will succeed only if
	// the vmodel doesn't already exist *or* exists with the same targetModelId (in
	// the latter case having no effect)
	ExpectedTargetModelId string `protobuf:"bytes,9,opt,name=expectedTargetModelId,proto3" json:"expectedTargetModelId,omitempty"`
	// contains filtered or unexported fields
}

func (*SetVModelRequest) Descriptor deprecated 

func (*SetVModelRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetVModelRequest.ProtoReflect.Descriptor instead.

func (*SetVModelRequest) GetAutoDeleteTargetModel 

func (x *SetVModelRequest) GetAutoDeleteTargetModel() bool

func (*SetVModelRequest) GetExpectedTargetModelId 

func (x *SetVModelRequest) GetExpectedTargetModelId() string

func (*SetVModelRequest) GetForce 

func (x *SetVModelRequest) GetForce() bool

func (*SetVModelRequest) GetLoadNow 

func (x *SetVModelRequest) GetLoadNow() bool

func (*SetVModelRequest) GetModelInfo 

func (x *SetVModelRequest) GetModelInfo() *ModelInfo

func (*SetVModelRequest) GetOwner 

func (x *SetVModelRequest) GetOwner() string

func (*SetVModelRequest) GetSync 

func (x *SetVModelRequest) GetSync() bool

func (*SetVModelRequest) GetTargetModelId 

func (x *SetVModelRequest) GetTargetModelId() string

func (*SetVModelRequest) GetUpdateOnly 

func (x *SetVModelRequest) GetUpdateOnly() bool

func (*SetVModelRequest) GetVModelId 

func (x *SetVModelRequest) GetVModelId() string

func (*SetVModelRequest) ProtoMessage 

func (*SetVModelRequest) ProtoMessage()

func (*SetVModelRequest) ProtoReflect 

func (x *SetVModelRequest) ProtoReflect() protoreflect.Message

func (*SetVModelRequest) Reset 

func (x *SetVModelRequest) Reset()

func (*SetVModelRequest) String 

func (x *SetVModelRequest) String() string

type UnimplementedModelMeshServer 

type UnimplementedModelMeshServer struct {
}

UnimplementedModelMeshServer must be embedded to have forward compatible implementations.

func (UnimplementedModelMeshServer) DeleteVModel 

func (UnimplementedModelMeshServer) DeleteVModel(context.Context, *DeleteVModelRequest) (*DeleteVModelResponse, error)

func (UnimplementedModelMeshServer) EnsureLoaded 

func (UnimplementedModelMeshServer) EnsureLoaded(context.Context, *EnsureLoadedRequest) (*ModelStatusInfo, error)

func (UnimplementedModelMeshServer) GetModelStatus 

func (UnimplementedModelMeshServer) GetModelStatus(context.Context, *GetStatusRequest) (*ModelStatusInfo, error)

func (UnimplementedModelMeshServer) GetVModelStatus 

func (UnimplementedModelMeshServer) GetVModelStatus(context.Context, *GetVModelStatusRequest) (*VModelStatusInfo, error)

func (UnimplementedModelMeshServer) RegisterModel 

func (UnimplementedModelMeshServer) RegisterModel(context.Context, *RegisterModelRequest) (*ModelStatusInfo, error)

func (UnimplementedModelMeshServer) SetVModel 

func (UnimplementedModelMeshServer) SetVModel(context.Context, *SetVModelRequest) (*VModelStatusInfo, error)

func (UnimplementedModelMeshServer) UnregisterModel 

func (UnimplementedModelMeshServer) UnregisterModel(context.Context, *UnregisterModelRequest) (*UnregisterModelResponse, error)

type UnregisterModelRequest 

type UnregisterModelRequest struct {
	ModelId string `protobuf:"bytes,1,opt,name=modelId,proto3" json:"modelId,omitempty"`
	// contains filtered or unexported fields
}

func (*UnregisterModelRequest) Descriptor deprecated 

func (*UnregisterModelRequest) Descriptor() ([]byte, []int)

Deprecated: Use UnregisterModelRequest.ProtoReflect.Descriptor instead.

func (*UnregisterModelRequest) GetModelId 

func (x *UnregisterModelRequest) GetModelId() string

func (*UnregisterModelRequest) ProtoMessage 

func (*UnregisterModelRequest) ProtoMessage()

func (*UnregisterModelRequest) ProtoReflect 

func (x *UnregisterModelRequest) ProtoReflect() protoreflect.Message

func (*UnregisterModelRequest) Reset 

func (x *UnregisterModelRequest) Reset()

func (*UnregisterModelRequest) String 

func (x *UnregisterModelRequest) String() string

type UnregisterModelResponse 

type UnregisterModelResponse struct {
	// contains filtered or unexported fields
}

func (*UnregisterModelResponse) Descriptor deprecated 

func (*UnregisterModelResponse) Descriptor() ([]byte, []int)

Deprecated: Use UnregisterModelResponse.ProtoReflect.Descriptor instead.

func (*UnregisterModelResponse) ProtoMessage 

func (*UnregisterModelResponse) ProtoMessage()

func (*UnregisterModelResponse) ProtoReflect 

func (x *UnregisterModelResponse) ProtoReflect() protoreflect.Message

func (*UnregisterModelResponse) Reset 

func (x *UnregisterModelResponse) Reset()

func (*UnregisterModelResponse) String 

func (x *UnregisterModelResponse) String() string

type UnsafeModelMeshServer 

type UnsafeModelMeshServer interface {
	// contains filtered or unexported methods
}

UnsafeModelMeshServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ModelMeshServer will result in compilation errors.

type VModelStatusInfo 

type VModelStatusInfo struct {
	Status VModelStatusInfo_VModelStatus `protobuf:"varint,1,opt,name=status,proto3,enum=mmesh.VModelStatusInfo_VModelStatus" json:"status,omitempty"`
	// id of underlying model to which apply/prediction
	// requests sent to this vmodel will be routed
	ActiveModelId string `protobuf:"bytes,2,opt,name=activeModelId,proto3" json:"activeModelId,omitempty"`
	// if targetModelId is not equal to activeModelId
	// then the vmodel is in a transitional state (waiting for
	// the target model to be in an appropriate state before
	// it's promoted to be the active model)
	TargetModelId string `protobuf:"bytes,3,opt,name=targetModelId,proto3" json:"targetModelId,omitempty"`
	// status of the currently active model
	ActiveModelStatus *ModelStatusInfo `protobuf:"bytes,4,opt,name=activeModelStatus,proto3" json:"activeModelStatus,omitempty"`
	// status of the target model, set only if targetModelId != activeModelId
	TargetModelStatus *ModelStatusInfo `protobuf:"bytes,5,opt,name=targetModelStatus,proto3" json:"targetModelStatus,omitempty"`
	// the owner of this vmodel, if any
	Owner string `protobuf:"bytes,6,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

func (*VModelStatusInfo) Descriptor deprecated 

func (*VModelStatusInfo) Descriptor() ([]byte, []int)

Deprecated: Use VModelStatusInfo.ProtoReflect.Descriptor instead.

func (*VModelStatusInfo) GetActiveModelId 

func (x *VModelStatusInfo) GetActiveModelId() string

func (*VModelStatusInfo) GetActiveModelStatus 

func (x *VModelStatusInfo) GetActiveModelStatus() *ModelStatusInfo

func (*VModelStatusInfo) GetOwner 

func (x *VModelStatusInfo) GetOwner() string

func (*VModelStatusInfo) GetStatus 

func (x *VModelStatusInfo) GetStatus() VModelStatusInfo_VModelStatus

func (*VModelStatusInfo) GetTargetModelId 

func (x *VModelStatusInfo) GetTargetModelId() string

func (*VModelStatusInfo) GetTargetModelStatus 

func (x *VModelStatusInfo) GetTargetModelStatus() *ModelStatusInfo

func (*VModelStatusInfo) ProtoMessage 

func (*VModelStatusInfo) ProtoMessage()

func (*VModelStatusInfo) ProtoReflect 

func (x *VModelStatusInfo) ProtoReflect() protoreflect.Message

func (*VModelStatusInfo) Reset 

func (x *VModelStatusInfo) Reset()

func (*VModelStatusInfo) String 

func (x *VModelStatusInfo) String() string

type VModelStatusInfo_VModelStatus 

type VModelStatusInfo_VModelStatus int32
const (
	// vmodel is not registered with the cluster
	VModelStatusInfo_NOT_FOUND VModelStatusInfo_VModelStatus = 0
	// vmodel is registered and in a steady-state (activeModelId == targetModelId)
	VModelStatusInfo_DEFINED VModelStatusInfo_VModelStatus = 1
	// vmodel is waiting for a new target model to be ready before
	// transitioning to it (activeModelId != targetModelId)
	VModelStatusInfo_TRANSITIONING VModelStatusInfo_VModelStatus = 2
	// the target model failed to load and so the transition is blocked;
	// will be retried periodically so *may* automatically recover from this state
	VModelStatusInfo_TRANSITION_FAILED VModelStatusInfo_VModelStatus = 3
	VModelStatusInfo_UNKNOWN           VModelStatusInfo_VModelStatus = 5
)

func (VModelStatusInfo_VModelStatus) Descriptor 

func (VModelStatusInfo_VModelStatus) Descriptor() protoreflect.EnumDescriptor

func (VModelStatusInfo_VModelStatus) Enum 

func (x VModelStatusInfo_VModelStatus) Enum() *VModelStatusInfo_VModelStatus

func (VModelStatusInfo_VModelStatus) EnumDescriptor deprecated 

func (VModelStatusInfo_VModelStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use VModelStatusInfo_VModelStatus.Descriptor instead.

func (VModelStatusInfo_VModelStatus) Number 

func (x VModelStatusInfo_VModelStatus) Number() protoreflect.EnumNumber

func (VModelStatusInfo_VModelStatus) String 

func (x VModelStatusInfo_VModelStatus) String() string

func (VModelStatusInfo_VModelStatus) Type 

func (VModelStatusInfo_VModelStatus) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.