service

package

Go to main page

Versions in this module

v1

v1.12.4

May 1, 2023

v1.12.3

Apr 28, 2023

v1.12.2

Apr 14, 2023

v1.12.1

Apr 7, 2023

v1.12.0

Apr 7, 2023

v1.11.0

Feb 25, 2023

v1.10.2

Feb 24, 2023

Changes in this version

+ type GenerateFTP interface

+ Exec func(context.Context, *gpmv1.ExecIn) (*gpmv1.ExecResult, error)

+ List func(context.Context, string) ([]*gpmv1.FileInfo, error)

+ Pull func(context.Context, string, bool, IOWriter) error

+ Push func(context.Context, IOReader) error

+ Terminal func(context.Context, IOStream) error

+ func NewSFtpService(ctx context.Context, server vserver.Server) (GenerateFTP, error)

+ type GenerateManager interface

+ Create func(context.Context, *gpmv1.ServiceSpec) (*gpmv1.Service, error)

+ Delete func(context.Context, string) (*gpmv1.Service, error)

+ Edit func(context.Context, string, *gpmv1.EditServiceSpec) (*gpmv1.Service, error)

+ Forget func(context.Context, string, string) error

+ Get func(context.Context, string) (*gpmv1.Service, error)

+ Info func(context.Context) (*gpmv1.GpmInfo, error)

+ Init func() error

+ Install func(context.Context, IOStream) error

+ List func(context.Context) ([]*gpmv1.Service, int64, error)

+ ListVersions func(context.Context, string) ([]*gpmv1.ServiceVersion, error)

+ Restart func(context.Context, string) (*gpmv1.Service, error)

+ Rollback func(context.Context, string, string) error

+ Start func(context.Context, string) (*gpmv1.Service, error)

+ Stop func(context.Context, string) (*gpmv1.Service, error)

+ TailLog func(context.Context, string, int64, bool, IOWriter) error

+ Update func(context.Context, IOStream) error

+ Upgrade func(context.Context, IOStream) error

+ func NewManagerService(ctx context.Context, server vserver.Server, db *store.DB) (GenerateManager, error)

v1.10.1

Feb 8, 2023

v1.10.0

Feb 7, 2023

Changes in this version

+ type FTP interface

+ Exec func(context.Context, *gpmv1.ExecIn) (*gpmv1.ExecResult, error)

+ List func(context.Context, string) ([]*gpmv1.FileInfo, error)

+ Pull func(context.Context, string, bool, IOWriter) error

+ Push func(context.Context, IOReader) error

+ Terminal func(context.Context, IOStream) error

+ type Manager interface

+ Create func(context.Context, *gpmv1.ServiceSpec) (*gpmv1.Service, error)

+ Delete func(context.Context, string) (*gpmv1.Service, error)

+ Edit func(context.Context, string, *gpmv1.EditServiceSpec) (*gpmv1.Service, error)

+ Forget func(context.Context, string, string) error

+ Get func(context.Context, string) (*gpmv1.Service, error)

+ Info func(context.Context) (*gpmv1.GpmInfo, error)

+ Init func() error

+ Install func(context.Context, IOStream) error

+ List func(context.Context) ([]*gpmv1.Service, int64, error)

+ ListVersions func(context.Context, string) ([]*gpmv1.ServiceVersion, error)

+ Restart func(context.Context, string) (*gpmv1.Service, error)

+ Rollback func(context.Context, string, string) error

+ Start func(context.Context, string) (*gpmv1.Service, error)

+ Stop func(context.Context, string) (*gpmv1.Service, error)

+ TailLog func(context.Context, string, int64, bool, IOWriter) error

+ Update func(context.Context, IOStream) error

+ Upgrade func(context.Context, IOStream) error

v1.9.5

Sep 8, 2022

v1.9.4

Sep 9, 2022

v1.9.3

Aug 11, 2022

v1.9.2

Dec 21, 2021

v1.9.1

Dec 10, 2021

v1.9.0

Dec 8, 2021

Changes in this version

type GpmAPI

+ func (s *GpmAPI) ForgetService(ctx context.Context, req *pb.ForgetServiceReq, rsp *pb.ForgetServiceRsp) (err error)

+ func (s *GpmAPI) RestartService(ctx context.Context, req *pb.RestartServiceReq, rsp *pb.RestartServiceRsp) (err error)

v1.8.0

Nov 17, 2021

v1.7.9

Oct 27, 2021

Changes in this version

+ const APIPath

+ const Handler

+ const Type

+ var APIAddress = ":7800"

+ var Address = ":7700"

+ var EnableLog = false

+ var EnableOpenAPI = true

+ var ROOT = "/opt/gpm"

+ type GpmAPI struct

+ API *RestAPI

+ G biz.Manager

+ T biz.FTP

+ func New(opts ...vine.Option) *GpmAPI

+ func (s *GpmAPI) CreateService(ctx context.Context, req *pb.CreateServiceReq, rsp *pb.CreateServiceRsp) (err error)

+ func (s *GpmAPI) DeleteService(ctx context.Context, req *pb.DeleteServiceReq, rsp *pb.DeleteServiceRsp) (err error)

+ func (s *GpmAPI) EditService(ctx context.Context, req *pb.EditServiceReq, rsp *pb.EditServiceRsp) (err error)

+ func (s *GpmAPI) Exec(ctx context.Context, req *pb.ExecReq, rsp *pb.ExecRsp) (err error)

+ func (s *GpmAPI) GetService(ctx context.Context, req *pb.GetServiceReq, rsp *pb.GetServiceRsp) (err error)

+ func (s *GpmAPI) Healthz(ctx context.Context, _ *pb.Empty, rsp *pb.Empty) error

+ func (s *GpmAPI) Info(ctx context.Context, _ *pb.InfoReq, rsp *pb.InfoRsp) (err error)

+ func (s *GpmAPI) Init() error

+ func (s *GpmAPI) InstallService(ctx context.Context, stream pb.GpmService_InstallServiceStream) error

+ func (s *GpmAPI) ListService(ctx context.Context, req *pb.ListServiceReq, rsp *pb.ListServiceRsp) (err error)

+ func (s *GpmAPI) ListServiceVersions(ctx context.Context, req *pb.ListServiceVersionsReq, ...) (err error)

+ func (s *GpmAPI) Ls(ctx context.Context, req *pb.LsReq, rsp *pb.LsRsp) (err error)

+ func (s *GpmAPI) Pull(ctx context.Context, req *pb.PullReq, stream pb.GpmService_PullStream) (err error)

+ func (s *GpmAPI) Push(ctx context.Context, stream pb.GpmService_PushStream) (err error)

+ func (s *GpmAPI) RebootService(ctx context.Context, req *pb.RebootServiceReq, rsp *pb.RebootServiceRsp) (err error)

+ func (s *GpmAPI) RollBackService(ctx context.Context, req *pb.RollbackServiceReq, rsp *pb.RollbackServiceRsp) (err error)

+ func (s *GpmAPI) Run() error

+ func (s *GpmAPI) StartService(ctx context.Context, req *pb.StartServiceReq, rsp *pb.StartServiceRsp) (err error)

+ func (s *GpmAPI) StopService(ctx context.Context, req *pb.StopServiceReq, rsp *pb.StopServiceRsp) (err error)

+ func (s *GpmAPI) Terminal(ctx context.Context, stream pb.GpmService_TerminalStream) error

+ func (s *GpmAPI) UpdateSelf(ctx context.Context, stream pb.GpmService_UpdateSelfStream) error

+ func (s *GpmAPI) UpgradeService(ctx context.Context, stream pb.GpmService_UpgradeServiceStream) error

+ func (s *GpmAPI) WatchServiceLog(ctx context.Context, req *pb.WatchServiceLogReq, ...) (err error)

+ type RestAPI struct

+ func (r *RestAPI) Init(opts ...apihttp.Option) error

v1.4.3

Aug 16, 2021

v1.4.2

Aug 16, 2021

v1.4.1

Aug 16, 2021

Changes in this version

+ type IOReader interface

+ Close func() error

+ Recv func() (interface{}, error)

+ type IOStream interface

+ Close func() error

+ Recv func() (interface{}, error)

+ Send func(msg interface{}) error

+ type IOWriter interface

+ Close func() error

+ Send func(interface{}) error

v1.4.0

Aug 12, 2021

Changes in this version

+ var ErrProcessNotFound = errors.New("process not found")

+ type Gpm interface

+ CreateService func(context.Context, *gpmv1.ServiceSpec) (*gpmv1.Service, error)

+ DeleteService func(context.Context, string) (*gpmv1.Service, error)

+ EditService func(context.Context, string, *gpmv1.EditServiceSpec) (*gpmv1.Service, error)

+ Exec func(context.Context, *gpmv1.ExecIn) (*gpmv1.ExecResult, error)

+ GetService func(context.Context, string) (*gpmv1.Service, error)

+ Info func(context.Context) (*gpmv1.GpmInfo, error)

+ Init func() error

+ InstallService func(context.Context, Stream) error

+ ListService func(context.Context) ([]*gpmv1.Service, int64, error)

+ ListServiceVersions func(context.Context, string) ([]*gpmv1.ServiceVersion, error)

+ Ls func(context.Context, string) ([]*gpmv1.FileInfo, error)

+ Pull func(context.Context, string, bool, Sender) error

+ Push func(context.Context, Stream) error

+ RebootService func(context.Context, string) (*gpmv1.Service, error)

+ RollbackService func(context.Context, string, string) error

+ StartService func(context.Context, string) (*gpmv1.Service, error)

+ StopService func(context.Context, string) (*gpmv1.Service, error)

+ Terminal func(context.Context, Stream) error

+ UpdateSelf func(context.Context, Stream) error

+ UpgradeService func(context.Context, Stream) error

+ WatchServiceLog func(context.Context, string, int64, bool, Sender) error

+ type Process struct

+ func NewProcess(in *gpmv1.Service) *Process

+ func (p *Process) Kill() error

+ func (p *Process) Start() (int32, error)

+ func (p *Process) Stop() error

+ type Sender interface

+ Close func() error

+ Send func(interface{}) error

+ type Stream interface

+ Close func() error

+ Recv func() (interface{}, error)

+ Send func(msg interface{}) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL