v1

package
v0.4.686 Latest Latest
Warning

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

 Go to latest Published: Apr 11, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_metaprov_modelaapi_services_publisherd_v1_publisherd_proto protoreflect.FileDescriptor

Functions

func RegisterPublisherdServiceServer 

func RegisterPublisherdServiceServer(s *grpc.Server, srv PublisherdServiceServer)

Types

type PackageModelRequest 

type PackageModelRequest struct {
	Dataproduct        *v1alpha11.DataProduct        `protobuf:"bytes,1,opt,name=dataproduct,proto3" json:"dataproduct,omitempty"`
	Dataproductversion *v1alpha11.DataProductVersion `protobuf:"bytes,2,opt,name=dataproductversion,proto3" json:"dataproductversion,omitempty"`
	Model              *v1alpha1.Model               `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
	Study              *v1alpha1.Study               `protobuf:"bytes,4,opt,name=study,proto3" json:"study,omitempty"`
	Datasource         *v1alpha11.DataSource         `protobuf:"bytes,5,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset            *v1alpha11.Dataset            `protobuf:"bytes,6,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Bucket             *v1alpha12.VirtualBucket      `protobuf:"bytes,7,opt,name=bucket,proto3" json:"bucket,omitempty"`
	CloudConn          *v1alpha12.Connection         `protobuf:"bytes,8,opt,name=cloudConn,proto3" json:"cloudConn,omitempty"`
	CloudSecret        map[string][]byte             `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PackageModelRequest) Descriptor deprecated 

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

Deprecated: Use PackageModelRequest.ProtoReflect.Descriptor instead.

func (*PackageModelRequest) GetBucket 

func (x *PackageModelRequest) GetBucket() *v1alpha12.VirtualBucket

func (*PackageModelRequest) GetCloudConn 

func (x *PackageModelRequest) GetCloudConn() *v1alpha12.Connection

func (*PackageModelRequest) GetCloudSecret 

func (x *PackageModelRequest) GetCloudSecret() map[string][]byte

func (*PackageModelRequest) GetDataproduct 

func (x *PackageModelRequest) GetDataproduct() *v1alpha11.DataProduct

func (*PackageModelRequest) GetDataproductversion 

func (x *PackageModelRequest) GetDataproductversion() *v1alpha11.DataProductVersion

func (*PackageModelRequest) GetDataset 

func (x *PackageModelRequest) GetDataset() *v1alpha11.Dataset

func (*PackageModelRequest) GetDatasource 

func (x *PackageModelRequest) GetDatasource() *v1alpha11.DataSource

func (*PackageModelRequest) GetModel 

func (x *PackageModelRequest) GetModel() *v1alpha1.Model

func (*PackageModelRequest) GetStudy 

func (x *PackageModelRequest) GetStudy() *v1alpha1.Study

func (*PackageModelRequest) ProtoMessage 

func (*PackageModelRequest) ProtoMessage()

func (*PackageModelRequest) ProtoReflect 

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

func (*PackageModelRequest) Reset 

func (x *PackageModelRequest) Reset()

func (*PackageModelRequest) String 

func (x *PackageModelRequest) String() string

type PackageModelResponse 

type PackageModelResponse struct {
	TarUri string `protobuf:"bytes,1,opt,name=tarUri,proto3" json:"tarUri,omitempty"` // the uri of the tar file
	Hash   string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*PackageModelResponse) Descriptor deprecated 

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

Deprecated: Use PackageModelResponse.ProtoReflect.Descriptor instead.

func (*PackageModelResponse) GetHash 

func (x *PackageModelResponse) GetHash() string

func (*PackageModelResponse) GetTarUri 

func (x *PackageModelResponse) GetTarUri() string

func (*PackageModelResponse) ProtoMessage 

func (*PackageModelResponse) ProtoMessage()

func (*PackageModelResponse) ProtoReflect 

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

func (*PackageModelResponse) Reset 

func (x *PackageModelResponse) Reset()

func (*PackageModelResponse) String 

func (x *PackageModelResponse) String() string

type PublishModelRequest 

type PublishModelRequest struct {
	Dataproduct          *v1alpha11.DataProduct        `protobuf:"bytes,1,opt,name=dataproduct,proto3" json:"dataproduct,omitempty"`
	Dataproductversion   *v1alpha11.DataProductVersion `protobuf:"bytes,2,opt,name=dataproductversion,proto3" json:"dataproductversion,omitempty"`
	Model                *v1alpha1.Model               `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
	Study                *v1alpha1.Study               `protobuf:"bytes,4,opt,name=study,proto3" json:"study,omitempty"`
	Datasource           *v1alpha11.DataSource         `protobuf:"bytes,5,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset              *v1alpha11.Dataset            `protobuf:"bytes,6,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Provider             string                        `protobuf:"bytes,7,opt,name=provider,proto3" json:"provider,omitempty"` // the image registry provider
	Imagename            string                        `protobuf:"bytes,8,opt,name=imagename,proto3" json:"imagename,omitempty"`
	ImagenameWithVersion string                        `protobuf:"bytes,9,opt,name=imagenameWithVersion,proto3" json:"imagenameWithVersion,omitempty"`
	Push                 bool                          `protobuf:"varint,10,opt,name=push,proto3" json:"push,omitempty"`
	Bucket               *v1alpha12.VirtualBucket      `protobuf:"bytes,11,opt,name=bucket,proto3" json:"bucket,omitempty"`
	CloudConn            *v1alpha12.Connection         `protobuf:"bytes,12,opt,name=cloudConn,proto3" json:"cloudConn,omitempty"`
	CloudSecret          map[string][]byte             `` // the image registry login details.
	/* 164-byte string literal not displayed */
	DockerConnection     *v1alpha12.Connection `protobuf:"bytes,14,opt,name=dockerConnection,proto3" json:"dockerConnection,omitempty"`
	DockerRegistrySecret map[string][]byte     `` // the image registry login details.
	/* 182-byte string literal not displayed */
	Kaniko bool `protobuf:"varint,19,opt,name=kaniko,proto3" json:"kaniko,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishModelRequest) Descriptor deprecated 

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

Deprecated: Use PublishModelRequest.ProtoReflect.Descriptor instead.

func (*PublishModelRequest) GetBucket 

func (x *PublishModelRequest) GetBucket() *v1alpha12.VirtualBucket

func (*PublishModelRequest) GetCloudConn 

func (x *PublishModelRequest) GetCloudConn() *v1alpha12.Connection

func (*PublishModelRequest) GetCloudSecret 

func (x *PublishModelRequest) GetCloudSecret() map[string][]byte

func (*PublishModelRequest) GetDataproduct 

func (x *PublishModelRequest) GetDataproduct() *v1alpha11.DataProduct

func (*PublishModelRequest) GetDataproductversion 

func (x *PublishModelRequest) GetDataproductversion() *v1alpha11.DataProductVersion

func (*PublishModelRequest) GetDataset 

func (x *PublishModelRequest) GetDataset() *v1alpha11.Dataset

func (*PublishModelRequest) GetDatasource 

func (x *PublishModelRequest) GetDatasource() *v1alpha11.DataSource

func (*PublishModelRequest) GetDockerConnection 

func (x *PublishModelRequest) GetDockerConnection() *v1alpha12.Connection

func (*PublishModelRequest) GetDockerRegistrySecret 

func (x *PublishModelRequest) GetDockerRegistrySecret() map[string][]byte

func (*PublishModelRequest) GetImagename 

func (x *PublishModelRequest) GetImagename() string

func (*PublishModelRequest) GetImagenameWithVersion 

func (x *PublishModelRequest) GetImagenameWithVersion() string

func (*PublishModelRequest) GetKaniko 

func (x *PublishModelRequest) GetKaniko() bool

func (*PublishModelRequest) GetModel 

func (x *PublishModelRequest) GetModel() *v1alpha1.Model

func (*PublishModelRequest) GetProvider 

func (x *PublishModelRequest) GetProvider() string

func (*PublishModelRequest) GetPush 

func (x *PublishModelRequest) GetPush() bool

func (*PublishModelRequest) GetStudy 

func (x *PublishModelRequest) GetStudy() *v1alpha1.Study

func (*PublishModelRequest) ProtoMessage 

func (*PublishModelRequest) ProtoMessage()

func (*PublishModelRequest) ProtoReflect 

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

func (*PublishModelRequest) Reset 

func (x *PublishModelRequest) Reset()

func (*PublishModelRequest) String 

func (x *PublishModelRequest) String() string

type PublishModelResponse 

type PublishModelResponse struct {
	ImageName string `protobuf:"bytes,1,opt,name=ImageName,proto3" json:"ImageName,omitempty"`
	Hash      string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishModelResponse) Descriptor deprecated 

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

Deprecated: Use PublishModelResponse.ProtoReflect.Descriptor instead.

func (*PublishModelResponse) GetHash 

func (x *PublishModelResponse) GetHash() string

func (*PublishModelResponse) GetImageName 

func (x *PublishModelResponse) GetImageName() string

func (*PublishModelResponse) ProtoMessage 

func (*PublishModelResponse) ProtoMessage()

func (*PublishModelResponse) ProtoReflect 

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

func (*PublishModelResponse) Reset 

func (x *PublishModelResponse) Reset()

func (*PublishModelResponse) String 

func (x *PublishModelResponse) String() string

type PublishNotebookRequest 

type PublishNotebookRequest struct {
	NotebookName      string                 `protobuf:"bytes,1,opt,name=notebookName,proto3" json:"notebookName,omitempty"`
	NotebookNamespace string                 `protobuf:"bytes,2,opt,name=notebookNamespace,proto3" json:"notebookNamespace,omitempty"`
	NotebookSpec      *v1alpha1.NotebookSpec `protobuf:"bytes,3,opt,name=notebookSpec,proto3" json:"notebookSpec,omitempty"`
	NotebookContent   string                 `protobuf:"bytes,4,opt,name=NotebookContent,proto3" json:"NotebookContent,omitempty"`
	Dockerfile        string                 `protobuf:"bytes,5,opt,name=Dockerfile,proto3" json:"Dockerfile,omitempty"`
	Provider          string                 `protobuf:"bytes,6,opt,name=provider,proto3" json:"provider,omitempty"` // the image registry provider
	Secret            map[string][]byte      ``                                                                      // the image registry login details
	/* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PublishNotebookRequest) Descriptor deprecated 

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

Deprecated: Use PublishNotebookRequest.ProtoReflect.Descriptor instead.

func (*PublishNotebookRequest) GetDockerfile 

func (x *PublishNotebookRequest) GetDockerfile() string

func (*PublishNotebookRequest) GetNotebookContent 

func (x *PublishNotebookRequest) GetNotebookContent() string

func (*PublishNotebookRequest) GetNotebookName 

func (x *PublishNotebookRequest) GetNotebookName() string

func (*PublishNotebookRequest) GetNotebookNamespace 

func (x *PublishNotebookRequest) GetNotebookNamespace() string

func (*PublishNotebookRequest) GetNotebookSpec 

func (x *PublishNotebookRequest) GetNotebookSpec() *v1alpha1.NotebookSpec

func (*PublishNotebookRequest) GetProvider 

func (x *PublishNotebookRequest) GetProvider() string

func (*PublishNotebookRequest) GetSecret 

func (x *PublishNotebookRequest) GetSecret() map[string][]byte

func (*PublishNotebookRequest) ProtoMessage 

func (*PublishNotebookRequest) ProtoMessage()

func (*PublishNotebookRequest) ProtoReflect 

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

func (*PublishNotebookRequest) Reset 

func (x *PublishNotebookRequest) Reset()

func (*PublishNotebookRequest) String 

func (x *PublishNotebookRequest) String() string

type PublishNotebookResponse 

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

func (*PublishNotebookResponse) Descriptor deprecated 

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

Deprecated: Use PublishNotebookResponse.ProtoReflect.Descriptor instead.

func (*PublishNotebookResponse) GetImageName 

func (x *PublishNotebookResponse) GetImageName() string

func (*PublishNotebookResponse) ProtoMessage 

func (*PublishNotebookResponse) ProtoMessage()

func (*PublishNotebookResponse) ProtoReflect 

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

func (*PublishNotebookResponse) Reset 

func (x *PublishNotebookResponse) Reset()

func (*PublishNotebookResponse) String 

func (x *PublishNotebookResponse) String() string

type PublisherdServiceClient 

type PublisherdServiceClient interface {
	// publish tar file including the reports
	PackageModel(ctx context.Context, in *PackageModelRequest, opts ...grpc.CallOption) (*PackageModelResponse, error)
	PublishModel(ctx context.Context, in *PublishModelRequest, opts ...grpc.CallOption) (*PublishModelResponse, error)
	// Publish a notebook.
	PublishNotebook(ctx context.Context, in *PublishNotebookRequest, opts ...grpc.CallOption) (*PublishNotebookResponse, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
}

PublisherdServiceClient is the client API for PublisherdService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPublisherdServiceClient 

func NewPublisherdServiceClient(cc grpc.ClientConnInterface) PublisherdServiceClient

type PublisherdServiceServer 

type PublisherdServiceServer interface {
	// publish tar file including the reports
	PackageModel(context.Context, *PackageModelRequest) (*PackageModelResponse, error)
	PublishModel(context.Context, *PublishModelRequest) (*PublishModelResponse, error)
	// Publish a notebook.
	PublishNotebook(context.Context, *PublishNotebookRequest) (*PublishNotebookResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
}

PublisherdServiceServer is the server API for PublisherdService service.

type ShutdownRequest 

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

func (*ShutdownRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

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

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

type ShutdownResponse 

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

func (*ShutdownResponse) Descriptor deprecated 

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

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect 

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

func (*ShutdownResponse) Reset 

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) String 

func (x *ShutdownResponse) String() string

type UnimplementedPublisherdServiceServer 

type UnimplementedPublisherdServiceServer struct {
}

UnimplementedPublisherdServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPublisherdServiceServer) PackageModel 

func (*UnimplementedPublisherdServiceServer) PackageModel(context.Context, *PackageModelRequest) (*PackageModelResponse, error)

func (*UnimplementedPublisherdServiceServer) PublishModel 

func (*UnimplementedPublisherdServiceServer) PublishModel(context.Context, *PublishModelRequest) (*PublishModelResponse, error)

func (*UnimplementedPublisherdServiceServer) PublishNotebook 

func (*UnimplementedPublisherdServiceServer) PublishNotebook(context.Context, *PublishNotebookRequest) (*PublishNotebookResponse, error)

func (*UnimplementedPublisherdServiceServer) Shutdown 

func (*UnimplementedPublisherdServiceServer) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)

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.