Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

proto_gen

package

Go to main page

Versions in this module

v0

v0.2.0

Feb 23, 2026

Changes in this version

type Task

+ TaskId string

+ func (x *Task) GetTaskId() string

v0.1.3

Feb 6, 2026

v0.1.2

Feb 6, 2026

v0.1.1

Nov 27, 2025

v0.1.0

Nov 19, 2025

Changes in this version

+ const RegistryService_AddTag_FullMethodName

+ const RegistryService_DeleteArtifact_FullMethodName

+ const RegistryService_GetArtifact_FullMethodName

+ const RegistryService_PullArtifact_FullMethodName

+ const RegistryService_QueryArtifacts_FullMethodName

+ const RegistryService_RemoveTag_FullMethodName

+ const RegistryService_UploadArtifact_FullMethodName

+ var File_registry_proto protoreflect.FileDescriptor

+ var File_task_proto protoreflect.FileDescriptor

+ var RegistryService_ServiceDesc = grpc.ServiceDesc

+ func RegisterRegistryServiceServer(s grpc.ServiceRegistrar, srv RegistryServiceServer)

+ type AddRemoveTagRequest struct

+ Fqn *FullyQualifiedName

+ Tag string

+ VersionHash string

+ func (*AddRemoveTagRequest) Descriptor() ([]byte, []int)

+ func (*AddRemoveTagRequest) ProtoMessage()

+ func (x *AddRemoveTagRequest) GetFqn() *FullyQualifiedName

+ func (x *AddRemoveTagRequest) GetTag() string

+ func (x *AddRemoveTagRequest) GetVersionHash() string

+ func (x *AddRemoveTagRequest) ProtoReflect() protoreflect.Message

+ func (x *AddRemoveTagRequest) Reset()

+ func (x *AddRemoveTagRequest) String() string

+ type Artifact struct

+ Fqn *FullyQualifiedName

+ Metadata *MetaData

+ Tags []string

+ VersionHash string

+ func (*Artifact) Descriptor() ([]byte, []int)

+ func (*Artifact) ProtoMessage()

+ func (x *Artifact) GetFqn() *FullyQualifiedName

+ func (x *Artifact) GetMetadata() *MetaData

+ func (x *Artifact) GetTags() []string

+ func (x *Artifact) GetVersionHash() string

+ func (x *Artifact) ProtoReflect() protoreflect.Message

+ func (x *Artifact) Reset()

+ func (x *Artifact) String() string

+ type ArtifactContent struct

+ Data []byte

+ func (*ArtifactContent) Descriptor() ([]byte, []int)

+ func (*ArtifactContent) ProtoMessage()

+ func (x *ArtifactContent) GetData() []byte

+ func (x *ArtifactContent) ProtoReflect() protoreflect.Message

+ func (x *ArtifactContent) Reset()

+ func (x *ArtifactContent) String() string

+ type ArtifactIdentifier struct

+ Fqn *FullyQualifiedName

+ Identifier isArtifactIdentifier_Identifier

+ func (*ArtifactIdentifier) Descriptor() ([]byte, []int)

+ func (*ArtifactIdentifier) ProtoMessage()

+ func (x *ArtifactIdentifier) GetFqn() *FullyQualifiedName

+ func (x *ArtifactIdentifier) GetIdentifier() isArtifactIdentifier_Identifier

+ func (x *ArtifactIdentifier) GetTag() string

+ func (x *ArtifactIdentifier) GetVersionHash() string

+ func (x *ArtifactIdentifier) ProtoReflect() protoreflect.Message

+ func (x *ArtifactIdentifier) Reset()

+ func (x *ArtifactIdentifier) String() string

+ type ArtifactIdentifier_Tag struct

+ Tag string

+ type ArtifactIdentifier_VersionHash struct

+ VersionHash string

+ type ArtifactListResponse struct

+ Artifacts []*Artifact

+ func (*ArtifactListResponse) Descriptor() ([]byte, []int)

+ func (*ArtifactListResponse) ProtoMessage()

+ func (x *ArtifactListResponse) GetArtifacts() []*Artifact

+ func (x *ArtifactListResponse) ProtoReflect() protoreflect.Message

+ func (x *ArtifactListResponse) Reset()

+ func (x *ArtifactListResponse) String() string

+ type ArtifactQuery struct

+ Author *string

+ Name *string

+ Source *string

+ func (*ArtifactQuery) Descriptor() ([]byte, []int)

+ func (*ArtifactQuery) ProtoMessage()

+ func (x *ArtifactQuery) GetAuthor() string

+ func (x *ArtifactQuery) GetName() string

+ func (x *ArtifactQuery) GetSource() string

+ func (x *ArtifactQuery) ProtoReflect() protoreflect.Message

+ func (x *ArtifactQuery) Reset()

+ func (x *ArtifactQuery) String() string

+ type FullyQualifiedName struct

+ Author string

+ Name string

+ Source string

+ func (*FullyQualifiedName) Descriptor() ([]byte, []int)

+ func (*FullyQualifiedName) ProtoMessage()

+ func (x *FullyQualifiedName) GetAuthor() string

+ func (x *FullyQualifiedName) GetName() string

+ func (x *FullyQualifiedName) GetSource() string

+ func (x *FullyQualifiedName) ProtoReflect() protoreflect.Message

+ func (x *FullyQualifiedName) Reset()

+ func (x *FullyQualifiedName) String() string

+ type MetaData struct

+ Created *timestamppb.Timestamp

+ Pulls int64

+ func (*MetaData) Descriptor() ([]byte, []int)

+ func (*MetaData) ProtoMessage()

+ func (x *MetaData) GetCreated() *timestamppb.Timestamp

+ func (x *MetaData) GetPulls() int64

+ func (x *MetaData) ProtoReflect() protoreflect.Message

+ func (x *MetaData) Reset()

+ func (x *MetaData) String() string

+ type RegistryServiceClient interface

+ AddTag func(ctx context.Context, in *AddRemoveTagRequest, opts ...grpc.CallOption) (*Artifact, error)

+ DeleteArtifact func(ctx context.Context, in *ArtifactIdentifier, opts ...grpc.CallOption) (*Artifact, error)

+ GetArtifact func(ctx context.Context, in *ArtifactIdentifier, opts ...grpc.CallOption) (*Artifact, error)

+ PullArtifact func(ctx context.Context, in *ArtifactIdentifier, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ArtifactContent], error)

+ QueryArtifacts func(ctx context.Context, in *ArtifactQuery, opts ...grpc.CallOption) (*ArtifactListResponse, error)

+ RemoveTag func(ctx context.Context, in *AddRemoveTagRequest, opts ...grpc.CallOption) (*Artifact, error)

+ UploadArtifact func(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[UploadArtifactRequest, Artifact], error)

+ func NewRegistryServiceClient(cc grpc.ClientConnInterface) RegistryServiceClient

+ type RegistryServiceServer interface

+ AddTag func(context.Context, *AddRemoveTagRequest) (*Artifact, error)

+ DeleteArtifact func(context.Context, *ArtifactIdentifier) (*Artifact, error)

+ GetArtifact func(context.Context, *ArtifactIdentifier) (*Artifact, error)

+ PullArtifact func(*ArtifactIdentifier, grpc.ServerStreamingServer[ArtifactContent]) error

+ QueryArtifacts func(context.Context, *ArtifactQuery) (*ArtifactListResponse, error)

+ RemoveTag func(context.Context, *AddRemoveTagRequest) (*Artifact, error)

+ UploadArtifact func(grpc.ClientStreamingServer[UploadArtifactRequest, Artifact]) error

+ 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

+ Function string

+ Input []byte

+ func (*Task) Descriptor() ([]byte, []int)

+ func (*Task) ProtoMessage()

+ func (x *Task) GetArtifact() *ArtifactIdentifier

+ func (x *Task) GetFunction() string

+ func (x *Task) GetInput() []byte

+ func (x *Task) ProtoReflect() protoreflect.Message

+ func (x *Task) Reset()

+ func (x *Task) String() string

+ type UnimplementedRegistryServiceServer struct

+ func (UnimplementedRegistryServiceServer) AddTag(context.Context, *AddRemoveTagRequest) (*Artifact, error)

+ func (UnimplementedRegistryServiceServer) DeleteArtifact(context.Context, *ArtifactIdentifier) (*Artifact, error)

+ func (UnimplementedRegistryServiceServer) GetArtifact(context.Context, *ArtifactIdentifier) (*Artifact, error)

+ func (UnimplementedRegistryServiceServer) PullArtifact(*ArtifactIdentifier, grpc.ServerStreamingServer[ArtifactContent]) error

+ func (UnimplementedRegistryServiceServer) QueryArtifacts(context.Context, *ArtifactQuery) (*ArtifactListResponse, error)

+ func (UnimplementedRegistryServiceServer) RemoveTag(context.Context, *AddRemoveTagRequest) (*Artifact, error)

+ func (UnimplementedRegistryServiceServer) UploadArtifact(grpc.ClientStreamingServer[UploadArtifactRequest, Artifact]) error

+ type UnsafeRegistryServiceServer interface

+ type UploadArtifactRequest struct

+ Request isUploadArtifactRequest_Request

+ func (*UploadArtifactRequest) Descriptor() ([]byte, []int)

+ func (*UploadArtifactRequest) ProtoMessage()

+ func (x *UploadArtifactRequest) GetContent() *ArtifactContent

+ func (x *UploadArtifactRequest) GetMetadata() *UploadMetadata

+ func (x *UploadArtifactRequest) GetRequest() isUploadArtifactRequest_Request

+ func (x *UploadArtifactRequest) ProtoReflect() protoreflect.Message

+ func (x *UploadArtifactRequest) Reset()

+ func (x *UploadArtifactRequest) String() string

+ type UploadArtifactRequest_Content struct

+ Content *ArtifactContent

+ type UploadArtifactRequest_Metadata struct

+ Metadata *UploadMetadata

+ type UploadMetadata struct

+ Fqn *FullyQualifiedName

+ Tags []string

+ func (*UploadMetadata) Descriptor() ([]byte, []int)

+ func (*UploadMetadata) ProtoMessage()

+ func (x *UploadMetadata) GetFqn() *FullyQualifiedName

+ func (x *UploadMetadata) GetTags() []string

+ func (x *UploadMetadata) ProtoReflect() protoreflect.Message

+ func (x *UploadMetadata) Reset()

+ func (x *UploadMetadata) String() string