code: func (c *Client) CreateRP(ctx context.Context, db string, rp *chronograf.RetentionPolicy) (*chronograf.RetentionPolicy, error) {
  	query := fmt.Sprintf(`CREATE RETENTION POLICY "%s" ON "%s" DURATION %s REPLICATION %d`, rp.Name, db, rp.Duration, rp.Replication)
  	if len(rp.ShardDuration) != 0 {
  		query = fmt.Sprintf(`%s SHARD DURATION %s`, query, rp.ShardDuration)
  	}
  
  	if rp.Default {
  		query = fmt.Sprintf(`%s DEFAULT`, query)
  	}
  
  	_, err := c.Query(ctx, chronograf.Query{
  		Command: query,
  		DB:      db,
  	})
  	if err != nil {
  		return nil, err
  	}
  
  	res, err := c.getRP(ctx, db, rp.Name)
  	if err != nil {
  		return nil, err
  	}
  
  	return &res, nil
  }
docs: // CreateRP creates a retention policy for a specific database