biz

README

Biz

Documentation

Index

• Variables
• type CRIUsecase
  • func NewCRIUsecase(logger log.Logger) *CRIUsecase
• type Cluster
• type ClusterMember
• type ClusterMicroservice
• type ClusterUsecase
  • func NewClusterUsecase(logger log.Logger, clis []*cluster.Client, c *conf.Bootstrap) *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
  • func NewCrontabUsecase() *CrontabUsecase
• type KVUsecase
• type Microservice

Variables

var (
	ErrEtcdClientNotReady = errors.New("etcd client not ready")
)

var ProviderSet = wire.NewSet(
	NewCRIUsecase,
	NewClusterUsecase,
	NewCrontabUsecase,
)

ProviderSet is biz providers.

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 ClusterMember struct {
	ID         uint64   `json:"id"`
	Name       string   `json:"name"`
	PeerURLs   []string `json:"peer_urls"`
	ClientURLs []string `json:"client_urls"`
	IsLearner  bool     `json:"is_learner"`
}

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 NewClusterUsecase(logger log.Logger, clis []*cluster.Client, c *conf.Bootstrap) *ClusterUsecase

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) GetValue

func (r *ClusterUsecase) GetValue(ctx context.Context, cluster string, key string) string

func (*ClusterUsecase) Keys

func (r *ClusterUsecase) Keys(ctx context.Context, clusterName string) map[string][]string

func (*ClusterUsecase) Ping

func (r *ClusterUsecase) Ping(_ context.Context) error

type CrontabUsecase

type CrontabUsecase struct{}

func NewCrontabUsecase

func NewCrontabUsecase() *CrontabUsecase

type KVUsecase

type KVUsecase struct {
}

type Microservice

type Microservice struct {
	Key       string            `json:"key"`
	ID        string            `json:"id"`
	Name      string            `json:"name"`
	Version   string            `json:"version"`
	Metadata  map[string]string `json:"metadata"`
	Endpoints []string          `json:"endpoints"`
	CreatedAt int64             `json:"created_at"`
}