grpcservice

package

v0.1.3 Latest Latest Go to latest Published: May 6, 2026 License: GPL-3.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/zeddo123/mlsolid

Links

Open Source Insights

Documentation ¶

Overview ¶

Package grpcservice implements the grpc server methods

Index ¶

func NewRunsResponse(runs []*types.Run) *mlsolidv1.RunsResponse
func ParseError(err error) error
func ParseMetric(m types.Metric) *mlsolidv1.Metric
func ParseMetrics(m map[string]types.Metric) map[string]*mlsolidv1.Metric
func StartServer(port string, ctrl *controllers.Controller, authEnabled bool)
type Service

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewRunsResponse ¶

func NewRunsResponse(runs []*types.Run) *mlsolidv1.RunsResponse

func ParseError ¶

func ParseError(err error) error

func ParseMetric ¶

func ParseMetric(m types.Metric) *mlsolidv1.Metric

func ParseMetrics ¶

func ParseMetrics(m map[string]types.Metric) map[string]*mlsolidv1.Metric

func StartServer ¶

func StartServer(port string, ctrl *controllers.Controller, authEnabled bool)

StartServer starts a grpc server instance.

Types ¶

type Service ¶

type Service struct {
	mlsolidv1grpc.UnimplementedMlsolidServiceServer

	Controller *controllers.Controller
}

Service implementation of mlsolid grpc server.

func (*Service) AddArtifact ¶

func (s *Service) AddArtifact(stream mlsolidv1grpc.MlsolidService_AddArtifactServer) error

func (*Service) AddMetrics ¶

func (s *Service) AddMetrics(ctx context.Context,
	req *mlsolidv1.AddMetricsRequest,
) (*mlsolidv1.AddMetricsResponse, error)

func (*Service) AddModelEntry ¶

func (s *Service) AddModelEntry(ctx context.Context,
	req *mlsolidv1.AddModelEntryRequest,
) (*mlsolidv1.AddModelEntryResponse, error)

func (*Service) Artifact ¶

func (s *Service) Artifact(req *mlsolidv1.ArtifactRequest, stream mlsolidv1grpc.MlsolidService_ArtifactServer) error

func (*Service) Benchmark ¶ added in v0.1.3

func (s *Service) Benchmark(ctx context.Context,
	req *mlsolidv1.BenchmarkRequest,
) (*mlsolidv1.BenchmarkResponse, error)

Benchmark pull a benchmark by its id.

func (*Service) BenchmarkRuns ¶ added in v0.1.3

func (s *Service) BenchmarkRuns(ctx context.Context,
	req *mlsolidv1.BenchmarkRunsRequest,
) (*mlsolidv1.BenchmarkRunsResponse, error)

BenchmarkRuns rpc method.

func (*Service) Benchmarks ¶ added in v0.1.3

func (s *Service) Benchmarks(ctx context.Context, req *mlsolidv1.BenchmarksRequest) (*mlsolidv1.BenchmarksResponse, error)

Benchmarks returns a list of benchmark ids.

func (*Service) BestModel ¶ added in v0.1.3

func (s *Service) BestModel(ctx context.Context,
	req *mlsolidv1.BestModelRequest,
) (*mlsolidv1.BestModelResponse, error)

BestModel rpc method.

func (*Service) CreateBenchmark ¶ added in v0.1.3

func (s *Service) CreateBenchmark(ctx context.Context, req *mlsolidv1.CreateBenchmarkRequest) (*mlsolidv1.CreateBenchmarkResponse, error)

CreateBenchmark grpc method to create a new benchmark.

func (*Service) CreateModelRegistry ¶

func (s *Service) CreateModelRegistry(ctx context.Context,
	req *mlsolidv1.CreateModelRegistryRequest,
) (*mlsolidv1.CreateModelRegistryResponse, error)

func (*Service) CreateRun ¶

func (s *Service) CreateRun(ctx context.Context,
	req *mlsolidv1.CreateRunRequest,
) (*mlsolidv1.CreateRunResponse, error)

func (*Service) DeleteBenchmark ¶ added in v0.1.3

func (s *Service) DeleteBenchmark(_ context.Context, _ *mlsolidv1.DeleteBenchmarkRequest) (*mlsolidv1.DeleteBenchmarkResponse, error)

DeleteBenchmark rpc method.

func (*Service) Experiment ¶

func (s *Service) Experiment(ctx context.Context,
	req *mlsolidv1.ExperimentRequest,
) (*mlsolidv1.ExperimentResponse, error)

func (*Service) Experiments ¶

func (s *Service) Experiments(ctx context.Context,
	_ *mlsolidv1.ExperimentsRequest,
) (*mlsolidv1.ExperimentsResponse, error)

func (*Service) ModelRegistry ¶

func (s *Service) ModelRegistry(ctx context.Context,
	req *mlsolidv1.ModelRegistryRequest,
) (*mlsolidv1.ModelRegistryResponse, error)

func (*Service) Run ¶

func (s *Service) Run(ctx context.Context, req *mlsolidv1.RunRequest) (*mlsolidv1.RunResponse, error)

func (*Service) Runs ¶

func (s *Service) Runs(ctx context.Context, req *mlsolidv1.RunsRequest) (*mlsolidv1.RunsResponse, error)

func (*Service) SetBenchmarkContainer ¶ added in v0.1.3

func (s *Service) SetBenchmarkContainer(ctx context.Context, req *mlsolidv1.SetBenchmarkContainerRequest) (*mlsolidv1.SetBenchmarkContainerResponse, error)

SetBenchmarkContainer sets the benchmark container of a registry.

func (*Service) StreamTaggedModel ¶

func (s *Service) StreamTaggedModel(req *mlsolidv1.StreamTaggedModelRequest,
	stream mlsolidv1grpc.MlsolidService_StreamTaggedModelServer,
) error

func (*Service) TagModel ¶

func (s *Service) TagModel(ctx context.Context, req *mlsolidv1.TagModelRequest) (*mlsolidv1.TagModelResponse, error)

func (*Service) TaggedModel ¶

func (s *Service) TaggedModel(ctx context.Context, req *mlsolidv1.TaggedModelRequest) (*mlsolidv1.TaggedModelResponse,
	error,
)

func (*Service) ToggleBenchmark ¶ added in v0.1.3

func (s *Service) ToggleBenchmark(ctx context.Context, req *mlsolidv1.ToggleBenchmarkRequest) (*mlsolidv1.ToggleBenchmarkResponse, error)

ToggleBenchmark toogles a benchmark's pause state.

func (*Service) UpdateBenchmark ¶ added in v0.1.3

func (s *Service) UpdateBenchmark(ctx context.Context, req *mlsolidv1.UpdateBenchmarkRequest) (*mlsolidv1.UpdateBenchmarkResponse, error)

UpdateBenchmark updates an existent benchmark.

Source Files ¶

View all Source files

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