gateway

type ApiRelease struct {
	*BasicItem
	Path      string
	Methods   []string
	Host      []string
	Protocols []string

	Plugins      map[string]*Plugin
	Service      string
	Rules        []*MatchRule
	Extends      map[string]any
	ProxyPath    string
	ProxyHeaders []*ProxyHeader
	Retry        int
	Timeout      int

	Labels  map[string]string
	Disable bool
}

type ApplicationRelease struct {
	*BasicItem
	Labels         map[string]string
	Authorizations []*Authorization
}

type AuthConfig struct {
	// 认证类型
	Type string
	// 认证信息
	Info map[string]interface{}
}

type Authorization struct {
	Type           string
	Position       string
	TokenName      string
	Expire         int64
	Config         map[string]interface{}
	Label          map[string]string
	HideCredential bool
}

type BasicItem struct {
	ID          string
	Description string
	Version     string
	Resource    string
	MatchLabels map[string]string
}

type ClientConfig struct {
	// 请求地址列表
	Addresses []string
	// 认证配置
	Auth *AuthConfig
}

type DynamicRelease struct {
	*BasicItem
	Attr map[string]interface{}
}

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

type HashRelease struct {
	HashKey string
	HashMap map[string]string
}

type IApplicationClient IResourceClient[ApplicationRelease]

type IClientDriver interface {
	Project() IProjectClient
	Application() IApplicationClient
	Service() IServiceClient
	Subscribe() ISubscribeClient
	Strategy() IStrategyClient
	Dynamic(resource string, profession string) (IDynamicClient, error)
	Hash() IHashClient
	PluginSetting() IPluginSetting
	Commit(ctx context.Context) error
	Rollback(ctx context.Context) error
	Begin(ctx context.Context) error
	Close(ctx context.Context) error
}

type IDynamicClient interface {
	IResourceClient[DynamicRelease]
	Versions(ctx context.Context, matchLabels map[string]string) (map[string]string, error)
	Version(ctx context.Context, resourceId string) (string, error)
}

type IFactory interface {
	Create(config *ClientConfig) (IClientDriver, error)
}

type IFactoryManager interface {
	Set(name string, factory IFactory)
	GetClient(name string, config *ClientConfig) (IClientDriver, error)
	Drivers() []string
}

type IHashClient IResourceClient[HashRelease]

type IPluginSetting interface {
	Init(ctx context.Context) error
	Set(ctx context.Context, cfgs []*PluginConfig) error
}

type IProjectClient IResourceClient[ProjectRelease]

type IResourceClient[T any] interface {
	Online(ctx context.Context, resources ...*T) error
	Offline(ctx context.Context, resources ...*T) error
}

type IServiceClient IResourceClient[ServiceRelease]

type IStrategyClient IResourceClient[eosc.Base[StrategyRelease]]

type ISubscribeClient IResourceClient[SubscribeRelease]

type InitHandleFunc func(ctx context.Context, clusterId string, client IClientDriver) error

type InitHandler interface {
	Init(ctx context.Context, clusterId string, client IClientDriver) error
}

type MatchRule struct {
	Position  string
	MatchType string
	Key       string
	Pattern   string
}

type Plugin struct {
	Disable bool
	Config  plugin_model.ConfigType
}

type PluginConfig struct {
	Id     string                 `json:"id"`
	Name   string                 `json:"name"`
	Status string                 `json:"status"`
	Config map[string]interface{} `json:"config"`
}

type ProjectRelease struct {
	Id         string                        `json:"id"`
	Version    string                        `json:"version"`
	Apis       []*ApiRelease                 `json:"apis"`
	Upstream   *UpstreamRelease              `json:"upstreams"`
	Strategies []*eosc.Base[StrategyRelease] `json:"strategies"`
}

type ProxyHeader struct {
	Key   string `json:"key"`
	Value string `json:"value"`
	Opt   string `json:"opt"`
}

type ServiceRelease struct {
	ID   string
	Apis []string
}

type StrategyRelease struct {
	Name     string              `json:"name"`
	Desc     string              `json:"description"`
	Driver   string              `json:"driver"`
	Priority int                 `json:"priority"`
	Filters  map[string][]string `json:"filters"`
	IsDelete bool                `json:"-"`
}

type SubscribeRelease struct {
	// 订阅服务ID
	Service string
	// 订阅方ID
	Application string
	// 过期时间
	Expired string
}

type UpstreamRelease struct {
	*BasicItem
	Nodes    []string
	PassHost string
	Scheme   string
	// Discovery 服务发现ID
	Discovery string
	// Service 服务发现服务名
	Service string
	Balance string
	Timeout int
	Labels  map[string]string
}

type Worker struct {
	Profession string
	Driver     string
}