v1

Documentation

Index

• func NewWorkFlow(app *KubeManage) *workflow
• func Setup(o *options.Options)
• type CloudGetter
• type CloudInterface
  • func NewCloud(c *KubeManage) CloudInterface
• type CoreService
  • func New(cfg *config.Config, factory dao.ShareDaoFactory) CoreService
• type KubeManage
  • func (c *KubeManage) Cloud() CloudInterface
  • func (c *KubeManage) System() SystemInterface
  • func (c *KubeManage) WorkFlow() WorkFlowService
• type Logger
• type SystemGetter
• type SystemInterface
  • func NewSystem(app *KubeManage) SystemInterface
• type WorkFlowService
• type WorkFlowServiceGetter
• type WorkflowResp

Functions

func NewWorkFlow

func NewWorkFlow(app *KubeManage) *workflow

func Setup

func Setup(o *options.Options)

Setup 完成核心应用接口的设置

Types

type CloudGetter

type CloudGetter interface {
	Cloud() CloudInterface
}

type CloudInterface

type CloudInterface interface {
	kube.PodsGetter
}

func NewCloud

func NewCloud(c *KubeManage) CloudInterface

type CoreService

type CoreService interface {
	WorkFlowServiceGetter
	CloudGetter
	SystemGetter
}

var CoreV1 CoreService

func New

func New(cfg *config.Config, factory dao.ShareDaoFactory) CoreService

type KubeManage

type KubeManage struct {
	Cfg     *config.Config
	Factory dao.ShareDaoFactory
}

func (*KubeManage) Cloud

func (c *KubeManage) Cloud() CloudInterface

func (*KubeManage) System

func (c *KubeManage) System() SystemInterface

func (*KubeManage) WorkFlow

func (c *KubeManage) WorkFlow() WorkFlowService

type Logger

type Logger interface {
	logger.Logger
}

var Log Logger

type SystemGetter

type SystemGetter interface {
	System() SystemInterface
}

type SystemInterface

type SystemInterface interface {
	sys.UserServiceGetter
	sys.MenuGetter
	sys.CasbinServiceGetter
	sys.AuthorityGetter
	sys.OperationServiceGetter
	sys.APIServiceGetter
}

SystemInterface 顶层抽象 包括系统相关接口

func NewSystem

func NewSystem(app *KubeManage) SystemInterface

type WorkFlowService

type WorkFlowService interface {
	Save(context.Context, *kubeDto.WorkFlowCreateInput) error
	Find(context.Context, *kubeDto.WorkFlowIDInput) (*model.Workflow, error)
	FindList(context.Context, *kubeDto.WorkFlowListInput) (*WorkflowResp, error)
	Delete(context.Context, int) error
}

type WorkFlowServiceGetter

type WorkFlowServiceGetter interface {
	WorkFlow() WorkFlowService
}

type WorkflowResp

type WorkflowResp struct {
	Items []*model.Workflow `json:"items"`
	Total int               `json:"total"`
}