Method ExportAll

module/upstream/iml.go:37–64

(ctx context.Context)

}

func (i *imlUpstreamModule) ExportAll(ctx context.Context) ([]*upstream_dto.ExportUpstream, error) {
	latestCommits, err := i.upstreamService.ListLatestCommit(ctx, cluster.DefaultClusterID)
	if err != nil {
		return nil, err
	}
	commitMap := utils.SliceToMap(latestCommits, func(c *commit.Commit[upstream.Config]) string {
		return c.Target
	})
	list, err := i.upstreamService.List(ctx)
	if err != nil {
		return nil, err
	}
	items := make([]*upstream_dto.ExportUpstream, 0, len(list))
	for _, u := range list {
		c, ok := commitMap[u.UUID]
		if !ok {
			continue
		}

		items = append(items, &upstream_dto.ExportUpstream{
			ID:       u.UUID,
			Name:     u.Name,
			Service:  u.Service,
			Upstream: upstream_dto.FromClusterConfig(c.Data),
		})
	}
	return items, nil
}

func (i *imlUpstreamModule) Get(ctx context.Context, pid string) (upstream_dto.UpstreamConfig, error) {
	_, err := i.serviceService.Check(ctx, pid, asServer)