proxystore

s := New()

endpoint := func(ip string, ready bool) *globalv1.EndpointInfo {
	return &globalv1.EndpointInfo{
		Namespace:   "default",
		SourceName:  "svc0",
		ServiceName: "svc0",
		Conditions: &globalv1.EndpointConditions{
			Ready: ready,
		},
		Endpoint: &localv1.Endpoint{
			IPs: &localv1.IPSet{V4: []string{ip}},
		},
	}
}

for _, twoReady := range []bool{true, false} {
	s.Update(func(tx *Tx) {
		tx.SetService(&localv1.Service{
			Namespace: "default",
			Name:      "svc0",
		})

		tx.SetEndpointsOfSource("default", "svc0", []*globalv1.EndpointInfo{
			endpoint("10.0.0.1", false),
			endpoint("10.0.0.2", twoReady),
		})
	})

	fmt.Println("two ready:", twoReady)
	infos := make([]*globalv1.EndpointInfo, 0)
	s.View(0, func(tx *Tx) {
		tx.EachEndpointOfService("default", "svc0", func(info *globalv1.EndpointInfo) {
			infos = append(infos, info)
		})
	})

	sort.Slice(infos, func(i, j int) bool { return infos[i].Endpoint.String() < infos[j].Endpoint.String() })

	for _, info := range infos {
		fmt.Println("-", info.Endpoint, "[", info.Conditions, "]")
	}
}

Output:

two ready: true
- IPs:{V4:"10.0.0.1"} [  ]
- IPs:{V4:"10.0.0.2"} [ Ready:true ]
two ready: false
- IPs:{V4:"10.0.0.1"} [  ]
- IPs:{V4:"10.0.0.2"} [  ]