server

package

v0.2.0 Latest Latest Go to latest Published: Apr 11, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type IS struct {
	v1.UnimplementedModelsInternalServiceServer
	// contains filtered or unexported fields
}

IS is an internal server.

func NewInternal(store *store.S, pathPrefix string) *IS

NewInternal creates an internal server.

func (s *IS) PublishModel(
	ctx context.Context,
	req *v1.PublishModelRequest,
) (*v1.PublishModelResponse, error)

PublishModel publishes a model.

func (s *IS) RegisterModel(
	ctx context.Context,
	req *v1.RegisterModelRequest,
) (*v1.RegisterModelResponse, error)

RegisterModel registers a model.

func (s *IS) Run(port int) error

Run starts the gRPC server.

type S struct {
	v1.UnimplementedModelsServiceServer
	// contains filtered or unexported fields
}

S is a server.

func New(store *store.S) *S

New creates a server.

func (s *S) DeleteModel(
	ctx context.Context,
	req *v1.DeleteModelRequest,
) (*v1.DeleteModelResponse, error)

DeleteModel deletes a model.

func (s *S) GetModel(
	ctx context.Context,
	req *v1.GetModelRequest,
) (*v1.Model, error)

GetModel gets a model.

func (s *S) ListModels(
	ctx context.Context,
	req *v1.ListModelsRequest,
) (*v1.ListModelsResponse, error)

ListModels lists models.

func (s *S) Run(port int) error

Run starts the gRPC server.

func (s *S) Stop()

Stop stops the gRPC server.