service

Documentation

Index

• Variables
• type GenerateFTP
  • func NewSFtpService(ctx context.Context, server vserver.Server) (GenerateFTP, error)
• type GenerateManager
  • func NewManagerService(ctx context.Context, server vserver.Server, db *store.DB) (GenerateManager, error)
• type IOReader
• type IOStream
• type IOWriter
• type Process
  • func NewProcess(in *gpmv1.Service, db *store.DB) *Process
  • func (p *Process) Kill() error
  • func (p *Process) Start() (int32, error)
  • func (p *Process) Stop() error

Variables

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

Types

type GenerateFTP

type GenerateFTP interface {
	List(context.Context, string) ([]*gpmv1.FileInfo, error)
	Pull(context.Context, string, bool, IOWriter) error
	Push(context.Context, IOReader) error
	Exec(context.Context, *gpmv1.ExecIn) (*gpmv1.ExecResult, error)
	Terminal(context.Context, IOStream) error
}

func NewSFtpService

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

type GenerateManager

type GenerateManager interface {
	Init() error
	Info(context.Context) (*gpmv1.GpmInfo, error)
	Update(context.Context, IOStream) error
	List(context.Context) ([]*gpmv1.Service, int64, error)
	Get(context.Context, string) (*gpmv1.Service, error)
	Create(context.Context, *gpmv1.ServiceSpec) (*gpmv1.Service, error)
	Edit(context.Context, string, *gpmv1.EditServiceSpec) (*gpmv1.Service, error)
	Start(context.Context, string) (*gpmv1.Service, error)
	Stop(context.Context, string) (*gpmv1.Service, error)
	Restart(context.Context, string) (*gpmv1.Service, error)
	Delete(context.Context, string) (*gpmv1.Service, error)
	TailLog(context.Context, string, int64, bool, IOWriter) error

	Install(context.Context, IOStream) error
	ListVersions(context.Context, string) ([]*gpmv1.ServiceVersion, error)
	Upgrade(context.Context, IOStream) error
	Rollback(context.Context, string, string) error
	Forget(context.Context, string, string) error
}

func NewManagerService

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

type IOReader

type IOReader interface {
	Recv() (interface{}, error)
	Close() error
}

type IOStream

type IOStream interface {
	Recv() (interface{}, error)
	Send(msg interface{}) error
	Close() error
}

type IOWriter

type IOWriter interface {
	Send(interface{}) error
	Close() error
}

type Process

type Process struct {
	*gpmv1.Service
	// contains filtered or unexported fields
}

func NewProcess

func NewProcess(in *gpmv1.Service, db *store.DB) *Process

func (*Process) Kill

func (p *Process) Kill() error

func (*Process) Start

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

func (*Process) Stop

func (p *Process) Stop() error