mothershippb

package
v0.0.0-...-483e9f6 Latest Latest
Warning

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

 Go to latest Published: May 3, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package mothershippb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	Entry_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "ARCHIVING",
		2: "ARCHIVED",
		3: "ON_HOLD",
		4: "CANCELLED",
		5: "FAILED",
		6: "RETRACTING",
		7: "RETRACTED",
	}
	Entry_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"ARCHIVING":         1,
		"ARCHIVED":          2,
		"ON_HOLD":           3,
		"CANCELLED":         4,
		"FAILED":            5,
		"RETRACTING":        6,
		"RETRACTED":         7,
	}
)

Enum value maps for Entry_State.

View Source 
var File_proto_v1_batch_proto protoreflect.FileDescriptor
View Source 
var File_proto_v1_entry_proto protoreflect.FileDescriptor
View Source 
var File_proto_v1_process_rpm_proto protoreflect.FileDescriptor
View Source 
var File_proto_v1_srpm_archiver_proto protoreflect.FileDescriptor
View Source 
var SrpmArchiver_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mothership.v1.SrpmArchiver",
	HandlerType: (*SrpmArchiverServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetBatch",
			Handler:    _SrpmArchiver_GetBatch_Handler,
		},
		{
			MethodName: "ListBatches",
			Handler:    _SrpmArchiver_ListBatches_Handler,
		},
		{
			MethodName: "CreateBatch",
			Handler:    _SrpmArchiver_CreateBatch_Handler,
		},
		{
			MethodName: "SealBatch",
			Handler:    _SrpmArchiver_SealBatch_Handler,
		},
		{
			MethodName: "GetEntry",
			Handler:    _SrpmArchiver_GetEntry_Handler,
		},
		{
			MethodName: "ListEntries",
			Handler:    _SrpmArchiver_ListEntries_Handler,
		},
		{
			MethodName: "SubmitEntry",
			Handler:    _SrpmArchiver_SubmitEntry_Handler,
		},
		{
			MethodName: "WorkerPing",
			Handler:    _SrpmArchiver_WorkerPing_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WorkerUploadObject",
			Handler:       _SrpmArchiver_WorkerUploadObject_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "proto/v1/srpm_archiver.proto",
}

SrpmArchiver_ServiceDesc is the grpc.ServiceDesc for SrpmArchiver service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterSrpmArchiverHandler 

func RegisterSrpmArchiverHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterSrpmArchiverHandler registers the http handlers for service SrpmArchiver to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterSrpmArchiverHandlerClient 

func RegisterSrpmArchiverHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SrpmArchiverClient) error

RegisterSrpmArchiverHandlerClient registers the http handlers for service SrpmArchiver to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SrpmArchiverClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SrpmArchiverClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "SrpmArchiverClient" to call the correct interceptors.

func RegisterSrpmArchiverHandlerFromEndpoint 

func RegisterSrpmArchiverHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterSrpmArchiverHandlerFromEndpoint is same as RegisterSrpmArchiverHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterSrpmArchiverHandlerServer 

func RegisterSrpmArchiverHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SrpmArchiverServer) error

RegisterSrpmArchiverHandlerServer registers the http handlers for service SrpmArchiver to "mux". UnaryRPC :call SrpmArchiverServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterSrpmArchiverHandlerFromEndpoint instead.

func RegisterSrpmArchiverServer 

func RegisterSrpmArchiverServer(s grpc.ServiceRegistrar, srv SrpmArchiverServer)

Types

type Batch 

type Batch struct {

	// Output only. Unique ID of the batch.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Custom ID of the batch. Optional
	BatchId string `protobuf:"bytes,2,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	// Worker ID that created the batch.
	WorkerId string `protobuf:"bytes,3,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// Output only. Timestamp when the batch was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. Timestamp when the batch was last updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Output only. Timestamp when the batch was sealed.
	// Batches are automatically sealed after an hour of inactivity.
	SealTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=seal_time,json=sealTime,proto3" json:"seal_time,omitempty"`
	// Output only. Bugtracker URI of the batch.
	BugtrackerUri *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=bugtracker_uri,json=bugtrackerUri,proto3" json:"bugtracker_uri,omitempty"`
	// Output only. Entry count of the batch.
	EntryCount int32 `protobuf:"varint,8,opt,name=entry_count,json=entryCount,proto3" json:"entry_count,omitempty"`
	// contains filtered or unexported fields
}

Batch is a collection of Entries that were imported closely together. It usually indicates an update batch from a single source.

func (*Batch) Descriptor deprecated 

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

Deprecated: Use Batch.ProtoReflect.Descriptor instead.

func (*Batch) GetBatchId 

func (x *Batch) GetBatchId() string

func (*Batch) GetBugtrackerUri 

func (x *Batch) GetBugtrackerUri() *wrapperspb.StringValue

func (*Batch) GetCreateTime 

func (x *Batch) GetCreateTime() *timestamppb.Timestamp

func (*Batch) GetEntryCount 

func (x *Batch) GetEntryCount() int32

func (*Batch) GetName 

func (x *Batch) GetName() string

func (*Batch) GetSealTime 

func (x *Batch) GetSealTime() *timestamppb.Timestamp

func (*Batch) GetUpdateTime 

func (x *Batch) GetUpdateTime() *timestamppb.Timestamp

func (*Batch) GetWorkerId 

func (x *Batch) GetWorkerId() string

func (*Batch) ProtoMessage 

func (*Batch) ProtoMessage()

func (*Batch) ProtoReflect 

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

func (*Batch) Reset 

func (x *Batch) Reset()

func (*Batch) String 

func (x *Batch) String() string

type CreateBatchRequest 

type CreateBatchRequest struct {

	// The batch to create.
	Batch *Batch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	// Custom ID for the batch. Optional
	BatchId string `protobuf:"bytes,2,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for CreateBatch method.

func (*CreateBatchRequest) Descriptor deprecated 

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

Deprecated: Use CreateBatchRequest.ProtoReflect.Descriptor instead.

func (*CreateBatchRequest) GetBatch 

func (x *CreateBatchRequest) GetBatch() *Batch

func (*CreateBatchRequest) GetBatchId 

func (x *CreateBatchRequest) GetBatchId() string

func (*CreateBatchRequest) ProtoMessage 

func (*CreateBatchRequest) ProtoMessage()

func (*CreateBatchRequest) ProtoReflect 

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

func (*CreateBatchRequest) Reset 

func (x *CreateBatchRequest) Reset()

func (*CreateBatchRequest) String 

func (x *CreateBatchRequest) String() string

type Entry 

type Entry struct {

	// Output only. Unique ID of the entry.
	// Format: `entries/{entry_id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Package NEVRA (name-epoch:version-release.arch) of the package being archived.
	EntryId string `protobuf:"bytes,2,opt,name=entry_id,json=entryId,proto3" json:"entry_id,omitempty"`
	// When the package was archived.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// OS release value the package was pulled from.
	OsRelease string `protobuf:"bytes,4,opt,name=os_release,json=osRelease,proto3" json:"os_release,omitempty"`
	// SHA256 of the package.
	// This value is output only as the API server will determine
	// the SHA256 of the package.
	Sha256Sum string `protobuf:"bytes,5,opt,name=sha256_sum,json=sha256Sum,proto3" json:"sha256_sum,omitempty"`
	// Repository name of the package as in which repository the package was archived from.
	Repository string `protobuf:"bytes,6,opt,name=repository,proto3" json:"repository,omitempty"`
	// Worker ID of the worker that archived the package.
	// This value is output only as the API server will determine
	// the worker ID of the worker that archived the package based
	// on the authentication token used to make the request.
	// If this field is not set, the package was archived by a
	// user instead of a worker.
	WorkerId *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// Name of the batch the package was archived in.
	// If this field is not set, the package was not archived in a batch.
	Batch *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=batch,proto3" json:"batch,omitempty"`
	// User email of the user that archived the package.
	// This value is output only as the API server will determine
	// the user email of the user that archived the package based
	// on the authentication token used to make the request.
	// If this field is not set, the package was archived by a
	// worker instead of a user.
	UserEmail *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=user_email,json=userEmail,proto3" json:"user_email,omitempty"`
	// URI to view commit
	CommitUri string `protobuf:"bytes,10,opt,name=commit_uri,json=commitUri,proto3" json:"commit_uri,omitempty"`
	// Commit hash of the resulting import
	CommitHash string `protobuf:"bytes,11,opt,name=commit_hash,json=commitHash,proto3" json:"commit_hash,omitempty"`
	// Commit branch of the resulting import
	CommitBranch string `protobuf:"bytes,12,opt,name=commit_branch,json=commitBranch,proto3" json:"commit_branch,omitempty"`
	// Commit tag of the resulting import
	CommitTag string `protobuf:"bytes,13,opt,name=commit_tag,json=commitTag,proto3" json:"commit_tag,omitempty"`
	// State of the entry.
	State Entry_State `protobuf:"varint,14,opt,name=state,proto3,enum=mothership.v1.Entry_State" json:"state,omitempty"`
	// Name of the package being archived.
	Pkg string `protobuf:"bytes,15,opt,name=pkg,proto3" json:"pkg,omitempty"`
	// Error message if on hold
	ErrorMessage string `protobuf:"bytes,16,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

Entry is a single entry in the mothership log. This describes the package being archived, which worker archived it, when it was archived, if it was in a batch and which OS release value the package was pulled from.

func (*Entry) Descriptor deprecated 

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

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetBatch 

func (x *Entry) GetBatch() *wrapperspb.StringValue

func (*Entry) GetCommitBranch 

func (x *Entry) GetCommitBranch() string

func (*Entry) GetCommitHash 

func (x *Entry) GetCommitHash() string

func (*Entry) GetCommitTag 

func (x *Entry) GetCommitTag() string

func (*Entry) GetCommitUri 

func (x *Entry) GetCommitUri() string

func (*Entry) GetCreateTime 

func (x *Entry) GetCreateTime() *timestamppb.Timestamp

func (*Entry) GetEntryId 

func (x *Entry) GetEntryId() string

func (*Entry) GetErrorMessage 

func (x *Entry) GetErrorMessage() string

func (*Entry) GetName 

func (x *Entry) GetName() string

func (*Entry) GetOsRelease 

func (x *Entry) GetOsRelease() string

func (*Entry) GetPkg 

func (x *Entry) GetPkg() string

func (*Entry) GetRepository 

func (x *Entry) GetRepository() string

func (*Entry) GetSha256Sum 

func (x *Entry) GetSha256Sum() string

func (*Entry) GetState 

func (x *Entry) GetState() Entry_State

func (*Entry) GetUserEmail 

func (x *Entry) GetUserEmail() *wrapperspb.StringValue

func (*Entry) GetWorkerId 

func (x *Entry) GetWorkerId() *wrapperspb.StringValue

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect 

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

func (*Entry) Reset 

func (x *Entry) Reset()

func (*Entry) String 

func (x *Entry) String() string

type Entry_State 

type Entry_State int32

Valid states of an entry. 

const (
	// Default value. This value is unused.
	Entry_STATE_UNSPECIFIED Entry_State = 0
	// The entry is being archived.
	Entry_ARCHIVING Entry_State = 1
	// The entry has been archived.
	Entry_ARCHIVED Entry_State = 2
	// One or more errors occurred while archiving the entry.
	// Usually related to patches failing to apply.
	// The entry will be placed "on hold" until the admin API
	// receives the "rescue" call
	Entry_ON_HOLD Entry_State = 3
	// Error occurred while archiving the entry and an admin
	// cancelled the entry.
	// This entry CAN'T be rescued.
	Entry_CANCELLED Entry_State = 4
	// Failed to archive the entry.
	// This entry CAN'T be rescued.
	Entry_FAILED Entry_State = 5
	// Retracting the entry.
	Entry_RETRACTING Entry_State = 6
	// Retracted. This entry CAN'T be rescued.
	// Another import may have happened, retraction is usually done
	// if debranding was not complete but successful.
	Entry_RETRACTED Entry_State = 7
)

func (Entry_State) Descriptor 

func (Entry_State) Descriptor() protoreflect.EnumDescriptor

func (Entry_State) Enum 

func (x Entry_State) Enum() *Entry_State

func (Entry_State) EnumDescriptor deprecated 

func (Entry_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Entry_State.Descriptor instead.

func (Entry_State) Number 

func (x Entry_State) Number() protoreflect.EnumNumber

func (Entry_State) String 

func (x Entry_State) String() string

func (Entry_State) Type 

func (Entry_State) Type() protoreflect.EnumType

type GetBatchRequest 

type GetBatchRequest struct {

	// The name of the batch to retrieve.
	// For example: "batches/1234".
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for GetBatch method.

func (*GetBatchRequest) Descriptor deprecated 

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

Deprecated: Use GetBatchRequest.ProtoReflect.Descriptor instead.

func (*GetBatchRequest) GetName 

func (x *GetBatchRequest) GetName() string

func (*GetBatchRequest) ProtoMessage 

func (*GetBatchRequest) ProtoMessage()

func (*GetBatchRequest) ProtoReflect 

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

func (*GetBatchRequest) Reset 

func (x *GetBatchRequest) Reset()

func (*GetBatchRequest) String 

func (x *GetBatchRequest) String() string

type GetEntryRequest 

type GetEntryRequest struct {

	// The name of the entry to retrieve.
	// For example: "entries/1234".
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for GetEntry method.

func (*GetEntryRequest) Descriptor deprecated 

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

Deprecated: Use GetEntryRequest.ProtoReflect.Descriptor instead.

func (*GetEntryRequest) GetName 

func (x *GetEntryRequest) GetName() string

func (*GetEntryRequest) ProtoMessage 

func (*GetEntryRequest) ProtoMessage()

func (*GetEntryRequest) ProtoReflect 

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

func (*GetEntryRequest) Reset 

func (x *GetEntryRequest) Reset()

func (*GetEntryRequest) String 

func (x *GetEntryRequest) String() string

type ImportRPMResponse 

type ImportRPMResponse struct {

	// Commit hash of the imported RPM
	// e.g. 1234567890abcdef1234567890abcdef12345678
	CommitHash string `protobuf:"bytes,1,opt,name=commit_hash,json=commitHash,proto3" json:"commit_hash,omitempty"`
	// Commit URI of the imported RPM
	CommitUri string `protobuf:"bytes,2,opt,name=commit_uri,json=commitUri,proto3" json:"commit_uri,omitempty"`
	// Commit branch of the imported RPM
	CommitBranch string `protobuf:"bytes,3,opt,name=commit_branch,json=commitBranch,proto3" json:"commit_branch,omitempty"`
	// Commit tag of the imported RPM
	CommitTag string `protobuf:"bytes,4,opt,name=commit_tag,json=commitTag,proto3" json:"commit_tag,omitempty"`
	// NEVRA of the imported RPM
	// e.g. rpm-1.0.0-1.el8.x86_64
	Nevra string `protobuf:"bytes,5,opt,name=nevra,proto3" json:"nevra,omitempty"`
	// Package name of the imported RPM
	// e.g. rpm
	Pkg string `protobuf:"bytes,6,opt,name=pkg,proto3" json:"pkg,omitempty"`
	// contains filtered or unexported fields
}

ImportRPMResponse is the response message for the ImportRPM activity

func (*ImportRPMResponse) Descriptor deprecated 

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

Deprecated: Use ImportRPMResponse.ProtoReflect.Descriptor instead.

func (*ImportRPMResponse) GetCommitBranch 

func (x *ImportRPMResponse) GetCommitBranch() string

func (*ImportRPMResponse) GetCommitHash 

func (x *ImportRPMResponse) GetCommitHash() string

func (*ImportRPMResponse) GetCommitTag 

func (x *ImportRPMResponse) GetCommitTag() string

func (*ImportRPMResponse) GetCommitUri 

func (x *ImportRPMResponse) GetCommitUri() string

func (*ImportRPMResponse) GetNevra 

func (x *ImportRPMResponse) GetNevra() string

func (*ImportRPMResponse) GetPkg 

func (x *ImportRPMResponse) GetPkg() string

func (*ImportRPMResponse) ProtoMessage 

func (*ImportRPMResponse) ProtoMessage()

func (*ImportRPMResponse) ProtoReflect 

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

func (*ImportRPMResponse) Reset 

func (x *ImportRPMResponse) Reset()

func (*ImportRPMResponse) String 

func (x *ImportRPMResponse) String() string

type ListBatchesRequest 

type ListBatchesRequest struct {

	// The maximum number of batches to return.
	// The service may return fewer than this value.
	// If unspecified, at most 50 batches will be returned.
	// The maximum value is 1000; values above 1000 will return an error
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `ListBatches` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListBatches` must
	// match the call that provided the page token.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The filter string, following the syntax described in
	// https://google.aip.dev/160.
	// Supports all fields of the `Batch` resource.
	// Examples:
	//   - By name: `name="batches/1234"`
	Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// The order to sort the results by. For example: `name desc`.
	// Supports all fields of the `Batch` resource.
	// Needs a suffix of either `asc` or `desc`.
	// Example: `name asc`, `created_at desc`.
	OrderBy string `protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

Request message for ListBatches method.

func (*ListBatchesRequest) Descriptor deprecated 

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

Deprecated: Use ListBatchesRequest.ProtoReflect.Descriptor instead.

func (*ListBatchesRequest) GetFilter 

func (x *ListBatchesRequest) GetFilter() string

func (*ListBatchesRequest) GetOrderBy 

func (x *ListBatchesRequest) GetOrderBy() string

func (*ListBatchesRequest) GetPageSize 

func (x *ListBatchesRequest) GetPageSize() int32

func (*ListBatchesRequest) GetPageToken 

func (x *ListBatchesRequest) GetPageToken() string

func (*ListBatchesRequest) ProtoMessage 

func (*ListBatchesRequest) ProtoMessage()

func (*ListBatchesRequest) ProtoReflect 

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

func (*ListBatchesRequest) Reset 

func (x *ListBatchesRequest) Reset()

func (*ListBatchesRequest) String 

func (x *ListBatchesRequest) String() string

type ListBatchesResponse 

type ListBatchesResponse struct {

	// The list of batches.
	Batches []*Batch `protobuf:"bytes,1,rep,name=batches,proto3" json:"batches,omitempty"`
	// A token to retrieve next page of results.
	// Pass this value in the
	// [ListBatchesRequest.page_token][peridot.tools.mothership.v1.ListBatchesRequest.page_token]
	// field in the subsequent call to `ListBatches` method to retrieve the next
	// page of results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response message for ListBatches method.

func (*ListBatchesResponse) Descriptor deprecated 

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

Deprecated: Use ListBatchesResponse.ProtoReflect.Descriptor instead.

func (*ListBatchesResponse) GetBatches 

func (x *ListBatchesResponse) GetBatches() []*Batch

func (*ListBatchesResponse) GetNextPageToken 

func (x *ListBatchesResponse) GetNextPageToken() string

func (*ListBatchesResponse) ProtoMessage 

func (*ListBatchesResponse) ProtoMessage()

func (*ListBatchesResponse) ProtoReflect 

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

func (*ListBatchesResponse) Reset 

func (x *ListBatchesResponse) Reset()

func (*ListBatchesResponse) String 

func (x *ListBatchesResponse) String() string

type ListEntriesRequest 

type ListEntriesRequest struct {

	// The maximum number of entries to return.
	// The service may return fewer than this value.
	// If unspecified, at most 50 entries will be returned.
	// The maximum value is 1000; values above 1000 will return an error
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `ListEntries` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListEntries` must
	// match the call that provided the page token.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The filter string, following the syntax described in
	// https://google.aip.dev/160.
	// Supports all fields of the `Entry` resource.
	// Examples:
	//   - By name: `name="entries/1234"`
	Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// The order to sort the results by. For example: `name desc`.
	// Supports all fields of the `Worker` resource.
	// Needs a suffix of either `asc` or `desc`.
	// Example: `name asc`, `created_at desc`.
	OrderBy string `protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

Request message for ListEntries method.

func (*ListEntriesRequest) Descriptor deprecated 

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

Deprecated: Use ListEntriesRequest.ProtoReflect.Descriptor instead.

func (*ListEntriesRequest) GetFilter 

func (x *ListEntriesRequest) GetFilter() string

func (*ListEntriesRequest) GetOrderBy 

func (x *ListEntriesRequest) GetOrderBy() string

func (*ListEntriesRequest) GetPageSize 

func (x *ListEntriesRequest) GetPageSize() int32

func (*ListEntriesRequest) GetPageToken 

func (x *ListEntriesRequest) GetPageToken() string

func (*ListEntriesRequest) ProtoMessage 

func (*ListEntriesRequest) ProtoMessage()

func (*ListEntriesRequest) ProtoReflect 

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

func (*ListEntriesRequest) Reset 

func (x *ListEntriesRequest) Reset()

func (*ListEntriesRequest) String 

func (x *ListEntriesRequest) String() string

type ListEntriesResponse 

type ListEntriesResponse struct {

	// The list of entries.
	Entries []*Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// A token to retrieve next page of results.
	// Pass this value in the
	// [ListEntriesRequest.page_token][peridot.tools.mothership.v1.ListEntriesRequest.page_token]
	// field in the subsequent call to `ListEntries` method to retrieve the next
	// page of results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response message for ListEntries method.

func (*ListEntriesResponse) Descriptor deprecated 

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

Deprecated: Use ListEntriesResponse.ProtoReflect.Descriptor instead.

func (*ListEntriesResponse) GetEntries 

func (x *ListEntriesResponse) GetEntries() []*Entry

func (*ListEntriesResponse) GetNextPageToken 

func (x *ListEntriesResponse) GetNextPageToken() string

func (*ListEntriesResponse) ProtoMessage 

func (*ListEntriesResponse) ProtoMessage()

func (*ListEntriesResponse) ProtoReflect 

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

func (*ListEntriesResponse) Reset 

func (x *ListEntriesResponse) Reset()

func (*ListEntriesResponse) String 

func (x *ListEntriesResponse) String() string

type ProcessRPMArgs 

type ProcessRPMArgs struct {

	// Public request
	Request *ProcessRPMRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Internal request
	InternalRequest *ProcessRPMInternalRequest `protobuf:"bytes,2,opt,name=internal_request,json=internalRequest,proto3" json:"internal_request,omitempty"`
	// contains filtered or unexported fields
}

ProcessRPMArgs is the arguments for the ProcessRPM workflow

func (*ProcessRPMArgs) Descriptor deprecated 

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

Deprecated: Use ProcessRPMArgs.ProtoReflect.Descriptor instead.

func (*ProcessRPMArgs) GetInternalRequest 

func (x *ProcessRPMArgs) GetInternalRequest() *ProcessRPMInternalRequest

func (*ProcessRPMArgs) GetRequest 

func (x *ProcessRPMArgs) GetRequest() *ProcessRPMRequest

func (*ProcessRPMArgs) ProtoMessage 

func (*ProcessRPMArgs) ProtoMessage()

func (*ProcessRPMArgs) ProtoReflect 

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

func (*ProcessRPMArgs) Reset 

func (x *ProcessRPMArgs) Reset()

func (*ProcessRPMArgs) String 

func (x *ProcessRPMArgs) String() string

type ProcessRPMInternalRequest 

type ProcessRPMInternalRequest struct {

	// Worker ID of the worker processing the RPM
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

ProcessRPMInternalRequest is the request message that the Server uses in its call to the ProcessRPM workflow

func (*ProcessRPMInternalRequest) Descriptor deprecated 

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

Deprecated: Use ProcessRPMInternalRequest.ProtoReflect.Descriptor instead.

func (*ProcessRPMInternalRequest) GetWorkerId 

func (x *ProcessRPMInternalRequest) GetWorkerId() string

func (*ProcessRPMInternalRequest) ProtoMessage 

func (*ProcessRPMInternalRequest) ProtoMessage()

func (*ProcessRPMInternalRequest) ProtoReflect 

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

func (*ProcessRPMInternalRequest) Reset 

func (x *ProcessRPMInternalRequest) Reset()

func (*ProcessRPMInternalRequest) String 

func (x *ProcessRPMInternalRequest) String() string

type ProcessRPMMetadata 

type ProcessRPMMetadata struct {

	// The time at which the workflow started
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The time at which the workflow finished
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

ProcessRPMMetadata is the metadata for the ProcessRPM workflow

func (*ProcessRPMMetadata) Descriptor deprecated 

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

Deprecated: Use ProcessRPMMetadata.ProtoReflect.Descriptor instead.

func (*ProcessRPMMetadata) GetEndTime 

func (x *ProcessRPMMetadata) GetEndTime() *timestamppb.Timestamp

func (*ProcessRPMMetadata) GetStartTime 

func (x *ProcessRPMMetadata) GetStartTime() *timestamppb.Timestamp

func (*ProcessRPMMetadata) ProtoMessage 

func (*ProcessRPMMetadata) ProtoMessage()

func (*ProcessRPMMetadata) ProtoReflect 

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

func (*ProcessRPMMetadata) Reset 

func (x *ProcessRPMMetadata) Reset()

func (*ProcessRPMMetadata) String 

func (x *ProcessRPMMetadata) String() string

type ProcessRPMRequest 

type ProcessRPMRequest struct {

	// URI of the RPM to process
	// e.g. gs://bucket/path/to/rpm.rpm
	// The server must have read access to the RPM and WILL error if it does not
	RpmUri string `protobuf:"bytes,1,opt,name=rpm_uri,json=rpmUri,proto3" json:"rpm_uri,omitempty"`
	// OS Release of the RPM
	// e.g. Red Hat Enterprise Linux release 8.8 (Ootpa)
	OsRelease string `protobuf:"bytes,2,opt,name=os_release,json=osRelease,proto3" json:"os_release,omitempty"`
	// Self reported checksum of the RPM
	// Must be a SHA256 checksum and match the RPM
	Checksum string `protobuf:"bytes,3,opt,name=checksum,proto3" json:"checksum,omitempty"`
	// Self reported repository of the RPM
	// e.g. BaseOS
	Repository string `protobuf:"bytes,4,opt,name=repository,proto3" json:"repository,omitempty"`
	// Batch to associate the RPM with
	Batch string `protobuf:"bytes,5,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

ProcessRPMRequest is the request message for the ProcessRPM workflow

func (*ProcessRPMRequest) Descriptor deprecated 

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

Deprecated: Use ProcessRPMRequest.ProtoReflect.Descriptor instead.

func (*ProcessRPMRequest) GetBatch 

func (x *ProcessRPMRequest) GetBatch() string

func (*ProcessRPMRequest) GetChecksum 

func (x *ProcessRPMRequest) GetChecksum() string

func (*ProcessRPMRequest) GetOsRelease 

func (x *ProcessRPMRequest) GetOsRelease() string

func (*ProcessRPMRequest) GetRepository 

func (x *ProcessRPMRequest) GetRepository() string

func (*ProcessRPMRequest) GetRpmUri 

func (x *ProcessRPMRequest) GetRpmUri() string

func (*ProcessRPMRequest) ProtoMessage 

func (*ProcessRPMRequest) ProtoMessage()

func (*ProcessRPMRequest) ProtoReflect 

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

func (*ProcessRPMRequest) Reset 

func (x *ProcessRPMRequest) Reset()

func (*ProcessRPMRequest) String 

func (x *ProcessRPMRequest) String() string

type ProcessRPMResponse 

type ProcessRPMResponse struct {

	// The entry created for the RPM
	Entry *Entry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

ProcessRPMResponse is the response message for the ProcessRPM workflow

func (*ProcessRPMResponse) Descriptor deprecated 

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

Deprecated: Use ProcessRPMResponse.ProtoReflect.Descriptor instead.

func (*ProcessRPMResponse) GetEntry 

func (x *ProcessRPMResponse) GetEntry() *Entry

func (*ProcessRPMResponse) ProtoMessage 

func (*ProcessRPMResponse) ProtoMessage()

func (*ProcessRPMResponse) ProtoReflect 

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

func (*ProcessRPMResponse) Reset 

func (x *ProcessRPMResponse) Reset()

func (*ProcessRPMResponse) String 

func (x *ProcessRPMResponse) String() string

type SealBatchRequest 

type SealBatchRequest struct {

	// The name of the batch to seal.
	// For example: "batches/1234".
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// All operation names that are part of the batch.
	// This is optional, but ensures that the batch is sealed only if all
	// operations are settled.
	OperationNames []string `protobuf:"bytes,2,rep,name=operation_names,json=operationNames,proto3" json:"operation_names,omitempty"`
	// contains filtered or unexported fields
}

Request message for SealBatch method.

func (*SealBatchRequest) Descriptor deprecated 

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

Deprecated: Use SealBatchRequest.ProtoReflect.Descriptor instead.

func (*SealBatchRequest) GetName 

func (x *SealBatchRequest) GetName() string

func (*SealBatchRequest) GetOperationNames 

func (x *SealBatchRequest) GetOperationNames() []string

func (*SealBatchRequest) ProtoMessage 

func (*SealBatchRequest) ProtoMessage()

func (*SealBatchRequest) ProtoReflect 

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

func (*SealBatchRequest) Reset 

func (x *SealBatchRequest) Reset()

func (*SealBatchRequest) String 

func (x *SealBatchRequest) String() string

type SealBatchResponse 

type SealBatchResponse struct {

	// The sealed batch.
	Batch *Batch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

Response message for SealBatch method.

func (*SealBatchResponse) Descriptor deprecated 

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

Deprecated: Use SealBatchResponse.ProtoReflect.Descriptor instead.

func (*SealBatchResponse) GetBatch 

func (x *SealBatchResponse) GetBatch() *Batch

func (*SealBatchResponse) ProtoMessage 

func (*SealBatchResponse) ProtoMessage()

func (*SealBatchResponse) ProtoReflect 

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

func (*SealBatchResponse) Reset 

func (x *SealBatchResponse) Reset()

func (*SealBatchResponse) String 

func (x *SealBatchResponse) String() string

type SrpmArchiverClient 

type SrpmArchiverClient interface {
	// Returns a batch
	GetBatch(ctx context.Context, in *GetBatchRequest, opts ...grpc.CallOption) (*Batch, error)
	// Returns a list of batches that match the filter criteria.
	ListBatches(ctx context.Context, in *ListBatchesRequest, opts ...grpc.CallOption) (*ListBatchesResponse, error)
	// Creates a batch.
	// Only worker credentials can create a batch.
	CreateBatch(ctx context.Context, in *CreateBatchRequest, opts ...grpc.CallOption) (*Batch, error)
	// Seal a batch
	// Only worker credentials can seal a batch.
	SealBatch(ctx context.Context, in *SealBatchRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Returns an entry
	GetEntry(ctx context.Context, in *GetEntryRequest, opts ...grpc.CallOption) (*Entry, error)
	// Returns a list of entries that match the filter criteria.
	ListEntries(ctx context.Context, in *ListEntriesRequest, opts ...grpc.CallOption) (*ListEntriesResponse, error)
	// Submits an SRPM to be archived.
	// A worker can call this method to submit an SRPM to be archived.
	// The call can occur even before uploading the SRPM to the object storage
	// that way it can be ensured that a certain hash is "leased" by the worker.
	// Other workers will still keep the hash in their backlog until the SRPM is
	// verified processed.
	// Until they can query an entry with `sha256_sum=X` matching the hash of the
	// SRPM, it will not be deleted from the backlog.
	// If after 2 hours the SRPM is not processed, the worker can assume that
	// the SRPM is lost and can be re-uploaded. It that case, the entry will be
	// re-assigned to the worker.
	// If a checksum can't be leased because it's already being processed,
	// AlreadyExists error will be returned.
	// The worker MUST stop processing the SRPM in that case.
	SubmitEntry(ctx context.Context, in *SubmitEntryRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// WorkerUploadObject is used by workers to upload objects to the
	// object storage service.
	// Returns AlreadyExists if the SRPM already exists.
	// This doesn't necessarily mean that the worker should stop processing,
	// especially if it acquired a lease to process this particular SRPM.
	WorkerUploadObject(ctx context.Context, opts ...grpc.CallOption) (SrpmArchiver_WorkerUploadObjectClient, error)
	// WorkerPing is used by workers to ping the server.
	// This is used to check if the worker is still alive.
	WorkerPing(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SrpmArchiverClient is the client API for SrpmArchiver service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSrpmArchiverClient 

func NewSrpmArchiverClient(cc grpc.ClientConnInterface) SrpmArchiverClient

type SrpmArchiverServer 

type SrpmArchiverServer interface {
	// Returns a batch
	GetBatch(context.Context, *GetBatchRequest) (*Batch, error)
	// Returns a list of batches that match the filter criteria.
	ListBatches(context.Context, *ListBatchesRequest) (*ListBatchesResponse, error)
	// Creates a batch.
	// Only worker credentials can create a batch.
	CreateBatch(context.Context, *CreateBatchRequest) (*Batch, error)
	// Seal a batch
	// Only worker credentials can seal a batch.
	SealBatch(context.Context, *SealBatchRequest) (*longrunning.Operation, error)
	// Returns an entry
	GetEntry(context.Context, *GetEntryRequest) (*Entry, error)
	// Returns a list of entries that match the filter criteria.
	ListEntries(context.Context, *ListEntriesRequest) (*ListEntriesResponse, error)
	// Submits an SRPM to be archived.
	// A worker can call this method to submit an SRPM to be archived.
	// The call can occur even before uploading the SRPM to the object storage
	// that way it can be ensured that a certain hash is "leased" by the worker.
	// Other workers will still keep the hash in their backlog until the SRPM is
	// verified processed.
	// Until they can query an entry with `sha256_sum=X` matching the hash of the
	// SRPM, it will not be deleted from the backlog.
	// If after 2 hours the SRPM is not processed, the worker can assume that
	// the SRPM is lost and can be re-uploaded. It that case, the entry will be
	// re-assigned to the worker.
	// If a checksum can't be leased because it's already being processed,
	// AlreadyExists error will be returned.
	// The worker MUST stop processing the SRPM in that case.
	SubmitEntry(context.Context, *SubmitEntryRequest) (*longrunning.Operation, error)
	// WorkerUploadObject is used by workers to upload objects to the
	// object storage service.
	// Returns AlreadyExists if the SRPM already exists.
	// This doesn't necessarily mean that the worker should stop processing,
	// especially if it acquired a lease to process this particular SRPM.
	WorkerUploadObject(SrpmArchiver_WorkerUploadObjectServer) error
	// WorkerPing is used by workers to ping the server.
	// This is used to check if the worker is still alive.
	WorkerPing(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

SrpmArchiverServer is the server API for SrpmArchiver service. All implementations must embed UnimplementedSrpmArchiverServer for forward compatibility

type SrpmArchiver_WorkerUploadObjectClient 

type SrpmArchiver_WorkerUploadObjectClient interface {
	Send(*WorkerUploadObjectRequest) error
	CloseAndRecv() (*WorkerUploadObjectResponse, error)
	grpc.ClientStream
}

type SrpmArchiver_WorkerUploadObjectServer 

type SrpmArchiver_WorkerUploadObjectServer interface {
	SendAndClose(*WorkerUploadObjectResponse) error
	Recv() (*WorkerUploadObjectRequest, error)
	grpc.ServerStream
}

type SubmitEntryRequest 

type SubmitEntryRequest struct {

	// Process request for RPM.
	// This request is sent to the worker to process the RPM.
	ProcessRpmRequest *ProcessRPMRequest `protobuf:"bytes,1,opt,name=process_rpm_request,json=processRpmRequest,proto3" json:"process_rpm_request,omitempty"`
	// contains filtered or unexported fields
}

Request message for SubmitEntry method.

func (*SubmitEntryRequest) Descriptor deprecated 

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

Deprecated: Use SubmitEntryRequest.ProtoReflect.Descriptor instead.

func (*SubmitEntryRequest) GetProcessRpmRequest 

func (x *SubmitEntryRequest) GetProcessRpmRequest() *ProcessRPMRequest

func (*SubmitEntryRequest) ProtoMessage 

func (*SubmitEntryRequest) ProtoMessage()

func (*SubmitEntryRequest) ProtoReflect 

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

func (*SubmitEntryRequest) Reset 

func (x *SubmitEntryRequest) Reset()

func (*SubmitEntryRequest) String 

func (x *SubmitEntryRequest) String() string

type UnimplementedSrpmArchiverServer 

type UnimplementedSrpmArchiverServer struct {
}

UnimplementedSrpmArchiverServer must be embedded to have forward compatible implementations.

func (UnimplementedSrpmArchiverServer) CreateBatch 

func (UnimplementedSrpmArchiverServer) CreateBatch(context.Context, *CreateBatchRequest) (*Batch, error)

func (UnimplementedSrpmArchiverServer) GetBatch 

func (UnimplementedSrpmArchiverServer) GetBatch(context.Context, *GetBatchRequest) (*Batch, error)

func (UnimplementedSrpmArchiverServer) GetEntry 

func (UnimplementedSrpmArchiverServer) GetEntry(context.Context, *GetEntryRequest) (*Entry, error)

func (UnimplementedSrpmArchiverServer) ListBatches 

func (UnimplementedSrpmArchiverServer) ListBatches(context.Context, *ListBatchesRequest) (*ListBatchesResponse, error)

func (UnimplementedSrpmArchiverServer) ListEntries 

func (UnimplementedSrpmArchiverServer) ListEntries(context.Context, *ListEntriesRequest) (*ListEntriesResponse, error)

func (UnimplementedSrpmArchiverServer) SealBatch 

func (UnimplementedSrpmArchiverServer) SealBatch(context.Context, *SealBatchRequest) (*longrunning.Operation, error)

func (UnimplementedSrpmArchiverServer) SubmitEntry 

func (UnimplementedSrpmArchiverServer) SubmitEntry(context.Context, *SubmitEntryRequest) (*longrunning.Operation, error)

func (UnimplementedSrpmArchiverServer) WorkerPing 

func (UnimplementedSrpmArchiverServer) WorkerPing(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedSrpmArchiverServer) WorkerUploadObject 

func (UnimplementedSrpmArchiverServer) WorkerUploadObject(SrpmArchiver_WorkerUploadObjectServer) error

type UnsafeSrpmArchiverServer 

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

UnsafeSrpmArchiverServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SrpmArchiverServer will result in compilation errors.

type WorkerUploadObjectRequest 

type WorkerUploadObjectRequest struct {

	// The object to upload.
	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

Request message for WorkerUploadObject method.

func (*WorkerUploadObjectRequest) Descriptor deprecated 

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

Deprecated: Use WorkerUploadObjectRequest.ProtoReflect.Descriptor instead.

func (*WorkerUploadObjectRequest) GetChunk 

func (x *WorkerUploadObjectRequest) GetChunk() []byte

func (*WorkerUploadObjectRequest) ProtoMessage 

func (*WorkerUploadObjectRequest) ProtoMessage()

func (*WorkerUploadObjectRequest) ProtoReflect 

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

func (*WorkerUploadObjectRequest) Reset 

func (x *WorkerUploadObjectRequest) Reset()

func (*WorkerUploadObjectRequest) String 

func (x *WorkerUploadObjectRequest) String() string

type WorkerUploadObjectResponse 

type WorkerUploadObjectResponse struct {

	// The object URI.
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

Response message for WorkerUploadObject method.

func (*WorkerUploadObjectResponse) Descriptor deprecated 

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

Deprecated: Use WorkerUploadObjectResponse.ProtoReflect.Descriptor instead.

func (*WorkerUploadObjectResponse) GetUri 

func (x *WorkerUploadObjectResponse) GetUri() string

func (*WorkerUploadObjectResponse) ProtoMessage 

func (*WorkerUploadObjectResponse) ProtoMessage()

func (*WorkerUploadObjectResponse) ProtoReflect 

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

func (*WorkerUploadObjectResponse) Reset 

func (x *WorkerUploadObjectResponse) Reset()

func (*WorkerUploadObjectResponse) String 

func (x *WorkerUploadObjectResponse) String() string

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.