proto

Documentation

Index

• Variables
• func RegisterProcgoServer(s grpc.ServiceRegistrar, srv ProcgoServer)
• type AllOrServices
  • func (*AllOrServices) Descriptor() ([]byte, []int)
  • func (x *AllOrServices) GetAll() bool
  • func (x *AllOrServices) GetServices() []*ServiceDefinition
  • func (*AllOrServices) ProtoMessage()
  • func (x *AllOrServices) ProtoReflect() protoreflect.Message
  • func (x *AllOrServices) Reset()
  • func (x *AllOrServices) String() string
• type ProcgoClient
  • func NewProcgoClient(cc grpc.ClientConnInterface) ProcgoClient
• type ProcgoServer
• type Procgo_LogsClient
• type Procgo_LogsServer
• type ServiceDefinition
  • func (*ServiceDefinition) Descriptor() ([]byte, []int)
  • func (x *ServiceDefinition) GetCommand() string
  • func (x *ServiceDefinition) GetName() string
  • func (*ServiceDefinition) ProtoMessage()
  • func (x *ServiceDefinition) ProtoReflect() protoreflect.Message
  • func (x *ServiceDefinition) Reset()
  • func (x *ServiceDefinition) String() string
• type Services
  • func (*Services) Descriptor() ([]byte, []int)
  • func (x *Services) GetServices() []*ServiceDefinition
  • func (*Services) ProtoMessage()
  • func (x *Services) ProtoReflect() protoreflect.Message
  • func (x *Services) Reset()
  • func (x *Services) String() string
• type UnimplementedProcgoServer
  • func (UnimplementedProcgoServer) KillAll(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
  • func (UnimplementedProcgoServer) List(context.Context, *emptypb.Empty) (*Services, error)
  • func (UnimplementedProcgoServer) Logs(*AllOrServices, Procgo_LogsServer) error
  • func (UnimplementedProcgoServer) Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
  • func (UnimplementedProcgoServer) Restart(context.Context, *Services) (*emptypb.Empty, error)
  • func (UnimplementedProcgoServer) Start(context.Context, *Services) (*emptypb.Empty, error)
  • func (UnimplementedProcgoServer) Stop(context.Context, *Services) (*emptypb.Empty, error)
• type UnsafeProcgoServer

Variables

var File_proto_procgo_proto protoreflect.FileDescriptor

Functions

func RegisterProcgoServer

func RegisterProcgoServer(s grpc.ServiceRegistrar, srv ProcgoServer)

Types

type AllOrServices

type AllOrServices struct {
	All      bool                 `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"`
	Services []*ServiceDefinition `protobuf:"bytes,2,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*AllOrServices) Descriptor

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

Deprecated: Use AllOrServices.ProtoReflect.Descriptor instead.

func (*AllOrServices) GetAll

func (x *AllOrServices) GetAll() bool

func (*AllOrServices) GetServices

func (x *AllOrServices) GetServices() []*ServiceDefinition

func (*AllOrServices) ProtoMessage

func (*AllOrServices) ProtoMessage()

func (*AllOrServices) ProtoReflect

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

func (*AllOrServices) Reset

func (x *AllOrServices) Reset()

func (*AllOrServices) String

func (x *AllOrServices) String() string

type ProcgoClient

type ProcgoClient interface {
	Start(ctx context.Context, in *Services, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Stop(ctx context.Context, in *Services, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Restart(ctx context.Context, in *Services, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Logs(ctx context.Context, in *AllOrServices, opts ...grpc.CallOption) (Procgo_LogsClient, error)
	List(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Services, error)
	KillAll(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ProcgoClient is the client API for Procgo 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 NewProcgoClient

func NewProcgoClient(cc grpc.ClientConnInterface) ProcgoClient

type ProcgoServer

type ProcgoServer interface {
	Start(context.Context, *Services) (*emptypb.Empty, error)
	Stop(context.Context, *Services) (*emptypb.Empty, error)
	Restart(context.Context, *Services) (*emptypb.Empty, error)
	Logs(*AllOrServices, Procgo_LogsServer) error
	List(context.Context, *emptypb.Empty) (*Services, error)
	KillAll(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ProcgoServer is the server API for Procgo service. All implementations must embed UnimplementedProcgoServer for forward compatibility

type Procgo_LogsClient

type Procgo_LogsClient interface {
	Recv() (*wrapperspb.BytesValue, error)
	grpc.ClientStream
}

type Procgo_LogsServer

type Procgo_LogsServer interface {
	Send(*wrapperspb.BytesValue) error
	grpc.ServerStream
}

type ServiceDefinition

type ServiceDefinition struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceDefinition) Descriptor

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

Deprecated: Use ServiceDefinition.ProtoReflect.Descriptor instead.

func (*ServiceDefinition) GetCommand

func (x *ServiceDefinition) GetCommand() string

func (*ServiceDefinition) GetName

func (x *ServiceDefinition) GetName() string

func (*ServiceDefinition) ProtoMessage

func (*ServiceDefinition) ProtoMessage()

func (*ServiceDefinition) ProtoReflect

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

func (*ServiceDefinition) Reset

func (x *ServiceDefinition) Reset()

func (*ServiceDefinition) String

func (x *ServiceDefinition) String() string

type Services

type Services struct {
	Services []*ServiceDefinition `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*Services) Descriptor

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

Deprecated: Use Services.ProtoReflect.Descriptor instead.

func (*Services) GetServices

func (x *Services) GetServices() []*ServiceDefinition

func (*Services) ProtoMessage

func (*Services) ProtoMessage()

func (*Services) ProtoReflect

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

func (*Services) Reset

func (x *Services) Reset()

func (*Services) String

func (x *Services) String() string

type UnimplementedProcgoServer

type UnimplementedProcgoServer struct {
}

UnimplementedProcgoServer must be embedded to have forward compatible implementations.

func (UnimplementedProcgoServer) KillAll

func (UnimplementedProcgoServer) KillAll(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedProcgoServer) List

func (UnimplementedProcgoServer) List(context.Context, *emptypb.Empty) (*Services, error)

func (UnimplementedProcgoServer) Logs

func (UnimplementedProcgoServer) Logs(*AllOrServices, Procgo_LogsServer) error

func (UnimplementedProcgoServer) Ping

func (UnimplementedProcgoServer) Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedProcgoServer) Restart

func (UnimplementedProcgoServer) Restart(context.Context, *Services) (*emptypb.Empty, error)

func (UnimplementedProcgoServer) Start

func (UnimplementedProcgoServer) Start(context.Context, *Services) (*emptypb.Empty, error)

func (UnimplementedProcgoServer) Stop

func (UnimplementedProcgoServer) Stop(context.Context, *Services) (*emptypb.Empty, error)

type UnsafeProcgoServer

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

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