interfaces

Documentation

Index

• Constants
• Variables
• type GpmAPI
  • 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
  • func (r *RestAPI) Init(opts ...apihttp.Option) error

Constants

const (
	Handler = "rpc"
	Type    = "api"
	APIPath = "/"
)

Variables

var (
	APIAddress    = ":7800"
	EnableOpenAPI = true
	EnableLog     = false
	Address       = ":7700"
	ROOT          = "/opt/gpm"
)

Types

type GpmAPI

type GpmAPI struct {
	vine.Service

	API *RestAPI

	H app.GpmApp `inject:""`
}

func New

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

func (*GpmAPI) CreateService

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

func (*GpmAPI) DeleteService

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

func (*GpmAPI) EditService

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

func (*GpmAPI) Exec

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

func (*GpmAPI) GetService

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

func (*GpmAPI) Healthz

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

func (*GpmAPI) Info

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

func (*GpmAPI) Init

func (s *GpmAPI) Init() error

func (*GpmAPI) InstallService

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

func (*GpmAPI) ListService

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

func (*GpmAPI) ListServiceVersions

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

func (*GpmAPI) Ls

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

func (*GpmAPI) Pull

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

func (*GpmAPI) Push

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

func (*GpmAPI) RebootService

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

func (*GpmAPI) RollBackService

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

func (*GpmAPI) Run

func (s *GpmAPI) Run() error

func (*GpmAPI) StartService

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

func (*GpmAPI) StopService

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

func (*GpmAPI) Terminal

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

func (*GpmAPI) UpdateSelf

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

func (*GpmAPI) UpgradeService

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

func (*GpmAPI) WatchServiceLog

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

type RestAPI

type RestAPI struct {
	apihttp.Server
	// contains filtered or unexported fields
}

func (*RestAPI) Init

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