handler

Documentation

Index

• type ProcgoServer
  • func NewProcgoServer() ProcgoServer
  • func (s *ProcgoServer) KillAll(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (s *ProcgoServer) List(_ context.Context, _ *emptypb.Empty) (*proto.Services, error)
  • func (s *ProcgoServer) Logs(definitions *proto.AllOrServices, stream proto.Procgo_LogsServer) error
  • func (s *ProcgoServer) Ping(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (s *ProcgoServer) Restart(_ context.Context, definitions *proto.Services) (*emptypb.Empty, error)
  • func (s *ProcgoServer) Start(_ context.Context, definitions *proto.Services) (*emptypb.Empty, error)
  • func (s *ProcgoServer) Stop(_ context.Context, definitions *proto.Services) (*emptypb.Empty, error)

Types

type ProcgoServer

type ProcgoServer struct {
	proto.UnimplementedProcgoServer
	Services       []*pkg.Service
	NewServiceChan chan *pkg.Service
	// ErrChan is used as done channel as well if error is nil
	ErrChan  chan error
	KillChan chan os.Signal
}

func NewProcgoServer

func NewProcgoServer() ProcgoServer

func (*ProcgoServer) KillAll

func (s *ProcgoServer) KillAll(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*ProcgoServer) List

func (s *ProcgoServer) List(_ context.Context, _ *emptypb.Empty) (*proto.Services, error)

func (*ProcgoServer) Logs

func (s *ProcgoServer) Logs(definitions *proto.AllOrServices, stream proto.Procgo_LogsServer) error

func (*ProcgoServer) Ping

func (s *ProcgoServer) Ping(_ context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*ProcgoServer) Restart

func (s *ProcgoServer) Restart(_ context.Context, definitions *proto.Services) (*emptypb.Empty, error)

func (*ProcgoServer) Start

func (s *ProcgoServer) Start(_ context.Context, definitions *proto.Services) (*emptypb.Empty, error)

func (*ProcgoServer) Stop

func (s *ProcgoServer) Stop(_ context.Context, definitions *proto.Services) (*emptypb.Empty, error)