Documentation ¶
Overview ¶
Package mshipadminpb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterMshipAdminHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterMshipAdminHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MshipAdminClient) error
- func RegisterMshipAdminHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterMshipAdminHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MshipAdminServer) error
- func RegisterMshipAdminServer(s grpc.ServiceRegistrar, srv MshipAdminServer)
- type BugTrackerConfig
- func (*BugTrackerConfig) Descriptor() ([]byte, []int)deprecated
- func (m *BugTrackerConfig) GetConfig() isBugTrackerConfig_Config
- func (x *BugTrackerConfig) GetMantis() *BugTrackerConfig_MantisConfig
- func (x *BugTrackerConfig) GetType() BugTrackerConfig_Type
- func (x *BugTrackerConfig) GetUri() string
- func (*BugTrackerConfig) ProtoMessage()
- func (x *BugTrackerConfig) ProtoReflect() protoreflect.Message
- func (x *BugTrackerConfig) Reset()
- func (x *BugTrackerConfig) String() string
- type BugTrackerConfig_Mantis
- type BugTrackerConfig_MantisConfig
- func (*BugTrackerConfig_MantisConfig) Descriptor() ([]byte, []int)deprecated
- func (x *BugTrackerConfig_MantisConfig) GetApiKey() string
- func (x *BugTrackerConfig_MantisConfig) GetProjectIds() map[int32]int64
- func (*BugTrackerConfig_MantisConfig) ProtoMessage()
- func (x *BugTrackerConfig_MantisConfig) ProtoReflect() protoreflect.Message
- func (x *BugTrackerConfig_MantisConfig) Reset()
- func (x *BugTrackerConfig_MantisConfig) String() string
- type BugTrackerConfig_Type
- func (BugTrackerConfig_Type) Descriptor() protoreflect.EnumDescriptor
- func (x BugTrackerConfig_Type) Enum() *BugTrackerConfig_Type
- func (BugTrackerConfig_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x BugTrackerConfig_Type) Number() protoreflect.EnumNumber
- func (x BugTrackerConfig_Type) String() string
- func (BugTrackerConfig_Type) Type() protoreflect.EnumType
- type CreateWorkerRequest
- func (*CreateWorkerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateWorkerRequest) GetWorkerId() string
- func (*CreateWorkerRequest) ProtoMessage()
- func (x *CreateWorkerRequest) ProtoReflect() protoreflect.Message
- func (x *CreateWorkerRequest) Reset()
- func (x *CreateWorkerRequest) String() string
- type DeleteWorkerRequest
- func (*DeleteWorkerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteWorkerRequest) GetName() string
- func (*DeleteWorkerRequest) ProtoMessage()
- func (x *DeleteWorkerRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteWorkerRequest) Reset()
- func (x *DeleteWorkerRequest) String() string
- type GetWorkerRequest
- type ListWorkersRequest
- func (*ListWorkersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkersRequest) GetFilter() string
- func (x *ListWorkersRequest) GetOrderBy() string
- func (x *ListWorkersRequest) GetPageSize() int32
- func (x *ListWorkersRequest) GetPageToken() string
- func (*ListWorkersRequest) ProtoMessage()
- func (x *ListWorkersRequest) ProtoReflect() protoreflect.Message
- func (x *ListWorkersRequest) Reset()
- func (x *ListWorkersRequest) String() string
- type ListWorkersResponse
- func (*ListWorkersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkersResponse) GetNextPageToken() string
- func (x *ListWorkersResponse) GetWorkers() []*Worker
- func (*ListWorkersResponse) ProtoMessage()
- func (x *ListWorkersResponse) ProtoReflect() protoreflect.Message
- func (x *ListWorkersResponse) Reset()
- func (x *ListWorkersResponse) String() string
- type MshipAdminClient
- type MshipAdminServer
- type RescueEntryImportRequest
- func (*RescueEntryImportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RescueEntryImportRequest) GetName() string
- func (*RescueEntryImportRequest) ProtoMessage()
- func (x *RescueEntryImportRequest) ProtoReflect() protoreflect.Message
- func (x *RescueEntryImportRequest) Reset()
- func (x *RescueEntryImportRequest) String() string
- type RetractEntryMetadata
- func (*RetractEntryMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *RetractEntryMetadata) GetEndTime() *timestamppb.Timestamp
- func (x *RetractEntryMetadata) GetStartTime() *timestamppb.Timestamp
- func (*RetractEntryMetadata) ProtoMessage()
- func (x *RetractEntryMetadata) ProtoReflect() protoreflect.Message
- func (x *RetractEntryMetadata) Reset()
- func (x *RetractEntryMetadata) String() string
- type RetractEntryRequest
- func (*RetractEntryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RetractEntryRequest) GetName() string
- func (*RetractEntryRequest) ProtoMessage()
- func (x *RetractEntryRequest) ProtoReflect() protoreflect.Message
- func (x *RetractEntryRequest) Reset()
- func (x *RetractEntryRequest) String() string
- type RetractEntryResponse
- func (*RetractEntryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RetractEntryResponse) GetName() string
- func (*RetractEntryResponse) ProtoMessage()
- func (x *RetractEntryResponse) ProtoReflect() protoreflect.Message
- func (x *RetractEntryResponse) Reset()
- func (x *RetractEntryResponse) String() string
- type UnimplementedMshipAdminServer
- func (UnimplementedMshipAdminServer) CreateWorker(context.Context, *CreateWorkerRequest) (*Worker, error)
- func (UnimplementedMshipAdminServer) DeleteWorker(context.Context, *DeleteWorkerRequest) (*emptypb.Empty, error)
- func (UnimplementedMshipAdminServer) GetWorker(context.Context, *GetWorkerRequest) (*Worker, error)
- func (UnimplementedMshipAdminServer) ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)
- func (UnimplementedMshipAdminServer) RescueEntryImport(context.Context, *RescueEntryImportRequest) (*emptypb.Empty, error)
- func (UnimplementedMshipAdminServer) RetractEntry(context.Context, *RetractEntryRequest) (*longrunning.Operation, error)
- type UnsafeMshipAdminServer
- type Worker
- func (*Worker) Descriptor() ([]byte, []int)deprecated
- func (x *Worker) GetApiSecret() string
- func (x *Worker) GetCreateTime() *timestamppb.Timestamp
- func (x *Worker) GetLastCheckinTime() *timestamppb.Timestamp
- func (x *Worker) GetName() string
- func (x *Worker) GetWorkerId() string
- func (*Worker) ProtoMessage()
- func (x *Worker) ProtoReflect() protoreflect.Message
- func (x *Worker) Reset()
- func (x *Worker) String() string
Constants ¶
This section is empty.
Variables ¶
var ( BugTrackerConfig_Type_name = map[int32]string{ 0: "UNKNOWN", 1: "MANTIS", } BugTrackerConfig_Type_value = map[string]int32{ "UNKNOWN": 0, "MANTIS": 1, } )
Enum value maps for BugTrackerConfig_Type.
var File_proto_admin_v1_bugtracker_proto protoreflect.FileDescriptor
var File_proto_admin_v1_mship_admin_proto protoreflect.FileDescriptor
var File_proto_admin_v1_worker_proto protoreflect.FileDescriptor
var MshipAdmin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "mothership.admin.v1.MshipAdmin", HandlerType: (*MshipAdminServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetWorker", Handler: _MshipAdmin_GetWorker_Handler, }, { MethodName: "ListWorkers", Handler: _MshipAdmin_ListWorkers_Handler, }, { MethodName: "CreateWorker", Handler: _MshipAdmin_CreateWorker_Handler, }, { MethodName: "DeleteWorker", Handler: _MshipAdmin_DeleteWorker_Handler, }, { MethodName: "RescueEntryImport", Handler: _MshipAdmin_RescueEntryImport_Handler, }, { MethodName: "RetractEntry", Handler: _MshipAdmin_RetractEntry_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/admin/v1/mship_admin.proto", }
MshipAdmin_ServiceDesc is the grpc.ServiceDesc for MshipAdmin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMshipAdminHandler ¶
func RegisterMshipAdminHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterMshipAdminHandler registers the http handlers for service MshipAdmin to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterMshipAdminHandlerClient ¶
func RegisterMshipAdminHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MshipAdminClient) error
RegisterMshipAdminHandlerClient registers the http handlers for service MshipAdmin to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MshipAdminClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MshipAdminClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MshipAdminClient" to call the correct interceptors.
func RegisterMshipAdminHandlerFromEndpoint ¶
func RegisterMshipAdminHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterMshipAdminHandlerFromEndpoint is same as RegisterMshipAdminHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterMshipAdminHandlerServer ¶
func RegisterMshipAdminHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MshipAdminServer) error
RegisterMshipAdminHandlerServer registers the http handlers for service MshipAdmin to "mux". UnaryRPC :call MshipAdminServer 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 RegisterMshipAdminHandlerFromEndpoint instead.
func RegisterMshipAdminServer ¶
func RegisterMshipAdminServer(s grpc.ServiceRegistrar, srv MshipAdminServer)
Types ¶
type BugTrackerConfig ¶
type BugTrackerConfig struct { // Type of the bug tracker. Type BugTrackerConfig_Type `protobuf:"varint,1,opt,name=type,proto3,enum=mothership.admin.v1.BugTrackerConfig_Type" json:"type,omitempty"` // URI of the bug tracker. Uri string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"` // Configuration for the bug tracker. // // Types that are assignable to Config: // // *BugTrackerConfig_Mantis Config isBugTrackerConfig_Config `protobuf_oneof:"config"` // contains filtered or unexported fields }
BugTrackerConfig is the configuration for a bug tracker. Usually, the bug tracker is a third-party service, such as Mantis or Track The configuration is used to track import batches
func (*BugTrackerConfig) Descriptor
deprecated
func (*BugTrackerConfig) Descriptor() ([]byte, []int)
Deprecated: Use BugTrackerConfig.ProtoReflect.Descriptor instead.
func (*BugTrackerConfig) GetConfig ¶
func (m *BugTrackerConfig) GetConfig() isBugTrackerConfig_Config
func (*BugTrackerConfig) GetMantis ¶
func (x *BugTrackerConfig) GetMantis() *BugTrackerConfig_MantisConfig
func (*BugTrackerConfig) GetType ¶
func (x *BugTrackerConfig) GetType() BugTrackerConfig_Type
func (*BugTrackerConfig) GetUri ¶
func (x *BugTrackerConfig) GetUri() string
func (*BugTrackerConfig) ProtoMessage ¶
func (*BugTrackerConfig) ProtoMessage()
func (*BugTrackerConfig) ProtoReflect ¶
func (x *BugTrackerConfig) ProtoReflect() protoreflect.Message
func (*BugTrackerConfig) Reset ¶
func (x *BugTrackerConfig) Reset()
func (*BugTrackerConfig) String ¶
func (x *BugTrackerConfig) String() string
type BugTrackerConfig_Mantis ¶
type BugTrackerConfig_Mantis struct { // User-defined configuration for MantisBT. Mantis *BugTrackerConfig_MantisConfig `protobuf:"bytes,3,opt,name=mantis,proto3,oneof"` }
type BugTrackerConfig_MantisConfig ¶
type BugTrackerConfig_MantisConfig struct { // API key for the bug tracker. ApiKey string `protobuf:"bytes,1,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"` // Project ID mapping. // Maps major version to project ID. ProjectIds map[int32]int64 `` /* 181-byte string literal not displayed */ // contains filtered or unexported fields }
Configuration options for MantisBT
func (*BugTrackerConfig_MantisConfig) Descriptor
deprecated
func (*BugTrackerConfig_MantisConfig) Descriptor() ([]byte, []int)
Deprecated: Use BugTrackerConfig_MantisConfig.ProtoReflect.Descriptor instead.
func (*BugTrackerConfig_MantisConfig) GetApiKey ¶
func (x *BugTrackerConfig_MantisConfig) GetApiKey() string
func (*BugTrackerConfig_MantisConfig) GetProjectIds ¶
func (x *BugTrackerConfig_MantisConfig) GetProjectIds() map[int32]int64
func (*BugTrackerConfig_MantisConfig) ProtoMessage ¶
func (*BugTrackerConfig_MantisConfig) ProtoMessage()
func (*BugTrackerConfig_MantisConfig) ProtoReflect ¶
func (x *BugTrackerConfig_MantisConfig) ProtoReflect() protoreflect.Message
func (*BugTrackerConfig_MantisConfig) Reset ¶
func (x *BugTrackerConfig_MantisConfig) Reset()
func (*BugTrackerConfig_MantisConfig) String ¶
func (x *BugTrackerConfig_MantisConfig) String() string
type BugTrackerConfig_Type ¶
type BugTrackerConfig_Type int32
Supported bug trackers.
const ( // Unknown bug tracker. BugTrackerConfig_UNKNOWN BugTrackerConfig_Type = 0 // MantisBT bug tracker. BugTrackerConfig_MANTIS BugTrackerConfig_Type = 1 )
func (BugTrackerConfig_Type) Descriptor ¶
func (BugTrackerConfig_Type) Descriptor() protoreflect.EnumDescriptor
func (BugTrackerConfig_Type) Enum ¶
func (x BugTrackerConfig_Type) Enum() *BugTrackerConfig_Type
func (BugTrackerConfig_Type) EnumDescriptor
deprecated
func (BugTrackerConfig_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use BugTrackerConfig_Type.Descriptor instead.
func (BugTrackerConfig_Type) Number ¶
func (x BugTrackerConfig_Type) Number() protoreflect.EnumNumber
func (BugTrackerConfig_Type) String ¶
func (x BugTrackerConfig_Type) String() string
func (BugTrackerConfig_Type) Type ¶
func (BugTrackerConfig_Type) Type() protoreflect.EnumType
type CreateWorkerRequest ¶
type CreateWorkerRequest struct { // Required. The worker name to use. // This id has to be at least 4 characters long and must be unique. WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"` // contains filtered or unexported fields }
(-- api-linter: core::0133::request-resource-field=disabled
aip.dev/not-precedent: There is no reason to require worker as we only allow the worker_id field to be customized. --)
CreateWorkerRequest is the request message for CreateWorker.
func (*CreateWorkerRequest) Descriptor
deprecated
func (*CreateWorkerRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateWorkerRequest.ProtoReflect.Descriptor instead.
func (*CreateWorkerRequest) GetWorkerId ¶
func (x *CreateWorkerRequest) GetWorkerId() string
func (*CreateWorkerRequest) ProtoMessage ¶
func (*CreateWorkerRequest) ProtoMessage()
func (*CreateWorkerRequest) ProtoReflect ¶
func (x *CreateWorkerRequest) ProtoReflect() protoreflect.Message
func (*CreateWorkerRequest) Reset ¶
func (x *CreateWorkerRequest) Reset()
func (*CreateWorkerRequest) String ¶
func (x *CreateWorkerRequest) String() string
type DeleteWorkerRequest ¶
type DeleteWorkerRequest struct { // Required. The name of the worker to delete. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
DeleteWorkerRequest is the request message for DeleteWorker.
func (*DeleteWorkerRequest) Descriptor
deprecated
func (*DeleteWorkerRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteWorkerRequest.ProtoReflect.Descriptor instead.
func (*DeleteWorkerRequest) GetName ¶
func (x *DeleteWorkerRequest) GetName() string
func (*DeleteWorkerRequest) ProtoMessage ¶
func (*DeleteWorkerRequest) ProtoMessage()
func (*DeleteWorkerRequest) ProtoReflect ¶
func (x *DeleteWorkerRequest) ProtoReflect() protoreflect.Message
func (*DeleteWorkerRequest) Reset ¶
func (x *DeleteWorkerRequest) Reset()
func (*DeleteWorkerRequest) String ¶
func (x *DeleteWorkerRequest) String() string
type GetWorkerRequest ¶
type GetWorkerRequest struct { // Required. The name of the worker to retrieve. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
GetWorkerRequest is the request message for GetWorker.
func (*GetWorkerRequest) Descriptor
deprecated
func (*GetWorkerRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkerRequest.ProtoReflect.Descriptor instead.
func (*GetWorkerRequest) GetName ¶
func (x *GetWorkerRequest) GetName() string
func (*GetWorkerRequest) ProtoMessage ¶
func (*GetWorkerRequest) ProtoMessage()
func (*GetWorkerRequest) ProtoReflect ¶
func (x *GetWorkerRequest) ProtoReflect() protoreflect.Message
func (*GetWorkerRequest) Reset ¶
func (x *GetWorkerRequest) Reset()
func (*GetWorkerRequest) String ¶
func (x *GetWorkerRequest) String() string
type ListWorkersRequest ¶
type ListWorkersRequest struct { // The maximum number of workers to return. // If not specified, the server will pick an appropriate default. PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // A page token, received from a previous `ListWorkers` call. // Provide this to retrieve the subsequent page. // When paginating, all other parameters provided to `ListWorkers` 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 to apply to list of workers. // Supports all fields of the `Worker` resource. Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"` // The order to apply to the list of workers. // 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 }
ListWorkersRequest is the request message for ListWorkers.
func (*ListWorkersRequest) Descriptor
deprecated
func (*ListWorkersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkersRequest.ProtoReflect.Descriptor instead.
func (*ListWorkersRequest) GetFilter ¶
func (x *ListWorkersRequest) GetFilter() string
func (*ListWorkersRequest) GetOrderBy ¶
func (x *ListWorkersRequest) GetOrderBy() string
func (*ListWorkersRequest) GetPageSize ¶
func (x *ListWorkersRequest) GetPageSize() int32
func (*ListWorkersRequest) GetPageToken ¶
func (x *ListWorkersRequest) GetPageToken() string
func (*ListWorkersRequest) ProtoMessage ¶
func (*ListWorkersRequest) ProtoMessage()
func (*ListWorkersRequest) ProtoReflect ¶
func (x *ListWorkersRequest) ProtoReflect() protoreflect.Message
func (*ListWorkersRequest) Reset ¶
func (x *ListWorkersRequest) Reset()
func (*ListWorkersRequest) String ¶
func (x *ListWorkersRequest) String() string
type ListWorkersResponse ¶
type ListWorkersResponse struct { // The workers belonging to the requested project. Workers []*Worker `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"` // A token, which can be sent as `page_token` to retrieve the next page. // If this field is omitted, there are no subsequent pages. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
ListWorkersResponse is the response message for ListWorkers.
func (*ListWorkersResponse) Descriptor
deprecated
func (*ListWorkersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkersResponse.ProtoReflect.Descriptor instead.
func (*ListWorkersResponse) GetNextPageToken ¶
func (x *ListWorkersResponse) GetNextPageToken() string
func (*ListWorkersResponse) GetWorkers ¶
func (x *ListWorkersResponse) GetWorkers() []*Worker
func (*ListWorkersResponse) ProtoMessage ¶
func (*ListWorkersResponse) ProtoMessage()
func (*ListWorkersResponse) ProtoReflect ¶
func (x *ListWorkersResponse) ProtoReflect() protoreflect.Message
func (*ListWorkersResponse) Reset ¶
func (x *ListWorkersResponse) Reset()
func (*ListWorkersResponse) String ¶
func (x *ListWorkersResponse) String() string
type MshipAdminClient ¶
type MshipAdminClient interface { // Gets a worker GetWorker(ctx context.Context, in *GetWorkerRequest, opts ...grpc.CallOption) (*Worker, error) // Lists the workers registered ListWorkers(ctx context.Context, in *ListWorkersRequest, opts ...grpc.CallOption) (*ListWorkersResponse, error) // (-- api-linter: core::0133::http-body=disabled // // aip.dev/not-precedent: See below in the CreateWorkerRequest. We only allow worker_id --) // // Creates a worker CreateWorker(ctx context.Context, in *CreateWorkerRequest, opts ...grpc.CallOption) (*Worker, error) // Deletes a worker // Worker cannot be deleted if it has created an entry. DeleteWorker(ctx context.Context, in *DeleteWorkerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Rescue an entry import attempt // This should be called after fixing patches that caused the import to fail. // This will re-run the import attempt. RescueEntryImport(ctx context.Context, in *RescueEntryImportRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Retract the entry // To be able to retract an entry, the entry must be in the `ARCHIVED` state. // This will allow an NVR to be re-imported. RetractEntry(ctx context.Context, in *RetractEntryRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) }
MshipAdminClient is the client API for MshipAdmin 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 NewMshipAdminClient ¶
func NewMshipAdminClient(cc grpc.ClientConnInterface) MshipAdminClient
type MshipAdminServer ¶
type MshipAdminServer interface { // Gets a worker GetWorker(context.Context, *GetWorkerRequest) (*Worker, error) // Lists the workers registered ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error) // (-- api-linter: core::0133::http-body=disabled // // aip.dev/not-precedent: See below in the CreateWorkerRequest. We only allow worker_id --) // // Creates a worker CreateWorker(context.Context, *CreateWorkerRequest) (*Worker, error) // Deletes a worker // Worker cannot be deleted if it has created an entry. DeleteWorker(context.Context, *DeleteWorkerRequest) (*emptypb.Empty, error) // Rescue an entry import attempt // This should be called after fixing patches that caused the import to fail. // This will re-run the import attempt. RescueEntryImport(context.Context, *RescueEntryImportRequest) (*emptypb.Empty, error) // Retract the entry // To be able to retract an entry, the entry must be in the `ARCHIVED` state. // This will allow an NVR to be re-imported. RetractEntry(context.Context, *RetractEntryRequest) (*longrunning.Operation, error) // contains filtered or unexported methods }
MshipAdminServer is the server API for MshipAdmin service. All implementations must embed UnimplementedMshipAdminServer for forward compatibility
type RescueEntryImportRequest ¶
type RescueEntryImportRequest struct { // Required. The name of the entry to rescue. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
RescueEntryImportRequest is the request message for RescueEntryImport.
func (*RescueEntryImportRequest) Descriptor
deprecated
func (*RescueEntryImportRequest) Descriptor() ([]byte, []int)
Deprecated: Use RescueEntryImportRequest.ProtoReflect.Descriptor instead.
func (*RescueEntryImportRequest) GetName ¶
func (x *RescueEntryImportRequest) GetName() string
func (*RescueEntryImportRequest) ProtoMessage ¶
func (*RescueEntryImportRequest) ProtoMessage()
func (*RescueEntryImportRequest) ProtoReflect ¶
func (x *RescueEntryImportRequest) ProtoReflect() protoreflect.Message
func (*RescueEntryImportRequest) Reset ¶
func (x *RescueEntryImportRequest) Reset()
func (*RescueEntryImportRequest) String ¶
func (x *RescueEntryImportRequest) String() string
type RetractEntryMetadata ¶
type RetractEntryMetadata 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 }
RetractEntryMetadata is the metadata message for RetractEntry.
func (*RetractEntryMetadata) Descriptor
deprecated
func (*RetractEntryMetadata) Descriptor() ([]byte, []int)
Deprecated: Use RetractEntryMetadata.ProtoReflect.Descriptor instead.
func (*RetractEntryMetadata) GetEndTime ¶
func (x *RetractEntryMetadata) GetEndTime() *timestamppb.Timestamp
func (*RetractEntryMetadata) GetStartTime ¶
func (x *RetractEntryMetadata) GetStartTime() *timestamppb.Timestamp
func (*RetractEntryMetadata) ProtoMessage ¶
func (*RetractEntryMetadata) ProtoMessage()
func (*RetractEntryMetadata) ProtoReflect ¶
func (x *RetractEntryMetadata) ProtoReflect() protoreflect.Message
func (*RetractEntryMetadata) Reset ¶
func (x *RetractEntryMetadata) Reset()
func (*RetractEntryMetadata) String ¶
func (x *RetractEntryMetadata) String() string
type RetractEntryRequest ¶
type RetractEntryRequest struct { // Required. The name of the entry to retract. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
RetractEntryRequest is the request message for RetractEntry.
func (*RetractEntryRequest) Descriptor
deprecated
func (*RetractEntryRequest) Descriptor() ([]byte, []int)
Deprecated: Use RetractEntryRequest.ProtoReflect.Descriptor instead.
func (*RetractEntryRequest) GetName ¶
func (x *RetractEntryRequest) GetName() string
func (*RetractEntryRequest) ProtoMessage ¶
func (*RetractEntryRequest) ProtoMessage()
func (*RetractEntryRequest) ProtoReflect ¶
func (x *RetractEntryRequest) ProtoReflect() protoreflect.Message
func (*RetractEntryRequest) Reset ¶
func (x *RetractEntryRequest) Reset()
func (*RetractEntryRequest) String ¶
func (x *RetractEntryRequest) String() string
type RetractEntryResponse ¶
type RetractEntryResponse struct { // The name of the entry that was retracted. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
RetractEntryResponse is the response message for RetractEntry.
func (*RetractEntryResponse) Descriptor
deprecated
func (*RetractEntryResponse) Descriptor() ([]byte, []int)
Deprecated: Use RetractEntryResponse.ProtoReflect.Descriptor instead.
func (*RetractEntryResponse) GetName ¶
func (x *RetractEntryResponse) GetName() string
func (*RetractEntryResponse) ProtoMessage ¶
func (*RetractEntryResponse) ProtoMessage()
func (*RetractEntryResponse) ProtoReflect ¶
func (x *RetractEntryResponse) ProtoReflect() protoreflect.Message
func (*RetractEntryResponse) Reset ¶
func (x *RetractEntryResponse) Reset()
func (*RetractEntryResponse) String ¶
func (x *RetractEntryResponse) String() string
type UnimplementedMshipAdminServer ¶
type UnimplementedMshipAdminServer struct { }
UnimplementedMshipAdminServer must be embedded to have forward compatible implementations.
func (UnimplementedMshipAdminServer) CreateWorker ¶
func (UnimplementedMshipAdminServer) CreateWorker(context.Context, *CreateWorkerRequest) (*Worker, error)
func (UnimplementedMshipAdminServer) DeleteWorker ¶
func (UnimplementedMshipAdminServer) DeleteWorker(context.Context, *DeleteWorkerRequest) (*emptypb.Empty, error)
func (UnimplementedMshipAdminServer) GetWorker ¶
func (UnimplementedMshipAdminServer) GetWorker(context.Context, *GetWorkerRequest) (*Worker, error)
func (UnimplementedMshipAdminServer) ListWorkers ¶
func (UnimplementedMshipAdminServer) ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)
func (UnimplementedMshipAdminServer) RescueEntryImport ¶
func (UnimplementedMshipAdminServer) RescueEntryImport(context.Context, *RescueEntryImportRequest) (*emptypb.Empty, error)
func (UnimplementedMshipAdminServer) RetractEntry ¶
func (UnimplementedMshipAdminServer) RetractEntry(context.Context, *RetractEntryRequest) (*longrunning.Operation, error)
type UnsafeMshipAdminServer ¶
type UnsafeMshipAdminServer interface {
// contains filtered or unexported methods
}
UnsafeMshipAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MshipAdminServer will result in compilation errors.
type Worker ¶
type Worker struct { // Output only. The resource name of the worker. // Format: `workers/{worker}` Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Unique identifier selected during creation. // Cannot be changed. Must conform to RFC-1034. WorkerId string `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"` // When the worker was created. CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Last check-in time of the worker. LastCheckinTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_checkin_time,json=lastCheckinTime,proto3" json:"last_checkin_time,omitempty"` // API secret that the worker should use to authenticate itself. // This is only returned when creating a new worker. // Can not be retrieved or changed later. ApiSecret string `protobuf:"bytes,5,opt,name=api_secret,json=apiSecret,proto3" json:"api_secret,omitempty"` // contains filtered or unexported fields }
Worker is a client registered with Mothership that can submit SRPMs. Usually these clients are servers that run the Linux distro that is being archived and staged. Only purpose of workers is to submit SRPMs and be able to identify who is submitting them.
func (*Worker) Descriptor
deprecated
func (*Worker) GetApiSecret ¶
func (*Worker) GetCreateTime ¶
func (x *Worker) GetCreateTime() *timestamppb.Timestamp
func (*Worker) GetLastCheckinTime ¶
func (x *Worker) GetLastCheckinTime() *timestamppb.Timestamp
func (*Worker) GetWorkerId ¶
func (*Worker) ProtoMessage ¶
func (*Worker) ProtoMessage()
func (*Worker) ProtoReflect ¶
func (x *Worker) ProtoReflect() protoreflect.Message