Documentation
¶
Index ¶
- Variables
- type CRIUsecase
- type Cluster
- type ClusterMember
- type ClusterMicroservice
- type ClusterUsecase
- func (r *ClusterUsecase) GetClusters(ctx context.Context) ([]*Cluster, error)
- func (r *ClusterUsecase) GetServices(ctx context.Context) ([]*ClusterMicroservice, error)
- func (r *ClusterUsecase) GetValue(ctx context.Context, cluster string, key string) string
- func (r *ClusterUsecase) Keys(ctx context.Context, clusterName string) map[string][]string
- func (r *ClusterUsecase) Ping(_ context.Context) error
- func (r *ClusterUsecase) UpdateHangState(ctx context.Context, cluster string, key string, hang bool) error
- type CrontabUsecase
- type KMicroservice
- type KVUsecase
- type Microservice
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrEtcdClientNotReady = errors.New(500, "ETCD_CLIENT_NOT_READY", "etcd client not ready") ErrServerNotEnabledFeature = errors.New(400, "SERVER_NOT_ENABLED_THIS_FEATURE", "server not enabled this feature") )
View Source
var ProviderSet = wire.NewSet( NewCRIUsecase, NewClusterUsecase, NewCrontabUsecase, )
ProviderSet is biz providers.
Functions ¶
This section is empty.
Types ¶
type CRIUsecase ¶
type CRIUsecase struct {
// contains filtered or unexported fields
}
docker / cri info.
features - list container - check container health - report container info to mallard2-agent
func NewCRIUsecase ¶
func NewCRIUsecase(logger log.Logger) *CRIUsecase
type Cluster ¶
type Cluster struct { Name string `json:"name"` // 集群名称 Healthy bool `json:"healthy"` // 是否健康 Members []*ClusterMember `json:"members"` // 集群成员 }
type ClusterMember ¶
type ClusterMicroservice ¶
type ClusterMicroservice struct { Name string `json:"name"` Services []*Microservice `json:"services"` }
type ClusterUsecase ¶
type ClusterUsecase struct {
// contains filtered or unexported fields
}
func NewClusterUsecase ¶
func (*ClusterUsecase) GetClusters ¶
func (r *ClusterUsecase) GetClusters(ctx context.Context) ([]*Cluster, error)
func (*ClusterUsecase) GetServices ¶
func (r *ClusterUsecase) GetServices(ctx context.Context) ([]*ClusterMicroservice, error)
func (*ClusterUsecase) UpdateHangState ¶
type CrontabUsecase ¶
type CrontabUsecase struct{}
func NewCrontabUsecase ¶
func NewCrontabUsecase() *CrontabUsecase
type KMicroservice ¶
type Microservice ¶
type Microservice struct { KMicroservice Key string `json:"key"` CreatedAt int64 `json:"created_at"` }
Click to show internal directories.
Click to hide internal directories.