proto_gen

type AddRemoveTagRequest struct {
	Fqn         *FullyQualifiedName `protobuf:"bytes,1,opt,name=fqn,proto3" json:"fqn,omitempty"`
	VersionHash string              `protobuf:"bytes,2,opt,name=versionHash,proto3" json:"versionHash,omitempty"`
	Tag         string              `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

type Artifact struct {
	Fqn         *FullyQualifiedName `protobuf:"bytes,1,opt,name=fqn,proto3" json:"fqn,omitempty"`
	VersionHash string              `protobuf:"bytes,2,opt,name=versionHash,proto3" json:"versionHash,omitempty"`
	Tags        []string            `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Metadata    *MetaData           `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type ArtifactContent struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type ArtifactIdentifier struct {
	Fqn *FullyQualifiedName `protobuf:"bytes,1,opt,name=fqn,proto3" json:"fqn,omitempty"`
	// Types that are valid to be assigned to Identifier:
	//
	//	*ArtifactIdentifier_VersionHash
	//	*ArtifactIdentifier_Tag
	Identifier isArtifactIdentifier_Identifier `protobuf_oneof:"identifier"`
	// contains filtered or unexported fields
}

type ArtifactIdentifier_Tag struct {
	Tag string `protobuf:"bytes,3,opt,name=tag,proto3,oneof"`
}

type ArtifactIdentifier_VersionHash struct {
	VersionHash string `protobuf:"bytes,2,opt,name=versionHash,proto3,oneof"`
}

type ArtifactListResponse struct {
	Artifacts []*Artifact `protobuf:"bytes,1,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
	// contains filtered or unexported fields
}

type ArtifactQuery struct {
	Source *string `protobuf:"bytes,1,opt,name=source,proto3,oneof" json:"source,omitempty"`
	Author *string `protobuf:"bytes,2,opt,name=author,proto3,oneof" json:"author,omitempty"`
	Name   *string `protobuf:"bytes,3,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type FullyQualifiedName struct {
	Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Author string `protobuf:"bytes,2,opt,name=author,proto3" json:"author,omitempty"`
	Name   string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type MetaData struct {
	Created *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created,proto3" json:"created,omitempty"`
	Pulls   int64                  `protobuf:"varint,2,opt,name=pulls,proto3" json:"pulls,omitempty"`
	// contains filtered or unexported fields
}

type RegistryServiceClient interface {
	QueryArtifacts(ctx context.Context, in *ArtifactQuery, opts ...grpc.CallOption) (*ArtifactListResponse, error)
	PullArtifact(ctx context.Context, in *ArtifactIdentifier, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ArtifactContent], error)
	UploadArtifact(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[UploadArtifactRequest, Artifact], error)
	DeleteArtifact(ctx context.Context, in *ArtifactIdentifier, opts ...grpc.CallOption) (*Artifact, error)
	GetArtifact(ctx context.Context, in *ArtifactIdentifier, opts ...grpc.CallOption) (*Artifact, error)
	AddTag(ctx context.Context, in *AddRemoveTagRequest, opts ...grpc.CallOption) (*Artifact, error)
	RemoveTag(ctx context.Context, in *AddRemoveTagRequest, opts ...grpc.CallOption) (*Artifact, error)
}

type RegistryServiceServer interface {
	QueryArtifacts(context.Context, *ArtifactQuery) (*ArtifactListResponse, error)
	PullArtifact(*ArtifactIdentifier, grpc.ServerStreamingServer[ArtifactContent]) error
	UploadArtifact(grpc.ClientStreamingServer[UploadArtifactRequest, Artifact]) error
	DeleteArtifact(context.Context, *ArtifactIdentifier) (*Artifact, error)
	GetArtifact(context.Context, *ArtifactIdentifier) (*Artifact, error)
	AddTag(context.Context, *AddRemoveTagRequest) (*Artifact, error)
	RemoveTag(context.Context, *AddRemoveTagRequest) (*Artifact, error)
	// contains filtered or unexported methods
}

type RegistryService_PullArtifactClient = grpc.ServerStreamingClient[ArtifactContent]

type RegistryService_PullArtifactServer = grpc.ServerStreamingServer[ArtifactContent]

type RegistryService_UploadArtifactClient = grpc.ClientStreamingClient[UploadArtifactRequest, Artifact]

type RegistryService_UploadArtifactServer = grpc.ClientStreamingServer[UploadArtifactRequest, Artifact]

type Task struct {
	Artifact *ArtifactIdentifier `protobuf:"bytes,1,opt,name=artifact,proto3" json:"artifact,omitempty"`
	Function string              `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"`
	Input    []byte              `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedRegistryServiceServer struct{}

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

type UploadArtifactRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*UploadArtifactRequest_Metadata
	//	*UploadArtifactRequest_Content
	Request isUploadArtifactRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type UploadArtifactRequest_Content struct {
	Content *ArtifactContent `protobuf:"bytes,2,opt,name=content,proto3,oneof"`
}

type UploadArtifactRequest_Metadata struct {
	Metadata *UploadMetadata `protobuf:"bytes,1,opt,name=metadata,proto3,oneof"`
}

type UploadMetadata struct {
	Fqn  *FullyQualifiedName `protobuf:"bytes,1,opt,name=fqn,proto3" json:"fqn,omitempty"`
	Tags []string            `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}