Method GetClusterList

pkg/client/client.go:147–172

(fn func(*metapb.Cluster) bool)

}

func (c *client) GetClusterList(fn func(*metapb.Cluster) bool) error {
	meta, err := c.getMetaClient()
	if err != nil {
		return err
	}

	stream, err := meta.GetClusterList(context.Background(), &rpcpb.GetClusterListReq{}, grpc.FailFast(true))
	if err != nil {
		return err
	}

	for {
		c, err := stream.Recv()
		if err == io.EOF {
			return nil
		}
		if err != nil {
			return err
		}

		next := fn(c)
		if !next {
			return nil
		}
	}
}

func (c *client) putServer(server metapb.Server) (uint64, error) {
	meta, err := c.getMetaClient()