Method TestPoolList

service/client_test.go:50–68

()

}

func (c *testClient) TestPoolList() []pools.Config {
	r, err := c.Query(c.Context(), srcfiles.Plain("from :pools"))
	require.NoError(c, err)
	defer r.Body.Close()
	var confs []pools.Config
	zr := bsupio.NewReader(super.NewContext(), r.Body)
	defer zr.Close()
	for {
		rec, err := zr.Read()
		require.NoError(c, err)
		if rec == nil {
			return confs
		}
		var pool pools.Config
		err = sup.UnmarshalBSUP(*rec, &pool)
		require.NoError(c, err)
		confs = append(confs, pool)
	}
}

func (c *testClient) TestPoolPost(payload api.PoolPostRequest) ksuid.KSUID {
	r, err := c.Connection.CreatePool(c.Context(), payload)