rpc

package
v0.0.0-...-dcf77fd Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2021 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	LogDevice_name = map[int32]string{
		0: "STDOUT",
		1: "STDERR",
	}
	LogDevice_value = map[string]int32{
		"STDOUT": 0,
		"STDERR": 1,
	}
)

Enum value maps for LogDevice.

View Source 
var (
	ProcessSignal_name = map[int32]string{
		0: "HUP",
		1: "INT",
		2: "QUIT",
		3: "KILL",
		4: "USR1",
		5: "USR2",
		6: "TERM",
		7: "STOP",
		8: "CONT",
	}
	ProcessSignal_value = map[string]int32{
		"HUP":  0,
		"INT":  1,
		"QUIT": 2,
		"KILL": 3,
		"USR1": 4,
		"USR2": 5,
		"TERM": 6,
		"STOP": 7,
		"CONT": 8,
	}
)

Enum value maps for ProcessSignal.

View Source 
var (
	ProcessState_name = map[int32]string{
		0:    "STOPPED",
		10:   "STARTING",
		20:   "RUNNING",
		30:   "BACKOFF",
		40:   "STOPPING",
		100:  "EXITED",
		200:  "FATAL",
		1000: "UNKNOWN",
	}
	ProcessState_value = map[string]int32{
		"STOPPED":  0,
		"STARTING": 10,
		"RUNNING":  20,
		"BACKOFF":  30,
		"STOPPING": 40,
		"EXITED":   100,
		"FATAL":    200,
		"UNKNOWN":  1000,
	}
)

Enum value maps for ProcessState.

View Source 
var File_service_proto protoreflect.FileDescriptor
View Source 
var Gopm_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gopm.rpc.Gopm",
	HandlerType: (*GopmServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetVersion",
			Handler:    _Gopm_GetVersion_Handler,
		},
		{
			MethodName: "GetProcessInfo",
			Handler:    _Gopm_GetProcessInfo_Handler,
		},
		{
			MethodName: "StartProcess",
			Handler:    _Gopm_StartProcess_Handler,
		},
		{
			MethodName: "StopProcess",
			Handler:    _Gopm_StopProcess_Handler,
		},
		{
			MethodName: "RestartProcess",
			Handler:    _Gopm_RestartProcess_Handler,
		},
		{
			MethodName: "StartAllProcesses",
			Handler:    _Gopm_StartAllProcesses_Handler,
		},
		{
			MethodName: "StopAllProcesses",
			Handler:    _Gopm_StopAllProcesses_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _Gopm_Shutdown_Handler,
		},
		{
			MethodName: "ReloadConfig",
			Handler:    _Gopm_ReloadConfig_Handler,
		},
		{
			MethodName: "SignalProcess",
			Handler:    _Gopm_SignalProcess_Handler,
		},
		{
			MethodName: "SignalProcessGroup",
			Handler:    _Gopm_SignalProcessGroup_Handler,
		},
		{
			MethodName: "SignalAllProcesses",
			Handler:    _Gopm_SignalAllProcesses_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "TailLog",
			Handler:       _Gopm_TailLog_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "service.proto",
}

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

Functions

func RegisterGopmServer 

func RegisterGopmServer(s grpc.ServiceRegistrar, srv GopmServer)

Types

type GopmClient 

type GopmClient interface {
	GetVersion(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*VersionResponse, error)
	GetProcessInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ProcessInfoResponse, error)
	StartProcess(ctx context.Context, in *StartStopRequest, opts ...grpc.CallOption) (*StartStopResponse, error)
	StopProcess(ctx context.Context, in *StartStopRequest, opts ...grpc.CallOption) (*StartStopResponse, error)
	RestartProcess(ctx context.Context, in *StartStopRequest, opts ...grpc.CallOption) (*StartStopResponse, error)
	StartAllProcesses(ctx context.Context, in *StartStopAllRequest, opts ...grpc.CallOption) (*ProcessInfoResponse, error)
	StopAllProcesses(ctx context.Context, in *StartStopAllRequest, opts ...grpc.CallOption) (*ProcessInfoResponse, error)
	Shutdown(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReloadConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReloadConfigResponse, error)
	TailLog(ctx context.Context, in *TailLogRequest, opts ...grpc.CallOption) (Gopm_TailLogClient, error)
	SignalProcess(ctx context.Context, in *SignalProcessRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SignalProcessGroup(ctx context.Context, in *SignalProcessRequest, opts ...grpc.CallOption) (*ProcessInfoResponse, error)
	SignalAllProcesses(ctx context.Context, in *SignalProcessRequest, opts ...grpc.CallOption) (*ProcessInfoResponse, error)
}

GopmClient is the client API for Gopm 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 NewGopmClient 

func NewGopmClient(cc grpc.ClientConnInterface) GopmClient

type GopmServer 

type GopmServer interface {
	GetVersion(context.Context, *emptypb.Empty) (*VersionResponse, error)
	GetProcessInfo(context.Context, *emptypb.Empty) (*ProcessInfoResponse, error)
	StartProcess(context.Context, *StartStopRequest) (*StartStopResponse, error)
	StopProcess(context.Context, *StartStopRequest) (*StartStopResponse, error)
	RestartProcess(context.Context, *StartStopRequest) (*StartStopResponse, error)
	StartAllProcesses(context.Context, *StartStopAllRequest) (*ProcessInfoResponse, error)
	StopAllProcesses(context.Context, *StartStopAllRequest) (*ProcessInfoResponse, error)
	Shutdown(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	ReloadConfig(context.Context, *emptypb.Empty) (*ReloadConfigResponse, error)
	TailLog(*TailLogRequest, Gopm_TailLogServer) error
	SignalProcess(context.Context, *SignalProcessRequest) (*emptypb.Empty, error)
	SignalProcessGroup(context.Context, *SignalProcessRequest) (*ProcessInfoResponse, error)
	SignalAllProcesses(context.Context, *SignalProcessRequest) (*ProcessInfoResponse, error)
	// contains filtered or unexported methods
}

GopmServer is the server API for Gopm service. All implementations must embed UnimplementedGopmServer for forward compatibility

type Gopm_TailLogClient 

type Gopm_TailLogClient interface {
	Recv() (*TailLogResponse, error)
	grpc.ClientStream
}

type Gopm_TailLogServer 

type Gopm_TailLogServer interface {
	Send(*TailLogResponse) error
	grpc.ServerStream
}

type LogDevice 

type LogDevice int32
const (
	LogDevice_STDOUT LogDevice = 0
	LogDevice_STDERR LogDevice = 1
)

func (LogDevice) Descriptor 

func (LogDevice) Descriptor() protoreflect.EnumDescriptor

func (LogDevice) Enum 

func (x LogDevice) Enum() *LogDevice

func (LogDevice) EnumDescriptor deprecated 

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

Deprecated: Use LogDevice.Descriptor instead.

func (LogDevice) Number 

func (x LogDevice) Number() protoreflect.EnumNumber

func (LogDevice) String 

func (x LogDevice) String() string

func (LogDevice) Type 

func (LogDevice) Type() protoreflect.EnumType

type ProcessInfo 

type ProcessInfo struct {
	Name          string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Group         string       `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	Description   string       `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Start         int64        `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty"`
	Stop          int64        `protobuf:"varint,5,opt,name=stop,proto3" json:"stop,omitempty"`
	Now           int64        `protobuf:"varint,6,opt,name=now,proto3" json:"now,omitempty"`
	State         ProcessState `protobuf:"varint,7,opt,name=state,proto3,enum=gopm.rpc.ProcessState" json:"state,omitempty"`
	StateName     string       `protobuf:"bytes,8,opt,name=state_name,json=stateName,proto3" json:"state_name,omitempty"`
	SpawnErr      string       `protobuf:"bytes,9,opt,name=spawn_err,json=spawnErr,proto3" json:"spawn_err,omitempty"`
	ExitStatus    int64        `protobuf:"varint,10,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	Logfile       string       `protobuf:"bytes,11,opt,name=logfile,proto3" json:"logfile,omitempty"`
	StdoutLogfile string       `protobuf:"bytes,12,opt,name=stdout_logfile,json=stdoutLogfile,proto3" json:"stdout_logfile,omitempty"`
	StderrLogfile string       `protobuf:"bytes,13,opt,name=stderr_logfile,json=stderrLogfile,proto3" json:"stderr_logfile,omitempty"`
	Pid           int64        `protobuf:"varint,14,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessInfo) Descriptor deprecated 

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

Deprecated: Use ProcessInfo.ProtoReflect.Descriptor instead.

func (*ProcessInfo) GetDescription 

func (x *ProcessInfo) GetDescription() string

func (*ProcessInfo) GetExitStatus 

func (x *ProcessInfo) GetExitStatus() int64

func (*ProcessInfo) GetFullName 

func (x *ProcessInfo) GetFullName() string

GetFullName get the full name of program includes group and name

func (*ProcessInfo) GetGroup 

func (x *ProcessInfo) GetGroup() string

func (*ProcessInfo) GetLogfile 

func (x *ProcessInfo) GetLogfile() string

func (*ProcessInfo) GetName 

func (x *ProcessInfo) GetName() string

func (*ProcessInfo) GetNow 

func (x *ProcessInfo) GetNow() int64

func (*ProcessInfo) GetPid 

func (x *ProcessInfo) GetPid() int64

func (*ProcessInfo) GetSpawnErr 

func (x *ProcessInfo) GetSpawnErr() string

func (*ProcessInfo) GetStart 

func (x *ProcessInfo) GetStart() int64

func (*ProcessInfo) GetState 

func (x *ProcessInfo) GetState() ProcessState

func (*ProcessInfo) GetStateName 

func (x *ProcessInfo) GetStateName() string

func (*ProcessInfo) GetStderrLogfile 

func (x *ProcessInfo) GetStderrLogfile() string

func (*ProcessInfo) GetStdoutLogfile 

func (x *ProcessInfo) GetStdoutLogfile() string

func (*ProcessInfo) GetStop 

func (x *ProcessInfo) GetStop() int64

func (*ProcessInfo) ProtoMessage 

func (*ProcessInfo) ProtoMessage()

func (*ProcessInfo) ProtoReflect 

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

func (*ProcessInfo) Reset 

func (x *ProcessInfo) Reset()

func (*ProcessInfo) String 

func (x *ProcessInfo) String() string

type ProcessInfoResponse 

type ProcessInfoResponse struct {
	Processes []*ProcessInfo `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessInfoResponse) Descriptor deprecated 

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

Deprecated: Use ProcessInfoResponse.ProtoReflect.Descriptor instead.

func (*ProcessInfoResponse) GetProcesses 

func (x *ProcessInfoResponse) GetProcesses() []*ProcessInfo

func (*ProcessInfoResponse) ProtoMessage 

func (*ProcessInfoResponse) ProtoMessage()

func (*ProcessInfoResponse) ProtoReflect 

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

func (*ProcessInfoResponse) Reset 

func (x *ProcessInfoResponse) Reset()

func (*ProcessInfoResponse) String 

func (x *ProcessInfoResponse) String() string

type ProcessInfos 

type ProcessInfos []*ProcessInfo

func (ProcessInfos) SortByName 

func (pi ProcessInfos) SortByName()

type ProcessSignal 

type ProcessSignal int32
const (
	ProcessSignal_HUP  ProcessSignal = 0
	ProcessSignal_INT  ProcessSignal = 1
	ProcessSignal_QUIT ProcessSignal = 2
	ProcessSignal_KILL ProcessSignal = 3
	ProcessSignal_USR1 ProcessSignal = 4
	ProcessSignal_USR2 ProcessSignal = 5
	ProcessSignal_TERM ProcessSignal = 6
	ProcessSignal_STOP ProcessSignal = 7
	ProcessSignal_CONT ProcessSignal = 8
)

func (ProcessSignal) Descriptor 

func (ProcessSignal) Descriptor() protoreflect.EnumDescriptor

func (ProcessSignal) Enum 

func (x ProcessSignal) Enum() *ProcessSignal

func (ProcessSignal) EnumDescriptor deprecated 

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

Deprecated: Use ProcessSignal.Descriptor instead.

func (ProcessSignal) Number 

func (x ProcessSignal) Number() protoreflect.EnumNumber

func (ProcessSignal) String 

func (x ProcessSignal) String() string

func (ProcessSignal) ToSignal 

func (x ProcessSignal) ToSignal() (os.Signal, error)

func (ProcessSignal) Type 

func (ProcessSignal) Type() protoreflect.EnumType

type ProcessState 

type ProcessState int32
const (
	ProcessState_STOPPED  ProcessState = 0
	ProcessState_STARTING ProcessState = 10
	ProcessState_RUNNING  ProcessState = 20
	ProcessState_BACKOFF  ProcessState = 30
	ProcessState_STOPPING ProcessState = 40
	ProcessState_EXITED   ProcessState = 100
	ProcessState_FATAL    ProcessState = 200
	ProcessState_UNKNOWN  ProcessState = 1000
)

func (ProcessState) Descriptor 

func (ProcessState) Descriptor() protoreflect.EnumDescriptor

func (ProcessState) Enum 

func (x ProcessState) Enum() *ProcessState

func (ProcessState) EnumDescriptor deprecated 

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

Deprecated: Use ProcessState.Descriptor instead.

func (ProcessState) Number 

func (x ProcessState) Number() protoreflect.EnumNumber

func (ProcessState) String 

func (x ProcessState) String() string

func (ProcessState) Type 

func (ProcessState) Type() protoreflect.EnumType

type ReloadConfigResponse 

type ReloadConfigResponse struct {
	AddedGroup   []string `protobuf:"bytes,1,rep,name=added_group,json=addedGroup,proto3" json:"added_group,omitempty"`
	ChangedGroup []string `protobuf:"bytes,2,rep,name=changed_group,json=changedGroup,proto3" json:"changed_group,omitempty"`
	RemovedGroup []string `protobuf:"bytes,3,rep,name=removed_group,json=removedGroup,proto3" json:"removed_group,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadConfigResponse) Descriptor deprecated 

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

Deprecated: Use ReloadConfigResponse.ProtoReflect.Descriptor instead.

func (*ReloadConfigResponse) GetAddedGroup 

func (x *ReloadConfigResponse) GetAddedGroup() []string

func (*ReloadConfigResponse) GetChangedGroup 

func (x *ReloadConfigResponse) GetChangedGroup() []string

func (*ReloadConfigResponse) GetRemovedGroup 

func (x *ReloadConfigResponse) GetRemovedGroup() []string

func (*ReloadConfigResponse) ProtoMessage 

func (*ReloadConfigResponse) ProtoMessage()

func (*ReloadConfigResponse) ProtoReflect 

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

func (*ReloadConfigResponse) Reset 

func (x *ReloadConfigResponse) Reset()

func (*ReloadConfigResponse) String 

func (x *ReloadConfigResponse) String() string

type SignalProcessRequest 

type SignalProcessRequest struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Signal ProcessSignal     `protobuf:"varint,2,opt,name=signal,proto3,enum=gopm.rpc.ProcessSignal" json:"signal,omitempty"`
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SignalProcessRequest) Descriptor deprecated 

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

Deprecated: Use SignalProcessRequest.ProtoReflect.Descriptor instead.

func (*SignalProcessRequest) GetLabels 

func (x *SignalProcessRequest) GetLabels() map[string]string

func (*SignalProcessRequest) GetName 

func (x *SignalProcessRequest) GetName() string

func (*SignalProcessRequest) GetSignal 

func (x *SignalProcessRequest) GetSignal() ProcessSignal

func (*SignalProcessRequest) ProtoMessage 

func (*SignalProcessRequest) ProtoMessage()

func (*SignalProcessRequest) ProtoReflect 

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

func (*SignalProcessRequest) Reset 

func (x *SignalProcessRequest) Reset()

func (*SignalProcessRequest) String 

func (x *SignalProcessRequest) String() string

type StartStopAllRequest 

type StartStopAllRequest struct {
	Wait bool `protobuf:"varint,2,opt,name=wait,proto3" json:"wait,omitempty"`
	// contains filtered or unexported fields
}

func (*StartStopAllRequest) Descriptor deprecated 

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

Deprecated: Use StartStopAllRequest.ProtoReflect.Descriptor instead.

func (*StartStopAllRequest) GetWait 

func (x *StartStopAllRequest) GetWait() bool

func (*StartStopAllRequest) ProtoMessage 

func (*StartStopAllRequest) ProtoMessage()

func (*StartStopAllRequest) ProtoReflect 

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

func (*StartStopAllRequest) Reset 

func (x *StartStopAllRequest) Reset()

func (*StartStopAllRequest) String 

func (x *StartStopAllRequest) String() string

type StartStopRequest 

type StartStopRequest struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Wait   bool              `protobuf:"varint,2,opt,name=wait,proto3" json:"wait,omitempty"`
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StartStopRequest) Descriptor deprecated 

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

Deprecated: Use StartStopRequest.ProtoReflect.Descriptor instead.

func (*StartStopRequest) GetLabels 

func (x *StartStopRequest) GetLabels() map[string]string

func (*StartStopRequest) GetName 

func (x *StartStopRequest) GetName() string

func (*StartStopRequest) GetWait 

func (x *StartStopRequest) GetWait() bool

func (*StartStopRequest) ProtoMessage 

func (*StartStopRequest) ProtoMessage()

func (*StartStopRequest) ProtoReflect 

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

func (*StartStopRequest) Reset 

func (x *StartStopRequest) Reset()

func (*StartStopRequest) String 

func (x *StartStopRequest) String() string

type StartStopResponse 

type StartStopResponse struct {
	// contains filtered or unexported fields
}

func (*StartStopResponse) Descriptor deprecated 

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

Deprecated: Use StartStopResponse.ProtoReflect.Descriptor instead.

func (*StartStopResponse) ProtoMessage 

func (*StartStopResponse) ProtoMessage()

func (*StartStopResponse) ProtoReflect 

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

func (*StartStopResponse) Reset 

func (x *StartStopResponse) Reset()

func (*StartStopResponse) String 

func (x *StartStopResponse) String() string

type TailLogRequest 

type TailLogRequest struct {
	Name         string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Device       LogDevice `protobuf:"varint,2,opt,name=device,proto3,enum=gopm.rpc.LogDevice" json:"device,omitempty"`
	BacklogLines int64     `protobuf:"varint,3,opt,name=backlogLines,proto3" json:"backlogLines,omitempty"`
	NoFollow     bool      `protobuf:"varint,4,opt,name=noFollow,proto3" json:"noFollow,omitempty"`
	// contains filtered or unexported fields
}

func (*TailLogRequest) Descriptor deprecated 

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

Deprecated: Use TailLogRequest.ProtoReflect.Descriptor instead.

func (*TailLogRequest) GetBacklogLines 

func (x *TailLogRequest) GetBacklogLines() int64

func (*TailLogRequest) GetDevice 

func (x *TailLogRequest) GetDevice() LogDevice

func (*TailLogRequest) GetName 

func (x *TailLogRequest) GetName() string

func (*TailLogRequest) GetNoFollow 

func (x *TailLogRequest) GetNoFollow() bool

func (*TailLogRequest) ProtoMessage 

func (*TailLogRequest) ProtoMessage()

func (*TailLogRequest) ProtoReflect 

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

func (*TailLogRequest) Reset 

func (x *TailLogRequest) Reset()

func (*TailLogRequest) String 

func (x *TailLogRequest) String() string

type TailLogResponse 

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

func (*TailLogResponse) Descriptor deprecated 

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

Deprecated: Use TailLogResponse.ProtoReflect.Descriptor instead.

func (*TailLogResponse) GetLines 

func (x *TailLogResponse) GetLines() []byte

func (*TailLogResponse) ProtoMessage 

func (*TailLogResponse) ProtoMessage()

func (*TailLogResponse) ProtoReflect 

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

func (*TailLogResponse) Reset 

func (x *TailLogResponse) Reset()

func (*TailLogResponse) String 

func (x *TailLogResponse) String() string

type UnimplementedGopmServer 

type UnimplementedGopmServer struct {
}

UnimplementedGopmServer must be embedded to have forward compatible implementations.

func (UnimplementedGopmServer) GetProcessInfo 

func (UnimplementedGopmServer) GetProcessInfo(context.Context, *emptypb.Empty) (*ProcessInfoResponse, error)

func (UnimplementedGopmServer) GetVersion 

func (UnimplementedGopmServer) GetVersion(context.Context, *emptypb.Empty) (*VersionResponse, error)

func (UnimplementedGopmServer) ReloadConfig 

func (UnimplementedGopmServer) ReloadConfig(context.Context, *emptypb.Empty) (*ReloadConfigResponse, error)

func (UnimplementedGopmServer) RestartProcess 

func (UnimplementedGopmServer) RestartProcess(context.Context, *StartStopRequest) (*StartStopResponse, error)

func (UnimplementedGopmServer) Shutdown 

func (UnimplementedGopmServer) Shutdown(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedGopmServer) SignalAllProcesses 

func (UnimplementedGopmServer) SignalAllProcesses(context.Context, *SignalProcessRequest) (*ProcessInfoResponse, error)

func (UnimplementedGopmServer) SignalProcess 

func (UnimplementedGopmServer) SignalProcess(context.Context, *SignalProcessRequest) (*emptypb.Empty, error)

func (UnimplementedGopmServer) SignalProcessGroup 

func (UnimplementedGopmServer) SignalProcessGroup(context.Context, *SignalProcessRequest) (*ProcessInfoResponse, error)

func (UnimplementedGopmServer) StartAllProcesses 

func (UnimplementedGopmServer) StartAllProcesses(context.Context, *StartStopAllRequest) (*ProcessInfoResponse, error)

func (UnimplementedGopmServer) StartProcess 

func (UnimplementedGopmServer) StartProcess(context.Context, *StartStopRequest) (*StartStopResponse, error)

func (UnimplementedGopmServer) StopAllProcesses 

func (UnimplementedGopmServer) StopAllProcesses(context.Context, *StartStopAllRequest) (*ProcessInfoResponse, error)

func (UnimplementedGopmServer) StopProcess 

func (UnimplementedGopmServer) StopProcess(context.Context, *StartStopRequest) (*StartStopResponse, error)

func (UnimplementedGopmServer) TailLog 

func (UnimplementedGopmServer) TailLog(*TailLogRequest, Gopm_TailLogServer) error

type UnsafeGopmServer 

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

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

type VersionResponse 

type VersionResponse struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionResponse) Descriptor deprecated 

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetVersion 

func (x *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect 

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

func (*VersionResponse) Reset 

func (x *VersionResponse) Reset()

func (*VersionResponse) String 

func (x *VersionResponse) 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.