server

Documentation

Index

• Variables
• func Action(cmd *cobra.Command, args []string) error
• func RegistryGpmAPIServer(svc vine.Service) (http.Handler, error)
• func RegistryGpmRpcServer(ctx context.Context, s vserver.Server, manager service.GenerateManager, ...) error
• type GpmApp
  • func New(s vine.Service) (*GpmApp, error)
  • func (app *GpmApp) Init(opts ...vine.Option) error
  • func (app *GpmApp) Run() error
• type GpmHttpServer
• type GpmServer
  • func (s *GpmServer) CreateService(ctx context.Context, req *pb.CreateServiceReq, rsp *pb.CreateServiceRsp) (err error)
  • func (s *GpmServer) DeleteService(ctx context.Context, req *pb.DeleteServiceReq, rsp *pb.DeleteServiceRsp) (err error)
  • func (s *GpmServer) EditService(ctx context.Context, req *pb.EditServiceReq, rsp *pb.EditServiceRsp) (err error)
  • func (s *GpmServer) Exec(ctx context.Context, req *pb.ExecReq, rsp *pb.ExecRsp) (err error)
  • func (s *GpmServer) ForgetService(ctx context.Context, req *pb.ForgetServiceReq, rsp *pb.ForgetServiceRsp) (err error)
  • func (s *GpmServer) GetService(ctx context.Context, req *pb.GetServiceReq, rsp *pb.GetServiceRsp) (err error)
  • func (s *GpmServer) Healthz(ctx context.Context, _ *pb.Empty, rsp *pb.Empty) error
  • func (s *GpmServer) Info(ctx context.Context, _ *pb.InfoReq, rsp *pb.InfoRsp) (err error)
  • func (s *GpmServer) InstallService(ctx context.Context, stream pb.GpmService_InstallServiceStream) error
  • func (s *GpmServer) ListService(ctx context.Context, req *pb.ListServiceReq, rsp *pb.ListServiceRsp) (err error)
  • func (s *GpmServer) ListServiceVersions(ctx context.Context, req *pb.ListServiceVersionsReq, ...) (err error)
  • func (s *GpmServer) Ls(ctx context.Context, req *pb.LsReq, rsp *pb.LsRsp) (err error)
  • func (s *GpmServer) Name() string
  • func (s *GpmServer) Pull(ctx context.Context, req *pb.PullReq, stream pb.GpmService_PullStream) (err error)
  • func (s *GpmServer) Push(ctx context.Context, stream pb.GpmService_PushStream) (err error)
  • func (s *GpmServer) RestartService(ctx context.Context, req *pb.RestartServiceReq, rsp *pb.RestartServiceRsp) (err error)
  • func (s *GpmServer) RollBackService(ctx context.Context, req *pb.RollbackServiceReq, rsp *pb.RollbackServiceRsp) (err error)
  • func (s *GpmServer) StartService(ctx context.Context, req *pb.StartServiceReq, rsp *pb.StartServiceRsp) (err error)
  • func (s *GpmServer) StopService(ctx context.Context, req *pb.StopServiceReq, rsp *pb.StopServiceRsp) (err error)
  • func (s *GpmServer) Terminal(ctx context.Context, stream pb.GpmService_TerminalStream) error
  • func (s *GpmServer) UpdateSelf(ctx context.Context, stream pb.GpmService_UpdateSelfStream) error
  • func (s *GpmServer) UpgradeService(ctx context.Context, stream pb.GpmService_UpgradeServiceStream) error
  • func (s *GpmServer) WatchServiceLog(ctx context.Context, req *pb.WatchServiceLogReq, ...) (err error)

Variables

var Flag = pflag.NewFlagSet("gpm", pflag.ContinueOnError)

Functions

func Action

func Action(cmd *cobra.Command, args []string) error

func RegistryGpmAPIServer

func RegistryGpmAPIServer(svc vine.Service) (http.Handler, error)

func RegistryGpmRpcServer

func RegistryGpmRpcServer(ctx context.Context, s vserver.Server, manager service.GenerateManager, ftp service.GenerateFTP) error

Types

type GpmApp

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

func New

func New(s vine.Service) (*GpmApp, error)

func (*GpmApp) Init

func (app *GpmApp) Init(opts ...vine.Option) error

func (*GpmApp) Run

func (app *GpmApp) Run() error

type GpmHttpServer

type GpmHttpServer struct {
	*gin.Engine
	// contains filtered or unexported fields
}

type GpmServer

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

func (*GpmServer) CreateService

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

func (*GpmServer) DeleteService

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

func (*GpmServer) EditService

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

func (*GpmServer) Exec

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

func (*GpmServer) ForgetService

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

func (*GpmServer) GetService

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

func (*GpmServer) Healthz

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

func (*GpmServer) Info

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

func (*GpmServer) InstallService

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

func (*GpmServer) ListService

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

func (*GpmServer) ListServiceVersions

func (s *GpmServer) ListServiceVersions(ctx context.Context, req *pb.ListServiceVersionsReq, rsp *pb.ListServiceVersionsRsp) (err error)

func (*GpmServer) Ls

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

func (*GpmServer) Name

func (s *GpmServer) Name() string

func (*GpmServer) Pull

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

func (*GpmServer) Push

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

func (*GpmServer) RestartService

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

func (*GpmServer) RollBackService

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

func (*GpmServer) StartService

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

func (*GpmServer) StopService

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

func (*GpmServer) Terminal

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

func (*GpmServer) UpdateSelf

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

func (*GpmServer) UpgradeService

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

func (*GpmServer) WatchServiceLog

func (s *GpmServer) WatchServiceLog(ctx context.Context, req *pb.WatchServiceLogReq, stream pb.GpmService_WatchServiceLogStream) (err error)