Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterProcessWrapperServer(s grpc.ServiceRegistrar, srv ProcessWrapperServer)
- type CheckStatusRequest
- type CheckStatusResponse
- func (*CheckStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckStatusResponse) GetFailureReason() string
- func (x *CheckStatusResponse) GetStatus() Status
- func (*CheckStatusResponse) ProtoMessage()
- func (x *CheckStatusResponse) ProtoReflect() protoreflect.Message
- func (x *CheckStatusResponse) Reset()
- func (x *CheckStatusResponse) String() string
- type InitForcefulShutdownRequest
- type InitForcefulShutdownResponse
- func (*InitForcefulShutdownResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InitForcefulShutdownResponse) GetFailureReason() string
- func (x *InitForcefulShutdownResponse) GetStatus() Status
- func (*InitForcefulShutdownResponse) ProtoMessage()
- func (x *InitForcefulShutdownResponse) ProtoReflect() protoreflect.Message
- func (x *InitForcefulShutdownResponse) Reset()
- func (x *InitForcefulShutdownResponse) String() string
- type InitGracefulShutdownRequest
- func (*InitGracefulShutdownRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InitGracefulShutdownRequest) GetShutdownCallback() *ShutdownCallback
- func (*InitGracefulShutdownRequest) ProtoMessage()
- func (x *InitGracefulShutdownRequest) ProtoReflect() protoreflect.Message
- func (x *InitGracefulShutdownRequest) Reset()
- func (x *InitGracefulShutdownRequest) String() string
- type InitGracefulShutdownResponse
- func (*InitGracefulShutdownResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InitGracefulShutdownResponse) GetFailureReason() string
- func (x *InitGracefulShutdownResponse) GetStatus() Status
- func (*InitGracefulShutdownResponse) ProtoMessage()
- func (x *InitGracefulShutdownResponse) ProtoReflect() protoreflect.Message
- func (x *InitGracefulShutdownResponse) Reset()
- func (x *InitGracefulShutdownResponse) String() string
- type ProcessWrapperClient
- type ProcessWrapperServer
- type ShutdownCallback
- func (*ShutdownCallback) Descriptor() ([]byte, []int)deprecated
- func (x *ShutdownCallback) GetHeaders() map[string]string
- func (x *ShutdownCallback) GetMethod() string
- func (x *ShutdownCallback) GetUrl() string
- func (*ShutdownCallback) ProtoMessage()
- func (x *ShutdownCallback) ProtoReflect() protoreflect.Message
- func (x *ShutdownCallback) Reset()
- func (x *ShutdownCallback) String() string
- type Status
- type UnimplementedProcessWrapperServer
- func (UnimplementedProcessWrapperServer) CheckStatus(context.Context, *CheckStatusRequest) (*CheckStatusResponse, error)
- func (UnimplementedProcessWrapperServer) InitForcefulShutdown(context.Context, *InitForcefulShutdownRequest) (*InitForcefulShutdownResponse, error)
- func (UnimplementedProcessWrapperServer) InitGracefulShutdown(context.Context, *InitGracefulShutdownRequest) (*InitGracefulShutdownResponse, error)
- type UnsafeProcessWrapperServer
Constants ¶
const ( ProcessWrapper_CheckStatus_FullMethodName = "/gitlab_com.gitlab_runner.runner_wrapper.ProcessWrapper/CheckStatus" ProcessWrapper_InitGracefulShutdown_FullMethodName = "/gitlab_com.gitlab_runner.runner_wrapper.ProcessWrapper/InitGracefulShutdown" ProcessWrapper_InitForcefulShutdown_FullMethodName = "/gitlab_com.gitlab_runner.runner_wrapper.ProcessWrapper/InitForcefulShutdown" )
Variables ¶
var ( Status_name = map[int32]string{ 0: "unknown", 1: "running", 2: "in_shutdown", 3: "stopped", } Status_value = map[string]int32{ "unknown": 0, "running": 1, "in_shutdown": 2, "stopped": 3, } )
Enum value maps for Status.
var File_proto_wrapper_proto protoreflect.FileDescriptor
var ProcessWrapper_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gitlab_com.gitlab_runner.runner_wrapper.ProcessWrapper", HandlerType: (*ProcessWrapperServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CheckStatus", Handler: _ProcessWrapper_CheckStatus_Handler, }, { MethodName: "InitGracefulShutdown", Handler: _ProcessWrapper_InitGracefulShutdown_Handler, }, { MethodName: "InitForcefulShutdown", Handler: _ProcessWrapper_InitForcefulShutdown_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/wrapper.proto", }
ProcessWrapper_ServiceDesc is the grpc.ServiceDesc for ProcessWrapper service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterProcessWrapperServer ¶
func RegisterProcessWrapperServer(s grpc.ServiceRegistrar, srv ProcessWrapperServer)
Types ¶
type CheckStatusRequest ¶
type CheckStatusRequest struct {
// contains filtered or unexported fields
}
func (*CheckStatusRequest) Descriptor
deprecated
func (*CheckStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckStatusRequest.ProtoReflect.Descriptor instead.
func (*CheckStatusRequest) ProtoMessage ¶
func (*CheckStatusRequest) ProtoMessage()
func (*CheckStatusRequest) ProtoReflect ¶
func (x *CheckStatusRequest) ProtoReflect() protoreflect.Message
func (*CheckStatusRequest) Reset ¶
func (x *CheckStatusRequest) Reset()
func (*CheckStatusRequest) String ¶
func (x *CheckStatusRequest) String() string
type CheckStatusResponse ¶
type CheckStatusResponse struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=gitlab_com.gitlab_runner.runner_wrapper.Status" json:"status,omitempty"` FailureReason string `protobuf:"bytes,2,opt,name=failureReason,proto3" json:"failureReason,omitempty"` // contains filtered or unexported fields }
func (*CheckStatusResponse) Descriptor
deprecated
func (*CheckStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckStatusResponse.ProtoReflect.Descriptor instead.
func (*CheckStatusResponse) GetFailureReason ¶
func (x *CheckStatusResponse) GetFailureReason() string
func (*CheckStatusResponse) GetStatus ¶
func (x *CheckStatusResponse) GetStatus() Status
func (*CheckStatusResponse) ProtoMessage ¶
func (*CheckStatusResponse) ProtoMessage()
func (*CheckStatusResponse) ProtoReflect ¶
func (x *CheckStatusResponse) ProtoReflect() protoreflect.Message
func (*CheckStatusResponse) Reset ¶
func (x *CheckStatusResponse) Reset()
func (*CheckStatusResponse) String ¶
func (x *CheckStatusResponse) String() string
type InitForcefulShutdownRequest ¶
type InitForcefulShutdownRequest struct {
// contains filtered or unexported fields
}
func (*InitForcefulShutdownRequest) Descriptor
deprecated
func (*InitForcefulShutdownRequest) Descriptor() ([]byte, []int)
Deprecated: Use InitForcefulShutdownRequest.ProtoReflect.Descriptor instead.
func (*InitForcefulShutdownRequest) ProtoMessage ¶
func (*InitForcefulShutdownRequest) ProtoMessage()
func (*InitForcefulShutdownRequest) ProtoReflect ¶
func (x *InitForcefulShutdownRequest) ProtoReflect() protoreflect.Message
func (*InitForcefulShutdownRequest) Reset ¶
func (x *InitForcefulShutdownRequest) Reset()
func (*InitForcefulShutdownRequest) String ¶
func (x *InitForcefulShutdownRequest) String() string
type InitForcefulShutdownResponse ¶
type InitForcefulShutdownResponse struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=gitlab_com.gitlab_runner.runner_wrapper.Status" json:"status,omitempty"` FailureReason string `protobuf:"bytes,2,opt,name=failureReason,proto3" json:"failureReason,omitempty"` // contains filtered or unexported fields }
func (*InitForcefulShutdownResponse) Descriptor
deprecated
func (*InitForcefulShutdownResponse) Descriptor() ([]byte, []int)
Deprecated: Use InitForcefulShutdownResponse.ProtoReflect.Descriptor instead.
func (*InitForcefulShutdownResponse) GetFailureReason ¶
func (x *InitForcefulShutdownResponse) GetFailureReason() string
func (*InitForcefulShutdownResponse) GetStatus ¶
func (x *InitForcefulShutdownResponse) GetStatus() Status
func (*InitForcefulShutdownResponse) ProtoMessage ¶
func (*InitForcefulShutdownResponse) ProtoMessage()
func (*InitForcefulShutdownResponse) ProtoReflect ¶
func (x *InitForcefulShutdownResponse) ProtoReflect() protoreflect.Message
func (*InitForcefulShutdownResponse) Reset ¶
func (x *InitForcefulShutdownResponse) Reset()
func (*InitForcefulShutdownResponse) String ¶
func (x *InitForcefulShutdownResponse) String() string
type InitGracefulShutdownRequest ¶
type InitGracefulShutdownRequest struct { ShutdownCallback *ShutdownCallback `protobuf:"bytes,1,opt,name=shutdownCallback,proto3" json:"shutdownCallback,omitempty"` // contains filtered or unexported fields }
func (*InitGracefulShutdownRequest) Descriptor
deprecated
func (*InitGracefulShutdownRequest) Descriptor() ([]byte, []int)
Deprecated: Use InitGracefulShutdownRequest.ProtoReflect.Descriptor instead.
func (*InitGracefulShutdownRequest) GetShutdownCallback ¶
func (x *InitGracefulShutdownRequest) GetShutdownCallback() *ShutdownCallback
func (*InitGracefulShutdownRequest) ProtoMessage ¶
func (*InitGracefulShutdownRequest) ProtoMessage()
func (*InitGracefulShutdownRequest) ProtoReflect ¶
func (x *InitGracefulShutdownRequest) ProtoReflect() protoreflect.Message
func (*InitGracefulShutdownRequest) Reset ¶
func (x *InitGracefulShutdownRequest) Reset()
func (*InitGracefulShutdownRequest) String ¶
func (x *InitGracefulShutdownRequest) String() string
type InitGracefulShutdownResponse ¶
type InitGracefulShutdownResponse struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=gitlab_com.gitlab_runner.runner_wrapper.Status" json:"status,omitempty"` FailureReason string `protobuf:"bytes,2,opt,name=failureReason,proto3" json:"failureReason,omitempty"` // contains filtered or unexported fields }
func (*InitGracefulShutdownResponse) Descriptor
deprecated
func (*InitGracefulShutdownResponse) Descriptor() ([]byte, []int)
Deprecated: Use InitGracefulShutdownResponse.ProtoReflect.Descriptor instead.
func (*InitGracefulShutdownResponse) GetFailureReason ¶
func (x *InitGracefulShutdownResponse) GetFailureReason() string
func (*InitGracefulShutdownResponse) GetStatus ¶
func (x *InitGracefulShutdownResponse) GetStatus() Status
func (*InitGracefulShutdownResponse) ProtoMessage ¶
func (*InitGracefulShutdownResponse) ProtoMessage()
func (*InitGracefulShutdownResponse) ProtoReflect ¶
func (x *InitGracefulShutdownResponse) ProtoReflect() protoreflect.Message
func (*InitGracefulShutdownResponse) Reset ¶
func (x *InitGracefulShutdownResponse) Reset()
func (*InitGracefulShutdownResponse) String ¶
func (x *InitGracefulShutdownResponse) String() string
type ProcessWrapperClient ¶
type ProcessWrapperClient interface { CheckStatus(ctx context.Context, in *CheckStatusRequest, opts ...grpc.CallOption) (*CheckStatusResponse, error) InitGracefulShutdown(ctx context.Context, in *InitGracefulShutdownRequest, opts ...grpc.CallOption) (*InitGracefulShutdownResponse, error) InitForcefulShutdown(ctx context.Context, in *InitForcefulShutdownRequest, opts ...grpc.CallOption) (*InitForcefulShutdownResponse, error) }
ProcessWrapperClient is the client API for ProcessWrapper 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 NewProcessWrapperClient ¶
func NewProcessWrapperClient(cc grpc.ClientConnInterface) ProcessWrapperClient
type ProcessWrapperServer ¶
type ProcessWrapperServer interface { CheckStatus(context.Context, *CheckStatusRequest) (*CheckStatusResponse, error) InitGracefulShutdown(context.Context, *InitGracefulShutdownRequest) (*InitGracefulShutdownResponse, error) InitForcefulShutdown(context.Context, *InitForcefulShutdownRequest) (*InitForcefulShutdownResponse, error) // contains filtered or unexported methods }
ProcessWrapperServer is the server API for ProcessWrapper service. All implementations must embed UnimplementedProcessWrapperServer for forward compatibility.
type ShutdownCallback ¶
type ShutdownCallback struct { Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` Headers map[string]string `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ShutdownCallback) Descriptor
deprecated
func (*ShutdownCallback) Descriptor() ([]byte, []int)
Deprecated: Use ShutdownCallback.ProtoReflect.Descriptor instead.
func (*ShutdownCallback) GetHeaders ¶
func (x *ShutdownCallback) GetHeaders() map[string]string
func (*ShutdownCallback) GetMethod ¶
func (x *ShutdownCallback) GetMethod() string
func (*ShutdownCallback) GetUrl ¶
func (x *ShutdownCallback) GetUrl() string
func (*ShutdownCallback) ProtoMessage ¶
func (*ShutdownCallback) ProtoMessage()
func (*ShutdownCallback) ProtoReflect ¶
func (x *ShutdownCallback) ProtoReflect() protoreflect.Message
func (*ShutdownCallback) Reset ¶
func (x *ShutdownCallback) Reset()
func (*ShutdownCallback) String ¶
func (x *ShutdownCallback) String() string
type Status ¶
type Status int32
func (Status) Descriptor ¶
func (Status) Descriptor() protoreflect.EnumDescriptor
func (Status) EnumDescriptor
deprecated
func (Status) Number ¶
func (x Status) Number() protoreflect.EnumNumber
func (Status) Type ¶
func (Status) Type() protoreflect.EnumType
type UnimplementedProcessWrapperServer ¶
type UnimplementedProcessWrapperServer struct{}
UnimplementedProcessWrapperServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedProcessWrapperServer) CheckStatus ¶
func (UnimplementedProcessWrapperServer) CheckStatus(context.Context, *CheckStatusRequest) (*CheckStatusResponse, error)
func (UnimplementedProcessWrapperServer) InitForcefulShutdown ¶
func (UnimplementedProcessWrapperServer) InitForcefulShutdown(context.Context, *InitForcefulShutdownRequest) (*InitForcefulShutdownResponse, error)
func (UnimplementedProcessWrapperServer) InitGracefulShutdown ¶
func (UnimplementedProcessWrapperServer) InitGracefulShutdown(context.Context, *InitGracefulShutdownRequest) (*InitGracefulShutdownResponse, error)
type UnsafeProcessWrapperServer ¶
type UnsafeProcessWrapperServer interface {
// contains filtered or unexported methods
}
UnsafeProcessWrapperServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProcessWrapperServer will result in compilation errors.