service

type AgentLinkService interface {
	RegisterAgent(in *vo.AgentLink, out *vo.AgentLink) error
	UnregisterAgent(id string, in *vo.AgentLink, out *vo.AgentLink) error
	FetchMessage(id string, in *vo.AgentLink, out *vo.AgentLink) error
	DispatchMessage(id string, in *vo.AgentLink, out *vo.AgentLink) error
}

type AgentLinkServiceImpl struct {
	markup.Component `id:"agent-link-service"  initMethod:"Init"`

	AgentPortMin int `inject:"${gie.agent.port.min}"`
	AgentPortMax int `inject:"${gie.agent.port.max}"`
	// contains filtered or unexported fields
}

type ApplicationUpdateService interface {
}

type ApplicationUpdateServiceImpl struct {
	markup.Component `id:"application-update-service" initMethod:"Init"`

	Env context.Environment `inject:"#env"`
}

type CommandService interface {
	Execute(ctx context.Context, o1 *dto.Command, o2 *dto.Command) error
}

type CommandServiceImpl struct {
	markup.Component `id:"command-service"`

	ClientFactory cli.ClientFactory `inject:"#cli-client-factory"`
	VFS           VFSService        `inject:"#vfs-service"`
	Tasks         TaskService       `inject:"#task-service"`
}

type ContentTypeFinder interface {
	// return '.xxx'
	GetFileNameSuffix(filename string) string

	FindContentType(suffix string) (string, error)
}

type ContentTypeService interface {
	NewFinder() ContentTypeFinder
}

type ContentTypeServiceImpl struct {
	markup.Component `id:"content-type-service" initMethod:"Init"`

	Context application.Context `inject:"context"`
	// contains filtered or unexported fields
}

type DBAService interface {
	StartMigration() error
	StartBackup() error
	StopBackup() error
	GetStatus(o *vo.DBA) error
}

type DBAServiceProxy struct {
	markup.Component `id:"dba-service"  initMethod:"Init" `

	Context  application.Context `inject:"context"`
	Selector string              `inject:"${dba.service.selector}"`
	// contains filtered or unexported fields
}

type FileSystemService interface {
	QueryRoots(param *dto.Dir, result *dto.Dir) error
	QueryDir(param *dto.Dir, result *dto.Dir) error
	QueryFile(param *dto.File, result *dto.File) error
}

type FileSystemServiceImpl struct {
	markup.Component `id:"filesystem-service"`

	VFS   VFSService         `inject:"#vfs-service"`
	Types ContentTypeService `inject:"#content-type-service"`
}

type GuiService struct {
	markup.Component `id:"gui-service" initMethod:"Init"`

	ClientFactory cli.ClientFactory `inject:"#cli-client-factory"`

	Port int `inject:"${server.port}"`
}

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

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

type MockDBAService struct {
	markup.Component `id:"mock-dba-service"`
	// contains filtered or unexported fields
}

type PlanService interface {
}

type RepositoryService interface {
	CloneRepository(o1 *dto.RepositoryClone, o2 *dto.RepositoryClone) error
	ImportRepository(o1 *dto.RepositoryImport, o2 *dto.RepositoryImport) error
	InitRepository(o1 *dto.RepositoryInit, o2 *dto.RepositoryInit) error

	Insert(o *dto.Repository) (*dto.Repository, error)
	GetAll() ([]*dto.Repository, error)
	GetOne(id string) (*dto.Repository, error)
	Update(id string, o *dto.Repository) (*dto.Repository, error)
	Delete(id string) error
}

type RepositoryServiceImpl struct {
	markup.Component `id:"repository-service"`

	Dao dao.RepositoryDAO `inject:"#repository-dao"`
}

type StarAPI interface {
	GetURI() string
	GetType() string

	Execute(invoking *StarInvoking) error
	Post(tx, rx interface{}) error
	Get(id string, rx interface{}) error
	Put(id string, tx, rx interface{}) error
	Delete(id string) error
}

type StarAgentService interface {
	GetAPI(selector string) (StarAPI, error)
}

type StarInvoking struct {
	BaseURL string
	Method  string
	Type    string
	ID      string

	Status  int
	Message string

	TxBody interface{}
	RxBody interface{}
}

type TaskHolder interface {
	io.Closer

	UpdateState(state task.State, status task.Status)
	HandleError(err error)

	GetID() string
	Cancel() error
	Error() error
	IsCancelling() bool

	GetTask() *dto.Task
	GetController() task.Controller
	GetReporter() task.ProgressReporter
}

type TaskService interface {
	Insert(o *dto.Task) (*dto.Task, error)
	GetAll() ([]*dto.Task, error)
	GetOne(id string) (*dto.Task, error)
	Update(id string, o *dto.Task) (*dto.Task, error)
	Delete(id string) error
	GetTaskHolder(id string) (TaskHolder, error)
}

type VFSService interface {
	Load(str string, result *dto.Dir) error
	LoadURI(uri lang.URI, result *dto.Dir) error
	ResolveURI(s string) (lang.URI, error)
	ResolvePath(s string) (fs.Path, error)
}

type VFSServiceImpl struct {
	markup.Component `id:"vfs-service" initMethod:"Init"`

	Handlers []vfs.Handler `inject:".vfs-handler"`
	Context  vfs.Context   `inject:"#vfs-context"`
}