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
- type CrontabUsecase
- type KVUsecase
- type Microservice
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrEtcdClientNotReady = errors.New("etcd client not ready")
)
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)
type CrontabUsecase ¶
type CrontabUsecase struct{}
func NewCrontabUsecase ¶
func NewCrontabUsecase() *CrontabUsecase
Click to show internal directories.
Click to hide internal directories.